dwdb pattern add

utic-common/src/main/java/com/utic/common/utils/TimeUtils.java

@@ -23,8 +23,7 @@ public class TimeUtils {
     public static void sleep(long delay) {
         try {
             TimeUnit.MILLISECONDS.sleep(delay);
-        }
-        catch (InterruptedException e) {
+        } catch (InterruptedException e) {
 //            Thread.currentThread().interrupt();
         }
     }

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

@@ -85,8 +85,7 @@ public class UticDwdbServerApplication implements CommandLineRunner, Application
 
                 ProcessStateService processStateService = SpringUtils.getBean(ProcessStateService.class);
                 processStateService.processStop();
-            }
-            catch (Exception e) {
+            } catch (Exception e) {
                 log.error("**    Application Terminated: {}", e.getMessage());
             }
             log.error("************************************************************************************");

utic-dwdb-server/src/main/java/com/utic/dwdb/server/dao/mapper/DwdbJobPrcsTablePartMapper.java

@@ -0,0 +1,22 @@
+package com.utic.dwdb.server.dao.mapper;
+
+import com.utic.dwdb.server.dto.*;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+@Mapper
+public interface DwdbJobPrcsTablePartMapper {
+
+    TablePartMonthDto findTablePartMonth();
+    TablePartMonthDto findTablePartDelMonth(@Param("savePeriod") String savePeriod);
+    List<TablePartInfoDto> findAllTablePartInfo();
+    TablePartCountDto findTablePartCount(@Param("partitionName") String partitionName);
+    TablePartCountDto findTablePartExist(@Param("tableName") String tableName, @Param("partitionName") String partitionName);
+
+    int alterAddPartitionByDate(@Param("tableName") String tableName, @Param("partitionName") String partitionName, @Param("lessThan") String lessThan);
+    int alterAddPartition(@Param("tableName") String tableName, @Param("partitionName") String partitionName, @Param("lessThan") String lessThan);
+    int alterDropPartition(@Param("tableName") String tableName, @Param("partitionName") String partitionName);
+
+}

utic-dwdb-server/src/main/java/com/utic/dwdb/server/dto/TablePartCountDto.java

@@ -0,0 +1,19 @@
+package com.utic.dwdb.server.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+
+@Data
+@Builder
+@NoArgsConstructor//(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+public class TablePartCountDto implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    private Integer partitionCount;
+
+}

utic-dwdb-server/src/main/java/com/utic/dwdb/server/dto/TablePartInfoDto.java

@@ -0,0 +1,25 @@
+package com.utic.dwdb.server.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+
+@Data
+@Builder
+@NoArgsConstructor//(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+public class TablePartInfoDto implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    private String tableName;
+    private String executeYn;
+    private String backupYn;
+    private Integer savePeriod;
+    private String backupLocation;
+    private String partitionType;
+    private Integer partitionLen;
+
+}

utic-dwdb-server/src/main/java/com/utic/dwdb/server/dto/TablePartMonthDto.java

@@ -0,0 +1,20 @@
+package com.utic.dwdb.server.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+
+@Data
+@Builder
+@NoArgsConstructor//(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+public class TablePartMonthDto implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    private String makeMonth;
+    private Integer partMonth;
+
+}

utic-dwdb-server/src/main/java/com/utic/dwdb/server/scheduler/ApplicationScheduler.java

@@ -25,8 +25,7 @@ public class ApplicationScheduler {
     public void updateProcessState() {
         try {
             this.processStateService.processRunning();
-        }
-        catch(Exception e) {
+        } catch(Exception e) {
             log.error("ApplicationScheduler.updateProcessState: Exception {}", e.getMessage());
         }
     }

utic-dwdb-server/src/main/java/com/utic/dwdb/server/scheduler/DwdbJobPrcsScheduler.java

@@ -27,8 +27,7 @@ public class DwdbJobPrcsScheduler {
     private void runJob(AbstractProcessController job, String jobName) {
         try {
             job.run();
-        }
-        catch(Exception e) {
+        } catch(Exception e) {
             log.error("[CRONJOB] DwdbJobPrcsScheduler: schedule job run failed: {}, {}", jobName, e.getMessage());
         }
     }

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

@@ -26,8 +26,7 @@ public class DwdbJobPrcs01DService implements AbstractProcessService {
 
         try {
             return this.dwdbJobMapper.findStatTime();
-        }
-        catch (Exception e) {
+        } catch (Exception e) {
             log.error("[01DAY...] (SEL) {}: Exception: {}", LogUtils.elapsedLog("initialize.findStatTime"), e.getMessage());
             return null;
         }
@@ -60,7 +59,7 @@ public class DwdbJobPrcs01DService implements AbstractProcessService {
             result = this.prcs01DMapper.insertStatDayCenter(prcsDay);
             log.info("[01DAY...] (INS) {}", LogUtils.elapsedLog("STAT_DAY_CENTER", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_DAY_CENTER", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_DAY_CENTER", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -69,7 +68,7 @@ public class DwdbJobPrcs01DService implements AbstractProcessService {
             result = this.prcs01DMapper.insertStatDay12Loc(prcsDay);
             log.info("[01DAY...] (INS) {}", LogUtils.elapsedLog("STAT_DAY_12LOC", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_DAY_12LOC", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_DAY_12LOC", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -78,7 +77,7 @@ public class DwdbJobPrcs01DService implements AbstractProcessService {
             result = this.prcs01DMapper.insertStatDayExw(prcsDay);
             log.info("[01DAY...] (INS) {}", LogUtils.elapsedLog("STAT_DAY_EXW", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_DAY_EXW", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_DAY_EXW", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -87,7 +86,7 @@ public class DwdbJobPrcs01DService implements AbstractProcessService {
             result = this.prcs01DMapper.insertStatDayLoc(prcsDay);
             log.info("[01DAY...] (INS) {}", LogUtils.elapsedLog("STAT_DAY_LOC", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_DAY_LOC", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_DAY_LOC", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -96,7 +95,7 @@ public class DwdbJobPrcs01DService implements AbstractProcessService {
             result = this.prcs01DMapper.insertStatDayObeLoc(prcsDay);
             log.info("[01DAY...] (INS) {}", LogUtils.elapsedLog("STAT_DAY_OBELOC", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_DAY_OBELOC", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_DAY_OBELOC", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -105,7 +104,7 @@ public class DwdbJobPrcs01DService implements AbstractProcessService {
             result = this.prcs01DMapper.insertDmCenterFilter();
             log.info("[01DAY...] (INS) {}", LogUtils.elapsedLog("DM_CENTER_FILTER", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("DM_CENTER_FILTER", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("DM_CENTER_FILTER", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         processingMonth(statTime);
@@ -134,7 +133,7 @@ public class DwdbJobPrcs01DService implements AbstractProcessService {
             result = this.prcsMonthMapper.insertStatMonthCenter();
             log.info("[01DAY...] (INS) {}", LogUtils.elapsedLog("STAT_MON_CENTER", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_MON_CENTER", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_MON_CENTER", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -143,7 +142,7 @@ public class DwdbJobPrcs01DService implements AbstractProcessService {
             result = this.prcsMonthMapper.insertStatMonth12Loc();
             log.info("[01DAY...] (INS) {}", LogUtils.elapsedLog("STAT_MON_12LOC", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_MON_12LOC", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_MON_12LOC", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -152,7 +151,7 @@ public class DwdbJobPrcs01DService implements AbstractProcessService {
             result = this.prcsMonthMapper.insertStatMonthExw();
             log.info("[01DAY...] (INS) {}", LogUtils.elapsedLog("STAT_MON_EXW", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_MON_EXW", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_MON_EXW", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -161,7 +160,7 @@ public class DwdbJobPrcs01DService implements AbstractProcessService {
             result = this.prcsMonthMapper.insertStatMonthLoc();
             log.info("[01DAY...] (INS) {}", LogUtils.elapsedLog("STAT_MON_LOC", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_MON_LOC", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_MON_LOC", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -170,7 +169,7 @@ public class DwdbJobPrcs01DService implements AbstractProcessService {
             result = this.prcsMonthMapper.insertStatMonthObeLoc();
             log.info("[01DAY...] (INS) {}", LogUtils.elapsedLog("STAT_MON_OBELOC", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_MON_OBELOC", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[01DAY...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_MON_OBELOC", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         log.info("[01DAY...] ..... {}", LogUtils.elapsedLog(processName + " 종료", elapsed.milliSeconds()));

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

@@ -28,8 +28,7 @@ public class DwdbJobPrcs01HService implements AbstractProcessService {
 
         try {
             return this.dwdbJobMapper.findStatTime();
-        }
-        catch (Exception e) {
+        } catch (Exception e) {
             log.error("[1HOUR...] (SEL) {}: Exception: {}", LogUtils.elapsedLog("initialize.findStatTime"), e.getMessage());
             return null;
         }
@@ -63,7 +62,7 @@ public class DwdbJobPrcs01HService implements AbstractProcessService {
             result = this.prcs01HMapper.insertStatHourCenter(pastStat01Hour, pastStat02Hour);
             log.info("[1HOUR...] (INS) {}", LogUtils.elapsedLog("STAT_HOUR_CENTER", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[1HOUR...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_HOUR_CENTER", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[1HOUR...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_HOUR_CENTER", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -72,7 +71,7 @@ public class DwdbJobPrcs01HService implements AbstractProcessService {
             result = this.prcs01HMapper.insertStatHour12Loc(pastStat01Hour, pastStat02Hour);
             log.info("[1HOUR...] (INS) {}", LogUtils.elapsedLog("STAT_HOUR_12LOC", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[1HOUR...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_HOUR_12LOC", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[1HOUR...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_HOUR_12LOC", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -81,7 +80,7 @@ public class DwdbJobPrcs01HService implements AbstractProcessService {
             result = this.prcs01HMapper.insertStatHourExw(pastStat01Hour, pastStat02Hour);
             log.info("[1HOUR...] (INS) {}", LogUtils.elapsedLog("STAT_HOUR_EXW", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[1HOUR...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_HOUR_EXW", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[1HOUR...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_HOUR_EXW", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -90,7 +89,7 @@ public class DwdbJobPrcs01HService implements AbstractProcessService {
             result = this.prcs01HMapper.insertStatHourLoc(pastStat01Hour, pastStat02Hour);
             log.info("[1HOUR...] (INS) {}", LogUtils.elapsedLog("STAT_HOUR_LOC", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[1HOUR...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_HOUR_LOC", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[1HOUR...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_HOUR_LOC", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -99,7 +98,7 @@ public class DwdbJobPrcs01HService implements AbstractProcessService {
             result = this.prcs01HMapper.insertStatHourObeLoc(pastStat01Hour, pastStat02Hour);
             log.info("[1HOUR...] (INS) {}", LogUtils.elapsedLog("STAT_HOUR_OBELOC", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[1HOUR...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_HOUR_OBELOC", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[1HOUR...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_HOUR_OBELOC", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -108,7 +107,7 @@ public class DwdbJobPrcs01HService implements AbstractProcessService {
             result = this.prcs01HMapper.insertDmTrafficCenter(pastStat01Hour, pastStat02Hour);
             log.info("[1HOUR...] (INS) {}", LogUtils.elapsedLog("DM_TRAFFIC_INCIDENT", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[1HOUR...] (INS) {}, Exception: {}", LogUtils.elapsedLog("DM_TRAFFIC_INCIDENT", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[1HOUR...] (INS) {}, Exception: {}", LogUtils.elapsedLog("DM_TRAFFIC_INCIDENT", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         initializePattern();
@@ -123,9 +122,8 @@ public class DwdbJobPrcs01HService implements AbstractProcessService {
         try {
             pattern = this.prcsPatternMapper.findPatternDay();
             log.info("[1HOUR...] (SEL) {}", LogUtils.elapsedLog("PATTERN DAY", 1, elapsed.milliSeconds()));
-        }
-        catch (Exception e) {
-            log.info("[1HOUR...] (SEL) {}, initializePattern, Exception: {}", LogUtils.elapsedLog("PATTERN DAY", elapsed.milliSeconds()), e.getMessage());
+        } catch (Exception e) {
+            log.error("[1HOUR...] (SEL) {}, initializePattern, Exception: {}", LogUtils.elapsedLog("PATTERN DAY", elapsed.milliSeconds()), e.getMessage());
             return;
         }
 
@@ -157,7 +155,7 @@ public class DwdbJobPrcs01HService implements AbstractProcessService {
             return patternJobLog;
         }
         catch (Exception e) {
-            log.info("[1HOUR...] (SEL) {}, findPatternJobLog, Exception: {}", LogUtils.elapsedLog("PATN_JOB_LOG", elapsed.milliSeconds()), e.getMessage());
+            log.error("[1HOUR...] (SEL) {}, findPatternJobLog, Exception: {}", LogUtils.elapsedLog("PATN_JOB_LOG", elapsed.milliSeconds()), e.getMessage());
             return null;
         }
     }
@@ -169,7 +167,7 @@ public class DwdbJobPrcs01HService implements AbstractProcessService {
             return result;
         }
         catch (Exception e) {
-            log.info("[1HOUR...] (INS) {}, findPatternJobLog, Exception: {}", LogUtils.elapsedLog("PATN_JOB_LOG", elapsed.milliSeconds()), e.getMessage());
+            log.error("[1HOUR...] (INS) {}, findPatternJobLog, Exception: {}", LogUtils.elapsedLog("PATN_JOB_LOG", elapsed.milliSeconds()), e.getMessage());
         }
         return 0;
     }
@@ -181,7 +179,7 @@ public class DwdbJobPrcs01HService implements AbstractProcessService {
             return result;
         }
         catch (Exception e) {
-            log.info("[1HOUR...] (UPD) {}, findPatternJobLog, Exception: {}", LogUtils.elapsedLog("PATN_JOB_LOG", elapsed.milliSeconds()), e.getMessage());
+            log.error("[1HOUR...] (UPD) {}, findPatternJobLog, Exception: {}", LogUtils.elapsedLog("PATN_JOB_LOG", elapsed.milliSeconds()), e.getMessage());
         }
         return 0;
     }
@@ -199,7 +197,7 @@ public class DwdbJobPrcs01HService implements AbstractProcessService {
             log.info("[1HOUR...] (DEL) {}", LogUtils.elapsedLog(tableName, 1, elapsed.milliSeconds()));
         }
         catch (Exception e) {
-            log.info("[1HOUR...] (SEL) {}, deletePatternWeekJob, Exception: {}", LogUtils.elapsedLog(tableName, elapsed.milliSeconds()), e.getMessage());
+            log.error("[1HOUR...] (SEL) {}, deletePatternWeekJob, Exception: {}", LogUtils.elapsedLog(tableName, elapsed.milliSeconds()), e.getMessage());
         }
     }
 
@@ -233,7 +231,7 @@ public class DwdbJobPrcs01HService implements AbstractProcessService {
                     log.info("[1HOUR...] (UPD) {}, [{}]", LogUtils.elapsedLog("PATN_WEEK_JOB", result, elapsed.milliSeconds()), patternTime);
                 }
                 catch (Exception e) {
-                    log.info("[1HOUR...] (UPD) {}, initialize05mPattern, Exception: {}", LogUtils.elapsedLog("PATN_WEEK_JOB", elapsed.milliSeconds()), e.getMessage());
+                    log.error("[1HOUR...] (UPD) {}, initialize05mPattern, Exception: {}", LogUtils.elapsedLog("PATN_WEEK_JOB", elapsed.milliSeconds()), e.getMessage());
                 }
             }
         }
@@ -258,7 +256,7 @@ public class DwdbJobPrcs01HService implements AbstractProcessService {
                     log.info("[1HOUR...] (UPD) {}, [{}]", LogUtils.elapsedLog("PATN_15MIN_WEEK_JOB", result, elapsed.milliSeconds()), patternTime);
                 }
                 catch (Exception e) {
-                    log.info("[1HOUR...] (UPD) {}, initialize15mPattern, Exception: {}", LogUtils.elapsedLog("PATN_15MIN_WEEK_JOB", elapsed.milliSeconds()), e.getMessage());
+                    log.error("[1HOUR...] (UPD) {}, initialize15mPattern, Exception: {}", LogUtils.elapsedLog("PATN_15MIN_WEEK_JOB", elapsed.milliSeconds()), e.getMessage());
                 }
             }
         }

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

@@ -24,8 +24,7 @@ public class DwdbJobPrcs04MService implements AbstractProcessService {
 
         try {
             return this.dwdbJobMapper.findStatTime();
-        }
-        catch (Exception e) {
+        } catch (Exception e) {
             log.error("[04MIN...] (SEL) {}: Exception: {}", LogUtils.elapsedLog("initialize.findStatTime"), e.getMessage());
             return null;
         }
@@ -51,7 +50,7 @@ public class DwdbJobPrcs04MService implements AbstractProcessService {
             result = this.prcs04MMapper.insertCurLinkStMoctLog(statTime.getPast10Min());
             log.info("[04MIN...] (INS) {}", LogUtils.elapsedLog("CURLINKST_MOCT_LOG(국토부 LINK)", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[04MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("CURLINKST_MOCT_LOG(건교부 LINK)", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[04MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("CURLINKST_MOCT_LOG(건교부 LINK)", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         // statRcv12LEXE
@@ -60,7 +59,7 @@ public class DwdbJobPrcs04MService implements AbstractProcessService {
             result = this.prcs04MMapper.insertCurLinkSt(statTime.getPast10Min());
             log.info("[04MIN...] (INS) {}", LogUtils.elapsedLog("CURLINKST(12개지자체 연계)", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[04MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("CURLINKST(12개지자체 연계)", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[04MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("CURLINKST(12개지자체 연계)", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         // statRcvLOCEXE
@@ -69,7 +68,7 @@ public class DwdbJobPrcs04MService implements AbstractProcessService {
             result = this.prcs04MMapper.insertRcvLinkTraffic(statTime.getPast10Min());
             log.info("[04MIN...] (INS) {}", LogUtils.elapsedLog("RCV_LINK_TRAFFIC(수도권교통정보)", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[04MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("RCV_LINK_TRAFFIC(수도권교통정보)", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[04MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("RCV_LINK_TRAFFIC(수도권교통정보)", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         // statRcvCNTEXE
@@ -78,7 +77,7 @@ public class DwdbJobPrcs04MService implements AbstractProcessService {
             result = this.prcs04MMapper.updateIncidentCenter(statTime.getPast10Min());
             log.info("[04MIN...] (UPD) {}", LogUtils.elapsedLog("INCIDENT_CENTER(돌발정보)", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[04MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("INCIDENT_CENTER(돌발정보)", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[04MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("INCIDENT_CENTER(돌발정보)", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -86,7 +85,7 @@ public class DwdbJobPrcs04MService implements AbstractProcessService {
             result = this.prcs04MMapper.insertTraffic5mHist(statTime.getPast05Min(), statTime.getPast30Min());
             log.info("[04MIN...] (INS) {}", LogUtils.elapsedLog("TRAFFIC5M_HIST", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[04MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("TRAFFIC5M_HIST", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[04MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("TRAFFIC5M_HIST", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -94,7 +93,7 @@ public class DwdbJobPrcs04MService implements AbstractProcessService {
             result = this.prcs04MMapper.insertCollInfoHist(statTime.getPast05Min(), statTime.getPast30Min());
             log.info("[04MIN...] (INS) {}", LogUtils.elapsedLog("COLLINFOHIST", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[04MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("COLLINFOHIST", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[04MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("COLLINFOHIST", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -102,7 +101,7 @@ public class DwdbJobPrcs04MService implements AbstractProcessService {
             result = this.prcs04MMapper.insertCollTrafficHist(statTime.getPast05Min(), statTime.getPast30Min());
             log.info("[04MIN...] (INS) {}", LogUtils.elapsedLog("COLLTRAFFICHIST", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[04MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("COLLTRAFFICHIST", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[04MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("COLLTRAFFICHIST", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
 
@@ -113,7 +112,7 @@ public class DwdbJobPrcs04MService implements AbstractProcessService {
             result = this.prcs04MMapper.insertTrafficObeLocHist(statTime.getPast10Min());
             log.info("[04MIN...] (INS) {}", LogUtils.elapsedLog("TRAFFIC_OBELOC_HIST", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[04MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("TRAFFIC_OBELOC_HIST", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[04MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("TRAFFIC_OBELOC_HIST", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         log.info("[04MIN...] ..... {}", LogUtils.elapsedLog(processName + " 종료", elapsed.milliSeconds()));

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

@@ -37,15 +37,13 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
             for (CodeValueDto code : codes) {
                 this.mapData.put(code.getMainCode()+code.getSubCode(), code);
             }
-        }
-        catch (Exception e) {
+        } catch (Exception e) {
             log.error("[05MIN...] (SEL) {}: Exception: {}", LogUtils.elapsedLog("initialize.findAllCodeValue"), e.getMessage());
         }
 
         try {
             return this.dwdbJobMapper.findStatTime();
-        }
-        catch (Exception e) {
+        } catch (Exception e) {
             log.error("[05MIN...] (SEL) {}: Exception: {}", LogUtils.elapsedLog("initialize.findStatTime"), e.getMessage());
             return null;
         }
@@ -76,28 +74,28 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
             result = this.prcs05MMapper.truncateStatLocal();
             log.info("[05MIN...] (DEL) {}", LogUtils.elapsedLog("STAT_LOCAL(TRUNCATE)", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[05MIN...] (DEL) {}, Exception: {}", LogUtils.elapsedLog("STAT_LOCAL(TRUNCATE)", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[05MIN...] (DEL) {}, Exception: {}", LogUtils.elapsedLog("STAT_LOCAL(TRUNCATE)", tmpelapsed.milliSeconds()), e.getMessage());
         }
         try {
             tmpelapsed.reset();
             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());
+            log.error("[05MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_LOCAL(12개지자체)", tmpelapsed.milliSeconds()), e.getMessage());
         }
         try {
             tmpelapsed.reset();
             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());
+            log.error("[05MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_LOCAL(수도권 지역센터)", tmpelapsed.milliSeconds()), e.getMessage());
         }
         try {
             tmpelapsed.reset();
             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());
+            log.error("[05MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_LOCAL(통합배포시스템)", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         // LINK_FILTER 데이터 입력
@@ -118,7 +116,7 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
             result = this.prcs05MMapper.truncateLinkFilter();
             log.info("[05MIN...] (DEL) {}", LogUtils.elapsedLog("LINK_FILTER(TRUNCATE)", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[05MIN...] (DEL) {}, Exception: {}", LogUtils.elapsedLog("LINK_FILTER(TRUNCATE)", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[05MIN...] (DEL) {}, Exception: {}", LogUtils.elapsedLog("LINK_FILTER(TRUNCATE)", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -127,7 +125,7 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
             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());
+            log.error("[05MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("LINK_FILTER(표준편차값)", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         // 패턴 최대최소값 UPDATE
@@ -141,7 +139,7 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
                 
                 runLinkFilterPatternUpdate(prcsPast30Min, holiday, codeValue2);
             } catch (Exception e) {
-                log.info("[05MIN...] (SEL) {}, Exception: {}", LogUtils.elapsedLog("HOLIDAY", tmpelapsed.milliSeconds()), e.getMessage());
+                log.error("[05MIN...] (SEL) {}, Exception: {}", LogUtils.elapsedLog("HOLIDAY", tmpelapsed.milliSeconds()), e.getMessage());
             }
             
         }
@@ -155,9 +153,8 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
             tmpelapsed.reset();
             result = this.prcs05MMapper.updateLinkFilterRoadRank();
             log.info("[05MIN...] (UPD) {}", LogUtils.elapsedLog("LINK_FILTER(도로등급 변경)", result, tmpelapsed.milliSeconds()));
-        }
-        catch (Exception e) {
-            log.info("[05MIN...] (UPD) {}, Exception: {}", LogUtils.elapsedLog("LINK_FILTER(도로등급 변경)", elapsed.milliSeconds()), e.getMessage());
+        } catch (Exception e) {
+            log.error("[05MIN...] (UPD) {}, Exception: {}", LogUtils.elapsedLog("LINK_FILTER(도로등급 변경)", elapsed.milliSeconds()), e.getMessage());
         }
 
         // LINK_FILTER 최대최소 속도 입력
@@ -172,7 +169,7 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
                         codeValue9.getMinValue(), codeValue9.getMaxValue());
                 log.info("[05MIN...] (UPD) {}", LogUtils.elapsedLog("LINK_FILTER(도로등급 필터링)", result, tmpelapsed.milliSeconds()));
             } catch (Exception e) {
-                log.info("[05MIN...] (UPD) {}, Exception: {}", LogUtils.elapsedLog("LINK_FILTER(도로등급 필터링)", tmpelapsed.milliSeconds()), e.getMessage());
+                log.error("[05MIN...] (UPD) {}, Exception: {}", LogUtils.elapsedLog("LINK_FILTER(도로등급 필터링)", tmpelapsed.milliSeconds()), e.getMessage());
             }
         }
         else {
@@ -186,7 +183,7 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
             result = this.prcs05MMapper.insertStatLocalLog();
             log.info("[05MIN...] (INS) {}", LogUtils.elapsedLog("STAT_LOCAL_LOG", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[05MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_LOCAL_LOG", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[05MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_LOCAL_LOG", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         // statDwd05MEXE
@@ -196,7 +193,7 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
             regDate = this.prcs05MMapper.findLinkFilterMakeDate();
             log.info("[05MIN...] (SEL) {}", LogUtils.elapsedLog("LINK_FILTER(생성일자)", 1, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[05MIN...] (SEL) {}, Exception: {}", LogUtils.elapsedLog("LINK_FILTER(생성일자)", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[05MIN...] (SEL) {}, Exception: {}", LogUtils.elapsedLog("LINK_FILTER(생성일자)", tmpelapsed.milliSeconds()), e.getMessage());
         }
         if (StringUtils.isEmpty(regDate)) {
             regDate = prcsPast25Min;  // LINK_FILTER 생성일자(MAK_DATE) 없을 경우
@@ -207,7 +204,7 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
             result = this.prcs05MMapper.insertCenterLog(regDate);
             log.info("[05MIN...] (INS) {}", LogUtils.elapsedLog("CENTER_LOG", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[05MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("CENTER_LOG", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[05MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("CENTER_LOG", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -215,7 +212,7 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
             result = this.prcs05MMapper.insertUtisLog(regDate);
             log.info("[05MIN...] (INS) {}", LogUtils.elapsedLog("UTIS_LOG", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[05MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("UTIS_LOG", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[05MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("UTIS_LOG", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -388,7 +385,7 @@ public class DwdbJobPrcs05MService implements AbstractProcessService {
             log.info("[05MIN...] (SEL) {}", LogUtils.elapsedLog("HOLIDAY", 1, tmpElapsed.milliSeconds()));
         }
         catch (Exception e) {
-            log.info("[05MIN...] (SEL) {}, patternUpdate[{}], Exception: {}", LogUtils.elapsedLog("HOLIDAY", tmpElapsed.milliSeconds()), patternTime, e.getMessage());
+            log.error("[05MIN...] (SEL) {}, patternUpdate[{}], Exception: {}", LogUtils.elapsedLog("HOLIDAY", tmpElapsed.milliSeconds()), patternTime, e.getMessage());
             return;
         }
 

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

@@ -35,15 +35,13 @@ public class DwdbJobPrcs15MService implements AbstractProcessService {
             for (CodeValueDto code : codes) {
                 this.mapData.put(code.getMainCode()+code.getSubCode(), code);
             }
-        }
-        catch (Exception e) {
+        } catch (Exception e) {
             log.error("[15MIN...] (SEL) {}: Exception: {}", LogUtils.elapsedLog("initialize.findAllCodeValue"), e.getMessage());
         }
 
         try {
             return this.dwdbJobMapper.findStatTime();
-        }
-        catch (Exception e) {
+        } catch (Exception e) {
             log.error("[15MIN...] (SEL) {}: Exception: {}", LogUtils.elapsedLog("initialize.findStatTime"), e.getMessage());
             return null;
         }
@@ -77,7 +75,7 @@ public class DwdbJobPrcs15MService implements AbstractProcessService {
             result = this.prcs15MMapper.insertStat15MinCenter(pastStat30Min, pastStat45Min);
             log.info("[15MIN...] (INS) {}", LogUtils.elapsedLog("STAT_15MIN_CENTER", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[15MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_15MIN_CENTER", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[15MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_15MIN_CENTER", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -86,7 +84,7 @@ public class DwdbJobPrcs15MService implements AbstractProcessService {
             result = this.prcs15MMapper.insertStat15Min12Loc(pastStat30Min, pastStat45Min);
             log.info("[15MIN...] (INS) {}", LogUtils.elapsedLog("STAT_15MIN_12LOC", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[15MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_15MIN_12LOC", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[15MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_15MIN_12LOC", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -95,7 +93,7 @@ public class DwdbJobPrcs15MService implements AbstractProcessService {
             result = this.prcs15MMapper.insertStat15MinExw(pastStat30Min, pastStat45Min);
             log.info("[15MIN...] (INS) {}", LogUtils.elapsedLog("STAT_15MIN_EXW", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[15MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_15MIN_EXW", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[15MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_15MIN_EXW", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -104,7 +102,7 @@ public class DwdbJobPrcs15MService implements AbstractProcessService {
             result = this.prcs15MMapper.insertStat15MinLoc(pastStat30Min, pastStat45Min);
             log.info("[15MIN...] (INS) {}", LogUtils.elapsedLog("STAT_15MIN_LOC", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[15MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_15MIN_LOC", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[15MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_15MIN_LOC", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -113,7 +111,7 @@ public class DwdbJobPrcs15MService implements AbstractProcessService {
             result = this.prcs15MMapper.insertStat15MinObeLoc(pastStat30Min, pastStat45Min);
             log.info("[15MIN...] (INS) {}", LogUtils.elapsedLog("STAT_15MIN_OBELOC", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[15MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_15MIN_OBELOC", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[15MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_15MIN_OBELOC", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         // 15 분 이력 저장
@@ -123,7 +121,7 @@ public class DwdbJobPrcs15MService implements AbstractProcessService {
             result = this.prcs15MMapper.insertTraffic15mHist(pastStat30Min, pastStat45Min);
             log.info("[15MIN...] (INS) {}", LogUtils.elapsedLog("TRAFFIC15M_HIST", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[15MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("TRAFFIC15M_HIST", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[15MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("TRAFFIC15M_HIST", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         // 15분 패턴 업데이트
@@ -153,9 +151,8 @@ public class DwdbJobPrcs15MService implements AbstractProcessService {
         try {
             holiday = this.prcsPatternMapper.findHoliday(patternTime);
             log.info("[15MIN...] (SEL) {}", LogUtils.elapsedLog("HOLIDAY", 1, tmpElapsed.milliSeconds()));
-        }
-        catch (Exception e) {
-            log.info("[15MIN...] (SEL) {}, patternUpdate[{}], Exception: {}", LogUtils.elapsedLog("HOLIDAY", tmpElapsed.milliSeconds()), patternTime, e.getMessage());
+        } catch (Exception e) {
+            log.error("[15MIN...] (SEL) {}, patternUpdate[{}], Exception: {}", LogUtils.elapsedLog("HOLIDAY", tmpElapsed.milliSeconds()), patternTime, e.getMessage());
             return;
         }
 
@@ -216,14 +213,14 @@ public class DwdbJobPrcs15MService implements AbstractProcessService {
                 log.info("[15MIN...] (MRG) {}", LogUtils.elapsedLog("PATN_15MIN_WEEK_JOB(MERGE)", result, elapsed.milliSeconds()));
             }
             catch (Exception e) {
-                log.info("[15MIN...] (MRG) {}, Exception: {}", LogUtils.elapsedLog("PATN_15MIN_WEEK_JOB(MERGE)", elapsed.milliSeconds()), e.getMessage());
+                log.error("[15MIN...] (MRG) {}, Exception: {}", LogUtils.elapsedLog("PATN_15MIN_WEEK_JOB(MERGE)", elapsed.milliSeconds()), e.getMessage());
             }
             try {
                 result = this.prcsPatternMapper.updateIncidentPatternWeekJob("PATN_15MIN_WEEK_JOB", columnName, patternTime);
                 log.info("[15MIN...] (UPD) {}", LogUtils.elapsedLog("PATN_15MIN_WEEK_JOB(UPDATE)", result, elapsed.milliSeconds()));
             }
             catch (Exception e) {
-                log.info("[15MIN...] (UPD) {}, Exception: {}", LogUtils.elapsedLog("PATN_15MIN_WEEK_JOB(UPDATE)", elapsed.milliSeconds()), e.getMessage());
+                log.error("[15MIN...] (UPD) {}, Exception: {}", LogUtils.elapsedLog("PATN_15MIN_WEEK_JOB(UPDATE)", elapsed.milliSeconds()), e.getMessage());
             }
         }
         else {

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

@@ -24,8 +24,7 @@ public class DwdbJobPrcs30MService implements AbstractProcessService {
 
         try {
             return this.dwdbJobMapper.findStatTime();
-        }
-        catch (Exception e) {
+        } catch (Exception e) {
             log.error("[30MIN...] (SEL) {}: Exception: {}", LogUtils.elapsedLog("initialize.findStatTime"), e.getMessage());
             return null;
         }
@@ -59,7 +58,7 @@ public class DwdbJobPrcs30MService implements AbstractProcessService {
             result = this.prcs30MMapper.insertStat30MinCenter(pastStat30Min, pastStat60Min);
             log.info("[30MIN...] (INS) {}", LogUtils.elapsedLog("STAT_30MIN_CENTER", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[30MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_30MIN_CENTER", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[30MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_30MIN_CENTER", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -68,7 +67,7 @@ public class DwdbJobPrcs30MService implements AbstractProcessService {
             result = this.prcs30MMapper.insertStat30Min12Loc(pastStat30Min, pastStat60Min);
             log.info("[30MIN...] (INS) {}", LogUtils.elapsedLog("STAT_30MIN_12LOC", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[30MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_30MIN_12LOC", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[30MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_30MIN_12LOC", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -77,7 +76,7 @@ public class DwdbJobPrcs30MService implements AbstractProcessService {
             result = this.prcs30MMapper.insertStat30MinExw(pastStat30Min, pastStat60Min);
             log.info("[30MIN...] (INS) {}", LogUtils.elapsedLog("STAT_30MIN_EXW", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[30MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_30MIN_EXW", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[30MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_30MIN_EXW", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -86,7 +85,7 @@ public class DwdbJobPrcs30MService implements AbstractProcessService {
             result = this.prcs30MMapper.insertStat30MinLoc(pastStat30Min, pastStat60Min);
             log.info("[30MIN...] (INS) {}", LogUtils.elapsedLog("STAT_30MIN_LOC", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[30MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_30MIN_LOC", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[30MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_30MIN_LOC", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         try {
@@ -95,7 +94,7 @@ public class DwdbJobPrcs30MService implements AbstractProcessService {
             result = this.prcs30MMapper.insertStat30MinObeLoc(pastStat30Min, pastStat60Min);
             log.info("[30MIN...] (INS) {}", LogUtils.elapsedLog("STAT_30MIN_OBELOC", result, tmpelapsed.milliSeconds()));
         } catch (Exception e) {
-            log.info("[30MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_30MIN_OBELOC", tmpelapsed.milliSeconds()), e.getMessage());
+            log.error("[30MIN...] (INS) {}, Exception: {}", LogUtils.elapsedLog("STAT_30MIN_OBELOC", tmpelapsed.milliSeconds()), e.getMessage());
         }
 
         log.info("[30MIN...] ..... {}", LogUtils.elapsedLog(processName + " 종료", elapsed.milliSeconds()));

utic-dwdb-server/src/main/resources/mybatis/mapper/DwdbJobPrcs05MMapper.xml

@@ -3,9 +3,9 @@
 
 <mapper namespace="com.utic.dwdb.server.dao.mapper.DwdbJobPrcs05MMapper">
 
-    <delete id="truncateStatLocal">
+    <update id="truncateStatLocal">
         TRUNCATE TABLE STAT_LOCAL
-    </delete>
+    </update>
 
     <insert id="insertStatLocal12Loc" parameterType="java.lang.String">
         INSERT INTO STAT_LOCAL(LOCAL_DATE, CENTER_ID, LINKID, REV_TYPE, SPEED)
@@ -34,9 +34,9 @@
     </insert>
 
 
-    <delete id="truncateLinkFilter">
+    <update id="truncateLinkFilter">
         TRUNCATE TABLE LINK_FILTER
-    </delete>
+    </update>
 
     <insert id="insertLinkFilter" parameterType="java.lang.String">
         INSERT INTO LINK_FILTER(LINKID, MAK_DATE, AVG_SPEED, DATA_CNT,

utic-dwdb-server/src/main/resources/mybatis/mapper/DwdbJobPrcsPatternMapper.xml

@@ -121,13 +121,13 @@
           AND EXE_DAY   = #{exeDay}
     </update>
 
-    <delete id="deletePatternWeekJob">
+    <update id="deletePatternWeekJob">
         TRUNCATE TABLE PATN_WEEK_JOB
-    </delete>
+    </update>
 
-    <delete id="deletePattern15MinWeekJob">
+    <update id="deletePattern15MinWeekJob">
         TRUNCATE TABLE PATN_15MIN_WEEK_JOB
-    </delete>
+    </update>
 
     <update id="updatePatternWeekJob" parameterType="java.lang.String">
         UPDATE PATN_WEEK_JOB

utic-dwdb-server/src/main/resources/mybatis/mapper/DwdbJobPrcsTablePartMapper.xml

@@ -0,0 +1,55 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="com.utic.dwdb.server.dao.mapper.DwdbJobPrcsTablePartMapper">
+
+    <select id="findTablePartMonth" resultType="com.utic.dwdb.server.dto.TablePartMonthDto">
+        SELECT TO_CHAR(ADD_MONTHS(SYSDATE, 1), 'YYYYMM') AS makeMonth,
+               TO_CHAR(ADD_MONTHS(SYSDATE, 2), 'YYYYMM') AS partMonth
+        FROM DUAL
+    </select>
+
+    <select id="findTablePartDelMonth" resultType="com.utic.dwdb.server.dto.TablePartMonthDto">
+        SELECT TO_CHAR(ADD_MONTHS(SYSDATE, TO_NUMBER(#{savePeriod}) - (TO_NUMBER(#{savePeriod}) * 2)), 'YYYYMM') AS makeMonth,
+               TO_CHAR(ADD_MONTHS(SYSDATE, 2), 'YYYYMM') AS partMonth
+        FROM DUAL
+    </select>
+
+    <select id="findAllTablePartInfo" parameterType="java.lang.String" resultType="com.utic.dwdb.server.dto.TablePartInfoDto">
+        SELECT TABLE_NAME            AS tableName,
+               EXECUTE_YN            AS executeYn,
+               BACKUP_YN             AS backupYn,
+               SAVE_PREIOD           AS savePeriod,
+               BACKUP_LOCATION       AS backupLocation,
+               PATITION_TYPE         AS partitionType,
+               NVL(PATITION_LEN, 99) AS partitionLen
+        FROM PARTITION_TABLE
+        WHERE EXECUTE_YN = 'Y'
+    </select>
+
+    <select id="findTablePartCount" parameterType="java.lang.String" resultType="com.utic.dwdb.server.dto.TablePartCountDto">
+        SELECT COUNT(1) AS partitionCount
+        FROM USER_TAB_PARTITIONS
+        WHERE PARTITION_NAME = #{partitionName}
+    </select>
+
+    <select id="findTablePartExist" parameterType="java.lang.String" resultType="com.utic.dwdb.server.dto.TablePartCountDto">
+        SELECT COUNT(1) AS partitionCount
+        FROM USER_TAB_PARTITIONS
+        WHERE TABLE_NAME = #{tableName}
+          AND PARTITION_NAME = #{partitionName}
+    </select>
+
+    <update id="alterAddPartitionByDate" parameterType="java.lang.String">
+        ALTER TABLE ${tableName} ADD PARTITION ${partitionName} VALUES LESS THAN(TO_DATE(#{lessThan}, 'YYYYMM'))
+    </update>
+
+    <update id="alterAddPartition" parameterType="java.lang.String">
+        ALTER TABLE ${tableName} ADD PARTITION ${partitionName} VALUES LESS THAN(#{lessThan})
+    </update>
+
+    <update id="alterDropPartition" parameterType="java.lang.String">
+        ALTER TABLE ${tableName} DROP PARTITION ${partitionName}
+    </update>
+
+</mapper>

utic-ptis-server/src/main/java/com/utic/ptis/server/UticPtisServerApplication.java

@@ -98,8 +98,7 @@ public class UticPtisServerApplication implements CommandLineRunner, Application
 
                 ProcessStateService processStateService = SpringUtils.getBean(ProcessStateService.class);
                 processStateService.processStop();
-            }
-            catch (Exception e) {
+            } catch (Exception e) {
                 log.error("**    Application Terminated: {}", e.getMessage());
             }
             log.error("************************************************************************************");

utic-ptis-server/src/main/java/com/utic/ptis/server/config/TraceConfig.java

@@ -40,8 +40,7 @@ public class TraceConfig {
             props.load(in);
             in.close();
             return props;
-        }
-        catch(Exception e) {
+        } catch(Exception e) {
 //            log.error("{}.getTraceFileInputStream: Exception1: {}", this.getClass().getSimpleName(), e.toString());
             return null;
         }
@@ -60,8 +59,7 @@ public class TraceConfig {
                 List<String> linkIds = StringUtils.split(dumps, ",");
                 this.debugLinks.addAll(linkIds);
             }
-        }
-        catch(Exception e) {
+        } catch(Exception e) {
             log.error("{}.loadDebugInfo: Exception2: {}", this.getClass().getSimpleName(), e.toString());
         }
     }

utic-ptis-server/src/main/java/com/utic/ptis/server/scheduler/ApplicationScheduler.java

@@ -25,8 +25,7 @@ public class ApplicationScheduler {
     public void updateProcessState() {
         try {
             this.processStateService.processRunning();
-        }
-        catch(Exception e) {
+        } catch(Exception e) {
             log.error("ApplicationScheduler.updateProcessState: Exception {}", e.getMessage());
         }
     }
@@ -36,8 +35,7 @@ public class ApplicationScheduler {
     public void processPtisTraffic() {
         try {
             this.traceConfig.loadTraceInfo();
-        }
-        catch(Exception e) {
+        } catch(Exception e) {
             log.error("ApplicationScheduler.processPtisTraffic: Exception {}", e.getMessage());
         }
     }

utic-ptis-server/src/main/java/com/utic/ptis/server/scheduler/LinkTrafPrcsScheduler.java

@@ -24,8 +24,7 @@ public class LinkTrafPrcsScheduler {
     private void runJob(AbstractProcessController job, String jobName) {
         try {
             job.run();
-        }
-        catch(Exception e) {
+        } catch(Exception e) {
             log.error("[CRONJOB] LinkTrafPrcsScheduler: schedule job run failed: {}, {}", jobName, e.getMessage());
         }
     }

utic-ptis-server/src/main/java/com/utic/ptis/server/service/worker/LinkTrafCollectWorker.java

@@ -70,8 +70,7 @@ public class LinkTrafCollectWorker implements Runnable {
             try {
                 sqlSession = sqlSessionFactory.openSession(ExecutorType.SIMPLE, false);
                 queryResult = sqlSession.selectList(queryId, params);
-            }
-            catch (Exception e) {
+            } catch (Exception e) {
                 log.error("[COLLECT] LinkTrafCollectWorker.run: Exception: [{}], {}, {}, {}", this.clctSystCd, jobType, queryId, e.getMessage());
             }
             finally {
@@ -101,13 +100,11 @@ public class LinkTrafCollectWorker implements Runnable {
                     this.mapData.put(this.clctSystCd, LinkCollectResultDto.builder().clctSystCd(this.clctSystCd).lists(queryResult).build());
                 }
             }
-        }
-        catch (InterruptedException e) {
-            log.info("[COLLECT] LinkTrafCollectWorker.run: InterruptedException, [{}], {}, {}.", this.clctSystCd, jobType, e.getMessage());
+        } catch (InterruptedException e) {
+            log.error("[COLLECT] LinkTrafCollectWorker.run: InterruptedException, [{}], {}, {}.", this.clctSystCd, jobType, e.getMessage());
             this.mapData.put(this.clctSystCd, LinkCollectResultDto.builder().clctSystCd(this.clctSystCd).lists(new ArrayList<>()).build());
-        }
-        catch (Exception e) {
-            log.info("[COLLECT] LinkTrafCollectWorker.run: Exception, [{}], {}, {}.", this.clctSystCd, jobType, e.getMessage());
+        } catch (Exception e) {
+            log.error("[COLLECT] LinkTrafCollectWorker.run: Exception, [{}], {}, {}.", this.clctSystCd, jobType, e.getMessage());
             this.mapData.put(this.clctSystCd, LinkCollectResultDto.builder().clctSystCd(this.clctSystCd).lists(new ArrayList<>()).build());
         }
         stopWatch.stop();

utic-ptis-server/src/main/java/com/utic/ptis/server/service/worker/LinkTrafDeleteWorker.java

@@ -30,12 +30,10 @@ public class LinkTrafDeleteWorker implements Runnable {
             else if (LinkTrafDeleteService.TABLE_TRAFFIC_CENTER_EXT.equals(this.deleteTable)) {
                 resultCount = this.mapper.deleteTrafficCenterExt();
             }
-        }
-        catch (InterruptedException e) {
-            log.info("[DELETE.] LinkTrafDeleteWorker.run: InterruptedException, [{}], {}.", this.deleteTable, e.getMessage());
-        }
-        catch (Exception e) {
-            log.info("[DELETE.] LinkTrafDeleteWorker.run: Exception, [{}], {}.", this.deleteTable, e.getMessage());
+        } catch (InterruptedException e) {
+            log.error("[DELETE.] LinkTrafDeleteWorker.run: InterruptedException, [{}], {}.", this.deleteTable, e.getMessage());
+        } catch (Exception e) {
+            log.error("[DELETE.] LinkTrafDeleteWorker.run: Exception, [{}], {}.", this.deleteTable, e.getMessage());
         }
         stopWatch.stop();
         this.dbmsJobResult.setEffects(resultCount);

utic-ptis-server/src/main/java/com/utic/ptis/server/service/worker/LinkTrafSaveDwdbCenterHistWorker.java

@@ -133,9 +133,8 @@ public class LinkTrafSaveDwdbCenterHistWorker implements Runnable {
             }
             sqlSession.flushStatements();
             sqlSession.commit();
-        }
-        catch (Exception e) {
-            log.info("[SAVE...] LinkTrafSaveDwdbCenterHistWorker.processBatch({}): Exception, [{}], {}.", dbmsJobResult.getJobIndex(), jobTable, e.getMessage());
+        } catch (Exception e) {
+            log.error("[SAVE...] LinkTrafSaveDwdbCenterHistWorker.processBatch({}): Exception, [{}], {}.", dbmsJobResult.getJobIndex(), jobTable, e.getMessage());
         }
         stopWatch.stop();
 

utic-ptis-server/src/main/java/com/utic/ptis/server/service/worker/LinkTrafSaveDwdbFusionLogWorker.java

@@ -28,12 +28,10 @@ public class LinkTrafSaveDwdbFusionLogWorker implements Runnable {
             Thread.sleep(10);
             LinkTrafFusionInfo obj = this.linkRepo.getFusionInfo();
             resultCount = this.mapper.insertLinkFusionLog(obj);
-        }
-        catch (InterruptedException e) {
-            log.info("[SAVE...] LinkTrafSaveDwdbFusionLogWorker.run: InterruptedException, [{}], {}.", jobTable, e.getMessage());
-        }
-        catch (Exception e) {
-            log.info("[SAVE...] LinkTrafSaveDwdbFusionLogWorker.run: Exception, [{}], {}.", jobTable, e.getMessage());
+        } catch (InterruptedException e) {
+            log.error("[SAVE...] LinkTrafSaveDwdbFusionLogWorker.run: InterruptedException, [{}], {}.", jobTable, e.getMessage());
+        } catch (Exception e) {
+            log.error("[SAVE...] LinkTrafSaveDwdbFusionLogWorker.run: Exception, [{}], {}.", jobTable, e.getMessage());
         }
 
         stopWatch.stop();

utic-ptis-server/src/main/java/com/utic/ptis/server/service/worker/LinkTrafSaveDwdbMissingValueHistWorker.java

@@ -122,9 +122,8 @@ public class LinkTrafSaveDwdbMissingValueHistWorker implements Runnable {
             }
             sqlSession.flushStatements();
             sqlSession.commit();
-        }
-        catch (Exception e) {
-            log.info("[SAVE...] LinkTrafSaveDwdbMissingValueHistWorker.processBatch({}): Exception, [{}], {}.", dbmsJobResult.getJobIndex(), jobTable, e.getMessage());
+        } catch (Exception e) {
+            log.error("[SAVE...] LinkTrafSaveDwdbMissingValueHistWorker.processBatch({}): Exception, [{}], {}.", dbmsJobResult.getJobIndex(), jobTable, e.getMessage());
         }
 
         stopWatch.stop();

utic-ptis-server/src/main/resources/mybatis/mapper/utic/asn/LinkTrafAsnMapper.xml

@@ -3,9 +3,9 @@
 
 <mapper namespace="com.utic.ptis.server.dao.mapper.utic.LinkTrafAsnMapper">
 
-    <delete id="deleteTrafficLoc">
+    <update id="deleteTrafficLoc">
         TRUNCATE TABLE TRAFFIC_LOC
-    </delete>
+    </update>
 
     <select id="findLinkTrafAsnTime" resultType="com.utic.ptis.server.dto.LinkTrafAsnTimeDto">
         SELECT TO_CHAR(SYSDATE,            'YYYYMMDDHH24MI')||'00' AS currTime,