手动同步提交

siwei-modules/siwei-apply/src/main/java/com/siwei/apply/controller/zrzysite/ZrzysiteConstructController.java

@@ -2,10 +2,12 @@ package com.siwei.apply.controller.zrzysite;
 
 import com.siwei.apply.domain.zrzysite.ZrzysiteConstruct;
 import com.siwei.apply.domain.vo.zrzysite.ZrzysiteConstructFilterVo;
+import com.siwei.apply.enums.AloneWorkFlowEnum;
 import com.siwei.apply.service.zrzysite.IZrzysiteCommonService;
 import com.siwei.apply.service.zrzysite.IZrzysiteGhhsService;
 import com.siwei.apply.service.zrzysite.IZrzysiteLandService;
 import com.siwei.common.core.domain.R;
+import com.siwei.common.core.utils.StringUtils;
 import com.siwei.common.core.web.controller.BaseController;
 import com.siwei.common.core.web.page.TableDataInfo;
 import com.siwei.common.security.annotation.InnerAuth;
@@ -13,6 +15,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
 import java.util.List;
+import java.util.Map;
 
 @RestController
 @RequestMapping("/zrzysite")
@@ -52,6 +55,25 @@ public class ZrzysiteConstructController extends BaseController {
     }
 
 
+    @PostMapping("/common/syncOneNode")
+    //@InnerAuth
+    public R<String> runSyncOneNode(@RequestBody Map<String,String> paramMap) {
+        String projectId = paramMap.get("projectId");
+        String nodeTableName = paramMap.get("nodeTableName");
+        if(StringUtils.isNotBlank(projectId) && StringUtils.isNotBlank(nodeTableName)){
+            if(AloneWorkFlowEnum.NODE_4.getName().equalsIgnoreCase(nodeTableName)){
+                zrzysiteGhhsService.syncCurrentNodeInfo(projectId,nodeTableName);
+            }else if(AloneWorkFlowEnum.NODE_5.getName().equalsIgnoreCase(nodeTableName)){
+                zrzysiteConstructService.syncCurrentNodeInfo(projectId,nodeTableName);
+            } else if(AloneWorkFlowEnum.NODE_6.getName().equalsIgnoreCase(nodeTableName)){
+                zrzysiteGhhsService.syncCurrentNodeInfo(projectId,nodeTableName);
+            }
+        }
+        return R.ok("syncOneNode success");
+    }
+
+
+    // ----手动同步接口实现----------------
     @GetMapping("/construct/{param}")
     //@InnerAuth
     public R<String> runConstructScheduled( @PathVariable("param") String param ) {