using System;
using System.Collections.Generic;

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

namespace CB.Data.SqlServer
{
    public class TVUserManage : Repository<TVUserInfo>, ITVUserService
    {
        public TVUserManage(string interfaceId)
            : base(interfaceId)
        {
        }

        public override bool Save(TVUserInfo entity)
        {
            throw new NotImplementedException();
        }

        public override bool Update(TVUserInfo entity)
        {
            DbParameter[] pars ={
                DbHelper.MakeInParam(InterfaceId,"@Uid",(DbType)SqlDbType.Int,4,entity.Uid),                    
                DbHelper.MakeInParam(InterfaceId,"@MacAddr",(DbType)SqlDbType.NChar,30,entity.MacAddr),
                DbHelper.MakeInParam(InterfaceId,"@AreaId",(DbType)SqlDbType.Int,4,entity.AreaId),
                DbHelper.MakeInParam(InterfaceId,"@LotteryId",(DbType)SqlDbType.Int,4,entity.LotteryId),
                DbHelper.MakeInParam(InterfaceId,"@ChartId",(DbType)SqlDbType.Int,4,entity.ChartId),
                DbHelper.MakeInParam(InterfaceId,"@Direction",(DbType)SqlDbType.Int,4,entity.Direction),
                DbHelper.MakeInParam(InterfaceId,"@OSInfo",(DbType)SqlDbType.NVarChar,500,entity.OSInfo),
                                };
            return TypeConverter.ObjectToInt(DbHelper.ExecuteScalar(InterfaceId, CommandType.StoredProcedure, "usp_TVUser_update", pars)) > 0;
        }

        public override bool Delete(int Id)
        {
            throw new NotImplementedException();
        }

        public override TVUserInfo Get<TKey>(TKey key)
        {
            throw new NotImplementedException();
        }

        public TVUserInfo GetTVUserByMac(string macAddr)
        {
            DbParameter[] pars ={
                DbHelper.MakeInParam(InterfaceId,"@MacAddr",(DbType)SqlDbType.NChar,30,macAddr),                    
                                };
            TVUserInfo entity = null;
            using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId, CommandType.StoredProcedure, "usp_TVUser_Get_mac", pars))
            {
                if (reader.Read())
                {
                    entity = LoadEntity(reader);
                }
                reader.Close();
            }
            return entity;
        }

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

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

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

            recordCount = 0;
            string field = "Uid, MacAddr, AreaId, LotteryId, ChartId, Direction, OSInfo"
                , orderField = "Uid Asc"
                , tableName = "UC_TVUser";
            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<TVUserInfo> list = new List<TVUserInfo>();
            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 TVUserInfo LoadEntity(DataRow dr)
        {
            return new TVUserInfo
            {
                Uid = TypeConverter.ObjectToInt(dr["Uid"]),
                MacAddr = dr["MacAddr"].ToString().Trim(),
                AreaId = TypeConverter.ObjectToInt(dr["AreaId"]),
                LotteryId = TypeConverter.ObjectToInt(dr["LotteryId"]),
                ChartId = TypeConverter.ObjectToInt(dr["ChartId"]),
                Direction = TypeConverter.ObjectToInt(dr["Direction"]),
                OSInfo = dr["OSInfo"].ToString().Trim()
            };
        }

        protected override TVUserInfo LoadEntity(IDataReader reader)
        {
            return new TVUserInfo
            {
                Uid = TypeConverter.ObjectToInt(reader["Uid"]),
                MacAddr = reader["MacAddr"].ToString().Trim(),
                AreaId = TypeConverter.ObjectToInt(reader["AreaId"]),
                LotteryId = TypeConverter.ObjectToInt(reader["LotteryId"]),
                ChartId = TypeConverter.ObjectToInt(reader["ChartId"]),
                Direction = TypeConverter.ObjectToInt(reader["Direction"]),
                OSInfo = reader["OSInfo"].ToString().Trim()
            };
        }
    }
}