|
@@ -15,6 +15,8 @@ import org.springframework.ws.server.endpoint.annotation.PayloadRoot;
|
|
|
import org.springframework.ws.server.endpoint.annotation.RequestPayload;
|
|
|
import org.springframework.ws.server.endpoint.annotation.ResponsePayload;
|
|
|
|
|
|
+import java.util.concurrent.TimeUnit;
|
|
|
+
|
|
|
/**
|
|
|
* @author kxuan
|
|
|
* @version 1.0
|
|
@@ -68,14 +70,16 @@ public class CountryEndpoint {
|
|
|
*/
|
|
|
@PayloadRoot(namespace = NAMESPACE_URI, localPart = "Invoke")
|
|
|
@ResponsePayload
|
|
|
- public InvokeResponse invoke(@RequestPayload Invoke request) throws JsonProcessingException {
|
|
|
+ public InvokeResponse invoke(@RequestPayload Invoke request) throws JsonProcessingException, InterruptedException {
|
|
|
var objectMapper=new ObjectMapper();
|
|
|
InvokeResponse invokeResponse=new InvokeResponse();
|
|
|
//书写调用第三方接口方法
|
|
|
log.info("开始数据同步");
|
|
|
+ TimeUnit.SECONDS.sleep(5);
|
|
|
if (request.getMethodName().equals("managerProject")){
|
|
|
projectMemberService.updateManagerMember(request.getParam());
|
|
|
}else if (request.getMethodName().equals("saleProject")){
|
|
|
+ log.info("同步销售项目组成员");
|
|
|
projectMemberService.updateSaleMember(request.getParam());
|
|
|
}else if (request.getMethodName().equals("developProject")){
|
|
|
projectMemberService.updateDevelopMember(request.getParam());
|