中间库事件插入

zc-business/src/main/java/com/zc/business/domain/MdEvent.java

@@ -649,18 +649,23 @@ public class MdEvent
         String eventType = dcEvent.getEventType().toString();
         if ("1".equals(eventType)){
             DcEventAccident dcEventAccident = dcEvent.getDcEventAccident();
+            if (dcEventAccident != null){
                 //事故天气情况
                 this.accidentWeather = dcEventAccident.getWeatherCondition();
                 //事故压车(公里)
                 this.accidentQueue = new BigDecimal(Float.toString(dcEventAccident.getTrafficJam()));
+            }
         } else if ("2".equals(eventType)){
             DcEventVehicleAccident dcEventVehicleAccident = dcEvent.getDcEventVehicleAccident();
+            if (dcEventVehicleAccident != null) {
                 //事故天气情况
                 this.accidentWeather = dcEventVehicleAccident.getWeatherCondition();
                 //事故压车(公里)
                 this.accidentQueue = new BigDecimal(Float.toString(dcEventVehicleAccident.getTrafficJam()));
+            }
         } else if ("3".equals(eventType)){
             DcEventTrafficControl dcEventTrafficControl = dcEvent.getDcEventTrafficControl();
+            if (dcEventTrafficControl != null) {
                 //管制分类
                 this.controlCategory = dcEventTrafficControl.getControlType();
                 //管制原因类型
@@ -673,24 +678,32 @@ public class MdEvent
                 this.controlType = dcEventTrafficControl.getLimitedType();
                 //管制车辆类型
                 this.controlVehicleType = dcEventTrafficControl.getVehicleType();
+            }
         } else if ("4".equals(eventType)){
             DcEventTrafficCongestion dcEventTrafficCongestion = dcEvent.getDcEventTrafficCongestion();
+            if (dcEventTrafficCongestion != null) {
                 //拥堵里程(公里)
                 this.congestionPile = dcEventTrafficCongestion.getCongestionMileage().longValue();
                 //拥堵原因
                 this.congestionReason = dcEventTrafficCongestion.getCongestionCause();
+            }
         } else if ("7".equals(eventType)){
             DcEventConstruction dcEventConstruction = dcEvent.getDcEventConstruction();
+            if (dcEventConstruction != null) {
                 //管制分类
                 this.controlCategory = dcEventConstruction.getControlMode();
+            }
         } else if ("8".equals(eventType)){
             DcEventServiceArea dcEventServiceArea = dcEvent.getDcEventServiceArea();
+            if (dcEventServiceArea != null) {
                 //管制出入口
                 this.controlStation = dcEventServiceArea.getFacilityId();
+            }
         } else if ("10".equals(eventType)){
             DcEventAbnormalWeather dcEventAbnormalWeather = dcEvent.getDcEventAbnormalWeather();
+            if (dcEventAbnormalWeather != null){
 
-
+            }
         }
 
     }

zc-business/src/main/java/com/zc/business/service/impl/DcEventServiceImpl.java

@@ -129,8 +129,8 @@ public class DcEventServiceImpl implements IDcEventService {
         if (i7 > 0) {
 
             //中间库
-//            MdEvent mdEvent = new MdEvent(dcEvent);
+            MdEvent mdEvent = new MdEvent(dcEvent);
-//            middleDatabaseService.insertMiddleDatabaseEvent(mdEvent);
+            middleDatabaseService.insertMiddleDatabaseEvent(mdEvent);
 
             //获取事件类型
             int eventType = Math.toIntExact(dcEvent.getEventType());