| | |
| | | |
| | | private static PwrdevAlarmService service; |
| | | |
| | | private static PwrDevAlarmVerifyService verifyService; |
| | | |
| | | private Session session; |
| | | |
| | | @Autowired |
| | | public void setService(PwrdevAlarmService service){ |
| | | PwrAlarmSocket.service = service; |
| | | } |
| | | @Autowired |
| | | public void setVerifyService(PwrDevAlarmVerifyService verifyService) { |
| | | PwrAlarmSocket.verifyService = verifyService; |
| | | } |
| | | |
| | | @OnOpen |
| | |
| | | if (session.isOpen()) { |
| | | //推送信息 |
| | | synchronized (session) { |
| | | Map<String, Response> res = new HashMap<>(); |
| | | Response powerAlarmRes = service.getAllPage2OfWebSocket(pwrdevAlarm); |
| | | res.put("powerAlarmRes",powerAlarmRes); |
| | | //告警手动确认 |
| | | Response verifyListRes = verifyService.getPageOfWebSocket(pwrdevAlarm); |
| | | res.put("verifyListRes",verifyListRes); |
| | | session.getBasicRemote().sendObject(res); |
| | | //session.getBasicRemote().sendObject(service.getAllPage2OfWebSocket(pwrdevAlarm)); |
| | | //获取告警参数改为一个机房一个 |
| | | session.getBasicRemote().sendObject(service.getAllPage2OfWebSocket_pid(pwrdevAlarm)); |
| | | } |
| | | threadFlagMap.put(thread.getId(),false); |
| | | } |