whyclxw
2025-05-28 e16302f9d475c7cc4dd18c5abf1a23cb5502e362
src/main/java/com/whyc/webSocket/InterfacePwrAlarmSocket.java
@@ -1,6 +1,6 @@
package com.whyc.webSocket;
import com.whyc.dto.InterfacePageParam;
import com.whyc.dto.InterfaceParam;
import com.whyc.service.InterfaceService;
import com.whyc.util.ActionUtil;
import org.springframework.beans.factory.annotation.Autowired;
@@ -40,8 +40,9 @@
    @OnMessage
    public void onMessage(Session session, String message){
        InterfacePageParam param = ActionUtil.getGson().fromJson(message, InterfacePageParam.class);
        InterfaceParam param = ActionUtil.getGson().fromJson(message, InterfaceParam.class);
        thread = new Thread("Thread_interfacePowerAlarm") {
            @Override
            public void run() {
                while (runFlag && !isInterrupted()) {
                    Thread thread = currentThread();
@@ -50,7 +51,7 @@
                        if (session.isOpen()) {
                            //推送信息
                            synchronized (session) {
                                session.getBasicRemote().sendObject(service.getPwrdevAlarm(param.getPageNum(),param.getPageSize()));
                                session.getBasicRemote().sendObject(service.getPwrdevAlarm(param.getPowerDeviceIds(), param.getInterfaceNumber()));
                            }
                            threadFlagMap.put(thread.getId(),false);
                        }