dev

src/main/java/com/its/vms/api/controller/EsbVmsController.java

@@ -1,6 +1,6 @@
 package com.its.vms.api.controller;
 
-import com.its.vms.dto.TbEsbVmsShortMsgDto;
+import com.its.vms.esb.dto.TbEsbVmsShortMsgDto;
 import com.its.vms.esb.service.EsbVmsTcpService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;

src/main/java/com/its/vms/dao/mapper/EsbVmsMapper.java

@@ -3,6 +3,7 @@ package com.its.vms.dao.mapper;
 import com.its.vms.entity.NewIdSeq;
 import com.its.vms.entity.TbEsbVmsShortMsg;
 import com.its.vms.entity.TbEsbVmsShortMsgResult;
+import com.its.vms.esb.entity.EsbServer;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
@@ -13,6 +14,7 @@ public interface EsbVmsMapper {
 
     NewIdSeq selectNextMsgId();
     List<TbEsbVmsShortMsg> selectVmsShortMsg();
+    List<EsbServer> selectEsbServer();
     int insertVmsShortMsg(@Param("obj") TbEsbVmsShortMsg obj);
     int updateVmsShortMsgResult(@Param("obj") TbEsbVmsShortMsgResult obj);
 

src/main/java/com/its/vms/entity/TbEsbVmsShortMsg.java

@@ -1,6 +1,6 @@
 package com.its.vms.entity;
 
-import com.its.vms.dto.TbEsbVmsShortMsgDto;
+import com.its.vms.esb.dto.TbEsbVmsShortMsgDto;
 import io.swagger.annotations.ApiModel;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
@@ -62,5 +62,4 @@ public class TbEsbVmsShortMsg implements Serializable {
                 .build();
     }
 
-
 }

src/main/java/com/its/vms/dto/TbEsbVmsShortMsgDto.java → src/main/java/com/its/vms/esb/dto/TbEsbVmsShortMsgDto.java

@@ -1,4 +1,4 @@
-package com.its.vms.dto;
+package com.its.vms.esb.dto;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.its.vms.entity.TbEsbVmsShortMsg;

src/main/java/com/its/vms/esb/entity/EsbServer.java

@@ -0,0 +1,19 @@
+package com.its.vms.esb.entity;
+
+import lombok.Builder;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * Long New ID DTO Class
+ */
+@Data
+@Builder
+public class EsbServer implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+    private String systIp;
+    private Integer port;
+
+}

src/main/java/com/its/vms/esb/service/EsbVmsTcpService.java

@@ -4,7 +4,7 @@ import com.its.app.utils.Elapsed;
 import com.its.app.utils.SysUtils;
 import com.its.vms.config.CommunicationConfig;
 import com.its.vms.dao.mapper.EsbVmsMapper;
-import com.its.vms.dto.TbEsbVmsShortMsgDto;
+import com.its.vms.esb.dto.TbEsbVmsShortMsgDto;
 import com.its.vms.entity.NewIdSeq;
 import com.its.vms.entity.TbEsbVmsShortMsg;
 import com.its.vms.entity.TbEsbVmsShortMsgResult;

src/main/resources/mybatis/mapper/EsbVmsMapper.xml

@@ -3,6 +3,17 @@
 
 <mapper namespace="com.its.vms.dao.mapper.EsbVmsMapper">
 
+    <select id="selectEsbServer" resultType="com.its.vms.esb.entity.EsbServer" fetchSize="5">
+    <![CDATA[
+        select t1.syst_ip_1  AS systIp,
+               t1.prgm_port  AS port
+        from tb_unit_syst t1
+        where t1.del_yn = 'N'
+          and t1.syst_id = 'ESB01'
+          and rownum = 1
+        ]]>
+    </select>
+
     <select id="selectVmsShortMsg" resultType="com.its.vms.entity.TbEsbVmsShortMsg" fetchSize="20">
     <![CDATA[
         select t1.msg_id       AS msgId,