Browse Source

接口修改

集成Redis
唐明亮 2 years ago
parent
commit
1d391addac
  1. 10
      be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent/Incoming/ShipReader.cs

10
be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent/Incoming/ShipReader.cs

@ -19,18 +19,20 @@ public class ShipReader : IReader
private readonly IIncomingFromExternalManager _incomingFromExternalManager; private readonly IIncomingFromExternalManager _incomingFromExternalManager;
private readonly ILogger<ShipReader> _logger; private readonly ILogger<ShipReader> _logger;
private readonly ISupplierItemAppService _supplierItemAppService; private readonly ISupplierItemAppService _supplierItemAppService;
private readonly ISupplierAppService _supplierAppService;
public ShipReader( public ShipReader(
IShipManager shipManager IShipManager shipManager
, IIncomingFromExternalManager incomingFromExternalManager , IIncomingFromExternalManager incomingFromExternalManager
, ILogger<ShipReader> logger, , ILogger<ShipReader> logger,
ISupplierItemAppService supplierItemAppService ISupplierItemAppService supplierItemAppService,
ISupplierAppService supplierAppService
) )
{ {
_shipManager = shipManager; _shipManager = shipManager;
_incomingFromExternalManager = incomingFromExternalManager; _incomingFromExternalManager = incomingFromExternalManager;
_logger = logger; _logger = logger;
_supplierItemAppService = supplierItemAppService; _supplierItemAppService = supplierItemAppService;
_supplierAppService = supplierAppService;
} }
public virtual async Task<List<IncomingFromExternal>> ReadAsync() public virtual async Task<List<IncomingFromExternal>> ReadAsync()
@ -103,10 +105,12 @@ public class ShipReader : IReader
continue; continue;
} }
var supplierItemDTO = await _supplierItemAppService.GetBySupplierCodeAndItemCodeAsync(item.SupplierCode, item.ERP).ConfigureAwait(false); var supplierItemDTO = await _supplierItemAppService.GetBySupplierCodeAndItemCodeAsync(item.SupplierCode, item.ERP).ConfigureAwait(false);
if (supplierItemDTO == null) var supplierDto = await _supplierAppService.GetByCodeAsync(item.SupplierCode).ConfigureAwait(false);
if (supplierItemDTO == null||supplierDto==null)
{ {
shipbillno.Add(item.ShipBillNo); shipbillno.Add(item.ShipBillNo);
} }
} }
return shipbillno; return shipbillno;
} }

Loading…
Cancel
Save