dev

src/main/java/com/its/rota/client/dao/mapper/batch/ItsRotaClientDao.java

@@ -0,0 +1,72 @@
+package com.its.rota.client.dao.mapper.batch;
+
+import com.beanit.its.CurrentLinkState;
+import com.its.app.common.utils.Elapsed;
+import com.its.rota.client.dao.mapper.BatchDaoService;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.ibatis.session.SqlSessionFactory;
+import org.springframework.stereotype.Repository;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+
+@Slf4j
+@Repository
+public class ItsRotaClientDao extends BatchDaoService {
+
+    public ItsRotaClientDao(SqlSessionFactory sqlSessionFactory) {
+        super(sqlSessionFactory);
+        this.serviceName = "ItsRotaClientDao";//this.getClass().getName();
+    }
+
+    public List<HashMap<String, Object>> getRcvLinkTraffic(String regDate, String fromCenterId, String toCenterId, List<CurrentLinkState> req) {
+        List<HashMap<String, Object>> lists = new ArrayList<>();
+        for (CurrentLinkState obj : req) {
+            HashMap<String, Object> param = new HashMap<>();
+
+            String linkNumber = obj.getLinkLinkIdNumber().toString();
+            if (linkNumber == null) {
+                continue;
+            }
+            linkNumber = linkNumber.trim();
+            if (linkNumber.startsWith("T")) {
+                continue;
+            }
+            try {
+                long tmpLinkNumber = Long.parseLong(linkNumber);
+                if (tmpLinkNumber < 1000000000L) {
+                    continue;
+                }
+                if (tmpLinkNumber > 4210000000L) {
+                    continue;
+                }
+            }
+            catch (NumberFormatException e) {
+                log.error("Parse LinkNumber Error: {}", linkNumber);
+                continue;
+            }
+
+            param.put("REGDATE",            regDate);
+            param.put("TOCENTERID",         toCenterId);
+            param.put("LINKNUMBER",         linkNumber);
+            param.put("FROMCENTERID",       fromCenterId);
+            param.put("SPEEDRATE",          obj.getLinkSpeedRate().intValue());
+            param.put("DENSITYRATE",        obj.getLinkDensityRate().intValue());
+            param.put("TRAVELTIMEQUANTITY", obj.getLinkTravelTimeQuantity().intValue());
+            param.put("DELAYQUANITY",       obj.getLinkDelayQuanity().intValue());
+
+            lists.add(param);
+        }
+        return lists;
+    }
+
+    public int insRcvLinkTraffic(String regDate, String fromCenterId, String toCenterId, List<CurrentLinkState> req) {
+        log.info("{}.insRcvLinkTraffic: START. {} EA", this.serviceName, req.size());
+        Elapsed elapsed = new Elapsed();
+        int total = insertBatch("insRcvLinkTraffic", getRcvLinkTraffic(regDate, fromCenterId, toCenterId, req));
+        log.info("{}.insRcvLinkTraffic: ..END. {} EA. {} ms.", this.serviceName, total, elapsed.milliSeconds());
+        return total;
+    }
+
+}

src/main/java/com/its/rota/client/dao/mapper/batch/ItsRotaDao.java

@@ -1,70 +0,0 @@
-package com.its.rota.client.dao.mapper.batch;
-
-import com.its.rota.client.dao.mapper.BatchDaoService;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.ibatis.session.SqlSessionFactory;
-import org.springframework.stereotype.Repository;
-
-@Slf4j
-@Repository
-public class ItsRotaDao extends BatchDaoService {
-
-    public ItsRotaDao(SqlSessionFactory sqlSessionFactory) {
-        super(sqlSessionFactory);
-        this.serviceName = "ItsRotaDao";//this.getClass().getName();
-    }
-//
-//    public List<HashMap<String, Object>> getSttsList(List<IntStatusDto> req) {
-//        List<HashMap<String, Object>> lists = new ArrayList<>();
-//        req.forEach(obj -> {
-//            HashMap<String, Object> param = new HashMap<>();
-//
-//            param.put("REGION_CD",                  obj.REGION_CD);
-//            param.put("INT_NO",                     obj.INT_NO);
-//            param.put("COLLCT_DTIME",               obj.COLLCT_DTIME);
-//            param.put("SYS_COLLCT_DTIME",           obj.SYS_COLLCT_DTIME);
-//            param.put("COMM_ON_OFF_FLAG",           obj.COMM_ON_OFF_FLAG);
-//            param.put("CONTRLR_OPER_MODE_CD",       obj.CONTRLR_OPER_MODE_CD);
-//            param.put("A_RING_PHASE_VAL",           obj.A_RING_PHASE_VAL);
-//            param.put("B_RING_PHASE_VAL",           obj.B_RING_PHASE_VAL);
-//            param.put("SIGLIGHT_TURNOFF_FLAG",      obj.SIGLIGHT_TURNOFF_FLAG);
-//            param.put("SIGLIGHT_BLINK_FLAG",        obj.SIGLIGHT_BLINK_FLAG);
-//            param.put("CONTRLR_MANUAL_FLAG",        obj.CONTRLR_MANUAL_FLAG);
-//            param.put("CONTRLR_TMDIFF_CONTRL_FLAG", obj.CONTRLR_TMDIFF_CONTRL_FLAG);
-//            param.put("MAP_NO",                     obj.MAP_NO);
-//            param.put("INT_SIG_CYCLE_CNT",          obj.INT_SIG_CYCLE_CNT);
-//            param.put("INT_SIG_CYCLE_LEN",          obj.INT_SIG_CYCLE_LEN);
-//            param.put("A_RING_1_PHASE_VAL",         obj.A_RING_1_PHASE_VAL);
-//            param.put("A_RING_2_PHASE_VAL",         obj.A_RING_2_PHASE_VAL);
-//            param.put("A_RING_3_PHASE_VAL",         obj.A_RING_3_PHASE_VAL);
-//            param.put("A_RING_4_PHASE_VAL",         obj.A_RING_4_PHASE_VAL);
-//            param.put("A_RING_5_PHASE_VAL",         obj.A_RING_5_PHASE_VAL);
-//            param.put("A_RING_6_PHASE_VAL",         obj.A_RING_6_PHASE_VAL);
-//            param.put("A_RING_7_PHASE_VAL",         obj.A_RING_7_PHASE_VAL);
-//            param.put("A_RING_8_PHASE_VAL",         obj.A_RING_8_PHASE_VAL);
-//            param.put("B_RING_1_PHASE_VAL",         obj.B_RING_1_PHASE_VAL);
-//            param.put("B_RING_2_PHASE_VAL",         obj.B_RING_2_PHASE_VAL);
-//            param.put("B_RING_3_PHASE_VAL",         obj.B_RING_3_PHASE_VAL);
-//            param.put("B_RING_4_PHASE_VAL",         obj.B_RING_4_PHASE_VAL);
-//            param.put("B_RING_5_PHASE_VAL",         obj.B_RING_5_PHASE_VAL);
-//            param.put("B_RING_6_PHASE_VAL",         obj.B_RING_6_PHASE_VAL);
-//            param.put("B_RING_7_PHASE_VAL",         obj.B_RING_7_PHASE_VAL);
-//            param.put("B_RING_8_PHASE_VAL",         obj.B_RING_8_PHASE_VAL);
-//            param.put("SIMULFLAG",                  obj.SIMULFLAG);
-//            param.put("GROUP_NO",                   obj.GROUP_NO);
-//            param.put("PPC_CONTRL_FLAG",            obj.PPC_CONTRL_FLAG);
-//
-//            lists.add(param);
-//        });
-//        return lists;
-//    }
-//
-//    public int updateStatus(List<IntStatusDto> req) {
-////        log.info("{}.updateStatus: START. {} EA", this.serviceName, req.size());
-////        Elapsed elapsed = new Elapsed();
-//        int total = updateBatch("updateIntPhaseStts", getSttsList(req));
-////        log.info("{}.updateStatus: ..END. {} EA. {} ms.", this.serviceName, total, elapsed.milliSeconds());
-//        return total;
-//    }
-
-}