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();