Commit d951d839 by HlQ

[add] 添加人数/人次异常指标

1 parent a1f1718d
...@@ -52,6 +52,9 @@ public class MqttClientMessageListener { ...@@ -52,6 +52,9 @@ public class MqttClientMessageListener {
case MqttMessageType.REID_ANALYZE: case MqttMessageType.REID_ANALYZE:
handleReid(jsonObj.toString()); handleReid(jsonObj.toString());
break; break;
case HEADCOUNT_RATIO:
handleHeadcountRatio(jsonObj.toString());
break;
// region store 事件 // region store 事件
case STORE_CUSTOMER_UNDULATE: case STORE_CUSTOMER_UNDULATE:
handleStoreCustomerUndulate(jsonObj.toString()); handleStoreCustomerUndulate(jsonObj.toString());
...@@ -144,6 +147,16 @@ public class MqttClientMessageListener { ...@@ -144,6 +147,16 @@ public class MqttClientMessageListener {
} }
/** /**
* 人数/人次异常
*
* @param payloadStr 事件记录
*/
private void handleHeadcountRatio(String payloadStr) {
EventRecord eventRecord = JsonUtil.parseObject(payloadStr, EventRecord.class);
recordService.save(eventRecord);
}
/**
* 客流数据中断 * 客流数据中断
* *
* @param payloadStr 事件记录 * @param payloadStr 事件记录
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!