dev

evps-comm-server/src/main/java/com/evps/comm/server/dao/mapper/EvpsServiceMapper.java

@@ -13,6 +13,7 @@ public interface EvpsServiceMapper {
     int insertEvpService(@Param("obj") KafkaEvpsServiceDto obj);
     int updateEvpService(@Param("obj") KafkaEvpsServiceDto obj);
     int insertEvpEvent(@Param("obj") KafkaEvpsEventDto obj);
+    int insertEvpEventCurr(@Param("obj") KafkaEvpsEventDto obj);
     int insertEvpRoute(Map<String, Object> obj);
     int insertEvpNode(Map<String, Object> obj);
     int insertEvpPhase(Map<String, Object> obj);

evps-comm-server/src/main/java/com/evps/comm/server/process/dbms/DbmsDataProcess.java

@@ -113,6 +113,13 @@ public class DbmsDataProcess {
                 case DbmsData.DBMS_DATA_INS_EVENT:
                     typeDesc = "DBMS_DATA_INS_EVENT";
                     KafkaEvpsEventDto event = (KafkaEvpsEventDto)data.getData();
+                    try {
+                        result = this.serviceMapper.insertEvpEventCurr(event);
+                    }
+                    catch (Exception e) {
+                        log.error("DBMS_DATA_INS_EVENT_CURR: [{}]. {}", center.getLogKey(), event);
+                        log.error("DBMS_DATA_INS_EVENT_CURR: [{}]. Exception: {}\r\n", center.getLogKey(), e.toString());
+                    }
                     try {
                         result = this.serviceMapper.insertEvpEvent(event);
                     }

evps-comm-server/src/main/resources/mybatis/mapper/EvpsServiceMapper.xml

@@ -65,6 +65,33 @@
         ]]>
     </insert>
 
+    <insert id="insertEvpEventCurr" parameterType="com.evps.common.kafka.dto.KafkaEvpsEventDto">
+    <![CDATA[
+        INSERT INTO tb_evp_event_curr (service_id,
+                                       clct_dt,
+                                       event_cd,
+                                       cur_lat,
+                                       cur_lng,
+                                       cur_spd,
+                                       rem_dist)
+        VALUES ( #{obj.serviceId},
+                 current_timestamp(3),
+                 #{obj.eventCd},
+                 #{obj.curLat},
+                 #{obj.curLng},
+                 #{obj.curSpd},
+                 #{obj.remDist}
+               )
+            ON DUPLICATE KEY UPDATE
+                 clct_dt  = current_timestamp(3),
+                 event_cd = #{obj.eventCd},
+                 cur_lat  = #{obj.curLat},
+                 cur_lng  = #{obj.curLng},
+                 cur_spd  = #{obj.curSpd},
+                 rem_dist = #{obj.remDist}
+        ]]>
+    </insert>
+
     <insert id="insertEvpRoute" parameterType="java.util.Map">
     <![CDATA[
         INSERT INTO tb_evp_route (service_id,