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

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

namespace CP.Model
{
    #region 遗漏模型

    /// <summary>
    /// 黑龙江6+1号码走势图遗漏模型
    /// </summary>
    public class Tchlj61DwHmMissInfo
    {
        /// <summary>
        /// 名称
        /// </summary>
        public string name { get; set; }

        /// <summary>
        /// 百/十个位号码
        /// </summary>
        public int[] hm { get; set; }

        /// <summary>
        /// 重号
        /// </summary>
        public int[] ch { get; set; }

        /// <summary>
        /// 冷热
        /// </summary>
        public int[] lr { get; set; }

        /// <summary>
        /// 大小
        /// </summary>
        public int[] dx { get; set; }

        /// <summary>
        /// 奇偶
        /// </summary>
        public int[] jo { get; set; }

        /// <summary>
        /// 质合
        /// </summary>
        public int[] zh { get; set; }

        /// <summary>
        /// 012路
        /// </summary>
        public int[] _012 { get; set; }

        /// <summary>
        /// 振幅
        /// </summary>
        public int[] zf { get; set; }

    }

    /// <summary>
    /// 黑龙江6+1跨度走势图遗漏模型
    /// </summary>
    public class Tchlj61KdMissInfo
    {

        public string name { get; set; }

        public int[] kd { get; set; }

        public int[] dx { get; set; }

        public int[] jo { get; set; }

        public int[] zh { get; set; }

        public int[] _012 { get; set; }

        public int[] zf { get; set; }

    }

    /// <summary>
    /// 黑龙江6+1号码分析遗漏模型
    /// </summary>
    public class Tchlj61HmfxMissInfo
    {
        /// <summary>
        /// 名称
        /// </summary>
        public string name { get; set; }

        public int[] fb { get; set; }

        /// <summary>
        /// 和值奇偶
        /// </summary>
        public int[] hzjo { get; set; }

        /// <summary>
        /// 和尾奇偶
        /// </summary>
        public int[] hwdx { get; set; }

        public int[] hwjo { get; set; }

        public int[] hwzh { get; set; }

        /// <summary>
        /// 跨度
        /// </summary>
        public int[] kd { get; set; }

        /// <summary>
        /// 跨度大小
        /// </summary>
        public int[] kddx { get; set; }

        public int[] kdjo { get; set; }

        public int[] kdzh { get; set; }
    }

    /// <summary>
    /// 黑龙江6+1和值遗漏模型
    /// </summary>
    public class Tchlj61HzMissInfo
    {
        public string name { get; set; }

        public int[] hz { get; set; }

        public int[] hw { get; set; }

        public int[] jo { get; set; }

        public int[] dx { get; set; }

        public int[] zh { get; set; }

        public int[] _012 { get; set; }

        /// <summary>
        /// 和值奇偶
        /// </summary>
        public int[] hzjo { get; set; }

        /// <summary>
        /// 和值大小
        /// </summary>
        public int[] hzdx { get; set; }

        /// <summary>
        /// 和值质合
        /// </summary>
        public int[] hzzh { get; set; }

        /// <summary>
        /// 和值012路
        /// </summary>
        public int[] hz012 { get; set; }

    }

    /// <summary>
    /// 黑龙江6+1号码遗漏模型
    /// </summary>
    public class Tchlj61NumMissInfo
    {
        /// <summary>
        /// 名称
        /// </summary>
        public string name { get; set; }

        /// <summary>
        /// 1~7位号码遗漏.
        /// </summary>
        public int[] s1 { get; set; }
        public int[] s2 { get; set; }
        public int[] s3 { get; set; }
        public int[] s4 { get; set; }
        public int[] s5 { get; set; }
        public int[] s6 { get; set; }
        public int[] s7 { get; set; }
    }

    #endregion

    #region 体彩黑龙江6+1基本模型
    /// <summary>
    /// 黑龙江6+1模型
    /// </summary>
    [TableName("tchlj61"), PrimaryKey("id")]
    public class Tchlj61Info
    {
        /// <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; }

        /// <summary>
        /// 开奖号第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>
        /// 星期
        /// </summary>
        public int week { get; set; }

        /// <summary>
        /// 开奖日期
        /// </summary>
        public DateTime date { get; set; }

        /// <summary>
        /// 在列表中的排名..
        /// 用于遗漏计算.
        /// </summary>
        [Ignore]
        public int rank { get; set; }

    }
    #endregion

    #region 体彩黑龙江6+1开奖完整模型
    /// <summary>
    /// 体彩黑龙江6+1开奖完整模型
    /// </summary>
    [TableName("tchlj61"), PrimaryKey("id")]
    public class Tchlj61LongInfo : Tchlj61Info
    {
        /// <summary>
        /// 自动编号ID
        /// </summary>
        public int id { get; set; }

        /// <summary>
        /// 特等奖注数
        /// </summary>
        public string zj { get; set; }

        /// <summary>
        /// 特等奖金额
        /// </summary>
        public string jo { 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 string zj4 { get; set; }

        /// <summary>
        /// 四等奖金额
        /// </summary>
        public string jo4 { get; set; }

        /// <summary>
        /// 五等奖注数
        /// </summary>
        public string zj5 { get; set; }

        /// <summary>
        /// 五等奖金额
        /// </summary>
        public string jo5 { get; set; }

        /// <summary>
        /// 开奖详情json
        /// </summary>
        public string winbonus { set; get; }

        /// <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; }

        /// <summary>
        /// 第1步(开奖号）状态  -1：未添加    2：完成   3：复查完成
        /// </summary>
        public int step1state { set; get; }

        /// <summary>
        /// 第2步(开奖详情）状态  -1：未添加  1：完成一半  2：完成   3：复查完成
        /// </summary>
        public int step2state { set; get; }

        [Ignore]
        public string isComplete
        {
            get
            {
                if (step2state == 3)
                    return "<span style='color:green;'>是</span>";
                return "<span style='color:red;'>否</span>";
            }
        }
    }


    #endregion

    

    /// <summary>
    /// 体彩黑龙江6+1数据库操作类
    /// </summary>
    public class Tchlj61Data : DataConnect
    {

        /// <summary>
        /// 所有黑龙江61的开奖数据
        /// </summary>
        /// <returns></returns>
        public static List<Tchlj61Info> GetTchlj61List()
        {
            List<Tchlj61Info> list = new List<Tchlj61Info>();
            string sql = string.Format("order by qi asc");
            DataConnect dc = new DataConnect();
            list = dc.db.Fetch<Tchlj61Info>(sql);
            if (list != null && list.Count > 0)
            {
                for (int i = 0; i < list.Count; i++)
                {
                    list[i].rank = i + 1;
                }
            }
            return list;
        }

        #region 开奖公告相关方法
        /// <summary>
        /// 获取开奖列表
        /// </summary>
        /// <param name="n">条数</param>
        /// <param name="type">默认0只有开奖号数据 1 带有开机号 2 带有试机号</param>
        /// <returns></returns>
        public static List<Tchlj61LongInfo> 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<Tchlj61LongInfo>(sql);
            }
        }
        /// <summary>
        /// 获取最新开奖信息
        /// </summary>
        /// <returns></returns>
        public static Tchlj61LongInfo GetTchlj61NewInfo()
        {
            string sql = string.Format("where n1>-1 order by qi desc limit 1 ");
            DataConnect dc = new DataConnect();
            return dc.db.SingleOrDefault<Tchlj61LongInfo>(sql);
        }
        /// <summary>
        /// 获取最新30条开奖信息
        /// </summary>
        /// <returns></returns>
        public static List<Tchlj61LongInfo> GetTchlj61Top30(int n = 30)
        {
            string sql = string.Format($"order by qi desc limit {n}");
            DataConnect dc = new DataConnect();
            return dc.db.Fetch<Tchlj61LongInfo>(sql);
        }


        #region 根据期数获取某期开奖信息
        /// <summary>
        /// 根据期数获取某期开奖信息
        /// </summary>
        /// <param name="qi"></param>
        /// <returns></returns>
        public static Tchlj61LongInfo GetTchlj61InfoByQi(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();
            Tchlj61LongInfo info = dc.db.SingleOrDefault<Tchlj61LongInfo>(sql);

            return info;
        }
        #endregion

        #region 根据年份取出当年所有期数
        /// <summary>
        /// 根据年份取出当年所有期数
        /// </summary>
        /// <param name="year"></param>
        /// <returns></returns>
        public static List<int> GetTchlj61QiListByYear(int year)
        {
            List<int> rlist = new List<int>();
            string sql = string.Format("where qi like '{0}%' order by qi desc", year);
            DataConnect dc = new DataConnect();
            var list = dc.db.Fetch<Tchlj61Info>(sql);
            if (list != null && list.Count > 0)
            {
                for (int i = 0; i < list.Count; i++)
                {
                    rlist.Add(list[i].qi);
                }
            }
            return rlist;
        }

        #endregion

        #endregion

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

        private static readonly object _lock = new object();

        public static void Add(Tchlj61LongInfo info)
        {
            if (info == null)
                return;
            if (info.qi <= 0)
                return;
            info.opencode = $"{info.n1},{info.n2},{info.n3},{info.n4},{info.n5},{info.n6}+{info.n7}";
            //和值
            info.hz = info.n1 + info.n2 + info.n3 + info.n4 + info.n5 + info.n6;
            //跨度
            List<int> list = new List<int>();
            list.Add(info.n1);
            list.Add(info.n2);
            list.Add(info.n3);
            list.Add(info.n4);
            list.Add(info.n5);
            list.Add(info.n6);
            list.Sort();
            info.kd = Math.Abs(list[5] - list[0]);
            //星期
            info.week = Utils.GetIntWeek(info.date.DayOfWeek.ToString());

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

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

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

        #endregion

    }

}