From a84ec20993bc390c82a50a47b9ea0e12f3dbba43 Mon Sep 17 00:00:00 2001
From: xuhy <3313886187@qq.com>
Date: 星期五, 23 八月 2024 17:12:45 +0800
Subject: [PATCH] 消息监听处理
---
ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java | 8 ++++++--
1 files changed, 6 insertions(+), 2 deletions(-)
diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java
index 22bb005..acf6897 100644
--- a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java
+++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/listener/IotMessageListener.java
@@ -24,8 +24,12 @@
* @throws IOException
*/
@PostMapping(value = "/message")
- public AjaxResult<Integer> add(@RequestBody JSONObject jsonObject) throws IOException {
- System.err.println(jsonObject);
+ public AjaxResult<String> message(@RequestBody JSONObject jsonObject) throws IOException {
+ log.info("接收到消息中转：{}",jsonObject);
+ JSONObject content = jsonObject.getJSONObject("content");
+ if (content.getString("name").equals("device_status_change")){
+ //设备状态改变
+ }
return AjaxResult.success();
}
--
Gitblit v1.7.1