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

namespace CP.Model
{
    #region model
    /// <summary>
    /// 体彩山东快乐扑克3
    /// </summary>
    [TableName("tcsdklpk3"), PrimaryKey("id")]
    public class Tcsdklpk3Info
    {
        /// <summary>
        /// 自动编号
        /// </summary>
        public int id { get; set; }

        /// <summary>
        /// 期号
        /// </summary>
        public int qi { get; set; }

        /// <summary>
        /// 号码一
        /// </summary>
        public int n1 { get; set; }

        /// <summary>
        /// 号码二
        /// </summary>
        public int n2 { get; set; }

        /// <summary>
        /// 号码三
        /// </summary>
        public int n3 { get; set; }

        /// <summary>
        /// 花色1 1为方片，2为红心，3为梅花，4为黑桃
        /// </summary>
        public int hs1 { get; set; }

        /// <summary>
        /// 花色2 1为方片，2为红心，3为梅花，4为黑桃
        /// </summary>
        public int hs2 { get; set; }

        /// <summary>
        /// 花色3 1为方片，2为红心，3为梅花，4为黑桃
        /// </summary>
        public int hs3 { get; set; }
        
        /// <summary>
        /// 开奖号字串
        /// 01,02,03,04,05
        /// </summary>
        public string opencode { get; set; }

        /// <summary>
        /// 和值
        /// </summary>
        public int hz { get; set; }

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

        /// <summary>
        /// 开奖时间
        /// </summary>
        public DateTime date { get; set; }

        /// <summary>
        /// 数据入库时间
        /// </summary>
        public DateTime addtime { get; set; }

        /// <summary>
        /// 是否有错误标记   0：无   1：有
        /// </summary>
        public int iserror { set; get; }

        /// <summary>
        /// 是否有异常  0：无异常   1：有异常   2：人工已处理无异常
        /// </summary>
        public int isexception { set; get; }

        /// <summary>
        /// 来源   0：mongo   1：后台手工
        /// </summary>
        public int origin { set; get; }

        [Ignore]
        public int rank { get; set; }
    }
    #endregion

    #region 遗漏模型

    /// <summary>
    /// 基本走势图上的遗漏模型
    /// </summary>
    public class Tcsdklpk3JbzsMissInfo
    {
        public string name { get; set; }

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

        /// <summary>
        /// 号码形态
        /// </summary>
        public int[] hmxt { set; get; }
    }

    /// <summary>
    /// 出号走势图上的遗漏模型
    /// </summary>
    public class Tcsdklpk3ChzsMissInfo
    {
        public string name { get; set; }

        /// <summary>
        /// 第一位
        /// </summary>
        public int[] hm1 { get; set; }

        /// <summary>
        /// 第二位
        /// </summary>
        public int[] hm2 { set; get; }

        /// <summary>
        /// 第三位
        /// </summary>
        public int[] hm3 { get; set; }

    }

    /// <summary>
    /// 和值走势图上的遗漏模型
    /// </summary>
    public class Tcsdklpk3HzzsMissInfo
    {
        public string name { get; set; }

        /// <summary>
        /// 和值
        /// </summary>
        public int[] hz { get; set; }

    }

    /// <summary>
    /// 大小走势图遗漏模型
    /// </summary>
    public class Tcsdklpk3DxMissInfo
    {
        /// <summary>
        /// 名称
        /// </summary>
        public string name { get; set; }

        public int[] dx1 { get; set; }

        public int[] dx2 { get; set; }

        public int[] dx3 { get; set; }

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

        /// <summary>
        /// 大小形态
        /// </summary>
        public int[] dxxt { get; set; }
    }

    /// <summary>
    /// 奇偶走势图遗漏模型
    /// </summary>
    public class Tcsdklpk3JoMissInfo
    {
        /// <summary>
        /// 名称
        /// </summary>
        public string name { get; set; }

        public int[] jo1 { get; set; }

        public int[] jo2 { get; set; }

        public int[] jo3 { get; set; }

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

        /// <summary>
        /// 奇偶形态
        /// </summary>
        public int[] joxt { get; set; }
    }

    /// <summary>
    /// 质合走势图遗漏模型
    /// </summary>
    public class Tcsdklpk3ZhMissInfo
    {
        /// <summary>
        /// 名称
        /// </summary>
        public string name { get; set; }

        public int[] zh1 { get; set; }

        public int[] zh2 { get; set; }

        public int[] zh3 { get; set; }

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

        /// <summary>
        /// 质合形态
        /// </summary>
        public int[] zhxt { get; set; }
    }

    /// <summary>
    /// 走势走势图上的遗漏模型
    /// </summary>
    public class Tcsdklpk3HszsMissInfo
    {
        public string name { get; set; }

        /// <summary>
        /// 第一位花色
        /// </summary>
        public int[] hs1 { get; set; }

        /// <summary>
        /// 第二位花色
        /// </summary>
        public int[] hs2 { get; set; }

        /// <summary>
        /// 第三位花色
        /// </summary>
        public int[] hs3 { get; set; }

        /// <summary>
        /// 和尾
        /// </summary>
        public int[] hw { get; set; }

    }

    #endregion

    #region 数据库操作
    /// <summary>
    /// 体彩山东快乐扑克3
    /// </summary>
    public class Tcsdklpk3Data : DataConnect
    {
        private static readonly object _lock = new object();
        /// <summary>
        /// 添加数据
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public static int Add(Tcsdklpk3Info model)
        {
            if (model == null && model.id <= 0)
                return 0;
            List<int> kjh = new List<int>() { model.n1%100,model.n2%100,model.n3%100};
            model.opencode = $"{model.n1},{model.n2},{model.n3}";
            model.hz = kjh.Sum();
            model.kd = kjh.Max() - kjh.Min();
            model.hs1 = model.n1 / 100;
            model.hs2 = model.n2 / 100;
            model.hs3 = model.n3 / 100;
            model.n1 = model.n1 % 100;
            model.n2 = model.n2 % 100;
            model.n3 = model.n3 % 100;
            model.addtime = DateTime.Now;
            lock (_lock)
            {
                using (Database db = new Database(mysql, MySqlClientFactory.Instance))
                {
                    if (db.Exists<Tcsdklpk3Info>($"where qi={model.qi}"))
                        return 0;
                    int ret = TypeConverter.ObjectToInt(db.Insert(model));
                    try
                    {
                        //更新api
                        DoHttpHelp.UpdateWebApi(GPEnum.tcsdklpk3.ToString());
                    }
                    catch (Exception) { }
                    return ret;
                }
            }
        }

        /// <summary>
        /// 最新一期
        /// </summary>
        /// <returns></returns>
        public static Tcsdklpk3Info GetTcsdklpk3NewInfo()
        {
            string sql = string.Format("where n1>-1 order by qi desc limit 1 ");
            using (Database db = new Database(mysql, MySqlClientFactory.Instance))
            {
                return db.SingleOrDefault<Tcsdklpk3Info>(sql);
            }
            
        }

        /// <summary>
        /// 最近N期的数据列表
        /// </summary>
        /// <returns></returns>
        public static List<Tcsdklpk3Info> GetList()
        {
            const string sql = "order by qi desc limit 2000";
            using (Database db = new Database(mysql, MySqlClientFactory.Instance))
            {
                var list = db.Fetch<Tcsdklpk3Info>(sql);
                var outlist = new List<Tcsdklpk3Info>();
                if (list != null && list.Count > 0)
                {
                    var size = list.Count;
                    for (int i = 0; i < size; i++)
                    {
                        Tcsdklpk3Info info = list[i];
                        info.rank = i + 1;
                        outlist.Add(info);
                    }
                }
                return outlist;
            }
        }

        public static Tcsdklpk3Info GetNewQiTop1(int dateint)
        {
            string sql = string.Empty;
            if (dateint == 0)
            {
                sql = string.Format("order by qi desc limit 1");
            }
            else
            {
                string _qistr = dateint.ToString() + "00";
                sql = string.Format("where qi<{0} order by qi desc limit 1", _qistr);
            }
            using (Database db = new Database(mysql, MySqlClientFactory.Instance))
            {
                return db.SingleOrDefault<Tcsdklpk3Info>(sql);
            }
        }


        /// <summary>
        /// 返回指定条件的最新期数，dateint=0，返回所有数据中的最新一条，即无附加条件的最新。
        /// 用于组合今天，昨天，前天的查询条件。
        /// </summary>
        /// <param name="dateint"></param>
        /// <returns></returns>
        public static string GetNewQiTop1Qi(int dateint)
        {
            int qi = TypeConverter.ObjectToInt(GetNewQiTop1(dateint).qi, 0);
            return qi.ToString();
        }

        /// <summary>
        /// 某一天的
        /// </summary>
        /// <param name="sqi"></param>
        /// <param name="eqi"></param>
        /// <returns></returns>
        public static List<Tcsdklpk3Info> GetOneDayKjList(DateTime sqi, DateTime eqi)
        {
            string sql = string.Format("where date BETWEEN '{0}' AND '{1}'", sqi, eqi);
            using (Database db = new Database(mysql, MySqlClientFactory.Instance))
            {
                List<Tcsdklpk3Info> list = db.Fetch<Tcsdklpk3Info>(sql);
                if (list != null && list.Count > 0)
                {
                    for (int i = 0; i < list.Count; i++)
                    {
                        if (list[i].qi.ToString().Length > 8)
                        {
                            list[i].qi = TypeConverter.StrToInt(list[i].qi.ToString().Substring(2), 0);
                        }
                    }
                }
                return list;
            }
        }

    } 
    #endregion
}