whyclxw
2025-05-28 e16302f9d475c7cc4dd18c5abf1a23cb5502e362
src/main/java/com/whyc/webSocket/PowerAlarmRealTimeSocket.java
@@ -2,6 +2,7 @@
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;
@@ -27,11 +28,19 @@
    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
@@ -54,8 +63,11 @@
                            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));