Browse Source

1.修改webservice

WoNiu 4 years ago
parent
commit
23fd6358af
1 changed files with 14 additions and 4 deletions
  1. 14 4
      src/main/java/com/galaxis/manatee/webservice/CountryEndpoint.java

+ 14 - 4
src/main/java/com/galaxis/manatee/webservice/CountryEndpoint.java

@@ -2,8 +2,10 @@ package com.galaxis.manatee.webservice;
 
 
 import com.galaxis.manatee.chuanyun_web_service.*;
+import com.galaxis.manatee.task.ChuanyunBasicDataScheduledTask;
 import com.galaxis.manatee.task.ChuanyunHumanResourceScheduledTask;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.ws.server.endpoint.annotation.Endpoint;
 import org.springframework.ws.server.endpoint.annotation.PayloadRoot;
 import org.springframework.ws.server.endpoint.annotation.RequestPayload;
@@ -19,9 +21,11 @@ public class CountryEndpoint {
 	private static final String NAMESPACE_URI = "http://galaxis.com/manatee/chuanyun-web-service";
 
 	private final ChuanyunHumanResourceScheduledTask chuanyunHumanResourceScheduledTask;
+	private final ChuanyunBasicDataScheduledTask chuanyunBasicDataScheduledTask;
 
-	public CountryEndpoint(ChuanyunHumanResourceScheduledTask chuanyunHumanResourceScheduledTask) {
+	public CountryEndpoint(ChuanyunHumanResourceScheduledTask chuanyunHumanResourceScheduledTask, ChuanyunBasicDataScheduledTask chuanyunBasicDataScheduledTask) {
 		this.chuanyunHumanResourceScheduledTask = chuanyunHumanResourceScheduledTask;
+		this.chuanyunBasicDataScheduledTask = chuanyunBasicDataScheduledTask;
 	}
 
 
@@ -56,13 +60,19 @@ public class CountryEndpoint {
 	 */
 	@PayloadRoot(namespace = NAMESPACE_URI, localPart = "Invoke")
 	@ResponsePayload
+	@Async
 	public InvokeResponse invoke(@RequestPayload Invoke request) {
         //书写调用第三方接口方法
-		log.info(request.getMethodName()+"----"+request.getParam()+"----"+request.getSchemaCode());
 		InvokeResponse invokeResponse=new InvokeResponse();
 		chuanyunHumanResourceScheduledTask.getPayrollManually();
-		log.info("更新薪酬项成功");
-		invokeResponse.setResponse("{}");
+		chuanyunHumanResourceScheduledTask.getUpdateLog();
+		chuanyunBasicDataScheduledTask.getUserCompanyManually();
+		chuanyunBasicDataScheduledTask.getCompanyManually();
+		chuanyunBasicDataScheduledTask.getGroupProjectManually();
+		chuanyunBasicDataScheduledTask.getCostCollectionManually();
+		chuanyunBasicDataScheduledTask.getReimbursementItemsManually();
+		log.info("数据同步成功");
+		invokeResponse.setResponse("{\"ResultCode\":\"0\",\"ErrorMessage\":\"0\"}");
 		return invokeResponse;
 	}
 }