XJ35X7Job.cs 27 KB

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