[add] 添加广场膨胀系数异常指标

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

@@ -21,7 +21,6 @@ import java.util.List;
 
 
 /**
 /**
  * <b>/MS/receive</b> topic 监听事件处理
  * <b>/MS/receive</b> topic 监听事件处理
- *
  */
  */
 @Service
 @Service
 @RequiredArgsConstructor
 @RequiredArgsConstructor
@@ -86,6 +85,9 @@ public class MqttClientMessageListener {
                 case MALL_SHOP_DATA_UNDULATE:
                 case MALL_SHOP_DATA_UNDULATE:
                     handleMallShopDataUndulate(jsonObj.toString());
                     handleMallShopDataUndulate(jsonObj.toString());
                     break;
                     break;
+                case MALL_DILATATION_UNDULATE:
+                    handleMallDilatationUndulate(jsonObj.toString());
+                    break;
                 // endregion
                 // endregion
                 default:
                 default:
                     log.info("未定义的消息类型:{}, payload:{}", type, jsonObj);
                     log.info("未定义的消息类型:{}, payload:{}", type, jsonObj);
@@ -256,6 +258,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 handleMallDilatationUndulate(String payloadStr) {
+        EventRecord eventRecord = JsonUtil.parseObject(payloadStr, EventRecord.class);
+        recordService.save(eventRecord);
+    }
     // endregion
     // endregion
 }
 }