whyclxw
2025-05-28 e16302f9d475c7cc4dd18c5abf1a23cb5502e362
src/main/java/com/whyc/webSocket/DevAlarmDataSocket.java
@@ -2,6 +2,8 @@
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;
@@ -26,12 +28,18 @@
    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
@@ -60,6 +68,9 @@
                        //查询分级告警的个数
                        Response levelRes = service.serchByLevel(alarmPar.getUId());
                        res.put("levelRes", levelRes);
                        //告警手动确认
                        Response verifyListRes = verifyService.getPageOfWebSocket(alarmPar);
                        res.put("verifyListRes",verifyListRes);
                        if (session.isOpen()) {
                            //推送信息
                            synchronized (session) {