ZJTC6J1Job.cs 28 KB

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