dev

src/main/java/com/its/traf/TrafPrcsServerApplication.java

@@ -12,7 +12,6 @@ import com.its.traf.service.its.UnitSystService;
 import com.its.traf.ui.JTextAreaOutputStream;
 import com.its.traf.ui.MainUI;
 import com.its.traf.xnet.center.udp.CenterCommUdpServer;
-import com.its.traf.xnet.center.udp.service.TrafficNotifyDataSender;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.DisposableBean;
 import org.springframework.beans.factory.InitializingBean;
@@ -156,9 +155,6 @@ public class TrafPrcsServerApplication implements CommandLineRunner, Application
         CenterCommUdpServer centerCommUdpServer = (CenterCommUdpServer)AppUtils.getBean(CenterCommUdpServer.class);
         centerCommUdpServer.run();
 
-        TrafficNotifyDataSender tess = (TrafficNotifyDataSender)AppUtils.getBean(TrafficNotifyDataSender.class);
-        tess.notifyTrafficPrcsCompleted("12345678901234");
-
         // schedule enable
         applicationConfig.setStartSchedule(true);
 

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

@@ -102,7 +102,7 @@ public class TrafPrcs05MController implements AbstractTrafPrcsController {
         this.prcsTime.setProcessing(false);
 
         // 가공완료 정보를 통보
-        this.trafficNotifyDataSender.notifyTrafficPrcsCompleted(this.prcsTime.getCurrTime());
+        this.trafficNotifyDataSender.notifyTrafficPrcsCompleted(this.prcsTime.getCurrFiveMin(), this.prcsTime.getPrcsFiveMin());
 
         AppRepository.getInstance().endPrcsJob(eTrafPrcsJob.PRCS_05M_ALL, 0, true);
 

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

@@ -6,6 +6,7 @@ import com.its.traf.service.its.*;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Controller;
+import org.springframework.util.StopWatch;
 
 @Slf4j
 @Controller
@@ -39,6 +40,10 @@ public class TrafPrcs05MPrepareController implements AbstractTrafPrcsController
 
     @Override
     public void run() {
+        StopWatch stopWatch = new StopWatch();
+        stopWatch.start("Prepared Job");
+        log.info("[PREPARE---]                  TrafPrcs05MPrepareController: START.");
+
         /*
          * 가공에 사용되는 시각 정보를 초기화 한다.
          * 기본정보를 미리 읽기위해 가공시간 설정
@@ -86,5 +91,7 @@ public class TrafPrcs05MPrepareController implements AbstractTrafPrcsController
         AppRepository.getInstance().endPrcsJob(eTrafPrcsJob.LOAD_PATTERN, this.ptrnLink05MService.count() + this.ptrnLink15MService.count() + this.ptrnIfsc05MService.count() + this.ptrnIfsc15MService.count() + this.ptrnRoad05MService.count() + this.ptrnRoad15MService.count(), false);
 
         AppRepository.getInstance().endPrcsJob(eTrafPrcsJob.LOAD_ALL, 0, true);
+        stopWatch.stop();
+        log.info("[PREPARE---]                  TrafPrcs05MPrepareController: ..END. {} ms", stopWatch.getTotalTimeMillis());
     }
 }

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

@@ -11,6 +11,7 @@ import com.its.traf.process.DbmsDataProcess;
 import com.its.traf.process.DbmsDataType;
 import com.its.traf.service.AbstractDataService;
 import com.its.traf.service.AbstractPrcsService;
+import com.its.traf.service.its.dao.IfscDaoService;
 import com.its.traf.vo.traffic.voIfscTraf;
 import com.its.traf.vo.traffic.voLinkTraf;
 import lombok.RequiredArgsConstructor;
@@ -35,6 +36,7 @@ public class TbIfscService extends AbstractDataService<Long, TbIfscDto> implemen
     private final TbSectGradService sectGradService;
     private final TbHldyInfrService hldyService;
     private final DbmsDataProcess dbmsDataProcess;
+    private final IfscDaoService ifscDaoService;
 
     /**
      * 기존 데이터 초기화
@@ -225,7 +227,8 @@ public class TbIfscService extends AbstractDataService<Long, TbIfscDto> implemen
 
         //if (updLists.size() > 0) {
             AppRepository.getInstance().startPrcsJob(eTrafPrcsJob.PRCS_IFSC_TRAF);
-            this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_IFSC_TRAF_UPDATE, false, updLists, updLists.size()));
+            //this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_IFSC_TRAF_UPDATE, false, updLists, updLists.size()));
+            this.ifscDaoService.batchUpdateFunc(DbmsDataType.TB_IFSC_TRAF_UPDATE, updLists);
         //}
         //if (insLists.size() > 0) {
             AppRepository.getInstance().startPrcsJob(eTrafPrcsJob.PRCS_IFSC_TRAF_HS);

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

@@ -14,6 +14,7 @@ import com.its.traf.scheduler.aspectj.SchedulerElapsed;
 import com.its.traf.service.AbstractDataService;
 import com.its.traf.service.AbstractPrcsService;
 import com.its.traf.service.its.collect.LinkRawDataCollectService;
+import com.its.traf.service.its.dao.LinkDaoService;
 import com.its.traf.service.its.prcs.TrafPrcsCorrectAlgo;
 import com.its.traf.service.its.prcs.TrafPrcsFilteringAlgo;
 import com.its.traf.service.its.prcs.TrafPrcsFusionAlgo;
@@ -50,6 +51,7 @@ public class TbLinkService extends AbstractDataService<Long, TbLinkDto> implemen
     private final TrafPrcsFilteringAlgo filteringAlgo;
     private final TrafPrcsFusionAlgo fusionAlgo;
     private final TrafPrcsSmoothingAlgo smoothingAlgo;
+    private final LinkDaoService linkDaoService;
 
     private List<voLinkFilter> linkFilterList = null;
 
@@ -489,7 +491,8 @@ public class TbLinkService extends AbstractDataService<Long, TbLinkDto> implemen
         }
 
         if (insLists.size() > 0) {
-            this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_INCD_ESTM_SECT_INSERT, false, insLists, insLists.size()));
+            //this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_INCD_ESTM_SECT_INSERT, false, insLists, insLists.size()));
+            this.linkDaoService.batchInsertFunc(DbmsDataType.TB_INCD_ESTM_SECT_INSERT, insLists);
         }
         return insLists.size();
     }
@@ -549,7 +552,8 @@ public class TbLinkService extends AbstractDataService<Long, TbLinkDto> implemen
 
         //if (updLists.size() > 0) {
             AppRepository.getInstance().startPrcsJob(eTrafPrcsJob.PRCS_LINK_TRAF);
-            this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_LINK_TRAF_UPDATE, false, updLists, updLists.size()));
+            //this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_LINK_TRAF_UPDATE, false, updLists, updLists.size()));
+            this.linkDaoService.batchUpdateFunc(DbmsDataType.TB_LINK_TRAF_UPDATE, updLists);
         //}
         //if (insLists.size() > 0) {
             AppRepository.getInstance().startPrcsJob(eTrafPrcsJob.PRCS_LINK_TRAF_HS);
@@ -600,6 +604,7 @@ public class TbLinkService extends AbstractDataService<Long, TbLinkDto> implemen
         }
         if (lists.size() > 0) {
             this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_CLCT_SYST_STTS_HS_INSERT, false, lists, lists.size()));
+            //this.linkDaoService.batchInsertFunc(DbmsDataType.TB_CLCT_SYST_STTS_HS_INSERT, lists);
         }
     }
 

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

@@ -11,6 +11,7 @@ import com.its.traf.process.DbmsDataProcess;
 import com.its.traf.process.DbmsDataType;
 import com.its.traf.service.AbstractDataService;
 import com.its.traf.service.AbstractPrcsService;
+import com.its.traf.service.its.dao.RoadDaoService;
 import com.its.traf.vo.traffic.voIfscTraf;
 import com.its.traf.vo.traffic.voRoadTraf;
 import lombok.RequiredArgsConstructor;
@@ -35,6 +36,7 @@ public class TbRoadService extends AbstractDataService<Long, TbRoadDto> implemen
     private final TbSectGradService sectGradService;
     private final TbHldyInfrService hldyService;
     private final DbmsDataProcess dbmsDataProcess;
+    private final RoadDaoService roadDaoService;
 
     /**
      * 기존 데이터 초기화
@@ -226,7 +228,8 @@ public class TbRoadService extends AbstractDataService<Long, TbRoadDto> implemen
 
         //if (updLists.size() > 0) {
             AppRepository.getInstance().startPrcsJob(eTrafPrcsJob.PRCS_ROAD_TRAF);
-            this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_ROAD_TRAF_UPDATE, false, updLists, updLists.size()));
+            //this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_ROAD_TRAF_UPDATE, false, updLists, updLists.size()));
+            this.roadDaoService.batchUpdateFunc(DbmsDataType.TB_ROAD_TRAF_UPDATE, updLists);
         //}
         //if (insLists.size() > 0) {
             AppRepository.getInstance().startPrcsJob(eTrafPrcsJob.PRCS_ROAD_TRAF_HS);

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

@@ -1,6 +1,5 @@
 package com.its.traf.service.its;
 
-import com.its.traf.config.AppUtils;
 import com.its.traf.dao.mapper.its.VmsIfscMapper;
 import com.its.traf.dto.its.*;
 import com.its.traf.global.AppRepository;
@@ -10,6 +9,7 @@ import com.its.traf.process.DbmsDataProcess;
 import com.its.traf.process.DbmsDataType;
 import com.its.traf.service.AbstractDataService;
 import com.its.traf.service.AbstractPrcsService;
+import com.its.traf.service.its.dao.VmsIfscDaoService;
 import com.its.traf.vo.traffic.voIfscTraf;
 import com.its.traf.vo.traffic.voVmsIfscTraf;
 import lombok.RequiredArgsConstructor;
@@ -28,6 +28,8 @@ public class TbVmsIfscService extends AbstractDataService<Long, TbVmsIfscDto> im
     private final TrafPrcsTime prcsTime;
     private final TbIfscService ifscService;
     private final TbVmsIfscGradService cmtrGradService;
+    private final DbmsDataProcess dbmsDataProcess;
+    private final VmsIfscDaoService vmsIfscDaoService;
 
     /**
      * 기존 데이터 초기화
@@ -190,14 +192,14 @@ public class TbVmsIfscService extends AbstractDataService<Long, TbVmsIfscDto> im
             }
         }
 
-        DbmsDataProcess dbmsDataProcess = (DbmsDataProcess) AppUtils.getBean(DbmsDataProcess.class);
         //if (updLists.size() > 0) {
             AppRepository.getInstance().startPrcsJob(eTrafPrcsJob.PRCS_VMS_TRAF);
-            dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_VMS_IFSC_TRAF_UPDATE, false, updLists, updLists.size()));
+            //this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_VMS_IFSC_TRAF_UPDATE, false, updLists, updLists.size()));
+            this.vmsIfscDaoService.batchUpdateFunc(DbmsDataType.TB_VMS_IFSC_TRAF_UPDATE, updLists);
         //}
         //if (insLists.size() > 0) {
             AppRepository.getInstance().startPrcsJob(eTrafPrcsJob.PRCS_VMS_TRAF_HS);
-            dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_VMS_IFSC_TRAF_HS_INSERT, false, insLists, insLists.size()));
+            this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_VMS_IFSC_TRAF_HS_INSERT, false, insLists, insLists.size()));
         //}
     }
 }

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

@@ -2,11 +2,10 @@ package com.its.traf.service.its;
 
 import com.its.traf.dto.its.TbLinkDto;
 import com.its.traf.dto.its.TbTrafPrcnStatDto;
-import com.its.traf.process.DbmsData;
-import com.its.traf.process.DbmsDataProcess;
 import com.its.traf.process.DbmsDataType;
 import com.its.traf.service.AbstractDataService;
 import com.its.traf.service.AbstractPrcsService;
+import com.its.traf.service.its.dao.LinkDaoService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -21,7 +20,8 @@ public class TrafPrcsCountService extends AbstractDataService<Long, TbLinkDto> i
     private final TbIfscService ifscService;
     private final TbRoadService roadService;
     private final TbVmsIfscService vmsIfscService;
-    private final DbmsDataProcess dbmsDataProcess;
+    //private final DbmsDataProcess dbmsDataProcess;
+    private final LinkDaoService linkDaoService;
 
     @Override
     public int load() {
@@ -54,7 +54,9 @@ public class TrafPrcsCountService extends AbstractDataService<Long, TbLinkDto> i
                 .VMS_IFSC_DELY_NUM(this.vmsIfscService.getDelyNum())
                 .VMS_IFSC_CNGS_NUM(this.vmsIfscService.getCngsNum())
                 .build();
-        this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_TRAF_PRCN_STAT_CREATE, false, stat, 1));
+
+        //this.dbmsDataProcess.add(new DbmsData(DbmsDataType.TB_TRAF_PRCN_STAT_CREATE, false, stat, 1));
+        this.linkDaoService.directQueryFunc(DbmsDataType.TB_TRAF_PRCN_STAT_CREATE, stat);
         return 0;
     }
 

src/main/java/com/its/traf/service/its/collect/LinkRawDataCollectService.java

@@ -89,7 +89,7 @@ public class LinkRawDataCollectService {
             if (collect != null) {
                 systStup.setClctNum(collect.getLists().size());
             }
-            log.info("LinkRawDataCollectService:collect: [{}], [{}] EA.", clctSyst, systStup.getClctNum());
+            log.info("[COLLECTING]LinkRawDataCollectService:collect: [{}], [{}] EA.", clctSyst, systStup.getClctNum());
         }
         return this.mapData.size();
     }

src/main/java/com/its/traf/service/its/collect/LinkRawDataCollectWorker.java

@@ -9,6 +9,7 @@ import com.its.traf.service.its.dao.LinkRawDataDaoService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.ibatis.session.SqlSessionFactory;
+import org.springframework.util.StopWatch;
 
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -41,8 +42,11 @@ public class LinkRawDataCollectWorker implements Runnable {
         } else if ("gits01".equals(beanName)) {
             jobType = eTrafPrcsJob.PRCS_LOAD_RAW_GITS;
         }
+
+        StopWatch stopWatch = new StopWatch();
         if (jobType != null) {
             AppRepository.getInstance().startPrcsJob(jobType);
+            stopWatch.start(jobType.getName());
         }
 
         try {
@@ -50,16 +54,20 @@ public class LinkRawDataCollectWorker implements Runnable {
         } catch (Exception e) {
             sqlSessionFactory = (SqlSessionFactory)AppUtils.getBean(SqlSessionFactory.class);
         }
+        int resultCount = 0;
         try {
             Thread.sleep(10);
             LinkRawDataDaoService linkRawDataDaoService = new LinkRawDataDaoService(sqlSessionFactory);
             List<LinkRawDataDto> result = linkRawDataDaoService.collect(this.CLCT_SYST_CD, this.params);
             if (result == null) {
-                this.mapData.put(this.CLCT_SYST_CD, LinkRawDataResultDto.builder().CLCT_SYST_CD(this.CLCT_SYST_CD).lists(new ArrayList<>()).build());
+                result = new ArrayList<>();
+                //this.mapData.put(this.CLCT_SYST_CD, LinkRawDataResultDto.builder().CLCT_SYST_CD(this.CLCT_SYST_CD).lists(new ArrayList<>()).build());
             }
             else {
-                this.mapData.put(this.CLCT_SYST_CD, LinkRawDataResultDto.builder().CLCT_SYST_CD(this.CLCT_SYST_CD).lists(result).build());
+                resultCount = result.size();
+                //this.mapData.put(this.CLCT_SYST_CD, LinkRawDataResultDto.builder().CLCT_SYST_CD(this.CLCT_SYST_CD).lists(result).build());
             }
+            this.mapData.put(this.CLCT_SYST_CD, LinkRawDataResultDto.builder().CLCT_SYST_CD(this.CLCT_SYST_CD).lists(result).build());
         } catch (InterruptedException e) {
             this.mapData.put(this.CLCT_SYST_CD, LinkRawDataResultDto.builder().CLCT_SYST_CD(this.CLCT_SYST_CD).lists(new ArrayList<>()).build());
         } catch (Exception e) {
@@ -67,6 +75,8 @@ public class LinkRawDataCollectWorker implements Runnable {
         }
         if (jobType != null) {
             AppRepository.getInstance().endPrcsJob(jobType, this.mapData.get(this.CLCT_SYST_CD).getLists().size(), false);
+            stopWatch.stop();
+            log.info("[COLLECTING] LinkRawDataCollectWorker:run----: [{}], [{}] EA. {} ms.", jobType.getName(), resultCount, stopWatch.getTotalTimeMillis());
         }
     }
 

src/main/java/com/its/traf/xnet/center/protocol/CENTER_COMM_MESSAGE.java

@@ -27,8 +27,8 @@ public class CENTER_COMM_MESSAGE {
 	public CENTER_COMM_MESSAGE() {
 
 	}
-	public CENTER_COMM_MESSAGE(int recvId, int opCode, int length, byte msgSeq) {
-		this.sendId       = (byte)CENTER_COMM_DEFINE.INT_ID_MAIN_OPER;
+	public CENTER_COMM_MESSAGE(int senderId, int recvId, int opCode, int length, byte msgSeq) {
+		this.sendId       = (byte)senderId;
 		this.recvId       = (byte)recvId;
 		this.totalFrame   = 1;
 		this.currentFrame = 1;

src/main/java/com/its/traf/xnet/center/protocol/CENTER_PG_STATE_RES.java

@@ -22,9 +22,9 @@ public class CENTER_PG_STATE_RES extends CENTER_COMM_MESSAGE {
 	private byte comm;
 	private byte action;
 
-	public CENTER_PG_STATE_RES(int senderId, byte db, byte comm, byte action) {
+	public CENTER_PG_STATE_RES(int senderId, int receiverId, byte db, byte comm, byte action) {
 
-		super(senderId, CENTER_COMM_DEFINE.INT_OP_PG_STATE_RES, 0, (byte)0x00);
+		super(senderId, receiverId, CENTER_COMM_DEFINE.INT_OP_PG_STATE_RES, 0, (byte)0x00);
 
 		this.count  = 0x01;
 		this.type   = (byte)senderId;

src/main/java/com/its/traf/xnet/center/protocol/CENTER_TRAFFIC_CHANGE.java

@@ -14,10 +14,12 @@ import java.nio.ByteOrder;
 public class CENTER_TRAFFIC_CHANGE extends CENTER_COMM_MESSAGE {
 
 	private String prcsTm;
+	private String currTm;
 
-	public CENTER_TRAFFIC_CHANGE(String prcsTm) {
-		super(CENTER_COMM_DEFINE.INT_ID_TRAFFIC_SERVER , CENTER_COMM_DEFINE.INT_OP_TRAFFIC_CHANGE, 0, (byte)0x00);
-		this.prcsTm  = prcsTm;
+	public CENTER_TRAFFIC_CHANGE(String prcsTm, String currTm) {
+		super(CENTER_COMM_DEFINE.INT_ID_TRAFFIC_SERVER, CENTER_COMM_DEFINE.INT_ID_MAIN_OPER , CENTER_COMM_DEFINE.INT_OP_TRAFFIC_CHANGE, 0, (byte)0x00);
+		this.prcsTm = prcsTm;
+		this.currTm = currTm;
 	}
 
 	public void setSenderId(int senderId) {
@@ -26,10 +28,10 @@ public class CENTER_TRAFFIC_CHANGE extends CENTER_COMM_MESSAGE {
 
 	@Override
 	public ByteBuffer getBuffer() {
-		int pktSize = CENTER_COMM_DEFINE.INT_TRAFFIC_TIME_SIZE;
+		int pktSize = CENTER_COMM_DEFINE.INT_TRAFFIC_TIME_SIZE + CENTER_COMM_DEFINE.INT_TRAFFIC_TIME_SIZE;
 		setLength((short)pktSize);
 
-		ByteBuffer byteBuffer = ByteBuffer.allocate(CENTER_HEADER_SIZE + getLength());
+		ByteBuffer byteBuffer = ByteBuffer.allocate(CENTER_COMM_MESSAGE.CENTER_HEADER_SIZE + getLength());
 		byteBuffer.order(ByteOrder.LITTLE_ENDIAN);
 
 		byteBuffer.put(getSendId());
@@ -38,12 +40,16 @@ public class CENTER_TRAFFIC_CHANGE extends CENTER_COMM_MESSAGE {
 		byteBuffer.put(getCurrentFrame());
 		byteBuffer.put(getMsgSeq());
 		byteBuffer.put(getOpCode());
-		byteBuffer.putShort((short)getLength());
+		byteBuffer.putShort(getLength());
 
 		byte[] prcsTmArr = new byte[CENTER_COMM_DEFINE.INT_TRAFFIC_TIME_SIZE];
 		SysUtils.copyStringToByteArray(prcsTmArr, prcsTmArr.length, this.prcsTm);
 		byteBuffer.put(prcsTmArr);
 
+		byte[] currTmArr = new byte[CENTER_COMM_DEFINE.INT_TRAFFIC_TIME_SIZE];
+		SysUtils.copyStringToByteArray(currTmArr, currTmArr.length, this.currTm);
+		byteBuffer.put(currTmArr);
+
 		return byteBuffer;
 	}
 

src/main/java/com/its/traf/xnet/center/udp/codec/CenterCommClientEncoder.java

@@ -46,7 +46,7 @@ public class CenterCommClientEncoder extends MessageToMessageEncoder<Object> {
 			log.info("SEND UDP: [ALL], {} Bytes.", sendBytes);
 		}
 		else {
-			log.info("SEND UDP: [{}:{}], {} Bytes.", this.remoteIpAddr, this.remotePort, sendBytes);
+			//log.info("SEND UDP: [{}:{}], {} Bytes.", this.remoteIpAddr, this.remotePort, sendBytes);
 		}
 
 		//log.info("SEND UDP, DUMP: {}", SysUtils.byteArrayToHex(((ByteBuffer) msg).array()));

src/main/java/com/its/traf/xnet/center/udp/service/TrafficNotifyDataSender.java

@@ -25,10 +25,10 @@ public class TrafficNotifyDataSender {
      *
      * @param prcsTm
      */
-    public void notifyTrafficPrcsCompleted(String prcsTm) {
-        log.info("notifyTrafficPrcsCompleted: {}", prcsTm);
+    public void notifyTrafficPrcsCompleted(String prcsTm, String currTm) {
+        //log.info("notifyTrafficPrcsCompleted: {}/{}", prcsTm, currTm);
         int sendUnit = 0;
-        CENTER_TRAFFIC_CHANGE commMsg = new CENTER_TRAFFIC_CHANGE(prcsTm);
+        CENTER_TRAFFIC_CHANGE commMsg = new CENTER_TRAFFIC_CHANGE(prcsTm, currTm);
 
         ConcurrentHashMap<String, TbUnitSystDto> unitSystMap = this.unitSystService.getUnitSystMap();
 		for (Map.Entry<String, TbUnitSystDto> e : unitSystMap.entrySet()) {
@@ -39,22 +39,22 @@ public class TrafficNotifyDataSender {
 
             boolean sendData = false;
             if ("UOT".equals(unit.getSYST_TYPE())) {
-                commMsg.setSenderId(CENTER_COMM_DEFINE.INT_ID_MAIN_OPER);
+                commMsg.setRecvId((byte)CENTER_COMM_DEFINE.INT_ID_MAIN_OPER);
                 sendData = true;
             }
             if ("VMS".equals(unit.getSYST_TYPE())) {
-                commMsg.setSenderId(CENTER_COMM_DEFINE.INT_ID_VMS_OPER);
+                commMsg.setRecvId((byte)CENTER_COMM_DEFINE.INT_ID_VMS_OPER);
                 sendData = true;
             }
             if (!sendData) {
                 continue;
             }
-            log.info("notifyTrafficPrcsCompleted: request {}:{}", unit.getSYST_IP_1(), unit.getPRGM_PORT());
+            //log.info("notifyTrafficPrcsCompleted: request {}:{}", unit.getSYST_IP_1(), unit.getPRGM_PORT());
             this.centerCommClientSender.run(unit.getSYST_IP_1(), unit.getPRGM_PORT(), commMsg.getBuffer());
             sendUnit++;
 		}
 
-        log.info("notifyTrafficPrcsCompleted: {}, Send {} Unit.", prcsTm, sendUnit);
+        log.info("[NOTIFY-TRF]                    notifyTrafficPrcsCompleted: {}/{}, Send {} Unit.", prcsTm, currTm, sendUnit);
     }
 
 }

src/main/java/com/its/traf/xnet/center/udp/thread/CenterCommClientSender.java

@@ -39,15 +39,15 @@ public class CenterCommClientSender {
             Channel channel = bootstrap.bind(0).sync().channel();
             ChannelFuture f = channel.writeAndFlush(sendBuffer).sync();
             if (!f.isDone() || !f.isSuccess()) {
-                log.error("CenterCommClientSender.run: Send Failed. isDone: {}, isSuccess: {}", f.isDone(), f.isSuccess());
+                log.error("[UDP-DATA  ]                    CenterCommClientSender.run: .SEND Failed. isDone: {}, isSuccess: {}", f.isDone(), f.isSuccess());
             }
         }
         catch(InterruptedException e) {
-            log.error("CenterCommClientSender.run: InterruptedException");
+            log.error("[UDP-DATA  ]                    CenterCommClientSender.run: .SEND InterruptedException");
         }
         finally {
             nioEventLoopGroup.shutdownGracefully();
-            log.info("CenterCommClientSender.run: {} Bytes, ip: {}, port: {}", sendBuffer.array().length, ip, port);
+            log.info("[UDP-DATA  ]                    CenterCommClientSender.run: .SEND {} Bytes, ip: {}, port: {}", sendBuffer.array().length, ip, port);
         }
     }
 }