FCS/FCS.Crawler/Content/UpdateService/UpdateJobs/Update_RealTimeJob.cs

using System;
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.ZCLotteryAgainst;
using FCS.Crawler.ZCLotteryAsianDish;
using FCS.Crawler.ZCLotteryGames;
using FCS.Crawler.ZCLotteryGrouping;
using FCS.Crawler.ZCLotteryIP;
using FCS.Crawler.ZCLotteryMatchs;
using FCS.Crawler.ZCLotteryScore;
using FCS.Crawler.ZCLotterySizeIndex;
using FCS.Crawler.ZCLotteryTeam;
using FCS.Interface;
using FCS.Models;
using Quartz;

namespace FCS.Crawler
{
    public class Update_RealTimeJob : CommonJob, IJob
    {
        public Update_RealTimeJob()
        {
            logName = "Update_RealTimeJob";
        }

        public void Execute(IJobExecutionContext context)
        {
            Config = CommonHelper.GetConfigFromDataMap(context.JobDetail.JobDataMap);
            Click();
        }

        public void Click()
        {

            ThreadPool.SetMaxThreads(200, 200);
            CommonHelper.LogBD("开始Update_RealTime", logName);
            new GamesJob().Click();
            CommonHelper.LogBD("比赛完成", logName);
            taskList.Add(Task.Run(() =>
            {
                new GamesDetailsJob().Click();
                CommonHelper.LogBD("GamesDetailsJob完成", logName);
            }));
            taskList.Add(Task.Run(() =>
            {
                new ScoreJob().Click();
                CommonHelper.LogBD("ScoreJob完成", logName);
            }));
            taskList.Add(Task.Run(() =>
            {
                new AgainstJob().Click();
                CommonHelper.LogBD("AgainstJob完成", logName);
            }));
            Task.WaitAll(taskList.ToArray());
            CommonHelper.LogBD("开始赔率", logName);
            ThreadPool.SetMaxThreads(50, 50);
            new Update_RealTimeJobToDayOne().Click();
            CommonHelper.LogBD("结束Update_RealTime", logName);
        }
    }

}