[add] 信号机灯态；环图请求存储redis

signal-utc-service/src/main/java/net/wanji/utc/service/staticinfo/impl/WanJiCommonStaticInfoServiceImpl.java

@@ -4,6 +4,7 @@ import cn.hutool.core.util.ObjectUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import lombok.RequiredArgsConstructor;
@@ -27,6 +28,7 @@ import net.wanji.utc.common.Result;
 import net.wanji.utc.service.control.impl.ControlCommandStrategyServiceImpl;
 import net.wanji.utc.service.staticinfo.WanJiCommonStaticInfoService;
 import net.wanji.utc.util.HttpRestUtil;
+import net.wanji.utc.util.RedisUtil;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
@@ -61,6 +63,7 @@ public class WanJiCommonStaticInfoServiceImpl implements WanJiCommonStaticInfoSe
     private final BaseCrossSchemeMapper baseCrossSchemeMapper;
     private final CrossSchemeStageOptLogMapper crossSchemeStageOptLogMapper;
     private final ControlCommandStrategyServiceImpl controlCommandStrategyService;
+    private final RedisUtil redisUtil;
 
 
     @Override
@@ -237,6 +240,15 @@ public class WanJiCommonStaticInfoServiceImpl implements WanJiCommonStaticInfoSe
         /*if (Objects.isNull(jsonViewObject) || jsonViewObject.getCode() != 200) {
             throw new Exception("方案环图请求远程服务调用异常，异常信息" + jsonViewObject.getMessage());
         }*/
+        try {
+            ObjectMapper mapper = JacksonUtils.getInstance();
+            CrossSchemeRings crossSchemeRings = mapper.convertValue(jsonViewObject.getContent(), CrossSchemeRings.class); // CrossSchemeRings
+            redisUtil.setHash("utc_scheme_offset", crossId, mapper.writeValueAsString(crossSchemeRings));
+        } catch (Exception e) {
+            log.error("方案换图请求存储redis失败：", e);
+            throw new RuntimeException(e);
+        }
+
         return jsonViewObject;
     }
 

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

@@ -23,6 +23,7 @@ import net.wanji.utc.common.typeenum.BasicEnum;
 import net.wanji.utc.kafka.ProducerHandler;
 import net.wanji.utc.service.runninginfo.HkLightsStatusService;
 import net.wanji.utc.service.runninginfo.SignalStatusService;
+import net.wanji.utc.util.RedisUtil;
 import net.wanji.utc.websocket.RealTimeDataWebSocket;
 import org.apache.commons.lang3.StringUtils;
 import org.elasticsearch.action.index.IndexRequest;
@@ -85,6 +86,8 @@ public class SignalStatusTask {
     @Qualifier("net.wanji.feign.service.EHualuFeignClients")
     @Autowired
     private EHualuFeignClients eHualuFeignClients;
+    @Autowired
+    private RedisUtil redisUtil;
 
     public static final ConcurrentHashMap<String, List<LightsStatusVO2>> produceListMap = new ConcurrentHashMap<>();
 
@@ -181,6 +184,7 @@ public class SignalStatusTask {
                         }
                         insertIntoHist(crossId, json);
                         produceListMap.put(crossId, listResult);
+                        redisUtil.setHash("utc_light_status", crossId, mapper.writeValueAsString(listResult));
                     } catch (Exception e) {
                         log.error("RealTimeDataWebSocket发送异常，异常信息：", e);
                     }