[update] 插入实时表逻辑优化

signal-optimize-service/src/main/java/net/wanji/opt/task/DataCenterProcessTask.java

@@ -4,6 +4,7 @@ import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import net.wanji.common.utils.tool.BeanListUtils;
 import net.wanji.common.utils.tool.JacksonUtils;
 import net.wanji.common.utils.tool.StringUtils;
@@ -25,6 +26,7 @@ import java.util.stream.Collectors;
  */
 @Component
 @RequiredArgsConstructor
+@Slf4j
 public class DataCenterProcessTask {
 
     private final CrossDirDataRealtimeMapper crossDirDataRealTimeMapper;
@@ -45,13 +47,29 @@ public class DataCenterProcessTask {
     public void realTimeDataSave() throws Exception {
         ObjectMapper instance = JacksonUtils.getInstance();
 
-        saveCrossRealTimeData(instance);
+        try {
+            saveCrossRealTimeData(instance);
+        } catch (Exception e) {
+            log.error("路口实时数据插入失败", e);
+        }
 
-        saveCrossRealTimeDirData(instance);
+        try {
+            saveCrossRealTimeDirData(instance);
+        } catch (Exception e) {
+            log.error("路口方向实时数据插入失败", e);
+        }
 
-        saveCrossRealTimeTurnData(instance);
+        try {
+            saveCrossRealTimeTurnData(instance);
+        } catch (Exception e) {
+            log.error("路口转向实时数据插入失败", e);
+        }
 
-        saveCrossRealTimeLaneData(instance);
+        try {
+            saveCrossRealTimeLaneData(instance);
+        } catch (Exception e) {
+            log.error("路口车道实时数据插入失败", e);
+        }
     }
 
     @Transactional