[update] 添加jackson工具类

signal-control-service/src/main/java/net/wanji/web/service/impl/PlanSendServiceImpl.java

@@ -9,6 +9,7 @@ import com.google.gson.Gson;
 import com.google.gson.GsonBuilder;
 import net.wanji.common.dto.CrossIdDTO;
 import net.wanji.common.framework.rest.JsonViewObject;
+import net.wanji.common.utils.tool.JacksonUtils;
 import net.wanji.databus.dao.entity.*;
 import net.wanji.databus.dao.mapper.*;
 import net.wanji.databus.dto.CrossSchedulesDTO;
@@ -428,7 +429,7 @@ public class PlanSendServiceImpl implements PlanSendService {
     }
 
     public void syncSchedules(String crossId, SchemePhaseLightsVO schemePhaseLightsVO) throws Exception {
-        ObjectMapper mapper = new ObjectMapper();
+        ObjectMapper mapper = JacksonUtils.getInstance();
         // 计划信息
         PlanSectionDTO planSectionDTO = new PlanSectionDTO();
         planSectionDTO.setCrossId(crossId);

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

@@ -7,10 +7,11 @@ import com.fasterxml.jackson.databind.ObjectMapper;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import net.wanji.common.framework.rest.JsonViewObject;
-import net.wanji.web.cache.BaseCrossInfoCache;
+import net.wanji.common.utils.tool.JacksonUtils;
 import net.wanji.databus.po.BaseCrossInfoPO;
 import net.wanji.databus.vo.SignalStatusVO;
 import net.wanji.feign.service.UtcFeignClients;
+import net.wanji.web.cache.BaseCrossInfoCache;
 import net.wanji.web.common.constant.Constant;
 import net.wanji.web.common.constant.ControlModeConst;
 import net.wanji.web.entity.TCrossControlHist;
@@ -66,7 +67,7 @@ public class SignalStatusTask {
                 return;
             }
             // utc服务信号机状态列表
-            ObjectMapper mapper = new ObjectMapper();
+            ObjectMapper mapper = JacksonUtils.getInstance();
             List<SignalStatusVO> content = mapper.convertValue(jsonViewObject.getContent(), new TypeReference<List<SignalStatusVO>>() {
             });
             // 信号机状态信息

signal-utc-service/src/main/java/net/wanji/utc/service/runninginfo/impl/WanJiCommonRunningStatusServiceImpl.java

@@ -5,6 +5,7 @@ import com.fasterxml.jackson.databind.ObjectMapper;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import net.wanji.common.framework.rest.JsonViewObject;
+import net.wanji.common.utils.tool.JacksonUtils;
 import net.wanji.databus.po.SignalStatusLogPO;
 import net.wanji.databus.vo.LightsStatusVO;
 import net.wanji.utc.cache.CrossInfoCache;
@@ -40,7 +41,7 @@ public class WanJiCommonRunningStatusServiceImpl implements WanJiCommonRunningSt
             if (Objects.isNull(jsonViewObject) || jsonViewObject.getCode() != 200) {
                 throw new Exception("获取运行状态、告警数据远程服务调用异常，异常信息" + jsonViewObject.getMessage());
             }
-            ObjectMapper mapper = new ObjectMapper();
+            ObjectMapper mapper = JacksonUtils.getInstance();
             result.addAll(mapper.convertValue(jsonViewObject.getContent(), new TypeReference<List<SignalStatusLogPO>>() {}));
         }
 
@@ -58,7 +59,7 @@ public class WanJiCommonRunningStatusServiceImpl implements WanJiCommonRunningSt
             if (Objects.isNull(jsonViewObject) || jsonViewObject.getCode() != 200) {
                 throw new Exception("获取灯态数据远程服务调用异常，异常信息" + jsonViewObject.getMessage());
             }
-            ObjectMapper objectMapper = new ObjectMapper();
+            ObjectMapper objectMapper = JacksonUtils.getInstance();
             result = objectMapper.convertValue(jsonViewObject.getContent(), new TypeReference<List<LightsStatusVO>>() {});
         }
         return result;

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

@@ -5,6 +5,7 @@ import com.fasterxml.jackson.databind.ObjectMapper;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import net.wanji.common.framework.rest.JsonViewObject;
+import net.wanji.common.utils.tool.JacksonUtils;
 import net.wanji.databus.dao.entity.*;
 import net.wanji.databus.dao.mapper.*;
 import net.wanji.databus.dto.CrossSchedulesDTO;
@@ -55,7 +56,7 @@ public class WanJiCommonStaticInfoServiceImpl implements WanJiCommonStaticInfoSe
         if (Objects.isNull(jsonViewObject) || jsonViewObject.getCode() != 200) {
             throw new Exception("获取方案数据-方案信息、相位信息、灯组信息远程服务调用异常，异常信息" + jsonViewObject.getMessage());
         }
-        ObjectMapper objectMapper = new ObjectMapper();
+        ObjectMapper objectMapper = JacksonUtils.getInstance();
         SchemePhaseLightsVO content = objectMapper.convertValue(jsonViewObject.getContent(), SchemePhaseLightsVO.class);
         List<CrossSchemePO> crossSchemeList = content.getCrossSchemeList();
         crossSchemeList.forEach(crossSchemePO -> {
@@ -114,7 +115,7 @@ public class WanJiCommonStaticInfoServiceImpl implements WanJiCommonStaticInfoSe
         if (Objects.isNull(jsonViewObject) || jsonViewObject.getCode() != 200) {
             throw new Exception("获取计划数据-计划信息、时段信息远程服务调用异常，异常信息" + jsonViewObject.getMessage());
         }
-        ObjectMapper mapper = new ObjectMapper();
+        ObjectMapper mapper = JacksonUtils.getInstance();
         List<PlanSectionVO> content = mapper.convertValue(jsonViewObject.getContent(), new TypeReference<List<PlanSectionVO>>() {});
         if (!CollectionUtils.isEmpty(content)) {
             for (PlanSectionVO planSectionVO : content) {
@@ -147,7 +148,7 @@ public class WanJiCommonStaticInfoServiceImpl implements WanJiCommonStaticInfoSe
         if (Objects.isNull(jsonViewObject) || jsonViewObject.getCode() != 200) {
             throw new Exception("获取时间表数据远程服务调用异常，异常信息" + jsonViewObject.getMessage());
         }
-        ObjectMapper mapper = new ObjectMapper();
+        ObjectMapper mapper = JacksonUtils.getInstance();
         List<CrossSchedulesPO> content = mapper.convertValue(jsonViewObject.getContent(), new TypeReference<List<CrossSchedulesPO>>() {});
 
         if (Objects.nonNull(content)) {

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

@@ -4,6 +4,7 @@ import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import lombok.extern.slf4j.Slf4j;
 import net.wanji.common.framework.rest.JsonViewObject;
+import net.wanji.common.utils.tool.JacksonUtils;
 import net.wanji.databus.dao.mapper.CrossInfoMapper;
 import net.wanji.databus.dao.mapper.ManufacturerInfoMapper;
 import net.wanji.databus.po.CrossInfoPO;
@@ -73,7 +74,7 @@ public class SignalStatusTask {
             if (!evenWarnWebSocketMap.isEmpty()) {
                 for (Map.Entry<String, RealTimeDataWebSocket> entry : evenWarnWebSocketMap.entrySet()) {
                     commonThreadPoolExecutor.execute(() -> {
-                        ObjectMapper mapper = new ObjectMapper();
+                        ObjectMapper mapper = JacksonUtils.getInstance();
                         String crossId = null;
                         String crossIdStr = entry.getKey();
                         if (StringUtils.isNotBlank(crossIdStr)) {

wj-common/src/main/java/net/wanji/common/utils/tool/JacksonUtils.java

+package net.wanji.common.utils.tool;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+/**
+ * Jackson ObjectMapper单例
+ * @author duanruiming
+ * @date 2023/07/17 11:01
+ */
+public class JacksonUtils {
+    private static final ObjectMapper mapper = new ObjectMapper();
+    public static ObjectMapper getInstance() {
+        return mapper;
+    }
+}