SCC/SCC.Crawler/AutoCheckJob/AutoCheckKJSSQJob.cs

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
{
    public class AutoCheckKJSSQJob : IJob
    {
        public AutoCheckKJSSQJob()
        {
            log = new LogHelper();
            services = IOC.Resolve<IDTOpenCode>();
            email = IOC.Resolve<IEmail>();
        }

        public void Execute(IJobExecutionContext context)
        {
            Config = CommonHelper.GetConfigFromDataMap(context.JobDetail.JobDataMap);
            //CheckGetKaiJiHao();
            //每天检测
            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);
            }
        }




        /// <summary>
        ///     获取开奖详情
        /// </summary>
        /// <param name="qishu"></param>
        /// <returns></returns>
        private string GetKaijiangDetails(string qishu)
        {
            var url = "https://www.8200.cn/kjh/ssq/" + qishu + ".htm";
            var htmlResource = NetHelper.GetUrlResponse(url, Encoding.GetEncoding("utf-8"));
            if (htmlResource == null) return null;
            if (!string.IsNullOrEmpty(htmlResource))
            {
                var doc = new HtmlDocument();
                doc.LoadHtml(htmlResource);

                var div = doc.DocumentNode.SelectSingleNode("//div[@class='text-16']");
                if (div == null) return null;
                //爬去奖金
                var jiangjin = div.ChildNodes.Where(node => node.Name == "p").ToList();
                var kaijianghao = jiangjin[0].InnerText.Remove(0, 8).Remove(22);
                //爬去奖项
                //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 = jiangjin[3].InnerText.Replace(" 亿元", "").Replace("奖池滚存：", "").Replace("--", "0")
                    .Replace(",", "").Trim();
                var trje = jiangjin[2].InnerText.Replace(" 亿元", "").Replace("本期销量：", "").Replace("--", "0")
                    .Replace(",", "").Trim();

                var entity = new KaijiangDetailsEntity
                {
                    Gdje = gdje == "0" ? "0" : (double.Parse(gdje) * 100000000).ToString(),
                    Trje = trje == "0" ? "0" : (double.Parse(trje) * 100000000).ToString()
                };

                //组装详情  
                var list = new List<Kaijiangitem>();
                for (var i = 0; i < trs.Count; i++)
                {
                    var tds = trs[i].ChildNodes.Where(node => node.Name == "td").ToList();

                    var kaijiangitem = new Kaijiangitem();

                    var TotalMoney = tds[1].InnerText.Replace("元", "").Replace("--", "0").Replace(",", "").Trim();
                    kaijiangitem.Name = tds[0].InnerText.Trim();
                    kaijiangitem.TotalMoney = TotalMoney == "0" ? "0" : double.Parse(TotalMoney).ToString();
                    kaijiangitem.Total = tds[2].InnerText.Trim().Replace(" 注", "");
                    list.Add(kaijiangitem);
                }

                entity.KaiJiangItems = list;

                return entity.TryToJson();
            }

            return "";
        }

        //#region  更新双色球开机号数据
        //private List<KaiJiangHao> GetKaiJiHao()
        //{
        //    var result = new List<KaiJiangHao>();
        //    var url = "https://www.8200.cn/kjh/ssq/kjih.htm?size=300";
        //    var htmlResource = NetHelper.GetUrlResponse(url, Encoding.GetEncoding("utf-8"));
        //    if (htmlResource == null) return null;
        //    if (!string.IsNullOrEmpty(htmlResource))
        //    {
        //        var doc = new HtmlDocument();
        //        doc.LoadHtml(htmlResource);

        //        var table = doc.DocumentNode.SelectSingleNode("//table");
        //        if (table == null) return result;
        //        var trs = table.ChildNodes.Where(node => node.Name == "tr").ToList();
        //        KaiJiangHao model = null;
        //        for (var i = 0; i < trs.Count; i++)
        //        {
        //            var tds = trs[i].ChildNodes.Where(S => S.Name.ToLower() == "td").ToList();
        //            model = new KaiJiangHao();
        //            model.QiHao = Convert.ToInt32(tds[0].InnerText.Trim());
        //            if (tds[2].InnerText.Trim() == "--")
        //            {
        //                model.Kaijianghao = null;
        //            }
        //            else
        //            {
        //                string source = tds[2].InnerText.Replace(" + ", ",").Replace(" ", ",").Replace(",,", ",").Trim();
        //                source = source.IndexOf(",") >= 0 ? source.Substring(1, source.Length - 1) : source;
        //                model.Kaijianghao = source;
        //            }
        //            result.Add(model);
        //        }
        //    }
        //    return result;
        //}
        //private void CheckGetKaiJiHao()
        //{
        //    try
        //    {
        //        var kaiJiHao = GetKaiJiHao();
        //        var newestQiHao = kaiJiHao.Count();

        //        List<KaiJiangHao> kai = GetKaiJiHao();
        //        foreach (var item in kai)
        //        {
        //            var isSucc = services.UpdateSSQDetailByTerm(currentLottery, item.QiHao, item.Kaijianghao);
        //            if (isSucc)
        //            {
        //                Trace.WriteLine($"更新{Config.LotteryName}第{ item.QiHao}期开奖详情成功！");

        //                log.Info(GetType(), $"更新{Config.LotteryName}第{ item.QiHao}期开奖详情成功！");
        //            }
        //            else
        //            {
        //                Trace.WriteLine($"更新{Config.LotteryName}第{ item.QiHao}期开奖详情失败！");

        //                log.Error(GetType(), $"更新{Config.LotteryName}第{ item.QiHao}期开奖详情失败！");
        //            }
        //        }


        //    }
        //    catch (Exception e)
        //    {
        //        log.Error(GetType(), e);
        //    }
        //}

        ////<span class="text-red">11 15 20 21 26 33</span> + <span class="text-blue">15</span>
        ////<b class="text-16"> 08  14  17  22  23  29  + 02</b>
        ////<b class="text-16"><i class="bg-nude font-style-normal">01</i>  05  14 <i class="bg-nude font-style-normal">22</i>  26  29  + 13</b>
        //#endregion

        #region Attribute

        /// <summary>
        ///     配置信息
        /// </summary>
        private SCCConfig Config;

        /// <summary>
        ///     当天抓取的最新一期开奖记录
        /// </summary>
        private OpenCode7DTModel LatestItem = null;

        /// <summary>
        ///     当天抓取失败列表
        /// </summary>
        private List<string> FailedQiHaoList = null;

        /// <summary>
        ///     日志对象
        /// </summary>
        private readonly LogHelper log;

        /// <summary>
        ///     数据服务
        /// </summary>
        private readonly IDTOpenCode services;

        /// <summary>
        ///     当前彩种
        /// </summary>
        private SCCLottery currentLottery => SCCLottery.SSQ;

        /// <summary>
        ///     邮件接口
        /// </summary>
        private IEmail email;

        /// <summary>
        ///     是否本次运行抓取到开奖数据
        /// </summary>
        private bool isGetData = false;

        #endregion
    }
}