[add] 添加门店监控点数据波动异常指标

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

@@ -20,9 +20,8 @@ import vion.utils.TopicUtil;
 import java.util.List;
 
 /**
- * 客户端消息监听的另一种方式
+ * <b>/MS/receive</b> topic 监听事件处理
  *
- * @author L.cm
  */
 @Service
 @RequiredArgsConstructor
@@ -58,6 +57,9 @@ public class MqttClientMessageListener {
                 case STORE_CUSTOMER_UNDULATE:
                     handleStoreCustomerUndulate(jsonObj.toString());
                     break;
+                case STORE_GATE_DATA_UNDULATE:
+                    handleStoreGateDateUndulate(jsonObj.toString());
+                    break;
                 case STORE_INOUT_MATCH_RATIO:
                     handleStoreInoutMatchRatio(jsonObj.toString());
                     break;
@@ -162,6 +164,16 @@ public class MqttClientMessageListener {
     }
 
     /**
+     * 门店监控点数据波动异常
+     *
+     * @param payloadStr 事件记录
+     */
+    private void handleStoreGateDateUndulate(String payloadStr) {
+        EventRecord eventRecord = JsonUtil.parseObject(payloadStr, EventRecord.class);
+        recordService.save(eventRecord);
+    }
+
+    /**
      * 门店进出匹配率异常
      *
      * @param payloadStr 事件记录