55128.cn_kjh.55128.cn_m.55128.cn/CP55128/CB.LotteryCatchData.Opencai/K3_AnHui.cs

using System;
using System.Collections.Generic;
using System.Xml;

using CB.Common;
using CB.Entity;
using CB.Entity.Frequency;
using CB.Interface.Infrastructure.Frequency;
using CB.LotteryCatchData.Entity;
using CB.LotteryCatchData.Interface;

namespace CB.LotteryCatchData.Opencai
{
    /// <summary>
    /// 湖南幸运赛车数据抓取实现
    /// </summary>
    public class K3_AnHui : CatchRepository, ICatchDataProvider
    {
        public override LotteryParamKeys GetLotteryParamKeys(string fileName)
        {
            return GetLotteryParamKeysDefault(fileName);
        }

        public override LotteryOpenCode GetLatestOpenCode()
        {
            return CB.Data.Frequency.K3AnHuiService.GetLatestOpenCodeForCatch();
        }

        public override IList<LotteryOpenCode> CatchData(LotteryConfigInfo config, LotteryParamKeys keys)
        {
            if (!this.IsCatchData(config, keys))
                return null;

            XmlDocument doc = new XmlDocument();
            try
            {
                doc.Load(config.DataUrl);
                var nodeList = doc.SelectNodes("xml/row");
                if (null == nodeList || 0 >= nodeList.Count)
                    return null;

                IList<LotteryOpenCode> list = new List<LotteryOpenCode>();
                LotteryOpenCode entity = null;
                string qi = "";
                string[] data;
                foreach (XmlNode node in nodeList)
                {
                    qi = node.Attributes["expect"].Value.Trim();
                    if (0 <= keys.LocalTerm.CompareTo(qi))
                        continue;
                    data = node.Attributes["opencode"].Value.Trim().Split(',');
                    entity = new LotteryOpenCode()
                    {
                        Term = long.Parse(qi)
                    };
                    entity.OpenCode = new List<int>();
                    entity.OpenCode.Add(TypeConverter.StrToInt(data[0]));
                    entity.OpenCode.Add(TypeConverter.StrToInt(data[1]));
                    entity.OpenCode.Add(TypeConverter.StrToInt(data[2]));
                    entity.Addtime = DateTime.Now;
                    entity.OpenTime = GetRealOpenTime(config.StartTime, config.OpenPeriod, qi, TypeConverter.StrToDateTime(node.Attributes["opentime"].Value.Trim(), entity.Addtime), 8, 3);

                    list.Add(entity);
                }
                return list;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        public override int SaveData(IList<LotteryOpenCode> list, ref LotteryParamKeys keys)
        {
            if (null == list || 0 >= list.Count)
                return -1;
            int n = 0;
            long term = Convert.ToInt64(keys.LocalTerm);
            DateTime t = keys.LastOpenTime;
            K3Info_AnHui entity = null;
            foreach (var item in list)
            {
                entity = new K3Info_AnHui()
                {
                    Term = item.Term,
                    OpenCode1 = item.OpenCode[0],
                    OpenCode2 = item.OpenCode[1],
                    OpenCode3 = item.OpenCode[2],
                    OpenTime = item.OpenTime,
                    Addtime = item.Addtime
                };
                if (CB.Data.Frequency.K3AnHuiService.Save(entity))
                {
                    n++;
                    if (term < item.Term)
                        term = item.Term;
                    if (t < item.OpenTime)
                        t = item.OpenTime;
                }
            }
            if (0 < n)
            {
                keys.IsCatch = 1;
                keys.LocalTerm = term.ToString();
                keys.LastOpenTime = t;
            }
            return n;
        }
    }
}