添加告警消息推送

amos-boot-module/amos-boot-module-api/amos-boot-module-ccs-api/pom.xml

@@ -9,4 +9,21 @@
     </parent>
     <modelVersion>4.0.0</modelVersion>
     <artifactId>amos-boot-module-ccs-api</artifactId>
+    <dependencies>
+    <dependency>
+        <groupId>org.typroject</groupId>
+        <artifactId>tyboot-component-emq</artifactId>
+        <version>1.1.20</version>
+        <exclusions>
+            <exclusion>
+                <groupId>org.typroject</groupId>
+                <artifactId>*</artifactId>
+            </exclusion>
+            <exclusion>
+                <groupId>org.apache.logging.log4j</groupId>
+                <artifactId>log4j-api</artifactId>
+            </exclusion>
+        </exclusions>
+    </dependency>
+    </dependencies>
 </project>
\ No newline at end of file

amos-boot-module/amos-boot-module-biz/amos-boot-module-ccs-biz/src/main/java/com/yeejoin/amos/boot/module/ccs/biz/service/impl/MqttReceiveServiceImpl.java

@@ -5,6 +5,7 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.json.JSONUtil;
+import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.yeejoin.amos.boot.module.ccs.api.dto.FireStationInfoDto;
 import com.yeejoin.amos.boot.module.ccs.api.entity.FireEquipmentSignalLog;
@@ -17,12 +18,15 @@ import com.yeejoin.amos.boot.module.ccs.api.vo.RawDataVO;
 import com.yeejoin.amos.boot.module.ccs.api.vo.ReceiveDataVO;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
+import org.eclipse.paho.client.mqttv3.MqttException;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.typroject.tyboot.component.emq.EmqKeeper;
 import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
 
 import java.util.ArrayList;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
@@ -43,6 +47,10 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
     @Autowired
     private FireEquipmentSignalLogMapper fireEquipmentSignalLogMapper;
 
+    @Autowired
+    protected EmqKeeper emqKeeper;
+
+    public static final String EMERGENCY_ALARM_DATA_REFRESH = "emergency/alarm/data/refresh";
 
     //TODO 逻辑待补充
     @Override
@@ -92,6 +100,15 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
                 fireEquipmentSignalLog.setLng(oneByCode.getLng());
                 fireEquipmentSignalLog.setLat(oneByCode.getLat());
                 fireEquipmentSignalLogMapper.insert(fireEquipmentSignalLog);
+
+                // 发送mqtt消息--刷新应急指挥屏数据
+                HashMap<String, String> refresh = new HashMap<>();
+                refresh.put("uuId", String.valueOf(System.currentTimeMillis()));
+                try {
+                    emqKeeper.getMqttClient().publish(EMERGENCY_ALARM_DATA_REFRESH, JSON.toJSONString(refresh).getBytes(), 0, false);
+                } catch (MqttException e) {
+                    e.printStackTrace();
+                }
             }
         } else if (ObjectUtil.isNotEmpty(receiveData) && StrUtil.isNotEmpty(receiveData.getActive()) &&
                 "update".equals(receiveData.getActive()) && ObjectUtil.isNotEmpty(receiveData.getRawData()) && StrUtil.isNotEmpty(receiveData.getRawData().getEquipmentSpecificCode())) {
@@ -102,6 +119,15 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
             updateWrapper.lambda().eq(FireEquipmentSignalLog::getFireEquipmentMrid, rawData.getEquipmentSpecificCode())
                     .eq(FireEquipmentSignalLog::getFireEquipmentIndexKey, rawData.getEquipmentIndexKey());
             fireEquipmentSignalLogServiceImpl.update(fireEquipmentSignalLog, updateWrapper);
+
+            // 发送mqtt消息--刷新应急指挥屏数据
+            HashMap<String, String> refresh = new HashMap<>();
+            refresh.put("uuId", String.valueOf(System.currentTimeMillis()));
+            try {
+                emqKeeper.getMqttClient().publish(EMERGENCY_ALARM_DATA_REFRESH, JSON.toJSONString(refresh).getBytes(), 0, false);
+            } catch (MqttException e) {
+                e.printStackTrace();
+            }
         }
         log.info(String.format("收到mqtt（警情）消息并处理完成：%s", message));
     }