diff --git a/src/main/java/com/example/webapi/controller/OnceWeighingController.java b/src/main/java/com/example/webapi/controller/OnceWeighingController.java index 461d4cb..e27f630 100644 --- a/src/main/java/com/example/webapi/controller/OnceWeighingController.java +++ b/src/main/java/com/example/webapi/controller/OnceWeighingController.java @@ -13,8 +13,9 @@ public class OnceWeighingController { this.dataSyncService = dataSyncService; } @PostMapping("/once-weighing/sync") - public ResponseEntity syncData() { - dataSyncService.syncOnceIncrementalData(); - return ResponseEntity.ok().build(); + public ResponseEntity syncData() { + int count = dataSyncService.syncOnceIncrementalData(); + System.out.println("手动同步触发,更新了" + count + "条数据"); + return ResponseEntity.ok(count); } } diff --git a/src/main/java/com/example/webapi/service/DataSyncService.java b/src/main/java/com/example/webapi/service/DataSyncService.java index 0b7b178..4f9cf6d 100644 --- a/src/main/java/com/example/webapi/service/DataSyncService.java +++ b/src/main/java/com/example/webapi/service/DataSyncService.java @@ -430,10 +430,12 @@ public class DataSyncService { // 获取PostgreSQL中最大的node_time(数据库层面) java.util.Date maxNodeTime = onceWeighingPostgreSQLRepository.findMaxNodeTime(); if (maxNodeTime == null) { + System.out.println("现在表里没有数据,将同步全量数据"); return syncOnceAllData(); } // 数据库层面过滤增量数据 List incrementalRecords = onceWeighingRepository.findByNodeTimeAfter(maxNodeTime); + System.out.println("找到需要同步的OnceWeighing数据条数为" + incrementalRecords.size()); int successCount = 0; for (com.example.webapi.entity.OnceWeighing source : incrementalRecords) { try { @@ -451,6 +453,7 @@ public class DataSyncService { System.err.println("同步记录失败,NODEID: " + source.getNodeId() + ", 错误: " + e.getMessage()); } } + System.out.println("成功同步了OnceWeighing数据条数为" + successCount); return successCount; } catch (Exception e) { e.printStackTrace();