shanji 3 years ago
parent
commit
187274990c
  1. 8
      BBWY.Server.Business/Order/OrderBusiness.cs
  2. 10
      BBWY.Server.Business/PurchaseOrder/PurchaseOrderBusiness.cs
  3. 2
      BBWY.Server.Model/Db/Order/OrderDropShipping.cs
  4. 6
      BBWY.Test/Program.cs

8
BBWY.Server.Business/Order/OrderBusiness.cs

@ -174,7 +174,9 @@ namespace BBWY.Server.Business
var orderIdList = orderList.Select(o => o.Id).ToList(); var orderIdList = orderList.Select(o => o.Id).ToList();
#region 处理代发信息 #region 处理代发信息
var orderDropShippingList = fsql.Select<OrderDropShipping>().Where(ods => orderIdList.Contains(ods.OrderId)).ToList().Map<IList<OrderDropShippingResponse>>(); var orderDropShippingList = fsql.Select<OrderDropShipping>().Where(ods => orderIdList.Contains(ods.OrderId) && ods.IsHistory == false)
.ToList()
.Map<IList<OrderDropShippingResponse>>();
foreach (var order in orderList) foreach (var order in orderList)
order.OrderDropShippingList = orderDropShippingList.Where(ods => ods.OrderId == order.Id).ToList(); order.OrderDropShippingList = orderDropShippingList.Where(ods => ods.OrderId == order.Id).ToList();
#endregion #endregion
@ -296,7 +298,7 @@ namespace BBWY.Server.Business
StorageAmount = g.Sum(g.Value.StorageAmount), StorageAmount = g.Sum(g.Value.StorageAmount),
PurchaseFreight = g.Sum(g.Value.PurchaseFreight) PurchaseFreight = g.Sum(g.Value.PurchaseFreight)
}); });
var orderDropShippingList = fsql.Select<OrderDropShipping>().Where(ods => orderIdList.Contains(ods.OrderId)).ToList(); var orderDropShippingList = fsql.Select<OrderDropShipping>().Where(ods => orderIdList.Contains(ods.OrderId) && ods.IsHistory == false).ToList();
foreach (var order in orderSourceList) foreach (var order in orderSourceList)
{ {
@ -327,7 +329,7 @@ namespace BBWY.Server.Business
var orderSkuList = fsql.Select<OrderSku>().Where(osku => osku.OrderId == orderId).ToList().Map<IList<OrderSkuResponse>>(); var orderSkuList = fsql.Select<OrderSku>().Where(osku => osku.OrderId == orderId).ToList().Map<IList<OrderSkuResponse>>();
var orderCouponList = fsql.Select<OrderCoupon>().Where(oc => oc.OrderId == orderId).ToList().Map<IList<OrderCouponResponse>>(); var orderCouponList = fsql.Select<OrderCoupon>().Where(oc => oc.OrderId == orderId).ToList().Map<IList<OrderCouponResponse>>();
var orderCostDetailList = fsql.Select<OrderCostDetail>().Where(ocd => ocd.OrderId == orderId && ocd.IsEnabled == true).ToList().Map<IList<OrderCostDetailResponse>>(); var orderCostDetailList = fsql.Select<OrderCostDetail>().Where(ocd => ocd.OrderId == orderId && ocd.IsEnabled == true).ToList().Map<IList<OrderCostDetailResponse>>();
var orderDropShippingList = fsql.Select<OrderDropShipping>().Where(ods => ods.OrderId == orderId).ToList().Map<IList<OrderDropShippingResponse>>(); var orderDropShippingList = fsql.Select<OrderDropShipping>().Where(ods => ods.OrderId == orderId && ods.IsHistory == false).ToList().Map<IList<OrderDropShippingResponse>>();
if (order.IsAfterSaleOrder) if (order.IsAfterSaleOrder)
orderResponse.AfterSaleOrderList = fsql.Select<AfterSaleOrder>().Where(aso => aso.OrderId == orderId).ToList<AfterSaleOrderResponse>(); orderResponse.AfterSaleOrderList = fsql.Select<AfterSaleOrder>().Where(aso => aso.OrderId == orderId).ToList<AfterSaleOrderResponse>();

10
BBWY.Server.Business/PurchaseOrder/PurchaseOrderBusiness.cs

@ -136,6 +136,12 @@ namespace BBWY.Server.Business
if (dbOrder.OrderState != Model.Enums.OrderState.) if (dbOrder.OrderState != Model.Enums.OrderState.)
throw new BusinessException("只能为等待采购的订单进行采购"); throw new BusinessException("只能为等待采购的订单进行采购");
var oldPourchaseIdList = fsql.Select<OrderCostDetail>().Where(ocd => ocd.OrderId == dbOrder.Id)
.ToList(ocd => ocd.PurchaseOrderPKId);
var deletePurchaseOrder = fsql.Delete<PurchaseOrder>().Where(po => oldPourchaseIdList.Contains(po.Id));
var deleteOrderCostDetail = fsql.Delete<OrderCostDetail>().Where(ocd => ocd.OrderId == dbOrder.Id);
#region 合并重复的采购sku #region 合并重复的采购sku
var repeatPurchaseSkuGroups = createOnlinePurchaseOrderRequest.CargoParamList.GroupBy(p => p.SkuId).ToList(); var repeatPurchaseSkuGroups = createOnlinePurchaseOrderRequest.CargoParamList.GroupBy(p => p.SkuId).ToList();
foreach (var group in repeatPurchaseSkuGroups) foreach (var group in repeatPurchaseSkuGroups)
@ -301,6 +307,10 @@ namespace BBWY.Server.Business
fsql.Transaction(() => fsql.Transaction(() =>
{ {
deletePurchaseOrder.ExecuteAffrows();
deleteOrderCostDetail.ExecuteAffrows();
fsql.Update<OrderDropShipping>().Set(ods => ods.IsHistory, true).Where(ods => ods.OrderId == createOnlinePurchaseOrderRequest.OrderId).ExecuteAffrows();
fsql.Insert(insertPurchaseOrders).ExecuteAffrows(); fsql.Insert(insertPurchaseOrders).ExecuteAffrows();
fsql.Insert(insertPurchaseOrderDetails).ExecuteAffrows(); fsql.Insert(insertPurchaseOrderDetails).ExecuteAffrows();
fsql.Insert(insertOrderCostDetails).ExecuteAffrows(); fsql.Insert(insertOrderCostDetails).ExecuteAffrows();

2
BBWY.Server.Model/Db/Order/OrderDropShipping.cs

@ -84,6 +84,8 @@ namespace BBWY.Server.Model.Db
/// </summary> /// </summary>
public long? ShopId { get; set; } public long? ShopId { get; set; }
[Column(DbType = "bit")]
public bool IsHistory { get; set; } = false;
} }
} }

6
BBWY.Test/Program.cs

@ -26,10 +26,10 @@ namespace BBWY.Test
{ {
var appkey = "120EA9EC65AB017567D78CC1139EEEA5"; var appkey = "120EA9EC65AB017567D78CC1139EEEA5";
var appSecret = "866a9877f5f24b03b537483b4defe75d"; var appSecret = "866a9877f5f24b03b537483b4defe75d";
var token = "e3bb89d1dcf6461fae2f197dfc5d6d68niyj";//"2ace3023200c4ea9aa682bbf8bffee18jztm"; var token = "2ace3023200c4ea9aa682bbf8bffee18jztm";//"2ace3023200c4ea9aa682bbf8bffee18jztm";
var startDate = DateTime.Parse("2022-09-29"); var startDate = DateTime.Parse("2022-07-06");
var endDate = DateTime.Parse("2022-09-29"); var endDate = DateTime.Parse("2022-10-05");
var jdClient = GetJdClient(appkey, appSecret); var jdClient = GetJdClient(appkey, appSecret);
var req = new DspPlatformFinanceOpenapiQuerycostdetailsRequest(); var req = new DspPlatformFinanceOpenapiQuerycostdetailsRequest();

Loading…
Cancel
Save