From 307ac5ff5f5f917f2eec2629449729e577b42dee Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期二, 03 六月 2025 09:29:05 +0800
Subject: [PATCH] 政务云
---
ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/produce/IotMessageProduce.java | 27 +++++++++------------------
1 files changed, 9 insertions(+), 18 deletions(-)
diff --git a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/produce/IotMessageProduce.java b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/produce/IotMessageProduce.java
index 009e8f1..3659dbc 100644
--- a/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/produce/IotMessageProduce.java
+++ b/ruoyi-service/ruoyi-integration/src/main/java/com/ruoyi/integration/iotda/utils/produce/IotMessageProduce.java
@@ -1,5 +1,6 @@
package com.ruoyi.integration.iotda.utils.produce;
+import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.huaweicloud.sdk.core.exception.ConnectionException;
import com.huaweicloud.sdk.core.exception.RequestTimeoutException;
@@ -39,14 +40,9 @@
*/
@PostMapping("/sendMessage")
public String sendMessage(String code, String name, JSONObject message){
+ log.info("消息下发至设备：code={}，name={}，message={}", code, name, message);
CreateMessageRequest request = new CreateMessageRequest();
- System.err.println(code);
- System.err.println(JSONObject.toJSONString(config));
- if(config.getTest() && code.equals(config.getTestDriverCode())){
- request.withDeviceId(config.getTestDeviceId());
- }else{
- request.withDeviceId(config.getDeviceId());
- }
+ request.withDeviceId(code);
DeviceMessageRequest body = new DeviceMessageRequest();
body.withMessageId(UUID.randomUUID().toString());
body.withName(name);
@@ -54,19 +50,14 @@
request.withBody(body);
try {
CreateMessageResponse response = iotBuilder.buildIot().createMessage(request);
- System.out.println(response.toString());
- } catch (ConnectionException e) {
+ log.info("消息下发至设备结果：{}", JSON.toJSONString(response));
+ return JSON.toJSONString(response);
+ } catch (Exception e) {
e.printStackTrace();
- } catch (RequestTimeoutException e) {
- e.printStackTrace();
- } catch (ServiceResponseException e) {
- e.printStackTrace();
- System.out.println(e.getHttpStatusCode());
- System.out.println(e.getRequestId());
- System.out.println(e.getErrorCode());
- System.out.println(e.getErrorMsg());
+ log.info("消息下发至设备异常：code---{}，msg---{}", code, e.getMessage());
+ log.error("消息下发至设备异常：code---{}，msg---{}", code, e.getMessage());
+ return e.getMessage();
}
- return null;
}
}
\ No newline at end of file
--
Gitblit v1.7.1