[add] 添加广场外围入口数据波动异常指标

src/main/java/vion/event/mqtt/MqttClientMessageListener.java

@@ -78,6 +78,9 @@ public class MqttClientMessageListener {
                 case MALL_DATA_UNDULATE:
                 case MALL_DATA_UNDULATE:
                     handleMallDataUndulate(jsonObj.toString());
                     handleMallDataUndulate(jsonObj.toString());
                     break;
                     break;
+                case MALL_GATE_DATA_UNDULATE:
+                    handleMallGateDataUndulate(jsonObj.toString());
+                    break;
                 // endregion
                 // endregion
                 default:
                 default:
                     log.info("未定义的消息类型:{}, payload:{}", type, jsonObj);
                     log.info("未定义的消息类型:{}, payload:{}", type, jsonObj);
@@ -144,6 +147,7 @@ public class MqttClientMessageListener {
     }
     }
 
 
     // region store 事件
     // region store 事件
+
     /**
     /**
      * 门店人数波动异常
      * 门店人数波动异常
      *
      *
@@ -187,6 +191,7 @@ public class MqttClientMessageListener {
     // endregion
     // endregion
 
 
     // region mall 事件
     // region mall 事件
+
     /**
     /**
      * 广场进出客流差异异常
      * 广场进出客流差异异常
      *
      *
@@ -216,6 +221,16 @@ public class MqttClientMessageListener {
         EventRecord eventRecord = JsonUtil.parseObject(payloadStr, EventRecord.class);
         EventRecord eventRecord = JsonUtil.parseObject(payloadStr, EventRecord.class);
         recordService.save(eventRecord);
         recordService.save(eventRecord);
     }
     }
+
+    /**
+     * 广场外围入口数据波动异常
+     *
+     * @param payloadStr 事件记录
+     */
+    private void handleMallGateDataUndulate(String payloadStr) {
+        EventRecord eventRecord = JsonUtil.parseObject(payloadStr, EventRecord.class);
+        recordService.save(eventRecord);
+    }
     // endregion
     // endregion
 }
 }