package com.whyc.service;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.github.pagehelper.PageHelper;
|
import com.github.pagehelper.PageInfo;
|
import com.whyc.dto.Response;
|
import com.whyc.mapper.BattSpareMapper;
|
import com.whyc.mapper.BattSpareRecordMapper;
|
import com.whyc.pojo.BattSpare;
|
import com.whyc.pojo.BattSpareRecord;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.text.CollationElementIterator;
|
import java.util.Date;
|
import java.util.List;
|
|
@Service
|
public class BattSpareService {
|
@Resource
|
private BattSpareMapper mapper;
|
@Resource
|
private BattSpareRecordMapper recordMapper;
|
|
public Response searchByCondition(int pageNum, int pageSize, BattSpare spare){
|
PageHelper.startPage(pageNum,pageSize);
|
List<BattSpare> list = mapper.searchByCondition(spare);
|
PageInfo<BattSpare> pageInfo = new PageInfo<>(list);
|
return new Response().set(1,pageInfo,"查询成功");
|
}
|
|
public Response add(BattSpare spare){
|
mapper.insertId(spare);
|
int lastId = spare.getNum();
|
if (lastId>0){
|
BattSpareRecord record = new BattSpareRecord();
|
record.setOperationType(0);
|
record.setOperationTime(new Date());
|
record.setOperationNum(spare.getMonCount());
|
record.setSpareNum(spare.getMonCount());
|
record.setSpareId(lastId);
|
recordMapper.insert(record);
|
return new Response().set(1,true,"添加成功");
|
}else {
|
return new Response().set(1,false,"添加失败");
|
}
|
|
}
|
|
public Response spareInOrOut(BattSpareRecord record){
|
//更新备件库表数量
|
BattSpare spare = mapper.selectById(record.getSpareId());
|
spare.setBattspareTime(record.getOperationTime());
|
int monCount = spare.getMonCount()+(record.getOperationType()*record.getOperationNum());
|
spare.setMonCount(monCount);
|
if(mapper.updateById(spare)>0){
|
record.setSpareNum(spare.getMonCount());
|
record.setOperationTime(new Date());
|
recordMapper.insert(record);
|
}
|
return new Response().set(1,true,"更新成功");
|
}
|
|
public Response getSpareRecord(Integer spareId){
|
QueryWrapper<BattSpareRecord> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq("spare_id",spareId);
|
queryWrapper.orderByDesc("operation_time");
|
List<BattSpareRecord> list = recordMapper.selectList(queryWrapper);
|
for (BattSpareRecord record:list) {
|
int operationType = record.getOperationType();
|
switch (operationType){
|
case -1:
|
record.setEventInfo("执行了备件出库操作,出库数量为:"+record.getOperationNum()+",备件库存数为:"+record.getSpareNum());
|
break;
|
case 1:
|
record.setEventInfo("执行了备件入库操作,入库数量为:"+record.getOperationNum()+",备件库存数为:"+record.getSpareNum());
|
break;
|
case 0:
|
record.setEventInfo("新创建了电池备件,并执行入库,入库数量为:"+record.getOperationNum()+",备件库存数为:"+record.getSpareNum());
|
break;
|
}
|
}
|
return new Response().set(1,list,"查询成功");
|
}
|
|
|
|
}
|
