From ba9557b5edf7f31ab8bce0ae57aaaaefd6459bb4 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期二, 08 十月 2024 14:06:54 +0800
Subject: [PATCH] 处理iot链接超时问题
---
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