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

修改商品售价按全量提交

yijia
shanji 2 years ago
parent
25795b92e4
commit
532221ecc1
3 changed files with 86 additions and 51 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. 37
      BBWYB.Server.Business/Product/ProductBusiness.cs
  2. 98
      BBWYB.Server.Business/PurchaseOrder/PurchaseOrderBusiness.cs
  3. 2
      SDKAdapter/OperationPlatform/Models/Request/Product/OP_EditProductPriceRequest.cs

37
BBWYB.Server.Business/Product/ProductBusiness.cs
View File

@ -1,5 +1,6 @@
using BBWYB.Common.Log; using BBWYB.Common.Log;
using BBWYB.Common.Models; using BBWYB.Common.Models;
using BBWYB.Server.Model;
using SDKAdapter.OperationPlatform.Client; using SDKAdapter.OperationPlatform.Client;
using SDKAdapter.OperationPlatform.Models; using SDKAdapter.OperationPlatform.Models;
using Yitter.IdGenerator; using Yitter.IdGenerator;
@ -14,7 +15,7 @@ namespace BBWYB.Server.Business
{ {
this.opPlatformClientFactory = opPlatformClientFactory; this.opPlatformClientFactory = opPlatformClientFactory;
} }
public OP_ProductListResponse GetProductList(OP_QueryProductRequest request) public OP_ProductListResponse GetProductList(OP_QueryProductRequest request)
{ {
return opPlatformClientFactory.GetClient(request.Platform).GetProductList(request); return opPlatformClientFactory.GetClient(request.Platform).GetProductList(request);
@ -27,6 +28,40 @@ namespace BBWYB.Server.Business
public void EditProductPrice(OP_EditProductPriceRequest request) public void EditProductPrice(OP_EditProductPriceRequest request)
{ {
var skuRequest = new OP_QueryProductSkuRequest()
{
AppKey = request.AppKey,
AppSecret = request.AppSecret,
AppToken = request.AppToken,
PageIndex = 1,
PageSize = 50,
Platform = request.Platform,
Spu = request.Spu
};
var editSkuList = new List<OP_EditProductSkuPriceRequest>();
while (true)
{
var response = GetProductSkuList(skuRequest);
if (response.Items.Count > 0)
{
editSkuList.AddRange(response.Items.Select(sku => new OP_EditProductSkuPriceRequest()
{
Sku = sku.Id,
Price = sku.Price,
}));
}
if (response.Items.Count < 50)
break;
skuRequest.PageIndex++;
}
foreach (var editReq in request.EditSkuList)
{
var editSku = editSkuList.FirstOrDefault(x => x.Sku == editReq.Sku);
if (editSku != null)
editSku.Price = editReq.Price;
}
request.EditSkuList.Clear();
request.EditSkuList.AddRange(editSkuList);
opPlatformClientFactory.GetClient(request.Platform).EditProductPrice(request); opPlatformClientFactory.GetClient(request.Platform).EditProductPrice(request);
} }
} }

98
BBWYB.Server.Business/PurchaseOrder/PurchaseOrderBusiness.cs
View File

@ -2465,21 +2465,21 @@ namespace BBWYB.Server.Business
#region 订单sku平价 #region 订单sku平价
var orderSku = dbOrderSkus.FirstOrDefault(osku => osku.SkuId == belongSkuId); var orderSku = dbOrderSkus.FirstOrDefault(osku => osku.SkuId == belongSkuId);
if (isEditOrderPrice) //if (isEditOrderPrice)
{ //{
orderSku.Price = currentOrderSkuProductAmount / orderSku.ItemTotal; // orderSku.Price = currentOrderSkuProductAmount / orderSku.ItemTotal;
orderSku.BuyerPayFreight = currentPurchaseFreight; // orderSku.BuyerPayFreight = currentPurchaseFreight;
op_EditPriceSkuRequests.Add(new OP_EditPriceSkuRequest() // op_EditPriceSkuRequests.Add(new OP_EditPriceSkuRequest()
{ // {
Freight = currentPurchaseFreight ?? 0M, // Freight = currentPurchaseFreight ?? 0M,
InPackAmountPrice = orderSku.InPackAmount ?? 0M, // InPackAmountPrice = orderSku.InPackAmount ?? 0M,
OrderSkuId = orderSku.Id.ToString(), // OrderSkuId = orderSku.Id.ToString(),
Price = orderSku.Price ?? 0M, // Price = orderSku.Price ?? 0M,
SkuId = orderSku.SkuId // SkuId = orderSku.SkuId
}); // });
updateOrderSkuList.Add(fsql.Update<OrderSku>(orderSku.Id).Set(osku => osku.Price, orderSku.Price) // updateOrderSkuList.Add(fsql.Update<OrderSku>(orderSku.Id).Set(osku => osku.Price, orderSku.Price)
.Set(osku => osku.BuyerPayFreight, orderSku.BuyerPayFreight)); // .Set(osku => osku.BuyerPayFreight, orderSku.BuyerPayFreight));
} //}
#endregion #endregion
var dbOrderSkuDetail = dbOrderCostDetails.FirstOrDefault(ocd => ocd.SkuId == belongSkuId && ocd.PurchaseOrderId == opi.PurchaseOrderId); var dbOrderSkuDetail = dbOrderCostDetails.FirstOrDefault(ocd => ocd.SkuId == belongSkuId && ocd.PurchaseOrderId == opi.PurchaseOrderId);
@ -2493,15 +2493,15 @@ namespace BBWYB.Server.Business
updateOrderCostDetailList.Add(fsql.Update<OrderCostDetail>().SetSource(dbOrderSkuDetail)); updateOrderCostDetailList.Add(fsql.Update<OrderCostDetail>().SetSource(dbOrderSkuDetail));
} }
} }
if (isEditOrderPrice) //if (isEditOrderPrice)
{ //{
dbOrder.OrderTotalPrice = totalPurchaseProductAmount + totalPurchaseFreight; // dbOrder.OrderTotalPrice = totalPurchaseProductAmount + totalPurchaseFreight;
dbOrder.OrderSellerPrice = totalPurchaseProductAmount; // dbOrder.OrderSellerPrice = totalPurchaseProductAmount;
dbOrder.FreightPrice = totalPurchaseFreight; // dbOrder.FreightPrice = totalPurchaseFreight;
updateOrder = fsql.Update<Order>(dbOrder.Id).Set(o => o.OrderTotalPrice, dbOrder.OrderTotalPrice) // updateOrder = fsql.Update<Order>(dbOrder.Id).Set(o => o.OrderTotalPrice, dbOrder.OrderTotalPrice)
.Set(o => o.OrderSellerPrice, dbOrder.OrderSellerPrice) // .Set(o => o.OrderSellerPrice, dbOrder.OrderSellerPrice)
.Set(o => o.FreightPrice, dbOrder.FreightPrice); // .Set(o => o.FreightPrice, dbOrder.FreightPrice);
} //}
dbOrderCost.CalculationOrderCostCostAndProfit(dbOrder.OrderTotalPrice ?? 0M, dbOrderCost.CalculationOrderCostCostAndProfit(dbOrder.OrderTotalPrice ?? 0M,
totalPurchaseProductAmount, totalPurchaseProductAmount,
@ -2515,34 +2515,34 @@ namespace BBWYB.Server.Business
foreach (var update in updateOrderCostDetailList) foreach (var update in updateOrderCostDetailList)
update.ExecuteAffrows(); update.ExecuteAffrows();
updateOrderCost?.ExecuteAffrows(); updateOrderCost?.ExecuteAffrows();
foreach (var update in updateOrderSkuList) //foreach (var update in updateOrderSkuList)
update.ExecuteAffrows(); // update.ExecuteAffrows();
updateOrder?.ExecuteAffrows(); //updateOrder?.ExecuteAffrows();
}); });
if (isEditOrderPrice) //if (isEditOrderPrice)
{ //{
#region 通知拳探改价 // #region 通知拳探改价
var opclient = opPlatformClientFactory.GetClient(AdapterEnums.PlatformType.拳探); // var opclient = opPlatformClientFactory.GetClient(AdapterEnums.PlatformType.拳探);
opclient.EditPrice(new OP_EditPriceRequest() // opclient.EditPrice(new OP_EditPriceRequest()
{ // {
AppKey = shop.AppKey, // AppKey = shop.AppKey,
AppSecret = shop.AppSecret, // AppSecret = shop.AppSecret,
AppToken = shop.AppToken, // AppToken = shop.AppToken,
OrderId = dbOrder.Id, // OrderId = dbOrder.Id,
EditItems = op_EditPriceSkuRequests // EditItems = op_EditPriceSkuRequests
}); // });
#endregion // #endregion
#region 通知C端改价 // #region 通知C端改价
restApiService.SendRequest("https://bbwy.qiyue666.com", // restApiService.SendRequest("https://bbwy.qiyue666.com",
"/Api/PurchaseOrder/QuanTanEditPriceCallback", // "/Api/PurchaseOrder/QuanTanEditPriceCallback",
new { orderId = dbOrder.Id }, // new { orderId = dbOrder.Id },
null, // null,
HttpMethod.Post); // HttpMethod.Post);
#endregion // #endregion
} //}
} }
catch (Exception ex) catch (Exception ex)
{ {

2
SDKAdapter/OperationPlatform/Models/Request/Product/OP_EditProductPriceRequest.cs
View File

@ -4,7 +4,7 @@
{ {
public string Spu { get; set; } public string Spu { get; set; }
public IList<OP_EditProductSkuPriceRequest> EditSkuList { get; set; } public List<OP_EditProductSkuPriceRequest> EditSkuList { get; set; }
} }
public class OP_EditProductSkuPriceRequest public class OP_EditProductSkuPriceRequest

Write Preview
Loading…
Cancel
Save