dwdb pattern add

utic-dwdb-server/src/main/java/com/utic/dwdb/server/UticDwdbServerApplication.java

@@ -2,7 +2,7 @@ package com.utic.dwdb.server;
 
 import com.utic.common.spring.SpringUtils;
 import com.utic.dwdb.server.config.ApplicationConfig;
-import com.utic.dwdb.server.controller.DwdbJobPrcs01DController;
+import com.utic.dwdb.server.controller.DwdbJobPrcs05MController;
 import com.utic.dwdb.server.service.ProcessStateService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.DisposableBean;
@@ -60,8 +60,8 @@ public class UticDwdbServerApplication implements CommandLineRunner, Application
         ProcessStateService processStateService = SpringUtils.getBean(ProcessStateService.class);
         processStateService.processStart();
 
-        DwdbJobPrcs01DController dwdbJobProcControl = SpringUtils.getBean(DwdbJobPrcs01DController.class);
-        dwdbJobProcControl.run();
+        DwdbJobPrcs05MController dwdbJobProcControl = SpringUtils.getBean(DwdbJobPrcs05MController.class);
+//        dwdbJobProcControl.run();
 
         applicationConfig.setStartSchedule(true);
 

utic-dwdb-server/src/main/java/com/utic/dwdb/server/service/DwdbJobPrcs05MService.java

@@ -65,6 +65,10 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
 
         Elapsed tmpelapsed = new Elapsed();
 
+        // 5분 정주기 시간에서 25분 30분 이전 시간을 구한다.
+        String prcsPast25Min = TimeUtils.addMinutes(statTime.getPrcs05Min(), -25);
+        String prcsPast30Min = TimeUtils.addMinutes(statTime.getPrcs05Min(), -30);
+
         // statFitTRFEXE
         int result;
         try {
@@ -76,22 +80,22 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
         }
         try {
             tmpelapsed.reset();
-//            result = this.prcs05MMapper.insertStatLocal12Loc(statTime.getPast25Min(), statTime.getPast30Min());
-//            log.info("[05MIN...] (INS) {}", LogUtils.elapsedLog("STAT_LOCAL(12개지자체)", result, tmpelapsed.milliSeconds()));
+            result = this.prcs05MMapper.insertStatLocal12Loc(prcsPast25Min, prcsPast30Min);
+            log.info("[05MIN...] (INS) {}", LogUtils.elapsedLog("STAT_LOCAL(12개지자체)", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
             log.info("[05MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_LOCAL(12개지자체)", tmpelapsed.milliSeconds()), e.getMessage());
         }
         try {
             tmpelapsed.reset();
-//            result = this.prcs05MMapper.insertStatLocalCapital(statTime.getPast25Min(), statTime.getPast30Min());
-//            log.info("[05MIN...] (INS) {}", LogUtils.elapsedLog("STAT_LOCAL(수도권 지역센터)", result, tmpelapsed.milliSeconds()));
+            result = this.prcs05MMapper.insertStatLocalCapital(prcsPast25Min, prcsPast30Min);
+            log.info("[05MIN...] (INS) {}", LogUtils.elapsedLog("STAT_LOCAL(수도권 지역센터)", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
             log.info("[05MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_LOCAL(수도권 지역센터)", tmpelapsed.milliSeconds()), e.getMessage());
         }
         try {
             tmpelapsed.reset();
-//            result = this.prcs05MMapper.insertStatLocal12Loc(statTime.getPast25Min(), statTime.getPast30Min());
-//            log.info("[05MIN...] (INS) {}", LogUtils.elapsedLog("STAT_LOCAL(통합배포시스템)", result, tmpelapsed.milliSeconds()));
+            result = this.prcs05MMapper.insertStatLocal12Loc(prcsPast25Min, prcsPast30Min);
+            log.info("[05MIN...] (INS) {}", LogUtils.elapsedLog("STAT_LOCAL(통합배포시스템)", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
             log.info("[05MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_LOCAL(통합배포시스템)", tmpelapsed.milliSeconds()), e.getMessage());
         }
@@ -120,8 +124,8 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
         try {
             // LINK_FILTER 표준편차 입력
             tmpelapsed.reset();
-//            result = this.prcs05MMapper.insertLinkFilter(statTime.getPast25Min(), codeValue0.getCodeValue(), codeValue5.getCodeValue());
-//            log.info("[05MIN...] (INS) {}", LogUtils.elapsedLog("LINK_FILTER(표준편차값)", result, tmpelapsed.milliSeconds()));
+            result = this.prcs05MMapper.insertLinkFilter(prcsPast25Min, codeValue0.getCodeValue(), codeValue5.getCodeValue());
+            log.info("[05MIN...] (INS) {}", LogUtils.elapsedLog("LINK_FILTER(표준편차값)", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
             log.info("[05MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("LINK_FILTER(표준편차값)", tmpelapsed.milliSeconds()), e.getMessage());
         }
@@ -132,10 +136,10 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
             log.info("[05MIN...] (UPD) {}: LINK_FILTER 통계 최대최소 필터링 사용", LogUtils.elapsedLog("LINK_FILTER(패턴 필터링)"));
             try {
                 tmpelapsed.reset();
-//                HolidayDto holiday = this.prcs05MMapper.findHoliday(statTime.getPast25Min());
-//                log.info("[05MIN...] (SEL) {}", LogUtils.elapsedLog("HOLIDAY", 1, tmpelapsed.milliSeconds()));
+                HolidayDto holiday = this.prcsPatternMapper.findHoliday(prcsPast25Min);
+                log.info("[05MIN...] (SEL) {}", LogUtils.elapsedLog("HOLIDAY", 1, tmpelapsed.milliSeconds()));
                 
-//                runLinkFilterPatternUpdate(statTime, holiday, codeValue2);
+                runLinkFilterPatternUpdate(prcsPast30Min, holiday, codeValue2);
             } catch (Exception e) {
                 log.info("[05MIN...] (SEL) {}, Exception: {}", LogUtils.elapsedLog("HOLIDAY", tmpelapsed.milliSeconds()), e.getMessage());
             }
@@ -195,7 +199,7 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
             log.info("[05MIN...] (SEL) {}, Exception: {}", LogUtils.elapsedLog("LINK_FILTER(생성일자)", tmpelapsed.milliSeconds()), e.getMessage());
         }
         if (StringUtils.isEmpty(regDate)) {
-//            regDate = statTime.getPast25Min();  // LINK_FILTER 생성일자(MAK_DATE) 없을 경우
+            regDate = prcsPast25Min;  // LINK_FILTER 생성일자(MAK_DATE) 없을 경우
         }
 
         try {
@@ -487,7 +491,7 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
         }
     }
 
-    private void runLinkFilterPatternUpdate(StatTimeDto statTime, HolidayDto holiday, CodeValueDto codeValue2) {
+    private void runLinkFilterPatternUpdate(String prcsPast30Min, HolidayDto holiday, CodeValueDto codeValue2) {
         Elapsed elapsed = new Elapsed();
         String logTable, fromTable;
         if (holiday.getHCnt() > 0) {
@@ -520,8 +524,8 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
         }
 
         try {
-//            int result = this.prcs05MMapper.updateLinkFilterPattern(fromTable, statTime.getPast25Min(), codeValue2.getMinValue(), codeValue2.getMaxValue());
-//            log.info("[05MIN...] (UPD) {}", LogUtils.elapsedLog(logTable+"(패턴 최대최소값 변경)", result, elapsed.milliSeconds()));
+            int result = this.prcs05MMapper.updateLinkFilterPattern(fromTable, prcsPast30Min, codeValue2.getMinValue(), codeValue2.getMaxValue());
+            log.info("[05MIN...] (UPD) {}", LogUtils.elapsedLog(logTable+"(패턴 최대최소값 변경)", result, elapsed.milliSeconds()));
         }
         catch (Exception e) {
             log.info("[05MIN...] (UPD) {}, Exception: {}", LogUtils.elapsedLog(logTable+"(패턴 최대최소값 변경)", elapsed.milliSeconds()), e.getMessage());