Skip to content

李苗 / Vion-DevOps

Go to a project
Commit cb11ee1c by HlQ
Options

[feat] 添加设备特征异常和视频场景异常处理

1 parent 06d04f0a
Inline Side-by-side
Showing 2 changed files with 26 additions and 0 deletions
src/main/java/vion/constant/MqttMessageType.java
...@@ -55,6 +55,10 @@ public enum MqttMessageType { ...@@ -55,6 +55,10 @@ public enum MqttMessageType {
* 店员识别异常 * 店员识别异常
*/ */
STAFF_RECOGNIZE("STAFF_RECOGNIZE"), STAFF_RECOGNIZE("STAFF_RECOGNIZE"),
/**
* 视频场景异常
*/
DEVICE_SCENE_EXCEPTION("DEVICE_SCENE_EXCEPTION"),
// endregion // endregion
// region store // region store
......
src/main/java/vion/event/mqtt/MqttClientMessageListener.java
...@@ -59,8 +59,10 @@ public class MqttClientMessageListener { ...@@ -59,8 +59,10 @@ public class MqttClientMessageListener {
case DEVICE_OFFLINE -> handleDeviceOffline(sendData); case DEVICE_OFFLINE -> handleDeviceOffline(sendData);
case REID_ANALYZE -> handleReid(sendData); case REID_ANALYZE -> handleReid(sendData);
case DEVICE_REGISTRATION -> handleDeviceRegistration(sendData); case DEVICE_REGISTRATION -> handleDeviceRegistration(sendData);
case DEVICE_FEATURE -> handleDeviceFeature(sendData);
case HEADCOUNT_RATIO -> handleHeadcountRatio(sendData); case HEADCOUNT_RATIO -> handleHeadcountRatio(sendData);
case STAFF_RECOGNIZE -> handleStaffRecognize(sendData); case STAFF_RECOGNIZE -> handleStaffRecognize(sendData);
case DEVICE_SCENE_EXCEPTION -> handleSceneException(sendData);
// endregion // endregion
// region store 指标 // region store 指标
...@@ -147,6 +149,16 @@ public class MqttClientMessageListener { ...@@ -147,6 +149,16 @@ public class MqttClientMessageListener {
} }
/** /**
* 设备特征异常
*
* @param sendData 事件记录
*/
private void handleDeviceFeature(SendData sendData) {
var recordList = silent(sendData);
saveRecInDB(recordList);
}
/**
* 人数/人次异常 * 人数/人次异常
* *
* @param sendData 事件记录 * @param sendData 事件记录
...@@ -167,6 +179,16 @@ public class MqttClientMessageListener { ...@@ -167,6 +179,16 @@ public class MqttClientMessageListener {
} }
/** /**
* 视频场景异常
*
* @param sendData 事件记录
*/
private void handleSceneException(SendData sendData) {
var recordList = silent(sendData);
saveRecInDB(recordList);
}
/**
* 客流数据中断 * 客流数据中断
* *
* @param sendData 事件记录 * @param sendData 事件记录
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!