巡检

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

@@ -24,7 +24,7 @@ import com.platform.service.event.WorkplaceBacklogEvent;
 import com.platform.service.fill.FillGatherTaskService;
 import com.platform.service.util.SendMessageUtils;
 import lombok.AllArgsConstructor;
-import org.apache.poi.hslf.model.Fill;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import tk.mybatis.mapper.weekend.Weekend;
 import tk.mybatis.mapper.weekend.WeekendCriteria;
@@ -42,6 +42,7 @@ import java.util.concurrent.TimeUnit;
  */
 @AllArgsConstructor
 @Service("fillGatherTaskService")
+@Slf4j
 public class FillGatherTaskServiceImpl extends BaseServiceImpl<FillGatherTaskMapper, FillGatherTask, FillGatherTaskDTO> implements FillGatherTaskService {
 
     private final FillGatherInfoMapper fillGatherInfoMapper;
@@ -91,6 +92,8 @@ public class FillGatherTaskServiceImpl extends BaseServiceImpl<FillGatherTaskMap
         // 4、启动超时监控预警信息
         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;
     }

platform-service/src/main/java/com/platform/service/redis/impl/RedisFillTaskService.java

@@ -56,6 +56,7 @@ public class RedisFillTaskService extends KeyExpirationEventMessageListener {
     @Override
     public void onMessage(Message message, byte[] pattern) {
         String expiredKey = message.toString();
+        logger.info("巡检任务redis回写----------------"+expiredKey);
         // 将拿到的过期键使用之前拼接时的特殊符号分割成字符数组 ，拿到保函id
         String[] expiredKeyArr = expiredKey.split(RedisKeyConstants.EXPIRE_BUSINESS_SEP);
         if(expiredKeyArr.length == 0){