浏览代码

1.webservice延迟五秒执行

WoNiu 4 年之前
父节点
当前提交
e1f6cd83e9

+ 4 - 1
src/main/java/com/galaxis/manatee/service/ProjectMemberService.java

@@ -17,6 +17,7 @@ import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 
 @Service
 @Slf4j
@@ -63,7 +64,9 @@ public class ProjectMemberService {
     }
 
     @Async
-    public void updateSaleMember(String param){
+    public void updateSaleMember(String param) throws InterruptedException {
+        TimeUnit.SECONDS.sleep(5);
+        log.info("同步销售项目组成员");
         var objectMapper=new ObjectMapper();
         param=param.substring(14,param.length()-2);
         log.info(param);

+ 0 - 2
src/main/java/com/galaxis/manatee/webservice/CountryEndpoint.java

@@ -75,11 +75,9 @@ public class CountryEndpoint {
 		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());