增加报警引导成功websocket通知前端标识:70000

‘liusuyi’

2024-03-08 f911f720666f340bcdca69863e42bce5b372cd4c

 ard-work/src/main/java/com/ruoyi/alarm/global/service/impl/QueueHandler.java

@@ -1,5 +1,6 @@
package com.ruoyi.alarm.global.service.impl;

import com.alibaba.fastjson.JSON;
import com.ruoyi.alarm.access.domain.ArdAlarmAccess;
import com.ruoyi.alarm.access.service.IArdAlarmAccessService;
import com.ruoyi.alarm.external.domain.ArdAlarmExternal;
@@ -23,6 +24,7 @@
import com.ruoyi.device.camera.domain.ArdCameras;
import com.ruoyi.device.camera.domain.CameraCmd;
import com.ruoyi.device.camera.service.ICameraSdkService;
import com.ruoyi.utils.websocket.util.WebSocketUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
@@ -33,6 +35,8 @@
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.*;

import static com.ruoyi.utils.websocket.util.WebSocketUtils.ONLINE_USER_SESSIONS;

/**
 * @Description: 队列处理器
@@ -108,6 +112,17 @@
            boolean guideRes = cameraSdkService.guideTargetPosition(cmd);
            if (guideRes) {
                log.debug("引导成功");
                //region 通知前端
                Map<String,Object> message = new HashMap<>();
                Map<String,String> data = new HashMap<>();
                data.put("cameraId",cmd.getCameraId());
                data.put("chanNo",cmd.getChanNo().toString());
                data.put("alarmType",cmd.getOperator());
                data.put("alarmId", guideTask.getAlarmId());
                data.put("wellId",guideTask.getWellId());
                message.put("70000",data);
                WebSocketUtils.sendMessageAll(message);
                //endregion
                cameraSdkService.controlLock(cmd);//上锁
                cameraSdkService.recordStart(cmd);//开始录像
                recordFlag = true;