9 changed files with 373 additions and 32 deletions
@ -0,0 +1,157 @@ |
|||||
|
using System; |
||||
|
using System.Collections.Generic; |
||||
|
using System.Linq; |
||||
|
using System.Threading.Tasks; |
||||
|
using Volo.Abp.EventBus; |
||||
|
using Volo.Abp.Uow; |
||||
|
using Win_in.Sfs.Basedata.Application.Contracts; |
||||
|
using Win_in.Sfs.Shared.Domain.Shared; |
||||
|
using Win_in.Sfs.Shared.Event; |
||||
|
using Win_in.Sfs.Wms.Inventory.Application.Contracts; |
||||
|
using Win_in.Sfs.Wms.Store.Domain; |
||||
|
using Win_in.Sfs.Wms.Store.Event.Transaction; |
||||
|
|
||||
|
namespace Win_in.Sfs.Wms.Store.Event.Transactions; |
||||
|
|
||||
|
public class ThirdLocationNoteEventHandler |
||||
|
: StoreInventoryEventHandlerBase |
||||
|
, ILocalEventHandler<SfsCreatedEntityEventData<ThirdLocationNote>> |
||||
|
, ILocalEventHandler<SfsCreatedEntityEventData<List<ThirdLocationNote>>> |
||||
|
, ILocalEventHandler<SfsConfirmedEntityEventData<ThirdLocationNote>> |
||||
|
{ |
||||
|
private const EnumTransType TransType = EnumTransType.TransferLib; |
||||
|
|
||||
|
private readonly ILocationAppService _locationAppService; |
||||
|
|
||||
|
public ThirdLocationNoteEventHandler(ILocationAppService locationAppService) |
||||
|
{ |
||||
|
_locationAppService = locationAppService; |
||||
|
} |
||||
|
|
||||
|
[UnitOfWork] |
||||
|
public virtual async Task HandleEventAsync(SfsCreatedEntityEventData<ThirdLocationNote> eventData) |
||||
|
{ |
||||
|
var entity = eventData.Entity; |
||||
|
var transferLogs = new List<TransferLogEditInput>(); |
||||
|
var route = EnumTransferRoute.OnTheWayToDestination; |
||||
|
|
||||
|
transferLogs.AddRange(await BuildTransferLogsAsync(entity, route).ConfigureAwait(false)); |
||||
|
|
||||
|
|
||||
|
await TransferLogAppService.AddManyAsync(transferLogs).ConfigureAwait(false); |
||||
|
} |
||||
|
|
||||
|
[UnitOfWork] |
||||
|
public virtual async Task HandleEventAsync(SfsCreatedEntityEventData<List<ThirdLocationNote>> eventData) |
||||
|
{ |
||||
|
var entities = eventData.Entity; |
||||
|
var transferLogs = new List<TransferLogEditInput>(); |
||||
|
//如果要做库存事务汇总,可以修改此处
|
||||
|
foreach (var thirdLocationNote in entities) |
||||
|
{ |
||||
|
var route = EnumTransferRoute.OnTheWayToDestination; |
||||
|
|
||||
|
transferLogs.AddRange(await BuildTransferLogsAsync(thirdLocationNote, route).ConfigureAwait(false)); |
||||
|
} |
||||
|
|
||||
|
await TransferLogAppService.AddManyAsync(transferLogs).ConfigureAwait(false); |
||||
|
} |
||||
|
|
||||
|
[UnitOfWork] |
||||
|
|
||||
|
public virtual async Task HandleEventAsync(SfsConfirmedEntityEventData<ThirdLocationNote> eventData) |
||||
|
{ |
||||
|
var entity = eventData.Entity; |
||||
|
|
||||
|
var inputList = await BuildTransferLogsAsync(entity, EnumTransferRoute.OnTheWayToDestination).ConfigureAwait(false); |
||||
|
await AddTransferLogsAsync(inputList).ConfigureAwait(false); |
||||
|
} |
||||
|
|
||||
|
private async Task AddTransferLogsAsync(List<TransferLogEditInput> inputList) |
||||
|
{ |
||||
|
var transferLogs = new List<TransferLogEditInput>(); |
||||
|
|
||||
|
transferLogs.AddRange(inputList); |
||||
|
|
||||
|
await TransferLogAppService.AddManyAsync(transferLogs).ConfigureAwait(false); |
||||
|
|
||||
|
} |
||||
|
|
||||
|
private async Task<List<TransferLogEditInput>> BuildTransferLogsAsync(ThirdLocationNote thirdLocationNote, EnumTransferRoute route) |
||||
|
{ |
||||
|
var transferLogs = new List<TransferLogEditInput>(); |
||||
|
foreach (var detail in thirdLocationNote.Details.Where(detail => detail.Qty != 0)) |
||||
|
{ |
||||
|
var transferLog = ObjectMapper.Map<ThirdLocationNoteDetail, TransferLogEditInput>(detail); |
||||
|
|
||||
|
LocationDTO fromLocationDTO = null; |
||||
|
LocationDTO toLocationDTO = null; |
||||
|
|
||||
|
if (thirdLocationNote.UseOnTheWayLocation) |
||||
|
{ |
||||
|
var location = await _locationAppService.GetByCodeAsync(detail.OnTheWayLocationCode).ConfigureAwait(false); |
||||
|
switch (route) |
||||
|
{ |
||||
|
case EnumTransferRoute.SourceToOnTheWay: |
||||
|
fromLocationDTO = await _locationAppService.GetByCodeAsync(detail.FromLocationCode).ConfigureAwait(false); |
||||
|
|
||||
|
toLocationDTO = await _locationAppService.GetByCodeAsync(detail.OnTheWayLocationCode).ConfigureAwait(false); |
||||
|
break; |
||||
|
case EnumTransferRoute.OnTheWayToDestination: |
||||
|
fromLocationDTO = await _locationAppService.GetByCodeAsync(detail.OnTheWayLocationCode).ConfigureAwait(false); |
||||
|
|
||||
|
toLocationDTO = await _locationAppService.GetByCodeAsync(detail.ToLocationCode).ConfigureAwait(false); |
||||
|
|
||||
|
await RemovePackingCodeAndContainerCodeAndLotAsync(transferLog).ConfigureAwait(false); |
||||
|
break; |
||||
|
case EnumTransferRoute.SourceToDestination: |
||||
|
default: |
||||
|
throw new ArgumentOutOfRangeException(nameof(route), route, null); |
||||
|
} |
||||
|
} |
||||
|
else |
||||
|
{ |
||||
|
fromLocationDTO = await _locationAppService.GetByCodeAsync(detail.FromLocationCode).ConfigureAwait(false); |
||||
|
toLocationDTO = await _locationAppService.GetByCodeAsync(detail.ToLocationCode).ConfigureAwait(false); |
||||
|
} |
||||
|
|
||||
|
transferLog.FromLocationCode = fromLocationDTO.Code; |
||||
|
transferLog.FromLocationArea = fromLocationDTO.AreaCode; |
||||
|
transferLog.FromLocationErpCode = fromLocationDTO.ErpLocationCode; |
||||
|
transferLog.FromLocationGroup = fromLocationDTO.LocationGroupCode; |
||||
|
|
||||
|
transferLog.ToLocationCode = toLocationDTO.Code; |
||||
|
transferLog.ToLocationArea = toLocationDTO.AreaCode; |
||||
|
transferLog.ToLocationErpCode = toLocationDTO.ErpLocationCode; |
||||
|
transferLog.ToLocationGroup = toLocationDTO.LocationGroupCode; |
||||
|
transferLog.TransSubType = Enum.Parse<EnumTransSubType>(thirdLocationNote.RequestType); |
||||
|
transferLog.TransType = TransType; |
||||
|
transferLog.DocNumber = thirdLocationNote.Number; |
||||
|
transferLog.JobNumber = thirdLocationNote.JobNumber; |
||||
|
|
||||
|
transferLog.FromPackingCode = ""; |
||||
|
transferLog.FromLot = ""; |
||||
|
transferLog.ToPackingCode = ""; |
||||
|
transferLog.ToLot = ""; |
||||
|
transferLog.FromStatus = EnumInventoryStatus.OK; |
||||
|
transferLog.ToStatus = EnumInventoryStatus.OK; |
||||
|
|
||||
|
transferLogs.Add(transferLog); |
||||
|
} |
||||
|
|
||||
|
return transferLogs; |
||||
|
} |
||||
|
|
||||
|
private async Task RemovePackingCodeAndContainerCodeAndLotAsync(TransferLogEditInput transferLogCreateInput) |
||||
|
{ |
||||
|
transferLogCreateInput.ToPackingCode = ""; |
||||
|
transferLogCreateInput.ToLot = ""; |
||||
|
transferLogCreateInput.ToContainerCode = ""; |
||||
|
|
||||
|
transferLogCreateInput.FromPackingCode = ""; |
||||
|
transferLogCreateInput.FromLot = ""; |
||||
|
transferLogCreateInput.FromContainerCode = ""; |
||||
|
|
||||
|
} |
||||
|
|
||||
|
} |
Loading…
Reference in new issue