接收解析告警前端发送的强制引导信息并进行引导

‘liusuyi’

2023-11-02 a845352eacdba8a8d05bb0e693e02c104b5abf98

接收解析告警前端发送的强制引导信息并进行引导

 ard-work/src/main/java/com/ruoyi/alarm/radar/service/ArdRadarService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,5 @@
package com.ruoyi.alarm.radar.service;

public interface ArdRadarService {
    void forceGuide(String msg);
}

 ard-work/src/main/java/com/ruoyi/alarm/radar/service/impl/ArdRadarServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,73 @@
package com.ruoyi.alarm.radar.service.impl;

import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.alarm.radar.service.ArdRadarService;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.device.camera.domain.CameraCmd;
import com.ruoyi.device.camera.service.ICameraSdkService;
import com.ruoyi.device.radar.mapper.ArdEquipRadarMapper;
import com.ruoyi.storage.minio.domain.jsonbean.JsonsRootBean;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.HashMap;
import java.util.Map;

/**
 * @Description: é›·è¾¾ä¸šåŠ¡
 * @ClassName: ArdRadarServiceImpl
 * @Author: åˆ˜è‹ä¹‰
 * @Date: 2023å¹´11月02日9:00:08
 **/
@Slf4j(topic = "guideQueue")
@Service
public class ArdRadarServiceImpl implements ArdRadarService {
    @Resource
    ICameraSdkService iCameraSdkService;
    @Resource
    ArdEquipRadarMapper ardEquipRadarMapper;

    /**
     * å¼‚步执行强制引导
     * åˆ˜è‹ä¹‰
     * 2023/11/2 9:00:55
     */
    @Override
    @Async
    public void forceGuide(String msg) {
        try {
            Map<String, Object> msgMap = JSONObject.parseObject(msg, Map.class);
            if (msgMap != null) {
                Double p = Double.parseDouble(msgMap.get("p").toString());
                Double t = Double.parseDouble(msgMap.get("t").toString());
                Double z = Double.parseDouble(msgMap.get("z").toString());
                String radarId = msgMap.get("radarId").toString();
                //获取雷达所在塔上的大光电
                String cameraIdWithTower = ardEquipRadarMapper.getCameraByRadar(radarId);
                if (StringUtils.isNotNull(cameraIdWithTower) && StringUtils.isNotEmpty(cameraIdWithTower)) {
                    log.debug("获取到雷达塔上的光电:" + cameraIdWithTower);
                    //如果雷达塔上有光电
                    CameraCmd cmd = new CameraCmd(cameraIdWithTower, 1);
                    cmd.setOperator("sys_radar_force");
                    Map<String, Double> ptzMap = new HashMap<>();
                    ptzMap.put("p", p);
                    ptzMap.put("t", t);
                    ptzMap.put("z", z);
                    cmd.setPtzMap(ptzMap);
                    boolean res = iCameraSdkService.setPtz(cmd);
                    if (res) {
                        log.debug("强制引导成功");
                    } else {
                        log.debug("强制引导失败");
                    }
                } else {
                    log.debug("未获取到雷达塔上的光电");
                }
            }
        } catch (Exception ex) {
            log.error("强制引导异常:"+ ex.getMessage());
        }
    }
}

 ard-work/src/main/java/com/ruoyi/utils/mqtt/MqttConsumerCallback.java

@@ -1,6 +1,7 @@
package com.ruoyi.utils.mqtt;

import com.ruoyi.alarm.global.service.impl.GlobalAlarmServiceImpl;
import com.ruoyi.alarm.radar.service.ArdRadarService;
import com.ruoyi.common.utils.spring.SpringUtils;
import com.ruoyi.statistical.service.StatisticalService;
import com.ruoyi.storage.minio.service.IStorageMinioEventService;
@@ -85,6 +86,11 @@
                StatisticalService statisticalService = SpringUtils.getBean(StatisticalService.class);
                statisticalService.data(new String(message.getPayload(), StandardCharsets.UTF_8));
            }
            if (topic.equals("radarForceGuide"))
            {
                ArdRadarService ardRadarService = SpringUtils.getBean(ArdRadarService.class);
                ardRadarService.forceGuide(new String(message.getPayload(), StandardCharsets.UTF_8));
            }
        } catch (Exception e) {
            log.debug("处理mqtt消息异常:" + e);
        }