diff --git a/script/src/main/java/com/xiang/xservice/fwd/schedule/PullDataFromFWDJob.java b/script/src/main/java/com/xiang/xservice/fwd/schedule/PullDataFromFWDJob.java
index 220e12f..6ffaa66 100644
--- a/script/src/main/java/com/xiang/xservice/fwd/schedule/PullDataFromFWDJob.java
+++ b/script/src/main/java/com/xiang/xservice/fwd/schedule/PullDataFromFWDJob.java
@@ -66,15 +66,15 @@ public class PullDataFromFWDJob {
 
     private final ExecutorService es =
             new ThreadPoolExecutor(
-                    5,
-                    10,
+                    1,
+                    1,
                     1000,
                     TimeUnit.MILLISECONDS,
                     new LinkedBlockingQueue<>(),
                     new MyThreadFactory("fwd-pull-data-http", Boolean.TRUE),
                     new ThreadPoolExecutor.AbortPolicy());
 
-    private void saveProjectInfo(ProjectList project, ProjectInfoResp projectInfoFromHttp) {
+    private FPerformProjectInfo saveProjectInfo(ProjectList project, ProjectInfoResp projectInfoFromHttp) {
         FPerformProjectInfo fPerformProjectInfo = new FPerformProjectInfo();
         fPerformProjectInfo.setNameDisplay(projectInfoFromHttp.getNameDisplay());
         fPerformProjectInfo.setStatus(projectInfoFromHttp.getStatus());
@@ -103,6 +103,7 @@ public class PullDataFromFWDJob {
             fPerformProjectInfo.setPreSaleTime(DateUtils.getDateTimeFromStr(projectInfoFromHttp.getPreSaleTime(), "yyyy/MM/dd HH:mm:ss"));
         }
         performProjectInfoMapper.insert(fPerformProjectInfo);
+        return fPerformProjectInfo;
     }
 
     /**
@@ -212,7 +213,7 @@ public class PullDataFromFWDJob {
         FPerformProjectInfo projectInfo = performProjectInfoMapper.getProjectByProjectId(performsByProjectIdFromHttp.getProjectId());
         if (Objects.isNull(projectInfo)) {
             // 不存在则新增
-            saveProjectInfo(project, projectInfoFromHttp);
+            projectInfo = saveProjectInfo(project, projectInfoFromHttp);
         } else {
             // 存在则更新
             buildUpdateProjectInfo(project, projectInfo, projectInfoFromHttp);