|
@@ -82,7 +82,10 @@ public class DbmsDataProcess {
|
|
}
|
|
}
|
|
|
|
|
|
public void process(DbmsData data) {
|
|
public void process(DbmsData data) {
|
|
- int result = -1;
|
|
|
|
|
|
+ int result1 = -1;
|
|
|
|
+ int result2 = -1;
|
|
|
|
+ long elapsedTime1 = 0;
|
|
|
|
+ long elapsedTime2 = 0;
|
|
int type = -1;
|
|
int type = -1;
|
|
int count = 0;
|
|
int count = 0;
|
|
RegionCenter center = data.getCenter();
|
|
RegionCenter center = data.getCenter();
|
|
@@ -97,21 +100,31 @@ public class DbmsDataProcess {
|
|
count = intTypeLists.size();
|
|
count = intTypeLists.size();
|
|
if (data.getCenter().isSimulateFlag()) {
|
|
if (data.getCenter().isSimulateFlag()) {
|
|
// 상태정보 업데이트
|
|
// 상태정보 업데이트
|
|
- result = this.sigTodpServerDao.updateIntSimulationSend(intTypeLists);
|
|
|
|
|
|
+ try {
|
|
|
|
+ result1 = this.sigTodpServerDao.updateIntSimulationSend(intTypeLists);
|
|
|
|
+ }
|
|
|
|
+ catch (Exception e) {
|
|
|
|
+ log.error("DbmsJobProcess.process: [{}]. {}, updateIntSimulationSend, Exception: {}", center.getLogKey(), type, e.getMessage());
|
|
|
|
+ }
|
|
|
|
+ elapsedTime1 = elapsed1.milliSeconds();
|
|
}
|
|
}
|
|
// TOD 데이터 무조건 업데이트
|
|
// TOD 데이터 무조건 업데이트
|
|
- result = this.sigTodpServerDao.updateIntSimulationSendTrans(intTypeLists);
|
|
|
|
|
|
+ elapsed1.reset();
|
|
|
|
+ try {
|
|
|
|
+ result2 = this.sigTodpServerDao.updateIntSimulationSendTrans(intTypeLists);
|
|
|
|
+ }
|
|
|
|
+ catch (Exception e) {
|
|
|
|
+ log.error("DbmsJobProcess.process: [{}]. {}, updateIntSimulationSendTrans, Exception: {}", center.getLogKey(), type, e.getMessage());
|
|
|
|
+ }
|
|
|
|
+ elapsedTime2 = elapsed1.milliSeconds();
|
|
break;
|
|
break;
|
|
|
|
|
|
default:
|
|
default:
|
|
log.error("DbmsJobProcess.process: Unknown Request {}.", type);
|
|
log.error("DbmsJobProcess.process: Unknown Request {}.", type);
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
- log.info("DbmsDataProcess.run: [{}]. {}, Request: {}, Result: {} EA. {}",
|
|
|
|
- center.getLogKey(), type, count, result, Elapsed.elapsedTimeStr(elapsed1.nanoSeconds()));
|
|
|
|
- }
|
|
|
|
- catch (Exception e) {
|
|
|
|
- log.error("DbmsJobProcess.process: [{}]. {}, Exception: {}", center.getLogKey(), type, e.getMessage());
|
|
|
|
|
|
+ log.info("DbmsDataProcess.run: [{}]. Request: {}, updateIntSimulationSend({} EA. {} ms.), updateIntSimulationSendTrans({} EA. {} ms.)",
|
|
|
|
+ center.getLogKey(), count, result1, elapsedTime1, result2, elapsedTime2);
|
|
}
|
|
}
|
|
finally {
|
|
finally {
|
|
MDC.remove(center.getLogKey());
|
|
MDC.remove(center.getLogKey());
|