|
|
@ -17,13 +17,13 @@ using Win_in.Sfs.Wms.Store.Domain.Shared; |
|
|
|
|
|
|
|
namespace Win_in.Sfs.Wms.Store.Event.BusinessRequest; |
|
|
|
|
|
|
|
public class AssembleIssueRequestsEventHandler |
|
|
|
public class AssembleIssueRequestEventHandler |
|
|
|
: StoreEventHandlerBase |
|
|
|
, ILocalEventHandler<SfsHandledEntityEventData<AssembleIssueRequests>> |
|
|
|
, ILocalEventHandler<SfsAbortedEntityEventData<AssembleIssueRequests>> |
|
|
|
, ILocalEventHandler<SfsCompletedEntityEventData<AssembleIssueRequests>> |
|
|
|
, ILocalEventHandler<SfsCreatedEntityEventData<AssembleIssueRequests>> |
|
|
|
, ILocalEventHandler<SfsCreatedEntityEventData<List<AssembleIssueRequests>>> |
|
|
|
, ILocalEventHandler<SfsHandledEntityEventData<AssembleIssueRequest>> |
|
|
|
, ILocalEventHandler<SfsAbortedEntityEventData<AssembleIssueRequest>> |
|
|
|
, ILocalEventHandler<SfsCompletedEntityEventData<AssembleIssueRequest>> |
|
|
|
, ILocalEventHandler<SfsCreatedEntityEventData<AssembleIssueRequest>> |
|
|
|
, ILocalEventHandler<SfsCreatedEntityEventData<List<AssembleIssueRequest>>> |
|
|
|
{ |
|
|
|
private readonly IAssembleIssueJobAppService _assembleJobAppService; |
|
|
|
private readonly IProductionLineAppService _productionLineAppService; |
|
|
@ -31,7 +31,7 @@ public class AssembleIssueRequestsEventHandler |
|
|
|
private readonly ILocationAppService _locationAppService; |
|
|
|
private readonly IBalanceAppService _balanceAppService; |
|
|
|
|
|
|
|
public AssembleIssueRequestsEventHandler( |
|
|
|
public AssembleIssueRequestEventHandler( |
|
|
|
IAssembleIssueJobAppService assembleJobAppService, IProductionLineAppService productionLineAppService, |
|
|
|
ILocationAppService locationAppService, |
|
|
|
IBalanceAppService balanceAppService, IProductionLineItemAppService productionLineItemAppService) |
|
|
@ -47,7 +47,7 @@ public class AssembleIssueRequestsEventHandler |
|
|
|
/// 创建后
|
|
|
|
/// </summary>
|
|
|
|
/// <param name="eventData">Event data</param>
|
|
|
|
public virtual async Task HandleEventAsync(SfsCreatedEntityEventData<AssembleIssueRequests> eventData) |
|
|
|
public virtual async Task HandleEventAsync(SfsCreatedEntityEventData<AssembleIssueRequest> eventData) |
|
|
|
{ |
|
|
|
await Task.CompletedTask.ConfigureAwait(false); |
|
|
|
} |
|
|
@ -56,7 +56,7 @@ public class AssembleIssueRequestsEventHandler |
|
|
|
/// 批量创建后
|
|
|
|
/// </summary>
|
|
|
|
/// <param name="eventData">Event data</param>
|
|
|
|
public virtual async Task HandleEventAsync(SfsCreatedEntityEventData<List<AssembleIssueRequests>> eventData) |
|
|
|
public virtual async Task HandleEventAsync(SfsCreatedEntityEventData<List<AssembleIssueRequest>> eventData) |
|
|
|
{ |
|
|
|
await Task.CompletedTask.ConfigureAwait(false); |
|
|
|
} |
|
|
@ -66,7 +66,7 @@ public class AssembleIssueRequestsEventHandler |
|
|
|
/// </summary>
|
|
|
|
/// <param name="eventData"></param>
|
|
|
|
/// <returns></returns>
|
|
|
|
public virtual async Task HandleEventAsync(SfsHandledEntityEventData<AssembleIssueRequests> eventData) |
|
|
|
public virtual async Task HandleEventAsync(SfsHandledEntityEventData<AssembleIssueRequest> eventData) |
|
|
|
{ |
|
|
|
var entity = eventData.Entity; |
|
|
|
|
|
|
@ -93,7 +93,7 @@ public class AssembleIssueRequestsEventHandler |
|
|
|
/// </summary>
|
|
|
|
/// <param name="eventData"></param>
|
|
|
|
/// <returns></returns>
|
|
|
|
public virtual async Task HandleEventAsync(SfsAbortedEntityEventData<AssembleIssueRequests> eventData) |
|
|
|
public virtual async Task HandleEventAsync(SfsAbortedEntityEventData<AssembleIssueRequest> eventData) |
|
|
|
{ |
|
|
|
await Task.CompletedTask.ConfigureAwait(false); |
|
|
|
} |
|
|
@ -103,10 +103,10 @@ public class AssembleIssueRequestsEventHandler |
|
|
|
/// </summary>
|
|
|
|
/// <param name="eventData"></param>
|
|
|
|
/// <returns></returns>
|
|
|
|
public virtual async Task HandleEventAsync(SfsCompletedEntityEventData<AssembleIssueRequests> eventData) |
|
|
|
public virtual async Task HandleEventAsync(SfsCompletedEntityEventData<AssembleIssueRequest> eventData) |
|
|
|
{ |
|
|
|
_ = eventData.Entity; |
|
|
|
// await _assembleJobAppService.CompleteByAssembleIssueRequestsAsync(entity.Number);
|
|
|
|
// await _assembleJobAppService.CompleteByAssembleIssueRequestAsync(entity.Number);
|
|
|
|
|
|
|
|
await Task.CompletedTask.ConfigureAwait(false); |
|
|
|
} |
|
|
@ -122,7 +122,7 @@ public class AssembleIssueRequestsEventHandler |
|
|
|
/// <returns></returns>
|
|
|
|
/// <exception cref="UserFriendlyException"></exception>
|
|
|
|
private async Task<List<AssembleIssueJobEditInput>> CreateAssembleIssueJobWithQtyTypeAsync |
|
|
|
(AssembleIssueRequests assembleRequest) |
|
|
|
(AssembleIssueRequest assembleRequest) |
|
|
|
{ |
|
|
|
var jobs = new List<AssembleIssueJobEditInput>(); |
|
|
|
|
|
|
@ -201,11 +201,11 @@ public class AssembleIssueRequestsEventHandler |
|
|
|
/// <param name="fromLocation"></param>
|
|
|
|
/// <returns></returns>
|
|
|
|
private async Task<AssembleIssueJobEditInput> BuildAssembleIssueJobCreateInputWithQtyTypeAsync( |
|
|
|
AssembleIssueRequests assembleRequest, |
|
|
|
AssembleIssueRequest assembleRequest, |
|
|
|
LocationDTO fromLocation) |
|
|
|
{ |
|
|
|
AssembleIssueJobEditInput job; |
|
|
|
job = ObjectMapper.Map<AssembleIssueRequests, AssembleIssueJobEditInput>(assembleRequest); |
|
|
|
job = ObjectMapper.Map<AssembleIssueRequest, AssembleIssueJobEditInput>(assembleRequest); |
|
|
|
job.JobType = EnumJobType.IssueJob; |
|
|
|
job.JobStatus = EnumJobStatus.Open; |
|
|
|
job.WorkGroupCode = fromLocation.WorkGroupCode; |
|
|
@ -216,7 +216,7 @@ public class AssembleIssueRequestsEventHandler |
|
|
|
job.Worker = "admin"; |
|
|
|
} |
|
|
|
|
|
|
|
job.AssembleIssueRequestsNumber = assembleRequest.Number; |
|
|
|
job.AssembleIssueRequestNumber = assembleRequest.Number; |
|
|
|
|
|
|
|
await Task.CompletedTask.ConfigureAwait(false); |
|
|
|
|
|
|
@ -232,8 +232,8 @@ public class AssembleIssueRequestsEventHandler |
|
|
|
/// <returns></returns>
|
|
|
|
/// <exception cref="UserFriendlyException"></exception>
|
|
|
|
private async Task<List<AssembleIssueJobDetailInput>> CreateAssembleIssueJobDetailInputsWithQtyTypeAsync( |
|
|
|
AssembleIssueRequests assembleRequest, |
|
|
|
AssembleIssueRequestsDetail assembleRequestDetail, string toLocationGroupCode) |
|
|
|
AssembleIssueRequest assembleRequest, |
|
|
|
AssembleIssueRequestDetail assembleRequestDetail, string toLocationGroupCode) |
|
|
|
{ |
|
|
|
var jobDetails = new List<AssembleIssueJobDetailInput>(); |
|
|
|
|
|
|
@ -296,7 +296,7 @@ public class AssembleIssueRequestsEventHandler |
|
|
|
/// <param name="toLocationGroupCode"></param>
|
|
|
|
/// <returns></returns>
|
|
|
|
private async Task<AssembleIssueJobDetailInput> BuildAssembleIssueJobDetailWithQtyTypeAsync( |
|
|
|
AssembleIssueRequestsDetail assembleRequestDetail, BalanceDTO balance, string toLocationGroupCode) |
|
|
|
AssembleIssueRequestDetail assembleRequestDetail, BalanceDTO balance, string toLocationGroupCode) |
|
|
|
{ |
|
|
|
//ProductionLineDTO prodLine = await _productionLineAppService.GetByLocationGroupCodeAsync(toLocationGroupCode).ConfigureAwait(false);
|
|
|
|
|
|
|
@ -343,7 +343,7 @@ public class AssembleIssueRequestsEventHandler |
|
|
|
/// <returns></returns>
|
|
|
|
/// <exception cref="UserFriendlyException"></exception>
|
|
|
|
private async Task<List<AssembleIssueJobEditInput>> CreateAssembleIssueJobWithBoxQtyTypeAsync |
|
|
|
(AssembleIssueRequests assembleRequest) |
|
|
|
(AssembleIssueRequest assembleRequest) |
|
|
|
{ |
|
|
|
var inputJobs = new List<AssembleIssueJobEditInput>(); |
|
|
|
var inputExpectOutEditInput = new ExpectOutEditInput(); |
|
|
@ -418,16 +418,16 @@ public class AssembleIssueRequestsEventHandler |
|
|
|
/// <param name="balanceDtos"></param>
|
|
|
|
/// <returns></returns>
|
|
|
|
private async Task<AssembleIssueJobEditInput> BuildAssembleIssueJobCreateInputWithBoxQtyTypeAsync( |
|
|
|
AssembleIssueRequests assembleRequest, |
|
|
|
AssembleIssueRequestsDetail assembleRequestDetail, BalanceDTO balanceDtos) |
|
|
|
AssembleIssueRequest assembleRequest, |
|
|
|
AssembleIssueRequestDetail assembleRequestDetail, BalanceDTO balanceDtos) |
|
|
|
{ |
|
|
|
var job = ObjectMapper.Map<AssembleIssueRequests, AssembleIssueJobEditInput>(assembleRequest); |
|
|
|
var job = ObjectMapper.Map<AssembleIssueRequest, AssembleIssueJobEditInput>(assembleRequest); |
|
|
|
job.JobType = EnumJobType.IssueJob; |
|
|
|
job.JobStatus = EnumJobStatus.Open; |
|
|
|
job.WorkGroupCode = assembleRequestDetail.ToLocationGroup; |
|
|
|
job.WarehouseCode = assembleRequestDetail.ToWarehouseCode; |
|
|
|
job.Worker = assembleRequest.Worker; |
|
|
|
job.AssembleIssueRequestsNumber = assembleRequest.Number; |
|
|
|
job.AssembleIssueRequestNumber = assembleRequest.Number; |
|
|
|
|
|
|
|
job.Details.Add(await BuildAssembleIssueJobDetailWithBoxQtyTypeAsync(assembleRequestDetail, balanceDtos) |
|
|
|
.ConfigureAwait(false)); |
|
|
@ -445,7 +445,7 @@ public class AssembleIssueRequestsEventHandler |
|
|
|
/// <param name="toLocationGroupCode"></param>
|
|
|
|
/// <returns></returns>
|
|
|
|
private async Task<AssembleIssueJobDetailInput> BuildAssembleIssueJobDetailWithBoxQtyTypeAsync( |
|
|
|
AssembleIssueRequestsDetail assembleRequestDetail, BalanceDTO balance) |
|
|
|
AssembleIssueRequestDetail assembleRequestDetail, BalanceDTO balance) |
|
|
|
{ |
|
|
|
var detail = new AssembleIssueJobDetailInput(); |
|
|
|
detail.RequestLocationCode = assembleRequestDetail.ToLocationCode; |