using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using CB.Common;
using CB.Data;
using CB.Entity;
using CB.Entity.Frequency;
using CB.Interface.Infrastructure;

namespace CB.Data.SqlServer
{
    public class LotteryServerManage : Repository<LotteryServerInfo>, ILotteryServerService
    {
        public LotteryServerManage(string interfaceId)
            : base(interfaceId)
        {
        }

        public override bool Save(LotteryServerInfo entity)
        {
            DbParameter[] pars ={
                DbHelper.MakeInParam(InterfaceId,"@Id",(DbType)SqlDbType.Int,4,entity.Id),                    
                DbHelper.MakeInParam(InterfaceId,"@Cid",(DbType)SqlDbType.Int,4,entity.Cid),
                DbHelper.MakeInParam(InterfaceId,"@Sid",(DbType)SqlDbType.Int,4,entity.Sid)
                                };
            return TypeConverter.ObjectToInt(DbHelper.ExecuteScalar(InterfaceId, CommandType.StoredProcedure, "usp_LotteryServer_save", pars)) > 0;
        }

        public override bool Update(LotteryServerInfo entity)
        {
            throw new NotImplementedException();
        }

        public override bool Delete(int Id)
        {
            DbParameter[] pars =
            {
                DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,150,
                    "DELETE FROM DT_LotteryServer WHERE [Id]=@Id"),
                DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@Id int"),
                DbHelper.MakeInParam(InterfaceId,"@Id",(DbType)SqlDbType.Int,4,Id)
            };
            return DbHelper.ExecuteNonQuery(InterfaceId, CommandType.StoredProcedure, "dbo.sp_executesql", pars) > 0;
        }

        public override LotteryServerInfo Get<TKey>(TKey key)
        {

            LotteryServerInfo 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],[Cid] ,[Sid] FROM  [DT_LotteryServer] WHERE Id= @Id",
                para))
            {
                if (reader.Read())
                {
                    Entity = LoadEntity(reader);
                }
                reader.Dispose();
            }
            return Entity;
        }

        public override IList<LotteryServerInfo> ToList()
        {
            IList<LotteryServerInfo> list = new List<LotteryServerInfo>();
            using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId, CommandType.Text,
                "SELECT [Id],[Cid],[Sid] FROM [DT_LotteryServer]"))
            {
                while (reader.Read())
                { list.Add(LoadEntity(reader)); }
                reader.Dispose();
            }
            return list;
        }

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

        public override IList<LotteryServerInfo> ToPaging(LotteryServerInfo entity, int pageSize, int pageIndex, out int recordCount)
        {
            string where = "1=1 ";

            if (entity.Sid > 0)
            {
                where += " AND [Sid]=" + entity.Sid;
            }

            recordCount = 0;
            string field = "[Id],[Cid],[Sid]"
                , orderField = "Sid Asc"
                , tableName = "DT_LotteryServer";
            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<LotteryServerInfo> list = new List<LotteryServerInfo>();
            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 LotteryServerInfo LoadEntity(DataRow dr)
        {
            return new LotteryServerInfo
            {
                Id = TypeConverter.ObjectToInt(dr["Id"]),
                Cid = TypeConverter.ObjectToInt(dr["Cid"]),
                Sid = TypeConverter.ObjectToInt(dr["Sid"]),
            };
        }

        protected override LotteryServerInfo LoadEntity(IDataReader reader)
        {
            return new LotteryServerInfo
           {
               Id = TypeConverter.ObjectToInt(reader["Id"]),
               Cid = TypeConverter.ObjectToInt(reader["Cid"]),
               Sid = TypeConverter.ObjectToInt(reader["Sid"]),
           };
        }

        public bool DeleteSid(int sid)
        {
            DbParameter[] pars =
            {
                DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,150,
                    "DELETE FROM DT_LotteryServer WHERE [Sid]=@Sid"),
                DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@Sid int"),
                DbHelper.MakeInParam(InterfaceId,"@Sid",(DbType)SqlDbType.Int,4,sid)
            };
            return DbHelper.ExecuteNonQuery(InterfaceId, CommandType.StoredProcedure, "dbo.sp_executesql", pars) > 0;
        }
    }
}