[update] 控制指令下发失败，定时恢复的定时任务修改

signal-utc-service/src/main/java/net/wanji/utc/task/CommandFaildTask.java

@@ -50,7 +50,7 @@ public class CommandFaildTask {
     @Resource
     private SignalCommandLogPOMapper signalCommandLogPOMapper;
 
-    @Scheduled(cron = "0/5 * * * * ?")
+    @Scheduled(fixedRate = 5 * 1000, initialDelay = 10 * 1000)
     public void commandFaildTask() throws Exception {
         try {
             LambdaQueryWrapper<SignalCommandPO> lambdaQueryWrapper = new LambdaQueryWrapper<>();
@@ -244,9 +244,9 @@ public class CommandFaildTask {
         //插入日志表
         int insert = signalCommandLogPOMapper.insert(signalCommandLogPO);
         if (insert > 0) {
-            log.info("定时任务 插入t_signal_command_log成功,crossId = {},commandType = {},time = {},insert = {}", jsonObject.getString("crossId"), commandType, LocalDateTimeUtil.formatNow(LocalDateTimeUtil.TIMEFORMATTER),insert);
-        }else {
-            log.info("定时任务 插入t_signal_command_log失败,crossId = {},commandType = {},time = {},insert = {}", jsonObject.getString("crossId"), commandType, LocalDateTimeUtil.formatNow(LocalDateTimeUtil.TIMEFORMATTER),insert);
+            log.info("定时任务 插入t_signal_command_log成功,crossId = {},commandType = {},time = {},insert = {}", jsonObject.getString("crossId"), commandType, LocalDateTimeUtil.formatNow(LocalDateTimeUtil.TIMEFORMATTER), insert);
+        } else {
+            log.info("定时任务 插入t_signal_command_log失败,crossId = {},commandType = {},time = {},insert = {}", jsonObject.getString("crossId"), commandType, LocalDateTimeUtil.formatNow(LocalDateTimeUtil.TIMEFORMATTER), insert);
         }
         SignalCommandPO signalCommandPO = new SignalCommandPO();
         BeanUtil.copyProperties(signalCommandLogPO, signalCommandPO);
@@ -256,9 +256,9 @@ public class CommandFaildTask {
         lambdaQueryWrapper.eq(SignalCommandPO::getCrossId, jsonObject.getString("crossId"));
         int update = signalCommandPOMapper.update(signalCommandPO, lambdaQueryWrapper);
         if (update > 0) {
-            log.info("定时任务 更新t_signal_command成功,crossId = {},commandType = {},time = {},update = {}", jsonObject.getString("crossId"), commandType, LocalDateTimeUtil.formatNow(LocalDateTimeUtil.TIMEFORMATTER),update);
-        }else {
-            log.info("定时任务 更新t_signal_command失败,crossId = {},commandType = {},time = {},update = {}", jsonObject.getString("crossId"), commandType, LocalDateTimeUtil.formatNow(LocalDateTimeUtil.TIMEFORMATTER),update);
+            log.info("定时任务 更新t_signal_command成功,crossId = {},commandType = {},time = {},update = {}", jsonObject.getString("crossId"), commandType, LocalDateTimeUtil.formatNow(LocalDateTimeUtil.TIMEFORMATTER), update);
+        } else {
+            log.info("定时任务 更新t_signal_command失败,crossId = {},commandType = {},time = {},update = {}", jsonObject.getString("crossId"), commandType, LocalDateTimeUtil.formatNow(LocalDateTimeUtil.TIMEFORMATTER), update);
         }
         List<SignalCommandPO> signalCommandPOS = signalCommandPOMapper.selectList(lambdaQueryWrapper);
         log.error("定时任务 更新t_signal_command成功,数据库中查询结果集：{}", signalCommandPOS);