第三方接口告警调整

whyczh

2022-07-04 ca65e20fb13a78913391be1a46630d9ea45b611e

第三方接口告警调整

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

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

import com.whyc.dto.InterfaceParam;
import com.whyc.service.InterfaceService;
import com.whyc.util.ActionUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@@ -38,7 +40,7 @@

    @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") {
            public void run() {
                while (runFlag && !isInterrupted()) {
@@ -48,7 +50,7 @@
                        if (session.isOpen()) {
                            //推送信息
                            synchronized (session) {
                                session.getBasicRemote().sendObject(service.getPwrdevAlarm());
                                session.getBasicRemote().sendObject(service.getPwrdevAlarm(param.getPowerDeviceIds()));
                            }
                            threadFlagMap.put(thread.getId(),false);
                        }