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.
241 lines
14 KiB
241 lines
14 KiB
using BBWYB.Common.Log;
|
|
using BBWYB.Common.Models;
|
|
using BBWYB.Server.Model;
|
|
using BBWYB.Server.Model.Db;
|
|
using BBWYB.Server.Model.Dto;
|
|
using Yitter.IdGenerator;
|
|
|
|
namespace BBWYB.Server.Business
|
|
{
|
|
public class PurchaserBusiness : BaseBusiness, IDenpendency
|
|
{
|
|
public PurchaserBusiness(IFreeSql fsql, NLogManager nLogManager, IIdGenerator idGenerator) : base(fsql, nLogManager, idGenerator)
|
|
{
|
|
|
|
}
|
|
|
|
public ListResponse<string> QueryPurchaserNameList(string keywords)
|
|
{
|
|
if (string.IsNullOrEmpty(keywords))
|
|
throw new BusinessException("关键字不能为空");
|
|
var list = fsql.Select<Purchaser>().Where(p => p.Name.Contains(keywords)).Distinct().ToList(x => x.Name);
|
|
return new ListResponse<string> { Items = list, TotalCount = list.Count() };
|
|
}
|
|
|
|
public ListResponse<string> QueryPurchaserLocationList(string keywords)
|
|
{
|
|
if (string.IsNullOrEmpty(keywords))
|
|
throw new BusinessException("关键字不能为空");
|
|
var list = fsql.Select<Purchaser>().Where(p => p.Location.Contains(keywords)).Distinct().ToList(x => x.Location);
|
|
return new ListResponse<string> { Items = list, TotalCount = list.Count() };
|
|
}
|
|
|
|
public ListResponse<PurchaserResponse> QueryPurchaserList(QueryPurchaserRequest request)
|
|
{
|
|
if (request.PageSize > 20)
|
|
request.PageSize = 20;
|
|
var purchaserList = 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))
|
|
.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
|
|
});
|
|
|
|
#endregion
|
|
|
|
#region 查询订单数
|
|
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
|
|
|
|
#region 查询采购金额
|
|
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
|
|
|
|
#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)
|
|
{
|
|
#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>()
|
|
{
|
|
Items = purchaserList,
|
|
TotalCount = count
|
|
};
|
|
}
|
|
|
|
public ListResponse<PurchaserExtendedInfoResponse> QueryPurchaserCategoryList(QueryPurchaserExtendedRequest request)
|
|
{
|
|
var list = fsql.Select<PurchaserExtendedInfo>()
|
|
.WhereIf(request.Type != null, x => x.Type == request.Type)
|
|
.WhereIf(!string.IsNullOrEmpty(request.Keywords), x => x.Name.Contains(request.Keywords))
|
|
.Count(out var count)
|
|
.ToList<PurchaserExtendedInfoResponse>();
|
|
return new ListResponse<PurchaserExtendedInfoResponse> { Items = list, TotalCount = count };
|
|
}
|
|
|
|
public void EditPurchaserExtendedInfo(EditPurchaserExtendedInfoRequest request)
|
|
{
|
|
var insertRelationList = new List<Purchaser_ExtendedInfo_Relation>();
|
|
insertRelationList.AddRange(request.CategoryIdList.Select(x => new Purchaser_ExtendedInfo_Relation()
|
|
{
|
|
Id = idGenerator.NewLong(),
|
|
PurchaserId = request.PurchaserId,
|
|
ExtendedType = Enums.PurchaserBasicInfoType.主营类目,
|
|
ExtendedInfoId = x
|
|
}));
|
|
|
|
insertRelationList.AddRange(request.TagIdList.Select(x => new Purchaser_ExtendedInfo_Relation()
|
|
{
|
|
Id = idGenerator.NewLong(),
|
|
PurchaserId = request.PurchaserId,
|
|
ExtendedType = Enums.PurchaserBasicInfoType.标签,
|
|
ExtendedInfoId = x
|
|
}));
|
|
|
|
fsql.Transaction(() =>
|
|
{
|
|
fsql.Delete<Purchaser_ExtendedInfo_Relation>().Where(r => r.PurchaserId == request.PurchaserId).ExecuteAffrows();
|
|
fsql.Update<Purchaser>(request.PurchaserId).Set(p => p.ManagmentMode, request.ManagmentMode).ExecuteAffrows();
|
|
if (insertRelationList.Count() > 0)
|
|
fsql.Insert(insertRelationList).ExecuteAffrows();
|
|
|
|
});
|
|
|
|
}
|
|
}
|
|
}
|
|
|