ZJTC6J1Job.cs 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621
  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. /// 浙江体彩6+1
  16. /// </summary>
  17. [DisallowConcurrentExecution]
  18. [PersistJobDataAfterExecution]
  19. public class ZJTC6J1Job : IJob
  20. {
  21. /// <summary>
  22. /// 初始化函数
  23. /// </summary>
  24. public ZJTC6J1Job()
  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 OpenCode7DTModel;
  40. try
  41. {
  42. //服务启动时配置初始数据
  43. if (LatestItem == null)
  44. {
  45. LatestItem = services.GetOpenCode7DTLastItem(currentLottery);
  46. if (LatestItem == null)
  47. LatestItem = new OpenCode7DTModel
  48. {
  49. Term = CommonHelper.GenerateQiHaoYYQQQ(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("yy")))
  57. LatestItem = new OpenCode7DTModel
  58. {
  59. Term = CommonHelper.GenerateQiHaoYYQQQ(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.GetFailedYYQQQList(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. /*
  105. * 2017358 17045697
  106. * 2017357 17039516
  107. * 2017356 17033161
  108. * 2017355 17026630
  109. * 2017354 17020136
  110. *
  111. * 2017260 16419781
  112. * 2017259 16415163
  113. */
  114. /// <summary>
  115. /// 通过主站点爬取开奖数据
  116. /// (浙江体彩网)
  117. /// </summary>
  118. private void DoTodayJobByMainUrl()
  119. {
  120. if (!string.IsNullOrEmpty(Config.MainUrl))
  121. {
  122. var OpenList = GetOpenListFromMainUrl(Config.MainUrl);
  123. if (OpenList.Count == 0) return; //无抓取数据
  124. var newestQiHao = OpenList.Max(w => w.Term).ToString();
  125. var startQiNum = Convert.ToInt32(LatestItem.Term.ToString().Substring(2)) + 1;
  126. var newestQiNum = Convert.ToInt32(newestQiHao.Substring(2));
  127. if (startQiNum > newestQiNum) return; //无最新数据
  128. //处理最新开奖数据
  129. var getQiHao = string.Empty;
  130. OpenCode7DTModel matchItem = null;
  131. for (var i = startQiNum; i <= newestQiNum; i++)
  132. {
  133. getQiHao = LatestItem.Term.ToString().Substring(0, 2) + i.ToString().PadLeft(3, '0');
  134. matchItem = OpenList.Where(R => R.Term.ToString() == getQiHao).FirstOrDefault();
  135. if (matchItem != null && services.AddDTOpen7Code(currentLottery, matchItem))
  136. {
  137. //Do Success Log
  138. log.Info(GetType(), CommonHelper.GetJobMainLogInfo(Config, getQiHao));
  139. LatestItem = matchItem;
  140. isGetData = true;
  141. }
  142. }
  143. }
  144. }
  145. /// <summary>
  146. /// 通过主站爬取错误期号列表中每一个期号
  147. /// (浙江体彩网)
  148. /// </summary>
  149. private void DoYesterdayFailedListByMainUrl()
  150. {
  151. if (!string.IsNullOrEmpty(Config.MainUrl) && FailedQiHaoList.Count > 0)
  152. {
  153. var OpenList = GetOpenListFromMainUrl(Config.MainUrl);
  154. if (OpenList.Count == 0) return; //无抓取数据
  155. OpenCode7DTModel matchItem = null;
  156. var SuccessList = new List<string>();
  157. foreach (var failedQiHao in FailedQiHaoList)
  158. {
  159. matchItem = OpenList.Where(R => R.Term.ToString() == failedQiHao).FirstOrDefault();
  160. if (matchItem != null && services.AddDTOpen7Code(currentLottery, matchItem))
  161. {
  162. //Do Success Log
  163. log.Info(GetType(), CommonHelper.GetJobMainLogInfo(Config, failedQiHao));
  164. if (matchItem.Term > LatestItem.Term) LatestItem = matchItem;
  165. isGetData = true;
  166. SuccessList.Add(failedQiHao);
  167. }
  168. }
  169. foreach (var successQiHao in SuccessList) FailedQiHaoList.Remove(successQiHao);
  170. }
  171. }
  172. /// <summary>
  173. /// 获取主站开奖列表数据
  174. /// </summary>
  175. /// <param name="mainUrl">主站地址</param>
  176. /// <returns></returns>
  177. private List<OpenCode7DTModel> GetOpenListFromMainUrl(string mainUrl)
  178. {
  179. var result = new List<OpenCode7DTModel>();
  180. try
  181. {
  182. var htmlResource = NetHelper.GetUrlResponse(Config.MainUrl, Encoding.UTF8);
  183. if (htmlResource == null) return result;
  184. var doc = new HtmlDocument();
  185. doc.LoadHtml(htmlResource);
  186. var tbody = doc.DocumentNode.SelectSingleNode("//tbody");
  187. if (tbody == null) return result;
  188. var trs = tbody.ChildNodes.Where(N => N.Name.ToLower() == "tr").ToList();
  189. foreach (var item in trs)
  190. {
  191. var tds = item.ChildNodes.Where(w => w.Name == "td").ToList();
  192. var qihao = tds[0].InnerText.Trim();
  193. var kaijianghao = tds[1].InnerText.Trim().Replace(" ", "");
  194. var opentime = tds[10].InnerText.Trim();
  195. var tmp = new OpenCode7DTModel
  196. {
  197. Term = long.Parse(qihao),
  198. OpenTime = DateTime.Parse(opentime)
  199. };
  200. tmp.OpenCode1 = int.Parse(kaijianghao.Substring(0, 1));
  201. tmp.OpenCode2 = int.Parse(kaijianghao.Substring(1, 1));
  202. tmp.OpenCode3 = int.Parse(kaijianghao.Substring(2, 1));
  203. tmp.OpenCode4 = int.Parse(kaijianghao.Substring(3, 1));
  204. tmp.OpenCode5 = int.Parse(kaijianghao.Substring(4, 1));
  205. tmp.OpenCode6 = int.Parse(kaijianghao.Substring(5, 1));
  206. tmp.OpenCode7 = int.Parse(kaijianghao.Substring(6, 1));
  207. OptimizeMainModel(ref tmp, item);
  208. result.Add(tmp);
  209. }
  210. var checkDataHelper = new CheckDataHelper();
  211. var dbdata = services.GetListS<OpenCode7DTModel>(currentLottery)
  212. .ToDictionary(w => w.Term.ToString(), w => w.GetCodeStr());
  213. checkDataHelper.CheckData(dbdata, result.ToDictionary(w => w.Term.ToString(), w => w.GetCodeStr()),
  214. Config.Area, currentLottery);
  215. result = result.OrderByDescending(S => S.Term).ToList();
  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. /// 完善主站浙江体彩6+1开奖详情信息
  226. /// </summary>
  227. /// <param name="model"></param>
  228. private bool OptimizeMainModel(ref OpenCode7DTModel model, HtmlNode tr)
  229. {
  230. try
  231. {
  232. var tds = tr.ChildNodes.Where(w => w.Name == "td").ToList();
  233. var entity = new KaijiangDetailsEntity();
  234. entity.KaiJiangItems = new List<Kaijiangitem>();
  235. var xiaoshoue = tds[8].InnerText.Trim();
  236. var jiangchi = (double.Parse(tds[9].InnerText.Trim()) * 10000).ToString();
  237. var tedengjiangary = tds[2].InnerText.Trim().Split('注', '元');
  238. var tedengjiang = new Kaijiangitem
  239. {
  240. Name = "特等奖",
  241. Total = tedengjiangary[0].Replace(",", string.Empty),
  242. TotalMoney = tedengjiangary[1].Replace(",", string.Empty).Replace("\t", "")
  243. };
  244. entity.KaiJiangItems.Add(tedengjiang);
  245. var yidengjiangary = tds[3].InnerText.Trim().Split('注', '元');
  246. var yidengjiang = new Kaijiangitem
  247. {
  248. Name = "一等奖",
  249. Total = yidengjiangary[0].Replace(",", string.Empty),
  250. TotalMoney = yidengjiangary[1].Replace(",", string.Empty).Replace("\t", "")
  251. };
  252. entity.KaiJiangItems.Add(yidengjiang);
  253. var erdengjiangary = tds[4].InnerText.Trim().Split('注', '元');
  254. var erdengjiang = new Kaijiangitem
  255. {
  256. Name = "二等奖",
  257. Total = erdengjiangary[0].Replace(",", string.Empty),
  258. TotalMoney = erdengjiangary[1].Replace(",", string.Empty).Replace("t\\", "")
  259. };
  260. entity.KaiJiangItems.Add(erdengjiang);
  261. var sandengjiangary = tds[5].InnerText.Trim().Split('注', '元');
  262. var sandengjiang = new Kaijiangitem
  263. {
  264. Name = "三等奖",
  265. Total = sandengjiangary[0].Replace(",", string.Empty),
  266. TotalMoney = sandengjiangary[1].Replace(",", string.Empty).Replace("\t", "")
  267. };
  268. entity.KaiJiangItems.Add(sandengjiang);
  269. var sidengjiangary = tds[6].InnerText.Trim().Split('注', '元');
  270. var sidengjiang = new Kaijiangitem
  271. {
  272. Name = "四等奖",
  273. Total = sidengjiangary[0].Replace(",", string.Empty),
  274. TotalMoney = sidengjiangary[1].Replace(",", string.Empty).Replace("\t", "")
  275. };
  276. entity.KaiJiangItems.Add(sidengjiang);
  277. var wudengjiangary = tds[7].InnerText.Trim().Split('注', '元');
  278. var wudengjiang = new Kaijiangitem
  279. {
  280. Name = "五等奖",
  281. Total = wudengjiangary[0].Replace(",", string.Empty),
  282. TotalMoney = wudengjiangary[1].Replace(",", string.Empty).Replace("\t", "")
  283. };
  284. entity.KaiJiangItems.Add(wudengjiang);
  285. model.Spare = entity.TryToJson();
  286. }
  287. catch (Exception ex)
  288. {
  289. log.Error(GetType(),
  290. string.Format("【{0}】通过主站点优化开奖列表时发生错误,错误信息【{1}】", Config.Area + currentLottery, ex.Message));
  291. }
  292. return false;
  293. }
  294. /// <summary>
  295. /// 通过备用站点抓取开奖数据
  296. /// (彩票两元网)
  297. /// </summary>
  298. private void DoTodayJobByBackUrl()
  299. {
  300. if (!string.IsNullOrEmpty(Config.BackUrl))
  301. {
  302. var OpenList = GetOpenListFromBackUrl(Config.BackUrl);
  303. if (OpenList.Count == 0) return; //无抓取数据
  304. var newestQiHao = OpenList.Max(w => w.Term).ToString();
  305. var startQiNum = Convert.ToInt32(LatestItem.Term.ToString().Substring(2)) + 1;
  306. var newestQiNum = Convert.ToInt32(newestQiHao.Substring(2));
  307. if (startQiNum > newestQiNum) return; //无最新数据
  308. //处理最新开奖数据
  309. var getQiHao = string.Empty;
  310. OpenCode7DTModel matchItem = null;
  311. for (var i = startQiNum; i <= newestQiNum; i++)
  312. {
  313. getQiHao = LatestItem.Term.ToString().Substring(0, 2) + i.ToString().PadLeft(3, '0');
  314. matchItem = OpenList.Where(R => R.Term.ToString() == getQiHao).FirstOrDefault();
  315. if (matchItem != null && OptimizeBackModel(ref matchItem) &&
  316. services.AddDTOpen7Code(currentLottery, matchItem))
  317. {
  318. //Do Success Log
  319. log.Info(GetType(), CommonHelper.GetJobBackLogInfo(Config, getQiHao));
  320. LatestItem = matchItem;
  321. isGetData = true;
  322. }
  323. }
  324. }
  325. }
  326. /// <summary>
  327. /// 通过备用地址抓取错误期号列表中每一个期号
  328. /// (彩票两元网)
  329. /// </summary>
  330. private void DoYesterdayFailedListByBackUrl()
  331. {
  332. if (!string.IsNullOrEmpty(Config.BackUrl) && FailedQiHaoList.Count > 0)
  333. {
  334. var OpenList = GetOpenListFromBackUrl(Config.BackUrl);
  335. if (OpenList.Count == 0) return; //无抓取数据
  336. OpenCode7DTModel matchItem = null;
  337. var SuccessList = new List<string>();
  338. foreach (var failedQiHao in FailedQiHaoList)
  339. {
  340. matchItem = OpenList.Where(R => R.Term.ToString() == failedQiHao).FirstOrDefault();
  341. if (matchItem != null && OptimizeBackModel(ref matchItem) &&
  342. services.AddDTOpen7Code(currentLottery, matchItem))
  343. {
  344. //Do Success Log
  345. log.Info(GetType(), CommonHelper.GetJobBackLogInfo(Config, failedQiHao));
  346. if (matchItem.Term > LatestItem.Term) LatestItem = matchItem;
  347. SuccessList.Add(failedQiHao);
  348. isGetData = true;
  349. }
  350. }
  351. foreach (var successQiHao in SuccessList) FailedQiHaoList.Remove(successQiHao);
  352. }
  353. }
  354. /// <summary>
  355. /// 获取备用站点开奖列表数据
  356. /// </summary>
  357. /// <param name="backUrl">备用站点</param>
  358. /// <returns></returns>
  359. private List<OpenCode7DTModel> GetOpenListFromBackUrl(string backUrl)
  360. {
  361. var result = new List<OpenCode7DTModel>();
  362. try
  363. {
  364. var htmlResource = NetHelper.GetUrlResponse(backUrl);
  365. if (htmlResource == null) return result;
  366. var doc = new HtmlDocument();
  367. doc.LoadHtml(htmlResource);
  368. var table = doc.DocumentNode.SelectSingleNode("//table");
  369. if (table == null) return result;
  370. var trs = table.ChildNodes.Where(node => node.Name.ToLower() == "tr").ToList();
  371. OpenCode7DTModel model = null;
  372. var lastYear = (CommonHelper.SCCSysDateTime.Year - 1).ToString().Substring(2);
  373. for (var i = 0; i < trs.Count; i++) //第一行
  374. {
  375. var trstyle = trs[i].Attributes["style"];
  376. if (trstyle != null && trstyle.Value == "display:none") continue;
  377. var tds = trs[i].ChildNodes.Where(node => node.Name.ToLower() == "td").ToList();
  378. if (tds.Count < 11) continue;
  379. if (tds[0].InnerText.Trim().StartsWith(lastYear)) break;
  380. model = new OpenCode7DTModel();
  381. model.OpenTime = Convert.ToDateTime(tds[9].InnerText.Trim());
  382. model.Term = Convert.ToInt64(tds[0].InnerText.Trim());
  383. var opencodeNode = tds[1].ChildNodes.Where(n => n.Name.ToLower() == "i").ToList();
  384. if (opencodeNode.Count < 7) continue;
  385. model.OpenCode1 = Convert.ToInt32(opencodeNode[0].InnerText.Trim());
  386. model.OpenCode2 = Convert.ToInt32(opencodeNode[1].InnerText.Trim());
  387. model.OpenCode3 = Convert.ToInt32(opencodeNode[2].InnerText.Trim());
  388. model.OpenCode4 = Convert.ToInt32(opencodeNode[3].InnerText.Trim());
  389. model.OpenCode5 = Convert.ToInt32(opencodeNode[4].InnerText.Trim());
  390. model.OpenCode6 = Convert.ToInt32(opencodeNode[5].InnerText.Trim());
  391. model.OpenCode7 = Convert.ToInt32(opencodeNode[6].InnerText.Trim());
  392. model.DetailUrl = backUrl + model.Term + "/";
  393. OptimizeBackModel(ref model);
  394. result.Add(model);
  395. }
  396. var checkDataHelper = new CheckDataHelper();
  397. var dbdata = services.GetListS<OpenCode7DTModel>(currentLottery)
  398. .ToDictionary(w => w.Term.ToString(), w => w.GetCodeStr());
  399. checkDataHelper.CheckData(dbdata, result.ToDictionary(w => w.Term.ToString(), w => w.GetCodeStr()),
  400. Config.Area, currentLottery);
  401. result = result.OrderByDescending(S => S.Term).ToList();
  402. }
  403. catch (Exception ex)
  404. {
  405. log.Error(GetType(),
  406. string.Format("【{0}】通过备用站点抓取开奖列表时发生错误,错误信息【{1}】", Config.Area + currentLottery, ex.Message));
  407. }
  408. return result;
  409. }
  410. /// <summary>
  411. /// 完善备用站点浙江体彩6+1开奖实体信息
  412. /// </summary>
  413. /// <param name="model"></param>
  414. private bool OptimizeBackModel(ref OpenCode7DTModel model)
  415. {
  416. try
  417. {
  418. var entity = new KaijiangDetailsEntity();
  419. entity.KaiJiangItems = new List<Kaijiangitem>();
  420. var htmlResource = NetHelper.GetUrlResponse(model.DetailUrl);
  421. if (!string.IsNullOrEmpty(htmlResource))
  422. {
  423. var doc = new HtmlDocument();
  424. doc.LoadHtml(htmlResource);
  425. var tables = doc.DocumentNode.SelectNodes("//table");
  426. if (tables.Count < 1) return false;
  427. var trs = tables[0].ChildNodes.Where(N => N.Name.ToLower() == "tr").ToList();
  428. for (var i = 1; i < trs.Count; i++) //第一行为表头
  429. {
  430. var tds = trs[i].ChildNodes.Where(N => N.Name.ToLower() == "td").ToList();
  431. if (tds.Count < 4) continue;
  432. if (tds[1].InnerText == "特等奖")
  433. {
  434. var tmp = new Kaijiangitem
  435. {
  436. Name = "特等奖",
  437. Total = tds[2].InnerText.Replace("注", string.Empty).Replace(",", string.Empty).Trim(),
  438. TotalMoney =
  439. tds[3].InnerText.Replace("元", string.Empty).Trim() == "--"
  440. ? "0"
  441. : tds[3].InnerText.Replace("元", string.Empty).Trim()
  442. };
  443. entity.KaiJiangItems.Add(tmp);
  444. //Level1Num = Convert.ToInt32(tds[2].InnerText.Replace("注", string.Empty).Replace(",", string.Empty).Trim());
  445. // Level1Money = Convert.ToDecimal(tds[3].InnerText.Replace("元", string.Empty).Trim() == "--" ? "0" : tds[3].InnerText.Replace("元", string.Empty).Trim());
  446. }
  447. else if (tds[1].InnerText == "一等奖")
  448. {
  449. var tmp = new Kaijiangitem
  450. {
  451. Name = "一等奖",
  452. Total = tds[2].InnerText.Replace("注", string.Empty).Replace(",", string.Empty).Trim(),
  453. TotalMoney =
  454. tds[3].InnerText.Replace("元", string.Empty).Trim() == "--"
  455. ? "0"
  456. : tds[3].InnerText.Replace("元", string.Empty).Trim()
  457. };
  458. entity.KaiJiangItems.Add(tmp);
  459. }
  460. else if (tds[1].InnerText == "二等奖")
  461. {
  462. var tmp = new Kaijiangitem
  463. {
  464. Name = "二等奖",
  465. Total = tds[2].InnerText.Replace("注", string.Empty).Replace(",", string.Empty).Trim(),
  466. TotalMoney =
  467. tds[3].InnerText.Replace("元", string.Empty).Trim() == "--"
  468. ? "0"
  469. : tds[3].InnerText.Replace("元", string.Empty).Trim()
  470. };
  471. entity.KaiJiangItems.Add(tmp);
  472. }
  473. else if (tds[1].InnerText == "三等奖")
  474. {
  475. var tmp = new Kaijiangitem
  476. {
  477. Name = "三等奖",
  478. Total = tds[2].InnerText.Replace("注", string.Empty).Replace(",", string.Empty).Trim(),
  479. TotalMoney =
  480. tds[3].InnerText.Replace("元", string.Empty).Trim() == "--"
  481. ? "0"
  482. : tds[3].InnerText.Replace("元", string.Empty).Trim()
  483. };
  484. entity.KaiJiangItems.Add(tmp);
  485. }
  486. else if (tds[1].InnerText == "四等奖")
  487. {
  488. var tmp = new Kaijiangitem
  489. {
  490. Name = "四等奖",
  491. Total = tds[2].InnerText.Replace("注", string.Empty).Replace(",", string.Empty).Trim(),
  492. TotalMoney =
  493. tds[3].InnerText.Replace("元", string.Empty).Trim() == "--"
  494. ? "0"
  495. : tds[3].InnerText.Replace("元", string.Empty).Trim()
  496. };
  497. entity.KaiJiangItems.Add(tmp);
  498. }
  499. else if (tds[1].InnerText == "五等奖")
  500. {
  501. var tmp = new Kaijiangitem
  502. {
  503. Name = "五等奖",
  504. Total = tds[2].InnerText.Replace("注", string.Empty).Replace(",", string.Empty).Trim(),
  505. TotalMoney =
  506. tds[3].InnerText.Replace("元", string.Empty).Trim() == "--"
  507. ? "0"
  508. : tds[3].InnerText.Replace("元", string.Empty).Trim()
  509. };
  510. entity.KaiJiangItems.Add(tmp);
  511. }
  512. var reg1 = new Regex(@"投注总额:([\d,.]*?) 元");
  513. var match1 = reg1.Match(htmlResource);
  514. if (match1.Success)
  515. {
  516. var sales = match1.Result("$1");
  517. // Sales = Convert.ToDecimal(sales);
  518. entity.Trje = sales;
  519. }
  520. var reg2 = new Regex(@"奖池资金累计金额:([\d,.]*?) 元");
  521. var match2 = reg2.Match(htmlResource);
  522. if (match2.Success)
  523. {
  524. var jackpot = match2.Result("$1");
  525. //Jackpot = Convert.ToDecimal(jackpot);
  526. entity.Gdje = jackpot;
  527. }
  528. // string.Format("{0},{1}^特等奖|{2}|{3},一等奖|{4}|{5},二等奖|{6}|{7},三等奖|{8}|{9},四等奖|{10}|{11},五等奖|{12}|{13}",
  529. // Sales, Jackpot, Level1Num, Level1Money, Level2Num, Level2Money, Level3Num, Level3Money,
  530. // Level4Num, Level4Money, Level5Num, Level5Money, Level6Num, Level6Money);
  531. }
  532. model.Spare = entity.TryToJson();
  533. }
  534. return true;
  535. }
  536. catch (Exception ex)
  537. {
  538. log.Error(GetType(),
  539. string.Format("【{0}】通过主站点优化开奖列表时发生错误,错误信息【{1}】", Config.Area + currentLottery, ex.Message));
  540. }
  541. return false;
  542. }
  543. #region Attribute
  544. /// <summary>
  545. /// 配置信息
  546. /// </summary>
  547. private SCCConfig Config;
  548. /// <summary>
  549. /// 当天抓取的最新一期开奖记录
  550. /// </summary>
  551. private OpenCode7DTModel LatestItem;
  552. /// <summary>
  553. /// 当天抓取失败列表
  554. /// </summary>
  555. private List<string> FailedQiHaoList;
  556. /// <summary>
  557. /// 日志对象
  558. /// </summary>
  559. private readonly LogHelper log;
  560. /// <summary>
  561. /// 数据服务
  562. /// </summary>
  563. private readonly IDTOpenCode services;
  564. /// <summary>
  565. /// 当前彩种
  566. /// </summary>
  567. private SCCLottery currentLottery => SCCLottery.ZheJiang6J1;
  568. /// <summary>
  569. /// 邮件接口
  570. /// </summary>
  571. private readonly IEmail email;
  572. /// <summary>
  573. /// 是否本次运行抓取到开奖数据
  574. /// </summary>
  575. private bool isGetData;
  576. #endregion
  577. }
  578. }