dengch 6 yıl önce
ebeveyn
işleme
7352f53b30
2 değiştirilmiş dosya ile 30 ekleme ve 1 silme
  1. 2 1
      SCC.Crawler/DT/FJ36X7Job.cs
  2. 28 0
      SCC.Crawler/GP/HUB11X5Job.cs

+ 2 - 1
SCC.Crawler/DT/FJ36X7Job.cs

@@ -75,7 +75,8 @@ namespace SCC.Crawler.DT
                 //当今日开奖并且当前时间是晚上8点过后开始抓取
                 if (CommonHelper.CheckTodayIsOpenDay(Config) && CommonHelper.SCCSysDateTime.Hour > 12)
                 {
-                   // DoTodayJobByDB();
+
+                    DoTodayJobByDB();
                     //DoTodayJobByMainUrl();
                     //DoTodayJobByBackUrl();
                 }

+ 28 - 0
SCC.Crawler/GP/HUB11X5Job.cs

@@ -61,6 +61,7 @@ namespace SCC.Crawler.GP
                 //当最新期号不符合当天总期数,执行当天作业
                 if (Convert.ToInt32(LatestQiHao.Substring(6)) != Config.TimesPerDay)
                 {
+                    DoTodayJobByDB();
                     DoTodayJobByMainUrl();
                     DoTodayJobByBackUrl();
                 }
@@ -73,6 +74,33 @@ namespace SCC.Crawler.GP
             context.JobDetail.JobDataMap["LatestQiHao"] = LatestQiHao;
         }
 
+        /// <summary>
+        /// 通过数据库获取开奖数据
+        /// </summary>
+        private void DoTodayJobByDB()
+        {
+
+            var OpenList = services.GetYesterdayFailQQListDB5_toDay(currentLottery, Config.TimesPerDay);
+            if (OpenList.Count == 0) return;//无抓取数据
+            var newestQiHao = OpenList.OrderBy(a => a.Key).Last().Key;
+            var startQiNum = Convert.ToInt32(LatestQiHao.Substring(6)) + 1;
+            var newestQiNum = Convert.ToInt32(newestQiHao.Substring(6));
+            if (startQiNum > newestQiNum) return;//无最新数据
+                                                 //处理最新开奖数据
+            string getQiHao = string.Empty;
+            for (var i = startQiNum; i <= newestQiNum; i++)
+            {
+                getQiHao = CommonHelper.GenerateTodayQiHaoYYMMDDQQQ(i);
+                var matchItem = OpenList.Where(R => R.Key == getQiHao).FirstOrDefault();
+                if (matchItem.Key != null && SaveRecord(getQiHao, matchItem.Value, false))
+                {
+                    //处理成功写入日志
+                    log.Info(typeof(ZJ11X5Job), CommonHelper.GetJobMainLogInfo(Config, getQiHao));
+                    LatestQiHao = getQiHao;
+                }
+            }
+        }
+
         /// <summary>
         /// 自检昨天开奖数据
         /// </summary>