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

namespace CY.SQLDAL
{
    public class RecoverySysInquiryDataDAL : IRecoverySysInquiryDataDAL
    {
        private Database _dataBase = null;

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

        public bool RecoverySysInquiryData(InquiryCondition condition,bool isAllRecovery)
        {
            bool isSuccess = true;
            CommonInquiryHelper commHelper = new CommonInquiryHelper(_dataBase);
            OA_CorporateClientsDAL corporateClientsDAL = new OA_CorporateClientsDAL(_dataBase);
            using (TransactionScope scope = new TransactionScope())
            {
                if (condition.CustomerId == Guid.Empty) //厂商恢复系统数据
                {
                    if (condition.InquiryId != Guid.Parse(UtilConst.AdminFirmId))
                    {
                        isSuccess = commHelper.DelInquiryParameterData(condition.InquiryId);
                        if (isSuccess)
                            isSuccess = UpdateInquiryIdByFirm(condition.FirmId);
                    }
                    if (isSuccess)
                    {
                        IEnumerable<OA_CorporateClients> clients = corporateClientsDAL.SelectListByFirmId(condition.FirmId);
                        foreach (OA_CorporateClients client in clients)
                        {
                            if (!isAllRecovery)
                            {
                                if (client.InquiryId == client.Keyid)
                                {
                                    continue;
                                }
                            }
                            if (client.InquiryId != Guid.Parse(UtilConst.AdminFirmId))
                            {
                                isSuccess = commHelper.DelInquiryParameterData(client.InquiryId);
                                if (!isSuccess)
                                    break;
                                else
                                {
                                    isSuccess = UpdateInquiryIdByCustomerToSys(client.Keyid);
                                    if (!isSuccess)
                                        break;
                                }
                            }
                        }
                    }
                }
                else //客户恢复到厂商数据
                {
                    if (condition.InquiryId == condition.CustomerId) 
                    {
                        isSuccess = commHelper.DelInquiryParameterData(condition.InquiryId);
                        if (isSuccess)
                        {
                            isSuccess = UpdateInquiryIdByCustomerToFirm(condition.CustomerId, condition.FirmId);
                        }
                    }
                }
                if (isSuccess)
                    scope.Complete();
            }
            return isSuccess;
        }

        /// <summary>
        /// 修改厂商的询价参数Id为厂商的询价参数
        /// </summary>
        /// <param name="customerd"></param>
        /// <param name="firmId"></param>
        /// <returns></returns>
        public bool UpdateInquiryIdByCustomerToFirm(Guid customerd, Guid firmId)
        {
            bool isSuccess = true;
            try
            {
                string sqlStr = string.Empty;
                Guid firmInquiryId = Guid.Empty;
                EC_MemberBasicDAL memberBasicDAL = new EC_MemberBasicDAL(_dataBase);
                EC_MemberBasic memberBasic = memberBasicDAL.SelectModleByMemberId(firmId);
                firmInquiryId = memberBasic.InquiryId;
                sqlStr = @"UPDATE dbo.OA_CorporateClients SET InquiryId=@firmInquiryId WHERE keyid=@customerd";
                SqlParameter[] pars = new SqlParameter[]{
                    new SqlParameter("@firmInquiryId",SqlDbType.UniqueIdentifier,16),
                    new SqlParameter("@customerd",SqlDbType.UniqueIdentifier,16),
                };
                pars[0].Value = firmInquiryId;
                pars[1].Value = customerd;
                isSuccess = (_dataBase.ExecuteSql(sqlStr, pars) > 0);
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return isSuccess;
        }

        //修改厂商的询价参数Id为系统ID
        public bool UpdateInquiryIdByCustomerToSys(Guid customerd)
        {
            bool isSuccess = true;
            try
            {
                string sqlStr = @"UPDATE dbo.OA_CorporateClients SET InquiryId=@adminId WHERE keyid=@customerd";
                SqlParameter[] pars = new SqlParameter[]{
                    new SqlParameter("@adminId",SqlDbType.UniqueIdentifier,16),
                    new SqlParameter("@customerd",SqlDbType.UniqueIdentifier,16),
                };
                pars[0].Value = Guid.Parse(UtilConst.AdminFirmId);
                pars[1].Value = customerd;
                isSuccess = (_dataBase.ExecuteSql(sqlStr, pars) > 0);
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return isSuccess;
        }

        /// <summary>
        /// 修改厂商的询价参数Id为系统ID
        /// </summary>
        /// <param name="firmId"></param>
        /// <returns></returns>
        public bool UpdateInquiryIdByFirm(Guid firmId)
        {
            bool isSuccess = true;
            try
            {
                string sqlStr = @"UPDATE dbo.EC_MemberBasic SET InquiryId=@adminId WHERE MemberId=@firmId";
                SqlParameter[] pars = new SqlParameter[]{
                    new SqlParameter("@adminId",SqlDbType.UniqueIdentifier,16),
                    new SqlParameter("@firmId",SqlDbType.UniqueIdentifier,16),
                };
                pars[0].Value = Guid.Parse(UtilConst.AdminFirmId);
                pars[1].Value = firmId;
                isSuccess = (_dataBase.ExecuteSql(sqlStr,pars)>0);
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return isSuccess;
        }
    }
}