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;
|
using System.Transactions;
|
|
namespace CY.SQLDAL
|
{
|
public class EC_SellerBusinessLimitsDAL : IEC_SellerBusinessLimitsDAL
|
{
|
|
private Database _dataBase = null;
|
|
|
|
private SysInquiry_PrintingTypeDAL _sysInquiry_PrintingTypeDAL = null;
|
|
public EC_SellerBusinessLimitsDAL()
|
{
|
_dataBase = new Database();
|
_sysInquiry_PrintingTypeDAL = new SysInquiry_PrintingTypeDAL();
|
}
|
|
public EC_SellerBusinessLimitsDAL(Database dataBase)
|
{
|
_dataBase = dataBase;
|
_sysInquiry_PrintingTypeDAL = new SysInquiry_PrintingTypeDAL();
|
}
|
|
/// <summary>
|
/// 新增
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public bool InserModel(Infrastructure.Domain.IAggregateRoot model)
|
{
|
Model.EC_SellerBusinessLimits trueModel = model as Model.EC_SellerBusinessLimits;
|
if (trueModel == null)
|
{
|
return false;
|
}
|
SysInquiry_PrintingTypeDAL _printingTypeDAL = new SysInquiry_PrintingTypeDAL();
|
SysInquiry_PrintingType _printModel = _printingTypeDAL.GetModelById(trueModel.BusinessId.Value);
|
trueModel.JoinFlag = _printModel.JoinFlag;
|
trueModel.SpecialFlag = _printModel.SpecialFlag;
|
|
IList<SqlParameter> sqlParms = new List<SqlParameter>()
|
{
|
new SqlParameter("@SellerId",trueModel.SellerId),
|
new SqlParameter("@BusinessId",trueModel.BusinessId),
|
new SqlParameter("@JoinFlag",trueModel.JoinFlag),
|
new SqlParameter("@SpecialFlag",trueModel.SpecialFlag),
|
new SqlParameter("@Status",trueModel.Status),
|
};
|
try
|
{
|
_dataBase.Query("sp_EC_SellerBusinessLimits_Insert", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
return true;
|
//string sqlStr=string.Empty;
|
//sqlStr=" INSERT INTO EC_SellerBusinessLimits ";
|
//sqlStr += " SELECT '{0}',KeyId,joinFlag,specialFlag,0 FROM dbo.SysInquiry_PrintingType WHERE ParentId<>0 AND Status=1";
|
//sqlStr = string.Format(sqlStr, trueModel.SellerId.ToString());
|
//try
|
//{
|
// _dataBase.Query(sqlStr,CommandType.Text,null);
|
//}
|
//catch(Exception ex)
|
//{
|
// return false;
|
//}
|
//return true;
|
}
|
|
/// <summary>
|
/// 修改
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public bool UpdateModel(Infrastructure.Domain.IAggregateRoot model)
|
{
|
Model.EC_SellerBusinessLimits trueModel = model as Model.EC_SellerBusinessLimits;
|
if (trueModel == null)
|
{
|
return false;
|
}
|
IList<SqlParameter> sqlParms = new List<SqlParameter>()
|
{
|
new SqlParameter("@BusinessId",trueModel.BusinessId),
|
new SqlParameter("@SellerId",trueModel.SellerId),
|
new SqlParameter("@Status",trueModel.Status)
|
};
|
try
|
{
|
_dataBase.Query("EC_SellerBusinessLimits_Update", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
return true;
|
}
|
|
public bool UpdateModelDetail(EC_SellerBusinessLimits model)
|
{
|
if (model == null)
|
return false;
|
IList<SqlParameter> sqlParms = new List<SqlParameter>()
|
{
|
new SqlParameter("@BusinessId",model.BusinessId),
|
new SqlParameter("@SellerId",model.SellerId),
|
new SqlParameter("@JoinFlag",model.JoinFlag),
|
new SqlParameter("@SpecialFlag",model.SpecialFlag)
|
};
|
try
|
{
|
_dataBase.Query("EC_SellerBusinessLimitsDetail_Update", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
return true;
|
}
|
|
/// <summary>
|
/// 修改
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public bool UpdateALL(Guid firmId)
|
{
|
IList<SqlParameter> sqlParms = new List<SqlParameter>()
|
{
|
new SqlParameter("@SellerId",firmId)
|
};
|
try
|
{
|
_dataBase.Query("EC_SellerBusinessLimits_UpdateAll", 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.EC_SellerBusinessLimits trueModel = model as Model.EC_SellerBusinessLimits;
|
if (trueModel == null)
|
{
|
return false;
|
}
|
IList<SqlParameter> sqlParms = new List<SqlParameter>()
|
{
|
new SqlParameter("@BusinessId",trueModel.BusinessId)
|
};
|
try
|
{
|
_dataBase.Query("sp_EC_SellerBusinessLimits_DeleteRow", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
return true;
|
}
|
|
public bool DeleteModel(Guid sellerId)
|
{
|
IList<SqlParameter> sqlParms = new List<SqlParameter>()
|
{
|
new SqlParameter("@SellerId",sellerId)
|
};
|
try
|
{
|
_dataBase.Query("sp_EC_SellerBusinessLimits_DeleteBySellerId", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
return true;
|
}
|
|
public IList<Model.SysInquiry_PrintingType> GetBusinessRangeByFirmId(Guid firmId)
|
{
|
string condition = string.Empty;
|
condition = " SellerId='" + firmId.ToString() + "' and Status='true' ";
|
IList<EC_SellerBusinessLimits> limitList = _dataBase.SelectModel<EC_SellerBusinessLimits>("*", "EC_SellerBusinessLimits", condition);
|
IList<SysInquiry_PrintingType> list = new List<SysInquiry_PrintingType>();
|
foreach (EC_SellerBusinessLimits limitModel in limitList)
|
{
|
SysInquiry_PrintingType model = _sysInquiry_PrintingTypeDAL.GetModelById(limitModel.BusinessId.Value);
|
if (model != null)
|
list.Add(model);
|
}
|
return list;
|
}
|
|
public bool SaveBusinessRangeByFirmId(IList<Model.EC_SellerBusinessLimits> list)
|
{
|
bool isSuccess = true;
|
|
if (list != null && list.Count > 0)
|
{
|
//EC_SellerBusinessLimits m = list[0];
|
//if (!IsExist(m.SellerId))
|
//{
|
// isSuccess = InserModel(m);
|
|
//}
|
////isSuccess = UpdateALL(m.SellerId);
|
//if (isSuccess)
|
//{
|
// foreach (EC_SellerBusinessLimits model in list)
|
// {
|
// isSuccess = UpdateModel(model);
|
// if (!isSuccess)
|
// break;
|
// }
|
//}
|
EC_SellerBusinessLimits m = list[0];
|
Guid sellerId=m.SellerId;
|
isSuccess=DeleteModel(sellerId);
|
if (isSuccess)
|
{
|
foreach (EC_SellerBusinessLimits model in list)
|
{
|
isSuccess = InserModel(model);
|
if (!isSuccess)
|
break;
|
}
|
if (isSuccess)
|
{
|
if (IsExistsFastSetByFirm(sellerId))
|
{
|
isSuccess = DeleteFastSetByFirm(sellerId);
|
if (isSuccess)
|
{
|
isSuccess = InsertFastSetByFirm(sellerId);
|
}
|
}
|
|
if (isSuccess)
|
{
|
isSuccess = InsertFastSetByCustomer(sellerId);
|
}
|
}
|
}
|
}
|
return isSuccess;
|
}
|
|
/// <summary>
|
/// 判断厂商是否保存了快速设置
|
/// </summary>
|
/// <param name="firmId"></param>
|
/// <returns></returns>
|
private bool IsExistsFastSetByFirm(Guid firmId)
|
{
|
bool isSussess = false;
|
string sqlStr=@"SELECT * FROM inquiry_FastSetByFirm WHERE FirmId=@FirmId";
|
SqlParameter par = new SqlParameter("@FirmId",firmId.ToString());
|
DataTable dt=_dataBase.QueryDataTable(sqlStr,CommandType.Text,par);
|
if(dt!=null&&dt.Rows.Count>0)
|
{
|
isSussess=true;
|
}
|
return isSussess;
|
}
|
|
/// <summary>
|
/// 判断厂商的客户是否保存了快速设置,有就返回客户ID列表
|
/// </summary>
|
/// <param name="firmId"></param>
|
/// <returns></returns>
|
private bool IsExistsFastSetByCustomer(Guid firmId,IList<string> CustomerIds)
|
{
|
bool isSussess = false;
|
string sqlStr = @"SELECT DISTINCT CustomerId FROM inquiry_FastSetByFirm WHERE FirmId=@FirmId and CustomerId is not null";
|
SqlParameter par = new SqlParameter("@FirmId", firmId.ToString());
|
DataTable dt = _dataBase.QueryDataTable(sqlStr, CommandType.Text, par);
|
if (dt != null && dt.Rows.Count > 0)
|
{
|
isSussess = true;
|
foreach (DataRow dr in dt.Rows)
|
{
|
CustomerIds.Add(dr["CustomerId"].ToString());
|
}
|
|
}
|
return isSussess;
|
}
|
|
/// <summary>
|
/// 移除没有权限的快速设置
|
/// </summary>
|
/// <param name="firmId"></param>
|
/// <returns></returns>
|
private bool DeleteFastSetByFirm(Guid firmId)
|
{
|
bool isSussess = true;
|
string sqlStr = @"DELETE inquiry_FastSetByFirm WHERE FirmId=@FirmId AND PrintTypeId NOT IN (SELECT BusinessId FROM EC_SellerBusinessLimits WHERE SellerId=@FirmId)";
|
SqlParameter par = new SqlParameter("@FirmId",firmId.ToString());
|
try
|
{
|
int i= _dataBase.ExecuteSql(sqlStr,par);
|
if (i > 0)
|
{
|
isSussess = true;
|
}
|
}
|
catch(Exception ex)
|
{
|
isSussess = false;
|
}
|
return isSussess;
|
}
|
|
/// <summary>
|
/// 给厂商新增有权限的快速设置数据
|
/// </summary>
|
/// <param name="firmId"></param>
|
/// <returns></returns>
|
private bool InsertFastSetByFirm(Guid firmId)
|
{
|
bool isSussess = true;
|
string sqlStr = @"INSERT INTO inquiry_FastSetByFirm
|
SELECT @FirmId,NULL,100,BusinessId
|
FROM EC_SellerBusinessLimits
|
WHERE SellerId=@FirmId AND BusinessId NOT IN (
|
SELECT PrintTypeId FROM inquiry_FastSetByFirm WHERE FirmId=@FirmId AND CustomerId IS NULL
|
)";
|
SqlParameter par = new SqlParameter("@FirmId", firmId.ToString());
|
try
|
{
|
int i = _dataBase.ExecuteSql(sqlStr, par);
|
if (i > 0)
|
{
|
isSussess = true;
|
}
|
}
|
catch(Exception ex)
|
{
|
isSussess = false;
|
}
|
return isSussess;
|
}
|
|
/// <summary>
|
/// 给已保存快速设置的客户新增有权限的快速设置数据
|
/// </summary>
|
/// <param name="firmId"></param>
|
/// <returns></returns>
|
private bool InsertFastSetByCustomer(Guid firmId)
|
{
|
bool isSussess = true;
|
IList<string> CustomerIds = new List<string>();
|
if (IsExistsFastSetByCustomer(firmId, CustomerIds))
|
{
|
try
|
{
|
foreach (string customerId in CustomerIds)
|
{
|
string sqlStr = @"INSERT INTO inquiry_FastSetByFirm
|
SELECT @FirmId,@CutomerId,100,BusinessId
|
FROM EC_SellerBusinessLimits
|
WHERE SellerId=@FirmId AND BusinessId NOT IN (
|
SELECT PrintTypeId FROM inquiry_FastSetByFirm WHERE FirmId=@FirmId
|
AND CustomerId=@CutomerId
|
)";
|
SqlParameter[] pars = new SqlParameter[]{
|
new SqlParameter("@FirmId",firmId.ToString()),
|
new SqlParameter("@CutomerId",customerId),
|
};
|
int i = _dataBase.ExecuteSql(sqlStr, pars);
|
if (i > 0)
|
{
|
isSussess = true;
|
}
|
}
|
}
|
catch(Exception ex)
|
{
|
isSussess = false;
|
}
|
}
|
else
|
{
|
isSussess = true;
|
}
|
return isSussess;
|
}
|
|
/// <summary>
|
/// 判断厂商是否有数据
|
/// </summary>
|
/// <param name="firmId"></param>
|
/// <returns></returns>
|
public bool IsExist(Guid firmId)
|
{
|
string condition = string.Empty;
|
condition = " SellerId='" + firmId.ToString() + "' ";
|
IList<EC_SellerBusinessLimits> limitList = _dataBase.SelectModel<EC_SellerBusinessLimits>("*", "EC_SellerBusinessLimits", condition);
|
if (limitList != null && limitList.Count > 0)
|
{
|
return true;
|
}
|
else
|
{
|
return false;
|
}
|
}
|
|
|
/// <summary>
|
/// 根据厂商Id获取其业务范围明细
|
/// </summary>
|
/// <param name="firmId"></param>
|
/// <returns></returns>
|
public IList<EC_SellerBusinessLimits> GetBusinessRangeDetaiByFirmId(Guid firmId)
|
{
|
string condition = string.Empty;
|
condition = " SellerId='" + firmId.ToString() + "' and status='true'";
|
IList<EC_SellerBusinessLimits> limitList = _dataBase.SelectModel<EC_SellerBusinessLimits>("*", "EC_SellerBusinessLimits", condition);
|
return limitList;
|
}
|
|
/// <summary>
|
/// 保存厂商设置的业务范围明细
|
/// </summary>
|
/// <param name="list"></param>
|
/// <returns></returns>
|
public bool SaveBusinessRangeDetailByFirmId(IList<EC_SellerBusinessLimits> list)
|
{
|
bool isSuccess = true;
|
using (TransactionScope scope = new TransactionScope())
|
{
|
foreach (EC_SellerBusinessLimits model in list)
|
{
|
isSuccess = UpdateModelDetail(model);
|
if (!isSuccess)
|
break;
|
}
|
if (isSuccess)
|
scope.Complete();
|
}
|
return isSuccess;
|
}
|
}
|
}
|
