巡检

platform-service/src/main/java/com/platform/service/fill/impl/FillGatherTaskServiceImpl.java

@@ -113,7 +113,6 @@ public class FillGatherTaskServiceImpl extends BaseServiceImpl<FillGatherTaskMap
         int initMin = model.getRequireHour()*60;
         int hours = model.getWarningHour() == null ? initMin + 120 : model.getWarningHour()*60 + initMin;
         log.info("-----------hours------------"+hours);
-        hours = 2;
         RedisUtils.setString(RedisKeyConstants.EXPIRE_BUSINESS_KEY_FILL_PREFIX + RedisKeyConstants.EXPIRE_BUSINESS_SEP + task.getId(), task.getId(), hours, TimeUnit.MINUTES);
         return task;
     }
@@ -166,6 +165,7 @@ public class FillGatherTaskServiceImpl extends BaseServiceImpl<FillGatherTaskMap
         updTask.setUpdateTime(LocalDateTime.now());
         updTask.setUpdateUserId(SecurityUtils.getUserInfo().getUserId());
         updTask.setUpdateUserName(SecurityUtils.getUserInfo().getUsername());
+        mapper.updateByPrimaryKeySelective(updTask);
         // 保存巡检更新记录
         FillUpdateRecord record = new FillUpdateRecord();
         record.setUpdateUserId(task.getCheckLeader());
@@ -176,6 +176,8 @@ public class FillGatherTaskServiceImpl extends BaseServiceImpl<FillGatherTaskMap
         record.setLateHour(model.getExtrahours());
         record.setType(FillUpdateRecordTypeEnum.LATE.getValue());
         fillUpdateRecordMapper.insert(record);
+        // 启动超时监控
+        RedisUtils.setString(RedisKeyConstants.EXPIRE_BUSINESS_KEY_FILL_PREFIX + RedisKeyConstants.EXPIRE_BUSINESS_SEP + task.getId(), task.getId(), model.getExtrahours()*60, TimeUnit.MINUTES);
     }
 
     @Override