优化 采购信息的异步线程池

pmapi/src/main/java/com/ningdatech/pmapi/gov/manage/GovProjectCollectionManage.java

@@ -534,26 +534,26 @@ public class GovProjectCollectionManage {
 
             String finalBaseProjId = baseProjId;
             UserInfoDetails finalUser = user;
-            threadPoolTaskScheduler.execute(() -> {
-                Integer index = 1;
-                for(GovBizProjectProcureDTO procure : procures){
-                    procure.setBaseProjId(finalBaseProjId);
-                    procure.setBaseProjName(baseProjName);
-                    procure.setBaseBidCode(finalBaseProjId + StrPool.DASH + index);
-                    GovBizProjectProcure saveProcure = BeanUtil.copyProperties(procure,GovBizProjectProcure.class);
-                    saveProcure.setBaseProjId(finalBaseProjId);
-                    saveProcure.setId(null);
-                    saveProcure.setAreaCode(RegionConst.RC_LS);
-                    saveProcure.setTongTime(LocalDateTime.now());
-                    saveProcure.setBizTime(LocalDateTime.now());
-                    saveProcure.setUpdateBy(finalUser.getUsername());
-                    saveProcure.setUpdateOn(LocalDateTime.now());
-                    if(procureService.save(saveProcure)){
-                        uploadFileToProvincialOssProcure(procure,null,saveProcure);
-                    }
-                    index++;
+
+            Integer index = 1;
+            for(GovBizProjectProcureDTO procure : procures){
+                procure.setBaseProjId(finalBaseProjId);
+                procure.setBaseProjName(baseProjName);
+                procure.setBaseBidCode(finalBaseProjId + StrPool.DASH + index);
+                GovBizProjectProcure saveProcure = BeanUtil.copyProperties(procure,GovBizProjectProcure.class);
+                saveProcure.setBaseProjId(finalBaseProjId);
+                saveProcure.setId(null);
+                saveProcure.setAreaCode(RegionConst.RC_LS);
+                saveProcure.setTongTime(LocalDateTime.now());
+                saveProcure.setBizTime(LocalDateTime.now());
+                saveProcure.setUpdateBy(finalUser.getUsername());
+                saveProcure.setUpdateOn(LocalDateTime.now());
+                if(procureService.save(saveProcure)){
+                    threadPoolTaskScheduler.execute(() -> uploadFileToProvincialOssProcure(procure,null,saveProcure));
                 }
-            });
+                index++;
+            }
+
         }
 
         //7. 推送数据（改为定时推送了）