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

namespace CB.Data.SqlServer
{
    public class TVServerManage : Repository<TVServerInfo>, ITVServerService
    {
        public TVServerManage(string interfaceId)
            : base(interfaceId)
        {
        }

        public override bool Save(TVServerInfo entity)
        {
            DbParameter[] pars ={
                DbHelper.MakeInParam(InterfaceId,"@Id",(DbType)SqlDbType.Int,4,entity.Id),                    
                DbHelper.MakeInParam(InterfaceId,"@Name",(DbType)SqlDbType.NVarChar,20,entity.Name),
                DbHelper.MakeInParam(InterfaceId,"@Url",(DbType)SqlDbType.NVarChar,200,entity.Url)
                                };
            return TypeConverter.ObjectToInt(DbHelper.ExecuteScalar(InterfaceId, CommandType.StoredProcedure, "usp_TVServer_save", pars)) > 0;
        }

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

        public override bool Delete(int id)
        {
            DbParameter[] pars =
            {
                DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,150,
                    "DELETE FROM DT_TVServer 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 TVServerInfo Get<TKey>(TKey key)
        {
            TVServerInfo 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],[Name] ,[Url] FROM  [DT_TVServer] WHERE Id= @Id",
                para))
            {
                if (reader.Read())
                {
                    Entity = LoadEntity(reader);
                }
                reader.Dispose();
            }
            return Entity;
        }

        public override IList<TVServerInfo> ToList()
        {
            IList<TVServerInfo> list = new List<TVServerInfo>();
            StringBuilder strSql = new StringBuilder();
            strSql.Append("SELECT  [Id],[Name] ,[Url]");
            strSql.Append(" FROM  DT_TVServer  ORDER BY Id ASC");

            using (DataTable dt = DbHelper.ExecuteDatatable(InterfaceId, strSql.ToString()))
            {
                if (null != dt && 0 < dt.Rows.Count)
                {
                    foreach (DataRow dr in dt.Rows)
                    { list.Add(LoadEntity(dr)); }
                }
                dt.Dispose();
            }
            return list;
        }

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

        public override IList<TVServerInfo> ToPaging(TVServerInfo entity, int pageSize, int pageIndex, out int recordCount)
        {
            throw new NotImplementedException();
        }

        /// <summary>
        /// 根据彩种获取彩种走势图所在服务器
        /// </summary>
        /// <param name="lid"></param>
        /// <returns></returns>
        public IList<TVServerInfo> GetTVServer(int lid)
        {
            IList<TVServerInfo> list = new List<TVServerInfo>();
            DbParameter[] pars =
            {
                DbHelper.MakeInParam(InterfaceId,"@statement",(DbType)SqlDbType.NVarChar,150,
                    "SELECT [Id],[Name],[Url] FROM [dbo].[DT_TVServer] WHERE [Id] IN (SELECT [Sid] FROM [DT_LotteryServer] WHERE [Cid]=@cid)"),
                DbHelper.MakeInParam(InterfaceId,"@params",(DbType)SqlDbType.NVarChar,10,"@cid int"),
                DbHelper.MakeInParam(InterfaceId,"@cid",(DbType)SqlDbType.Int,4,lid)
            };
            using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId, CommandType.StoredProcedure, "dbo.sp_executesql", pars))
            {
                while (reader.Read())
                {
                    list.Add(LoadEntity(reader));
                }
                reader.Close();
            }
            return list;
        }

        protected override TVServerInfo LoadEntity(IDataReader reader)
        {
            return new TVServerInfo
            {
                Id = Convert.ToInt32(reader["Id"]),
                Name = reader["Name"].ToString().Trim(),
                Url = reader["Url"].ToString().Trim(),
            };
        }
        protected override TVServerInfo LoadEntity(DataRow dr)
        {
            return new TVServerInfo
            {
                Id = Convert.ToInt32(dr["Id"]),
                Name = dr["Name"].ToString().Trim(),
                Url = dr["Url"].ToString().Trim(),
            };
        }
    }
}