[update] socketClient优化

signal-utc-service/src/main/java/net/wanji/utc/cache/WebSocketClient.java

@@ -3,6 +3,7 @@ package net.wanji.utc.cache;
 import lombok.extern.slf4j.Slf4j;
 import net.wanji.databus.po.CrossInfoPO;
 import net.wanji.utc.websocket.WebSocketClientHandler;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.core.annotation.Order;
 import org.springframework.stereotype.Component;
@@ -13,6 +14,7 @@ import javax.websocket.Session;
 import javax.websocket.WebSocketContainer;
 import java.net.URI;
 import java.util.List;
+import java.util.Objects;
 
 /**
  * @author duanruiming
@@ -24,6 +26,9 @@ import java.util.List;
 public class WebSocketClient implements CommandLineRunner {
     public static Session session;
 
+    @Value("${server.port}")
+    private int port;
+
     @Override
     public void run(String... args) throws Exception {
         try {
@@ -34,10 +39,12 @@ public class WebSocketClient implements CommandLineRunner {
             List<CrossInfoPO> crossInfoList = CrossInfoCache.crossInfoList;
             if (!CollectionUtils.isEmpty(crossInfoList)) {
                 for (CrossInfoPO crossInfoPO : crossInfoList) {
-                    String crossId = crossInfoPO.getId();
-                    String uri = "ws://localhost:32000/utc/signalStatus/" + crossId + ",preload";
-                    session = container.connectToServer(WebSocketClientHandler.class, URI.create(uri));
-                    log.info("ws客户端建立成功：[{}]", crossId);
+                    if (!Objects.equals(23, crossInfoPO.getManufacturerId())) {
+                        String crossId = crossInfoPO.getId();
+                        String uri = "ws://localhost:" + port + "/utc/signalStatus/" + crossId + ",preload";
+                        session = container.connectToServer(WebSocketClientHandler.class, URI.create(uri));
+                        log.info("ws客户端建立成功：[{}]", crossId);
+                    }
                 }
             }
         } catch (Exception e) {