1.批量操作感知事件

2.气象检测器数据修改

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

@@ -34,14 +34,22 @@ public class DcMeteorologicalDetectorData extends BaseEntity
     @Excel(name = "能见度")
     private String visibility;
 
-    /** 路面状况 */
+    /** 路面温度 */
-    @Excel(name = "路面状况")
+    @Excel(name = "路面温度")
-    private String roadSurfaceStatus;
+    private String remoteRoadSurfaceTemperature;
 
     /** 气压 */
     @Excel(name = "气压")
     private String atmosphericPressure;
 
+    /** 降水类型 */
+    @Excel(name = "降水类型")
+    private String precipitationType;
+
+    /** 湿滑系数 */
+    @Excel(name = "湿滑系数")
+    private String wetSlipperyCoefficient;
+
     /** 气温 */
     @Excel(name = "气温")
     private String temperature;
@@ -58,49 +66,18 @@ public class DcMeteorologicalDetectorData extends BaseEntity
     @Excel(name = "风速")
     private String windSpeed;
 
-    /** 冰点温度 */
+    /** 路面状态 */
-    @Excel(name = "冰点温度")
+    @Excel(name = "路面状态")
-    private String freezingPointTemperature;
+    private String remoteRoadSurfaceStatus;
-
-    /** 盐度值 */
-    @Excel(name = "盐度值")
-    private String salinityValue;
-
-    /** 路面温度 */
-    @Excel(name = "路面温度")
-    private String roadSurfaceTemperature;
-
-    /** 水膜厚度(GS1) */
-    @Excel(name = "水膜厚度(GS1)")
-    private String waterFilmThickness;
-
-    /** 降水类型 */
-    @Excel(name = "降水类型")
-    private String precipitationType;
 
-    /** 湿滑系数 */
+    /** 水膜厚度 */
-    @Excel(name = "湿滑系数")
+    @Excel(name = "水膜厚度")
-    private String wetSlipperyCoefficient;
+    private String waterFilmIceSnowValue;
 
-    /** 传感器温度 */
-    @Excel(name = "传感器温度")
-    private String sensorTemperature;
 
-    /** 远程路面温度 */
-    @Excel(name = "远程路面温度")
-    private String remoteRoadSurfaceTemperature;
 
-    /** 远程路面状态 */
-    @Excel(name = "远程路面状态")
-    private String remoteRoadSurfaceStatus;
 
-    /** 路基温度 */
-    @Excel(name = "路基温度")
-    private String subSurfaceTemperature;
 
-    /** 水膜厚度(GS2) */
-    @Excel(name = "水膜厚度(GS2)")
-    private String waterFilmIceSnowValue;
 
     public void setId(Long id) 
     {
@@ -147,15 +124,6 @@ public class DcMeteorologicalDetectorData extends BaseEntity
     {
         return visibility;
     }
-    public void setRoadSurfaceStatus(String roadSurfaceStatus) 
-    {
-        this.roadSurfaceStatus = roadSurfaceStatus;
-    }
-
-    public String getRoadSurfaceStatus() 
-    {
-        return roadSurfaceStatus;
-    }
     public void setAtmosphericPressure(String atmosphericPressure) 
     {
         this.atmosphericPressure = atmosphericPressure;
@@ -201,42 +169,7 @@ public class DcMeteorologicalDetectorData extends BaseEntity
     {
         return windSpeed;
     }
-    public void setFreezingPointTemperature(String freezingPointTemperature) 
-    {
-        this.freezingPointTemperature = freezingPointTemperature;
-    }
-
-    public String getFreezingPointTemperature() 
-    {
-        return freezingPointTemperature;
-    }
-    public void setSalinityValue(String salinityValue) 
-    {
-        this.salinityValue = salinityValue;
-    }
-
-    public String getSalinityValue() 
-    {
-        return salinityValue;
-    }
-    public void setRoadSurfaceTemperature(String roadSurfaceTemperature) 
-    {
-        this.roadSurfaceTemperature = roadSurfaceTemperature;
-    }
 
-    public String getRoadSurfaceTemperature() 
-    {
-        return roadSurfaceTemperature;
-    }
-    public void setWaterFilmThickness(String waterFilmThickness) 
-    {
-        this.waterFilmThickness = waterFilmThickness;
-    }
-
-    public String getWaterFilmThickness() 
-    {
-        return waterFilmThickness;
-    }
     public void setPrecipitationType(String precipitationType) 
     {
         this.precipitationType = precipitationType;
@@ -255,15 +188,7 @@ public class DcMeteorologicalDetectorData extends BaseEntity
     {
         return wetSlipperyCoefficient;
     }
-    public void setSensorTemperature(String sensorTemperature) 
-    {
-        this.sensorTemperature = sensorTemperature;
-    }
 
-    public String getSensorTemperature() 
-    {
-        return sensorTemperature;
-    }
     public void setRemoteRoadSurfaceTemperature(String remoteRoadSurfaceTemperature) 
     {
         this.remoteRoadSurfaceTemperature = remoteRoadSurfaceTemperature;
@@ -282,15 +207,7 @@ public class DcMeteorologicalDetectorData extends BaseEntity
     {
         return remoteRoadSurfaceStatus;
     }
-    public void setSubSurfaceTemperature(String subSurfaceTemperature) 
-    {
-        this.subSurfaceTemperature = subSurfaceTemperature;
-    }
 
-    public String getSubSurfaceTemperature() 
-    {
-        return subSurfaceTemperature;
-    }
     public void setWaterFilmIceSnowValue(String waterFilmIceSnowValue)
     {
         this.waterFilmIceSnowValue = waterFilmIceSnowValue;
@@ -309,22 +226,15 @@ public class DcMeteorologicalDetectorData extends BaseEntity
             .append("rainfall", getRainfall())
             .append("visibilityType", getVisibilityType())
             .append("visibility", getVisibility())
-            .append("roadSurfaceStatus", getRoadSurfaceStatus())
             .append("atmosphericPressure", getAtmosphericPressure())
             .append("temperature", getTemperature())
             .append("humidity", getHumidity())
             .append("windDirection", getWindDirection())
             .append("windSpeed", getWindSpeed())
-            .append("freezingPointTemperature", getFreezingPointTemperature())
-            .append("salinityValue", getSalinityValue())
-            .append("roadSurfaceTemperature", getRoadSurfaceTemperature())
-            .append("waterFilmThickness", getWaterFilmThickness())
             .append("precipitationType", getPrecipitationType())
             .append("wetSlipperyCoefficient", getWetSlipperyCoefficient())
-            .append("sensorTemperature", getSensorTemperature())
             .append("remoteRoadSurfaceTemperature", getRemoteRoadSurfaceTemperature())
             .append("remoteRoadSurfaceStatus", getRemoteRoadSurfaceStatus())
-            .append("subSurfaceTemperature", getSubSurfaceTemperature())
             .append("waterFilmIceSnowValue", getWaterFilmIceSnowValue())
             .toString();
     }

zc-business/src/main/java/com/zc/business/mapper/DcEventMapper.java

@@ -73,6 +73,16 @@ public interface DcEventMapper extends BaseMapper<DcEvent>
 
     List<Map<String,String>>selectCount();
 
+    /**
+     * @Description 批量添加事件
+     *
+     * @author liuwenge
+     * @date 2024/3/18 15:02
+     * @param eventList
+     * @return boolean
+     */
+    boolean batchInsertDcEvent(List<DcEvent> eventList);
+
 }
 
 

zc-business/src/main/java/com/zc/business/mapper/MiddleDatabaseMapper.java

@@ -81,4 +81,14 @@ public interface MiddleDatabaseMapper
      * @return 结果
      */
     boolean updateMiddleDatabaseEvent(MdEvent mdEvent);
+
+    /**
+     * @Description 中间库批量添加事件
+     *
+     * @author liuwenge
+     * @date 2024/3/18 15:09
+     * @param mdEventList
+     * @return boolean
+     */
+    boolean batchInsertMiddleDatabaseEvent(List<MdEvent> mdEventList);
 }

zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java

@@ -425,20 +425,20 @@ public class DeviceMessageHandler {
         mdDeviceData.setTimeStamp(new Date());
         mdDeviceData.setCreatorUserId("自动存储");
 
-        Map<String, Object> expands = new HashMap<>();
+        Map<String,Object> expands = new HashMap<>();
-        expands.put("rainFall", meteorologicalDetectorData.getRainfall()); //雨量
+        expands.put("rainFall",meteorologicalDetectorData.getRainfall()); //雨量
-        expands.put("windSpeed", meteorologicalDetectorData.getWindSpeed()); //风速
+        expands.put("windDirection",meteorologicalDetectorData.getWindDirection()); //风向
-        expands.put("windDirection", meteorologicalDetectorData.getWindDirection()); //风向
+        expands.put("windSpeed",meteorologicalDetectorData.getWindSpeed()); //风速
-        expands.put("temperature", meteorologicalDetectorData.getTemperature()); //大气温度
+        expands.put("temperature",meteorologicalDetectorData.getTemperature()); //大气温度
-        expands.put("humidity", meteorologicalDetectorData.getHumidity()); //大气湿度
+        expands.put("humidity",meteorologicalDetectorData.getHumidity()); //大气湿度
-        expands.put("airPressure", meteorologicalDetectorData.getAtmosphericPressure()); //数字气压
+        expands.put("airPressure",meteorologicalDetectorData.getAtmosphericPressure()); //气压
-        expands.put("wet", meteorologicalDetectorData.getWetSlipperyCoefficient()); //湿滑
+        expands.put("waterThick",meteorologicalDetectorData.getWaterFilmIceSnowValue()); //水膜厚度
-        expands.put("rainXingTai", meteorologicalDetectorData.getPrecipitationType()); //雨量降水形态
+        expands.put("wet",meteorologicalDetectorData.getWetSlipperyCoefficient()); //湿滑
-        expands.put("visibility", meteorologicalDetectorData.getVisibility()); //能见度
+        expands.put("rainXingTai",meteorologicalDetectorData.getPrecipitationType()); //雨量降水形态
-        expands.put("pathContactLu", meteorologicalDetectorData.getRoadSurfaceTemperature()); //路面温度
+        expands.put("visibility",meteorologicalDetectorData.getVisibility()); //能见度
-        expands.put("pathContactBing", meteorologicalDetectorData.getFreezingPointTemperature()); //冰点温度
+        expands.put("remoteRoadSurfaceTemperature",meteorologicalDetectorData.getRemoteRoadSurfaceTemperature()); //路面温度
-        expands.put("pathContactYan", meteorologicalDetectorData.getSalinityValue()); //路面盐度
+        expands.put("pathContactZhuang",meteorologicalDetectorData.getRemoteRoadSurfaceStatus()); //路面状况
-        expands.put("pathContactZhuang", meteorologicalDetectorData.getRemoteRoadSurfaceStatus()); //路面状况
+
 
         mdDeviceData.setExpands(JSONObject.toJSONString(expands));
 

zc-business/src/main/java/com/zc/business/service/IMiddleDatabaseService.java

@@ -89,4 +89,7 @@ public interface IMiddleDatabaseService
      */
     boolean updateMiddleDatabaseEvent(MdEvent mdEvent);
 
+
+    boolean batchInsertMiddleDatabaseEvent(List<MdEvent> mdEventList);
+
 }

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

@@ -358,92 +358,20 @@ public class DcEventServiceImpl extends ServiceImpl<DcEventMapper, DcEvent> impl
      */
     @Override
     public boolean batchInsertDcEventWarning(List<DcEvent> dcEventList) {
-        for (DcEvent dcEvent : dcEventList) {
 
-            //设置事件Id UUID无下划线格式32
+        boolean flag = dcEventMapper.batchInsertDcEvent(dcEventList);
-            String uuid = dcEvent.getId();
-            int i7 = dcEventMapper.insertDcEvent(dcEvent);
-            if (i7 > 0) {
-                //中间库
-                MdEvent mdEvent = new MdEvent(dcEvent);
-                middleDatabaseService.insertMiddleDatabaseEvent(mdEvent);
-
-                //获取事件类型
-                int eventType = Math.toIntExact(dcEvent.getEventType());
-                switch (eventType) {
-                    //交通事故
-                    case 1:
-                        if (dcEvent.getDcEventAccident() != null) {
-                            dcEvent.getDcEventAccident().setId(uuid);
-                            int i1 = dcEventAccidentMapper.insertDcEventAccident(dcEvent.getDcEventAccident());
-                        }
-
-                        break;
-                    //车辆事故
-                    case 2:
-                        if (dcEvent.getDcEventVehicleAccident() != null) {
-                            dcEvent.getDcEventVehicleAccident().setId(uuid);
-                            int i5 = dcEventVehicleAccidentMapper.insertDcEventVehicleAccident(dcEvent.getDcEventVehicleAccident());
-                        }
-
-                        break;
-                    //交通管制
-                    case 3:
-                        if (dcEvent.getDcEventTrafficControl() != null) {
-                            dcEvent.getDcEventTrafficControl().setId(uuid);
-                            int i6 = dcEventTrafficControlMapper.insertDcEventTrafficControl(dcEvent.getDcEventTrafficControl());
-                        }
-                        break;
-                    //交通拥堵
-                    case 4:
-                        if (dcEvent.getDcEventTrafficCongestion() != null) {
-                            dcEvent.getDcEventTrafficCongestion().setId(uuid);
-                            int i4 = dcEventTrafficCongestionMapper.insertDcEventTrafficCongestion(dcEvent.getDcEventTrafficCongestion());
-                        }
-
-                        break;
-                    //非法上路
-                    case 5:
-                        break;
-                    //路障清除
-                    case 6:
-                        break;
-                    //施工建设
-                    case 7:
-                        if (dcEvent.getDcEventConstruction() != null) {
-                            dcEvent.getDcEventConstruction().setId(uuid);
-                            int i2 = dcEventConstructionMapper.insertDcEventConstruction(dcEvent.getDcEventConstruction());
-                        }
-
-                        break;
-                    //服务区异常
-                    case 8:
-                        if (dcEvent.getDcEventServiceArea() != null) {
-                            dcEvent.getDcEventServiceArea().setId(uuid);
-                            int i3 = dcEventServiceAreaMapper.insertDcEventServiceArea(dcEvent.getDcEventServiceArea());
-                        }
-                        break;
-                    //设施设备隐患
-                    case 9:
-                        break;
-                    //异常天气
-                    case 10:
-                        if (dcEvent.getDcEventAbnormalWeather() != null) {
-                            dcEvent.getDcEventAbnormalWeather().setId(uuid);
-                            int i = dcEventAbnormalWeatherMapper.insertDcEventAbnormalWeather(dcEvent.getDcEventAbnormalWeather());
-                        }
-                        break;
-                    //其他事件
-                    case 11:
-                        break;
-                    //
-                    default:
-                        break;
 
-                }
+        if (flag) {
+            //中间库
+            List<MdEvent> mdEventList = new ArrayList<>();
+            for (DcEvent dcEvent : dcEventList) {
+                MdEvent mdEvent = new MdEvent(dcEvent);
+                mdEventList.add(mdEvent);
             }
+            middleDatabaseService.batchInsertMiddleDatabaseEvent(mdEventList);
         }
-        return true;
+
+        return flag;
     }
 
     /**

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

@@ -153,4 +153,10 @@ public class MiddleDatabaseServiceImpl implements IMiddleDatabaseService {
         }
         return middleDatabaseMapper.updateMiddleDatabaseEvent(mdEvent);
     }
+
+    @Override
+    public boolean batchInsertMiddleDatabaseEvent(List<MdEvent> mdEventList){
+        return middleDatabaseMapper.batchInsertMiddleDatabaseEvent(mdEventList);
+    }
+
 }

zc-business/src/main/resources/mapper/business/DcEventMapper.xml

@@ -544,8 +544,69 @@
                 <if test="isPerceived != null">#{isPerceived},</if>
             </trim>
         </insert>
+    <insert id="batchInsertDcEvent"  useGeneratedKeys="true" keyProperty="id">
+        <foreach collection ="list" item="dcEvent" index= "index" separator =";">
+            insert into dc_event
+            <trim prefix="(" suffix=")" suffixOverrides=",">
+                <if test="dcEvent.id != null">id,</if>
+                <if test="dcEvent.deptId != null">dept_id,</if>
+                <if test="dcEvent.stakeMark != null and dcEvent.stakeMark != ''">stake_mark,</if>
+                <if test="dcEvent.direction != null and dcEvent.direction != ''">direction,</if>
+                <if test="dcEvent.userId != null">user_id,</if>
+                <if test="dcEvent.startTime != null">start_time,</if>
+                <if test="dcEvent.endTime != null">end_time,</if>
+                <if test="dcEvent.estimatedEndTime != null">estimated_end_time,</if>
+                <if test="dcEvent.eventLevel != null">event_level,</if>
+                <if test="dcEvent.eventType != null">event_type,</if>
+                <if test="dcEvent.eventSubclass != null">event_subclass,</if>
+                <if test="dcEvent.eventCause != null">event_cause,</if>
+                <if test="dcEvent.description != null">description,</if>
+                <if test="dcEvent.eventState != null">event_state,</if>
+                <if test="dcEvent.eventSource != null">event_source,</if>
+                <if test="dcEvent.eventNature != null">event_nature,</if>
+                <if test="dcEvent.remark != null">remark,</if>
+                <if test="dcEvent.createTime != null">create_time,</if>
+                <if test="dcEvent.updateTime != null">update_time,</if>
+                <if test="dcEvent.eventSourceTips != null">event_source_tips,</if>
+                <if test="dcEvent.inTunnel != null">in_tunnel,</if>
+                <if test="dcEvent.roadId != null">road_id,</if>
+                <if test="dcEvent.lang != null">lang,</if>
+                <if test="dcEvent.eventTitle != null">event_title,</if>
+                <if test="dcEvent.occurrenceTime != null">occurrence_time,</if>
+                <if test="dcEvent.isPerceived != null">is_perceived,</if>
+            </trim>
+            <trim prefix="values (" suffix=")" suffixOverrides=",">
+                <if test="dcEvent.id != null">#{dcEvent.id},</if>
+                <if test="dcEvent.deptId != null">#{dcEvent.deptId},</if>
+                <if test="dcEvent.stakeMark != null and dcEvent.stakeMark != ''">#{dcEvent.stakeMark},</if>
+                <if test="dcEvent.direction != null and dcEvent.direction != ''">#{dcEvent.direction},</if>
+                <if test="dcEvent.userId != null">#{dcEvent.userId},</if>
+                <if test="dcEvent.startTime != null">#{dcEvent.startTime},</if>
+                <if test="dcEvent.endTime != null">#{dcEvent.endTime},</if>
+                <if test="dcEvent.estimatedEndTime != null">#{dcEvent.estimatedEndTime},</if>
+                <if test="dcEvent.eventLevel != null">#{dcEvent.eventLevel},</if>
+                <if test="dcEvent.eventType != null">#{dcEvent.eventType},</if>
+                <if test="dcEvent.eventSubclass != null">#{dcEvent.eventSubclass},</if>
+                <if test="dcEvent.eventCause != null">#{dcEvent.eventCause},</if>
+                <if test="dcEvent.description != null">#{dcEvent.description},</if>
+                <if test="dcEvent.eventState != null">#{dcEvent.eventState},</if>
+                <if test="dcEvent.eventSource != null">#{dcEvent.eventSource},</if>
+                <if test="dcEvent.eventNature != null">#{dcEvent.eventNature},</if>
+                <if test="dcEvent.remark != null">#{dcEvent.remark},</if>
+                <if test="dcEvent.createTime != null">#{dcEvent.createTime},</if>
+                <if test="dcEvent.updateTime != null">#{dcEvent.updateTime},</if>
+                <if test="dcEvent.eventSourceTips != null">#{dcEvent.eventSourceTips},</if>
+                <if test="dcEvent.inTunnel != null">#{dcEvent.inTunnel},</if>
+                <if test="dcEvent.roadId != null">#{dcEvent.roadId},</if>
+                <if test="dcEvent.lang != null">#{dcEvent.lang},</if>
+                <if test="dcEvent.eventTitle != null">#{dcEvent.eventTitle},</if>
+                <if test="dcEvent.occurrenceTime != null">#{dcEvent.occurrenceTime},</if>
+                <if test="dcEvent.isPerceived != null">#{dcEvent.isPerceived},</if>
+            </trim>
+        </foreach>
+    </insert>
 
-        <update id="updateDcEvent" parameterType="DcEvent">
+    <update id="updateDcEvent" parameterType="DcEvent">
             update dc_event
             <trim prefix="SET" suffixOverrides=",">
                 <if test="deptId != null">dept_id = #{deptId},</if>

zc-business/src/main/resources/mapper/business/MiddleDatabaseMapper.xml

@@ -231,6 +231,92 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         </foreach>
     </insert>
 
+    <insert id="batchInsertMiddleDatabaseEvent">
+        <foreach collection ="list" item="mdEvent" index= "index" separator =";">
+            insert into event
+            <trim prefix="(" suffix=")" suffixOverrides=",">
+                <if test="mdEvent.fusionId != null">fusionId,</if>
+                <if test="mdEvent.eventName != null">event_name,</if>
+                <if test="mdEvent.eventTypeCode != null">event_type_code,</if>
+                <if test="mdEvent.eventDesc != null">event_desc,</if>
+                <if test="mdEvent.occurTime != null">occur_time,</if>
+                <if test="mdEvent.endTime != null">end_time,</if>
+                <if test="mdEvent.stakeNumber != null and mdEvent.stakeNumber != ''">stake_number,</if>
+                <if test="mdEvent.longitude != null">longitude,</if>
+                <if test="mdEvent.latitude != null">latitude,</if>
+                <if test="mdEvent.lane != null">lane,</if>
+                <if test="mdEvent.direction != null and mdEvent.direction != ''">direction,</if>
+                <if test="mdEvent.location != null">location,</if>
+                <if test="mdEvent.eventSourceCode != null">event_source_code,</if>
+                <if test="mdEvent.eventSource != null">event_source,</if>
+                <if test="mdEvent.eventStatus != null">event_status,</if>
+                <if test="mdEvent.eventLevel != null">event_level,</if>
+                <if test="mdEvent.sectionId != null">section_id,</if>
+                <if test="mdEvent.eventTypeCode2 != null">event_type_code2,</if>
+                <if test="mdEvent.eventCause != null">event_cause,</if>
+                <if test="mdEvent.accidentWeather != null">accident_weather,</if>
+                <if test="mdEvent.accidentQueue != null">accident_queue,</if>
+                <if test="mdEvent.congestionPile != null">congestion_pile,</if>
+                <if test="mdEvent.congestionReason != null">congestion_reason,</if>
+                <if test="mdEvent.controlCategory != null">control_category,</if>
+                <if test="mdEvent.controlReason != null">control_reason,</if>
+                <if test="mdEvent.controlReasonType != null">control_reason_type,</if>
+                <if test="mdEvent.controlStation != null">control_station,</if>
+                <if test="mdEvent.controlPile != null">control_pile,</if>
+                <if test="mdEvent.controlStrategy != null">control_strategy,</if>
+                <if test="mdEvent.controlType != null">control_type,</if>
+                <if test="mdEvent.controlVehicleType != null">control_vehicle_type,</if>
+                <if test="mdEvent.creatorUserId != null">CreatorUserId,</if>
+                <if test="mdEvent.lastModificationTime != null">LastModificationTime,</if>
+                <if test="mdEvent.lastModifierUserId != null">LastModifierUserId,</if>
+                <if test="mdEvent.isDeleted != null">IsDeleted,</if>
+                <if test="mdEvent.deleterUserId != null">DeleterUserId,</if>
+                <if test="mdEvent.deletionTime != null">DeletionTime,</if>
+                CreationTime,
+            </trim>
+            <trim prefix="values (" suffix=")" suffixOverrides=",">
+                <if test="mdEvent.fusionId != null">#{mdEvent.fusionId},</if>
+                <if test="mdEvent.eventName != null">#{mdEvent.eventName},</if>
+                <if test="mdEvent.eventTypeCode != null">#{mdEvent.eventTypeCode},</if>
+                <if test="mdEvent.eventDesc != null">#{mdEvent.eventDesc},</if>
+                <if test="mdEvent.occurTime != null">#{mdEvent.occurTime},</if>
+                <if test="mdEvent.endTime != null">#{mdEvent.endTime},</if>
+                <if test="mdEvent.stakeNumber != null and mdEvent.stakeNumber != ''">#{mdEvent.stakeNumber},</if>
+                <if test="mdEvent.longitude != null">#{mdEvent.longitude},</if>
+                <if test="mdEvent.latitude != null">#{mdEvent.latitude},</if>
+                <if test="mdEvent.lane != null">#{mdEvent.lane},</if>
+                <if test="mdEvent.direction != null and mdEvent.direction != ''">#{mdEvent.direction},</if>
+                <if test="mdEvent.location != null">#{mdEvent.location},</if>
+                <if test="mdEvent.eventSourceCode != null">#{mdEvent.eventSourceCode},</if>
+                <if test="mdEvent.eventSource != null">#{mdEvent.eventSource},</if>
+                <if test="mdEvent.eventStatus != null">#{mdEvent.eventStatus},</if>
+                <if test="mdEvent.eventLevel != null">#{mdEvent.eventLevel},</if>
+                <if test="mdEvent.sectionId != null">#{mdEvent.sectionId},</if>
+                <if test="mdEvent.eventTypeCode2 != null">#{mdEvent.eventTypeCode2},</if>
+                <if test="mdEvent.eventCause != null">#{mdEvent.eventCause},</if>
+                <if test="mdEvent.accidentWeather != null">#{mdEvent.accidentWeather},</if>
+                <if test="mdEvent.accidentQueue != null">#{mdEvent.accidentQueue},</if>
+                <if test="mdEvent.congestionPile != null">#{mdEvent.congestionPile},</if>
+                <if test="mdEvent.congestionReason != null">#{mdEvent.congestionReason},</if>
+                <if test="mdEvent.controlCategory != null">#{mdEvent.controlCategory},</if>
+                <if test="mdEvent.controlReason != null">#{mdEvent.controlReason},</if>
+                <if test="mdEvent.controlReasonType != null">#{mdEvent.controlReasonType},</if>
+                <if test="mdEvent.controlStation != null">#{mdEvent.controlStation},</if>
+                <if test="mdEvent.controlPile != null">#{mdEvent.controlPile},</if>
+                <if test="mdEvent.controlStrategy != null">#{mdEvent.controlStrategy},</if>
+                <if test="mdEvent.controlType != null">#{mdEvent.controlType},</if>
+                <if test="mdEvent.controlVehicleType != null">#{mdEvent.controlVehicleType},</if>
+                <if test="mdEvent.creatorUserId != null">#{mdEvent.creatorUserId},</if>
+                <if test="mdEvent.lastModificationTime != null">#{mdEvent.lastModificationTime},</if>
+                <if test="mdEvent.lastModifierUserId != null">#{mdEvent.lastModifierUserId},</if>
+                <if test="mdEvent.isDeleted != null">#{mdEvent.isDeleted},</if>
+                <if test="mdEvent.deleterUserId != null">#{mdEvent.deleterUserId},</if>
+                <if test="mdEvent.deletionTime != null">#{mdEvent.deletionTime},</if>
+                now()
+            </trim>
+        </foreach>
+    </insert>
+
     <update id="updateMiddleDatabaseDeviceInfo" parameterType="MdDevice">
         update device
         <set>