From e434aa108151ca8c5b5f430be51eefdb6ef7c309 Mon Sep 17 00:00:00 2001
From: bsw215583320 <baoshiwei121@163.com>
Date: 星期一, 25 十一月 2024 21:03:31 +0800
Subject: [PATCH] feat(dry): 添加工单ID查询故障记录功能 - 在 DryOpcDeviceController、OpcController 和 OpcCustomRunner 中添加 ConditionalOnProperty 注解，用于条件性地启用 OPC 相关功能
---
jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/mqtt/MqttSampleCallback.java | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/mqtt/MqttSampleCallback.java b/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/mqtt/MqttSampleCallback.java
index 1efee35..1143056 100644
--- a/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/mqtt/MqttSampleCallback.java
+++ b/jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/mqtt/MqttSampleCallback.java
@@ -216,11 +216,11 @@
case MqttConstant.TENANT_UP_PREFIX_FAULT_DATA:
ThreadUtil.execute(() -> {
try {
-
- JSONObject jsonObject = JSON.parseObject(message);
- List<DryFaultRecord> faultRecords = JSON.parseArray(jsonObject.get("data").toString(), DryFaultRecord.class);
- System.err.println(faultRecords.toString());
- faultRecordService.saveBatch(faultRecords);
+ MqMessage<List<DryFaultRecord>> listMqMessage = JSON.parseObject(message, new TypeReference<MqMessage<List<DryFaultRecord>>>() {
+ });
+ // List<DryFaultRecord> faultRecords = JSON.parseArray(jsonObject.get("data").toString(), DryFaultRecord.class);
+ System.err.println(listMqMessage.toString());
+ faultRecordService.saveBatch(listMqMessage.getData());
} catch (Exception e) {
e.printStackTrace();
--
Gitblit v1.9.3