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