[update] 优化实时数据插入逻辑

signal-optimize-service/src/main/java/net/wanji/opt/cache/CrossDirTurnPhaseCache.java

@@ -6,7 +6,6 @@ import net.wanji.common.enums.TurnConvertEnum;
 import net.wanji.common.enums.WeekEnum;
 import net.wanji.common.framework.Constants;
 import net.wanji.common.utils.tool.DateUtil;
-import net.wanji.opt.common.exception.OptServiceException;
 import net.wanji.opt.dto.*;
 import net.wanji.opt.service.CrossSchedulesService;
 import net.wanji.opt.service.CrossSchemeService;
@@ -97,7 +96,7 @@ public class CrossDirTurnPhaseCache implements CommandLineRunner {
                         dir = lights.getDir();
                         if (Objects.isNull(lights.getLaneInfos())) {
                             log.error("{}-路口， {}-方案，{}-灯组，灯组中车道信息不能为空", crossId, scheme.getId(), lights.getId());
-                            throw new OptServiceException("当前路口：".concat(crossId).concat(", 灯组关联车道信息不能为空"));
+                            continue;
                         }
                         for (LaneInfoDTO lane : lights.getLaneInfos()) {
                             // 车道转向转换为转向类型，并去重

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

@@ -15,6 +15,7 @@ import org.springframework.util.CollectionUtils;
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * @author duanruiming
@@ -47,6 +48,7 @@ public class DataCenterProcessTask {
         if (StringUtils.isNotBlank(crossRealTimeData)) {
             List<CrossDataRealtimePO> crossDataRealtimePOS = instance.readValue(crossRealTimeData, new TypeReference<List<CrossDataRealtimePO>>() {});
             if (!CollectionUtils.isEmpty(crossDataRealtimePOS)) {
+                crossDataRealTimeMapper.deleteBatch(crossDataRealtimePOS.stream().map(CrossDataRealtimePO::getCrossId).collect(Collectors.toList()));
                 crossDataRealTimeMapper.insertBatch(crossDataRealtimePOS);
                 List<CrossDataHistPO> crossDataHistPOS = new ArrayList<>(crossDataRealtimePOS.size());
                 BeanListUtils.populateList(crossDataRealtimePOS, crossDataHistPOS, CrossDataHistPO.class);
@@ -58,6 +60,7 @@ public class DataCenterProcessTask {
         if (StringUtils.isNotBlank(crossRealTimeDirData)) {
             List<CrossDirDataRealtimePO> crossDirDataRealtimePOS = instance.readValue(crossRealTimeDirData, new TypeReference<List<CrossDirDataRealtimePO>>() {});
             if (!CollectionUtils.isEmpty(crossDirDataRealtimePOS)) {
+                crossDirDataRealTimeMapper.deleteBatch(crossDirDataRealtimePOS.stream().map(CrossDirDataRealtimePO::getCrossId).collect(Collectors.toList()));
                 crossDirDataRealTimeMapper.insertBatch(crossDirDataRealtimePOS);
                 List<CrossDirDataHistPO> list = new ArrayList<>(crossDirDataRealtimePOS.size());
                 BeanListUtils.populateList(crossDirDataRealtimePOS, list, CrossDirDataHistPO.class);
@@ -69,6 +72,7 @@ public class DataCenterProcessTask {
         if (StringUtils.isNotBlank(crossRealTimeTurnData)) {
             List<CrossTurnDataRealtimePO> crossTurnDataRealtimePOS = instance.readValue(crossRealTimeTurnData, new TypeReference<List<CrossTurnDataRealtimePO>>() {});
             if (!CollectionUtils.isEmpty(crossTurnDataRealtimePOS)) {
+                crossTurnDataRealTimeMapper.deleteBatch(crossTurnDataRealtimePOS.stream().map(CrossTurnDataRealtimePO::getCrossId).collect(Collectors.toList()));
                 crossTurnDataRealTimeMapper.insertBatch(crossTurnDataRealtimePOS);
                 List<CrossTurnDataHistPO> list = new ArrayList<>(crossTurnDataRealtimePOS.size());
                 BeanListUtils.populateList(crossTurnDataRealtimePOS, list, CrossTurnDataHistPO.class);
@@ -80,6 +84,7 @@ public class DataCenterProcessTask {
         if (StringUtils.isNotBlank(crossRealTimeLaneData)) {
             List<CrossLaneDataRealTimePO> crossLaneDataRealTimePOS = instance.readValue(crossRealTimeLaneData, new TypeReference<List<CrossLaneDataRealTimePO>>() {});
             if (!CollectionUtils.isEmpty(crossLaneDataRealTimePOS)) {
+                crossLaneDataRealTimeMapper.deleteBatch(crossLaneDataRealTimePOS.stream().map(CrossLaneDataRealTimePO::getCrossId).collect(Collectors.toList()));
                 crossLaneDataRealTimeMapper.insertBatch(crossLaneDataRealTimePOS);
                 List<CrossLaneDataHistPO> crossLaneDataHistPOS = new ArrayList<>(crossLaneDataRealTimePOS.size());
                 BeanListUtils.populateList(crossLaneDataRealTimePOS, crossLaneDataHistPOS, CrossLaneDataHistPO.class);