Update_RealTimeJob.cs 1.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253
  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. Task.Run(() => new ScoreJob().Click());
  43. Task.Run(() => new AgainstJob().Click());
  44. while (!CommonHelper.ThreadsFinsh())
  45. continue;
  46. CommonHelper.LogBD("结束Update_RealTime", logName);
  47. }
  48. }
  49. }