| | |
| | | |
| | | import com.whyc.dto.Response; |
| | | import com.whyc.dto.paramter.DevAlarmPar; |
| | | import com.whyc.pojo.DevAlarmDataVerify; |
| | | import com.whyc.service.DevAlarmDataVerifyService; |
| | | import com.whyc.service.DevalarmDataService; |
| | | import com.whyc.util.ActionUtil; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | private volatile Map<Long,Boolean> threadFlagMap = new HashMap<>(); |
| | | |
| | | private static DevalarmDataService service; |
| | | private static DevAlarmDataVerifyService verifyService; |
| | | |
| | | private Session session; |
| | | |
| | | @Autowired |
| | | public void setService(DevalarmDataService service){ |
| | | DevAlarmDataSocket.service = service; |
| | | } |
| | | |
| | | @Autowired |
| | | public void setVerifyService(DevAlarmDataVerifyService verifyService) { |
| | | DevAlarmDataSocket.verifyService = verifyService; |
| | | } |
| | | |
| | | @OnOpen |
| | |
| | | //查询分级告警的个数 |
| | | Response levelRes = service.serchByLevel(alarmPar.getUId()); |
| | | res.put("levelRes", levelRes); |
| | | //告警手动确认 |
| | | Response verifyListRes = verifyService.getPageOfWebSocket(alarmPar); |
| | | res.put("verifyListRes",verifyListRes); |
| | | if (session.isOpen()) { |
| | | //推送信息 |
| | | synchronized (session) { |