|
@@ -65,29 +65,31 @@ public class GgitsEtlpService {
|
|
|
|
|
|
public void run() {
|
|
|
Elapsed elapsed = new Elapsed();
|
|
|
+ log.info("================================================================================================>");
|
|
|
log.info("GGITS DBASE ETLP START.");
|
|
|
|
|
|
initEtlp();
|
|
|
|
|
|
// //교차로구성_연계, SCS_T_CON_INTLC
|
|
|
-// etlpIntLc();
|
|
|
+ etlpIntLc();
|
|
|
//교차로이동류_연계, SCS_T_CON_INTFLOW
|
|
|
etlpIntFlow();
|
|
|
//교차로일계획_연계, SCS_T_CON_INTDPLAN
|
|
|
-// etlpIntDPlan();
|
|
|
+ etlpIntDPlan();
|
|
|
// //교차로주간계획_연계, SCS_T_CON_INTWEEK
|
|
|
-// etlpIntWeek();
|
|
|
+ etlpIntWeek();
|
|
|
// //교차로예약계획_연계, SCS_T_CON_INTFPLAN
|
|
|
-// etlpIntFPlan();
|
|
|
+ etlpIntFPlan();
|
|
|
// //교차로시그널맵_연계, SCS_T_CON_INTSIGMAP
|
|
|
-// etlpIntSigmap();
|
|
|
+ etlpIntSigmap();
|
|
|
log.info("GGITS DBASE ETLP ..END: {}", elapsed.elapsedTimeStr());
|
|
|
+ log.info("<================================================================================================");
|
|
|
}
|
|
|
|
|
|
//교차로구성_연계, SCS_T_CON_INTLC
|
|
|
private void etlpIntLc() {
|
|
|
Elapsed elapsed = new Elapsed();
|
|
|
- log.info("교차로구성_연계, SCS_T_CON_INTLC START.");
|
|
|
+ log.info("TB_INT, SCS_T_CON_INTLC START.");
|
|
|
List<HashMap<String, Object>> lists = new ArrayList<>();
|
|
|
|
|
|
for (String key : this.centerList) {
|
|
@@ -102,7 +104,8 @@ public class GgitsEtlpService {
|
|
|
etlp.setStartTime(TimeUtils.now());
|
|
|
try {
|
|
|
MDC.put("id", center.getLogKey());
|
|
|
- log.info("교차로구성_연계, START. {}, {}, {}, {}",
|
|
|
+ log.info("================================================================================================>");
|
|
|
+ log.info("TB_INT, SCS_T_CON_INTLC START. {}, {}, {}, {}",
|
|
|
center.getRegionCd(), center.getRegionNm(), center.getMinNodeId(), center.getMaxNodeId());
|
|
|
|
|
|
this.sigMapper.initTbInt(center.getRegionCd());
|
|
@@ -114,7 +117,7 @@ public class GgitsEtlpService {
|
|
|
|
|
|
List<TbScsTConIntLc> jobLists = this.gitsMapper.selectScsTConIntLc(center);
|
|
|
|
|
|
- log.info("교차로구성_연계, START. {}, {}, SIG: {} EA, GGITS: {} EA.",
|
|
|
+ log.info("TB_INT, SCS_T_CON_INTLC START. {}, {}, SIG: {} EA, GGITS: {} EA.",
|
|
|
center.getRegionCd(), center.getRegionNm(), intLists.size(), jobLists.size());
|
|
|
|
|
|
center.getEtlpIntLc().setReadCount(jobLists.size());
|
|
@@ -143,12 +146,13 @@ public class GgitsEtlpService {
|
|
|
}
|
|
|
etlp.setWriteCount(writeCount);
|
|
|
etlp.setSuccess(true);
|
|
|
- log.info("교차로구성_연계, ..END. {}, {}, {} EA. {} ms.",
|
|
|
- center.getRegionCd(), center.getRegionNm(), jobLists.size(), job.milliSeconds());
|
|
|
+ log.info("TB_INT, SCS_T_CON_INTLC ..END. {}, {}, JOB: {}, WRITE: {} EA. {} ms.",
|
|
|
+ center.getRegionCd(), center.getRegionNm(), jobLists.size(), writeCount, job.milliSeconds());
|
|
|
}
|
|
|
catch (Exception e) {
|
|
|
etlp.setSuccess(false);
|
|
|
- log.error("교차로구성_연계, Exception: {}, {}, {}", center.getRegionCd(), center.getRegionNm(), e.getMessage());
|
|
|
+ log.error("{}", lists.get(0));
|
|
|
+ log.error("TB_INT, SCS_T_CON_INTLC: {}, {}, Exceptions: {}", center.getRegionCd(), center.getRegionNm(), e.getMessage());
|
|
|
}
|
|
|
finally {
|
|
|
center.setElapsed(center.getElapsed() + job.milliSeconds());
|
|
@@ -156,13 +160,13 @@ public class GgitsEtlpService {
|
|
|
MDC.clear();
|
|
|
}
|
|
|
}
|
|
|
- log.info("교차로구성_연계, SCS_T_CON_INTLC ..END: {}", elapsed.elapsedTimeStr());
|
|
|
+ log.info("TB_INT, SCS_T_CON_INTLC ..END: {}", elapsed.elapsedTimeStr());
|
|
|
}
|
|
|
|
|
|
//교차로이동류_연계, SCS_T_CON_INTFLOW
|
|
|
private void etlpIntFlow() {
|
|
|
Elapsed elapsed = new Elapsed();
|
|
|
- log.info("교차로이동류_연계, SCS_T_CON_INTFLOW START.");
|
|
|
+ log.info("TB_INT_FLOW, SCS_T_CON_INTFLOW START.");
|
|
|
List<HashMap<String, Object>> lists = new ArrayList<>();
|
|
|
|
|
|
for (String key : this.centerList) {
|
|
@@ -177,7 +181,7 @@ public class GgitsEtlpService {
|
|
|
etlp.setStartTime(TimeUtils.now());
|
|
|
try {
|
|
|
MDC.put("id", center.getLogKey());
|
|
|
- log.info("교차로이동류_연계, SCS_T_CON_INTFLOW START. {}, {}, {}, {}",
|
|
|
+ log.info("TB_INT_FLOW, SCS_T_CON_INTFLOW START. {}, {}, {}, {}",
|
|
|
center.getRegionCd(), center.getRegionNm(), center.getMinNodeId(), center.getMaxNodeId());
|
|
|
List<TbScsTConIntFlow> result = this.gitsMapper.selectScsTConIntFlow(center);
|
|
|
etlp.setReadCount(result.size());
|
|
@@ -186,7 +190,6 @@ public class GgitsEtlpService {
|
|
|
for(TbScsTConIntFlow obj: result) {
|
|
|
HashMap<String, Object> param = obj.toSig(center.getRegionCd());
|
|
|
lists.add(param);
|
|
|
- log.info("{}", param);
|
|
|
if (lists.size() >= BatchDaoService.MAX_BATCH_SIZE) {
|
|
|
writeCount += this.dao.updateTbIntFlow(lists);
|
|
|
lists = new ArrayList<>();
|
|
@@ -197,12 +200,13 @@ public class GgitsEtlpService {
|
|
|
}
|
|
|
etlp.setWriteCount(writeCount);
|
|
|
etlp.setSuccess(true);
|
|
|
- log.info("교차로이동류_연계, SCS_T_CON_INTFLOW ..END. {}, {}, {} EA. {} ms.",
|
|
|
- center.getRegionCd(), center.getRegionNm(), result.size(), job.milliSeconds());
|
|
|
+ log.info("TB_INT_FLOW, SCS_T_CON_INTFLOW ..END. {}, {}, JOB: {}, WRITE: {} EA. {} ms.",
|
|
|
+ center.getRegionCd(), center.getRegionNm(), result.size(), writeCount, job.milliSeconds());
|
|
|
}
|
|
|
catch (Exception e) {
|
|
|
etlp.setSuccess(false);
|
|
|
- log.error("교차로이동류_연계, SCS_T_CON_INTFLOW: {}, {}, Exceptions: {}", center.getRegionCd(), center.getRegionNm(), e.getMessage());
|
|
|
+ log.error("{}", lists.get(0));
|
|
|
+ log.error("TB_INT_FLOW, SCS_T_CON_INTFLOW: {}, {}, Exceptions: {}", center.getRegionCd(), center.getRegionNm(), e.getMessage());
|
|
|
}
|
|
|
finally {
|
|
|
center.setElapsed(center.getElapsed() + job.milliSeconds());
|
|
@@ -210,12 +214,12 @@ public class GgitsEtlpService {
|
|
|
MDC.clear();
|
|
|
}
|
|
|
}
|
|
|
- log.info("교차로이동류_연계, SCS_T_CON_INTFLOW ..END: {}", elapsed.elapsedTimeStr());
|
|
|
+ log.info("TB_INT_FLOW, SCS_T_CON_INTFLOW ..END: {}", elapsed.elapsedTimeStr());
|
|
|
}
|
|
|
//교차로일계획_연계, SCS_T_CON_INTDPLAN
|
|
|
private void etlpIntDPlan() {
|
|
|
Elapsed elapsed = new Elapsed();
|
|
|
- log.info("교차로일계획_연계, SCS_T_CON_INTDPLAN START.");
|
|
|
+ log.info("TB_INT_OPER_PLAN, SCS_T_CON_INTDPLAN START.");
|
|
|
List<HashMap<String, Object>> lists = new ArrayList<>();
|
|
|
|
|
|
for (String key : this.centerList) {
|
|
@@ -230,7 +234,7 @@ public class GgitsEtlpService {
|
|
|
etlp.setStartTime(TimeUtils.now());
|
|
|
try {
|
|
|
MDC.put("id", center.getLogKey());
|
|
|
- log.info("교차로일계획_연계, SCS_T_CON_INTDPLAN START. {}, {}, {}, {}",
|
|
|
+ log.info("TB_INT_OPER_PLAN, SCS_T_CON_INTDPLAN START. {}, {}, {}, {}",
|
|
|
center.getRegionCd(), center.getRegionNm(), center.getMinNodeId(), center.getMaxNodeId());
|
|
|
List<TbScsTConIntDPlan> result = this.gitsMapper.selectScsTConIntDPlan(center);
|
|
|
etlp.setReadCount(result.size());
|
|
@@ -249,12 +253,13 @@ public class GgitsEtlpService {
|
|
|
}
|
|
|
etlp.setWriteCount(writeCount);
|
|
|
etlp.setSuccess(true);
|
|
|
- log.info("교차로일계획_연계, SCS_T_CON_INTDPLAN ..END. {}, {}, {} EA. {} ms.",
|
|
|
- center.getRegionCd(), center.getRegionNm(), result.size(), job.milliSeconds());
|
|
|
+ log.info("TB_INT_OPER_PLAN, SCS_T_CON_INTDPLAN ..END. {}, {}, JOB: {}, WRITE: {} EA. {} ms.",
|
|
|
+ center.getRegionCd(), center.getRegionNm(), result.size(), writeCount, job.milliSeconds());
|
|
|
}
|
|
|
catch (Exception e) {
|
|
|
etlp.setSuccess(false);
|
|
|
- log.error("교차로일계획_연계, SCS_T_CON_INTDPLAN: {}, {}, Exceptions: {}", center.getRegionCd(), center.getRegionNm(), e.getMessage());
|
|
|
+ log.error("{}", lists.get(0));
|
|
|
+ log.error("TB_INT_OPER_PLAN, SCS_T_CON_INTDPLAN: {}, {}, Exceptions: {}", center.getRegionCd(), center.getRegionNm(), e.getMessage());
|
|
|
}
|
|
|
finally {
|
|
|
center.setElapsed(center.getElapsed() + job.milliSeconds());
|
|
@@ -262,12 +267,12 @@ public class GgitsEtlpService {
|
|
|
MDC.clear();
|
|
|
}
|
|
|
}
|
|
|
- log.info("교차로일계획_연계, SCS_T_CON_INTDPLAN ..END: {}", elapsed.elapsedTimeStr());
|
|
|
+ log.info("TB_INT_OPER_PLAN, SCS_T_CON_INTDPLAN ..END: {}", elapsed.elapsedTimeStr());
|
|
|
}
|
|
|
//교차로주간계획_연계, SCS_T_CON_INTWEEK
|
|
|
private void etlpIntWeek() {
|
|
|
Elapsed elapsed = new Elapsed();
|
|
|
- log.info("교차로주간계획_연계, SCS_T_CON_INTWEEK START.");
|
|
|
+ log.info("TB_INT_DY_PLAN, SCS_T_CON_INTWEEK START.");
|
|
|
List<HashMap<String, Object>> lists = new ArrayList<>();
|
|
|
|
|
|
for (String key : this.centerList) {
|
|
@@ -282,7 +287,7 @@ public class GgitsEtlpService {
|
|
|
etlp.setStartTime(TimeUtils.now());
|
|
|
try {
|
|
|
MDC.put("id", center.getLogKey());
|
|
|
- log.info("교차로주간계획_연계, SCS_T_CON_INTWEEK START. {}, {}, {}, {}",
|
|
|
+ log.info("TB_INT_DY_PLAN, SCS_T_CON_INTWEEK START. {}, {}, {}, {}",
|
|
|
center.getRegionCd(), center.getRegionNm(), center.getMinNodeId(), center.getMaxNodeId());
|
|
|
List<TbScsTConIntWeek> result = this.gitsMapper.selectScsTConIntWeek(center);
|
|
|
etlp.setReadCount(result.size());
|
|
@@ -301,12 +306,13 @@ public class GgitsEtlpService {
|
|
|
}
|
|
|
etlp.setWriteCount(writeCount);
|
|
|
etlp.setSuccess(true);
|
|
|
- log.info("교차로주간계획_연계, SCS_T_CON_INTWEEK ..END. {}, {}, {} EA. {} ms.",
|
|
|
- center.getRegionCd(), center.getRegionNm(), result.size(), job.milliSeconds());
|
|
|
+ log.info("TB_INT_DY_PLAN, SCS_T_CON_INTWEEK ..END. {}, {}, JOB: {}, WRITE: {} EA. {} ms.",
|
|
|
+ center.getRegionCd(), center.getRegionNm(), result.size(), writeCount, job.milliSeconds());
|
|
|
}
|
|
|
catch (Exception e) {
|
|
|
etlp.setSuccess(false);
|
|
|
- log.error("교차로주간계획_연계, SCS_T_CON_INTWEEK: {}, {}, Exceptions: {}", center.getRegionCd(), center.getRegionNm(), e.getMessage());
|
|
|
+ log.error("{}", lists.get(0));
|
|
|
+ log.error("TB_INT_DY_PLAN, SCS_T_CON_INTWEEK: {}, {}, Exceptions: {}", center.getRegionCd(), center.getRegionNm(), e.getMessage());
|
|
|
}
|
|
|
finally {
|
|
|
center.setElapsed(center.getElapsed() + job.milliSeconds());
|
|
@@ -314,12 +320,12 @@ public class GgitsEtlpService {
|
|
|
MDC.clear();
|
|
|
}
|
|
|
}
|
|
|
- log.info("교차로주간계획_연계, SCS_T_CON_INTWEEK ..END: {}", elapsed.elapsedTimeStr());
|
|
|
+ log.info("TB_INT_DY_PLAN, SCS_T_CON_INTWEEK ..END: {}", elapsed.elapsedTimeStr());
|
|
|
}
|
|
|
//교차로예약계획_연계, SCS_T_CON_INTFPLAN
|
|
|
private void etlpIntFPlan() {
|
|
|
Elapsed elapsed = new Elapsed();
|
|
|
- log.info("교차로예약계획_연계, SCS_T_CON_INTFPLAN START.");
|
|
|
+ log.info("TB_INT_RESRV_PLAN, SCS_T_CON_INTFPLAN START.");
|
|
|
List<HashMap<String, Object>> lists = new ArrayList<>();
|
|
|
|
|
|
for (String key : this.centerList) {
|
|
@@ -334,7 +340,7 @@ public class GgitsEtlpService {
|
|
|
etlp.setStartTime(TimeUtils.now());
|
|
|
try {
|
|
|
MDC.put("id", center.getLogKey());
|
|
|
- log.info("교차로예약계획_연계, SCS_T_CON_INTFPLAN START. {}, {}, {}, {}",
|
|
|
+ log.info("TB_INT_RESRV_PLAN, SCS_T_CON_INTFPLAN START. {}, {}, {}, {}",
|
|
|
center.getRegionCd(), center.getRegionNm(), center.getMinNodeId(), center.getMaxNodeId());
|
|
|
List<TbScsTConIntFPlan> result = this.gitsMapper.selectScsTConIntFPlan(center);
|
|
|
etlp.setReadCount(result.size());
|
|
@@ -353,12 +359,13 @@ public class GgitsEtlpService {
|
|
|
}
|
|
|
etlp.setWriteCount(writeCount);
|
|
|
etlp.setSuccess(true);
|
|
|
- log.info("교차로예약계획_연계, SCS_T_CON_INTFPLAN ..END. {}, {}, {} EA. {} ms.",
|
|
|
- center.getRegionCd(), center.getRegionNm(), result.size(), job.milliSeconds());
|
|
|
+ log.info("TB_INT_RESRV_PLAN, SCS_T_CON_INTFPLAN ..END. {}, {}, JOB: {}, WRITE: {} EA. {} ms.",
|
|
|
+ center.getRegionCd(), center.getRegionNm(), result.size(), writeCount, job.milliSeconds());
|
|
|
}
|
|
|
catch (Exception e) {
|
|
|
etlp.setSuccess(false);
|
|
|
- log.error("교차로예약계획_연계, SCS_T_CON_INTFPLAN: {}, {}, Exceptions: {}", center.getRegionCd(), center.getRegionNm(), e.getMessage());
|
|
|
+ log.error("{}", lists.get(0));
|
|
|
+ log.error("TB_INT_RESRV_PLAN, SCS_T_CON_INTFPLAN: {}, {}, Exceptions: {}", center.getRegionCd(), center.getRegionNm(), e.getMessage());
|
|
|
}
|
|
|
finally {
|
|
|
center.setElapsed(center.getElapsed() + job.milliSeconds());
|
|
@@ -366,12 +373,12 @@ public class GgitsEtlpService {
|
|
|
MDC.clear();
|
|
|
}
|
|
|
}
|
|
|
- log.info("교차로예약계획_연계, SCS_T_CON_INTFPLAN ..END: {}", elapsed.elapsedTimeStr());
|
|
|
+ log.info("TB_INT_RESRV_PLAN, SCS_T_CON_INTFPLAN ..END: {}", elapsed.elapsedTimeStr());
|
|
|
}
|
|
|
//교차로시그널맵_연계, SCS_T_CON_INTSIGMAP
|
|
|
private void etlpIntSigmap() {
|
|
|
Elapsed elapsed = new Elapsed();
|
|
|
- log.info("교차로시그널맵_연계, SCS_T_CON_INTSIGMAP START.");
|
|
|
+ log.info("TB_INT_SIGNALMAP, SCS_T_CON_INTSIGMAP START.");
|
|
|
List<HashMap<String, Object>> lists = new ArrayList<>();
|
|
|
|
|
|
for (String key : this.centerList) {
|
|
@@ -386,7 +393,7 @@ public class GgitsEtlpService {
|
|
|
etlp.setStartTime(TimeUtils.now());
|
|
|
try {
|
|
|
MDC.put("id", center.getLogKey());
|
|
|
- log.info("교차로시그널맵_연계, SCS_T_CON_INTSIGMAP START. {}, {}, {}, {}",
|
|
|
+ log.info("TB_INT_SIGNALMAP, SCS_T_CON_INTSIGMAP START. {}, {}, {}, {}",
|
|
|
center.getRegionCd(), center.getRegionNm(), center.getMinNodeId(), center.getMaxNodeId());
|
|
|
List<TbScsTConIntSigmap> result = this.gitsMapper.selectScsTConIntSigmap(center);
|
|
|
etlp.setReadCount(result.size());
|
|
@@ -405,12 +412,14 @@ public class GgitsEtlpService {
|
|
|
}
|
|
|
etlp.setWriteCount(writeCount);
|
|
|
etlp.setSuccess(true);
|
|
|
- log.info("교차로시그널맵_연계, SCS_T_CON_INTSIGMAP ..END. {}, {}, {} EA. {} ms.",
|
|
|
- center.getRegionCd(), center.getRegionNm(), result.size(), job.milliSeconds());
|
|
|
+ log.info("TB_INT_SIGNALMAP, SCS_T_CON_INTSIGMAP ..END. {}, {}, JOB: {}, WRITE: {} EA. {} ms.",
|
|
|
+ center.getRegionCd(), center.getRegionNm(), result.size(), writeCount, job.milliSeconds());
|
|
|
+ log.info("<================================================================================================");
|
|
|
}
|
|
|
catch (Exception e) {
|
|
|
etlp.setSuccess(false);
|
|
|
- log.error("교차로시그널맵_연계, SCS_T_CON_INTSIGMAP: {}, {}, Exceptions: {}", center.getRegionCd(), center.getRegionNm(), e.getMessage());
|
|
|
+ log.error("{}", lists.get(0));
|
|
|
+ log.error("TB_INT_SIGNALMAP, SCS_T_CON_INTSIGMAP: {}, {}, Exceptions: {}", center.getRegionCd(), center.getRegionNm(), e.getMessage());
|
|
|
}
|
|
|
finally {
|
|
|
center.setElapsed(center.getElapsed() + job.milliSeconds());
|
|
@@ -418,6 +427,6 @@ public class GgitsEtlpService {
|
|
|
MDC.clear();
|
|
|
}
|
|
|
}
|
|
|
- log.info("교차로시그널맵_연계, SCS_T_CON_INTSIGMAP ..END: {}", elapsed.elapsedTimeStr());
|
|
|
+ log.info("TB_INT_SIGNALMAP, SCS_T_CON_INTSIGMAP ..END: {}", elapsed.elapsedTimeStr());
|
|
|
}
|
|
|
}
|