From dc7300e21fe53f74e08eb2fa494a83430e2e54ca Mon Sep 17 00:00:00 2001
From: zouyu <2723363702@qq.com>
Date: 星期四, 26 三月 2026 11:25:58 +0800
Subject: [PATCH] 绩效管理：人员考勤功能模块
---
cnas-device/src/main/java/com/ruoyi/device/mqtt/MQCallback.java | 20 ++++++++++----------
1 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/cnas-device/src/main/java/com/ruoyi/device/mqtt/MQCallback.java b/cnas-device/src/main/java/com/ruoyi/device/mqtt/MQCallback.java
index f85eab0..8d4d37b 100644
--- a/cnas-device/src/main/java/com/ruoyi/device/mqtt/MQCallback.java
+++ b/cnas-device/src/main/java/com/ruoyi/device/mqtt/MQCallback.java
@@ -70,19 +70,19 @@
try {
String parse = new String(message.getPayload());
switch (topic){
- case "/ztt/v3/2455220/publish":
- //鑰愪笣锛氱洿娴佺數闃绘暟鎹В鏋�
- mqCallback.collectBridgeService.addBridgeValueByNS(parse);
+ case "/aiot/a4b27900-c6b7-11f0-8b13-c14e8310d70b"://鎴愬搧璇曢獙瀹�-浼搁暱鐜�
+ mqCallback.collectBridgeService.elongationDataAnalysis(parse);
break;
- case "/ztt/v3/2455221/publish":
- //鑰愪笣锛氫几闀跨巼鏁版嵁瑙ｆ瀽
- log.info("浼搁暱鐜囨秷鎭綋锛歿}",parse);
+ case "/aiot/4e40cdb0-c6b7-11f0-8b13-c14e8310d70b"://鎴愬搧璇曢獙瀹�-鐢甸樆
+ mqCallback.collectBridgeService.dcResistanceDataAnalysis(parse);
+ break;
+ case "/aiot/5447dad0-c6b9-11f0-8b13-c14e8310d70b"://杩囩▼璇曢獙瀹�-浼搁暱鐜�
+ mqCallback.collectBridgeService.elongationDataAnalysis(parse);
+ break;
+ case "/aiot/51eaff10-c6b9-11f0-8b13-c14e8310d70b"://杩囩▼璇曢獙瀹�-鐢甸樆
+ mqCallback.collectBridgeService.dcResistanceDataAnalysis(parse);
break;
}
- // 濉厖閲囬泦鏁版嵁
-// JSONObject jsonObject = JSONObject.parseObject(parse);
-// mqCallback.collectBridgeService.addBridgeValue(jsonObject);
-
} catch (Exception e) {
e.printStackTrace();
log.info("============銆嬨�嬫帴鏀舵秷鎭富棰樺紓甯� : " + e.getMessage());
--
Gitblit v1.9.3