socket接口更新

whyczh

2022-02-21 adeb04f6f9cacb575e9b41a81aaada5ea2ad1b5e

socket接口更新

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

@@ -13,6 +13,7 @@
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.CopyOnWriteArraySet;

@Component
@ServerEndpoint(value = "/battAlarmData",encoders = WebSocketEncoder.class)
@@ -51,15 +52,15 @@
                exit=false;
                while (!thread.isInterrupted()&&!exit) {
                    try {
                        Map<String, Response> res=new HashMap<>();
                        //查询已确认信息
                        alarmPar.setAlmIsConfirmed(1);
                        Response confirmedAlarms=service.serchByConditionOfWebSocket(alarmPar);
                        res.put("confirmedAlarms",confirmedAlarms);
                        alarmPar.setAlmIsConfirmed(0);
                        Response unconfirmedAlarms=service.serchByConditionOfWebSocket(alarmPar);
                        res.put("unconfirmedAlarms",unconfirmedAlarms);
                        if (session.isOpen()) {
                            Map<String, Response> res=new HashMap<>();
                            //查询已确认信息
                            alarmPar.setAlmIsConfirmed(1);
                            Response confirmedAlarms=service.serchByConditionOfWebSocket(alarmPar);
                            res.put("confirmedAlarms",confirmedAlarms);
                            alarmPar.setAlmIsConfirmed(0);
                            Response unconfirmedAlarms=service.serchByConditionOfWebSocket(alarmPar);
                            res.put("unconfirmedAlarms",unconfirmedAlarms);
                            //推送信息
                            session.getBasicRemote().sendObject(new Response().set(1,res));
                        }