using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using CY.IDAL;
using System.Data.SqlClient;
using System.Data;
using CY.Model;

namespace CY.SQLDAL
{
    public class Info_ContentDAL : IInfo_ContentDAL
    {

        private Database _dataBase = null;

        public Info_ContentDAL()
        {
            _dataBase = new Database();
        }

        public Info_ContentDAL(Database database)
        {
            _dataBase = database;
        }

        /// <summary>
        /// 新增
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool InserModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.Info_Content trueModel = model as Model.Info_Content;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                    new SqlParameter("@MemberId",trueModel.MemberId),
					new SqlParameter("@Title",trueModel.Title),
					new SqlParameter("@Title_Bold",trueModel.Title_Bold),
					new SqlParameter("@Title_Color",trueModel.Title_Color),
					new SqlParameter("@SortID",trueModel.SortID),
					new SqlParameter("@Keyword",trueModel.Keyword),
					new SqlParameter("@MeteDesc",trueModel.MeteDesc),
					new SqlParameter("@FromSource",trueModel.FromSource),
					new SqlParameter("@Author",trueModel.Author),
					new SqlParameter("@WebLink",trueModel.WebLink),
					new SqlParameter("@IsRecommendation",trueModel.IsRecommendation),
					new SqlParameter("@IsTop",trueModel.IsTop),
					new SqlParameter("@InfoContent",trueModel.InfoContent),
					new SqlParameter("@Star",trueModel.Star),
					new SqlParameter("@Hits",trueModel.Hits),
					new SqlParameter("@OrderNum",trueModel.OrderNum),
					new SqlParameter("@CreatTime",trueModel.CreatTime),
					new SqlParameter("@UpTime",trueModel.UpTime),
					new SqlParameter("@GoodNum",trueModel.GoodNum),
					new SqlParameter("@MediumNum",trueModel.MediumNum),
					new SqlParameter("@BadNum",trueModel.BadNum),
                    new SqlParameter("@TypeId",trueModel.TypeId)
            };
            try
            {
                _dataBase.Query("sp_Info_Content_Insert", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        /// <summary>
        /// 修改
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool UpdateModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.Info_Content trueModel = model as Model.Info_Content;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {	
                    new SqlParameter("@Keyid",trueModel.Keyid),
                    new SqlParameter("@MemberId",trueModel.MemberId),
					new SqlParameter("@Title",trueModel.Title ?? ""),
					new SqlParameter("@Title_Bold",trueModel.Title_Bold),
					new SqlParameter("@Title_Color",trueModel.Title_Color??""),
					new SqlParameter("@SortID",trueModel.SortID??0),
					new SqlParameter("@Keyword",trueModel.Keyword ??""),
					new SqlParameter("@MeteDesc",trueModel.MeteDesc??""),
					new SqlParameter("@FromSource",trueModel.FromSource??""),
					new SqlParameter("@Author",trueModel.Author??""),
					new SqlParameter("@WebLink",trueModel.WebLink??""),
					new SqlParameter("@IsRecommendation",trueModel.IsRecommendation),
					new SqlParameter("@IsTop",trueModel.IsTop),
					new SqlParameter("@InfoContent",trueModel.InfoContent??""),
					new SqlParameter("@Star",trueModel.Star??1),
					new SqlParameter("@Hits",trueModel.Hits??1),
					new SqlParameter("@OrderNum",trueModel.OrderNum??1),
					new SqlParameter("@CreatTime",trueModel.CreatTime),
					new SqlParameter("@UpTime",trueModel.UpTime),
					new SqlParameter("@GoodNum",trueModel.GoodNum??0),
					new SqlParameter("@MediumNum",trueModel.MediumNum??0),
					new SqlParameter("@BadNum",trueModel.BadNum??0),
                    new SqlParameter("@TypeId",trueModel.TypeId??0)
            };
            try
            {
                _dataBase.Query("sp_Info_Content_Update", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public bool DeleteModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.Info_Content trueModel = model as Model.Info_Content;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                	new SqlParameter("@Keyid",trueModel.Keyid)
            };
            try
            {
                _dataBase.Query("sp_Info_Content_DeleteRow", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        /// <summary>
        /// 分页查询
        /// </summary>
        /// <param name="query"></param>
        /// <param name="pagination"></param>
        /// <returns></returns>
        public IEnumerable<Model.Info_Content> SelectModelPage(Infrastructure.Query.Query query, Infrastructure.Query.Pagination pagination)
        {
            throw new NotImplementedException();
        }

        /// <summary>
        /// 单个查询
        /// </summary>
        /// <param name="query"></param>
        /// <returns></returns>
        public IEnumerable<Model.Info_Content> SelectAllModel(Infrastructure.Query.Query query)
        {
            throw new NotImplementedException();
        }

        /// <summary>
        /// 根据分类编号分页查询
        /// </summary>
        /// <param name="pagination"></param>
        /// <param name="TypeId"></param>
        /// <param name="SortId"></param>
        /// <param name="Title"></param>
        /// <param name="OrderString"></param>
        /// <returns></returns>
        public IEnumerable<Model.Info_Content> SelectModelPage(Infrastructure.Query.Pagination pagination, Guid FirmId, int? TypeId, int? SortId, string Title, string OrderString)
        {
            if (SortId == null || SortId <= 0)
                return null;//错误数据返会空 
            try
            {
                Info_SortDAL dal_Info_SortDAL = new Info_SortDAL();

                string SelectRow = " a.*,b.Title as TypeName ";

                string condtion = " 1=1 ";

                if (TypeId > 0)
                    condtion += " and TypeId='" + TypeId + "' ";

                if (SortId > 0)
                {
                    string keyids = dal_Info_SortDAL.GetKeyidsByParentId(SortId);
                    condtion += " and SortID in (" + keyids + ") ";
                }

                if (Guid.Empty != FirmId)
                    condtion += " and MemberId = '" + FirmId + "' ";

                if (!string.IsNullOrEmpty(Title))
                    condtion += " and a.Title like '%" + Title + "%'";

                string test = "select " + SelectRow + " from Info_Content where" + condtion;

                IList<Info_Content> result = _dataBase.SelectModelPage<Model.Info_Content>(pagination, SelectRow, " Info_Content as a left join  Info_Sort as b on a.SortID = b.Keyid", ("a." + (OrderString.Replace("OrderNum", "a.OrderNum"))).Replace("a.a.", "a."), OrderString, condtion) as IList<Info_Content>;//执行查询
                return null == result ? null : result;//返回结果
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 根据分类查询全部信息
        /// </summary>
        /// <param name="SortId"></param>
        /// <param name="Num"></param>
        /// <returns></returns>
        public IEnumerable<Model.Info_Content> SelectListBySortId(Guid Bussinessid, int? Num)
        {
            if (Bussinessid == null)
                return null;//错误数据返会空 
            try
            {
                IList<Info_Content> result = _dataBase.SelectModel<Info_Content>(" top " + Num + " *", "Info_Content", string.Format(" MemberId='{0}' and SortID<>415", Bussinessid)) as IList<Info_Content>;//执行查询

                return result;//返回结果
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 根据分类查询全部信息
        /// </summary>
        /// <param name="SortId"></param>
        /// <returns></returns>
        public IEnumerable<Model.Info_Content> SelectListBySortId(int? SortId)
        {
            if (SortId == null || SortId <= 0)
                return null;//错误数据返会空 
            try
            {
                IList<Info_Content> result = _dataBase.SelectModel<Info_Content>(" *", "Info_Content", string.Format(" SortID='{0}' ", SortId)) as IList<Info_Content>;//执行查询

                return result;//返回结果
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 根据分类编号,条数,标题,排序字段分页查询
        /// </summary>
        /// <param name="SortId"></param>
        /// <param name="Num"></param>
        /// <returns></returns>
        public IEnumerable<Model.Info_Content> SelectListByWhere(int? SortId, int? Num, bool IsHomeShow)
        {
            if (SortId == null || SortId <= 0)
                return null;//错误数据返会空 
            try
            {
                using (IDataReader i_IDataReader = _dataBase.QueryDataReader("sp_Info_Content_SelectListByWhere", CommandType.StoredProcedure, new SqlParameter("@Num", Num), new SqlParameter("@Keyid", SortId), new SqlParameter("@IsHomeShow", IsHomeShow)))
                {
                    IList<Info_Content> result = _dataBase.ReadDataToModel<Info_Content>(i_IDataReader) as IList<Info_Content>;//执行查询
                    return null == result ? null : result;//返回结果
                }
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 根据编号查询信息
        /// </summary>
        /// <param name="Keyid"></param>
        /// <returns></returns>
        public Model.Info_Content SelectModelBySortId(int? Keyid)
        {
            if (Keyid == null || Keyid <= 0)
                return null;//错误数据返会空 
            try
            {
                IList<Info_Content> result = _dataBase.SelectModel<Info_Content>("*", "Info_Content", string.Format(" Keyid='{0}' ", Keyid)) as IList<Info_Content>;//执行查询
                if (result != null && result.Count > 0)
                    return result[0];//返回结果
                else
                    return null;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
    }
}