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

namespace CB.Data.SqlServer
{
    public class AreaManage : Repository<AreaInfo>, IAreaService
    {
        public AreaManage(string interfaceId)
            : base(interfaceId)
        {
        }

        public override bool Save(AreaInfo entity)
        {
            DbParameter[] pars ={
                DbHelper.MakeInParam(InterfaceId,"@aid",(DbType)SqlDbType.Int,4,entity.Aid),                    
                DbHelper.MakeInParam(InterfaceId,"@Name",(DbType)SqlDbType.NVarChar,100,entity.Name),
                DbHelper.MakeInParam(InterfaceId,"@pid",(DbType)SqlDbType.Int,4,entity.ParentId),
                DbHelper.MakeInParam(InterfaceId,"@areaid",(DbType)SqlDbType.Int,4,(int)entity.Depth),
                                };
            return TypeConverter.ObjectToInt(DbHelper.ExecuteScalar(InterfaceId,CommandType.StoredProcedure, "usp_Area_save", pars)) > 0;
        }

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

        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_Area_Delete", pars)) > 0;
        }

        public override AreaInfo Get<TKey>(TKey key)
        {
            AreaInfo Entity = null;
            DbParameter[] para = 
            {
                DbHelper.MakeInParam(InterfaceId,"@Id",(DbType)SqlDbType.Int,4,key)
            };
            using (IDataReader reader = DbHelper.ExecuteReader(InterfaceId,CommandType.Text,
                "Select TOP 1 [Aid],[Name],[ParentId],[Depth] From [DT_Area] WHERE Aid= @Id", para))
            {
                if (reader.Read())
                {
                    Entity = LoadEntity(reader);
                }
                reader.Dispose();
            }
            return Entity;
        }

        public override IList<AreaInfo> ToList()
        {
            IList<AreaInfo> list = new List<AreaInfo>();
            using (DataTable dt = DbHelper.ExecuteDatatable(InterfaceId, "SELECT [Aid],[Name],[ParentId],[Depth] FROM [DT_Area] ORDER BY Aid 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<AreaInfo> ToList(AreaInfo entity)
        {
            IList<AreaInfo> list = new List<AreaInfo>();
            using (DataTable dt = DbHelper.ExecuteDatatable(InterfaceId, "SELECT [Aid],[Name],[ParentId],[Depth] FROM [DT_Area] ORDER BY Aid 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<AreaInfo> ToPaging(AreaInfo entity, int pageSize, int pageIndex, out int recordCount)
        {
            string where = "1=1 ";
            if (!string.IsNullOrEmpty(entity.Name))
            {
                where += "and [Name] like '%" + entity.Name + "%'";
            }
            recordCount = 0;
            string field = "[Aid],[Name],[ParentId],[Depth]"
                , orderField = "Aid"
                , tableName = "DT_Area";
            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<AreaInfo> list = new List<AreaInfo>();
            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 AreaInfo LoadEntity(IDataReader reader)
        {
            AreaInfo entity = new AreaInfo
            {
                Aid = Convert.ToInt32(reader["Aid"]),
                Name = reader["Name"].ToString().Trim(),
                ParentId = TypeConverter.ObjectToInt(reader["ParentId"]),
                Depth = (AreaType)Enum.Parse(typeof(AreaType), reader["Depth"].ToString())
            };
            return entity;
        }
        protected override AreaInfo LoadEntity(DataRow reader)
        {
            AreaInfo entity = new AreaInfo
            {
                Aid = Convert.ToInt32(reader["Aid"]),
                Name = reader["Name"].ToString().Trim(),
                ParentId = TypeConverter.ObjectToInt(reader["ParentId"]),
                Depth = (AreaType)Enum.Parse(typeof(AreaType), reader["Depth"].ToString())
            };
            return entity;
        }
    }
}