From c098f1e3a3e052aa3d65584aae6dc003a70d75ad Mon Sep 17 00:00:00 2001
From: wlzboy <66905212@qq.com>
Date: 星期二, 16 十二月 2025 00:09:14 +0800
Subject: [PATCH] feat: 停止轮询 uncount
---
ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/GpsSyncTask.java | 16 ++++++++++------
1 files changed, 10 insertions(+), 6 deletions(-)
diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/GpsSyncTask.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/GpsSyncTask.java
index 692c14f..5292236 100644
--- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/GpsSyncTask.java
+++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/GpsSyncTask.java
@@ -3,6 +3,7 @@
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
+import java.util.stream.Collectors;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -40,13 +41,16 @@
*/
public void syncGpsData() {
try {
- log.info("寮�濮嬪悓姝PS鏁版嵁...");
+// log.info("寮�濮嬪悓姝PS鏁版嵁...");
// 1. 鑾峰彇鎵�鏈夎溅杈嗕俊鎭�
List<VehicleInfo> vehicleList = vehicleInfoService.selectVehicleInfoList(new VehicleInfo());
+ List<String> deviceIds = vehicleList.stream().map(VehicleInfo::getDeviceId).collect(Collectors.toList());
// 2. 鑾峰彇鎵�鏈夎溅杈嗙殑GPS鏈�鍚庝綅缃�
- GpsLastPositionResponse gpsLastPositionResponse = gpsCollectService.getLastPosition(new GpsLastPositionRequest());
+ GpsLastPositionRequest request = new GpsLastPositionRequest();
+// request.setDeviceids(deviceIds);
+ GpsLastPositionResponse gpsLastPositionResponse = gpsCollectService.getLastPosition(request);
// 3. 閬嶅巻杞﹁締鍒楄〃锛岃幏鍙栨瘡涓溅杈嗙殑GPS浣嶇疆
for (VehicleInfo vehicle : vehicleList) {
@@ -64,7 +68,7 @@
}
}
- log.info("GPS鏁版嵁鍚屾瀹屾垚");
+// log.info("GPS鏁版嵁鍚屾瀹屾垚");
} catch (Exception e) {
log.error("GPS鏁版嵁鍚屾澶辫触: {}", e.getMessage());
}
@@ -114,9 +118,9 @@
// 淇濆瓨GPS浣嶇疆淇℃伅
vehicleGpsService.insertVehicleGps(gps);
- log.info("杞﹁締[{}]GPS浣嶇疆宸叉洿鏂�: 缁忓害={}, 绾害={}, 璁惧鏃堕棿={}, 澶勭悊鏃堕棿={}",
- vehicle.getVehicleNo(), position.getCallon(), position.getCallat(),
- gps.getDeviceReportTime(), gps.getPlatformProcessTime());
+// log.info("杞﹁締[{}]GPS浣嶇疆宸叉洿鏂�: 缁忓害={}, 绾害={}, 璁惧鏃堕棿={}, 澶勭悊鏃堕棿={}",
+// vehicle.getVehicleNo(), position.getCallon(), position.getCallat(),
+// gps.getDeviceReportTime(), gps.getPlatformProcessTime());
} catch (Exception e) {
log.error("鏇存柊杞﹁締[{}]GPS浣嶇疆澶辫触: {}", vehicle.getVehicleNo(), e.getMessage());
}
--
Gitblit v1.9.1