123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177 |
- 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 AutoCheckKJQXCJob : IJob
- {
- public AutoCheckKJQXCJob()
- {
- log = new LogHelper();
- services = IOC.Resolve<IDTOpenCode>();
- email = IOC.Resolve<IEmail>();
- }
- 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))
- {
-
- 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)
- {
- var url = "https://www.8200.cn/kjh/qxc/" + qishu + ".htm";
- 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='text-16']");
- if (div == null) return null;
-
- var jiangjin = div.ChildNodes.Where(node => node.Name == "p").ToList();
-
-
- var table = doc.DocumentNode.SelectSingleNode("//table");
- var trs = table.ChildNodes.Where(node => node.Name == "tr").ToList();
- var gdje = jiangjin[2].InnerText.Replace(" 万元", "").Replace("奖池滚存:", "").Replace("--", "0").Replace(",", "")
- .Trim();
- var trje = jiangjin[1].InnerText.Replace(" 万元", "").Replace("本期销量:", "").Replace("--", "0").Replace(",", "")
- .Trim();
- var entity = new KaijiangDetailsEntity
- {
- Gdje = gdje == "0" ? "0" : (double.Parse(gdje) * 10000).ToString(),
- Trje = trje == "0" ? "0" : (double.Parse(trje) * 10000).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(" 注", "").Replace("--", "0").Trim();
- list.Add(kaijiangitem);
- }
- entity.KaiJiangItems = list;
- return entity.TryToJson();
- }
- #region Attribute
-
-
-
- private SCCConfig Config;
-
-
-
- private OpenCode7DTModel LatestItem = null;
-
-
-
- private List<string> FailedQiHaoList = null;
-
-
-
- private readonly LogHelper log;
-
-
-
- private readonly IDTOpenCode services;
-
-
-
- private SCCLottery currentLottery => SCCLottery.QXC;
-
-
-
- private IEmail email;
-
-
-
- private bool isGetData = false;
- #endregion
- }
- }
|