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

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

@@ -81,6 +81,9 @@ public class MqttClientMessageListener {
                 case MALL_GATE_DATA_UNDULATE:
                 case MALL_GATE_DATA_UNDULATE:
                     handleMallGateDataUndulate(jsonObj.toString());
                     handleMallGateDataUndulate(jsonObj.toString());
                     break;
                     break;
+                case MALL_SHOP_DATA_UNDULATE:
+                    handleMallShopDataUndulate(jsonObj.toString());
+                    break;
                 // endregion
                 // endregion
                 default:
                 default:
                     log.info("未定义的消息类型:{}, payload:{}", type, jsonObj);
                     log.info("未定义的消息类型:{}, payload:{}", type, jsonObj);
@@ -231,6 +234,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 handleMallShopDataUndulate(String payloadStr) {
+        EventRecord eventRecord = JsonUtil.parseObject(payloadStr, EventRecord.class);
+        recordService.save(eventRecord);
+    }
     // endregion
     // endregion
 }
 }