kjh.api.55128.cn_old/CP.Model/df/Hongkong6hc.cs

using CP.Common;
using MC.ORM;
using MySql.Data.MySqlClient;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace CP.Model
{
    [TableName("fchongkong"), PrimaryKey("id")]
    public class Hongkong6hc
    {
        #region 六合彩

        /// <summary>
        /// 开奖信息自动编号
        /// </summary>
        public int id { get; set; }
        /// <summary>
        /// 期数  
        /// </summary>
        public int qi { get; set; }
        /// <summary>
        /// 开奖号第1位
        /// </summary>
        public int n1 { get; set; }
        /// <summary>
        /// 开奖号第2位
        /// </summary>
        public int n2 { get; set; }
        /// <summary>
        /// 开奖号第3位
        /// </summary>
        public int n3 { get; set; }
        /// <summary>
        /// 开奖号第4位
        /// </summary>
        public int n4 { get; set; }
        /// <summary>
        /// 开奖号第5位
        /// </summary>
        public int n5 { get; set; }
        /// 开奖号第6位
        /// </summary>
        public int n6 { get; set; }
        /// <summary>
        /// 开奖号第7位 特码
        /// </summary>
        public int n7 { get; set; }
        
        /// <summary>
        /// 和值
        /// </summary>
        public int hz { get; set; }
        /// <summary>
        /// 跨度
        /// </summary>
        public int kd { get; set; }
        /// <summary>
        /// AC值 
        /// </summary>
        public int ac { get; set; }
        /// <summary>
        /// 星期 
        /// </summary>
        public int week { get; set; }
        /// <summary>
        /// 开奖日期
        /// </summary>
        public DateTime date { get; set; }
        /// <summary>
        /// 在列表中的排名..
        /// 用于遗漏计算.
        /// </summary>
        [Ignore]
        public int rank { get; set; }

        /// <summary>
        /// 一等奖注数
        /// </summary>
        public string zj1 { get; set; }

        /// <summary>
        /// 一等奖金额
        /// </summary>
        public string jo1 { get; set; }

        /// <summary>
        /// 二等奖注数
        /// </summary>
        public string zj2 { get; set; }

        /// <summary>
        /// 二等奖金额
        /// </summary>
        public string jo2 { get; set; }

        /// <summary>
        /// 三等奖注数
        /// </summary>
        public string zj3 { get; set; }

        /// <summary>
        /// 三等奖金额
        /// </summary>
        public string jo3 { get; set; }

        /// <summary>
        /// 添加开奖日期
        /// </summary>
        public DateTime addtime { get; set; }

        /// <summary>
        /// 投注金额
        /// </summary>
        public string tzmoney { get; set; }

        /// <summary>
        /// 奖池
        /// </summary>
        public string nextmoney { get; set; }

        /// <summary>
        ///是否复查 
        /// </summary>
        public int ischeck { get; set; }

        /// <summary>
        /// 号码
        /// </summary>
        public string opencode { get; set; }

        #endregion
    }

    #region 遗漏

    /// <summary>
    /// 双色球出号走势图上的遗漏模型
    /// </summary>
    public class Hongkong6hcChzsMissInfo
    {
        /// <summary>
        /// 名称
        /// </summary>
        public string name { get; set; }

        /// <summary>
        /// 遗漏
        /// </summary>
        public int[] yl{ get; set; }

    }

    /// <summary>
    /// 香港彩特码波色上的遗漏模型
    /// </summary>
    public class Hongkong6hcBszsMissInfo
    {
        /// <summary>
        /// 名称
        /// </summary>
        public string name { get; set; }

        /// <summary>
        /// 波色遗漏
        /// </summary>
        public int[] bsyl { get; set; }
        /// <summary>
        /// 半波遗漏
        /// </summary>
        public int[] bbyl { get; set; }

    }
    
    /// <summary>
    /// 香港彩特码单双上的遗漏模型
    /// </summary>
    public class Hongkong6hcDszsMissInfo
    {
        /// <summary>
        /// 名称
        /// </summary>
        public string name { get; set; }

        /// <summary>
        /// 遗漏
        /// </summary>
        public int[] tmdsyl { get; set; }
        public int[] ttdsyl { get; set; }
        public int[] hsdsyl { get; set; }

    }


    /// <summary>
    /// 特码头数走势上的遗漏模型
    /// </summary>
    public class Hongkong6hcTmtsMissInfo
    {
        /// <summary>
        /// 名称
        /// </summary>
        public string name { get; set; }

        /// <summary>
        /// 特头走势
        /// </summary>
        public int[] ttzs { get; set; }
        /// <summary>
        /// 特头单双
        /// </summary>
        public int[] ttds { get; set; }

    }

    /// <summary>
    /// 特码尾数走势上的遗漏模型
    /// </summary>
    public class Hongkong6hcTmwsMissInfo
    {
        /// <summary>
        /// 名称
        /// </summary>
        public string name { get; set; }

        /// <summary>
        /// 特尾走势
        /// </summary>
        public int[] twzs { get; set; }
        /// <summary>
        /// 尾数大小
        /// </summary>
        public int[] twdx { get; set; }

    }

    #endregion


    public class Hongkong6hcData : DataConnect
    {
        /// <summary>
        /// 数据列表..
        /// </summary>
        /// <returns></returns>
        public static List<Hongkong6hc> GetFchk6List()
        {
            List<Hongkong6hc> list = new List<Hongkong6hc>();

            string sql = string.Format("order by qi asc");
            DataConnect dc = new DataConnect();
            list = dc.db.Fetch<Hongkong6hc>(sql);
            if (list != null && list.Count > 0)
            {
                for (int i = 0; i < list.Count; i++)
                {
                    list[i].rank = i + 1;
                }
            }
            return list;

        }

        #region 开奖号抓取相关数据层方法

        private static readonly object _lock = new object();

        public static void Add(Hongkong6hc info)
        {
            if (info == null)
                return;
            if (info.qi <= 0)
                return;
            info.opencode = $"{info.n1:00},{info.n2:00},{info.n3:00},{info.n4:00},{info.n5:00},{info.n6:00}+{info.n7:00}";
            List<int> kjh = new List<int>() { info.n1, info.n2, info.n3, info.n4, info.n5, info.n6 };
            //和值
            info.hz = kjh.Sum();
            //跨度
            info.kd = kjh.Max() - kjh.Min();
            //星期
            info.week = Utils.GetIntWeek(info.date.DayOfWeek.ToString());
            //AC值
            string[] kjhstr = { info.n1.ToString(), info.n2.ToString(), info.n3.ToString(), info.n4.ToString(), info.n5.ToString(), info.n6.ToString() };
            info.ac = ToolUtils.GetAC(kjhstr);
            

            lock (_lock)
            {
                using (Database db = new Database(mysql, MySqlClientFactory.Instance))
                {
                    if (db.Exists<Hongkong6hc>($"where qi={info.qi}"))
                        return;
                    db.Insert(info);
                    try
                    {
                        //更新api
                        DoHttpHelp.UpdateWebApi(DFEnum.hk6.ToString());
                    }
                    catch (Exception) { }
                }
            }
        }

        public static void Update(Hongkong6hc model)
        {
            if (model == null)
                return;
            using (Database db = new Database(mysql, MySqlClientFactory.Instance))
            {
                var entity = db.SingleOrDefault<Hongkong6hc>(model.id);
                entity.ac = model.ac;
                entity.week = model.week;
                entity.kd = model.kd;
                entity.hz = model.hz;
                db.Update(entity);
            }
        }

        public static Hongkong6hc GetLastOne()
        {
            using (Database db = new Database(mysql, MySqlClientFactory.Instance))
            {
                var entity = db.SingleOrDefault<Hongkong6hc>($"order by qi desc limit 1");
                return entity;
            }
        }

        #endregion

        /// <summary>
        /// 获取开奖列表
        /// </summary>
        /// <param name="n">条数</param>
        /// <param name="type">默认0只有开奖号数据 1 带有开机号 2 带有试机号</param>
        /// <returns></returns>
        public static List<Hongkong6hc> GetList(int n = 30, bool isall = false)
        {
            string sql = $"where n1 > -1 order by qi desc limit {n}";
            if (isall)
            {
                sql = $"where n1 > -1 order by qi desc";
            }
            using (Database db = new Database(mysql, MySqlClientFactory.Instance))
            {
                return db.Fetch<Hongkong6hc>(sql);
            }
        }
        /// <summary>
        /// 返回指定期数的完整开奖信息
        /// </summary>
        /// <param name="qi"></param>
        /// <returns></returns>
        public static Hongkong6hc GetByQi(int qi)
        {
            string sql = string.Empty;
            if (qi == 0)
                sql = string.Format("order by qi desc limit 1");
            else
                sql = string.Format("where qi={0} limit 1", qi);
            DataConnect dc = new DataConnect();
            Hongkong6hc info = dc.db.SingleOrDefault<Hongkong6hc>(sql);

            return info;
        }
    }
}