Update_RealTimeJob.cs 1.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Diagnostics;
  4. using System.Linq;
  5. using System.Text;
  6. using System.Threading;
  7. using System.Threading.Tasks;
  8. using FCS.Common;
  9. using FCS.Crawler.ZCLotteryAgainst;
  10. using FCS.Crawler.ZCLotteryAsianDish;
  11. using FCS.Crawler.ZCLotteryGames;
  12. using FCS.Crawler.ZCLotteryGrouping;
  13. using FCS.Crawler.ZCLotteryIP;
  14. using FCS.Crawler.ZCLotteryMatchs;
  15. using FCS.Crawler.ZCLotteryOdds;
  16. using FCS.Crawler.ZCLotteryScore;
  17. using FCS.Crawler.ZCLotterySizeIndex;
  18. using FCS.Crawler.ZCLotteryTeam;
  19. using FCS.Interface;
  20. using FCS.Models;
  21. using Quartz;
  22. namespace FCS.Crawler
  23. {
  24. public class Update_RealTimeJob : CommonJob, IJob
  25. {
  26. public Update_RealTimeJob()
  27. {
  28. logName = "Update_RealTimeJob";
  29. }
  30. public void Execute(IJobExecutionContext context)
  31. {
  32. Config = CommonHelper.GetConfigFromDataMap(context.JobDetail.JobDataMap);
  33. Click();
  34. }
  35. public void Click()
  36. {
  37. ThreadPool.SetMaxThreads(200, 200);
  38. CommonHelper.LogBD("开始Update_RealTime", logName);
  39. List<F_Games> list = new List<F_Games>();
  40. new GamesJob().Click(out list);
  41. Task.Run(() => new GamesDetailsJob().Click());
  42. while (CommonHelper.ThreadsFinsh())
  43. continue;
  44. CommonHelper.LogBD("结束Update_RealTime", logName);
  45. }
  46. }
  47. }