dev

src/main/java/com/its/traf/controller/its/TrafPrcs05MController.java

@@ -8,6 +8,7 @@ import com.its.traf.xnet.center.udp.service.TrafficNotifyDataSender;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Controller;
+import org.springframework.util.StopWatch;
 
 @Slf4j
 @Controller
@@ -65,6 +66,10 @@ public class TrafPrcs05MController implements AbstractTrafPrcsController {
             log.error("Previous processing is not completed.");
         }
 
+        StopWatch stopWatch = new StopWatch();
+        stopWatch.start("TrafPrcs05MController");
+        log.info("[TRAFFIC---]                         TrafPrcs05MController: START.");
+
         AppRepository.getInstance().startPrcsJob(eTrafPrcsJob.PRCS_05M_ALL);
 
         // 가공 시작
@@ -106,5 +111,8 @@ public class TrafPrcs05MController implements AbstractTrafPrcsController {
 
         AppRepository.getInstance().endPrcsJob(eTrafPrcsJob.PRCS_05M_ALL, 0, true);
 
+        stopWatch.stop();
+        log.info("[TRAFFIC---]                         TrafPrcs05MController: ..END. {} ms", stopWatch.getTotalTimeMillis());
+
     }
 }

src/main/java/com/its/traf/controller/its/TrafPrcs05MPrepareController.java

@@ -41,7 +41,7 @@ public class TrafPrcs05MPrepareController implements AbstractTrafPrcsController
     @Override
     public void run() {
         StopWatch stopWatch = new StopWatch();
-        stopWatch.start("Prepared Job");
+        stopWatch.start("TrafPrcs05MPrepareController");
         log.info("[PREPARE---]                  TrafPrcs05MPrepareController: START.");
 
         /*

src/main/java/com/its/traf/controller/its/TrafPrcs15MController.java

@@ -8,6 +8,7 @@ import com.its.traf.vo.statistics.voStatistics;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Controller;
+import org.springframework.util.StopWatch;
 
 import java.util.Date;
 
@@ -36,6 +37,11 @@ public class TrafPrcs15MController implements AbstractTrafPrcsController {
 
     @Override
     public void run() {
+
+        StopWatch stopWatch = new StopWatch();
+        stopWatch.start("TrafPrcs15MController");
+        log.info("[TRAFFIC---]                         TrafPrcs15MController: START.");
+
         /**
          * 15분 통계 정보 생성
          */
@@ -52,5 +58,9 @@ public class TrafPrcs15MController implements AbstractTrafPrcsController {
         voStat.setSTAT_FROM(this.fromTime);
         voStat.setSTAT_TO(this.toTime);
         voStat.setDAY_TYPE_CD(weekCd);
+
+        stopWatch.stop();
+        log.info("[TRAFFIC---]                         TrafPrcs15MController: ..END. {} ms", stopWatch.getTotalTimeMillis());
+
     }
 }

src/main/java/com/its/traf/controller/its/TrafPrcs30MController.java

@@ -8,6 +8,7 @@ import com.its.traf.vo.statistics.voStatistics;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Controller;
+import org.springframework.util.StopWatch;
 
 import java.util.Date;
 
@@ -36,6 +37,11 @@ public class TrafPrcs30MController implements AbstractTrafPrcsController {
 
     @Override
     public void run() {
+
+        StopWatch stopWatch = new StopWatch();
+        stopWatch.start("TrafPrcs30MController");
+        log.info("[TRAFFIC---]                         TrafPrcs30MController: START.");
+
         /**
          * 30분 통계 정보 생성
          */
@@ -52,5 +58,9 @@ public class TrafPrcs30MController implements AbstractTrafPrcsController {
         voStat.setSTAT_FROM(this.fromTime);
         voStat.setSTAT_TO(this.toTime);
         voStat.setDAY_TYPE_CD(weekCd);
+
+        stopWatch.stop();
+        log.info("[TRAFFIC---]                         TrafPrcs30MController: ..END. {} ms", stopWatch.getTotalTimeMillis());
+
     }
 }

src/main/java/com/its/traf/controller/its/TrafPrcsDDController.java

@@ -12,6 +12,7 @@ import com.its.traf.vo.statistics.voStatistics;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Controller;
+import org.springframework.util.StopWatch;
 
 import java.util.Date;
 
@@ -40,6 +41,11 @@ public class TrafPrcsDDController implements AbstractTrafPrcsController {
 
     @Override
     public void run() {
+
+        StopWatch stopWatch = new StopWatch();
+        stopWatch.start("TrafPrcsDDController");
+        log.info("[TRAFFIC---]                          TrafPrcsDDController: START.");
+
         /**
          * 일 통계 정보 생성
          */
@@ -68,5 +74,9 @@ public class TrafPrcsDDController implements AbstractTrafPrcsController {
         this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_INCD_SECT_STAT_DD_CREATE, false, voStat, 1));
         // 돌발 유형별 일 통계
         this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_INCD_TYPE_STAT_DD_CREATE, false, voStat, 1));
+
+        stopWatch.stop();
+        log.info("[TRAFFIC---]                          TrafPrcsDDController: ..END. {} ms", stopWatch.getTotalTimeMillis());
+
     }
 }

src/main/java/com/its/traf/controller/its/TrafPrcsHHController.java

@@ -12,6 +12,7 @@ import com.its.traf.vo.statistics.voStatistics;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Controller;
+import org.springframework.util.StopWatch;
 
 import java.util.Date;
 
@@ -40,6 +41,11 @@ public class TrafPrcsHHController implements AbstractTrafPrcsController {
 
     @Override
     public void run() {
+
+        StopWatch stopWatch = new StopWatch();
+        stopWatch.start("TrafPrcsHHController");
+        log.info("[TRAFFIC---]                          TrafPrcsHHController: START.");
+
         /**
          * 시간 통계 정보 생성
          */
@@ -62,5 +68,9 @@ public class TrafPrcsHHController implements AbstractTrafPrcsController {
 
         AppRepository.getInstance().startStatJob(eTrafStatJob.STAT_ROAD_HH);
         this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_ROAD_STAT_HH_CREATE, false, voStat, 1));
+
+        stopWatch.stop();
+        log.info("[TRAFFIC---]                          TrafPrcsHHController: ..END. {} ms", stopWatch.getTotalTimeMillis());
+
     }
 }

src/main/java/com/its/traf/controller/its/TrafPrcsMNController.java

@@ -12,6 +12,7 @@ import com.its.traf.vo.statistics.voStatistics;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Controller;
+import org.springframework.util.StopWatch;
 
 import java.util.Date;
 
@@ -40,6 +41,11 @@ public class TrafPrcsMNController implements AbstractTrafPrcsController {
 
     @Override
     public void run() {
+
+        StopWatch stopWatch = new StopWatch();
+        stopWatch.start("TrafPrcsMNController");
+        log.info("[TRAFFIC---]                          TrafPrcsMNController: START.");
+
         /**
          * 월 통계 정보 생성
          */
@@ -67,5 +73,9 @@ public class TrafPrcsMNController implements AbstractTrafPrcsController {
         this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_INCD_SECT_STAT_MN_CREATE, false, voStat, 1));
         // 돌발 유형별 일 통계
         this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_INCD_TYPE_STAT_MN_CREATE, false, voStat, 1));
+
+        stopWatch.stop();
+        log.info("[TRAFFIC---]                          TrafPrcsMNController: ..END. {} ms", stopWatch.getTotalTimeMillis());
+
     }
 }

src/main/java/com/its/traf/controller/its/TrafPrcsYYController.java

@@ -12,6 +12,7 @@ import com.its.traf.vo.statistics.voStatistics;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Controller;
+import org.springframework.util.StopWatch;
 
 import java.util.Date;
 
@@ -40,6 +41,11 @@ public class TrafPrcsYYController implements AbstractTrafPrcsController {
 
     @Override
     public void run() {
+
+        StopWatch stopWatch = new StopWatch();
+        stopWatch.start("TrafPrcsYYController");
+        log.info("[TRAFFIC---]                          TrafPrcsYYController: START.");
+
         /**
          * 년 통계 정보 생성
          */
@@ -62,5 +68,9 @@ public class TrafPrcsYYController implements AbstractTrafPrcsController {
 
         AppRepository.getInstance().startStatJob(eTrafStatJob.STAT_ROAD_YY);
         this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_ROAD_STAT_YY_CREATE, false, voStat, 1));
+
+        stopWatch.stop();
+        log.info("[TRAFFIC---]                          TrafPrcsYYController: ..END. {} ms", stopWatch.getTotalTimeMillis());
+
     }
 }

src/main/java/com/its/traf/scheduler/TrafPrcsSchedulerTask.java

@@ -19,7 +19,7 @@ public class TrafPrcsSchedulerTask {
     private final TrafPrcs05MPrepareController trafPrcs05MPrepareController;
     private final TrafPrcs05MController trafPrcs05MController;
     private final TrafPrcs15MController trafPrcs15MController;
-    private final TrafPrcs15MController trafPrcs30MController;
+    private final TrafPrcs30MController trafPrcs30MController;
     private final TrafPrcsHHController trafPrcsHHController;
     private final TrafPrcsDDController trafPrcsDDController;
     private final TrafPrcsMNController trafPrcsMNController;

src/main/java/com/its/traf/scheduler/UnitSystSchedulerTask.java

@@ -34,10 +34,7 @@ public class UnitSystSchedulerTask {
         //Elapsed elapsed = new Elapsed();
         //log.info("              UnitSystSchedule: start. {}", Thread.currentThread().getName());
         // 1. 프로세스 상태정보 업데이트
-        boolean insHs = this.unitSystService.updateUnitSystStts(true);
-        if (insHs) {
-            this.unitSystService.loadMaster();
-        }
+        this.unitSystService.updateUnitSystStts(true);
         //log.info("              UnitSystSchedule: ..end. {} ms. {}", elapsed.milliSeconds(), Thread.currentThread().getName());
     }
 

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

@@ -95,7 +95,7 @@ public class UnitSystService {
         }
     }
 
-    public boolean updateUnitSystStts(boolean isRun) {
+    public void updateUnitSystStts(boolean isRun) {
         String keyData = "unit";
         MDC.put("id", keyData);
         boolean insHs = false;
@@ -125,6 +125,5 @@ public class UnitSystService {
         }
         MDC.remove(keyData);
         MDC.clear();
-        return insHs;
     }
 }