[update] 测试查找问题

signal-control-service/src/main/java/net/wanji/web/task/CommonEventWarnTask.java

@@ -83,7 +83,7 @@ public class CommonEventWarnTask {
      */
     private JsonViewObject getSignalWarnData() {
         List<CommonEventAlarmOutVo> results = new ArrayList<>();
-
+        log.info("=============信号机告警===============");
         JsonViewObject jsonViewObject = utcFeignClients.runningStatusAlarm();
         if (Objects.isNull(jsonViewObject) || jsonViewObject.getCode() != 200) {
             return jsonViewObject.fail("信号机告警UTC服务调用异常！");
@@ -91,6 +91,7 @@ public class CommonEventWarnTask {
         LocalDateTime now = LocalDateTime.now();
         String formatNow = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss").format(now);
         List<Map<String, Object>> content = (List<Map<String, Object>>) jsonViewObject.getContent();
+        log.info("=============信号机告警：{}", content);
         content.forEach(map -> {
             Map<String, Object> result = map;
             String signalId = (String) result.get("signalId");

signal-control-service/src/main/java/net/wanji/web/task/SignalStatusTask.java

@@ -36,7 +36,7 @@ public class SignalStatusTask {
     private final ControlHistMapper controlHistMapper;
     private final TDeviceStatusLogMapper tDeviceStatusLogMapper;
 
-    @Scheduled(fixedRate = 1 * 60 * 1000)
+    @Scheduled(fixedRate = 2 * 60 * 1000)
     @Transactional
     public void syncSignalStatus() {
         try {
@@ -47,6 +47,7 @@ public class SignalStatusTask {
             }
             List<Map<String, Object>> source = (List<Map<String, Object>>) jsonViewObject.getContent();
             List<SignalStatusVO> content = BeanMapUtils.mapsToObjects(source, SignalStatusVO.class);
+            log.info("SignalStatusVOTOMap: {}", content);
             content.forEach(signalStatusVO -> {
                 String signalId = signalStatusVO.getSignalId();
                 String crossId = signalStatusVO.getCrossId();
@@ -58,6 +59,8 @@ public class SignalStatusTask {
                 if (StringUtils.isNotEmpty(crossId)) {
                     lambdaQueryWrapper.eq(TDeviceStatusInfo::getCode, crossId);
                     TDeviceStatusInfo tDeviceStatusInfo = tDeviceStatusMapper.selectOne(lambdaQueryWrapper);
+                    log.info("TDeviceStatusInfo::getCode: {}", tDeviceStatusInfo.getCode());
+
                     if (isExucuteUpdate(currentSignalStatus, currentFaultType, tDeviceStatusInfo)) {
                         tDeviceStatusInfo.setStatus(currentSignalStatus);
                         tDeviceStatusInfo.setFaultType(currentFaultType);