Browse Source

恢复改价回调

qianyi
shanji 3 years ago
parent
commit
e5176d5aa1
  1. 9
      BBWY.Server.Business/PurchaseOrder/PurchaseOrderBusiness.cs

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

@ -410,8 +410,8 @@ namespace BBWY.Server.Business
/// <param name="jObject"></param> /// <param name="jObject"></param>
private void OrderPriceModificationCallbackFrom1688(JObject jObject) private void OrderPriceModificationCallbackFrom1688(JObject jObject)
{ {
//var purchaseOrderId = jObject["data"].Value<string>("orderId"); var purchaseOrderId = jObject["data"].Value<string>("orderId");
//Task.Factory.StartNew(() => OrderPriceModificationCallback(purchaseOrderId, Enums.Platform.阿里巴巴), CancellationToken.None, TaskCreationOptions.LongRunning, taskSchedulerManager.PurchaseOrderCallbackTaskScheduler); Task.Factory.StartNew(() => OrderPriceModificationCallback(purchaseOrderId, Enums.Platform.), CancellationToken.None, TaskCreationOptions.LongRunning, taskSchedulerManager.PurchaseOrderCallbackTaskScheduler);
} }
#endregion #endregion
@ -638,15 +638,14 @@ namespace BBWY.Server.Business
orderDropshipping.PurchaseAmount = purchaseOrderSimpleInfo.TotalAmount; orderDropshipping.PurchaseAmount = purchaseOrderSimpleInfo.TotalAmount;
fsql.Transaction(() => fsql.Transaction(() =>
{ {
foreach (var update in updatePurchaseOrders) foreach (var update in updatePurchaseOrders)
update.ExecuteAffrows(); update.ExecuteAffrows();
foreach (var update in updateOrderCostDetails) foreach (var update in updateOrderCostDetails)
update.ExecuteAffrows(); update.ExecuteAffrows();
fsql.Update<OrderCost>(orderCost.OrderId).SetSource(orderCost).ExecuteAffrows(); fsql.Update<OrderCost>().SetSource(orderCost).ExecuteAffrows();
fsql.Update<OrderDropShipping>(orderDropshipping.OrderId).SetSource(orderDropshipping).ExecuteAffrows(); fsql.Update<OrderDropShipping>().SetSource(orderDropshipping).ExecuteAffrows();
}); });
} }
catch (Exception ex) catch (Exception ex)

Loading…
Cancel
Save