密码验证加-

whyclxw

2025-05-28 e16302f9d475c7cc4dd18c5abf1a23cb5502e362

 src/main/java/com/whyc/webSocket/GroupStationSocket.java

@@ -1,5 +1,6 @@
package com.whyc.webSocket;

import com.whyc.config.WebSocketConfig;
import com.whyc.dto.Response;
import com.whyc.factory.ThreadPoolExecutorFactory;
import com.whyc.pojo.Battinf;
@@ -24,7 +25,7 @@
 * 运维分配-班组管理
 */
@Component
@ServerEndpoint(value = "/groupStation",encoders = WebSocketEncoder.class)
@ServerEndpoint(value = "/groupStation",encoders = WebSocketEncoder.class,configurator = WebSocketConfig.class)
public class GroupStationSocket {
    private volatile Thread thread;

@@ -42,10 +43,10 @@
    @OnOpen
    public void onOpen(Session session, EndpointConfig config){
        this.session = session;
        //HttpSession httpSession = (HttpSession) config.getUserProperties().get("httpSession");
        //UserInf user = (UserInf) httpSession.getAttribute("user");
        //final int userId = user.getUId().intValue();
        final int userId = 1001;
        HttpSession httpSession = (HttpSession) config.getUserProperties().get("httpSession");
        UserInf user = (UserInf) httpSession.getAttribute("user");
        final int userId = user.getUId().intValue();
        //final int userId = 1001;
        Thread thread = new Thread() {
            @Override
            public void run() {