HeNan22X5Job.cs 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Text.RegularExpressions;
  6. using HtmlAgilityPack;
  7. using Quartz;
  8. using SCC.Common;
  9. using SCC.Crawler.Tools;
  10. using SCC.Interface;
  11. using SCC.Models;
  12. namespace SCC.Crawler.DT
  13. {
  14. /// <summary>
  15. /// 河南22选5
  16. /// </summary>
  17. [DisallowConcurrentExecution]
  18. [PersistJobDataAfterExecution]
  19. public class HeNan22X5Job : IJob
  20. {
  21. /// <summary>
  22. /// 初始化函数
  23. /// </summary>
  24. public HeNan22X5Job()
  25. {
  26. log = new LogHelper();
  27. services = IOC.Resolve<IDTOpenCode>();
  28. email = IOC.Resolve<IEmail>();
  29. }
  30. /// <summary>
  31. /// 作业执行入口
  32. /// </summary>
  33. /// <param name="context">作业执行上下文</param>
  34. public void Execute(IJobExecutionContext context)
  35. {
  36. Config = CommonHelper.GetConfigFromDataMap(context.JobDetail.JobDataMap);
  37. //预设节假日不开奖
  38. if (Config.SkipDate.Contains(CommonHelper.SCCSysDateTime.ToString("yyyyMMdd"))) return;
  39. LatestItem = context.JobDetail.JobDataMap["LatestItem"] as OpenCode5DTModel;
  40. try
  41. {
  42. //服务启动时配置初始数据
  43. if (LatestItem == null)
  44. {
  45. LatestItem = services.GetOpenCode5DTLastItem(currentLottery);
  46. if (LatestItem == null)
  47. LatestItem = new OpenCode5DTModel
  48. {
  49. Term = CommonHelper.GenerateQiHaoYYYYQQQ(0),
  50. OpenTime = new DateTime(CommonHelper.SCCSysDateTime.Year, 1, 1)
  51. };
  52. }
  53. //程序时间第二天,程序根据配置检查是否昨天有开奖
  54. isGetData = false;
  55. if (CommonHelper.CheckDTIsNeedGetData(Config)) CheckingOpenDayTheLotteryData();
  56. if (!LatestItem.Term.ToString().StartsWith(CommonHelper.SCCSysDateTime.ToString("yyyy")))
  57. LatestItem = new OpenCode5DTModel
  58. {
  59. Term = CommonHelper.GenerateQiHaoYYYYQQQ(0),
  60. OpenTime = new DateTime(CommonHelper.SCCSysDateTime.Year, 1, 1)
  61. };
  62. //当今日开奖并且当前时间是晚上8点过后开始抓取
  63. if (CommonHelper.CheckTodayIsOpenDay(Config) && CommonHelper.SCCSysDateTime.Hour > 12)
  64. {
  65. DoTodayJobByMainUrl();
  66. DoTodayJobByBackUrl();
  67. }
  68. }
  69. catch (Exception ex)
  70. {
  71. log.Error(GetType(), string.Format("【{0}】抓取时发生错误,错误信息【{1}】", Config.Area + currentLottery, ex.Message));
  72. }
  73. //保存最新期号
  74. context.JobDetail.JobDataMap["LatestItem"] = LatestItem;
  75. }
  76. /// <summary>
  77. /// 自检爬取未爬取到的开奖数据,并对昨日开奖但未爬取到开奖数据的彩种添加邮件提醒
  78. /// </summary>
  79. private void CheckingOpenDayTheLotteryData()
  80. {
  81. //从数据库中获取昨天数据抓取失败列表
  82. FailedQiHaoList = services.GetFailedYYYYQQQList(currentLottery);
  83. if (FailedQiHaoList.Count > 0)
  84. {
  85. DoYesterdayFailedListByMainUrl();
  86. DoYesterdayFailedListByBackUrl();
  87. }
  88. if (LatestItem.OpenTime.ToString("yyyyMMdd") !=
  89. CommonHelper.SCCSysDateTime.AddDays(-1).ToString("yyyyMMdd"))
  90. {
  91. //开奖时间(昨天)未抓取到最新开奖数据,则再抓取一次,若还不成功则写入待发送邮件列表
  92. DoTodayJobByMainUrl();
  93. DoTodayJobByBackUrl();
  94. if (LatestItem.OpenTime.ToString("yyyyMMdd") !=
  95. CommonHelper.SCCSysDateTime.AddDays(-1).ToString("yyyyMMdd"))
  96. {
  97. var openQiHao = (LatestItem.Term + 1).ToString();
  98. if (email.AddEmail(Config.Area + currentLottery, openQiHao,
  99. CommonHelper.GenerateDTOpenTime(Config)))
  100. log.Error(GetType(), CommonHelper.GetJobLogError(Config, openQiHao));
  101. }
  102. }
  103. }
  104. /// <summary>
  105. /// 通过主站点爬取开奖数据
  106. /// (河南福彩网)
  107. /// </summary>
  108. private void DoTodayJobByMainUrl()
  109. {
  110. if (!string.IsNullOrEmpty(Config.MainUrl))
  111. {
  112. var OpenList = GetOpenListFromMainUrl(Config.MainUrl);
  113. if (OpenList.Count == 0) return; //无抓取数据
  114. var newestQiHao = OpenList.First().Term.ToString();
  115. var startQiNum = Convert.ToInt32(LatestItem.Term.ToString().Substring(4)) + 1;
  116. var newestQiNum = Convert.ToInt32(newestQiHao);
  117. if (startQiNum > newestQiNum) return; //无最新数据
  118. //处理最新开奖数据
  119. var getQiHao = string.Empty;
  120. OpenCode5DTModel matchItem = null;
  121. for (var i = startQiNum; i <= newestQiNum; i++)
  122. {
  123. getQiHao = LatestItem.Term.ToString().Substring(0, 4) + i.ToString().PadLeft(3, '0');
  124. matchItem = OpenList.Where(R => R.Term.ToString() == getQiHao).FirstOrDefault();
  125. if (matchItem != null && OptimizeMainModel(ref matchItem) &&
  126. services.AddDTOpen5Code(currentLottery, matchItem))
  127. {
  128. //Do Success Log
  129. log.Info(GetType(), CommonHelper.GetJobMainLogInfo(Config, getQiHao));
  130. LatestItem = matchItem;
  131. isGetData = true;
  132. }
  133. }
  134. }
  135. }
  136. /// <summary>
  137. /// 通过主站爬取错误期号列表中每一个期号
  138. /// (河南福彩网)
  139. /// </summary>
  140. private void DoYesterdayFailedListByMainUrl()
  141. {
  142. if (!string.IsNullOrEmpty(Config.MainUrl) && FailedQiHaoList.Count > 0)
  143. {
  144. var OpenList = GetOpenListFromMainUrl(Config.MainUrl);
  145. if (OpenList.Count == 0) return; //无抓取数据
  146. OpenCode5DTModel matchItem = null;
  147. var SuccessList = new List<string>();
  148. foreach (var failedQiHao in FailedQiHaoList)
  149. {
  150. matchItem = OpenList.Where(R => R.Term.ToString() == failedQiHao).FirstOrDefault();
  151. if (matchItem != null && OptimizeMainModel(ref matchItem) &&
  152. services.AddDTOpen5Code(currentLottery, matchItem))
  153. {
  154. //Do Success Log
  155. log.Info(GetType(), CommonHelper.GetJobMainLogInfo(Config, failedQiHao));
  156. if (matchItem.Term > LatestItem.Term) LatestItem = matchItem;
  157. isGetData = true;
  158. SuccessList.Add(failedQiHao);
  159. }
  160. }
  161. foreach (var successQiHao in SuccessList) FailedQiHaoList.Remove(successQiHao);
  162. }
  163. }
  164. /// <summary>
  165. /// 获取主站开奖列表数据
  166. /// </summary>
  167. /// <param name="mainUrl">主站地址</param>
  168. /// <returns></returns>
  169. private List<OpenCode5DTModel> GetOpenListFromMainUrl(string mainUrl)
  170. {
  171. var result = new List<OpenCode5DTModel>();
  172. try
  173. {
  174. var url = new Uri(mainUrl);
  175. var htmlResource = NetHelper.GetUrlResponse(url.AbsoluteUri);
  176. if (htmlResource == null) return result;
  177. var doc = new HtmlDocument();
  178. doc.LoadHtml(htmlResource);
  179. var table = doc.DocumentNode.SelectSingleNode("//table");
  180. if (table == null) return result;
  181. var trs = table.ChildNodes.Where(S => S.Name.ToLower() == "tr").ToList();
  182. List<HtmlNode> tds = null;
  183. string term = string.Empty, openCodeString = string.Empty, optimizeUrl = string.Empty;
  184. decimal sales = 0, pool = 0;
  185. OpenCode5DTModel model = null;
  186. HtmlNode nodeA = null;
  187. for (var i = 1; i == trs.Count; i++)
  188. {
  189. tds = trs[i].ChildNodes.Where(S => S.Name.ToLower() == "td").ToList();
  190. if (tds.Count < 8) continue;
  191. model = new OpenCode5DTModel();
  192. term = tds[0].InnerText.Trim();
  193. if (term.StartsWith((CommonHelper.SCCSysDateTime.Year - 1).ToString())) break;
  194. model.Term = Convert.ToInt64(tds[0].InnerText.Trim());
  195. openCodeString = tds[1].InnerText.Trim();
  196. model.OpenCode1 = Convert.ToInt32(openCodeString.Substring(0, 2));
  197. model.OpenCode2 = Convert.ToInt32(openCodeString.Substring(2, 2));
  198. model.OpenCode3 = Convert.ToInt32(openCodeString.Substring(4, 2));
  199. model.OpenCode4 = Convert.ToInt32(openCodeString.Substring(6, 2));
  200. model.OpenCode5 = Convert.ToInt32(openCodeString.Substring(8, 2));
  201. model.OpenTime = Convert.ToDateTime(tds[6].InnerText.Trim());
  202. sales = Convert.ToDecimal(tds[2].InnerText.Trim());
  203. pool = Convert.ToDecimal(tds[5].InnerText.Trim());
  204. model.Spare = sales + "|" + pool;
  205. nodeA = tds[7].ChildNodes.Where(N => N.Name.ToLower() == "a").FirstOrDefault();
  206. if (nodeA == null) continue;
  207. optimizeUrl = nodeA.Attributes["href"].Value;
  208. model.DetailUrl = new Uri(url, optimizeUrl).AbsoluteUri;
  209. result.Add(model);
  210. }
  211. var checkDataHelper = new CheckDataHelper();
  212. var dbdata = services.GetListS<OpenCode5DTModel>(currentLottery)
  213. .ToDictionary(w => w.Term.ToString(), w => w.GetCodeStr());
  214. checkDataHelper.CheckData(dbdata, result.ToDictionary(w => w.Term.ToString(), w => w.GetCodeStr()),
  215. Config.Area, currentLottery);
  216. }
  217. catch (Exception ex)
  218. {
  219. log.Error(GetType(),
  220. string.Format("【{0}】通过主站点抓取开奖列表时发生错误,错误信息【{1}】", Config.Area + currentLottery, ex.Message));
  221. }
  222. return result;
  223. }
  224. /// <summary>
  225. /// 完善主站江苏体彩7位数开奖详情信息
  226. /// </summary>
  227. /// <param name="model"></param>
  228. private bool OptimizeMainModel(ref OpenCode5DTModel model)
  229. {
  230. try
  231. {
  232. var entity = new KaijiangDetailsEntity();
  233. entity.KaiJiangItems = new List<Kaijiangitem>();
  234. var htmlResource = NetHelper.GetUrlResponse(model.DetailUrl);
  235. if (string.IsNullOrWhiteSpace(htmlResource)) return false;
  236. var doc = new HtmlDocument();
  237. doc.LoadHtml(htmlResource);
  238. var table = doc.DocumentNode.SelectSingleNode("//table");
  239. if (table == null) return false;
  240. var trs = table.ChildNodes.Where(C => C.Name == "tr").ToList();
  241. List<HtmlNode> tds = null;
  242. foreach (var tr in trs)
  243. {
  244. tds = tr.ChildNodes.Where(S => S.Name.ToLower() == "td").ToList();
  245. if (tds.Count < 3) continue;
  246. if (tds[0].InnerText == "一等奖")
  247. {
  248. var tmp = new Kaijiangitem
  249. {
  250. Name = "一等奖",
  251. Total = tds[1].InnerText.Replace("注", ""),
  252. TotalMoney = tds[2].InnerText.Replace("元", "")
  253. };
  254. entity.KaiJiangItems.Add(tmp);
  255. // Level1Num = Convert.ToInt32(tds[1].InnerText.Replace("注", ""));
  256. // Level1Money = Convert.ToInt32(tds[2].InnerText.Replace("元", ""));
  257. }
  258. else if (tds[0].InnerText == "二等奖")
  259. {
  260. var tmp = new Kaijiangitem
  261. {
  262. Name = "二等奖",
  263. Total = tds[1].InnerText.Replace("注", ""),
  264. TotalMoney = tds[2].InnerText.Replace("元", "")
  265. };
  266. entity.KaiJiangItems.Add(tmp);
  267. }
  268. else if (tds[0].InnerText == "三等奖")
  269. {
  270. var tmp = new Kaijiangitem
  271. {
  272. Name = "三等奖",
  273. Total = tds[1].InnerText.Replace("注", ""),
  274. TotalMoney = tds[2].InnerText.Replace("元", "")
  275. };
  276. entity.KaiJiangItems.Add(tmp);
  277. }
  278. else if (tds[0].InnerText == "好运二")
  279. {
  280. var tmp = new Kaijiangitem
  281. {
  282. Name = "好运二",
  283. Total = tds[1].InnerText.Replace("注", ""),
  284. TotalMoney = tds[2].InnerText.Replace("元", "")
  285. };
  286. entity.KaiJiangItems.Add(tmp);
  287. }
  288. else if (tds[0].InnerText == "好运三")
  289. {
  290. var tmp = new Kaijiangitem
  291. {
  292. Name = "好运三",
  293. Total = tds[1].InnerText.Replace("注", ""),
  294. TotalMoney = tds[2].InnerText.Replace("元", "")
  295. };
  296. entity.KaiJiangItems.Add(tmp);
  297. }
  298. else if (tds[0].InnerText == "好运四")
  299. {
  300. var tmp = new Kaijiangitem
  301. {
  302. Name = "好运四",
  303. Total = tds[1].InnerText.Replace("注", ""),
  304. TotalMoney = tds[2].InnerText.Replace("元", "")
  305. };
  306. entity.KaiJiangItems.Add(tmp);
  307. }
  308. }
  309. var salesjackpot = model.Spare.Split('|');
  310. entity.Trje = salesjackpot[0];
  311. entity.Gdje = salesjackpot[1];
  312. model.Spare = entity.TryToJson();
  313. //string.Format("{0},{1}^一等奖|{2}|{3},二等奖|{4}|{5},三等奖|{6}|{7},好运二|{8}|{9},好运三|{10}|{11},好运四|{12}|{13}",
  314. // salesjackpot[0], salesjackpot[1], Level1Num, Level1Money, Level2Num, Level2Money, Level3Num, Level3Money,
  315. // Level4Num, Level4Money, Level5Num, Level5Money, Level6Num, Level6Money);
  316. return true;
  317. }
  318. catch (Exception ex)
  319. {
  320. log.Error(GetType(),
  321. string.Format("【{0}】通过主站点完善抓取开奖列表时发生错误,错误信息【{1}】", Config.Area + currentLottery, ex.Message));
  322. }
  323. return false;
  324. }
  325. /// <summary>
  326. /// 通过备用站点抓取开奖数据
  327. /// (彩票两元网)
  328. /// </summary>
  329. private void DoTodayJobByBackUrl()
  330. {
  331. if (!string.IsNullOrEmpty(Config.BackUrl))
  332. {
  333. var OpenList = GetOpenListFromBackUrl();
  334. if (OpenList.Count == 0) return; //无抓取数据
  335. var newestQiHao = OpenList.First().Term.ToString();
  336. var startQiNum = Convert.ToInt32(LatestItem.Term.ToString().Substring(4)) + 1;
  337. var newestQiNum = Convert.ToInt32(newestQiHao.Substring(4));
  338. if (startQiNum > newestQiNum) return; //无最新数据
  339. //处理最新开奖数据
  340. var getQiHao = string.Empty;
  341. OpenCode5DTModel matchItem = null;
  342. for (var i = startQiNum; i <= newestQiNum; i++)
  343. {
  344. getQiHao = LatestItem.Term.ToString().Substring(0, 4) + i.ToString().PadLeft(3, '0');
  345. matchItem = OpenList.Where(R => R.Term.ToString() == getQiHao).FirstOrDefault();
  346. if (matchItem != null && OptimizeBackModel(ref matchItem) &&
  347. services.AddDTOpen5Code(currentLottery, matchItem))
  348. {
  349. //Do Success Log
  350. log.Info(GetType(), CommonHelper.GetJobBackLogInfo(Config, getQiHao));
  351. LatestItem = matchItem;
  352. isGetData = true;
  353. }
  354. }
  355. }
  356. }
  357. /// <summary>
  358. /// 通过备用地址抓取错误期号列表中每一个期号
  359. /// (彩票两元网)
  360. /// </summary>
  361. private void DoYesterdayFailedListByBackUrl()
  362. {
  363. if (!string.IsNullOrEmpty(Config.BackUrl) && FailedQiHaoList.Count > 0)
  364. {
  365. var OpenList = GetOpenListFromBackUrl();
  366. if (OpenList.Count == 0) return; //无抓取数据
  367. OpenCode5DTModel matchItem = null;
  368. var SuccessList = new List<string>();
  369. foreach (var failedQiHao in FailedQiHaoList)
  370. {
  371. matchItem = OpenList.Where(R => R.Term.ToString() == failedQiHao).FirstOrDefault();
  372. if (matchItem != null && OptimizeBackModel(ref matchItem) &&
  373. services.AddDTOpen5Code(currentLottery, matchItem))
  374. {
  375. //Do Success Log
  376. log.Info(GetType(), CommonHelper.GetJobBackLogInfo(Config, failedQiHao));
  377. if (matchItem.Term > LatestItem.Term) LatestItem = matchItem;
  378. SuccessList.Add(failedQiHao);
  379. isGetData = true;
  380. }
  381. }
  382. foreach (var successQiHao in SuccessList) FailedQiHaoList.Remove(successQiHao);
  383. }
  384. }
  385. /// <summary>
  386. /// 获取备用站点开奖列表数据
  387. /// </summary>
  388. /// <returns></returns>
  389. private List<OpenCode5DTModel> GetOpenListFromBackUrl()
  390. {
  391. var result = new List<OpenCode5DTModel>();
  392. try
  393. {
  394. var url = new Uri(Config.BackUrl);
  395. var htmlResource = NetHelper.GetUrlResponse(Config.BackUrl, Encoding.GetEncoding("gb2312"));
  396. if (htmlResource == null) return result;
  397. var doc = new HtmlDocument();
  398. doc.LoadHtml(htmlResource);
  399. var table = doc.DocumentNode.SelectSingleNode("//table");
  400. if (table == null) return result;
  401. var trs = table.ChildNodes.Where(node => node.Name == "tr").ToList();
  402. OpenCode5DTModel model = null;
  403. HtmlNode nodeA = null;
  404. var optimizeUrl = string.Empty;
  405. for (var i = 2; i < trs.Count; i++) //第一二行为表头
  406. {
  407. var trstyle = trs[i].Attributes["style"];
  408. if (trstyle != null && trstyle.Value == "display:none") continue;
  409. var tds = trs[i].ChildNodes.Where(node => node.Name == "td").ToList();
  410. if (tds.Count < 10) continue;
  411. model = new OpenCode5DTModel();
  412. nodeA = tds[0].ChildNodes.Where(n => n.Name == "a").FirstOrDefault();
  413. if (nodeA == null) continue;
  414. model.Term = Convert.ToInt64(nodeA.InnerText.Trim());
  415. optimizeUrl = nodeA.Attributes["href"].Value;
  416. model.DetailUrl = new Uri(url, optimizeUrl).AbsoluteUri;
  417. model.OpenTime = Convert.ToDateTime(tds[9].InnerText);
  418. if (tds[1].ChildNodes.Count == 0) continue;
  419. var opencodeNode = tds[1].ChildNodes.Where(n => n.Name.ToLower() == "i").ToList();
  420. if (opencodeNode.Count < 5) continue;
  421. model.OpenCode1 = Convert.ToInt32(opencodeNode[0].InnerText.Trim());
  422. model.OpenCode2 = Convert.ToInt32(opencodeNode[1].InnerText.Trim());
  423. model.OpenCode3 = Convert.ToInt32(opencodeNode[2].InnerText.Trim());
  424. model.OpenCode4 = Convert.ToInt32(opencodeNode[3].InnerText.Trim());
  425. model.OpenCode5 = Convert.ToInt32(opencodeNode[4].InnerText.Trim());
  426. result.Add(model);
  427. }
  428. var checkDataHelper = new CheckDataHelper();
  429. var dbdata = services.GetListS<OpenCode5DTModel>(currentLottery)
  430. .ToDictionary(w => w.Term.ToString(), w => w.GetCodeStr());
  431. checkDataHelper.CheckData(dbdata, result.ToDictionary(w => w.Term.ToString(), w => w.GetCodeStr()),
  432. Config.Area, currentLottery);
  433. result = result.OrderByDescending(S => S.Term).ToList();
  434. }
  435. catch (Exception ex)
  436. {
  437. log.Error(GetType(),
  438. string.Format("【{0}】通过备用站点抓取开奖列表时发生错误,错误信息【{1}】", Config.Area + currentLottery, ex.Message));
  439. }
  440. return result;
  441. }
  442. /// <summary>
  443. /// 完善备用站点江苏体彩7位数开奖实体信息
  444. /// </summary>
  445. /// <param name="model"></param>
  446. private bool OptimizeBackModel(ref OpenCode5DTModel model)
  447. {
  448. try
  449. {
  450. var entity = new KaijiangDetailsEntity();
  451. entity.KaiJiangItems = new List<Kaijiangitem>();
  452. var htmlResource = NetHelper.GetUrlResponse(model.DetailUrl, Encoding.GetEncoding("gb2312"));
  453. if (string.IsNullOrWhiteSpace(htmlResource)) return false;
  454. var doc = new HtmlDocument();
  455. doc.LoadHtml(htmlResource);
  456. var table = doc.DocumentNode.SelectSingleNode("//table");
  457. if (table == null) return false;
  458. var trs = table.ChildNodes.Where(N => N.Name.ToLower() == "tr").ToList();
  459. List<HtmlNode> tds = null;
  460. for (var i = 1; i < trs.Count; i++) //第一行为表头
  461. {
  462. tds = trs[i].ChildNodes.Where(N => N.Name.ToLower() == "td").ToList();
  463. if (tds.Count < 5) continue;
  464. if (tds[1].InnerText == "一等奖")
  465. {
  466. var tmp = new Kaijiangitem
  467. {
  468. Name = "一等奖",
  469. Total = tds[2].InnerText,
  470. TotalMoney = tds[3].InnerText
  471. };
  472. entity.KaiJiangItems.Add(tmp);
  473. //Level1Num = Convert.ToInt32(tds[2].InnerText);
  474. // Level1Money = Convert.ToDecimal(tds[3].InnerText);
  475. }
  476. if (tds[1].InnerText == "二等奖")
  477. {
  478. var tmp = new Kaijiangitem
  479. {
  480. Name = "二等奖",
  481. Total = tds[2].InnerText,
  482. TotalMoney = tds[3].InnerText
  483. };
  484. entity.KaiJiangItems.Add(tmp);
  485. }
  486. if (tds[1].InnerText == "三等奖")
  487. {
  488. var tmp = new Kaijiangitem
  489. {
  490. Name = "三等奖",
  491. Total = tds[2].InnerText,
  492. TotalMoney = tds[3].InnerText
  493. };
  494. entity.KaiJiangItems.Add(tmp);
  495. }
  496. if (tds[1].InnerText == "好运二")
  497. {
  498. var tmp = new Kaijiangitem
  499. {
  500. Name = "好运二",
  501. Total = tds[2].InnerText,
  502. TotalMoney = tds[3].InnerText
  503. };
  504. entity.KaiJiangItems.Add(tmp);
  505. }
  506. if (tds[1].InnerText == "好运三")
  507. {
  508. var tmp = new Kaijiangitem
  509. {
  510. Name = "好运三",
  511. Total = tds[2].InnerText,
  512. TotalMoney = tds[3].InnerText
  513. };
  514. entity.KaiJiangItems.Add(tmp);
  515. }
  516. if (tds[1].InnerText == "好运四")
  517. {
  518. var tmp = new Kaijiangitem
  519. {
  520. Name = "好运四",
  521. Total = tds[2].InnerText,
  522. TotalMoney = tds[3].InnerText
  523. };
  524. entity.KaiJiangItems.Add(tmp);
  525. }
  526. }
  527. var reg = new Regex(@"本期投注总额:([\d.,]*?)元");
  528. var match = reg.Match(htmlResource);
  529. if (match.Success) entity.Trje = match.Result("$1").Replace(",", string.Empty);
  530. reg = new Regex(@"奖池资金累计金额:([\d.,]*?)元");
  531. match = reg.Match(htmlResource);
  532. if (match.Success) entity.Gdje = match.Result("$1").Replace(",", string.Empty);
  533. model.Spare = entity.TryToJson();
  534. //string.Format("{0},{1}^一等奖|{2}|{3},二等奖|{4}|{5},三等奖|{6}|{7},好运二|{8}|{9},好运三|{10}|{11},好运四|{12}|{13}",
  535. // Sales, Jackpot, Level1Num, Level1Money, Level2Num, Level2Money, Level3Num, Level3Money,
  536. // Level4Num, Level4Money, Level5Num, Level5Money, Level6Num, Level6Money);
  537. return true;
  538. }
  539. catch (Exception ex)
  540. {
  541. log.Error(GetType(),
  542. string.Format("【{0}】通过备用站点优化开奖列表时发生错误,错误信息【{1}】", Config.Area + currentLottery, ex.Message));
  543. }
  544. return false;
  545. }
  546. #region Attribute
  547. /// <summary>
  548. /// 配置信息
  549. /// </summary>
  550. private SCCConfig Config;
  551. /// <summary>
  552. /// 当天抓取的最新一期开奖记录
  553. /// </summary>
  554. private OpenCode5DTModel LatestItem;
  555. /// <summary>
  556. /// 当天抓取失败列表
  557. /// </summary>
  558. private List<string> FailedQiHaoList;
  559. /// <summary>
  560. /// 日志对象
  561. /// </summary>
  562. private readonly LogHelper log;
  563. /// <summary>
  564. /// 数据服务
  565. /// </summary>
  566. private readonly IDTOpenCode services;
  567. /// <summary>
  568. /// 当前彩种
  569. /// </summary>
  570. private SCCLottery currentLottery => SCCLottery.HeNan22X5;
  571. /// <summary>
  572. /// 邮件接口
  573. /// </summary>
  574. private readonly IEmail email;
  575. /// <summary>
  576. /// 是否本次运行抓取到开奖数据
  577. /// </summary>
  578. private bool isGetData;
  579. #endregion
  580. }
  581. }