second commit

src/main/java/com/its/dsrc/dao/mapper/RseStatMapper.java

@@ -7,6 +7,6 @@ import org.apache.ibatis.annotations.Param;
 @Mapper
 public interface RseStatMapper {
 
-    int CRT_TB_RSE_OBU_CLCT_HH_STAT(@Param("prcs") voStatisticsTime paramStat);
-    int CRT_TB_RSE_OBU_CLCT_DD_STAT(@Param("prcs") voStatisticsTime paramStat);
+    int CRT_TB_RSE_OBU_CLCT_STAT_HH(@Param("prcs") voStatisticsTime paramStat);
+    int CRT_TB_RSE_OBU_CLCT_STAT_DD(@Param("prcs") voStatisticsTime paramStat);
 }

src/main/java/com/its/dsrc/scheduler/SchedulerTask.java

@@ -89,12 +89,12 @@ public class SchedulerTask {
 
             if (its.isStatHour()) {
                 // 매시 5분 가공완료후 1시간 통계
-                this.statisticsServices.CRT_TB_RSE_OBU_CLCT_HH_STAT(its.getStatHourTime(), its.getStatHourTime(), its.getStatHourTo());
+                this.statisticsServices.CRT_TB_RSE_OBU_CLCT_STAT_HH(its.getStatHourTime(), its.getStatHourTime(), its.getStatHourTo());
             }
 
             if (its.isStatDay()) {
                 // 00시 10분 가공이 끝나면 이전일의 통계 정보를 가공.
-                this.statisticsServices.CRT_TB_RSE_OBU_CLCT_DD_STAT(its.getStatDayFrom(), its.getStatDayFrom(), its.getStatDayTo());
+                this.statisticsServices.CRT_TB_RSE_OBU_CLCT_STAT_DD(its.getStatDayFrom(), its.getStatDayFrom(), its.getStatDayTo());
             }
             its.setProcessing(false);
         }

src/main/java/com/its/dsrc/service/StatisticsServices.java

@@ -31,25 +31,25 @@ public class StatisticsServices {
     }
 
     @Async("statisticsExecutor")
-    public void CRT_TB_RSE_OBU_CLCT_HH_STAT(String statDt, String fromDt, String toDt) {
+    public void CRT_TB_RSE_OBU_CLCT_STAT_HH(String statDt, String fromDt, String toDt) {
         MDC.put("id", logKey);
         Elapsed elapsed = new Elapsed();
         voStatisticsTime statTime = new voStatisticsTime(statDt, fromDt, toDt);
-        log.info("CRT_TB_RSE_OBU_CLCT_HH_STAT :: start. [{}], {}", statTime.toString(), Thread.currentThread().getName());
-        this.statMapper.CRT_TB_RSE_OBU_CLCT_HH_STAT(statTime);
-        log.info("CRT_TB_RSE_OBU_CLCT_HH_STAT :: ..end. [{}], {} ms. {}", statTime.toString(), elapsed.milliSeconds(), Thread.currentThread().getName());
+        log.info("CRT_TB_RSE_OBU_CLCT_STAT_HH :: start. [{}], {}", statTime.toString(), Thread.currentThread().getName());
+        this.statMapper.CRT_TB_RSE_OBU_CLCT_STAT_HH(statTime);
+        log.info("CRT_TB_RSE_OBU_CLCT_STAT_HH :: ..end. [{}], {} ms. {}", statTime.toString(), elapsed.milliSeconds(), Thread.currentThread().getName());
         MDC.remove(logKey);
         MDC.clear();
     }
 
     @Async("statisticsExecutor")
-    public void CRT_TB_RSE_OBU_CLCT_DD_STAT(String statDt, String fromDt, String toDt) {
+    public void CRT_TB_RSE_OBU_CLCT_STAT_DD(String statDt, String fromDt, String toDt) {
         MDC.put("id", logKey);
         Elapsed elapsed = new Elapsed();
         voStatisticsTime statTime = new voStatisticsTime(statDt, fromDt, toDt);
-        log.info("CRT_TB_RSE_OBU_CLCT_DD_STAT :: start. [{}], {}", statTime.toString(), Thread.currentThread().getName());
-        this.statMapper.CRT_TB_RSE_OBU_CLCT_DD_STAT(statTime);
-        log.info("CRT_TB_RSE_OBU_CLCT_DD_STAT :: ..end. [{}], {} ms. {}", statTime.toString(), elapsed.milliSeconds(), Thread.currentThread().getName());
+        log.info("CRT_TB_RSE_OBU_CLCT_STAT_DD :: start. [{}], {}", statTime.toString(), Thread.currentThread().getName());
+        this.statMapper.CRT_TB_RSE_OBU_CLCT_STAT_DD(statTime);
+        log.info("CRT_TB_RSE_OBU_CLCT_STAT_DD :: ..end. [{}], {} ms. {}", statTime.toString(), elapsed.milliSeconds(), Thread.currentThread().getName());
         MDC.remove(logKey);
         MDC.clear();
     }

src/main/java/com/its/dsrc/service/UnitSystService.java

@@ -37,7 +37,7 @@ public class UnitSystService {
     private final TbUnitSystStts unitSystStts = TbUnitSystStts.builder().build();
 
     private String processId;
-    private int sttsMin;
+    private int historyMin;
     public static String _srcIpAddr;
 
     @PostConstruct
@@ -45,6 +45,7 @@ public class UnitSystService {
         log.info("[INIT...] UnitSystService.init: start.");
         ProcessConfig processConfig = (ProcessConfig) AppUtils.getBean(ProcessConfig.class);
         this.processId = processConfig.getId();
+        this.historyMin = -1;
 
         try {
             InetAddress local = InetAddress.getLocalHost();
@@ -102,9 +103,9 @@ public class UnitSystService {
         boolean insHs = false;
         Calendar cal = Calendar.getInstance();
         int min = cal.get(Calendar.MINUTE);
-        if ((min % 5) == 0) {
+        if ((min % 5) == 0 && this.historyMin != min) {
             insHs = true;
-            this.sttsMin = min;
+            this.historyMin = min;
         }
 
         String SYST_STTS_CD = isRun ? "SPS1" : "SPS3";

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

@@ -3,9 +3,9 @@
 
 <mapper namespace="com.its.dsrc.dao.mapper.RseStatMapper">
 
-    <insert id="CRT_TB_RSE_OBU_CLCT_HH_STAT" parameterType="com.its.dsrc.vo.voStatisticsTime">
+    <insert id="CRT_TB_RSE_OBU_CLCT_STAT_HH" parameterType="com.its.dsrc.vo.voStatisticsTime">
     <![CDATA[
-		INSERT INTO TB_RSE_OBU_CLCT_HH_STAT (STAT_DT,
+		INSERT INTO TB_RSE_OBU_CLCT_STAT_HH (STAT_DT,
                                              RSE_CTLR_NMBR,
 		                                     DAY_TYPE_CD,
 		                                     CLCT_NUM
@@ -22,9 +22,9 @@
     ]]>
     </insert>
 
-    <insert id="CRT_TB_RSE_OBU_CLCT_DD_STAT" parameterType="com.its.dsrc.vo.voStatisticsTime">
+    <insert id="CRT_TB_RSE_OBU_CLCT_STAT_DD" parameterType="com.its.dsrc.vo.voStatisticsTime">
     <![CDATA[
-		INSERT INTO TB_RSE_OBU_CLCT_DD_STAT (STAT_DT,
+		INSERT INTO TB_RSE_OBU_CLCT_STAT_DD (STAT_DT,
                                              RSE_CTLR_NMBR,
 		                                     DAY_TYPE_CD,
 		                                     CLCT_NUM
@@ -33,7 +33,7 @@
                 RSE_CTLR_NMBR    AS RSE_CTLR_NMBR,
 		        MIN(DAY_TYPE_CD) AS DAY_TYPE_CD,
 		        SUM(CLCT_NUM)    AS CLCT_NUM
-		  FROM TB_RSE_OBU_CLCT_HH_STAT
+		  FROM TB_RSE_OBU_CLCT_STAT_HH
 		 WHERE STAT_DT BETWEEN #{prcs.FROM_DT} AND #{prcs.TO_DT}                               
 		 GROUP BY RSE_CTLR_NMBR
     ]]>
@@ -47,7 +47,7 @@
                         RSE_CTLR_NMBR    AS RSE_CTLR_NMBR,
                         MIN(DAY_TYPE_CD) AS DAY_TYPE_CD,
                         SUM(CLCT_NUM)    AS CLCT_NUM
-                FROM TB_RSE_OBU_CLCT_HH_STAT
+                FROM TB_RSE_OBU_CLCT_STAT_HH
                 WHERE STAT_DT = #{prcs.STAT_DT}
                 GROUP BY RSE_CTLR_NMBR ) M
             ON (L.STAT_DT = M.STAT_DT AND L.RSE_CTLR_NMBR = M.RSE_CTLR_NMBR)