From 9a9b747962cc00801d8cce4137d1e123d556a79b Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期六, 02 十一月 2024 16:59:59 +0800
Subject: [PATCH] 修复iotdb大批插入数据问题
---
collect/src/main/java/com/qianwen/mdc/collect/job/DeviceStatusAggregateJob.java | 16 ++++++++++------
1 files changed, 10 insertions(+), 6 deletions(-)
diff --git a/collect/src/main/java/com/qianwen/mdc/collect/job/DeviceStatusAggregateJob.java b/collect/src/main/java/com/qianwen/mdc/collect/job/DeviceStatusAggregateJob.java
index f11cedb..bdb5dd8 100644
--- a/collect/src/main/java/com/qianwen/mdc/collect/job/DeviceStatusAggregateJob.java
+++ b/collect/src/main/java/com/qianwen/mdc/collect/job/DeviceStatusAggregateJob.java
@@ -29,14 +29,18 @@
public ReturnT<String> workStationAggregateJobHandler(String param) throws Exception {
XxlJobLogger.log("XXL-JOB, 瀹氭椂璁＄畻宸ヤ綅鐨勭姸鎬侊紝浜ч噺绛変俊鎭�,寮�濮嬪彂閫�.....", new Object[0]);
- Map<Long, WorkstationDTO> workstations = workstationCache.getWorkstations();
- if (ObjectUtil.isNotEmpty(workstations)) {
+ Map<String, WorkstationDTO> workstationsMap = workstationCache.getWorkstations();
+ if (ObjectUtil.isNotEmpty(workstationsMap)) {
- Set<Long> workStationIds = workstations.keySet();
- log.info("鑱氬悎鐘舵�佸伐浣嶆�绘暟:{}",workStationIds.size());
- for(Long workstationId :workStationIds) {
+ Set<String> workstationIds = workstationsMap.keySet();
+
+ log.info("鑱氬悎鐘舵�佸伐浣嶆�绘暟:{}",workstationsMap.size());
+
+
+ for(String workstationId :workstationIds) {
log.info("寮�濮嬭仛鍚堝伐浣峽}鐨勭姸鎬�",workstationId);
- deviceStateAggregateService.stateAggregate(workstationId);
+ Long wid = Long.parseLong(workstationId);
+ deviceStateAggregateService.stateAggregate(wid);
}
}
log.info("鑱氬悎鐘舵�佹暣浣撶粨鏉�");
--
Gitblit v1.9.3