From 7ef593e1e3c35aaeecf9318f0b3941230d3ed002 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期三, 09 十月 2024 11:22:54 +0800
Subject: [PATCH] 增加在数据点计算规则后数据点名称加_n的适配
---
collect/src/main/java/com/qianwen/mdc/collect/job/DeviceStatusAggregateJob.java | 6 ++++--
1 files changed, 4 insertions(+), 2 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 99e115c..f11cedb 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,15 +29,17 @@
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)) {
+
Set<Long> workStationIds = workstations.keySet();
+ log.info("鑱氬悎鐘舵�佸伐浣嶆�绘暟:{}",workStationIds.size());
for(Long workstationId :workStationIds) {
+ log.info("寮�濮嬭仛鍚堝伐浣峽}鐨勭姸鎬�",workstationId);
deviceStateAggregateService.stateAggregate(workstationId);
}
}
-
+ log.info("鑱氬悎鐘舵�佹暣浣撶粨鏉�");
XxlJobLogger.log("XXL-JOB, 瀹氭椂璁＄畻宸ヤ綅鐨勭姸鎬侊紝浜ч噺绛変俊鎭�,鍙戦�佺粨鏉�", new Object[0]);
return ReturnT.SUCCESS;
}
--
Gitblit v1.9.3