审批页面修改

lxw

2023-08-15 160e150009b51a39fa95d9462c3798ba28d51a09

 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();