dev

src/main/java/com/its/rota/client/dao/mapper/CenterMapper.java

@@ -8,6 +8,6 @@ import java.util.List;
 @Mapper
 public interface CenterMapper {
 
-    List<TbCenter> selectCenter();
-    List<TbCenter> selectRegionCenter();
+    List<TbCenter> selCenter();
+    List<TbCenter> selRegionCenter();
 }

src/main/java/com/its/rota/client/dao/mapper/IncidentMapper.java

@@ -2,7 +2,10 @@ package com.its.rota.client.dao.mapper;
 
 import org.apache.ibatis.annotations.Mapper;
 
+import java.util.Map;
+
 @Mapper
 public interface IncidentMapper {
-    int deleteRcvIncident();
+    int delRcvIncident();
+    int insRcvIncident(Map<String, Object> obj);
 }

src/main/java/com/its/rota/client/dao/mapper/RcvLogMapper.java

@@ -1,9 +1,13 @@
 package com.its.rota.client.dao.mapper;
 
+import com.its.rota.client.entity.TbRcvLog;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 @Mapper
 public interface RcvLogMapper {
 
-    int deleteRcvLog();
+    int delRcvLog();
+    int insSndLog(@Param("obj") TbRcvLog obj);
+    int insCenterRecv(@Param("obj") TbRcvLog obj);
 }

src/main/java/com/its/rota/client/dao/mapper/TrafficMapper.java

@@ -2,7 +2,10 @@ package com.its.rota.client.dao.mapper;
 
 import org.apache.ibatis.annotations.Mapper;
 
+import java.util.Map;
+
 @Mapper
 public interface TrafficMapper {
-    int deleteRcvLinkTraffic();
+    int delRcvLinkTraffic();
+    int insRcvLinkTraffic(Map<String, Object> obj);
 }

src/main/java/com/its/rota/client/entity/TbRcvLog.java

@@ -0,0 +1,22 @@
+package com.its.rota.client.entity;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@NoArgsConstructor//(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+public class TbRcvLog {
+
+    private String logDate;
+    private String infoKind;
+    private String toCenterId;
+    private String fromCenterId;
+    private String dupKey;
+    private int seq;
+    private int dataCnt;
+
+}

src/main/java/com/its/rota/client/process/dbms/DbmsDataProcess.java

@@ -91,13 +91,13 @@ public class DbmsDataProcess {
                 case DbmsData.DBMS_DATA_LOG_INCIDENT:
                     break;
                 case DbmsData.DBMS_DATA_DELETE_RCV_LINK_TRAFFIC:
-                    result = this.trafficMapper.deleteRcvLinkTraffic();
+                    result = this.trafficMapper.delRcvLinkTraffic();
                     break;
                 case DbmsData.DBMS_DATA_DELETE_RCV_LOG:
-                    result = this.rcvLogMapper.deleteRcvLog();
+                    result = this.rcvLogMapper.delRcvLog();
                     break;
                 case DbmsData.DBMS_DATA_DELETE_RCV_INCIDENT:
-                    result = this.incidentMapper.deleteRcvIncident();
+                    result = this.incidentMapper.delRcvIncident();
                     break;
                 default:
                     result = -1;

src/main/java/com/its/rota/client/repository/ApplicationRepository.java

@@ -42,7 +42,7 @@ public class ApplicationRepository {
 
     private void loadCenterInfo() {
         try {
-            List<TbCenter> lists  = this.mapper.selectCenter();
+            List<TbCenter> lists  = this.mapper.selCenter();
             log.info("ApplicationRepository.loadCenterInfo: {} EA", lists.size());
             for (TbCenter entity : lists) {
                 log.info("ApplicationRepository.loadCenterInfo: {}.", entity);
@@ -59,7 +59,7 @@ public class ApplicationRepository {
         Elapsed elapsed = new Elapsed();
 
         try {
-            List<TbCenter> lists  = this.mapper.selectRegionCenter();
+            List<TbCenter> lists  = this.mapper.selRegionCenter();
             log.info("ApplicationRepository.loadRegionCenterInfo: {} EA", lists.size());
             for (TbCenter entity : lists) {
                 log.info("ApplicationRepository.loadRegionCenterInfo: {}.", entity);

src/main/resources/mybatis/mapper/CenterMapper.xml

@@ -3,7 +3,7 @@
 
 <mapper namespace="com.its.rota.client.dao.mapper.CenterMapper">
 
-    <select id="selectCenter" resultType="com.its.rota.client.entity.TbCenter">
+    <select id="selCenter" resultType="com.its.rota.client.entity.TbCenter">
         <![CDATA[
         SELECT SUBSTR(centerid, 1, 10) as centerid,
                SUBSTR(centerinfo, 1, 20) as centerInfo,
@@ -20,7 +20,7 @@
         ]]>
     </select>
 
-    <select id="selectRegionCenter" resultType="com.its.rota.client.entity.TbCenter" fetchSize="100">
+    <select id="selRegionCenter" resultType="com.its.rota.client.entity.TbCenter" fetchSize="100">
         <![CDATA[
         SELECT SUBSTR(centerid, 1, 10) as centerid,
                SUBSTR(centerinfo, 1, 20) as centerInfo,

src/main/resources/mybatis/mapper/IncidentMapper.xml

@@ -3,11 +3,46 @@
 
 <mapper namespace="com.its.rota.client.dao.mapper.IncidentMapper">
 
-    <delete id="deleteRcvIncident">
+    <delete id="delRcvIncident">
         <![CDATA[
         DELETE FROM RCV_INCIDENT
         WHERE logdate < SYSDATE - 3
         ]]>
     </delete>
 
+    <insert id="insRcvIncident" parameterType="java.util.Map">
+    <![CDATA[
+        INSERT INTO RCV_INCIDENT(TOCENTERID,
+                                 LINK_LINKIDNUMBER,
+                                 LOGDATE,
+                                 FROMCENTERID,
+                                 NODE_NODEIDNUMBER,
+                                 CONTACTORGANIZATIONNAMETEXT,
+                                 DESCRIPTIONTYPEINCIDENTCODE,
+                                 DESCRIPTIONTYPEINCIDENTOTHER,
+                                 INCIDENTVEHICLESINVOLVEDCODE,
+                                 INCIDENTVEHICLESINVOLVEDOTHER,
+                                 INCIDENTSTATUSCODE,
+                                 INCIDENTSTATUSOTHER,
+                                 UPDATETYPECODE,
+                                 UPDATETYPEOTHER,
+                                 SENDYN)
+        VALUES(:rec.szToCenterId,
+               :rec.szLinkNumber,
+               SYSDATE,
+               :rec.szFromCenterId,
+               :rec.szNodeNumber,
+               :rec.szContactOrganizationNameText,
+               :rec.nDescriptionTypeIncidentCode,
+               :rec.szDescriptionTypeIncidentOther,
+               :rec.nIncidentVehiclesInvolvedCode,
+               :rec.szIncidentVehiclesInvolvedOther,
+               :rec.nIncidentStatusCode,
+               :rec.szIncidentStatusOther,
+               :rec.nUpdateTypeCode,
+               :rec.szUpdateTypeOther,
+               'N')
+        ]]>
+    </insert>
+
 </mapper>

src/main/resources/mybatis/mapper/RcvLogMapper.xml

@@ -3,11 +3,27 @@
 
 <mapper namespace="com.its.rota.client.dao.mapper.RcvLogMapper">
 
-    <delete id="deleteRcvLog">
+    <delete id="delRcvLog">
         <![CDATA[
         DELETE FROM RCV_LOG
         WHERE logdate < SYSDATE - 1
         ]]>
     </delete>
 
+    <insert id="insSndLog" parameterType="com.its.rota.client.entity.TbRcvLog">
+        <![CDATA[
+        INSERT INTO SND_LOG(logdate, infokind, tocenterid, dupkey, fromcenterid, datacnt)
+        VALUES(SYSDATE, #{obj.infoKind}, #{obj.toCenterId}, #{obj.dupKey}, #{obj.fromCenterId}, #{obj.dataCnt})
+        ]]>
+--         INSERT INTO RCV_LOG(logdate, infokind, tocenterid, dupkey, fromcenterid, datacnt)
+--         VALUES(SYSDATE, :pLog->szInfoKind, :pLog->szToCenterId, NVL(:pLog->szDupKey, 'DupKey'), :pLog->szFromCenterId, :pLog->DataCnt);
+    </insert>
+
+    <insert id="insCenterRecv" parameterType="com.its.rota.client.entity.TbRcvLog">
+        <![CDATA[
+        INSERT INTO CENTER_RECEIVE@UTISDB(LOGDATE, CENTERID, INFOTYPE, SEQ, DATACNT)
+        VALUES(SYSDATE, #{obj.fromCenterId}, 'R1', #{obj.seq}, #{obj.dataCnt})
+        ]]>
+    </insert>
+
 </mapper>

src/main/resources/mybatis/mapper/TrafficMapper.xml

@@ -3,11 +3,37 @@
 
 <mapper namespace="com.its.rota.client.dao.mapper.TrafficMapper">
 
-    <delete id="deleteRcvLinkTraffic">
+    <delete id="delRcvLinkTraffic">
         <![CDATA[
         DELETE FROM RCV_LINK_TRAFFIC
         WHERE logdate < SYSDATE - 15/1440 -- 15 분전
         ]]>
     </delete>
 
+    <insert id="insRcvLinkTraffic" parameterType="java.util.Map">
+    <![CDATA[
+        INSERT INTO RCV_LINK_TRAFFIC(REGDATE,
+                                     TOCENTERID,
+                                     LINKNUMBER,
+                                     LOGDATE,
+                                     FROMCENTERID,
+                                     SPEEDRATE,
+                                     DENSITYRATE,
+                                     TRAVELTIMEQUANTITY,
+                                     DELAYQUANITY
+        )
+        VALUES(
+        TO_DATE(#{REGDATE}, 'YYYYMMDDHH24MISS'),
+                #{TOCENTERID},
+                #{LINKNUMBER},
+                SYSDATE,
+                #{FROMCENTERID},
+                #{SPEEDRATE},
+                #{DENSITYRATE},
+                #{TRAVELTIMEQUANTITY},
+                #{DELAYQUANITY}
+               )
+        ]]>
+    </insert>
+
 </mapper>