Browse Source

更新

dev_DY_CC
赵新宇 1 year ago
parent
commit
ded20edb54
  1. 29
      be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.InjectionMoldingTaskAgent/Incoming/InjectionMoldingRequestReader.cs

29
be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.InjectionMoldingTaskAgent/Incoming/InjectionMoldingRequestReader.cs

@ -28,14 +28,14 @@ public class InjectionMoldingRequestReader : IReader
private readonly IInjectionRequestAppService _injectionRequest; private readonly IInjectionRequestAppService _injectionRequest;
private readonly IItemBasicAppService _itemService; private readonly IItemBasicAppService _itemService;
private readonly ILocationAppService _locService; private readonly ILocationAppService _locService;
private readonly IIncomingFromExternalManager _incomingFromExternalManager;
private readonly ILogger<InjectionMoldingRequestReader> _logger; private readonly ILogger<InjectionMoldingRequestReader> _logger;
private readonly IOptions<InjectionMoldingTaskOptions> _options; private readonly IOptions<InjectionMoldingTaskOptions> _options;
private readonly IHttpClientFactory _httpClientFactory; private readonly IHttpClientFactory _httpClientFactory;
public InjectionMoldingRequestReader( public InjectionMoldingRequestReader(
IInjectionRequestAppService injectionRequest IInjectionRequestAppService injectionRequest
, IIncomingFromExternalManager incomingFromExternalManager
, ILogger<InjectionMoldingRequestReader> logger , ILogger<InjectionMoldingRequestReader> logger
, IOptions<InjectionMoldingTaskOptions> options , IOptions<InjectionMoldingTaskOptions> options
, IHttpClientFactory httpClientFactory , IHttpClientFactory httpClientFactory
@ -45,7 +45,7 @@ public class InjectionMoldingRequestReader : IReader
) )
{ {
_injectionRequest = injectionRequest; _injectionRequest = injectionRequest;
_incomingFromExternalManager = incomingFromExternalManager;
_logger = logger; _logger = logger;
_options = options; _options = options;
_httpClientFactory = httpClientFactory; _httpClientFactory = httpClientFactory;
@ -54,6 +54,11 @@ public class InjectionMoldingRequestReader : IReader
} }
/// <summary>
/// 读取注塑叫料任务
/// </summary>
/// <returns></returns>
public virtual async Task<List<IncomingFromExternal>> ReadAsync() public virtual async Task<List<IncomingFromExternal>> ReadAsync()
{ {
try try
@ -180,8 +185,24 @@ public class InjectionMoldingRequestReader : IReader
return "Error occurred"; return "Error occurred";
} }
private List<InjectionRequest> Parse(string p_str)
{
List<InjectionRequest> requests = new List<InjectionRequest>();
return System.Text.Json.JsonSerializer.Deserialize<List<InjectionRequest>>(p_str);
}
public class InjectionRequest public class InjectionRequest
{ {
/// <summary> /// <summary>
/// 零件M /// 零件M

Loading…
Cancel
Save