shjung 2 жил өмнө
parent
commit
6669a9cd4d

+ 56 - 53
src/main/java/com/its/dsrc/DsrcCommServerApplication.java

@@ -1,6 +1,7 @@
 package com.its.dsrc;
 
 import com.its.app.AppUtils;
+import com.its.app.utils.OS;
 import com.its.app.utils.SysUtils;
 import com.its.dsrc.config.ProcessConfig;
 import com.its.dsrc.process.DbmsDataProcess;
@@ -13,11 +14,11 @@ import com.its.dsrc.ui.MainUI;
 import com.its.dsrc.xnettcp.dsrc.DsrcTcpCommServerService;
 import com.its.dsrc.xnettcp.dsrc.process.TcpServerDataProcess;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.catalina.connector.Connector;
 import org.springframework.beans.factory.DisposableBean;
 import org.springframework.beans.factory.InitializingBean;
 import org.springframework.boot.Banner;
 import org.springframework.boot.CommandLineRunner;
+import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.builder.SpringApplicationBuilder;
 import org.springframework.boot.context.ApplicationPidFileWriter;
@@ -60,30 +61,30 @@ import java.net.URL;
 //public class DsrcCommServerApplication implements CommandLineRunner, ApplicationListener<ContextClosedEvent>, InitializingBean, DisposableBean {
 public class DsrcCommServerApplication implements CommandLineRunner, ApplicationListener<ContextClosedEvent>, InitializingBean, DisposableBean {
 
-    private Connector connector;
+    private static String applicationName = "dsrc-comm-server";
 
     public static void main(String[] args) {
-        File file1 = new File("./conf/dsrc-comm-server.pid");
+        File file1 = new File("./conf/" + applicationName + ".pid");
         if (file1.exists()) {
             System.out.println(System.getProperty("Program Already Running....."));
             log.error("Program Already Running.....");
-            //return;
         }
 
-        ApplicationContext context = new SpringApplicationBuilder(DsrcCommServerApplication.class)
-                //.web(WebApplicationType.NONE)
-                .listeners(new ApplicationPidFileWriter("./conf/dsrc-comm-server.pid"))
-                .headless(false)
-                .bannerMode(Banner.Mode.OFF)
-                .run(args);
-
-//        SpringApplication application = new SpringApplicationBuilder()
-//                .sources(DsrcCommServerApplication.class)
-//                .listeners(new ApplicationPidFileWriter("./conf/dsrc-comm-server.pid"))
-//                //.headless(false)
-//                //.web(WebApplicationType.NONE)
-//                .build();
-//        application.run(args);
+        if (!OS.isWindows()) {
+            ApplicationContext context = new SpringApplicationBuilder(DsrcCommServerApplication.class)
+                    //.web(WebApplicationType.NONE)
+                    .listeners(new ApplicationPidFileWriter("./conf/" + applicationName + ".pid"))
+                    .headless(false)
+                    .bannerMode(Banner.Mode.OFF)
+                    .run(args);
+        } else {
+            SpringApplication application = new SpringApplicationBuilder()
+                    .sources(DsrcCommServerApplication.class)
+                    .listeners(new ApplicationPidFileWriter("./conf/" + applicationName + ".pid"))
+                    .build();
+            application.setBannerMode(Banner.Mode.OFF);
+            application.run(args);
+        }
     }
 
     @Override
@@ -132,43 +133,45 @@ public class DsrcCommServerApplication implements CommandLineRunner, Application
         // schedule enable
         processConfig.setStartSchedule(true);
 
-        SwingUtilities.invokeLater(() -> {
-            String sysTime = SysUtils.getSysTimeStr();
-            //JFrame.setDefaultLookAndFeelDecorated(true);
-            JFrame frame = new JFrame("DSRC 통신 서버 - [" + sysTime + "]");
-            MainUI UI = new MainUI(frame);
-            try {
-                ClassPathResource file = new ClassPathResource("static/image/application.png");
-                URL imgURL = file.getURL();
-                frame.setIconImage(new ImageIcon(imgURL).getImage());
-            } catch (IOException e) {
-                log.error("Not found application icon image");
-            }
-            frame.setModalExclusionType(Dialog.ModalExclusionType.APPLICATION_EXCLUDE);
-            frame.setContentPane(UI.getRootPanel());
-            frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
-            frame.addWindowListener(new WindowAdapter() {
-                @Override
-                public void windowClosing(WindowEvent e) {
-                    if (JOptionPane.showConfirmDialog(UI.getRootPanel(), "시스템을 종료 하시겠습니까?", "시스템 종료", 0) == 0) {
-                        System.exit(0);
-                    } else {
-                        frame.setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE);
-                    }
+        if (!OS.isWindows()) {
+            SwingUtilities.invokeLater(() -> {
+                String sysTime = SysUtils.getSysTimeStr();
+                //JFrame.setDefaultLookAndFeelDecorated(true);
+                JFrame frame = new JFrame("DSRC 통신 서버 - [" + sysTime + "]");
+                MainUI UI = new MainUI(frame);
+                try {
+                    ClassPathResource file = new ClassPathResource("static/image/application.png");
+                    URL imgURL = file.getURL();
+                    frame.setIconImage(new ImageIcon(imgURL).getImage());
+                } catch (IOException e) {
+                    log.error("Not found application icon image");
                 }
+                frame.setModalExclusionType(Dialog.ModalExclusionType.APPLICATION_EXCLUDE);
+                frame.setContentPane(UI.getRootPanel());
+                frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
+                frame.addWindowListener(new WindowAdapter() {
+                    @Override
+                    public void windowClosing(WindowEvent e) {
+                        if (JOptionPane.showConfirmDialog(UI.getRootPanel(), "시스템을 종료 하시겠습니까?", "시스템 종료", 0) == 0) {
+                            System.exit(0);
+                        } else {
+                            frame.setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE);
+                        }
+                    }
+                });
+                frame.pack();
+                frame.setBounds(100, 100, 1000, 800);
+                frame.setLocationRelativeTo(null);
+                frame.setVisible(true);
+
+                JTextArea logArea = UI.getTaLog();
+                logArea.setText(null);
+                JTextAreaOutputStream out = new JTextAreaOutputStream(logArea);
+                System.setOut(new PrintStream(out));
+
+                UI.LoadControllerInfo();
             });
-            frame.pack();
-            frame.setBounds(100, 100, 1000, 800);
-            frame.setLocationRelativeTo(null);
-            frame.setVisible(true);
-
-            JTextArea logArea = UI.getTaLog();
-            logArea.setText(null);
-            JTextAreaOutputStream out = new JTextAreaOutputStream(logArea);
-            System.setOut(new PrintStream(out));
-
-            UI.LoadControllerInfo();
-        });
+        }
     }
 
     public void terminateApplication() {

+ 4 - 13
src/main/java/com/its/dsrc/process/DbmsData.java

@@ -7,20 +7,11 @@ import lombok.Setter;
 @Setter
 public class DbmsData {
 
-    public static final int DBMS_DATA_UNIT_SYST_STTS = 0;
-    public static final int DBMS_DATA_CTLR_STTS      = 1;
-    public static final int DBMS_DATA_OBU_GATHER_LOG = 10;
-    public static final int DBMS_DATA_SECT_TRAF_HS   = 11;
-    public static final int DBMS_DATA_SECT_PASS_HS   = 12;
-    public static final int DBMS_DATA_LOG_HS         = 13;
-    public static final int DBMS_DATA_MULTIMEDIA_HS  = 14;
-    public static final int DBMS_DATA_CTRL_HS        = 15;
+    private DbmsDataType type;
+    private boolean      isHistory;
+    private Object       data;
 
-    private int     type;
-    private boolean isHistory;
-    private Object  data;
-
-    public DbmsData(int type, boolean isHistory, Object data) {
+    public DbmsData(DbmsDataType type, boolean isHistory, Object data) {
         this.type      = type;
         this.isHistory = isHistory;
         this.data      = data;

+ 9 - 9
src/main/java/com/its/dsrc/process/DbmsDataProcess.java

@@ -77,7 +77,7 @@ public class DbmsDataProcess {
      * @param data
      */
     public void runJob(DbmsData data) {
-        if (data.getType() == DbmsData.DBMS_DATA_UNIT_SYST_STTS) {
+        if (data.getType() == DbmsDataType.DBMS_DATA_UNIT_SYST_STTS) {
             TbUnitSystStts stts = (TbUnitSystStts) data.getData();
             this.unitSystMapper.updateUnitSystStts(stts);       // 상태정보 업데이트
             if (data.isHistory()) {
@@ -91,9 +91,9 @@ public class DbmsDataProcess {
 
     public void process(DbmsData data) {
         try {
-            int type = data.getType();
+            DbmsDataType type = data.getType();
             switch(type) {
-                case DbmsData.DBMS_DATA_CTLR_STTS:
+                case DBMS_DATA_CTLR_STTS:
                     List<TbRseCtlrStts> ctlrSttsList = (List<TbRseCtlrStts>)data.getData();
                     this.rseCtlrDao.updateStts(ctlrSttsList, data.isHistory());
                     if (data.isHistory()) {
@@ -101,26 +101,26 @@ public class DbmsDataProcess {
                     }
                     ctlrSttsList.clear();
                     break;
-                case DbmsData.DBMS_DATA_OBU_GATHER_LOG:
+                case DBMS_DATA_OBU_GATHER_LOG:
                     List<TbRseObuClct> obuGatherInfos = (List<TbRseObuClct>)data.getData();
                     this.rseObuClctService.insertOBUGatherInfoHs(obuGatherInfos);
                     break;
-                case DbmsData.DBMS_DATA_SECT_TRAF_HS:
+                case DBMS_DATA_SECT_TRAF_HS:
                     List<TbRseSectTraf> sectTrafInfos = (List<TbRseSectTraf>)data.getData();
                     this.rseObuClctService.insertDsrcSectTraf(sectTrafInfos);
                     break;
-                case DbmsData.DBMS_DATA_SECT_PASS_HS:
+                case DBMS_DATA_SECT_PASS_HS:
                     List<TbRseSectPassHs> sectPassInfos = (List<TbRseSectPassHs>)data.getData();
                     this.rseObuClctService.insertDsrcSectPassHs(sectPassInfos);
                     break;
-                case DbmsData.DBMS_DATA_LOG_HS:
+                case DBMS_DATA_LOG_HS:
                     this.rseCtlrMapper.insertRseCtlrCnncHs((TbRseCtlrCnncHs)data.getData());
                     break;
-                case DbmsData.DBMS_DATA_MULTIMEDIA_HS:
+                case DBMS_DATA_MULTIMEDIA_HS:
                     List<TbRseOffrSectTraf> dsrcOffrInfrHs = (List<TbRseOffrSectTraf>)data.getData();
                     this.multimediaService.insertDsrcOffrInfrHs(dsrcOffrInfrHs);
                     break;
-                case DbmsData.DBMS_DATA_CTRL_HS:
+                case DBMS_DATA_CTRL_HS:
                     this.rseCtlrMapper.insertRseCtrlHs((TbRseCtrlHs)data.getData());
                     break;
             }

+ 14 - 0
src/main/java/com/its/dsrc/process/DbmsDataType.java

@@ -0,0 +1,14 @@
+package com.its.dsrc.process;
+
+public enum DbmsDataType {
+
+    DBMS_DATA_UNIT_SYST_STTS,
+    DBMS_DATA_CTLR_STTS,
+    DBMS_DATA_OBU_GATHER_LOG,
+    DBMS_DATA_SECT_TRAF_HS,
+    DBMS_DATA_SECT_PASS_HS,
+    DBMS_DATA_LOG_HS,
+    DBMS_DATA_MULTIMEDIA_HS,
+    DBMS_DATA_CTRL_HS,
+
+}

+ 2 - 1
src/main/java/com/its/dsrc/service/RseCtlrService.java

@@ -9,6 +9,7 @@ import com.its.dsrc.entity.TbRseObuNonCrypt;
 import com.its.dsrc.global.AppRepository;
 import com.its.dsrc.process.DbmsData;
 import com.its.dsrc.process.DbmsDataProcess;
+import com.its.dsrc.process.DbmsDataType;
 import com.its.dsrc.vo.NET;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -135,7 +136,7 @@ public class RseCtlrService {
         // 제어기 상태정보 DB 업데이트
         if (ctlrSttsList.size() > 0) {
             DbmsDataProcess dbmsDataProcess = (DbmsDataProcess) AppUtils.getBean(DbmsDataProcess.class);
-            dbmsDataProcess.add(new DbmsData(DbmsData.DBMS_DATA_CTLR_STTS, insHs, ctlrSttsList));
+            dbmsDataProcess.add(new DbmsData(DbmsDataType.DBMS_DATA_CTLR_STTS, insHs, ctlrSttsList));
         }
 
         log.info("RseCtlrService.updateCtlrStts: total {}, normal {}, error {}", normal + error, normal, error);

+ 4 - 3
src/main/java/com/its/dsrc/service/RseSectService.java

@@ -5,12 +5,13 @@ import com.its.app.utils.SysUtils;
 import com.its.dsrc.config.DsrcConfig;
 import com.its.dsrc.dao.mapper.RseSectMapper;
 import com.its.dsrc.entity.TbRseSect;
+import com.its.dsrc.entity.TbRseSectPassHs;
 import com.its.dsrc.entity.TbRseSectTraf;
 import com.its.dsrc.global.AppRepository;
 import com.its.dsrc.process.DbmsData;
 import com.its.dsrc.process.DbmsDataProcess;
+import com.its.dsrc.process.DbmsDataType;
 import com.its.dsrc.vo.voDsrcObuPassInfo;
-import com.its.dsrc.entity.TbRseSectPassHs;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -308,12 +309,12 @@ public class RseSectService {
 
         // 구간소통정보 목록을 데이터베이스에 저장
         if (sectTrafList.size() > 0) {
-            this.dbmsDataProcess.add(new DbmsData(DbmsData.DBMS_DATA_SECT_TRAF_HS, false, sectTrafList));
+            this.dbmsDataProcess.add(new DbmsData(DbmsDataType.DBMS_DATA_SECT_TRAF_HS, false, sectTrafList));
         }
 
         // OBU 구간 통행 정보를 데이터베이스에 저장
         if (sectPassList.size() > 0) {
-            this.dbmsDataProcess.add(new DbmsData(DbmsData.DBMS_DATA_SECT_PASS_HS, false, sectPassList));
+            this.dbmsDataProcess.add(new DbmsData(DbmsDataType.DBMS_DATA_SECT_PASS_HS, false, sectPassList));
         }
 
         log.info("makeDsrcSectTraffic: End.....");

+ 2 - 1
src/main/java/com/its/dsrc/service/UnitSystService.java

@@ -8,6 +8,7 @@ import com.its.dsrc.entity.TbUnitSyst;
 import com.its.dsrc.entity.TbUnitSystStts;
 import com.its.dsrc.process.DbmsData;
 import com.its.dsrc.process.DbmsDataProcess;
+import com.its.dsrc.process.DbmsDataType;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -120,7 +121,7 @@ public class UnitSystService {
             }
         }
         else {
-            this.dbmsDataProcess.add(new DbmsData(DbmsData.DBMS_DATA_UNIT_SYST_STTS, insHs, this.unitSystStts));
+            this.dbmsDataProcess.add(new DbmsData(DbmsDataType.DBMS_DATA_UNIT_SYST_STTS, insHs, this.unitSystStts));
             if (insHs) {
                 loadMaster();
             }

+ 3 - 2
src/main/java/com/its/dsrc/xnettcp/dsrc/handler/DsrcAsn1ServerIdleStatePacketHandler.java

@@ -5,10 +5,11 @@ import com.its.app.AppUtils;
 import com.its.app.utils.NettyUtils;
 import com.its.app.utils.SysUtils;
 import com.its.dsrc.entity.TbRseCtlr;
+import com.its.dsrc.entity.TbRseCtlrCnncHs;
 import com.its.dsrc.global.AppRepository;
 import com.its.dsrc.process.DbmsData;
 import com.its.dsrc.process.DbmsDataProcess;
-import com.its.dsrc.entity.TbRseCtlrCnncHs;
+import com.its.dsrc.process.DbmsDataType;
 import com.its.dsrc.xnettcp.dsrc.process.service.ControlDeviceService;
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelFuture;
@@ -95,7 +96,7 @@ public class DsrcAsn1ServerIdleStatePacketHandler extends IdleStateHandler {
                 voLog.setCLCT_DT(SysUtils.getSysTime());
 
                 log.debug("DsrcAsn1ServerIdleStatePacketHandler.---channelInactive: {}. {}", ipAddress, voLog.toString());
-                this.dbmsDataProcess.add(new DbmsData(DbmsData.DBMS_DATA_LOG_HS, false, voLog));
+                this.dbmsDataProcess.add(new DbmsData(DbmsDataType.DBMS_DATA_LOG_HS, false, voLog));
             }
             obj.setDupCon(false);
         }

+ 2 - 1
src/main/java/com/its/dsrc/xnettcp/dsrc/process/response/AcceptResponse.java

@@ -9,6 +9,7 @@ import com.its.dsrc.entity.TbRseCtlr;
 import com.its.dsrc.entity.TbRseCtrlHs;
 import com.its.dsrc.process.DbmsData;
 import com.its.dsrc.process.DbmsDataProcess;
+import com.its.dsrc.process.DbmsDataType;
 import com.its.dsrc.xnetudp.service.CenterCommResponseService;
 import io.netty.channel.ChannelHandlerContext;
 import lombok.extern.slf4j.Slf4j;
@@ -77,7 +78,7 @@ public class AcceptResponse implements DsrcAsn1Response {
             // 데이터베이스에 저장하고 운영단말로 전송한다.
             CenterCommResponseService responseService = (CenterCommResponseService) AppUtils.getBean(CenterCommResponseService.class);
             responseService.response(this.obj, command, (byte) 0x00);   // 명령 성공으로 설정
-            this.dbmsDataProcess.add(new DbmsData(DbmsData.DBMS_DATA_CTLR_STTS, false, command));
+            this.dbmsDataProcess.add(new DbmsData(DbmsDataType.DBMS_DATA_CTLR_STTS, false, command));
         }
         return true;
     }

+ 3 - 2
src/main/java/com/its/dsrc/xnettcp/dsrc/process/response/LoginResponse.java

@@ -12,10 +12,11 @@ import com.its.app.AppUtils;
 import com.its.app.utils.NettyUtils;
 import com.its.dsrc.config.DsrcConfig;
 import com.its.dsrc.entity.TbRseCtlr;
+import com.its.dsrc.entity.TbRseCtlrCnncHs;
 import com.its.dsrc.process.DbmsData;
 import com.its.dsrc.process.DbmsDataProcess;
+import com.its.dsrc.process.DbmsDataType;
 import com.its.dsrc.vo.NET;
-import com.its.dsrc.entity.TbRseCtlrCnncHs;
 import com.its.dsrc.xnettcp.dsrc.handler.DsrcAsn1ServerIdleStatePacketHandler;
 import com.its.dsrc.xnettcp.dsrc.process.service.LoginDeviceService;
 import io.netty.channel.ChannelFuture;
@@ -172,7 +173,7 @@ public class LoginResponse implements DsrcAsn1Response {
             // 중복 접속(이미 통신중인 세션이 존재함)
             voLog.setLOG_TYPE(Integer.toString(TbRseCtlrCnncHs.LOG_TYPE_DUP_LOGIN));
         }
-        this.dbmsDataProcess.add(new DbmsData(DbmsData.DBMS_DATA_LOG_HS,false, voLog));
+        this.dbmsDataProcess.add(new DbmsData(DbmsDataType.DBMS_DATA_LOG_HS,false, voLog));
 
         if (loginAccept) {
             this.obj.getSeq().resetValue();

+ 3 - 2
src/main/java/com/its/dsrc/xnettcp/dsrc/process/response/LogoutResponse.java

@@ -4,9 +4,10 @@ import com.beanit.asn1dsrc.dsrc.C2CAuthenticatedMessage;
 import com.its.app.AppUtils;
 import com.its.app.utils.NettyUtils;
 import com.its.dsrc.entity.TbRseCtlr;
+import com.its.dsrc.entity.TbRseCtlrCnncHs;
 import com.its.dsrc.process.DbmsData;
 import com.its.dsrc.process.DbmsDataProcess;
-import com.its.dsrc.entity.TbRseCtlrCnncHs;
+import com.its.dsrc.process.DbmsDataType;
 import io.netty.channel.ChannelHandlerContext;
 import lombok.extern.slf4j.Slf4j;
 
@@ -36,7 +37,7 @@ public class LogoutResponse implements DsrcAsn1Response {
             voLog.setRSE_CTLR_NMBR(this.obj.getID());
             voLog.setLOG_ADDRESS(NettyUtils.getRemoteIpAddress(this.ctx.channel()));
             voLog.setLoginInfo(this.c2c);
-            this.dbmsDataProcess.add(new DbmsData(DbmsData.DBMS_DATA_LOG_HS, false, voLog));
+            this.dbmsDataProcess.add(new DbmsData(DbmsDataType.DBMS_DATA_LOG_HS, false, voLog));
         }
         return true;
     }

+ 2 - 1
src/main/java/com/its/dsrc/xnettcp/dsrc/process/response/RejectResponse.java

@@ -10,6 +10,7 @@ import com.its.dsrc.entity.TbRseCtlr;
 import com.its.dsrc.entity.TbRseCtrlHs;
 import com.its.dsrc.process.DbmsData;
 import com.its.dsrc.process.DbmsDataProcess;
+import com.its.dsrc.process.DbmsDataType;
 import com.its.dsrc.xnettcp.dsrc.handler.DsrcAsn1ServerIdleStatePacketHandler;
 import com.its.dsrc.xnetudp.service.CenterCommResponseService;
 import io.netty.channel.ChannelHandlerContext;
@@ -73,7 +74,7 @@ public class RejectResponse implements DsrcAsn1Response {
             // 데이터베이스에 저장하고 운영단말로 전송한다.
             CenterCommResponseService responseService = (CenterCommResponseService) AppUtils.getBean(CenterCommResponseService.class);
             responseService.response(this.obj, command, (byte) 0x01);   // 명령 실패로 설정
-            this.dbmsDataProcess.add(new DbmsData(DbmsData.DBMS_DATA_CTLR_STTS, false, command));
+            this.dbmsDataProcess.add(new DbmsData(DbmsDataType.DBMS_DATA_CTLR_STTS, false, command));
         }
         return true;
     }

+ 3 - 2
src/main/java/com/its/dsrc/xnettcp/dsrc/process/service/ControlDeviceService.java

@@ -9,11 +9,12 @@ import com.its.app.AppUtils;
 import com.its.app.utils.SysUtils;
 import com.its.dsrc.entity.TbRseCtlr;
 import com.its.dsrc.entity.TbRseObuNonCrypt;
+import com.its.dsrc.entity.TbRseOffrDrct;
 import com.its.dsrc.global.AppRepository;
 import com.its.dsrc.process.DbmsData;
 import com.its.dsrc.process.DbmsDataProcess;
+import com.its.dsrc.process.DbmsDataType;
 import com.its.dsrc.vo.NET;
-import com.its.dsrc.entity.TbRseOffrDrct;
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelFuture;
 import lombok.extern.slf4j.Slf4j;
@@ -114,7 +115,7 @@ public class ControlDeviceService {
                 }
             }
             DbmsDataProcess dbmsDataProcess = (DbmsDataProcess) AppUtils.getBean(DbmsDataProcess.class);
-            dbmsDataProcess.add(new DbmsData(DbmsData.DBMS_DATA_CTLR_STTS, false, obj.getStts()));
+            dbmsDataProcess.add(new DbmsData(DbmsDataType.DBMS_DATA_CTLR_STTS, false, obj.getStts()));
 
             log.info("ControlDeviceService.decoding_ControlDevice_Status: {}", obj.getStts().toString());
         }

+ 2 - 1
src/main/java/com/its/dsrc/xnettcp/dsrc/process/service/MultiMediaDataService.java

@@ -16,6 +16,7 @@ import com.its.dsrc.entity.TbRseOffrSectTraf;
 import com.its.dsrc.global.AppRepository;
 import com.its.dsrc.process.DbmsData;
 import com.its.dsrc.process.DbmsDataProcess;
+import com.its.dsrc.process.DbmsDataType;
 import com.its.dsrc.vo.NET;
 import com.its.dsrc.vo.voDsrcOffrSectTraf;
 import io.netty.channel.ChannelFuture;
@@ -234,7 +235,7 @@ public class MultiMediaDataService {
         }
         // DSRC 제공구간 제공이력을 이력테이블에 저장한다.
         DbmsDataProcess dbmsDataProcess = (DbmsDataProcess) AppUtils.getBean(DbmsDataProcess.class);
-        dbmsDataProcess.add(new DbmsData(DbmsData.DBMS_DATA_MULTIMEDIA_HS, false, this.offrInfrHsList));
+        dbmsDataProcess.add(new DbmsData(DbmsDataType.DBMS_DATA_MULTIMEDIA_HS, false, this.offrInfrHsList));
     }
 
     public EndApplicationMessage makeEndApplicationMessage(TbRseCtlr obj, MultiMediaDataList multiMediaDataList) {

+ 2 - 1
src/main/java/com/its/dsrc/xnettcp/dsrc/process/service/OBUGatherInfoService.java

@@ -7,6 +7,7 @@ import com.its.dsrc.entity.TbRseObuClct;
 import com.its.dsrc.global.AppRepository;
 import com.its.dsrc.process.DbmsData;
 import com.its.dsrc.process.DbmsDataProcess;
+import com.its.dsrc.process.DbmsDataType;
 import com.its.dsrc.service.RseSectService;
 import com.its.dsrc.vo.voDsrcObuPassInfo;
 import lombok.Getter;
@@ -140,7 +141,7 @@ public class OBUGatherInfoService {
 
         if (obuGatherInfos.size() > 0) {
             // OBU 수집정보를 데이터베이스에 저장
-            this.dbmsDataProcess.add(new DbmsData(DbmsData.DBMS_DATA_OBU_GATHER_LOG, false, (Object)obuGatherInfos));
+            this.dbmsDataProcess.add(new DbmsData(DbmsDataType.DBMS_DATA_OBU_GATHER_LOG, false, (Object)obuGatherInfos));
         }
         return true;
     }

+ 2 - 1
src/main/java/com/its/dsrc/xnetudp/service/CenterCommResponseService.java

@@ -5,6 +5,7 @@ import com.its.dsrc.entity.TbRseCtlr;
 import com.its.dsrc.entity.TbRseCtrlHs;
 import com.its.dsrc.process.DbmsData;
 import com.its.dsrc.process.DbmsDataProcess;
+import com.its.dsrc.process.DbmsDataType;
 import com.its.dsrc.xnetudp.protocol.CENTER_DSRC_RES_CONTROL;
 import com.its.dsrc.xnetudp.thread.CenterCommClientSender;
 import lombok.extern.slf4j.Slf4j;
@@ -20,7 +21,7 @@ public class CenterCommResponseService {
 
         // 제어명령 데이터베이스 저장
         DbmsDataProcess dbmsDataProcess = (DbmsDataProcess) AppUtils.getBean(DbmsDataProcess.class);
-        dbmsDataProcess.add(new DbmsData(DbmsData.DBMS_DATA_CTRL_HS, false, ctlrCntl));
+        dbmsDataProcess.add(new DbmsData(DbmsDataType.DBMS_DATA_CTRL_HS, false, ctlrCntl));
 
         // 제어명령 운영단말 응답
         CENTER_DSRC_RES_CONTROL res = new CENTER_DSRC_RES_CONTROL(ctlrCntl.getReq().getMsgSeq());