郑勃旭 2 years ago
parent
commit
09fb537163
  1. 26
      be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/IncomingToWmsWorker.cs

26
be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/IncomingToWmsWorker.cs

@ -67,7 +67,8 @@ public class IncomingToWmsWorker : AsyncPeriodicBackgroundWorkerBase
{ {
try try
{ {
await AddOrUpdateWmsAsync(workerContext, incomingToWms).ConfigureAwait(false); await AddOrUpdateWmsAsync(workerContext, incomingToWms).ConfigureAwait(false);
} }
catch (Exception e) catch (Exception e)
{ {
@ -168,8 +169,8 @@ public class IncomingToWmsWorker : AsyncPeriodicBackgroundWorkerBase
private async Task SendProductReceipt(PeriodicBackgroundWorkerContext workerContext, IncomingToWms incomingToWms) private async Task SendProductReceipt(PeriodicBackgroundWorkerContext workerContext, IncomingToWms incomingToWms)
{ // 定义请求的 URL { // 定义请求的 URL
string apiUrl = "http://dev.ccwin-in.com:60085/api/wms/store/product-receipt-note"; string apiUrl = "http://10.164.113.31:60085/api/wms/store/product-receipt-note";
string authUrl = "http://dev.ccwin-in.com:60083";
var productReceiptJson = JsonSerializer.Deserialize<ProductReceiptNoteEditInput>(incomingToWms.DataContent); var productReceiptJson = JsonSerializer.Deserialize<ProductReceiptNoteEditInput>(incomingToWms.DataContent);
try try
{ {
@ -195,20 +196,17 @@ public class IncomingToWmsWorker : AsyncPeriodicBackgroundWorkerBase
// 处理请求异常 // 处理请求异常
// 可以记录日志或者抛出异常 // 可以记录日志或者抛出异常
Console.WriteLine(ex.Message); Console.WriteLine(ex.Message);
incomingToWms.SetError(EnumExchangeDataErrorCode.Exception, ex.Message); //incomingToWms.SetError(EnumExchangeDataErrorCode.Exception, ex.Message);
} }
finally //finally
{ //{
//Resolve dependencies // //Resolve dependencies
var incomingToWmsManager = workerContext.ServiceProvider.GetRequiredService<IIncomingToWmsManager>(); // var incomingToWmsManager = workerContext.ServiceProvider.GetRequiredService<IIncomingToWmsManager>();
//Do the work
var incomingToWmsList = await incomingToWmsManager.GetToBeProcessedListAsync().ConfigureAwait(false);
//归档并删除
await incomingToWmsManager.ArchiveAutoSaveAsync(incomingToWms).ConfigureAwait(false);
} // //归档并删除
// await incomingToWmsManager.ArchiveAutoSaveAsync(incomingToWms).ConfigureAwait(false);
// await incomingToWms.HandleProductReceiptsAsync(workerContext).ConfigureAwait(false); //}
} }
} }

Loading…
Cancel
Save