增加手动触发同步轨道衡数据的接口

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

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