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 Integrity_ComplainanInfoDAL : IIntegrity_ComplainanInfoDAL
    {
        private Database _dataBase = null;

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

        /// <summary>
        /// 新增
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool InserModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.Integrity_ComplainanInfo trueModel = model as Model.Integrity_ComplainanInfo;
            if (trueModel == null)
            {
                return false;
            }
            SqlParameter orderIdPar = null;
            if (trueModel.OrderId.HasValue)
            {
                orderIdPar = new SqlParameter("@OrderId", trueModel.OrderId);
            }
            else
            {
                orderIdPar = new SqlParameter("@OrderId", DBNull.Value);
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                new SqlParameter("@RespondentId",trueModel.RespondentId),
					new SqlParameter("@ComplainantId",trueModel.ComplainantId),
					new SqlParameter("@OrderCode",trueModel.OrderCode),
					new SqlParameter("@ComplaintsReason",trueModel.ComplaintsReason),
					new SqlParameter("@ComplaintsStatusId",trueModel.ComplaintsStatusId),
					new SqlParameter("@ComplaintsTypeId",trueModel.ComplaintsTypeId),
					new SqlParameter("@ComplaintsTime",trueModel.ComplaintsTime),
                    new SqlParameter("@LastUpdateTime",trueModel.LastUpdateTime),
                    orderIdPar
            };
            try
            {
                _dataBase.Query("sp_Integrity_ComplainanInfo_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.Integrity_ComplainanInfo trueModel = model as Model.Integrity_ComplainanInfo;
            if (trueModel == null)
            {
                return false;
            }
            SqlParameter auditTimePar = null;
            if (trueModel.AuditTime.HasValue)
            {
                auditTimePar = new SqlParameter("@AuditTime", trueModel.AuditTime.Value);
            }
            else
            {
                auditTimePar = new SqlParameter("@AuditTime", DBNull.Value);
            }
            SqlParameter handleTimePar = null;
            if (trueModel.HandleTime.HasValue)
            {
                handleTimePar = new SqlParameter("@HandleTime", trueModel.HandleTime.Value);
            }
            else
            {
                handleTimePar = new SqlParameter("@HandleTime", DBNull.Value);
            }
            SqlParameter canclTimePar = null;
            if (trueModel.CanclTime.HasValue)
            {
                canclTimePar = new SqlParameter("@CanclTime", trueModel.CanclTime.Value);
            }
            else
            {
                canclTimePar = new SqlParameter("@CanclTime", DBNull.Value);
            }
            SqlParameter reciveTimePar = null;
            if (trueModel.ReciveTime.HasValue)
            {
                reciveTimePar = new SqlParameter("@ReciveTime", trueModel.ReciveTime.Value);
            }
            else
            {
                reciveTimePar = new SqlParameter("@ReciveTime", DBNull.Value);
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {   new SqlParameter("@Keyid",trueModel.Keyid),
					new SqlParameter("@ComplaintsStatusId",trueModel.ComplaintsStatusId),
					new SqlParameter("@ProcessingResults",trueModel.ProcessingResults),
					new SqlParameter("@HandlePeople",trueModel.HandlePeople),
					new SqlParameter("@AuditPeople",trueModel.AuditPeople),
                    new SqlParameter("@RecivePeople",trueModel.RecivePeople),
                    auditTimePar,
					handleTimePar,
                    canclTimePar,
                    reciveTimePar,
                    new SqlParameter("@LastUpdateTime",trueModel.LastUpdateTime)
            };
            try
            {
                _dataBase.Query("sp_Integrity_ComplainanInfo_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.Integrity_ComplainanInfo trueModel = model as Model.Integrity_ComplainanInfo;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                new SqlParameter("@Keyid",trueModel.Keyid)
            };
            try
            {
                _dataBase.Query("sp_Integrity_ComplainanInfo_DeleteRow", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        public IEnumerable<Model.Integrity_ComplainanInfo> SelectModelPageByFirm(int complaintsTypeId, string respondentName, string orderCode, int complaintsStatusId, Guid memberId, Infrastructure.Query.Pagination pagination)
        {
            string selectTarget = @" t.* ";
            string fromSouce = @" ( 
                                SELECT a.*,b.Name AS RespondentName,c.Name AS ComplaintsStatus,d.Name as ComplaintsTypeName
                                FROM Integrity_ComplainanInfo a INNER JOIN dbo.EC_MemberBasic b
                                ON a.RespondentId=b.MemberId INNER JOIN Sys_Dictionary c ON a.ComplaintsStatusId=c.MeanValue AND c.DicType='投诉状态'
                                INNER JOIN Sys_Dictionary d ON a.ComplaintsTypeId=d.MeanValue AND d.DicType='投诉类型'
                                where a.ComplainantId='" + memberId.ToString() + "' ";

            if (complaintsTypeId != -1)
            {
                fromSouce += " and a.complaintsTypeId='" + complaintsTypeId + "'";
            }
            if (!string.IsNullOrEmpty(respondentName))
            {
                fromSouce += " and b.Name like '%" + respondentName + "%'";
            }
            if (!string.IsNullOrEmpty(orderCode))
            {
                fromSouce += " and a.orderCode like '%" + orderCode + "%'";
            }

            if (complaintsStatusId != -1)
            {
                fromSouce += " and a.complaintsStatusId=" + complaintsStatusId;
            }
            fromSouce += " ) as t";
            return _dataBase.SelectModelPage<Integrity_ComplainanInfo>(pagination, selectTarget, fromSouce, "t.LastUpdateTime desc ", "LastUpdateTime desc ");
        }

        public IEnumerable<Model.Integrity_ComplainanInfo> SelectModelPageBysys(int complaintsTypeId, string respondentName, string orderCode, int complaintsStatusId, Infrastructure.Query.Pagination pagination)
        {
            string selectTarget = @" t.* ";
            string fromSouce = @" ( 
                                SELECT a.*,b.Name AS RespondentName,c.Name AS ComplaintsStatus,d.Name as ComplaintsTypeName,e.Name as ComplainantName
                                FROM Integrity_ComplainanInfo a INNER JOIN dbo.EC_MemberBasic b
                                ON a.RespondentId=b.MemberId 
                                INNER JOIN dbo.EC_MemberBasic e
                                ON a.ComplainantId=e.MemberId 
                                INNER JOIN Sys_Dictionary c ON a.ComplaintsStatusId=c.MeanValue AND c.DicType='投诉状态'
                                INNER JOIN Sys_Dictionary d ON a.ComplaintsTypeId=d.MeanValue AND d.DicType='投诉类型'
                                where 1=1 ";

            if (complaintsTypeId != -1)
            {
                fromSouce += " and a.complaintsTypeId='" + complaintsTypeId + "'";
            }
            if (!string.IsNullOrEmpty(respondentName))
            {
                fromSouce += " and b.Name like '%" + respondentName + "%'";
            }
            if (!string.IsNullOrEmpty(orderCode))
            {
                fromSouce += " and a.orderCode like '%" + orderCode + "%'";
            }

            if (complaintsStatusId != -1)
            {
                fromSouce += " and a.complaintsStatusId=" + complaintsStatusId;
            }
            fromSouce += " ) as t";
            return _dataBase.SelectModelPage<Integrity_ComplainanInfo>(pagination, selectTarget, fromSouce, "t.LastUpdateTime desc ", "LastUpdateTime desc ");
        }

        /// <summary>
        /// 根据keyId获取投诉实体
        /// </summary>
        /// <param name="keyId"></param>
        /// <returns></returns>
        public Integrity_ComplainanInfo GetModel(int keyId)
        {
            string selectTarget = " a.*,b.Name AS RespondentName,c.Name AS ComplaintsStatus,d.Name as ComplaintsTypeName,e.Name as ComplainantName ";
            string fromSouce = @" Integrity_ComplainanInfo a INNER JOIN dbo.EC_MemberBasic b
                                ON a.RespondentId=b.MemberId
                                INNER JOIN dbo.EC_MemberBasic e
                                ON a.ComplainantId=e.MemberId  
                                INNER JOIN Sys_Dictionary c ON a.ComplaintsStatusId=c.MeanValue AND c.DicType='投诉状态'
                                INNER JOIN Sys_Dictionary d ON a.ComplaintsTypeId=d.MeanValue AND d.DicType='投诉类型' ";
            string condition = string.Empty;
            condition = " a.KeyId=" + keyId;
            IList<Integrity_ComplainanInfo> result = _dataBase.SelectModel<Integrity_ComplainanInfo>(selectTarget, fromSouce, condition);
            return null == result || result.Count == 0 ? null : result[0];
        }
    }
}