[add] 添加广场店铺进出差异异常和数据波动异常指标

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

@@ -72,6 +72,12 @@ public class MqttClientMessageListener {
                 case MALL_INOUT_DIFF:
                 case MALL_INOUT_DIFF:
                     handleMallInoutDiff(jsonObj.toString());
                     handleMallInoutDiff(jsonObj.toString());
                     break;
                     break;
+                case MALL_SHOP_INOUT_DIFF:
+                    handleMallShopInoutDiff(jsonObj.toString());
+                    break;
+                case MALL_DATA_UNDULATE:
+                    handleMallDataUndulate(jsonObj.toString());
+                    break;
                 // endregion
                 // endregion
                 default:
                 default:
                     log.info("未定义的消息类型:{}, payload:{}", type, jsonObj);
                     log.info("未定义的消息类型:{}, payload:{}", type, jsonObj);
@@ -190,6 +196,26 @@ 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 handleMallShopInoutDiff(String payloadStr) {
+        EventRecord eventRecord = JsonUtil.parseObject(payloadStr, EventRecord.class);
+        recordService.save(eventRecord);
+    }
+
+    /**
+     * 广场数据波动异常
+     *
+     * @param payloadStr 事件记录
+     */
+    private void handleMallDataUndulate(String payloadStr) {
+        EventRecord eventRecord = JsonUtil.parseObject(payloadStr, EventRecord.class);
+        recordService.save(eventRecord);
+    }
     // endregion
     // endregion
 }
 }