pengcong001
/
bbwyb
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

完善采购商列表查询

liangku_skuoptimazation
shanji 2 years ago
parent
8153e7389b
commit
f0a45608f5
2 changed files with 204 additions and 133 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 331
      BBWYB.Server.Business/Purchaser/PurchaserBusiness.cs
  2. 6
      BBWYB.Server.Model/Dto/Request/Purchaser/QueryPurchaserRequest.cs

331
BBWYB.Server.Business/Purchaser/PurchaserBusiness.cs
View File

@ -3,6 +3,7 @@ using BBWYB.Common.Models;
using BBWYB.Server.Model; using BBWYB.Server.Model;
using BBWYB.Server.Model.Db; using BBWYB.Server.Model.Db;
using BBWYB.Server.Model.Dto; using BBWYB.Server.Model.Dto;
using FreeSql;
using Yitter.IdGenerator; using Yitter.IdGenerator;
namespace BBWYB.Server.Business namespace BBWYB.Server.Business
@ -32,73 +33,68 @@ namespace BBWYB.Server.Business
public ListResponse<PurchaserResponse> QueryPurchaserList(QueryPurchaserRequest request) public ListResponse<PurchaserResponse> QueryPurchaserList(QueryPurchaserRequest request)
{ {
if (request.PageSize > 20) #region 数据验证
request.PageSize = 20; if (request.RecentDayCondition != null && request.RecentDayCondition.RecentDay > 0)
var purchaserList = fsql.Select<Purchaser>() {
.WhereIf(!string.IsNullOrEmpty(request.Spu), p => fsql.Select<PurchaseSchemeProduct>() if (request.RecentDayCondition.PurchasedCountComparisonOperator != null)
.Where(psp1 => psp1.PurchaserId == p.Id && {
psp1.ProductId == request.Spu) if (request.RecentDayCondition.PurchasedCount == null || (request.RecentDayCondition.PurchasedCountComparisonOperator == Enums.ComparisonOperator.介于 &&
.Any()) request.RecentDayCondition.PurchasedCount2 == null))
.WhereIf(!string.IsNullOrEmpty(request.Sku), p => fsql.Select<PurchaseSchemeProduct>() throw new BusinessException("采购量条件不完整");
.Where(psp2 => psp2.PurchaserId == p.Id && }
psp2.SkuId == request.Sku)
.Any())
.WhereIf(request.PurchaserNameList != null && request.PurchaserNameList.Count() > 0, p => request.PurchaserNameList.Contains(p.Name))
.WhereIf(request.CategoryIdList != null && request.CategoryIdList.Count() > 0, p => fsql.Select<Purchaser_ExtendedInfo_Relation>()
.Where(per => per.PurchaserId == p.Id &&
request.CategoryIdList.Contains(per.ExtendedInfoId.Value)).Any())
.WhereIf(request.LocationList != null && request.LocationList.Count() > 0, p => request.LocationList.Contains(p.Location))
.Page(request.PageIndex, request.PageSize)
.Count(out var count)
.ToList<PurchaserResponse>();
var purchaserIdList = purchaserList.Select(p => p.Id).ToList();
#region 查询SPU绑定数/SKU绑定数
var bindList = fsql.Select<PurchaseSchemeProduct, PurchaseScheme>()
.InnerJoin((psp, psc) => psp.SkuPurchaseSchemeId == psc.Id)
.Where((psp, psc) => psc.ShopId == request.ShopId && purchaserIdList.Contains(psp.PurchaserId))
.GroupBy((psp, psc) => new { psp.PurchaserId, psp.ProductId, psp.SkuId })
.ToList(g => new
{
g.Key.PurchaserId,
g.Key.ProductId,
g.Key.SkuId
});
#endregion
#region 查询SPU采购数/SKU采购数
var purchasedList = fsql.Select<SkuHistoryPurchaserRelation, ProductSku>()
.InnerJoin((spr, ps) => spr.SkuId == ps.Id)
.Where((spr, ps) => ps.ShopId == request.ShopId && purchaserIdList.Contains(spr.PurchaserId))
.GroupBy((spr, ps) => new { spr.PurchaserId, spr.SkuId, ps.ProductId })
.ToList(g => new
{
g.Key.PurchaserId,
g.Key.ProductId,
g.Key.SkuId
});
if (request.RecentDayCondition.PurchasedAmountComparisonOperator != null)
{
if (request.RecentDayCondition.PurchasedAmount == null || (request.RecentDayCondition.PurchasedAmountComparisonOperator == Enums.ComparisonOperator.介于 &&
request.RecentDayCondition.PurchasedAmount2 == null))
throw new BusinessException("采购金额条件不完整");
}
}
#endregion #endregion
#region 查询订单数 if (request.PageSize > 20)
var poList = fsql.Select<OrderPurchaseInfo, Order>() request.PageSize = 20;
.InnerJoin((opi, o) => opi.OrderId == o.Id)
.Where((opi, o) => opi.ShopId == request.ShopId &&
opi.IsEnabled == true &&
o.OrderState != Enums.OrderState.已取消 &&
purchaserIdList.Contains(opi.PurchaserId))
.GroupBy((opi, o) => opi.PurchaserId)
.ToList(g => new
{
PurchaserId = g.Key,
Count = g.Count()
});
#endregion var select = fsql.Select<Purchaser>()
.WhereIf(!string.IsNullOrEmpty(request.Spu), p => fsql.Select<PurchaseSchemeProduct>()
.Where(psp1 => psp1.PurchaserId == p.Id &&
psp1.ProductId == request.Spu)
.Any())
.WhereIf(!string.IsNullOrEmpty(request.Sku), p => fsql.Select<PurchaseSchemeProduct>()
.Where(psp2 => psp2.PurchaserId == p.Id &&
psp2.SkuId == request.Sku)
.Any())
.WhereIf(request.PurchaserNameList != null &&
request.PurchaserNameList.Count() > 0, p => request.PurchaserNameList.Contains(p.Name))
.WhereIf(request.CategoryIdList != null &&
request.CategoryIdList.Count() > 0, p => fsql.Select<Purchaser_ExtendedInfo_Relation>()
.Where(per => per.PurchaserId == p.Id &&
request.CategoryIdList.Contains(per.ExtendedInfoId.Value)).Any())
.WhereIf(request.LocationList != null && request.LocationList.Count() > 0, p => request.LocationList.Contains(p.Location))
.WhereIf(request.ManagmentMode != null, p => p.ManagmentMode == request.ManagmentMode);
#region 查询采购金额 if (request.RecentDayCondition != null && request.RecentDayCondition.RecentDay > 0)
var purchaseAmountList = fsql.Select<OrderCostDetail, Order, OrderPurchaseRelationInfo, OrderPurchaseInfo>() {
var recentStartDay = DateTime.Now.Date.AddDays(request.RecentDayCondition.RecentDay.Value * -1);
if (request.RecentDayCondition.PurchasedCountComparisonOperator != null)
{
var childSelect = fsql.Select<OrderPurchaseInfo, Order>()
.InnerJoin((opi, o) => opi.OrderId == o.Id)
.Where((opi, o) => opi.ShopId == request.ShopId &&
opi.IsEnabled == true &&
o.OrderState != Enums.OrderState.已取消 &&
opi.CreateTime >= recentStartDay)
.GroupBy((opi, o) => opi.PurchaserId)
.HavingIf(request.RecentDayCondition.PurchasedCountComparisonOperator == Enums.ComparisonOperator.等于, g => g.Count() == request.RecentDayCondition.PurchasedCount)
.HavingIf(request.RecentDayCondition.PurchasedCountComparisonOperator == Enums.ComparisonOperator.小于, g => g.Count() <= request.RecentDayCondition.PurchasedCount)
.HavingIf(request.RecentDayCondition.PurchasedCountComparisonOperator == Enums.ComparisonOperator.大于, g => g.Count() >= request.RecentDayCondition.PurchasedCount)
.HavingIf(request.RecentDayCondition.PurchasedCountComparisonOperator == Enums.ComparisonOperator.介于, g => g.Count() >= request.RecentDayCondition.PurchasedCount && g.Count() <= request.RecentDayCondition.PurchasedCount2)
.WithTempQuery(g => new { g.Value.Item1.PurchaserId, Count = g.Count() }).As("pcc");
select = select.Where(p => childSelect.Where(pcc => pcc.PurchaserId == p.Id).Any());
}
if (request.RecentDayCondition.PurchasedAmountComparisonOperator != null)
{
var childSelect = fsql.Select<OrderCostDetail, Order, OrderPurchaseRelationInfo, OrderPurchaseInfo>()
.InnerJoin((ocd, o, ori, opi) => ocd.OrderId == o.Id) .InnerJoin((ocd, o, ori, opi) => ocd.OrderId == o.Id)
.InnerJoin((ocd, o, ori, opi) => ocd.OrderId == ori.OrderId && ocd.SkuId == ori.BelongSkuId) .InnerJoin((ocd, o, ori, opi) => ocd.OrderId == ori.OrderId && ocd.SkuId == ori.BelongSkuId)
.InnerJoin((ocd, o, ori, opi) => ori.OrderId == opi.OrderId) .InnerJoin((ocd, o, ori, opi) => ori.OrderId == opi.OrderId)
@ -106,89 +102,162 @@ namespace BBWYB.Server.Business
o.OrderState != Enums.OrderState.已取消 && o.OrderState != Enums.OrderState.已取消 &&
ocd.IsEnabled == true && ocd.IsEnabled == true &&
opi.IsEnabled == true && opi.IsEnabled == true &&
purchaserIdList.Contains(opi.PurchaserId)) opi.CreateTime >= recentStartDay)
.GroupBy((ocd, o, ori, opi) => opi.PurchaserId) .GroupBy((ocd, o, ori, opi) => opi.PurchaserId)
.ToList(g => new .HavingIf(request.RecentDayCondition.PurchasedAmountComparisonOperator == Enums.ComparisonOperator.等于, g => g.Sum(g.Value.Item1.SkuAmount + g.Value.Item1.PurchaseFreight) == request.RecentDayCondition.PurchasedAmount)
{ .HavingIf(request.RecentDayCondition.PurchasedAmountComparisonOperator == Enums.ComparisonOperator.小于, g => g.Sum(g.Value.Item1.SkuAmount + g.Value.Item1.PurchaseFreight) <= request.RecentDayCondition.PurchasedAmount)
PurchaserId = g.Key, .HavingIf(request.RecentDayCondition.PurchasedAmountComparisonOperator == Enums.ComparisonOperator.大于, g => g.Sum(g.Value.Item1.SkuAmount + g.Value.Item1.PurchaseFreight) >= request.RecentDayCondition.PurchasedAmount)
PurchaseAmount = g.Sum(g.Value.Item1.SkuAmount) + g.Sum(g.Value.Item1.PurchaseFreight) .HavingIf(request.RecentDayCondition.PurchasedAmountComparisonOperator == Enums.ComparisonOperator.介于, g => g.Sum(g.Value.Item1.SkuAmount + g.Value.Item1.PurchaseFreight) >= request.RecentDayCondition.PurchasedAmount && g.Sum(g.Value.Item1.SkuAmount + g.Value.Item1.PurchaseFreight) <= request.RecentDayCondition.PurchasedAmount2)
}); .WithTempQuery(g => new { g.Value.Item4.PurchaserId, PurchasedAmount = g.Sum(g.Value.Item1.SkuAmount + g.Value.Item1.PurchaseFreight) }).As("pca");
#endregion select = select.Where(p => childSelect.Where(pca => pca.PurchaserId == p.Id).Any());
}
#region 查询最近采购时间 }
var recentPurchaseTimeList = fsql.Select<OrderPurchaseInfo, Order>()
.InnerJoin((opi1, o) => o.OrderState != Enums.OrderState.已取消)
.Where((opi1, o) => opi1.ShopId == request.ShopId &&
purchaserIdList.Contains(opi1.PurchaserId) &&
opi1.IsEnabled == true)
.GroupBy((opi1, o) => opi1.PurchaserId)
.WithTempQuery(g => new { MaxId = g.Max(g.Value.Item1.Id) })
.From<OrderPurchaseInfo>()
.InnerJoin((opi1, opi2) => opi1.MaxId == opi2.Id)
.ToList((opi1, opi2) => new
{
opi2.PurchaserId,
opi2.CreateTime
});
#endregion
#region 查询标签/主营类目
var purchaserExtendInfoList = fsql.Select<PurchaserExtendedInfo, Purchaser_ExtendedInfo_Relation>()
.InnerJoin((pei, per) => pei.Id == per.ExtendedInfoId)
.Where((pei, per) => purchaserIdList.Contains(per.PurchaserId))
.ToList((pei, per) => new
{
pei.Id,
pei.Name,
pei.Type,
per.PurchaserId
});
#endregion
foreach (var purchaser in purchaserList) var pageSelect = select.Page(request.PageIndex, request.PageSize);
var sql = pageSelect.ToSql();
var purchaserList = select.Page(request.PageIndex, request.PageSize)
.Count(out var count)
.ToList<PurchaserResponse>();
if (purchaserList.Count() > 0)
{ {
#region SPU绑定数/SKU绑定数 var purchaserIdList = purchaserList.Select(p => p.Id).ToList();
var currentBindList = bindList.Where(x => x.PurchaserId == purchaser.Id).ToList();
purchaser.BindingSpuCount = currentBindList.Select(x => x.ProductId).Distinct().Count(); #region 查询SPU绑定数/SKU绑定数
purchaser.BindingSkuCount = currentBindList.Select(x => x.SkuId).Count(); var bindList = fsql.Select<PurchaseSchemeProduct, PurchaseScheme>()
.InnerJoin((psp, psc) => psp.SkuPurchaseSchemeId == psc.Id)
.Where((psp, psc) => psc.ShopId == request.ShopId && purchaserIdList.Contains(psp.PurchaserId))
.GroupBy((psp, psc) => new { psp.PurchaserId, psp.ProductId, psp.SkuId })
.ToList(g => new
{
g.Key.PurchaserId,
g.Key.ProductId,
g.Key.SkuId
});
#endregion #endregion
#region SPU采购数/SKU采购数 #region 查询SPU采购数/SKU采购数
var currentPurchasedList = purchasedList.Where(x => x.PurchaserId == purchaser.Id).ToList(); var purchasedList = fsql.Select<SkuHistoryPurchaserRelation, ProductSku>()
purchaser.PurchasedSpuCount = currentPurchasedList.Select(x => x.ProductId).Distinct().Count(); .InnerJoin((spr, ps) => spr.SkuId == ps.Id)
purchaser.PurchasedSkuCount = currentPurchasedList.Select(x => x.SkuId).Count(); .Where((spr, ps) => ps.ShopId == request.ShopId && purchaserIdList.Contains(spr.PurchaserId))
.GroupBy((spr, ps) => new { spr.PurchaserId, spr.SkuId, ps.ProductId })
.ToList(g => new
{
g.Key.PurchaserId,
g.Key.ProductId,
g.Key.SkuId
});
#endregion #endregion
#region 订单数 #region 查询订单数
purchaser.PurchasedCount = poList.FirstOrDefault(x => x.PurchaserId == purchaser.Id)?.Count ?? 0; var poList = fsql.Select<OrderPurchaseInfo, Order>()
.InnerJoin((opi, o) => opi.OrderId == o.Id)
.Where((opi, o) => opi.ShopId == request.ShopId &&
opi.IsEnabled == true &&
o.OrderState != Enums.OrderState.已取消 &&
purchaserIdList.Contains(opi.PurchaserId))
.GroupBy((opi, o) => opi.PurchaserId)
.ToList(g => new
{
PurchaserId = g.Key,
Count = g.Count()
});
#endregion #endregion
#region 采购金额 #region 查询采购金额
purchaser.PurchaseAmount = purchaseAmountList.FirstOrDefault(x => x.PurchaserId == purchaser.Id)?.PurchaseAmount ?? 0; var purchaseAmountList = fsql.Select<OrderCostDetail, Order, OrderPurchaseRelationInfo, OrderPurchaseInfo>()
.InnerJoin((ocd, o, ori, opi) => ocd.OrderId == o.Id)
.InnerJoin((ocd, o, ori, opi) => ocd.OrderId == ori.OrderId && ocd.SkuId == ori.BelongSkuId)
.InnerJoin((ocd, o, ori, opi) => ori.OrderId == opi.OrderId)
.Where((ocd, o, ori, opi) => o.ShopId == request.ShopId &&
o.OrderState != Enums.OrderState.已取消 &&
ocd.IsEnabled == true &&
opi.IsEnabled == true &&
purchaserIdList.Contains(opi.PurchaserId))
.GroupBy((ocd, o, ori, opi) => opi.PurchaserId)
.ToList(g => new
{
PurchaserId = g.Key,
PurchaseAmount = g.Sum(g.Value.Item1.SkuAmount) + g.Sum(g.Value.Item1.PurchaseFreight)
});
#endregion #endregion
#region 最近采购时间 #region 查询最近采购时间
purchaser.LastPurchaseTime = recentPurchaseTimeList.FirstOrDefault(x => x.PurchaserId == purchaser.Id)?.CreateTime; var recentPurchaseTimeList = fsql.Select<OrderPurchaseInfo, Order>()
.InnerJoin((opi1, o) => o.OrderState != Enums.OrderState.已取消)
.Where((opi1, o) => opi1.ShopId == request.ShopId &&
purchaserIdList.Contains(opi1.PurchaserId) &&
opi1.IsEnabled == true)
.GroupBy((opi1, o) => opi1.PurchaserId)
.WithTempQuery(g => new { MaxId = g.Max(g.Value.Item1.Id) })
.From<OrderPurchaseInfo>()
.InnerJoin((opi1, opi2) => opi1.MaxId == opi2.Id)
.ToList((opi1, opi2) => new
{
opi2.PurchaserId,
opi2.CreateTime
});
#endregion #endregion
#region 主营类目/标签 #region 查询标签/主营类目
var currentExtendInfoList = purchaserExtendInfoList.Where(x => x.PurchaserId == purchaser.Id).ToList(); var purchaserExtendInfoList = fsql.Select<PurchaserExtendedInfo, Purchaser_ExtendedInfo_Relation>()
purchaser.CategoryList = currentExtendInfoList.Where(x => x.Type == Enums.PurchaserBasicInfoType.主营类目) .InnerJoin((pei, per) => pei.Id == per.ExtendedInfoId)
.Select(x => new PurchaserExtendedInfoResponse() .Where((pei, per) => purchaserIdList.Contains(per.PurchaserId))
{ .ToList((pei, per) => new
Id = x.Id, {
Name = x.Name, pei.Id,
Type = x.Type pei.Name,
}).ToList(); pei.Type,
per.PurchaserId
purchaser.TagList = currentExtendInfoList.Where(x => x.Type == Enums.PurchaserBasicInfoType.标签) });
.Select(x => new PurchaserExtendedInfoResponse()
{
Id = x.Id,
Name = x.Name,
Type = x.Type
}).ToList();
#endregion #endregion
foreach (var purchaser in purchaserList)
{
#region SPU绑定数/SKU绑定数
var currentBindList = bindList.Where(x => x.PurchaserId == purchaser.Id).ToList();
purchaser.BindingSpuCount = currentBindList.Select(x => x.ProductId).Distinct().Count();
purchaser.BindingSkuCount = currentBindList.Select(x => x.SkuId).Count();
#endregion
#region SPU采购数/SKU采购数
var currentPurchasedList = purchasedList.Where(x => x.PurchaserId == purchaser.Id).ToList();
purchaser.PurchasedSpuCount = currentPurchasedList.Select(x => x.ProductId).Distinct().Count();
purchaser.PurchasedSkuCount = currentPurchasedList.Select(x => x.SkuId).Count();
#endregion
#region 订单数
purchaser.PurchasedCount = poList.FirstOrDefault(x => x.PurchaserId == purchaser.Id)?.Count ?? 0;
#endregion
#region 采购金额
purchaser.PurchaseAmount = purchaseAmountList.FirstOrDefault(x => x.PurchaserId == purchaser.Id)?.PurchaseAmount ?? 0;
#endregion
#region 最近采购时间
purchaser.LastPurchaseTime = recentPurchaseTimeList.FirstOrDefault(x => x.PurchaserId == purchaser.Id)?.CreateTime;
#endregion
#region 主营类目/标签
var currentExtendInfoList = purchaserExtendInfoList.Where(x => x.PurchaserId == purchaser.Id).ToList();
purchaser.CategoryList = currentExtendInfoList.Where(x => x.Type == Enums.PurchaserBasicInfoType.主营类目)
.Select(x => new PurchaserExtendedInfoResponse()
{
Id = x.Id,
Name = x.Name,
Type = x.Type
}).ToList();
purchaser.TagList = currentExtendInfoList.Where(x => x.Type == Enums.PurchaserBasicInfoType.标签)
.Select(x => new PurchaserExtendedInfoResponse()
{
Id = x.Id,
Name = x.Name,
Type = x.Type
}).ToList();
#endregion
}
} }
return new ListResponse<PurchaserResponse>() return new ListResponse<PurchaserResponse>()

6
BBWYB.Server.Model/Dto/Request/Purchaser/QueryPurchaserRequest.cs
View File

@ -31,6 +31,8 @@ namespace BBWYB.Server.Model.Dto
/// </summary> /// </summary>
public QueryPurchaserConditionByDayRequest RecentDayCondition { get; set; } public QueryPurchaserConditionByDayRequest RecentDayCondition { get; set; }
public Enums.ManagmentMode? ManagmentMode { get; set; }
/// <summary> /// <summary>
/// 页码 从1开始 /// 页码 从1开始
/// </summary> /// </summary>
@ -51,7 +53,7 @@ namespace BBWYB.Server.Model.Dto
/// </summary> /// </summary>
public int? RecentDay { get; set; } public int? RecentDay { get; set; }
public Enums.ComparisonOperator PurchasedCountComparisonOperator { get; set; } public Enums.ComparisonOperator? PurchasedCountComparisonOperator { get; set; }
/// <summary> /// <summary>
/// 采购量,大于/小于/等于/介于时传该值,可空 /// 采购量,大于/小于/等于/介于时传该值,可空
@ -63,7 +65,7 @@ namespace BBWYB.Server.Model.Dto
/// </summary> /// </summary>
public int? PurchasedCount2 { get; set; } public int? PurchasedCount2 { get; set; }
public Enums.ComparisonOperator PurchasedAmountComparisonOperator { get; set; } public Enums.ComparisonOperator? PurchasedAmountComparisonOperator { get; set; }
/// <summary> /// <summary>
/// 采购额,大于/小于/等于/介于时传该值,可空 /// 采购额,大于/小于/等于/介于时传该值,可空

Write Preview
Loading…
Cancel
Save