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

namespace CY.SQLDAL
{
    public class FollowRecordInfoDAL : IFollowRecordInfoDAL
    {
        private Database _dataBase = null;

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

        public IList<Model.Inquiry_FollowRecordInfo> GetModeList(int recordId, Infrastructure.Query.Pagination pa)
        {
            string selectTarget = " a.*,b.Name AS FollowTypeName,c.Name AS IntentTypeName,d.Name as ResultStatusStr ";
            string fromSouce = @" Inquiry_FollowRecordInfo a INNER JOIN Sys_Dictionary b
                                    ON a.FollowTypeId=b.MeanValue AND b.DicType='跟单方式'
                                    INNER JOIN Sys_Dictionary c ON a.IntentTypeId=c.MeanValue
                                    AND c.DicType='成交意向'
                                    inner join Sys_Dictionary d on a.resultStatus=d.meanvalue and d.DicType='成交状态' 
                                    where a.RecordId=" + recordId;
            return _dataBase.SelectModelPage<Model.Inquiry_FollowRecordInfo>(pa, selectTarget, fromSouce, "a.FollowTime desc", "FollowTime desc ", string.Empty);
        }

        public bool InserModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.Inquiry_FollowRecordInfo trueModel = model as Model.Inquiry_FollowRecordInfo;
            if (trueModel == null)
            {
                return false;
            }
            SqlParameter customerPricePar = null;
            if (trueModel.CustomerPrice.HasValue)
            {
                customerPricePar = new SqlParameter("@CustomerPrice", trueModel.CustomerPrice.Value);
            }
            else
            {
                customerPricePar = new SqlParameter("@CustomerPrice", DBNull.Value);
            }
            SqlParameter[] parameters = {
					new SqlParameter("@FollowPerson", SqlDbType.VarChar,100),
					new SqlParameter("@FollowTypeId", SqlDbType.Int,4),
					new SqlParameter("@IntentTypeId", SqlDbType.Int,4),
					new SqlParameter("@FollowRecord", SqlDbType.VarChar,400),
					new SqlParameter("@FollowTime", SqlDbType.DateTime),
                    new SqlParameter("@RecordId", SqlDbType.Int,4),
                    new SqlParameter("@ResultStatus", SqlDbType.Int,4),
                    customerPricePar
            };
            parameters[0].Value = trueModel.FollowPerson;
            parameters[1].Value = trueModel.FollowTypeId;
            parameters[2].Value = trueModel.IntentTypeId;
            parameters[3].Value = trueModel.FollowRecord;
            parameters[4].Value = trueModel.FollowTime;
            parameters[5].Value = trueModel.RecordId;
            parameters[6].Value = trueModel.ResultStatus;
            try
            {
                _dataBase.Query("Inquiry_FollowRecordInfo_ADD", CommandType.StoredProcedure, parameters);
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        public bool UpdateModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.Inquiry_FollowRecordInfo trueModel = model as Model.Inquiry_FollowRecordInfo;
            if (trueModel == null)
            {
                return false;
            }
            SqlParameter customerPricePar = null;
            if (trueModel.CustomerPrice.HasValue)
            {
                customerPricePar = new SqlParameter("@CustomerPrice", trueModel.CustomerPrice.Value);
            }
            else
            {
                customerPricePar = new SqlParameter("@CustomerPrice", DBNull.Value);
            }
            SqlParameter[] parameters = {
					new SqlParameter("@FollowPerson", SqlDbType.VarChar,100),
					new SqlParameter("@FollowTypeId", SqlDbType.Int,4),
					new SqlParameter("@IntentTypeId", SqlDbType.Int,4),
					new SqlParameter("@FollowRecord", SqlDbType.VarChar,400),
					new SqlParameter("@FollowTime", SqlDbType.DateTime),
                    new SqlParameter("@KeyId", SqlDbType.Int,4),
                    new SqlParameter("@RecordId", SqlDbType.Int,4),
                    new SqlParameter("@ResultStatus", SqlDbType.Int,4),
                    customerPricePar
            };
            parameters[0].Value = trueModel.FollowPerson;
            parameters[1].Value = trueModel.FollowTypeId;
            parameters[2].Value = trueModel.IntentTypeId;
            parameters[3].Value = trueModel.FollowRecord;
            parameters[4].Value = trueModel.FollowTime;
            parameters[5].Value = trueModel.KeyId;
            parameters[6].Value = trueModel.RecordId;
            parameters[7].Value = trueModel.ResultStatus;
            try
            {
                _dataBase.Query("Inquiry_FollowRecordInfo_Update", CommandType.StoredProcedure, parameters);
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        public bool DeleteModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.Inquiry_FollowRecordInfo trueModel = model as Model.Inquiry_FollowRecordInfo;
            if (trueModel == null)
            {
                return false;
            }
            SqlParameter[] parameters = {
                    new SqlParameter("@KeyId", SqlDbType.Int,4)
            };
            parameters[0].Value = trueModel.KeyId;
            try
            {
                _dataBase.Query("Inquiry_FollowRecordInfo_Delete", CommandType.StoredProcedure, parameters);
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        public bool DeleteModel(int keyId)
        {
            SqlParameter[] parameters = {
                    new SqlParameter("@KeyId", SqlDbType.Int,4)
            };
            parameters[0].Value = keyId;
            try
            {
                _dataBase.Query("Inquiry_FollowRecordInfo_Delete", CommandType.StoredProcedure, parameters);
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        /// <summary>
        /// 批量删除记录
        /// </summary>
        /// <param name="keyIdList"></param>
        /// <returns></returns>
        public bool DeleteModelList(List<int> keyIdList)
        {
            if (keyIdList == null || keyIdList.Count == 0)
            {
                return true;
            }
            bool isSuccess = true;
            using (TransactionScope scope = new TransactionScope())
            {
                foreach (int keyId in keyIdList)
                {
                    isSuccess = DeleteModel(keyId);
                    if (!isSuccess)
                        break;
                }
                if (isSuccess)
                    scope.Complete();
            }
            return isSuccess;
        }
    }
}