瀏覽代碼

Merge branch 'master' of http://39.108.190.163:3000/zx66/FCS

lyl 6 年之前
父節點
當前提交
34280c8cfa

+ 14 - 2
FCS.Crawler/Content/UpdateService/UpdateJobs/UpdateJob.cs

@@ -3,8 +3,10 @@ using System.Collections.Generic;
 using System.Diagnostics;
 using System.Linq;
 using System.Text;
+using System.Threading;
 using System.Threading.Tasks;
 using FCS.Common;
+using FCS.Crawler.Basketball;
 using FCS.Crawler.ZCLotteryAgainst;
 using FCS.Crawler.ZCLotteryAsianDish;
 using FCS.Crawler.ZCLotteryGames;
@@ -34,10 +36,20 @@ namespace FCS.Crawler
 
         public void Click()
         {
+            ThreadPool.SetMaxThreads(200, 200);
             CommonHelper.LogBD("Update开始", logName);
             new IPJob().GetIP();
-            new FootballMatchJob().GetAll();
-            new GroupingJob().Click();
+            Task.Run(() =>
+            {
+                new FootballMatchJob().GetAll();
+                new GroupingJob().Click();
+            });
+            Task.Run(() =>
+            {
+                new B_GroupingJob().Click();
+                new B_GamesJob().Click();
+                new B_PlayersStatisticsJob().Click();
+            });
             CommonHelper.LogBD("Update结束", logName);
         }
     }

+ 3 - 1
FCS.Crawler/Content/UpdateService/UpdateJobs/Update_RealTimeJob.cs

@@ -41,7 +41,9 @@ namespace FCS.Crawler
             List<F_Games> list = new List<F_Games>();
             new GamesJob().Click(out list);
             Task.Run(() => new GamesDetailsJob().Click());
-            while (CommonHelper.ThreadsFinsh())
+            Task.Run(() => new ScoreJob().Click());
+            Task.Run(() => new AgainstJob().Click());
+            while (!CommonHelper.ThreadsFinsh())
                 continue;
             CommonHelper.LogBD("结束Update_RealTime", logName);
         }