UpdateJob.cs 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  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.Basketball;
  10. using FCS.Crawler.ZCLotteryAgainst;
  11. using FCS.Crawler.ZCLotteryAsianDish;
  12. using FCS.Crawler.ZCLotteryGames;
  13. using FCS.Crawler.ZCLotteryGrouping;
  14. using FCS.Crawler.ZCLotteryIP;
  15. using FCS.Crawler.ZCLotteryMatchs;
  16. using FCS.Crawler.ZCLotteryScore;
  17. using FCS.Crawler.ZCLotterySizeIndex;
  18. using FCS.Interface;
  19. using FCS.Models;
  20. using FCS.Models.DTO;
  21. using FCS.Models.Entity;
  22. using HtmlAgilityPack;
  23. using Newtonsoft.Json;
  24. using Newtonsoft.Json.Linq;
  25. using Quartz;
  26. using static FCS.Crawler.ZCLotteryAsianDish.AsianDishJob;
  27. namespace FCS.Crawler
  28. {
  29. public class UpdateJob : CommonJob, IJob
  30. {
  31. public UpdateJob()
  32. {
  33. logName = "UpdateJob";
  34. }
  35. public void Execute(IJobExecutionContext context)
  36. {
  37. Config = CommonHelper.GetConfigFromDataMap(context.JobDetail.JobDataMap);
  38. Click();
  39. }
  40. public void Click()
  41. {
  42. ThreadPool.SetMaxThreads(200, 200);
  43. CommonHelper.LogBD("Update开始", logName);
  44. new IPJob().GetIP();
  45. CommonHelper.LogBD("IP结束", logName);
  46. taskList.Add(Task.Run(() =>
  47. {
  48. new FootballMatchJob().GetAll();
  49. CommonHelper.LogBD("FootballMatchJob结束", logName);
  50. new GroupingJob().Click();
  51. CommonHelper.LogBD("GroupingJob结束 足球分支结束", logName);
  52. }));
  53. taskList.Add(Task.Run(() =>
  54. {
  55. new B_GroupingJob().Click();
  56. CommonHelper.LogBD("B_GroupingJob结束", logName);
  57. new B_TeamJob().GetAll();
  58. CommonHelper.LogBD("B_TeamJob结束", logName);
  59. new B_PlayerJob().GetAll();
  60. CommonHelper.LogBD("B_PlayerJob结束", logName);
  61. new B_GamesJob().Click();
  62. CommonHelper.LogBD("B_GamesJob结束", logName);
  63. new B_TeamStatisticsJob().Click();
  64. CommonHelper.LogBD("B_TeamStatisticsJob结束", logName);
  65. new B_SizeBallRankingJob().Click();
  66. CommonHelper.LogBD("B_SizeBallRankingJob结束", logName);
  67. new B_PlayersStatisticsJob().Click();
  68. CommonHelper.LogBD("B_PlayersStatisticsJob结束", logName);
  69. new B_MakeBallRankingJob().Click();
  70. CommonHelper.LogBD("B_MakeBallRankingJob结束", logName);
  71. new B_LeagueRankingJob().Click();
  72. CommonHelper.LogBD("B_LeagueRankingJob结束 篮球结束", logName);
  73. }));
  74. Task.WaitAll(taskList.ToArray());
  75. //new GamesJob().Click();
  76. //CommonHelper.LogBD("GamesJob结束 开始赔率", logName);
  77. //ThreadPool.SetMaxThreads(50, 50);
  78. //new Update_RealTimeJobToDay10().Click();
  79. CommonHelper.LogBD("Update结束", logName);
  80. }
  81. }
  82. }