完成代码

integrate-system/src/main/java/com/system/controller/SynchronizationController.java

@@ -7,6 +7,9 @@ import com.system.transfer.configure.InitConnectParamOutVo;
 import com.system.transfer.response.RestResponse;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+
+import java.util.Map;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
@@ -47,6 +50,12 @@ public class SynchronizationController {
         return synchronizationService.manualSynchronization();
     }
 
+    @ApiOperation("手动同步")
+    @PostMapping("/manual/synchronizationByParam")
+    public Object manualSynchronizationByParam(@RequestBody Map<String, String> docTypeMap) {
+        return synchronizationService.manualSynchronizationByParam(docTypeMap.get("docType"));
+    }
+
     @ApiOperation("查询金蝶参数")
     @GetMapping("/init/connect/param")
     public RestResponse initConnectParam() {

integrate-system/src/main/java/com/system/serivce/ISynchronizationService.java

 package com.system.serivce;
 
+import java.util.Map;
+
 import com.system.quartz.model.QuartzJob;
 import com.system.transfer.configure.InitConnectParamCheckInVo;
 import com.system.transfer.configure.InitConnectParamCreateInVo;
@@ -38,6 +40,12 @@ public interface ISynchronizationService {
      * @return 结果
      */
     Object manualSynchronization();
+    
+    /**
+     * 手动同步
+     * @return
+     */
+    Object manualSynchronizationByParam(String docType);
 
     /**
      * 查询金蝶配置

integrate-system/src/main/java/com/system/serivce/impl/SynchronizationServiceImpl.java

@@ -21,6 +21,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
+import java.util.HashMap;
 import java.util.Map;
 
 /**
@@ -153,5 +154,18 @@ public class SynchronizationServiceImpl implements ISynchronizationService {
         }
     }
 
+	@Override
+	public Object manualSynchronizationByParam(String docType) {
+		// TODO Auto-generated method stub
+        try {
+        	Map<String, String> docParam = new HashMap<String, String>();
+        	docParam.put("docType", docType);
+            String result = HttpUtil.httpPost("http://kingdee-adapter:12001/kingdee/api/kingdee/manual/synchronizationByParam",  JsonUtil.toString(docParam)).getBody();
+            return JsonUtil.toMap(result, String.class, Object.class);
+        } catch (Exception e) {
+            return RestResponse.fail("操作失败，手动执行失败");
+        }
+	}
+
 
 }