using System; using System.Collections.Generic; using System.Diagnostics; using System.Linq; using System.Text; using HtmlAgilityPack; using Quartz; using SCC.Common; using SCC.Interface; using SCC.Models; namespace SCC.Crawler.AutoCheckJob.AutoCheckDFJob { public class AutoCheckZJ20X5Job : IJob { public AutoCheckZJ20X5Job() { log = new LogHelper(); services = IOC.Resolve(); email = IOC.Resolve(); } public void Execute(IJobExecutionContext context) { Config = CommonHelper.GetConfigFromDataMap(context.JobDetail.JobDataMap); //每天检测 Check(); } private void Check() { try { var dict = services.GetLast1NTerm(currentLottery, 10); if (dict.Count > 0) foreach (var dic in dict) { var key = dic.Key; var Spare = dic.Value; var res = GetKaijiangDetails(key.ToString()); if (!string.IsNullOrEmpty(res) && !res.Equals(Spare)) { //TODO 更新数据库 var isSucc = services.UpdateKJDetailByTerm(currentLottery, key, res); if (isSucc) { Trace.WriteLine($"更新{Config.LotteryName}第{key}期开奖详情成功!"); log.Info(GetType(), $"更新{Config.LotteryName}第{key}期开奖详情成功!"); } else { Trace.WriteLine($"更新{Config.LotteryName}第{key}期开奖详情失败!"); log.Error(GetType(), $"更新{Config.LotteryName}第{key}期开奖详情失败!"); } } else { Trace.WriteLine($"未更新{Config.LotteryName}第{key}期开奖详情!原因:内容相同。"); } } } catch (Exception e) { log.Error(GetType(), e); } } /// /// 获取开奖详情 /// /// /// private string GetKaijiangDetails(string qishu) { //https://www.cp2y.com/20x5/20x5kj/18017/ var url = "https://www.cp2y.com/20x5/20x5kj/" + qishu + "/"; var htmlResource = NetHelper.GetUrlResponse(url, Encoding.GetEncoding("utf-8")); if (htmlResource == null) return null; var doc = new HtmlDocument(); doc.LoadHtml(htmlResource); var div = doc.DocumentNode.SelectSingleNode("//div[@class='fl lh24 f14']"); if (div == null) return null; var div2 = div.ChildNodes.Where(node => node.Name == "div").ToList(); //爬去奖金 var trjeg = div2[1].ChildNodes.Where(node => node.Name == "span").ToList(); var gdjeg = div2[2].ChildNodes.Where(node => node.Name == "span").ToList(); //爬去奖项 //var tbody = div.ChildNodes.Where(node => node.Name == "tbody").ToList(); var table = doc.DocumentNode.SelectSingleNode("//table"); var trs = table.ChildNodes.Where(node => node.Name == "tr").ToList(); var gdje = gdjeg[1].InnerText.Replace("奖池资金累计金额:", "").Replace(" 元", "").Replace("--", "0").Replace(",", "") .Trim(); var trje = trjeg[1].InnerText.Replace("本期体彩20选5投注总额:", "").Replace(" 元", "").Replace("--", "0") .Replace(",", "").Trim(); var entity = new KaijiangDetailsEntity { Gdje = gdje == "0" ? "0" : (double.Parse(gdje) * 1).ToString(), Trje = trje == "0" ? "0" : (double.Parse(trje) * 1).ToString() }; //TODO //组装详情 var list = new List(); for (var i = 1; i < trs.Count; i++) { var tds = trs[i].ChildNodes.Where(node => node.Name == "td").ToList(); var kaijiangitem = new Kaijiangitem(); var TotalMoney = tds[3].InnerText.Replace("元", "").Replace("--", "0").Replace(",", "").Trim(); kaijiangitem.Name = tds[1].InnerText.Trim(); kaijiangitem.TotalMoney = TotalMoney == "0" ? "0" : double.Parse(TotalMoney).ToString(); kaijiangitem.Total = tds[2].InnerText.Replace(" 注", "").Replace("--", "0").Trim(); list.Add(kaijiangitem); } entity.KaiJiangItems = list; return entity.TryToJson(); } #region Attribute /// /// 配置信息 /// private SCCConfig Config; /// /// 当天抓取的最新一期开奖记录 /// private OpenCode7DTModel LatestItem = null; /// /// 当天抓取失败列表 /// private List FailedQiHaoList = null; /// /// 日志对象 /// private readonly LogHelper log; /// /// 数据服务 /// private readonly IDTOpenCode services; /// /// 当前彩种 /// private SCCLottery currentLottery => SCCLottery.ZheJiang20x5; /// /// 邮件接口 /// private IEmail email; /// /// 是否本次运行抓取到开奖数据 /// private bool isGetData = false; #endregion } }