mqtt告警

ruoyi-common/src/main/java/com/ruoyi/common/constant/Constants.java

@@ -194,6 +194,8 @@ public class Constants {
     public static final String TO_SERVER_LEAVE_STAT = "toServer_leaveStat";
     //玩手机告警接收
     public static final String TO_SERVER_PLAY_STAT = "toServer_playStat";
+    //人员聚集
+    public static final String TO_SERVER_PEO_GATHER = "toServer_peoGather";
     //获取通道画框图片
     public static final String TO_SERVER_PIC_POS= "toServer_picPos";
     //首页统计折线图往期年份数据

ruoyi-system/src/main/java/com/ruoyi/mqtt/service/MqttMessageListener.java

@@ -61,7 +61,11 @@ public class MqttMessageListener {
         else if(message.getTopic().equals(TO_SERVER_PLAY_STAT)){
             //插入告警信息
             warnManageService.addWarnManage(message,ONE);
-        }else if(message.getTopic().equals(TO_SERVER_PIC_POS)){
+        }else if(message.getTopic().equals(TO_SERVER_PEO_GATHER)){
+            //插入告警信息
+            warnManageService.addWarnManage(message,TWO);
+        }
+        else if(message.getTopic().equals(TO_SERVER_PIC_POS)){
             try {
                 //返回值为photoAddress_channelId
                 String payload = message.getPayload();