|
@@ -53,6 +53,45 @@ public class FillGatherTaskServiceImpl extends BaseServiceImpl<FillGatherTaskMap
|
|
|
private final FillGatherTaskDetailMapper fillGatherTaskDetailMapper;
|
|
|
private final SysUserMapper sysUserMapper;
|
|
|
private final FillUpdateRecordMapper fillUpdateRecordMapper;
|
|
|
+
|
|
|
+ private void deleteDetails(List<String> detailIds){
|
|
|
+ for(int i=0;i<detailIds.size();i++){
|
|
|
+ FillGatherTaskDetail detail = new FillGatherTaskDetail();
|
|
|
+ detail.setId(detailIds.get(i));
|
|
|
+ }
|
|
|
+ fillGatherTaskDetailMapper.deleteByPrimaryKey(detailIds);
|
|
|
+ }
|
|
|
+ @Override
|
|
|
+ public int updateDetails(FillGatherTaskDTO dto) {
|
|
|
+ //先获取勾选设备,更新
|
|
|
+ FillGatherTask task1 = mapper.selectOne(new FillGatherTask().setId(dto.getId()));
|
|
|
+ FillGatherTask task = new FillGatherTask();
|
|
|
+ task.setId(dto.getId());
|
|
|
+ if (dto.getIsAdd()==0){
|
|
|
+ //删除
|
|
|
+ task.setTotalNum(task1.getTotalNum()-dto.getSbIds().size());
|
|
|
+ task.setWaitNum(task1.getTotalNum()-dto.getSbIds().size());
|
|
|
+ deleteDetails(dto.getDetailIds());
|
|
|
+ }else if (dto.getIsAdd()==1){
|
|
|
+ task.setTotalNum(task1.getTotalNum()+dto.getSbIds().size());
|
|
|
+ task.setWaitNum(task1.getTotalNum()+dto.getSbIds().size());
|
|
|
+ //新增明细,调用saveDetail方法
|
|
|
+ String content = getContentByGatherId(dto.getGatherId());
|
|
|
+ saveDetails(content,dto.getSbIds(),dto.getSortNums(),task.getId());
|
|
|
+ }
|
|
|
+ task.setStatus(FillGatherTaskStatusEnum.PROCESSING.getValue());
|
|
|
+ mapper.updateByPrimaryKey(task);
|
|
|
+ // 3、通知相关人员(巡检人和主管)
|
|
|
+ sendMessageToChecker(task,1);
|
|
|
+ sendMessageToChecker(task,2);
|
|
|
+ // 4、启动超时监控预警信息
|
|
|
+ int initMin = task.getRequireHour()*60;
|
|
|
+ int hours = task.getWarningHour() == null ? initMin + 120 : task.getWarningHour()*60 + initMin;
|
|
|
+ log.info("-----------hours------------"+hours);
|
|
|
+ RedisUtils.setString(RedisKeyConstants.EXPIRE_BUSINESS_KEY_FILL_PREFIX + RedisKeyConstants.EXPIRE_BUSINESS_SEP + task.getId(), task.getId(), hours, TimeUnit.MINUTES);
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+
|
|
|
@Override
|
|
|
public int batchDelete(List<String> ids) {
|
|
|
Weekend<FillGatherTask> weekend = new Weekend<>(FillGatherTask.class);
|