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;
@@ -53,7 +54,7 @@
                    while (!currentThread().isInterrupted()) {
                        Response groupWithStationAndAlarm = baoJiGroupService.getGroupWithStationAndAlarm(userId);
                        session.getBasicRemote().sendObject(groupWithStationAndAlarm);
                        sleep(4000);
                        sleep(10000);
                    }
                } catch (Exception e) {
                    e.printStackTrace();