优化资产导入自动创建业主账号

Your Name

2023-07-01 da52e842ad2ae4e0c05a419836b95651ed46861d

优化资产导入自动创建业主账号

 service-api/src/main/java/com/java110/api/websocket/MessageWebsocket.java

@@ -155,7 +155,10 @@
     * 实现服务器主动推送
     */
    public void sendMessage(String message) throws IOException {
        this.session.getBasicRemote().sendText(message);
        //this.session.getBasicRemote().sendText(message);
        synchronized (this.session) {
            this.session.getBasicRemote().sendText(message);
        }
    }



 service-api/src/main/java/com/java110/api/websocket/ParkingAreaWebsocket.java

@@ -139,7 +139,10 @@
     * 实现服务器主动推送
     */
    public void sendMessage(String message) throws IOException {
        this.session.getBasicRemote().sendText(message);
       // this.session.getBasicRemote().sendText(message);
        synchronized (this.session) {
            this.session.getBasicRemote().sendText(message);
        }
    }



 service-api/src/main/java/com/java110/api/websocket/ParkingBoxWebsocket.java

@@ -139,7 +139,10 @@
     * 实现服务器主动推送
     */
    public void sendMessage(String message) throws IOException {
        this.session.getBasicRemote().sendText(message);
        //this.session.getBasicRemote().sendText(message);
        synchronized (this.session) {
            this.session.getBasicRemote().sendText(message);
        }
    }



 springboot/src/main/java/com/java110/boot/websocket/MessageWebsocket.java

@@ -155,7 +155,10 @@
     * 实现服务器主动推送
     */
    public void sendMessage(String message) throws IOException {
        this.session.getBasicRemote().sendText(message);
        //this.session.getBasicRemote().sendText(message);
        synchronized (this.session) {
            this.session.getBasicRemote().sendText(message);
        }
    }



 springboot/src/main/java/com/java110/boot/websocket/ParkingAreaWebsocket.java

@@ -139,7 +139,10 @@
     * 实现服务器主动推送
     */
    public void sendMessage(String message) throws IOException {
        this.session.getBasicRemote().sendText(message);
        synchronized (this.session) {
            this.session.getBasicRemote().sendText(message);
        }
        //this.session.getBasicRemote().sendText(message);
    }


@@ -149,9 +152,10 @@
    public static void sendInfo(String message, String paId) throws IOException {
        logger.info("发送消息到:" + paId + "，报文:" + message);
        for (ParkingAreaWebsocket server : webSocketMap.values()) {
            if (paId.equals(server.paId)) {
                webSocketMap.get(server.clientId).sendMessage(message);
            if (!paId.equals(server.paId)) {
                continue;
            }
            webSocketMap.get(server.clientId).sendMessage(message);
        }
    }


 springboot/src/main/java/com/java110/boot/websocket/ParkingBoxWebsocket.java

@@ -139,7 +139,10 @@
     * 实现服务器主动推送
     */
    public void sendMessage(String message) throws IOException {
        this.session.getBasicRemote().sendText(message);
        //this.session.getBasicRemote().sendText(message);
        synchronized (this.session) {
            this.session.getBasicRemote().sendText(message);
        }
    }