From 3fca58a8cfdb4d8196c36b027b019409ec8d1df2 Mon Sep 17 00:00:00 2001
From: wangjian <wangjian@163.com>
Date: Wed, 27 Aug 2025 09:32:28 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=89=8B=E5=8A=A8=E8=A7=A6?=
 =?UTF-8?q?=E5=8F=91=E5=90=8C=E6=AD=A5=E8=BD=A8=E9=81=93=E8=A1=A1=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E7=9A=84=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/OnceWeighingController.java    | 20 +++++++++++++++++++
 .../webapi/service/DataSyncService.java       |  2 +-
 2 files changed, 21 insertions(+), 1 deletion(-)
 create mode 100644 src/main/java/com/example/webapi/controller/OnceWeighingController.java

diff --git a/src/main/java/com/example/webapi/controller/OnceWeighingController.java b/src/main/java/com/example/webapi/controller/OnceWeighingController.java
new file mode 100644
index 0000000..461d4cb
--- /dev/null
+++ b/src/main/java/com/example/webapi/controller/OnceWeighingController.java
@@ -0,0 +1,20 @@
+package com.example.webapi.controller;
+
+import com.example.webapi.service.DataSyncService;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+public class OnceWeighingController {
+    private final DataSyncService dataSyncService;
+
+    public OnceWeighingController(DataSyncService dataSyncService) {
+        this.dataSyncService = dataSyncService;
+    }
+    @PostMapping("/once-weighing/sync")
+    public ResponseEntity<Void> syncData() {
+        dataSyncService.syncOnceIncrementalData();
+        return ResponseEntity.ok().build();
+    }
+}
diff --git a/src/main/java/com/example/webapi/service/DataSyncService.java b/src/main/java/com/example/webapi/service/DataSyncService.java
index 924439f..0b7b178 100644
--- a/src/main/java/com/example/webapi/service/DataSyncService.java
+++ b/src/main/java/com/example/webapi/service/DataSyncService.java
@@ -425,7 +425,7 @@ public class DataSyncService {
      * 一次过磅-增量同步（基于node_time，数据库层面过滤）
      */
     @Transactional(transactionManager = "postgresqlTransactionManager")
-    public int syncOnceIncrementalData() {
+    public synchronized int syncOnceIncrementalData() {
         try {
             // 获取PostgreSQL中最大的node_time（数据库层面）
             java.util.Date maxNodeTime = onceWeighingPostgreSQLRepository.findMaxNodeTime();