四川省网关接口相关5

jiazx0107@163.com

2023-10-25 03e26beab1d9c382b685c26059e6dec274a0d7d4

 src/main/java/com/fzzy/gateway/hx2023/websocket/WebSocketDeviceLed.java

文件名从 src/main/java/com/fzzy/gateway/sc2023/websocket/WebSocketDeviceLed.java 修改
@@ -1,7 +1,8 @@
package com.fzzy.gateway.sc2023.websocket;
package com.fzzy.gateway.hx2023.websocket;

import com.alibaba.fastjson.JSONObject;
import com.fzzy.gateway.sc2023.data.WebSocketPacket;
import com.fzzy.gateway.hx2023.ScConstant;
import com.fzzy.gateway.hx2023.data.WebSocketPacket;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.stereotype.Component;
@@ -17,7 +18,7 @@
 */
@Slf4j
@Component
@ServerEndpoint(value = "/device-message-sender/${productId}/${deviceId}")
@ServerEndpoint(value = "/device-message-sender/{productId}/{deviceId}")
public class WebSocketDeviceLed {

    private static Map<String, Session> sessionPool = new ConcurrentHashMap<>();
@@ -41,6 +42,8 @@
        sessionPool.put(key, session);
        sessionIds.put(session.getId(), key);

        ScConstant.updateOnline(deviceId);

        log.info("new webSocket,clientId={}", key);
    }

@@ -51,6 +54,10 @@

        sessionPool.remove(key);
        sessionIds.remove(session.getId());

        String deviceId = key.substring(0, key.indexOf("-"));

        ScConstant.updateOffOnline(deviceId);

        log.info("WebSocket杩炴帴鍏抽棴={}", key);

@@ -75,6 +82,10 @@

        String key = sessionIds.get(session.getId());

        String deviceId = key.substring(0, key.indexOf("-"));

        ScConstant.updateOffOnline(deviceId);

        sessionPool.remove(key);
        sessionIds.remove(session.getId());
        error.printStackTrace();