注释掉多区域的结果保存定时器

src/main/java/com/founder/interservice/controller/PushWaDataController.java

@@ -146,25 +146,6 @@ public class PushWaDataController {
         try{
             String result = pushWaDataService.sendTogetherTask(taskCaseId,taskName,username,startTime,endTime,objectType,objectValue);
             saveTogetherTask(result,taskCaseId,taskName,username,startTime,endTime,objectType,objectValue,fsrSfzh);
-            if (!StringUtils.isEmpty(result) && result.contains("{")) {
-                JSONObject resultObject = JSONObject.parseObject(result);
-                if (null != resultObject && resultObject.containsKey("data") && null != resultObject.get("data")) {
-                    Object taskIdObj = resultObject.get("data");
-                    if (null != taskIdObj && "" != taskIdObj) {
-                        String taskId = taskIdObj.toString();
-                        Map header=new HashMap();
-                        header.put("Accept-Encoding","gzip, deflate, br");
-                        header.put("Accept-Language","zh-CN,zh;q=0.9");
-                        header.put("Authorization","Basic YWRtaW46YWRtaW4=");
-                        header.put("Connection","keep-alive");
-                        header.put("Content-Type","application/json");
-                        Map paramMap=new HashMap();
-                        paramMap.put("taskId",taskId);
-                        String url=cqzzPlatformUrl+"/runTogetherThread";
-                        HttpClient.doPost(url,header,paramMap);
-                    }
-                }
-            }
             resultVO = ResultVOUtil.success(JSONObject.parseObject(result));
         }catch (InterServiceException e){
             e.printStackTrace();

src/main/java/com/founder/interservice/protogenesis/controller/ProtoController.java

@@ -288,26 +288,6 @@ public class ProtoController {
             //String result="{ "success":true, "message":null, "data":"774120bff0fea8ba6dfb6c1c6b20ec84-562-A01-xjzd-fangzheng-6-1558439147664", "errCode":null }";
             saveRegionalsTask(param, result);
             resultVO = ResultVOUtil.success(result);
-            if (!StringUtils.isEmpty(result) && result.contains("{")) {
-                JSONObject resultObject = JSONObject.parseObject(result);
-                if (null != resultObject && resultObject.containsKey("data") && null != resultObject.get("data")) {
-                    Object taskIdObj = resultObject.get("data");
-                    if (null != taskIdObj && "" != taskIdObj) {
-                        String taskId = taskIdObj.toString();
-                        Map header=new HashMap();
-                        header.put("Accept-Encoding","gzip, deflate, br");
-                        header.put("Accept-Language","zh-CN,zh;q=0.9");
-                        header.put("Authorization","Basic YWRtaW46YWRtaW4=");
-                        header.put("Connection","keep-alive");
-                        header.put("Content-Type","application/json");
-                        Map paramMap=new HashMap();
-                        paramMap.put("taskId",taskId);
-                        String url=cqzzPlatformUrl+"/runRegionalThread";
-                        HttpClient.doPost(url,header,paramMap);
-                    }
-                }
-            }
-
         } catch (InterServiceException e) {
             resultVO = ResultVOUtil.error(e.getCode(), e.getMessage(), null);
         }

src/main/java/com/founder/interservice/regionalanalysis/service/impl/RegionalScheduledService.java

@@ -49,7 +49,7 @@ public class RegionalScheduledService {
      * @Author: cao peng
      * @date: 2018/8/22 0022-16:35
      */
-    @Scheduled(initialDelay = 60000,fixedDelay = 180000) //项目启动后延迟两分钟执行，每次执行完后两分钟后再次执行
+    //@Scheduled(initialDelay = 60000,fixedDelay = 180000) //项目启动后延迟两分钟执行，每次执行完后两分钟后再次执行
     public void queryTaskResult(){
         System.out.println("=============开始执行定时任务================");
         System.out.println("线程名称========== " + Thread.currentThread().getName());
@@ -125,7 +125,7 @@ public class RegionalScheduledService {
      * 2.开启新线程调取标识号的关联数据
      * 3.调取标识号关联数据完成，然后更新任务
      */
-    @Scheduled(initialDelay = 120000,fixedDelay = 60000) //项目启动后延迟两分钟执行，每次执行完后两分钟后再次执行
+    //@Scheduled(initialDelay = 120000,fixedDelay = 60000) //项目启动后延迟两分钟执行，每次执行完后两分钟后再次执行
     public void queryFinishTaskResult(){
         System.out.println("=============开始执行调取关联数据定时任务================");
         System.out.println("线程名称========== " + Thread.currentThread().getName());

src/main/java/com/founder/interservice/regionalanalysis/service/impl/RegionalsScheduledService.java

@@ -52,7 +52,7 @@ public class RegionalsScheduledService {
      * @Author: cao peng
      * @date: 2018/8/22 0022-16:35
      */
-    @Scheduled(initialDelay = 60000,fixedDelay = 60000) //项目启动后延迟三分钟执行，每次执行完后三分钟后再次执行
+    //@Scheduled(initialDelay = 60000,fixedDelay = 60000) //项目启动后延迟三分钟执行，每次执行完后三分钟后再次执行
     public void queryRegionalsTaskResult(){
         System.out.println("=============RegionalsTask  Start Running================");
         System.out.println("=============RegionalsTask  Start Running================");
@@ -198,7 +198,7 @@ public class RegionalsScheduledService {
      * 2.开启新线程调取标识号的关联数据
      * 3.调取标识号关联数据完成，然后更新任务
      */
-    @Scheduled(initialDelay = 120000,fixedDelay = 60000) //项目启动后延迟两分钟执行，每次执行完后两分钟后再次执行
+    //@Scheduled(initialDelay = 120000,fixedDelay = 60000) //项目启动后延迟两分钟执行，每次执行完后两分钟后再次执行
     public void queryFinishTaskResult(){
         System.out.println("=============开始执行调取关联数据定时任务================");
         System.out.println("线程名称========== " + Thread.currentThread().getName());