You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
410 lines
21 KiB
410 lines
21 KiB
using BBWYB.Common.Extensions;
|
|
using BBWYB.Common.Log;
|
|
using BBWYB.Common.Models;
|
|
using BBWYB.Server.Model;
|
|
using BBWYB.Server.Model.Db;
|
|
using BBWYB.Server.Model.Dto;
|
|
using FreeSql;
|
|
using Yitter.IdGenerator;
|
|
|
|
namespace BBWYB.Server.Business
|
|
{
|
|
public class PurchaseSchemeBusiness : BaseBusiness, IDenpendency
|
|
{
|
|
private PurchaseProductAPIService purchaseProductAPIService;
|
|
|
|
public PurchaseSchemeBusiness(IFreeSql fsql, NLogManager nLogManager, IIdGenerator idGenerator, PurchaseProductAPIService purchaseProductAPIService) : base(fsql, nLogManager, idGenerator)
|
|
{
|
|
this.purchaseProductAPIService = purchaseProductAPIService;
|
|
}
|
|
|
|
private void ExtractNewPurchaser<T>(IList<T> purchaserSchemeList, IList<Purchaser> addPurchaserList) where T : InputPurchaseSchemeRequest
|
|
{
|
|
List<string> reqeustPurchaserIdList = new List<string>();
|
|
foreach (var scheme in purchaserSchemeList)
|
|
reqeustPurchaserIdList.AddRange(scheme.PurchaseSchemeProductList.Select(p => p.PurchaserId));
|
|
reqeustPurchaserIdList = reqeustPurchaserIdList.Distinct().ToList();
|
|
|
|
//var reqeustPurchaserIdList = purchaserSchemeList.Select(s => s.PurchaserId).Distinct().ToList();
|
|
var existPurchaserIdList = fsql.Select<Purchaser>().Where(p => reqeustPurchaserIdList.Contains(p.Id)).ToList(p => p.Id);
|
|
var newPurchaserIdList = reqeustPurchaserIdList.Except(existPurchaserIdList);
|
|
foreach (var scheme in purchaserSchemeList)
|
|
{
|
|
foreach (var ps in scheme.PurchaseSchemeProductList)
|
|
{
|
|
if (newPurchaserIdList.Any(p => p == ps.PurchaserId) && !addPurchaserList.Any(p => p.Id == ps.PurchaserId))
|
|
{
|
|
addPurchaserList.Add(new Purchaser()
|
|
{
|
|
Id = ps.PurchaserId,
|
|
Id2 = ps.PurchaserId2,
|
|
Name = ps.PurchaserName,
|
|
Location = ps.PurchaserLocation,
|
|
Platform = scheme.PurchasePlatform
|
|
});
|
|
}
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
public void EditPurchaseScheme(BatchCURDSchemeRequest batchCURDSchemeRequest)
|
|
{
|
|
if (batchCURDSchemeRequest.EditPurchaseSchemeList.Count == 0 &&
|
|
batchCURDSchemeRequest.AddPurchaseSchemeList.Count == 0)
|
|
throw new BusinessException("非法参数");
|
|
if (batchCURDSchemeRequest.AddPurchaseSchemeList.Any(ps => ps.PurchaseSchemeProductList.Any(pp => string.IsNullOrEmpty(pp.PurchaserId) ||
|
|
string.IsNullOrEmpty(pp.PurchaserName))))
|
|
throw new BusinessException("新增方案中有采购商Id/Name/Location为空");
|
|
|
|
if (batchCURDSchemeRequest.EditPurchaseSchemeList.Any(ps => ps.PurchaseSchemeProductList.Any(pp => string.IsNullOrEmpty(pp.PurchaserId) ||
|
|
string.IsNullOrEmpty(pp.PurchaserName))))
|
|
throw new BusinessException("编辑方案中有采购商Id/Name/Location为空");
|
|
|
|
List<PurchaseScheme> addPurchaseSchemeList = null;
|
|
List<PurchaseSchemeProduct> addPurchaseSchemeProductList = new List<PurchaseSchemeProduct>();
|
|
List<PurchaseSchemeProductSku> addPurchaseSchemeProductSkuList = new List<PurchaseSchemeProductSku>();
|
|
List<Purchaser> newPurchaserList = new List<Purchaser>();
|
|
List<long> deletePurchaseSchemeIdList = new List<long>();
|
|
|
|
#region 新增采购方案
|
|
if (batchCURDSchemeRequest.AddPurchaseSchemeList.Count > 0)
|
|
{
|
|
ExtractNewPurchaser(batchCURDSchemeRequest.AddPurchaseSchemeList, newPurchaserList);
|
|
|
|
addPurchaseSchemeList = batchCURDSchemeRequest.AddPurchaseSchemeList.Map<List<PurchaseScheme>>();
|
|
|
|
foreach (var scheme in addPurchaseSchemeList)
|
|
{
|
|
scheme.Id = idGenerator.NewLong();
|
|
scheme.CreateTime = DateTime.Now;
|
|
|
|
foreach (var purchaseProduct in scheme.PurchaseSchemeProductList)
|
|
{
|
|
purchaseProduct.Id = idGenerator.NewLong();
|
|
purchaseProduct.CreateTime = DateTime.Now;
|
|
purchaseProduct.SkuPurchaseSchemeId = scheme.Id;
|
|
foreach (var purchaseProductSku in purchaseProduct.PurchaseSchemeProductSkuList)
|
|
{
|
|
purchaseProductSku.Id = idGenerator.NewLong();
|
|
purchaseProductSku.CreateTime = DateTime.Now;
|
|
purchaseProductSku.SkuPurchaseSchemeId = scheme.Id;
|
|
}
|
|
addPurchaseSchemeProductSkuList.AddRange(purchaseProduct.PurchaseSchemeProductSkuList);
|
|
}
|
|
addPurchaseSchemeProductList.AddRange(scheme.PurchaseSchemeProductList);
|
|
}
|
|
}
|
|
#endregion
|
|
|
|
#region 更新采购方案
|
|
if (batchCURDSchemeRequest.EditPurchaseSchemeList.Count > 0)
|
|
{
|
|
//ExtractNewPurchaser(batchCURDSchemeRequest.EditPurchaseSchemeList, newPurchaserList);
|
|
deletePurchaseSchemeIdList.AddRange(batchCURDSchemeRequest.EditPurchaseSchemeList.Select(ps => ps.Id));
|
|
|
|
var editPurchaseSchemeList = batchCURDSchemeRequest.EditPurchaseSchemeList.Map<List<PurchaseScheme>>();
|
|
foreach (var scheme in editPurchaseSchemeList)
|
|
{
|
|
foreach (var purchaseProduct in scheme.PurchaseSchemeProductList)
|
|
{
|
|
purchaseProduct.Id = idGenerator.NewLong();
|
|
purchaseProduct.CreateTime = DateTime.Now;
|
|
purchaseProduct.SkuPurchaseSchemeId = scheme.Id;
|
|
foreach (var purchaseProductSku in purchaseProduct.PurchaseSchemeProductSkuList)
|
|
{
|
|
purchaseProductSku.Id = idGenerator.NewLong();
|
|
purchaseProductSku.CreateTime = DateTime.Now;
|
|
purchaseProductSku.SkuPurchaseSchemeId = scheme.Id;
|
|
}
|
|
addPurchaseSchemeProductSkuList.AddRange(purchaseProduct.PurchaseSchemeProductSkuList);
|
|
}
|
|
addPurchaseSchemeProductList.AddRange(scheme.PurchaseSchemeProductList);
|
|
}
|
|
}
|
|
#endregion
|
|
|
|
foreach (var purchaseProductSku in addPurchaseSchemeProductSkuList)
|
|
{
|
|
if (purchaseProductSku.PurchaseRatio == null)
|
|
purchaseProductSku.PurchaseRatio = 1;
|
|
}
|
|
|
|
fsql.Transaction(() =>
|
|
{
|
|
if (newPurchaserList.Count > 0)
|
|
fsql.Insert(newPurchaserList).ExecuteAffrows();
|
|
|
|
//更新，删除已存在的采购方案商品和Sku
|
|
if (deletePurchaseSchemeIdList.Count > 0)
|
|
{
|
|
fsql.Delete<PurchaseSchemeProduct>().Where(p => deletePurchaseSchemeIdList.Contains(p.SkuPurchaseSchemeId)).ExecuteAffrows();
|
|
fsql.Delete<PurchaseSchemeProductSku>().Where(p => deletePurchaseSchemeIdList.Contains(p.SkuPurchaseSchemeId)).ExecuteAffrows();
|
|
}
|
|
|
|
//新增
|
|
if (addPurchaseSchemeList != null && addPurchaseSchemeList.Count > 0)
|
|
fsql.Insert(addPurchaseSchemeList).ExecuteAffrows();
|
|
if (addPurchaseSchemeProductList.Count > 0)
|
|
fsql.Insert(addPurchaseSchemeProductList).ExecuteAffrows();
|
|
if (addPurchaseSchemeProductSkuList.Count > 0)
|
|
fsql.Insert(addPurchaseSchemeProductSkuList).ExecuteAffrows();
|
|
|
|
});
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取采购方案(不含采购配配件基本信息)
|
|
/// </summary>
|
|
/// <param name="querySchemeRequest"></param>
|
|
/// <returns></returns>
|
|
public IList<PurchaseSchemeResponse> GetPurchaseSchemeList(QuerySchemeRequest request)
|
|
{
|
|
var select = fsql.Select<PurchaseScheme>();
|
|
if (request.SchemeId != null && request.SchemeId != 0)
|
|
select = select.Where(ps => ps.Id == request.SchemeId);
|
|
else if (request.SchemeIdList != null && request.SchemeIdList.Count() > 0)
|
|
select = select.Where(ps => request.SchemeIdList.Contains(ps.Id));
|
|
else
|
|
{
|
|
select = select.WhereIf(request.ShopId != null && request.ShopId != 0, ps => ps.ShopId == request.ShopId)
|
|
.WhereIf(request.SkuIdList != null && request.SkuIdList.Count() > 0, ps => request.SkuIdList.Contains(ps.SkuId));
|
|
|
|
if (request.PurchasePlatform != null || !string.IsNullOrEmpty(request.PurchaserId))
|
|
{
|
|
//var childSelect = fsql.Select<PurchaseSchemeProduct, Purchaser>()
|
|
// .InnerJoin((psp, p) => psp.PurchaserId == p.Id)
|
|
// .WhereIf(request.PurchasePlatform != null, (psp, p) => p.Platform == request.PurchasePlatform)
|
|
// .WhereIf(!string.IsNullOrEmpty(request.PurchaserId), (psp, p) => psp.PurchaserId == request.PurchaserId);
|
|
//select = select.Where(ps => childSelect.Where((psp, p) => psp.SkuPurchaseSchemeId == ps.Id).Any());
|
|
|
|
select = select.Where(ps => fsql.Select<PurchaseSchemeProduct, Purchaser>()
|
|
.InnerJoin((psp, p) => psp.PurchaserId == p.Id)
|
|
.WhereIf(request.PurchasePlatform != null, (psp, p) => p.Platform == request.PurchasePlatform)
|
|
.WhereIf(!string.IsNullOrEmpty(request.PurchaserId), (psp, p) => psp.PurchaserId == request.PurchaserId)
|
|
.Where((psp, p) => psp.SkuPurchaseSchemeId == ps.Id).Any());
|
|
}
|
|
//.WhereIf(querySchemeRequest.PurchasePlatform != null, ps => ps.PurchasePlatform == querySchemeRequest.PurchasePlatform);
|
|
}
|
|
var sql = select.ToSql();
|
|
var purchaseSchemeList = select.ToList<PurchaseSchemeResponse>();
|
|
|
|
|
|
if (purchaseSchemeList.Count > 0)
|
|
{
|
|
var purchaseSchemeIdList = purchaseSchemeList.Select(p => p.Id).ToList();
|
|
|
|
var purchaseSchemeProductList = fsql.Select<PurchaseSchemeProduct, Purchaser>()
|
|
.InnerJoin((psp, p) => psp.PurchaserId == p.Id)
|
|
.Where((psp, p) => purchaseSchemeIdList.Contains(psp.SkuPurchaseSchemeId))
|
|
.ToList((psp, p) => new PurchaseSchemeProductResponse
|
|
{
|
|
CreateTime = psp.CreateTime,
|
|
Id = psp.Id,
|
|
ProductId = psp.ProductId,
|
|
PurchaseProductId = psp.PurchaseProductId,
|
|
PurchaseUrl = psp.PurchaseUrl,
|
|
SkuId = psp.SkuId,
|
|
SkuPurchaseSchemeId = psp.SkuPurchaseSchemeId,
|
|
PurchaserId = p.Id,
|
|
PurchaserId2 = p.Id2,
|
|
PurchaserLocation = p.Location,
|
|
PurchaserName = p.Name,
|
|
PurchasePlatform = p.Platform,
|
|
});
|
|
|
|
var purchaseSchemeProductSkuList = fsql.Select<PurchaseSchemeProductSku>().Where(p => purchaseSchemeIdList.Contains(p.SkuPurchaseSchemeId))
|
|
.ToList().Map<List<PurchaseSchemeProductSkuResponse>>();
|
|
|
|
foreach (var scheme in purchaseSchemeList)
|
|
{
|
|
var schemeProductList = purchaseSchemeProductList.Where(ps => ps.SkuPurchaseSchemeId == scheme.Id);
|
|
if (schemeProductList.Count() > 0)
|
|
{
|
|
scheme.PurchaseSchemeProductList.AddRange(schemeProductList);
|
|
foreach (var schemeProduct in schemeProductList)
|
|
{
|
|
var schemeProductSkuList = purchaseSchemeProductSkuList.Where(psk => psk.SkuPurchaseSchemeId == scheme.Id &&
|
|
psk.PurchaseProductId == schemeProduct.PurchaseProductId);
|
|
if (schemeProductSkuList.Count() > 0)
|
|
schemeProduct.PurchaseSchemeProductSkuList.AddRange(schemeProductSkuList);
|
|
}
|
|
}
|
|
|
|
#region 封装采购商
|
|
foreach (var schemeProduct in schemeProductList)
|
|
{
|
|
if (!scheme.PurchaserList.Any(p => p.Id == schemeProduct.PurchaserId))
|
|
{
|
|
scheme.PurchaserList.Add(new Purchaser()
|
|
{
|
|
Id = schemeProduct.PurchaserId,
|
|
Id2 = schemeProduct.PurchaserId2,
|
|
Location = schemeProduct.PurchaserLocation,
|
|
Name = schemeProduct.PurchaserName,
|
|
Platform = schemeProduct.PurchasePlatform
|
|
});
|
|
}
|
|
}
|
|
#endregion
|
|
}
|
|
}
|
|
return purchaseSchemeList;
|
|
}
|
|
|
|
public IList<PurchaseSchemeResponse> RefreshPurchaseScheme(RefreshSchemeRequest request)
|
|
{
|
|
var purchaseSchemeList = GetPurchaseSchemeList(new QuerySchemeRequest()
|
|
{
|
|
SchemeIdList = request.SchemeIdList
|
|
});
|
|
List<IUpdate<PurchaseScheme>> updatePurchaseSchemeList = new List<IUpdate<PurchaseScheme>>();
|
|
foreach (var purchaseScheme in purchaseSchemeList)
|
|
{
|
|
var amount = 0M;
|
|
var purchasePlatformGroups = purchaseScheme.PurchaseSchemeProductList.GroupBy(p => p.PurchasePlatform);
|
|
foreach (var purchasePlatformGroup in purchasePlatformGroups)
|
|
{
|
|
var purchaseProductIds = purchasePlatformGroup.Select(p => p.PurchaseProductId).ToArray();
|
|
var purchaseSkuIds = new List<string>();
|
|
foreach (var purchaseProduct in purchaseScheme.PurchaseSchemeProductList)
|
|
{
|
|
purchaseSkuIds.AddRange(purchaseProduct.PurchaseSchemeProductSkuList.Select(ps => ps.PurchaseSkuId));
|
|
}
|
|
var purchaseSkuBasicInfoList = BatchGetPurchaseSkuBasicInfo(new BatchPurchaseSkuBasicInfoRequest()
|
|
{
|
|
FirstApiMode = Enums.PurchaseProductAPIMode.Spider,
|
|
PriceMode = Enums.PurchaseOrderMode.批发,
|
|
Params = new List<BatchPurchaseSkuBasicInfoParamRequest>()
|
|
{
|
|
new BatchPurchaseSkuBasicInfoParamRequest()
|
|
{
|
|
Platform = purchasePlatformGroup.Key.Value,
|
|
PurchaseProductIds = purchaseProductIds,
|
|
PurchaseSkuIds = purchaseSkuIds
|
|
}
|
|
}
|
|
});
|
|
amount += purchaseSkuBasicInfoList.Sum(p => p.ItemList.Sum(s => s.Price));
|
|
}
|
|
|
|
if (purchaseScheme.DefaultCost != amount)
|
|
{
|
|
purchaseScheme.DefaultCost = amount;
|
|
var update = fsql.Update<PurchaseScheme>(purchaseScheme.Id).Set(p => p.DefaultCost, amount);
|
|
updatePurchaseSchemeList.Add(update);
|
|
}
|
|
}
|
|
|
|
if (updatePurchaseSchemeList.Count() > 0)
|
|
{
|
|
fsql.Transaction(() =>
|
|
{
|
|
foreach (var update in updatePurchaseSchemeList)
|
|
update.ExecuteAffrows();
|
|
});
|
|
}
|
|
|
|
return purchaseSchemeList;
|
|
}
|
|
|
|
///// <summary>
|
|
///// 获取共同拥有的采购商
|
|
///// </summary>
|
|
///// <param name="querySchemeRequest"></param>
|
|
///// <returns></returns>
|
|
//public IList<Purchaser> GetSharePurchaser(QuerySchemeRequest querySchemeRequest)
|
|
//{
|
|
// var skuCount = querySchemeRequest.SkuIdList.Count();
|
|
|
|
// var purchaseSchemeList = fsql.Select<PurchaseScheme, Purchaser>().InnerJoin((ps, p) => ps.PurchaserId == p.Id)
|
|
// .Where((ps, p) => ps.ShopId == querySchemeRequest.ShopId)
|
|
// .Where((ps, p) => querySchemeRequest.SkuIdList.Contains(ps.SkuId))
|
|
// .ToList();
|
|
// if (purchaseSchemeList.Count() == 0)
|
|
// return null;
|
|
|
|
// var group = purchaseSchemeList.GroupBy(p => p.PurchaserId);
|
|
// var sharePurchaserIdList = new List<string>();
|
|
// foreach (var g in group)
|
|
// {
|
|
// if (g.Count() == skuCount)
|
|
// sharePurchaserIdList.Add(g.Key);
|
|
// }
|
|
// if (sharePurchaserIdList.Count == 0)
|
|
// return null;
|
|
|
|
// return fsql.Select<Purchaser>().Where(p => sharePurchaserIdList.Contains(p.Id)).ToList();
|
|
//}
|
|
|
|
//public void DeletePurchaser(DeletePurchaseSchemeRequest deletePurchaseSchemeRequest)
|
|
//{
|
|
// var purchaseSchemeIdList = fsql.Select<PurchaseScheme>().Where(ps => ps.ProductId == deletePurchaseSchemeRequest.ProductId &&
|
|
// ps.PurchaserId == deletePurchaseSchemeRequest.PurchaserId).ToList(ps => ps.Id);
|
|
|
|
// fsql.Transaction(() =>
|
|
// {
|
|
// fsql.Delete<PurchaseScheme>(purchaseSchemeIdList).ExecuteAffrows();
|
|
// fsql.Delete<PurchaseSchemeProduct>().Where(psp => purchaseSchemeIdList.Contains(psp.SkuPurchaseSchemeId)).ExecuteAffrows();
|
|
// fsql.Delete<PurchaseSchemeProductSku>().Where(psps => purchaseSchemeIdList.Contains(psps.SkuPurchaseSchemeId)).ExecuteAffrows();
|
|
// });
|
|
//}
|
|
|
|
public void DeletePurchaseScheme(long schemeId)
|
|
{
|
|
fsql.Transaction(() =>
|
|
{
|
|
fsql.Delete<PurchaseScheme>(schemeId).ExecuteAffrows();
|
|
fsql.Delete<PurchaseSchemeProduct>().Where(p => p.SkuPurchaseSchemeId == schemeId).ExecuteAffrows();
|
|
fsql.Delete<PurchaseSchemeProductSku>().Where(p => p.SkuPurchaseSchemeId == schemeId).ExecuteAffrows();
|
|
});
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取采购Sku的基本信息
|
|
/// </summary>
|
|
/// <param name="request"></param>
|
|
/// <returns></returns>
|
|
public PurchaseSkuBasicInfoResponse GetPurchaseSkuBasicInfo(PurchaseSkuBasicInfoRequest request)
|
|
{
|
|
return purchaseProductAPIService.GetProductInfo(request);
|
|
}
|
|
|
|
public IList<PurchaseSkuBasicInfoResponse> BatchGetPurchaseSkuBasicInfo(BatchPurchaseSkuBasicInfoRequest request)
|
|
{
|
|
var list = new List<PurchaseSkuBasicInfoResponse>();
|
|
foreach (var param in request.Params)
|
|
{
|
|
foreach (var purchaseId in param.PurchaseProductIds)
|
|
{
|
|
var response = GetPurchaseSkuBasicInfo(new PurchaseSkuBasicInfoRequest()
|
|
{
|
|
FirstApiMode = request.FirstApiMode,
|
|
PriceMode = request.PriceMode,
|
|
Platform = param.Platform,
|
|
PurchaseProductId = purchaseId
|
|
});
|
|
if (response != null)
|
|
{
|
|
if (param.PurchaseSkuIds != null && param.PurchaseSkuIds.Count() > 0)
|
|
{
|
|
for (var i = 0; i < response.ItemList.Count(); i++)
|
|
{
|
|
var skuInfo = response.ItemList[i];
|
|
if (!param.PurchaseSkuIds.Any(s => s == skuInfo.PurchaseSkuId))
|
|
{
|
|
response.ItemList.RemoveAt(i);
|
|
i--;
|
|
}
|
|
}
|
|
}
|
|
list.Add(response);
|
|
}
|
|
}
|
|
}
|
|
return list;
|
|
}
|
|
|
|
|
|
}
|
|
}
|
|
|