提交 73cd4ede authored 作者: 邓砥奕's avatar 邓砥奕

更新

上级 acf3b060
...@@ -346,6 +346,12 @@ public class BackController { ...@@ -346,6 +346,12 @@ public class BackController {
ids.forEach(integer -> { ids.forEach(integer -> {
DeviceLogDto deviceLogDto = new DeviceLogDto(integer, "上传退回单", fileVoList); DeviceLogDto deviceLogDto = new DeviceLogDto(integer, "上传退回单", fileVoList);
deviceLogService.addLog(deviceLogDto); deviceLogService.addLog(deviceLogDto);
DeviceLibrary deviceLibrary = deviceLibraryService.getOne(integer);
deviceLibrary.setLocationUnit(allotBackBill.getReceiveUnit());
deviceLibrary.setLifeStatus(2);
deviceLibrary.setOwnUnit(allotBackBill.getReceiveUnit());
deviceLibrary.setManageStatus(1);
deviceLibraryService.update(deviceLibrary);
}); });
if (idList.size()>0) { if (idList.size()>0) {
MessageBto messageBto = new MessageBto(taskBto.getId(), taskBto.getBusinessType(), "被选为经办人", idList, 1); MessageBto messageBto = new MessageBto(taskBto.getId(), taskBto.getBusinessType(), "被选为经办人", idList, 1);
......
...@@ -60,4 +60,7 @@ public class DeviceChange { ...@@ -60,4 +60,7 @@ public class DeviceChange {
@ApiModelProperty(value = "区块链记录id") @ApiModelProperty(value = "区块链记录id")
private String recordId; private String recordId;
@Column(name = "change_files",columnDefinition = "TEXT")
private String changeFiles;
} }
...@@ -34,4 +34,5 @@ public class DeviceEditVo { ...@@ -34,4 +34,5 @@ public class DeviceEditVo {
@Min(value = 1,message = "id不能小于1") @Min(value = 1,message = "id不能小于1")
@ApiModelProperty(value = "换新维修详情id", example = "1") @ApiModelProperty(value = "换新维修详情id", example = "1")
private Integer id; private Integer id;
} }
...@@ -36,12 +36,15 @@ public class ScriptSaveVo { ...@@ -36,12 +36,15 @@ public class ScriptSaveVo {
@ApiModelProperty(value = "数量") @ApiModelProperty(value = "数量")
private Integer num; private Integer num;
@ApiModelProperty(value = "列装Id") @ApiModelProperty(value = "列装Id/维修装备Id")
private Integer id; private Integer id;
@ApiModelProperty(value = "备注") @ApiModelProperty(value = "备注")
private String remark; private String remark;
@ApiModelProperty(value = "维修记录Id")
private Integer detailId;
public String toJson(){ public String toJson(){
return JacksonUtil.toJSon(this); return JacksonUtil.toJSon(this);
} }
......
...@@ -194,7 +194,7 @@ public enum StatusEnum { ...@@ -194,7 +194,7 @@ public enum StatusEnum {
/** /**
* 待盖章出库 * 待盖章出库
*/ */
WAIT_SIGN(341,"待盖章出库"), WAIT_SIGN(341,"等待盖章"),
/** /**
* 待自查 * 待自查
...@@ -237,22 +237,22 @@ public enum StatusEnum { ...@@ -237,22 +237,22 @@ public enum StatusEnum {
WAIT_RECEIVE(701, "等待接收维修装备"), WAIT_RECEIVE(701, "等待接收维修装备"),
REPAIR_RECEIVE_CONFIRM(702, "接收维修装备待审核"), REPAIR_RECEIVE_CONFIRM(702, "接收维修装备待审核"),
REPAIRING(703, "维修中"), REPAIRING(703, "维修中"),
WAIT_UPLOAD_FILE(704, "等待上传送修单"), WAIT_UPLOAD_FILE(704, "等待上传签收单"),
WAIT_UPLOAD_SEND_FILE(722, "等待上传送修单"), WAIT_UPLOAD_SEND_FILE(722, "等待上传回执单"),
COUNTRY_REPAIRING(777, "等待接收维修退回装备"), COUNTRY_REPAIRING(777, "等待接收维修退回装备"),
REPAIR_SEND_DRAFT(788,"草稿"), REPAIR_SEND_DRAFT(788,"草稿"),
REPAIR_SEND_SIGN_WAIT_CONFIRM(790,"申请签章待审核"), REPAIR_SEND_SIGN_WAIT_CONFIRM(790,"申请签章待审核"),
REPAIR_SEND_WAIT_SIGN(791,"待盖章出库"), REPAIR_SEND_WAIT_SIGN(791,"等待盖章"),
/** /**
* 维修完成退回状态 * 维修完成退回状态
*/ */
REPAIR_BACK_CONFIRM(800, "维修退回装备出库待审核"), REPAIR_BACK_CONFIRM(800, "维修退回装备出库待审核"),
WAIT_BACK_RECEIVE(801, "等待接收维修退回装备"), WAIT_BACK_RECEIVE(801, "等待接收维修退回装备"),
REPAIR_BACK_RECEIVE_CONFIRM(802, "接收维修退回装备待审核"), REPAIR_BACK_RECEIVE_CONFIRM(802, "接收维修退回装备待审核"),
WAIT_UPLOAD_BACK_FILE(804, "等待上传回执单"), WAIT_UPLOAD_BACK_FILE(804, "等待上传签收单"),
WAIT_UPLOAD_BACK_SEND_FILE(810, "等待上传领取单"), WAIT_UPLOAD_BACK_SEND_FILE(810, "等待上传回执单"),
REPAIR_BACK_SIGN_WAIT_CONFIRM(820,"申请签章待审核"), REPAIR_BACK_SIGN_WAIT_CONFIRM(820,"申请签章待审核"),
REPAIR_BACK_WAIT_SIGN(821,"待盖章出库"), REPAIR_BACK_WAIT_SIGN(821,"等待盖章"),
REPAIR_BACK_DRAFT(888,"草稿"), REPAIR_BACK_DRAFT(888,"草稿"),
/** /**
...@@ -264,7 +264,7 @@ public enum StatusEnum { ...@@ -264,7 +264,7 @@ public enum StatusEnum {
WAIT_UPLOAD_BACK_FILE_2(911, "待上传退回单"), WAIT_UPLOAD_BACK_FILE_2(911, "待上传退回单"),
BACK_DRAFT(922,"草稿"), BACK_DRAFT(922,"草稿"),
BACK_SIGN_WAIT_CONFIRM(930,"申请签章待审核"), BACK_SIGN_WAIT_CONFIRM(930,"申请签章待审核"),
BACK_WAIT_SIGN(931,"待盖章出库"), BACK_WAIT_SIGN(931,"等待盖章"),
/** /**
* 报废状态 * 报废状态
......
...@@ -398,12 +398,12 @@ public class PackingController { ...@@ -398,12 +398,12 @@ public class PackingController {
map.put("error","型号"+packingModelEdit.getModel()+"已存在"); map.put("error","型号"+packingModelEdit.getModel()+"已存在");
return ResponseEntity.ok(map); return ResponseEntity.ok(map);
} }
BeanUtils.copyProperties(packingModelEdit,packingLibrary);
if (packingModelEdit.getModel()!=null&&!packingModelEdit.getModel().equals(packingLibrary.getModel())){ if (packingModelEdit.getModel()!=null&&!packingModelEdit.getModel().equals(packingLibrary.getModel())){
packingLibrary.setModel(packingModelEdit.getModel()); packingLibrary.setModel(packingModelEdit.getModel());
packingLibrary.setName(packingModelEdit.getModel()); packingLibrary.setName(packingModelEdit.getModel());
packingLibraryService.changeAllModel(packingLibrary.getId(),packingModelEdit.getModel()); packingLibraryService.changeAllModel(packingLibrary.getId(),packingModelEdit.getModel());
} }
BeanUtils.copyProperties(packingModelEdit,packingLibrary);
packingLibraryService.update(packingLibrary); packingLibraryService.update(packingLibrary);
//发送阅知信息 //发送阅知信息
List<Integer> userIds = userPublicService.findOtherUser(userUtils.getCurrentUserId()); List<Integer> userIds = userPublicService.findOtherUser(userUtils.getCurrentUserId());
...@@ -420,6 +420,9 @@ public class PackingController { ...@@ -420,6 +420,9 @@ public class PackingController {
@PostMapping("/update/device") @PostMapping("/update/device")
public ResponseEntity updateDevice(@RequestBody @Validated PackingLibraryUpdateVo packingLibraryUpdateVo){ public ResponseEntity updateDevice(@RequestBody @Validated PackingLibraryUpdateVo packingLibraryUpdateVo){
PackingLibrary packingLibrary = packingLibraryService.getOne(packingLibraryUpdateVo.getPackingId()); PackingLibrary packingLibrary = packingLibraryService.getOne(packingLibraryUpdateVo.getPackingId());
if (!packingLibraryUpdateVo.getMatchingRange().equals(packingLibrary.getMatchingRange())&&packingLibraryService.matchingRangeIsExist(packingLibrary.getPartParentId(),packingLibraryUpdateVo.getMatchingRange())){
throw new ApiException("该型号下已存在配用范围为"+configCache.getMatchingRangeMap().get(packingLibraryUpdateVo.getMatchingRange())+"的装备");
}
//复制相同的字段 //复制相同的字段
if (packingLibraryUpdateVo.getName()!=null&&!packingLibraryUpdateVo.getName().equals(packingLibrary.getName())&&!packingLibraryService.nameIsExist(packingLibrary.getModel(),packingLibraryUpdateVo.getName())){ if (packingLibraryUpdateVo.getName()!=null&&!packingLibraryUpdateVo.getName().equals(packingLibrary.getName())&&!packingLibraryService.nameIsExist(packingLibrary.getModel(),packingLibraryUpdateVo.getName())){
//添加列装日志 //添加列装日志
......
...@@ -21,7 +21,7 @@ public interface PackingLibraryDao extends JpaRepository<PackingLibrary, Integer ...@@ -21,7 +21,7 @@ public interface PackingLibraryDao extends JpaRepository<PackingLibrary, Integer
List<PackingLibrary> findAllByIsRootAndPackingStatus(Integer isRoot,Integer packingStatus); List<PackingLibrary> findAllByIsRootAndPackingStatus(Integer isRoot,Integer packingStatus);
List<PackingLibrary> findAllByPartParentIdAndMatchingRange(Integer partParentId,Integer matchingRange); List<PackingLibrary> findAllByPartParentIdAndMatchingRangeAndPackingStatus(Integer partParentId,Integer matchingRange,Integer packingStatus);
List<PackingLibrary> findAllByDeleteTag(Integer deleteTag); List<PackingLibrary> findAllByDeleteTag(Integer deleteTag);
} }
...@@ -576,7 +576,7 @@ public class PackingLibraryServiceImpl implements PackingLibraryService { ...@@ -576,7 +576,7 @@ public class PackingLibraryServiceImpl implements PackingLibraryService {
*/ */
@Override @Override
public PackingLibrary findSamePacking(Integer parentId,Integer matchingRange) { public PackingLibrary findSamePacking(Integer parentId,Integer matchingRange) {
List<PackingLibrary> packingLibraries = packingLibraryDao.findAllByPartParentIdAndMatchingRange(parentId,matchingRange); List<PackingLibrary> packingLibraries = packingLibraryDao.findAllByPartParentIdAndMatchingRangeAndPackingStatus(parentId,matchingRange,2);
if (packingLibraries.isEmpty()){ if (packingLibraries.isEmpty()){
return null; return null;
} }
......
...@@ -11,7 +11,6 @@ import com.tykj.dev.device.library.service.DeviceLogService; ...@@ -11,7 +11,6 @@ import com.tykj.dev.device.library.service.DeviceLogService;
import com.tykj.dev.device.library.subject.Dto.DeviceLogDto; import com.tykj.dev.device.library.subject.Dto.DeviceLogDto;
import com.tykj.dev.device.library.subject.domin.DeviceChange; import com.tykj.dev.device.library.subject.domin.DeviceChange;
import com.tykj.dev.device.library.subject.domin.DeviceLibrary; import com.tykj.dev.device.library.subject.domin.DeviceLibrary;
import com.tykj.dev.device.library.subject.vo.DeviceEditVo;
import com.tykj.dev.device.library.subject.vo.DeviceLibraryUpdateVo; import com.tykj.dev.device.library.subject.vo.DeviceLibraryUpdateVo;
import com.tykj.dev.device.library.subject.vo.FileVo; import com.tykj.dev.device.library.subject.vo.FileVo;
import com.tykj.dev.device.library.subject.vo.ScriptSaveVo; import com.tykj.dev.device.library.subject.vo.ScriptSaveVo;
...@@ -34,6 +33,7 @@ import com.tykj.dev.device.task.subject.bto.TaskLogBto; ...@@ -34,6 +33,7 @@ import com.tykj.dev.device.task.subject.bto.TaskLogBto;
import com.tykj.dev.device.user.read.service.MessageService; import com.tykj.dev.device.user.read.service.MessageService;
import com.tykj.dev.device.user.read.subject.bto.MessageBto; import com.tykj.dev.device.user.read.subject.bto.MessageBto;
import com.tykj.dev.device.user.subject.dao.UserDao; import com.tykj.dev.device.user.subject.dao.UserDao;
import com.tykj.dev.device.user.subject.entity.Units;
import com.tykj.dev.device.user.subject.entity.User; import com.tykj.dev.device.user.subject.entity.User;
import com.tykj.dev.device.user.subject.service.UnitsService; import com.tykj.dev.device.user.subject.service.UnitsService;
import com.tykj.dev.device.user.subject.service.UserPublicService; import com.tykj.dev.device.user.subject.service.UserPublicService;
...@@ -280,20 +280,20 @@ public class RepairController { ...@@ -280,20 +280,20 @@ public class RepairController {
RepairSendBill deviceRepairSendBillEntity1 = new RepairSendBill(); RepairSendBill deviceRepairSendBillEntity1 = new RepairSendBill();
BeanUtils.copyProperties(repairBillSaveVo, repairBill1); BeanUtils.copyProperties(repairBillSaveVo, repairBill1);
BeanUtils.copyProperties(repairBillSaveVo, deviceRepairSendBillEntity1); BeanUtils.copyProperties(repairBillSaveVo, deviceRepairSendBillEntity1);
if (repairBillSaveVo.getScriptSaveVos() != null) {
deviceRepairSendBillEntity1.setScriptJson(JacksonUtil.toJSon(repairBillSaveVo.getScriptSaveVos()));
}
//如果当前为省向国家发起的
if (level == 1) {
repairBill1.setRepairStatus(4);
deviceRepairSendBillEntity1.setRepairStatus(5);
} else {
repairBill1.setRepairStatus(2);
deviceRepairSendBillEntity1.setRepairStatus(2);
}
repairBill = deviceRepairBillService.addEntity(repairBill1); repairBill = deviceRepairBillService.addEntity(repairBill1);
deviceRepairSendBillEntity = deviceRepairSendBillService.addEntity(deviceRepairSendBillEntity1); deviceRepairSendBillEntity = deviceRepairSendBillService.addEntity(deviceRepairSendBillEntity1);
} }
if (repairBillSaveVo.getScriptSaveVos() != null) {
deviceRepairSendBillEntity.setScriptJson(JacksonUtil.toJSon(repairBillSaveVo.getScriptSaveVos()));
}
//如果当前为省向国家发起的
if (level == 1) {
repairBill.setRepairStatus(4);
deviceRepairSendBillEntity.setRepairStatus(5);
} else {
repairBill.setRepairStatus(2);
deviceRepairSendBillEntity.setRepairStatus(2);
}
if (repairBillSaveVo.getRepairUseraId() != null) { if (repairBillSaveVo.getRepairUseraId() != null) {
repairBill.setRepairUserA(userPublicService.getOne(repairBillSaveVo.getRepairUseraId()).getName()); repairBill.setRepairUserA(userPublicService.getOne(repairBillSaveVo.getRepairUseraId()).getName());
} }
...@@ -319,13 +319,16 @@ public class RepairController { ...@@ -319,13 +319,16 @@ public class RepairController {
StringBuffer stringBuffer = new StringBuffer(); StringBuffer stringBuffer = new StringBuffer();
//存维修详情单 //存维修详情单
for (DeviceDetailVo d : repairBillSaveVo.getDeviceList()) { for (DeviceDetailVo d : repairBillSaveVo.getDeviceList()) {
RepairDetail oldRepairDetail = deviceRepairDetailService.getOne(d.getId()); RepairDetail oldRepairDetail = null;
if (d.getId()!=null) {
oldRepairDetail =deviceRepairDetailService.getOne(d.getId());
}
stringBuffer.append(d.getDeviceId()); stringBuffer.append(d.getDeviceId());
stringBuffer.append("Ǵ"); stringBuffer.append("Ǵ");
stringBuffer.append(d.getRemark()); stringBuffer.append(d.getRemark());
stringBuffer.append("Ǵ"); stringBuffer.append("Ǵ");
DeviceLibrary deviceLibraryEntity = deviceLibraryService.getOne(d.getDeviceId()); DeviceLibrary deviceLibraryEntity = deviceLibraryService.getOne(d.getDeviceId());
if (oldRepairDetail.getDeviceRepairBillId()==0) { if (oldRepairDetail!=null&&oldRepairDetail.getDeviceRepairBillId()==0) {
oldRepairDetail.setRemark(d.getRemark()); oldRepairDetail.setRemark(d.getRemark());
oldRepairDetail.setDeviceRepairBillId(repairBill1.getId()); oldRepairDetail.setDeviceRepairBillId(repairBill1.getId());
oldRepairDetail.setRepairStatus(0); oldRepairDetail.setRepairStatus(0);
...@@ -376,12 +379,26 @@ public class RepairController { ...@@ -376,12 +379,26 @@ public class RepairController {
List<Integer> ids = userPublicService.findOtherUser(userUtils.getCurrentUserId()); List<Integer> ids = userPublicService.findOtherUser(userUtils.getCurrentUserId());
if (level == 1) { if (level == 1) {
ownUnit = userUtils.getCurrentUnitId(); ownUnit = userUtils.getCurrentUnitId();
TaskBto taskBto = new TaskBto(StatusEnum.WAIT_UPLOAD_FILE.id, "维修业务", null, ".", repairBill1.getId(), 5, ownUnit, 1, "country", userIds); if (repairBillSaveVo.getTaskId()==null) {
saveEntity = taskService.start(taskBto); TaskBto taskBto = new TaskBto(StatusEnum.WAIT_UPLOAD_FILE.id, "维修业务", null, ".", repairBill1.getId(), 5, ownUnit, 1, "country", userIds);
saveEntity = taskService.start(taskBto);
}
else {
TaskBto taskBto1 = taskService.get(repairBillSaveVo.getTaskId());
taskBto1.setCustomInfo("country");
saveEntity = taskService.moveToSpecial(taskBto1,StatusEnum.WAIT_UPLOAD_FILE);
}
} else { } else {
ownUnit = userPublicService.findUnitIdByName(repairBill.getReceiveUnit()); ownUnit = userPublicService.findUnitIdByName(repairBill.getReceiveUnit());
TaskBto taskBto = new TaskBto(StatusEnum.WAIT_RECEIVE.id, "维修业务", null, ".", repairBill1.getId(), 5, ownUnit, 1, null, userIds); if (repairBillSaveVo.getTaskId()==null) {
saveEntity = taskService.start(taskBto); TaskBto taskBto = new TaskBto(StatusEnum.WAIT_RECEIVE.id, "维修业务", null, ".", repairBill1.getId(), 5, ownUnit, 1, null, userIds);
saveEntity = taskService.start(taskBto);
}
else {
TaskBto taskBto1 = taskService.get(repairBillSaveVo.getTaskId());
taskBto1.setOwnUnit(ownUnit);
saveEntity = taskService.moveToSpecial(taskBto1,StatusEnum.WAIT_RECEIVE);
}
ids.addAll(userDao.findAllByUnitsId(userPublicService.findUnitIdByName(repairBill.getReceiveUnit())).stream() ids.addAll(userDao.findAllByUnitsId(userPublicService.findUnitIdByName(repairBill.getReceiveUnit())).stream()
.map(User::getUserId) .map(User::getUserId)
.collect(Collectors.toList())); .collect(Collectors.toList()));
...@@ -498,7 +515,8 @@ public class RepairController { ...@@ -498,7 +515,8 @@ public class RepairController {
//更新装备状态 //更新装备状态
DeviceLibrary deviceLibraryEntity = deviceLibraryService.getOne(id); DeviceLibrary deviceLibraryEntity = deviceLibraryService.getOne(id);
deviceLibraryEntity.setLifeStatus(4); deviceLibraryEntity.setLifeStatus(4);
deviceLibraryEntity.setLocationUnit(userUtils.getCurrentUserUnitName()); deviceLibraryEntity.setLocationUnit(repairBill.getReceiveUnit());
deviceLibraryEntity.setManageStatus(1);
//存装备日志 //存装备日志
DeviceLogDto deviceLogDto = new DeviceLogDto(id, "接收并发起入库", fileVoList); DeviceLogDto deviceLogDto = new DeviceLogDto(id, "接收并发起入库", fileVoList);
deviceLogService.addLog(deviceLogDto); deviceLogService.addLog(deviceLogDto);
...@@ -519,7 +537,7 @@ public class RepairController { ...@@ -519,7 +537,7 @@ public class RepairController {
} }
//改变维修详情装备所在单位为当前单位 //改变维修详情装备所在单位为当前单位
repairDetailEntities.forEach(repairDetail -> { repairDetailEntities.forEach(repairDetail -> {
repairDetail.setLocationUnit(userUtils.getCurrentUserUnitName()); repairDetail.setLocationUnit(repairBill.getReceiveUnit());
repairDetail.setRepairStatus(1); repairDetail.setRepairStatus(1);
deviceRepairDetailService.update(repairDetail); deviceRepairDetailService.update(repairDetail);
}); });
...@@ -556,6 +574,12 @@ public class RepairController { ...@@ -556,6 +574,12 @@ public class RepairController {
deviceRepairBillService.update(repairBill); deviceRepairBillService.update(repairBill);
deviceRepairSendBillService.update(repairSendBill); deviceRepairSendBillService.update(repairSendBill);
} }
if (taskBto.getBillStatus().equals(StatusEnum.WAIT_RECEIVE.id)) {
taskBto.setRemark("入库盖章");
}
else {
taskBto.setRemark("出库盖章");
}
taskService.moveToSpecial(taskBto,StatusEnum.REPAIR_SEND_SIGN_WAIT_CONFIRM,userId); taskService.moveToSpecial(taskBto,StatusEnum.REPAIR_SEND_SIGN_WAIT_CONFIRM,userId);
myWebSocket.sendMessage1(); myWebSocket.sendMessage1();
return ResponseEntity.ok("申请成功"); return ResponseEntity.ok("申请成功");
...@@ -717,8 +741,16 @@ public class RepairController { ...@@ -717,8 +741,16 @@ public class RepairController {
//获取当前维修业务,维修单 //获取当前维修业务,维修单
Integer userId = userUtils.getCurrentUserId(); Integer userId = userUtils.getCurrentUserId();
//生成维修退回单 //生成维修退回单
RepairBackBill repairBackBill = new RepairBackBill(); RepairBackBill repairBackBill;
BeanUtils.copyProperties(repairBackBillSaveVo, repairBackBill); if (repairBackBillSaveVo.getTaskId()!=null){
repairBackBill = deviceRepairBackBillService.getOne(taskService.get(repairBackBillSaveVo.getTaskId()).getBillId());
MapperUtils.copyNoNullProperties(repairBackBillSaveVo,repairBackBill);
}
else {
RepairBackBill repairBackBill1 =new RepairBackBill();
BeanUtils.copyProperties(repairBackBillSaveVo, repairBackBill1);
repairBackBill = deviceRepairBackBillService.save(repairBackBill1);
}
repairBackBill.setBackStatus(2); repairBackBill.setBackStatus(2);
repairBackBill.setSendTime(new Date()); repairBackBill.setSendTime(new Date());
repairBackBill.setTitle("维修退回业务"); repairBackBill.setTitle("维修退回业务");
...@@ -732,7 +764,7 @@ public class RepairController { ...@@ -732,7 +764,7 @@ public class RepairController {
if (repairBackBillSaveVo.getScriptSaveVos()!=null){ if (repairBackBillSaveVo.getScriptSaveVos()!=null){
repairBackBill.setScriptJson(JacksonUtil.toJSon(repairBackBillSaveVo.getScriptSaveVos())); repairBackBill.setScriptJson(JacksonUtil.toJSon(repairBackBillSaveVo.getScriptSaveVos()));
} }
RepairBackBill deviceRepairBackBillEntity1 = deviceRepairBackBillService.save(repairBackBill); RepairBackBill deviceRepairBackBillEntity1 = deviceRepairBackBillService.update(repairBackBill);
Calendar calendar = Calendar.getInstance(); Calendar calendar = Calendar.getInstance();
String s1 = "NO:第" + calendar.get(Calendar.YEAR) + "LQ" + repairBackBill.getId() + "号"; String s1 = "NO:第" + calendar.get(Calendar.YEAR) + "LQ" + repairBackBill.getId() + "号";
deviceRepairBackBillEntity1.setDocNum(s1); deviceRepairBackBillEntity1.setDocNum(s1);
...@@ -741,8 +773,16 @@ public class RepairController { ...@@ -741,8 +773,16 @@ public class RepairController {
List<Integer> userIds = new ArrayList<>(); List<Integer> userIds = new ArrayList<>();
userIds.add(userId); userIds.add(userId);
userIds.add(0); userIds.add(0);
TaskBto taskBto1 = new TaskBto(StatusEnum.WAIT_BACK_RECEIVE.id, "维修退回", null, ".", deviceRepairBackBillEntity1.getId(), BusinessEnum.REPAIR_BACK.id,userPublicService.findUnitIdByName(repairBackBill.getReceiveUnit()), 1, null, userIds); TaskBto task;
TaskBto task = taskService.start(taskBto1); if (repairBackBillSaveVo.getTaskId()==null) {
TaskBto taskBto1 = new TaskBto(StatusEnum.WAIT_BACK_RECEIVE.id, "维修退回", null, ".", deviceRepairBackBillEntity1.getId(), BusinessEnum.REPAIR_BACK.id, userPublicService.findUnitIdByName(repairBackBill.getReceiveUnit()), 1, null, userIds);
task = taskService.start(taskBto1);
}
else {
TaskBto taskBto1 = taskService.get(repairBackBillSaveVo.getTaskId());
taskBto1.setOwnUnit(userPublicService.findUnitIdByName(repairBackBill.getReceiveUnit()));
task = taskService.moveToSpecial(taskBto1,StatusEnum.WAIT_BACK_RECEIVE);
}
TaskBto taskBto2 = new TaskBto(StatusEnum.WAIT_UPLOAD_BACK_SEND_FILE.id, "维修退回", task.getId(), task.getNodeIdDetail() + task.getId() + ".", task.getBillId(), BusinessEnum.REPAIR_BACK.id, userPublicService.findUnitIdByName(repairBackBill.getSendUnit()), 0, null, Collections.singletonList(0)); TaskBto taskBto2 = new TaskBto(StatusEnum.WAIT_UPLOAD_BACK_SEND_FILE.id, "维修退回", task.getId(), task.getNodeIdDetail() + task.getId() + ".", task.getBillId(), BusinessEnum.REPAIR_BACK.id, userPublicService.findUnitIdByName(repairBackBill.getSendUnit()), 0, null, Collections.singletonList(0));
taskService.start(taskBto2); taskService.start(taskBto2);
//添加业务日志 //添加业务日志
...@@ -788,10 +828,9 @@ public class RepairController { ...@@ -788,10 +828,9 @@ public class RepairController {
//获取当前任务 //获取当前任务
TaskBto taskBto; TaskBto taskBto;
Integer userId = userUtils.getCurrentUserId(); Integer userId = userUtils.getCurrentUserId();
Integer level = userUtils.getCurrentUnitLevel();
//获取退回单和装备id //获取退回单和装备id
RepairBackBill repairBackBill; RepairBackBill repairBackBill;
if (level == 2 || level == 3) { if (repairReceiveVo.getTaskId()!=null) {
taskBto = taskService.get(repairReceiveVo.getTaskId()); taskBto = taskService.get(repairReceiveVo.getTaskId());
TaskDisposeUtil.isNotSubmit(taskBto.getBillStatus(),StatusEnum.WAIT_BACK_RECEIVE); TaskDisposeUtil.isNotSubmit(taskBto.getBillStatus(),StatusEnum.WAIT_BACK_RECEIVE);
taskService.addInvolveUser(taskBto,userId); taskService.addInvolveUser(taskBto,userId);
...@@ -835,7 +874,7 @@ public class RepairController { ...@@ -835,7 +874,7 @@ public class RepairController {
RepairBackBill repairBackBill1 = deviceRepairBackBillService.update(repairBackBill); RepairBackBill repairBackBill1 = deviceRepairBackBillService.update(repairBackBill);
TaskBto taskBto2; TaskBto taskBto2;
Map<Integer,List<Integer>> messageMap = new HashMap<>(); Map<Integer,List<Integer>> messageMap = new HashMap<>();
if (level == 1) { if (repairReceiveVo.getTaskId()==null) {
List<Integer> userIds = new ArrayList<>(); List<Integer> userIds = new ArrayList<>();
if (repairReceiveVo.getStatus()==0) { if (repairReceiveVo.getStatus()==0) {
userIds.add(userId); userIds.add(userId);
...@@ -851,9 +890,11 @@ public class RepairController { ...@@ -851,9 +890,11 @@ public class RepairController {
RepairDetail repairDetail = deviceRepairDetailService.getOne(d.getId()); RepairDetail repairDetail = deviceRepairDetailService.getOne(d.getId());
repairDetail.setRepairBackBillId(repairBackBill1.getId()); repairDetail.setRepairBackBillId(repairBackBill1.getId());
repairDetail.setRepairStatus(5); repairDetail.setRepairStatus(5);
repairDetail.setLocationUnit(repairBackBill.getReceiveUnit());
if (repairDetail.getPid()!=null) { if (repairDetail.getPid()!=null) {
RepairDetail repairDetail1 = deviceRepairDetailService.getOne(repairDetail.getPid()); RepairDetail repairDetail1 = deviceRepairDetailService.getOne(repairDetail.getPid());
repairDetail1.setRepairStatus(2); repairDetail1.setRepairStatus(2);
repairDetail1.setLocationUnit(repairBackBill.getReceiveUnit());
deviceRepairDetailService.update(repairDetail1); deviceRepairDetailService.update(repairDetail1);
Integer unitId = userPublicService.getOne(repairDetail1.getCreateUserId()).getUnitsId(); Integer unitId = userPublicService.getOne(repairDetail1.getCreateUserId()).getUnitsId();
if (messageMap.get(unitId)==null) { if (messageMap.get(unitId)==null) {
...@@ -880,9 +921,11 @@ public class RepairController { ...@@ -880,9 +921,11 @@ public class RepairController {
List<RepairDetail> repairDetailList = repairDetailDao.findByRepairBackBillId(repairBackBill.getId()); List<RepairDetail> repairDetailList = repairDetailDao.findByRepairBackBillId(repairBackBill.getId());
repairDetailList.forEach(repairDetail -> { repairDetailList.forEach(repairDetail -> {
repairDetail.setRepairStatus(5); repairDetail.setRepairStatus(5);
repairDetail.setLocationUnit(repairBackBill.getReceiveUnit());
if (repairDetail.getPid()!=null) { if (repairDetail.getPid()!=null) {
RepairDetail repairDetail1 = deviceRepairDetailService.getOne(repairDetail.getPid()); RepairDetail repairDetail1 = deviceRepairDetailService.getOne(repairDetail.getPid());
repairDetail1.setRepairStatus(2); repairDetail1.setRepairStatus(2);
repairDetail1.setLocationUnit(repairBackBill.getReceiveUnit());
deviceRepairDetailService.update(repairDetail1); deviceRepairDetailService.update(repairDetail1);
Integer unitId = userPublicService.getOne(repairDetail1.getCreateUserId()).getUnitsId(); Integer unitId = userPublicService.getOne(repairDetail1.getCreateUserId()).getUnitsId();
if (messageMap.get(unitId)==null) { if (messageMap.get(unitId)==null) {
...@@ -905,11 +948,11 @@ public class RepairController { ...@@ -905,11 +948,11 @@ public class RepairController {
Integer id = Integer.parseInt(s.substring(0, s.length() - 1)); Integer id = Integer.parseInt(s.substring(0, s.length() - 1));
//更改装备状态 //更改装备状态
DeviceLibrary deviceLibraryEntity = deviceLibraryService.getOne(id); DeviceLibrary deviceLibraryEntity = deviceLibraryService.getOne(id);
Integer unitId = userPublicService.findUnitIdByName(deviceLibraryEntity.getOwnUnit()); deviceLibraryEntity.setLocationUnit(repairBackBill.getReceiveUnit());
deviceLibraryEntity.setLocationUnit(userUtils.getCurrentUserUnitName());
if (deviceLibraryEntity.getOwnUnit().equals(deviceLibraryEntity.getLocationUnit())) { if (deviceLibraryEntity.getOwnUnit().equals(deviceLibraryEntity.getLocationUnit())) {
deviceLibraryEntity.setLifeStatus(2); deviceLibraryEntity.setLifeStatus(2);
} }
deviceLibraryEntity.setManageStatus(1);
//添加装备日志 //添加装备日志
DeviceLogDto deviceLogDto = new DeviceLogDto(id, "维修退回装备接收并发起入库", fileVoList); DeviceLogDto deviceLogDto = new DeviceLogDto(id, "维修退回装备接收并发起入库", fileVoList);
deviceLogService.addLog(deviceLogDto); deviceLogService.addLog(deviceLogDto);
...@@ -930,7 +973,7 @@ public class RepairController { ...@@ -930,7 +973,7 @@ public class RepairController {
} }
//发送阅知信息 //发送阅知信息
List<Integer> ids = userPublicService.findOtherUser(userUtils.getCurrentUserId()); List<Integer> ids = userPublicService.findOtherUser(userUtils.getCurrentUserId());
if (level>1) { if (repairReceiveVo.getTaskId()!=null) {
ids.addAll(userDao.findAllByUnitsId(userPublicService.findUnitIdByName(repairBackBill.getSendUnit())).stream() ids.addAll(userDao.findAllByUnitsId(userPublicService.findUnitIdByName(repairBackBill.getSendUnit())).stream()
.map(User::getUserId) .map(User::getUserId)
.collect(Collectors.toList())); .collect(Collectors.toList()));
...@@ -974,6 +1017,12 @@ public class RepairController { ...@@ -974,6 +1017,12 @@ public class RepairController {
repairBackBill.setReceiveUseraId(userUtils.getCurrentUserId()); repairBackBill.setReceiveUseraId(userUtils.getCurrentUserId());
deviceRepairBackBillService.update(repairBackBill); deviceRepairBackBillService.update(repairBackBill);
} }
if (taskBto.getBillStatus().equals(StatusEnum.WAIT_BACK_RECEIVE.id)) {
taskBto.setRemark("入库盖章");
}
else {
taskBto.setRemark("出库盖章");
}
taskService.moveToSpecial(taskBto,StatusEnum.REPAIR_BACK_SIGN_WAIT_CONFIRM,userId); taskService.moveToSpecial(taskBto,StatusEnum.REPAIR_BACK_SIGN_WAIT_CONFIRM,userId);
myWebSocket.sendMessage1(); myWebSocket.sendMessage1();
return ResponseEntity.ok("申请成功"); return ResponseEntity.ok("申请成功");
...@@ -1380,9 +1429,9 @@ public class RepairController { ...@@ -1380,9 +1429,9 @@ public class RepairController {
@ApiOperation(value = "查询维修管理列表", notes = "可以通过这个接口查询维修管理列表") @ApiOperation(value = "查询维修管理列表", notes = "可以通过这个接口查询维修管理列表")
@PostMapping(value = "/repairList") @PostMapping(value = "/repairList")
public ResponseEntity getRepairList(@RequestBody RepairTaskSelectVo repairTaskSelectVo) { public ResponseEntity getRepairList(@RequestBody RepairTaskSelectVo repairTaskSelectVo) {
Map<Integer,DeviceLibrary> deviceLibraryMap = deviceLibraryService.getAllDeviceMap(); // Map<Integer,DeviceLibrary> deviceLibraryMap = deviceLibraryService.getAllDeviceMap();
Integer type = repairTaskSelectVo.getType(); Integer type = repairTaskSelectVo.getType();
Integer userId = userUtils.getCurrentUserId(); // Integer userId = userUtils.getCurrentUserId();
String unitName = userUtils.getCurrentUserUnitName(); String unitName = userUtils.getCurrentUserUnitName();
//待维修装备 //待维修装备
if (type==1){ if (type==1){
...@@ -1391,7 +1440,7 @@ public class RepairController { ...@@ -1391,7 +1440,7 @@ public class RepairController {
integerList.add(9); integerList.add(9);
List<RepairDetail> repairDetails = repairDetailDao.findAllByRepairStatusIn(integerList,repairTaskSelectVo.getPageable().getSort()); List<RepairDetail> repairDetails = repairDetailDao.findAllByRepairStatusIn(integerList,repairTaskSelectVo.getPageable().getSort());
repairDetails.forEach(repairDetail -> { repairDetails.forEach(repairDetail -> {
repairDetail.setLocationUnit(deviceLibraryMap.get(repairDetail.getDeviceId()).getLocationUnit()); // repairDetail.setLocationUnit(deviceLibraryMap.get(repairDetail.getDeviceId()).getLocationUnit());
repairDetail.setConfigName(); repairDetail.setConfigName();
}); });
List<RepairDetail> repairDetails1 = repairDetails.stream().filter(repairDetail -> repairDetail.getLocationUnit().equals(unitName)).collect(Collectors.toList()); List<RepairDetail> repairDetails1 = repairDetails.stream().filter(repairDetail -> repairDetail.getLocationUnit().equals(unitName)).collect(Collectors.toList());
...@@ -1402,9 +1451,10 @@ public class RepairController { ...@@ -1402,9 +1451,10 @@ public class RepairController {
List<Integer> integerList = new ArrayList<>(); List<Integer> integerList = new ArrayList<>();
integerList.add(5); integerList.add(5);
integerList.add(9); integerList.add(9);
integerList.add(4);
List<RepairDetail> repairDetails1 = repairDetailDao.findAllByRepairStatusNotIn(integerList,repairTaskSelectVo.getPageable().getSort()); List<RepairDetail> repairDetails1 = repairDetailDao.findAllByRepairStatusNotIn(integerList,repairTaskSelectVo.getPageable().getSort());
repairDetails1.forEach(repairDetail -> { repairDetails1.forEach(repairDetail -> {
repairDetail.setLocationUnit(deviceLibraryMap.get(repairDetail.getDeviceId()).getLocationUnit()); // repairDetail.setLocationUnit(deviceLibraryMap.get(repairDetail.getDeviceId()).getLocationUnit());
repairDetail.setConfigName(); repairDetail.setConfigName();
}); });
List<RepairDetail> repairDetails2 = repairDetails1.stream().filter(repairDetail -> userPublicService.findUnitsNameByUserId(repairDetail.getCreateUserId()).equals(unitName)).collect(Collectors.toList()); List<RepairDetail> repairDetails2 = repairDetails1.stream().filter(repairDetail -> userPublicService.findUnitsNameByUserId(repairDetail.getCreateUserId()).equals(unitName)).collect(Collectors.toList());
...@@ -1414,22 +1464,34 @@ public class RepairController { ...@@ -1414,22 +1464,34 @@ public class RepairController {
else if(type==3){ else if(type==3){
List<RepairDetail> repairDetails = repairDetailDao.findAllByRepairStatus(2,repairTaskSelectVo.getPageable().getSort()); List<RepairDetail> repairDetails = repairDetailDao.findAllByRepairStatus(2,repairTaskSelectVo.getPageable().getSort());
repairDetails.forEach(repairDetail -> { repairDetails.forEach(repairDetail -> {
repairDetail.setLocationUnit(deviceLibraryMap.get(repairDetail.getDeviceId()).getLocationUnit()); // repairDetail.setLocationUnit(deviceLibraryMap.get(repairDetail.getDeviceId()).getLocationUnit());
repairDetail.setConfigName(); repairDetail.setConfigName();
}); });
List<RepairDetail> repairDetails2 = repairDetails.stream().filter(repairDetail -> repairDetail.getLocationUnit().equals(unitName)).collect(Collectors.toList()); List<RepairDetail> repairDetails2 = repairDetails.stream().filter(repairDetail -> repairDetail.getLocationUnit().equals(unitName)).collect(Collectors.toList());
return ResponseEntity.ok(PageUtil.getPerPage(repairTaskSelectVo.getPage(),repairTaskSelectVo.getSize(),repairDetails2,repairTaskSelectVo.getPageable())); return ResponseEntity.ok(PageUtil.getPerPage(repairTaskSelectVo.getPage(),repairTaskSelectVo.getSize(),repairDetails2,repairTaskSelectVo.getPageable()));
} }
// else if(type==4){ else if(type==4){
// List<RepairDetail> repairDetails = repairDetailDao.findAllByRepairStatus(2,repairTaskSelectVo.getPageable().getSort()); Integer level = userUtils.getCurrentUnitLevel();
// repairDetails.forEach(repairDetail -> { List<RepairDetail> repairDetails;
// repairDetail.setLocationUnit(deviceLibraryMap.get(repairDetail.getDeviceId()).getLocationUnit()); if (level==1) {
// repairDetail.setConfigName(); repairDetails = repairDetailDao.findAllByRepairStatusIn(Arrays.asList(4, 5), repairTaskSelectVo.getPageable().getSort());
// }); }
// return ResponseEntity.ok(repairDetails.stream().filter(repairDetail -> repairDetail.getLocationUnit().equals(unitName)).collect(Collectors.toList())); else if (level==2) {
// } repairDetails = repairDetailDao.findAllByRepairStatus(5, repairTaskSelectVo.getPageable().getSort());
}
else {
throw new ApiException("区县没有维修完成列表");
}
repairDetails.forEach(repairDetail -> {
repairDetail.setConfigName();
});
List<String> units = unitsService.findListById(0).stream().map(Units::getName).collect(Collectors.toList());
units.addAll(unitsService.findBySubordinateNotOneself(userUtils.getCurrentUnitId()).stream().map(Units::getName).collect(Collectors.toList()));
List<RepairDetail> repairDetails2 = repairDetails.stream().filter(repairDetail -> units.contains(repairDetail.getLocationUnit())).collect(Collectors.toList());
return ResponseEntity.ok(PageUtil.getPerPage(repairTaskSelectVo.getPage(),repairTaskSelectVo.getSize(),repairDetails2,repairTaskSelectVo.getPageable()));
}
else { else {
throw new ApiException("type只能为1,2,3"); throw new ApiException("type只能为1,2,3,4");
} }
} }
...@@ -1475,33 +1537,92 @@ public class RepairController { ...@@ -1475,33 +1537,92 @@ public class RepairController {
@PostMapping(value = "/changeNew") @PostMapping(value = "/changeNew")
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public ResponseEntity change(@RequestBody DeviceEditVo deviceEditVo){ public ResponseEntity change(@RequestBody DeviceEditVo deviceEditVo){
RepairDetail repairDetail = deviceRepairDetailService.getOne(deviceEditVo.getId());
DeviceLibrary deviceLibraryEntity = deviceLibraryService.getOne(deviceEditVo.getDeviceId()); DeviceLibrary deviceLibraryEntity = deviceLibraryService.getOne(deviceEditVo.getDeviceId());
//创建新装备
DeviceLibrary newDevice = new DeviceLibrary();
BeanUtils.copyProperties(deviceLibraryEntity,newDevice);
newDevice.setId(null);
newDevice.setLocationUnit(userUtils.getCurrentUserUnitName());
if (newDevice.getOwnUnit().equals(newDevice.getLocationUnit())) {
newDevice.setLifeStatus(2);
}
DeviceLibrary deviceLibrary = deviceLibraryService.addEntity(newDevice);
//添加新的维修换新装备记录
RepairDetail newRepairDetail = new RepairDetail();
BeanUtils.copyProperties(repairDetail,newRepairDetail);
newRepairDetail.setId(null);
newRepairDetail.setDeviceId(deviceLibrary.getId());
newRepairDetail.setLocationUnit(userUtils.getCurrentUserUnitName());
newRepairDetail.setRepairStatus(5);
if (newRepairDetail.getPid()!=null) {
RepairDetail repairDetail1 = deviceRepairDetailService.getOne(repairDetail.getPid());
repairDetail1.setRepairStatus(2);
repairDetail1.setLocationUnit(userUtils.getCurrentUserUnitName());
deviceRepairDetailService.update(repairDetail1);
Integer unitId = userPublicService.getOne(repairDetail1.getCreateUserId()).getUnitsId();
List<Integer> integerList = new ArrayList<>();
integerList.addAll(userDao.findAllByUnitsId(unitId).stream()
.map(User::getUserId)
.collect(Collectors.toList()));
MessageBto messageBto2 = new MessageBto(0, 5, "待领取送修装备", integerList);
messageBto2.setRecord(String.valueOf(repairDetail1.getId()));
messageService.add(messageBto2);
}
//旧的维修记录改为已报废
repairDetail.setRepairStatus(4);
repairDetail.setLocationUnit(deviceLibraryEntity.getLocationUnit());
repairDetail.setOwnUnit(deviceLibraryEntity.getLocationUnit());
deviceRepairDetailService.update(repairDetail);
deviceLibraryEntity.setOwnUnit(deviceLibraryEntity.getLocationUnit());
deviceLibraryEntity.setLifeStatus(5);
deviceLibraryService.update(deviceLibraryEntity);
if (deviceEditVo.getUpdateVoList() != null) { if (deviceEditVo.getUpdateVoList() != null) {
DeviceLibraryUpdateVo libraryUpdateVo = deviceEditVo.getUpdateVoList(); DeviceLibraryUpdateVo libraryUpdateVo = deviceEditVo.getUpdateVoList();
if (libraryUpdateVo.getProdNumber() != null && !libraryUpdateVo.getProdNumber().equals(deviceLibraryEntity.getProdNumber())) { if (libraryUpdateVo.getProdNumber() != null && !libraryUpdateVo.getProdNumber().equals(deviceLibraryEntity.getProdNumber())) {
//添加装备日志 //添加装备日志
String remark = "装备换新:将装备生产序列号由" + deviceLibraryEntity.getProdNumber() + "为" + libraryUpdateVo.getProdNumber(); String remark = "装备换新:将装备生产序列号由" + deviceLibraryEntity.getProdNumber() + "为" + libraryUpdateVo.getProdNumber();
DeviceLogDto deviceLogDto = new DeviceLogDto(deviceEditVo.getDeviceId(), remark, null); DeviceLogDto deviceLogDto = new DeviceLogDto(deviceEditVo.getDeviceId(), remark, null);
deviceLogService.addLog(deviceLogDto); deviceLogService.addLog(deviceLogDto);
deviceLibraryEntity.setProdNumber(libraryUpdateVo.getProdNumber()); deviceLibrary.setProdNumber(libraryUpdateVo.getProdNumber());
} }
if (libraryUpdateVo.getSeqNumber() != null && !libraryUpdateVo.getSeqNumber().equals(deviceLibraryEntity.getSeqNumber())) { if (libraryUpdateVo.getSeqNumber() != null && !libraryUpdateVo.getSeqNumber().equals(deviceLibraryEntity.getSeqNumber())) {
if (deviceLibraryDao.getAllBySeqNumber(libraryUpdateVo.getSeqNumber()).size()>0){ if (deviceLibraryDao.getAllBySeqNumber(libraryUpdateVo.getSeqNumber()).size()>0){
throw new ApiException("序列号"+libraryUpdateVo.getSeqNumber()+"已存在"); throw new ApiException("序列号"+libraryUpdateVo.getSeqNumber()+"已存在");
} }
else { else {
String remark = "装备换新:将装备序列号由" + deviceLibraryEntity.getSeqNumber() + "为" + libraryUpdateVo.getSeqNumber(); String remark = "装备换新:将装备序列号由" + deviceLibraryEntity.getSeqNumber() + "为" + libraryUpdateVo.getSeqNumber();
DeviceLogDto deviceLogDto = new DeviceLogDto(deviceEditVo.getDeviceId(), remark, null); DeviceLogDto deviceLogDto = new DeviceLogDto(deviceEditVo.getDeviceId(), remark, null);
deviceLogService.addLog(deviceLogDto); deviceLogService.addLog(deviceLogDto);
deviceLibraryEntity.setSeqNumber(libraryUpdateVo.getSeqNumber()); deviceLibrary.setSeqNumber(libraryUpdateVo.getSeqNumber());
//改变维修详情的序列号 newRepairDetail.setSeqNumber(libraryUpdateVo.getSeqNumber());
repairDetailDao.findAllByDeviceId(deviceEditVo.getDeviceId()).forEach(repairDetail -> {
repairDetail.setSeqNumber(libraryUpdateVo.getSeqNumber());
deviceRepairDetailService.update(repairDetail);
});
} }
} }
} }
deviceLibraryService.update(deviceLibrary);
deviceRepairDetailService.save(newRepairDetail);
//修改所有父维修记录序列号
if (newRepairDetail.getPid()!=null){
RepairDetail repairDetail1 = deviceRepairDetailService.getOne(newRepairDetail.getPid());
repairDetail1.setSeqNumber(newRepairDetail.getSeqNumber());
repairDetail1.setDeviceId(newRepairDetail.getDeviceId());
repairDetail1.setLocationUnit(userUtils.getCurrentUserUnitName());
deviceRepairDetailService.update(repairDetail1);
if (repairDetail1.getPid() != null) {
RepairDetail repairDetail2 = deviceRepairDetailService.getOne(newRepairDetail.getPid());
repairDetail2.setSeqNumber(newRepairDetail.getSeqNumber());
repairDetail2.setDeviceId(newRepairDetail.getDeviceId());
repairDetail2.setLocationUnit(userUtils.getCurrentUserUnitName());
deviceRepairDetailService.update(repairDetail2);
}
}
DeviceChange deviceChange = new DeviceChange();
deviceChange.setNewDeviceId(deviceLibrary.getId());
deviceChange.setOldDeviceId(deviceLibraryEntity.getId());
if (deviceEditVo.getSendFiles()!=null&&deviceEditVo.getSendFiles().size()>0) {
deviceChange.setChangeFiles(FilesUtil.stringFileToList(deviceEditVo.getSendFiles()));
}
deviceChangeService.add(deviceChange);
return ResultUtil.success("更新成功"); return ResultUtil.success("更新成功");
} }
...@@ -1565,11 +1686,48 @@ public class RepairController { ...@@ -1565,11 +1686,48 @@ public class RepairController {
ids.forEach(integer -> { ids.forEach(integer -> {
DeviceLogDto deviceLogDto = new DeviceLogDto(integer, "上传领取单", fileVoList); DeviceLogDto deviceLogDto = new DeviceLogDto(integer, "上传领取单", fileVoList);
deviceLogService.addLog(deviceLogDto); deviceLogService.addLog(deviceLogDto);
DeviceLibrary deviceLibraryEntity = deviceLibraryService.getOne(integer);
deviceLibraryEntity.setLocationUnit(repairBackBill.getReceiveUnit());
deviceLibraryEntity.setLifeStatus(2);
deviceLibraryEntity.setManageStatus(1);
deviceLibraryService.update(deviceLibraryEntity);
});
//获取维修详情
List<RepairDetail> repairDetailList = repairDetailDao.findByRepairBackBillId(repairBackBill.getId());
Map<Integer,List<Integer>> messageMap = new HashMap<>();
repairDetailList.forEach(repairDetail -> {
repairDetail.setRepairStatus(5);
repairDetail.setLocationUnit(repairBackBill.getReceiveUnit());
if (repairDetail.getPid()!=null) {
RepairDetail repairDetail1 = deviceRepairDetailService.getOne(repairDetail.getPid());
repairDetail1.setRepairStatus(2);
repairDetail1.setLocationUnit(repairBackBill.getReceiveUnit());
deviceRepairDetailService.update(repairDetail1);
Integer unitId = userPublicService.getOne(repairDetail1.getCreateUserId()).getUnitsId();
if (messageMap.get(unitId)==null) {
messageMap.put(unitId, Collections.singletonList(repairDetail1.getId()));
}
else {
List<Integer> integers = new ArrayList<>(messageMap.getOrDefault(unitId, new ArrayList<>()));
integers.add(repairDetail1.getId());
messageMap.put(unitId,integers);
}
}
deviceRepairDetailService.update(repairDetail);
}); });
if (idList.size()>0) { if (idList.size()>0) {
MessageBto messageBto = new MessageBto(taskBto.getId(), taskBto.getBusinessType(), "被选为经办人", idList, 1); MessageBto messageBto = new MessageBto(taskBto.getId(), taskBto.getBusinessType(), "被选为经办人", idList, 1);
messageService.add(messageBto); messageService.add(messageBto);
} }
messageMap.keySet().forEach(integer -> {
List<Integer> integerList = new ArrayList<>();
integerList.addAll(userDao.findAllByUnitsId(integer).stream()
.map(User::getUserId)
.collect(Collectors.toList()));
MessageBto messageBto2 = new MessageBto(0, 5, "待领取送修装备", integerList);
messageBto2.setRecord(StringSplitUtil.idListToString(messageMap.get(integer)));
messageService.add(messageBto2);
});
} }
return ResponseEntity.ok("OK"); return ResponseEntity.ok("OK");
} }
...@@ -1591,6 +1749,7 @@ public class RepairController { ...@@ -1591,6 +1749,7 @@ public class RepairController {
else { else {
RepairBill repairBill = deviceRepairBillService.getOne(taskBto.getBillId()); RepairBill repairBill = deviceRepairBillService.getOne(taskBto.getBillId());
RepairSendBill repairSendBill = deviceRepairSendBillDao.findByDeviceRepairBillId(repairBill.getId()); RepairSendBill repairSendBill = deviceRepairSendBillDao.findByDeviceRepairBillId(repairBill.getId());
List<RepairDetail> repairDetailEntities = deviceRepairDetailService.findByBillId(repairBill.getId());
//保存账单 //保存账单
repairSendBill.setSendFiles(FilesUtil.stringFileToList(fileVo.getSendFiles())); repairSendBill.setSendFiles(FilesUtil.stringFileToList(fileVo.getSendFiles()));
List<Integer> idList = new ArrayList<>(); List<Integer> idList = new ArrayList<>();
...@@ -1630,9 +1789,20 @@ public class RepairController { ...@@ -1630,9 +1789,20 @@ public class RepairController {
List<FileVo> fileVoList = new ArrayList<>(); List<FileVo> fileVoList = new ArrayList<>();
fileVo.getSendFiles().forEach(fileRet -> fileVoList.add(new FileVo("维修单", fileRet.getName(), fileRet.getPreviewPath()))); fileVo.getSendFiles().forEach(fileRet -> fileVoList.add(new FileVo("维修单", fileRet.getName(), fileRet.getPreviewPath())));
ids.forEach(integer -> { ids.forEach(integer -> {
DeviceLibrary deviceLibraryEntity = deviceLibraryService.getOne(integer);
deviceLibraryEntity.setLifeStatus(4);
deviceLibraryEntity.setLocationUnit(repairBill.getReceiveUnit());
deviceLibraryEntity.setManageStatus(1);
deviceLibraryService.update(deviceLibraryEntity);
DeviceLogDto deviceLogDto = new DeviceLogDto(integer, "上传维修单", fileVoList); DeviceLogDto deviceLogDto = new DeviceLogDto(integer, "上传维修单", fileVoList);
deviceLogService.addLog(deviceLogDto); deviceLogService.addLog(deviceLogDto);
}); });
//改变维修详情装备所在单位为当前单位
repairDetailEntities.forEach(repairDetail -> {
repairDetail.setLocationUnit(repairBill.getReceiveUnit());
repairDetail.setRepairStatus(1);
deviceRepairDetailService.update(repairDetail);
});
if (idList.size()>0) { if (idList.size()>0) {
MessageBto messageBto = new MessageBto(taskBto.getId(), taskBto.getBusinessType(), "被选为经办人", idList, 1); MessageBto messageBto = new MessageBto(taskBto.getId(), taskBto.getBusinessType(), "被选为经办人", idList, 1);
messageService.add(messageBto); messageService.add(messageBto);
......
...@@ -81,7 +81,6 @@ public class RepairDetail { ...@@ -81,7 +81,6 @@ public class RepairDetail {
* 所在单位 * 所在单位
*/ */
@ApiModelProperty(value = "所在单位") @ApiModelProperty(value = "所在单位")
@Transient
private String locationUnit; private String locationUnit;
/** /**
* 所属单位 * 所属单位
......
package com.tykj.dev.device.repair.subject.vo;
import com.tykj.dev.device.file.entity.FileRet;
import com.tykj.dev.device.library.subject.vo.DeviceLibraryUpdateVo;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import javax.validation.constraints.Min;
import javax.validation.constraints.NotNull;
import java.util.List;
/**
* @author dengdiyi
*/
@Data
@ApiModel("装备编辑类")
public class DeviceEditVo {
@ApiModelProperty(value = "装备库更新信息")
private DeviceLibraryUpdateVo updateVoList;
@ApiModelProperty(value = "新增配件信息列表")
private List<Integer> partAddIdList;
@ApiModelProperty(value = "删除相关配件id")
private List<Integer> partIdDeleteList;
@NotNull(message = "deviceId不能为空")
@Min(value = 1,message = "deviceId不能小于1")
@ApiModelProperty(value = "装备id", example = "1")
private Integer deviceId;
@Min(value = 1,message = "id不能小于1")
@ApiModelProperty(value = "换新维修详情id", example = "1")
private Integer id;
@ApiModelProperty(value = "换新单")
private List<FileRet> sendFiles;
}
...@@ -499,11 +499,14 @@ public class StatisticalServiceImpl implements StatisticalService { ...@@ -499,11 +499,14 @@ public class StatisticalServiceImpl implements StatisticalService {
workBench.setSelfDeviceNum(Long.valueOf(deviceLibraries.stream().filter(deviceLibrary -> deviceLibrary.getOwnUnit().equals(unitName)).count()).intValue()); workBench.setSelfDeviceNum(Long.valueOf(deviceLibraries.stream().filter(deviceLibrary -> deviceLibrary.getOwnUnit().equals(unitName)).count()).intValue());
workBench.setMatchingDeviceNum(new Long(matchingDeviceLibraryDao.count()).intValue()); workBench.setMatchingDeviceNum(new Long(matchingDeviceLibraryDao.count()).intValue());
workBench.setDailyDeviceNum(Long.valueOf(deviceLibraries.stream().filter(deviceLibrary -> deviceLibrary.getOwnUnit().equals(unitName)&&Arrays.asList(2,14).contains(deviceLibrary.getLifeStatus())).count()).intValue()); workBench.setDailyDeviceNum(Long.valueOf(deviceLibraries.stream().filter(deviceLibrary -> deviceLibrary.getOwnUnit().equals(unitName)&&Arrays.asList(2,14).contains(deviceLibrary.getLifeStatus())).count()).intValue());
List<Task> tasks = taskDao.findAllByBusinessType(7); List<Task> allTasks = taskDao.findAll();
List<Task> tasks = allTasks.stream().filter(task -> task.getBusinessType()==7).collect(Collectors.toList());
List<Task> tasks2 = allTasks.stream().filter(task -> task.getBusinessType()==4).collect(Collectors.toList());
workBench.setCheckNum(Long.valueOf(tasks.stream().filter(task -> "check".equals(task.getCustomInfo())).count()).intValue()); workBench.setCheckNum(Long.valueOf(tasks.stream().filter(task -> "check".equals(task.getCustomInfo())).count()).intValue());
workBench.setCompleteCheckNum(Long.valueOf(tasks.stream().filter(task -> task.getBillStatus()==9999&&"check".equals(task.getCustomInfo())).count()).intValue()); workBench.setCompleteCheckNum(Long.valueOf(tasks.stream().filter(task -> task.getBillStatus()==9999&&"check".equals(task.getCustomInfo())).count()).intValue());
workBench.setExamNum(Long.valueOf(tasks.stream().filter(task -> task.getParentTaskId()==0&&"exam".equals(task.getCustomInfo())&&task.getOwnUnit().equals(unit)).count()).intValue()); workBench.setExamNum(Long.valueOf(tasks.stream().filter(task -> task.getParentTaskId()==0&&"exam".equals(task.getCustomInfo())&&task.getOwnUnit().equals(unit)).count()).intValue());
workBench.setExamCompleteNum(Long.valueOf(tasks.stream().filter(task -> task.getBillStatus()==9999&&task.getParentTaskId()==0&&"exam".equals(task.getCustomInfo())&&task.getOwnUnit().equals(unit)).count()).intValue()); workBench.setExamCompleteNum(Long.valueOf(tasks.stream().filter(task -> task.getBillStatus()==9999&&task.getParentTaskId()==0&&"exam".equals(task.getCustomInfo())&&task.getOwnUnit().equals(unit)).count()).intValue());
workBench.setSelfCheckNum(Long.valueOf(tasks2.stream().filter(task -> task.getBillStatus()==9999&&unit.equals(task.getOwnUnit())).count()).intValue());
return workBench; return workBench;
} }
......
...@@ -38,4 +38,6 @@ public class WorkBench { ...@@ -38,4 +38,6 @@ public class WorkBench {
private Integer lossNum = 0; private Integer lossNum = 0;
private Integer foundNum = 0; private Integer foundNum = 0;
private Integer selfCheckNum;
} }
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论