From 7b8faf097b1037248e5e37edc9acd15ca1267010 Mon Sep 17 00:00:00 2001
From: wangjian <wangjian@163.com>
Date: Sun, 31 Aug 2025 10:41:10 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=90=8C=E6=AD=A5=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E6=97=B6=E7=9A=84=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../example/webapi/controller/OnceWeighingController.java  | 7 ++++---
 .../java/com/example/webapi/service/DataSyncService.java   | 3 +++
 2 files changed, 7 insertions(+), 3 deletions(-)

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<Void> syncData() {
-        dataSyncService.syncOnceIncrementalData();
-        return ResponseEntity.ok().build();
+    public ResponseEntity<Integer> 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<com.example.webapi.entity.OnceWeighing> 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();