Browse Source

通知齐库

updatebug
shanji 2 years ago
parent
commit
67c5439ca9
  1. 30
      BBWYB.Server.Business/PurchaseOrder/PurchaseOrderBusiness.cs

30
BBWYB.Server.Business/PurchaseOrder/PurchaseOrderBusiness.cs

@ -573,6 +573,11 @@ namespace BBWYB.Server.Business
.WhereIf(purchaseOrderIds.Count() == 1, ops => ops.PurchaseOrderId == purchaseOrderIds[0])
.ToList();
var dbOrderPurchaseRelationInfoList = fsql.Select<OrderPurchaseRelationInfo>()
.WhereIf(purchaseOrderIds.Count() > 1, opr => purchaseOrderIds.Contains(opr.PurchaseOrderId))
.WhereIf(purchaseOrderIds.Count() == 1, opr => opr.PurchaseOrderId == purchaseOrderIds[0])
.ToList();
foreach (var orderEntryId in orderEntryIds)
{
var dbOrderPurchaseSkuInfo = dbOrderPurchaseSkuInfoList.FirstOrDefault(x => x.Id == orderEntryId);
@ -592,7 +597,30 @@ namespace BBWYB.Server.Business
{
var isSignAll = group.Count() == group.Where(x => x.ExpressState == "SIGN").Count();
//通知齐库
#region 通知齐库
var relationList = dbOrderPurchaseRelationInfoList.Where(x => x.PurchaseOrderId == group.Key).ToList();
foreach (var relation in relationList)
{
//通知C端
try
{
restApiService.SendRequest("http://qiku.qiyue666.com",
"/Api/PackPurchaseTask/UpdateAvailabilityState",
new
{
availability = isSignAll ? 0 : 1,
orderId = relation.OrderId,
skuId = relation.SourceSkuId
},
null,
HttpMethod.Post);
}
catch (Exception ex)
{
}
}
#endregion
}
var groupsByOrderIds = dbOrderPurchaseSkuInfoList.GroupBy(x => x.OrderId);

Loading…
Cancel
Save