whyclxw
2025-05-28 e16302f9d475c7cc4dd18c5abf1a23cb5502e362
src/main/java/com/whyc/webSocket/PwrAlarmSocket.java
@@ -29,17 +29,11 @@
    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
@@ -59,13 +53,9 @@
                        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);
                        }