lxw
2022-12-23 4c4a0f472ff695fcf0e7133baf88e44944eafd19
src/main/java/com/whyc/webSocket/BattAlarmDataSocket.java
@@ -41,6 +41,7 @@
    public synchronized void onMessage(Session session, String message){
        AlarmPar alarmPar = ActionUtil.getGson().fromJson(message, AlarmPar.class);
        thread = new Thread("Thread_battAlarmData") {
            @Override
            public void run() {
                while (runFlag&&!isInterrupted()) {
                    Thread thread = currentThread();
@@ -54,6 +55,9 @@
                        alarmPar.setAlmIsConfirmed(0);
                        Response unconfirmedAlarms=service.serchByConditionOfWebSocket(alarmPar);
                        res.put("unconfirmedAlarms",unconfirmedAlarms);
                        //查询分级告警的个数
                        Response levelRes = service.serchByLevel();
                        res.put("levelRes", levelRes);
                        if (session.isOpen()) {
                            //推送信息
                            synchronized (session) {