From fe82f1f9a9be911d1420fe3b018ea85dd5fff1a3 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期四, 21 十一月 2024 21:22:58 +0800
Subject: [PATCH] 代码整理
---
collect/src/main/java/com/qianwen/mdc/collect/job/DeviceStatusAggregateJob.java | 20 +++++++++++++-------
1 files changed, 13 insertions(+), 7 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..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,15 +29,21 @@
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();
- for(Long workstationId :workStationIds) {
- deviceStateAggregateService.stateAggregate(workstationId);
+ Map<String, WorkstationDTO> workstationsMap = workstationCache.getWorkstations();
+ if (ObjectUtil.isNotEmpty(workstationsMap)) {
+
+ Set<String> workstationIds = workstationsMap.keySet();
+
+ log.info("鑱氬悎鐘舵�佸伐浣嶆�绘暟:{}",workstationsMap.size());
+
+
+ for(String workstationId :workstationIds) {
+ log.info("寮�濮嬭仛鍚堝伐浣峽}鐨勭姸鎬�",workstationId);
+ Long wid = Long.parseLong(workstationId);
+ deviceStateAggregateService.stateAggregate(wid);
}
}
-
+ log.info("鑱氬悎鐘舵�佹暣浣撶粨鏉�");
XxlJobLogger.log("XXL-JOB, 瀹氭椂璁＄畻宸ヤ綅鐨勭姸鎬侊紝浜ч噺绛変俊鎭�,鍙戦�佺粨鏉�", new Object[0]);
return ReturnT.SUCCESS;
}
--
Gitblit v1.9.3