From 31ef4e5133bca08144d8c8bf1fa17edebfa96bed Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期日, 15 六月 2025 16:37:36 +0800
Subject: [PATCH] syncDutyReportTask
---
ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncDutyReportTask.java | 16 ++++++++++++++--
1 files changed, 14 insertions(+), 2 deletions(-)
diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncDutyReportTask.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncDutyReportTask.java
index 2d7ced6..54555d6 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncDutyReportTask.java
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/SyncDutyReportTask.java
@@ -22,6 +22,10 @@
import java.util.Map;
/**
+ * 同步能源日报
+ * 0 10 0 * * ?
+ *
+ *
* @author PanZhibao
* @Description
* @createTime 2025年06月13日
@@ -57,6 +61,7 @@
logger.info("responseStr is null");
return;
}
+ logger.info("responseStr={}", responseStr);
Map<String, BigDecimal> dataMap1 = new HashMap<>();
Map<String, BigDecimal> dataMap2 = new HashMap<>();
JSONArray jsonArray = JSONArray.parseArray(responseStr);
@@ -71,17 +76,24 @@
logger.info("DutyReportEntity list is empty");
return;
}
+ logger.info("DutyReportEntity list size={}", list.size());
+ logger.info("dataMap1={}", JSONObject.toJSONString(dataMap1));
+ logger.info("dataMap2={}", JSONObject.toJSONString(dataMap2));
for (DutyReportEntity dutyReportEntity : list) {
- if (dataMap1.get(dutyReportEntity.getCdeIndex()) != null) {
+
+ if (dataMap1.get(dutyReportEntity.getCdeIndex()) != null && StringUtils.isNotBlank(dutyReportEntity.getPointNo1())) {
ApiPointValueWriteDTO writeDTO = new ApiPointValueWriteDTO();
writeDTO.setPointNo(dutyReportEntity.getPointNo1());
writeDTO.setValue(dataMap1.get(dutyReportEntity.getCdeIndex()));
+ logger.info("writeDTO={}", JSONObject.toJSONString(writeDTO));
dataPointApi.writePointRealValue(writeDTO);
}
- if (dataMap2.get(dutyReportEntity.getCdeIndex()) != null) {
+
+ if (dataMap2.get(dutyReportEntity.getCdeIndex()) != null && StringUtils.isNotBlank(dutyReportEntity.getPointNo2())) {
ApiPointValueWriteDTO writeDTO = new ApiPointValueWriteDTO();
writeDTO.setPointNo(dutyReportEntity.getPointNo2());
writeDTO.setValue(dataMap2.get(dutyReportEntity.getCdeIndex()));
+ logger.info("writeDTO={}", JSONObject.toJSONString(writeDTO));
dataPointApi.writePointRealValue(writeDTO);
}
}
--
Gitblit v1.9.3