55128.cn_kjh.55128.cn_m.55128.cn/CP55128/CB.Data.SqlServer/Lottery/TCP3Manage.cs

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;

using System.Data.SqlClient;
using System.Text;
using CB.Common;
using CB.Data;
using CB.Entity;
using CB.Interface.Infrastructure;


namespace CB.Data.SqlServer
{
    public class TCP3Manage : Repository<TCP3Info>, ITCP3Service
    {
        public TCP3Manage(string interfaceId)
            : base(interfaceId)
        {
        }
        public override bool Save(TCP3Info entity)
        {
            DbParameter[] pars ={
                DbHelper.MakeInParam(InterfaceId,"@Term",(DbType)SqlDbType.Int,4,entity.Term),
                DbHelper.MakeInParam(InterfaceId,"@OpenCode1",(DbType)SqlDbType.Int,4,entity.OpenCode1),
                DbHelper.MakeInParam(InterfaceId,"@OpenCode2",(DbType)SqlDbType.Int,4,entity.OpenCode2),
                DbHelper.MakeInParam(InterfaceId,"@OpenCode3",(DbType)SqlDbType.Int,4,entity.OpenCode3),
                DbHelper.MakeInParam(InterfaceId,"@OpenCode4",(DbType)SqlDbType.Int,4,entity.OpenCode4),
                DbHelper.MakeInParam(InterfaceId,"@OpenCode5",(DbType)SqlDbType.Int,4,entity.OpenCode5),
                DbHelper.MakeInParam(InterfaceId,"@OpenTime",(DbType)SqlDbType.DateTime,0,entity.OpenTime),
                DbHelper.MakeInParam(InterfaceId,"@ShiJiHao",(DbType)SqlDbType.NVarChar,0,entity.ShiJiHao),
                DbHelper.MakeInParam(InterfaceId,"@KaiJiHao",(DbType)SqlDbType.NVarChar,0,entity.KaiJiHao),
                DbHelper.MakeInParam(InterfaceId,"@Detail",(DbType)SqlDbType.NVarChar,500,entity.Detail)
                                };
            return TypeConverter.ObjectToInt(DbHelper.ExecuteScalar(InterfaceId,CommandType.StoredProcedure, "usp_TCP3_save", pars)) > 0;
        }

        public override bool Update(TCP3Info entity)
        {
            DbParameter[] pars ={
                DbHelper.MakeInParam(InterfaceId,"@Term",(DbType)SqlDbType.Int,4,entity.Term),
                DbHelper.MakeInParam(InterfaceId,"@OpenCode1",(DbType)SqlDbType.Int,4,entity.OpenCode1),
                DbHelper.MakeInParam(InterfaceId,"@OpenCode2",(DbType)SqlDbType.Int,4,entity.OpenCode2),
                DbHelper.MakeInParam(InterfaceId,"@OpenCode3",(DbType)SqlDbType.Int,4,entity.OpenCode3),
                DbHelper.MakeInParam(InterfaceId,"@OpenCode4",(DbType)SqlDbType.Int,4,entity.OpenCode4),
                DbHelper.MakeInParam(InterfaceId,"@OpenCode5",(DbType)SqlDbType.Int,4,entity.OpenCode5),
                DbHelper.MakeInParam(InterfaceId,"@OpenTime",(DbType)SqlDbType.DateTime,0,entity.OpenTime),
                DbHelper.MakeInParam(InterfaceId,"@ShiJiHao",(DbType)SqlDbType.NVarChar,0,entity.ShiJiHao),
                DbHelper.MakeInParam(InterfaceId,"@KaiJiHao",(DbType)SqlDbType.NVarChar,0,entity.KaiJiHao),
                DbHelper.MakeInParam(InterfaceId,"@Detail",(DbType)SqlDbType.NVarChar,500,entity.Detail)
                                };
            return TypeConverter.ObjectToInt(DbHelper.ExecuteScalar(InterfaceId, CommandType.StoredProcedure, "usp_TCP3_save", pars)) > 0;
        }

        public override bool Delete(int id)
        {
            DbParameter[] pars ={
                 DbHelper.MakeInParam(InterfaceId,"@Id",(DbType)SqlDbType.Int,4,id)
                                };
            return TypeConverter.ObjectToInt(DbHelper.ExecuteScalar(InterfaceId,CommandType.StoredProcedure, "usp_TCP3_Delete", pars)) > 0;
        }

        public override TCP3Info Get<TKey>(TKey key)
        {
            TCP3Info Entity = null;
            DbParameter[] para = 
            {
                DbHelper.MakeInParam(InterfaceId,"@Id",(DbType)SqlDbType.Int,4,key)
            };
            using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId,CommandType.Text,
                "SELECT TOP 1 [Id],[Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenTime],[ShiJiHao],[KaiJiHao],[Detail],[Addtime] FROM [DT_TCP3] WHERE [Id]=@Id",
                para))
            {
                if (reader.Read())
                {
                    Entity = LoadEntity(reader);
                }
                reader.Dispose();
            }
            return Entity;
        }

        public override IList<TCP3Info> ToList()
        {
            IList<TCP3Info> list = new List<TCP3Info>();
            using (DataTable dt = DbHelper.ExecuteDatatable(InterfaceId,
         "SELECT [Id],[Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenTime],[ShiJiHao],[KaiJiHao],[Detail],[Addtime] FROM [DT_TCP3] ORDER BY [Term] ASC"))
            {
                if (null != dt && 0 < dt.Rows.Count)
                {
                    foreach (DataRow dr in dt.Rows)
                    {
                        list.Add(LoadEntity(dr));
                    }
                }
                dt.Dispose();
            }
            return list;
        }

        public override IList<TCP3Info> ToList(TCP3Info entity)
        {
            throw new NotImplementedException();
        }

        public override IList<TCP3Info> ToPaging(TCP3Info entity, int pageSize, int pageIndex, out int recordCount)
        {
            string where = "1=1 ";
            if (null != entity)
            {
                if (entity.Term > 0)
                    where += " AND [Term]=" + entity.Term;
            }
            recordCount = 0;
            string field = "[Id],[Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenTime],[ShiJiHao],[KaiJiHao],[Detail],[Addtime]"
                , orderField = "[Term] DESC"
                , tableName = "DT_TCP3";
            DbParameter[] para = 
            {
                DbHelper.MakeInParam(InterfaceId,"@pageSize",(DbType)SqlDbType.Int,4,pageSize),
                DbHelper.MakeInParam(InterfaceId,"@page",(DbType)SqlDbType.Int,4,pageIndex),
                DbHelper.MakeInParam(InterfaceId,"@tableName",(DbType)SqlDbType.NVarChar,500,tableName),
                DbHelper.MakeInParam(InterfaceId,"@field",(DbType)SqlDbType.NVarChar,1000,field),
                DbHelper.MakeInParam(InterfaceId,"@orderField",(DbType)SqlDbType.NVarChar,50,orderField),
                DbHelper.MakeInParam(InterfaceId,"@where",(DbType)SqlDbType.NVarChar,2000,where)
            };
            IList<TCP3Info> list = new List<TCP3Info>();
            using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId,CommandType.StoredProcedure, "usp_st_page", para))
            {
                while (reader.Read())
                {
                    list.Add(LoadEntity(reader));
                }
                if (reader.NextResult() && reader.Read())
                {
                    recordCount = reader.GetInt32(0);
                }
                reader.Dispose();
            }
            return list;
        }

        protected override TCP3Info LoadEntity(DataRow dr)
        {
            TCP3Info entity = new TCP3Info
            {
                Id = TypeConverter.ObjectToInt(dr["Id"]),
                Term = TypeConverter.ObjectToInt(dr["Term"]),
                OpenCode1 = TypeConverter.ObjectToInt(dr["OpenCode1"]),
                OpenCode2 = TypeConverter.ObjectToInt(dr["OpenCode2"]),
                OpenCode3 = TypeConverter.ObjectToInt(dr["OpenCode3"]),
                OpenCode4 = TypeConverter.ObjectToInt(dr["OpenCode4"]),
                OpenCode5 = TypeConverter.ObjectToInt(dr["OpenCode5"]),
                OpenTime = TypeConverter.ObjectToDateTime(dr["OpenTime"], DateTime.MinValue),
                ShiJiHao = dr["ShiJiHao"].ToString().Trim(),
                KaiJiHao = dr["KaiJiHao"].ToString().Trim(),
                Detail = dr["Detail"].ToString(),
                Addtime = TypeConverter.ObjectToDateTime(dr["Addtime"], DateTime.MinValue)
            };
            entity.OpenCode = new List<int>() { entity.OpenCode1, entity.OpenCode2, entity.OpenCode3, entity.OpenCode4, entity.OpenCode5 };
            return entity;
        }

        protected override TCP3Info LoadEntity(IDataReader reader)
        {
            TCP3Info entity = new TCP3Info
            {
                Id = TypeConverter.ObjectToInt(reader["Id"]),
                Term = TypeConverter.ObjectToInt(reader["Term"]),
                OpenCode1 = TypeConverter.ObjectToInt(reader["OpenCode1"]),
                OpenCode2 = TypeConverter.ObjectToInt(reader["OpenCode2"]),
                OpenCode3 = TypeConverter.ObjectToInt(reader["OpenCode3"]),
                OpenCode4 = TypeConverter.ObjectToInt(reader["OpenCode4"]),
                OpenCode5 = TypeConverter.ObjectToInt(reader["OpenCode5"]),
                OpenTime = TypeConverter.ObjectToDateTime(reader["OpenTime"], DateTime.MinValue),
                ShiJiHao = reader["ShiJiHao"].ToString().Trim(),
                KaiJiHao = reader["KaiJiHao"].ToString().Trim(),
                Detail = reader["Detail"].ToString(),
                Addtime = TypeConverter.ObjectToDateTime(reader["Addtime"], DateTime.MinValue)
            };
            entity.OpenCode = new List<int>() { entity.OpenCode1, entity.OpenCode2, entity.OpenCode3, entity.OpenCode4, entity.OpenCode5 };
            return entity;
        }
        public IList<TCP3Info> ToListForTrend(long term, LotterySearchField fields)
        {
            IList<TCP3Info> list = new List<TCP3Info>();
            DbParameter[] para;
            int numRepeat = null == fields ? 0 : fields.NumRepeat;
            switch (numRepeat)
            {
                //组三
                case 1:
                    para = new DbParameter[]
                        {
                            DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,400,"SELECT TOP 2 [Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenTime],[ShiJiHao],[KaiJiHao] FROM [DT_TCP3] WHERE [Term]<=@qi AND (([OpenCode1] = [OpenCode2] AND [OpenCode1] != [OpenCode3]) OR ([OpenCode1] = [OpenCode3] AND [OpenCode2] != [OpenCode3]) OR ([OpenCode2] = [OpenCode3] AND [OpenCode1] != [OpenCode3])) ORDER BY [Term] DESC"),
                            DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@qi int"),
                            DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term)
                        };
                    break;
                //豹子
                case 2:
                    para = new DbParameter[]
                        {
                            DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,300,"SELECT TOP 2 [Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenTime],[ShiJiHao],[KaiJiHao] FROM [DT_TCP3] WHERE [Term]<=@qi AND [OpenCode1] = [OpenCode2] AND [OpenCode2] = [OpenCode3] ORDER BY [Term] DESC"),
                            DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@qi int"),
                            DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term)
                        };
                    break;
                default:
                    para = new DbParameter[]
                        {
                            DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,300,"SELECT TOP 2 [Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenTime],[ShiJiHao],[KaiJiHao] FROM [DT_TCP3] WHERE [Term]<=@qi ORDER BY [Term] DESC"),
                            DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@qi int"),
                            DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term)
                        };
                    break;
            }
            using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId,CommandType.StoredProcedure, "dbo.sp_executesql", para))
            {
                while (reader.Read())
                {
                    var entity = new TCP3Info
                    {
                        Term = TypeConverter.ObjectToInt(reader["Term"]),
                        OpenCode1 = TypeConverter.ObjectToInt(reader["OpenCode1"]),
                        OpenCode2 = TypeConverter.ObjectToInt(reader["OpenCode2"]),
                        OpenCode3 = TypeConverter.ObjectToInt(reader["OpenCode3"]),
                        OpenCode4 = TypeConverter.ObjectToInt(reader["OpenCode4"]),
                        OpenCode5 = TypeConverter.ObjectToInt(reader["OpenCode5"]),
                        OpenTime = TypeConverter.ObjectToDateTime(reader["OpenTime"], DateTime.MinValue),
                        ShiJiHao = reader["ShiJiHao"].ToString().Trim(),
                        KaiJiHao = reader["KaiJiHao"].ToString().Trim()
                    };
                    entity.OpenCode = new List<int>() { entity.OpenCode1, entity.OpenCode2, entity.OpenCode3, entity.OpenCode4, entity.OpenCode5 };
                    list.Add(entity);
                }
                reader.Dispose();
            }
            return list;
        }
        public IList<TCP3Info> ToListForNextTrend(long term, LotterySearchField fields)
        {
            IList<TCP3Info> list = new List<TCP3Info>();
            DbParameter[] para;
            int numRepeat = null == fields ? 0 : fields.NumRepeat;
            switch (numRepeat)
            {
                //组三
                case 1:
                    para = new DbParameter[]
                        {
                            DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,400,"SELECT TOP 2 [Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenTime],[ShiJiHao],[KaiJiHao] FROM [DT_TCP3] WHERE [Term]>=@qi AND (([OpenCode1] = [OpenCode2] AND [OpenCode1] != [OpenCode3]) OR ([OpenCode1] = [OpenCode3] AND [OpenCode2] != [OpenCode3]) OR ([OpenCode2] = [OpenCode3] AND [OpenCode1] != [OpenCode3])) ORDER BY [Term] ASC"),
                            DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@qi int"),
                            DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term)
                        };
                    break;
                //豹子
                case 2:
                    para = new DbParameter[]
                        {
                            DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,300,"SELECT TOP 2 [Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenTime],[ShiJiHao],[KaiJiHao] FROM [DT_TCP3] WHERE [Term]>=@qi AND [OpenCode1] = [OpenCode2] AND [OpenCode2] = [OpenCode3] ORDER BY [Term] ASC"),
                            DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@qi int"),
                            DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term)
                        };
                    break;
                default:
                    para = new DbParameter[]
                        {
                            DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,300,"SELECT TOP 2 [Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenTime],[ShiJiHao],[KaiJiHao] FROM [DT_TCP3] WHERE [Term]>=@qi ORDER BY [Term] ASC"),
                            DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@qi int"),
                            DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term)
                        };
                    break;
            }
            using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId,CommandType.StoredProcedure, "dbo.sp_executesql", para))
            {
                while (reader.Read())
                {
                    var entity = new TCP3Info
                    {
                        Term = TypeConverter.ObjectToInt(reader["Term"]),
                        OpenCode1 = TypeConverter.ObjectToInt(reader["OpenCode1"]),
                        OpenCode2 = TypeConverter.ObjectToInt(reader["OpenCode2"]),
                        OpenCode3 = TypeConverter.ObjectToInt(reader["OpenCode3"]),
                        OpenCode4 = TypeConverter.ObjectToInt(reader["OpenCode4"]),
                        OpenCode5 = TypeConverter.ObjectToInt(reader["OpenCode5"]),
                        OpenTime = TypeConverter.ObjectToDateTime(reader["OpenTime"], DateTime.MinValue),
                        ShiJiHao = reader["ShiJiHao"].ToString().Trim(),
                        KaiJiHao = reader["KaiJiHao"].ToString().Trim()
                    };
                    entity.OpenCode = new List<int>() { entity.OpenCode1, entity.OpenCode2, entity.OpenCode3, entity.OpenCode4, entity.OpenCode5 };
                    list.Add(entity);
                }
                reader.Dispose();
            }
            return list;
        }
        /// <summary>
        /// 前台页面查询时使用
        /// </summary>
        /// <param name="term">期数</param>
        /// <param name="fields">查询条件</param>
        /// <returns></returns>
        public IList<TCP3Info> GetListToEnd(long term, TrendChartSearchField fields)
        {
            IList<TCP3Info> list = new List<TCP3Info>();
            DbParameter[] para;
            int numRepeat = null == fields ? 0 : fields.NumRepeat;

            string query = "";
            int topSize = 0;
            if (null != fields)
            {
                if (fields.Year > 0)
                {
                    query += " and Term between " + (fields.Year * 1000).ToString() + " and " + ((fields.Year + 1) * 1000).ToString() + " ";
                    fields.Record = 1500;
                }
                else if (fields.StartTerm > 0 && fields.EndTerm > 0)
                { query += " and Term between " + fields.StartTerm.ToString() + " and " + fields.EndTerm.ToString() + " "; fields.Record = 1500; }
                else if (fields.Record == 0)
                { fields.Record = 30; }
                topSize = fields.Record;
            }
            string topSql = "";
            if (topSize > 0) topSql = " top (" + topSize.ToString() + ")";
            switch (numRepeat)
            {
                case 1://组三
                    para = new DbParameter[]
                        {
                            DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,400,"SELECT  "+topSql+"   [Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenTime],[ShiJiHao],[KaiJiHao] FROM [DT_TCP3]  WHERE OpenCode1 > -1 AND [Term]>=@qi AND (([OpenCode1] = [OpenCode2] AND [OpenCode1] != [OpenCode3]) OR ([OpenCode1] = [OpenCode3] AND [OpenCode2] != [OpenCode3]) OR ([OpenCode2] = [OpenCode3] AND [OpenCode1] != [OpenCode3]))  "+ query+" ORDER BY [Term] DESC"),
                            DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@qi int"),
                            DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term)
                        };
                    break;
                case 2://豹子
                    para = new DbParameter[]
                        {
                            DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,300,"SELECT  "+topSql+"   [Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenTime],[ShiJiHao],[KaiJiHao] FROM [DT_TCP3]  WHERE OpenCode1 > -1 AND  [Term]>=@qi AND [OpenCode1] = [OpenCode2] AND [OpenCode2] = [OpenCode3]  "+ query+" ORDER BY [Term] DESC"),
                            DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@qi int"),
                            DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term)
                        };
                    break;
                default:
                    para = new DbParameter[]
                        {
                            DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,300,"SELECT  "+topSql+"   [Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenTime],[ShiJiHao],[KaiJiHao] FROM [DT_TCP3]  WHERE OpenCode1 > -1 AND  [Term]>=@qi  "+ query+" ORDER BY [Term] DESC"),
                            DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@qi int"),
                            DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term)
                        };
                    break;
            }
            using (DataTable dt = DbHelper.ExecuteDatatable(InterfaceId,CommandType.StoredProcedure, "dbo.sp_executesql", para))
            {
                if (null != dt && 0 < dt.Rows.Count)
                {
                    foreach (DataRow dr in dt.Rows)
                    {
                        var entity = new TCP3Info
                        {
                            Term = TypeConverter.ObjectToInt(dr["Term"]),
                            OpenCode1 = TypeConverter.ObjectToInt(dr["OpenCode1"]),
                            OpenCode2 = TypeConverter.ObjectToInt(dr["OpenCode2"]),
                            OpenCode3 = TypeConverter.ObjectToInt(dr["OpenCode3"]),
                            OpenCode4 = TypeConverter.ObjectToInt(dr["OpenCode4"]),
                            OpenCode5 = TypeConverter.ObjectToInt(dr["OpenCode5"]),
                            OpenTime = TypeConverter.ObjectToDateTime(dr["OpenTime"], DateTime.MinValue),
                            ShiJiHao = dr["ShiJiHao"].ToString().Trim(),
                            KaiJiHao = dr["KaiJiHao"].ToString().Trim()
                        };
                        entity.OpenCode = new List<int>() { entity.OpenCode1, entity.OpenCode2, entity.OpenCode3, entity.OpenCode4, entity.OpenCode5 };
                        list.Add(entity);
                    }
                }
                dt.Dispose();
            }
            return list;
        }
        public IList<TCP3Info> GetListToEnd(long term, LotterySearchField fields)
        {
            IList<TCP3Info> list = new List<TCP3Info>();
            DbParameter[] para;
            int numRepeat = null == fields ? 0 : fields.NumRepeat;
            switch (numRepeat)
            {
                case 1://组三
                    para = new DbParameter[]
                        {
                            DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,400,"SELECT [Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenTime],[ShiJiHao],[KaiJiHao] FROM [DT_TCP3]  WHERE [Term]>=@qi AND (([OpenCode1] = [OpenCode2] AND [OpenCode1] != [OpenCode3]) OR ([OpenCode1] = [OpenCode3] AND [OpenCode2] != [OpenCode3]) OR ([OpenCode2] = [OpenCode3] AND [OpenCode1] != [OpenCode3])) ORDER BY [Term] ASC"),
                            DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@qi int"),
                            DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term)
                        };
                    break;
                case 2://豹子
                    para = new DbParameter[]
                        {
                            DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,300,"SELECT [Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenTime],[ShiJiHao],[KaiJiHao] FROM [DT_TCP3]  WHERE [Term]>=@qi AND [OpenCode1] = [OpenCode2] AND [OpenCode2] = [OpenCode3] ORDER BY [Term] ASC"),
                            DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@qi int"),
                            DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term)
                        };
                    break;
                default:
                    para = new DbParameter[]
                        {
                            DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,300,"SELECT [Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenTime],[ShiJiHao],[KaiJiHao] FROM [DT_TCP3]  WHERE [Term]>=@qi ORDER BY [Term] ASC"),
                            DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@qi int"),
                            DbHelper.MakeInParam(InterfaceId,"@qi",(DbType)SqlDbType.Int,4,term)
                        };
                    break;
            }
            using (DataTable dt = DbHelper.ExecuteDatatable(InterfaceId, CommandType.StoredProcedure, "dbo.sp_executesql", para))
            {
                if (null != dt && 0 < dt.Rows.Count)
                {
                    foreach (DataRow dr in dt.Rows)
                    {
                        var entity = new TCP3Info
                        {
                            Term = TypeConverter.ObjectToInt(dr["Term"]),
                            OpenCode1 = TypeConverter.ObjectToInt(dr["OpenCode1"]),
                            OpenCode2 = TypeConverter.ObjectToInt(dr["OpenCode2"]),
                            OpenCode3 = TypeConverter.ObjectToInt(dr["OpenCode3"]),
                            OpenCode4 = TypeConverter.ObjectToInt(dr["OpenCode4"]),
                            OpenCode5 = TypeConverter.ObjectToInt(dr["OpenCode5"]),
                            OpenTime = TypeConverter.ObjectToDateTime(dr["OpenTime"], DateTime.MinValue),
                            ShiJiHao = dr["ShiJiHao"].ToString().Trim(),
                            KaiJiHao = dr["KaiJiHao"].ToString().Trim()
                        };
                        entity.OpenCode = new List<int>() { entity.OpenCode1, entity.OpenCode2, entity.OpenCode3, entity.OpenCode4, entity.OpenCode5 };
                        list.Add(entity);
                    }
                }
                dt.Dispose();
            }
            return list;
        }
        /// <summary>
        /// 根据条件获取top多少行
        /// </summary>
        /// <param name="entity"></param>
        /// <param name="pageSize"></param>
        /// <param name="pageIndex"></param>
        /// <param name="recordCount"></param>
        /// <param name="Order"></param>
        /// <returns></returns>
        public IList<TCP3Info> GetTopListByOrder(TCP3Info entity, int pageSize, int pageIndex, out int recordCount, string Order = "ASC")
        {
            recordCount = 0;
            string field = "[Id],[Term],[OpenCode1],[OpenCode2],[OpenCode3],[OpenCode4],[OpenCode5],[OpenTime],[ShiJiHao],[KaiJiHao],[Detail],[Addtime]"
                , orderField = "Term " + Order
                , where = ""
                , tableName = "DT_TCP3";
            DbParameter[] para = 
            {
                DbHelper.MakeInParam(InterfaceId,"@pageSize",(DbType)SqlDbType.Int,4,pageSize),
                DbHelper.MakeInParam(InterfaceId,"@page",(DbType)SqlDbType.Int,4,pageIndex),
                DbHelper.MakeInParam(InterfaceId,"@tableName",(DbType)SqlDbType.NVarChar,500,tableName),
                DbHelper.MakeInParam(InterfaceId,"@field",(DbType)SqlDbType.NVarChar,1000,field),
                DbHelper.MakeInParam(InterfaceId,"@orderField",(DbType)SqlDbType.NVarChar,50,orderField),
                DbHelper.MakeInParam(InterfaceId,"@where",(DbType)SqlDbType.NVarChar,2000,where)
            };
            IList<TCP3Info> list = new List<TCP3Info>();
            using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId,CommandType.StoredProcedure, "usp_st_page", para))
            {
                while (reader.Read())
                {
                    list.Add(LoadEntity(reader));
                }
                if (reader.NextResult() && reader.Read())
                {
                    recordCount = reader.GetInt32(0);
                }
                reader.Dispose();
            }
            return list;
        }
    }
}