| | |
| | | |
| | | import com.whyc.dto.Response; |
| | | import com.whyc.pojo.PwrdevAlarm; |
| | | import com.whyc.service.PwrDevAlarmVerifyService; |
| | | import com.whyc.service.PwrdevAlarmService; |
| | | import com.whyc.util.ActionUtil; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | |
| | | private static PwrdevAlarmService service; |
| | | |
| | | private static PwrDevAlarmVerifyService verifyService; |
| | | |
| | | |
| | | private Session session; |
| | | |
| | | @Autowired |
| | | public void setService(PwrdevAlarmService service){ |
| | | PowerAlarmRealTimeSocket.service = service; |
| | | } |
| | | |
| | | @Autowired |
| | | public void setVerifyService(PwrDevAlarmVerifyService verifyService) { |
| | | PowerAlarmRealTimeSocket.verifyService = verifyService; |
| | | } |
| | | |
| | | @OnOpen |
| | |
| | | Response alarmRes = service.getAllPageOfWebSocket(pwrdevAlarm); |
| | | res.put("alarmRes", alarmRes); |
| | | //查询分级告警的个数 |
| | | Response levelRes = service.serchByLevel(pwrdevAlarm.getUsrId()); |
| | | Response levelRes = service.serchByLevel(pwrdevAlarm.getUsrId(), pwrdevAlarm.getAlmTypes()); |
| | | res.put("levelRes", levelRes); |
| | | //告警手动确认 |
| | | Response verifyListRes = verifyService.getPageOfWebSocket(pwrdevAlarm); |
| | | res.put("verifyListRes",verifyListRes); |
| | | //推送信息 |
| | | synchronized (session) { |
| | | session.getBasicRemote().sendObject(new Response().set(1, res)); |