4 changed files with 58 additions and 2 deletions
@ -0,0 +1,40 @@ |
|||
using System.Collections.Generic; |
|||
using System.Threading.Tasks; |
|||
using Volo.Abp.EventBus; |
|||
using Volo.Abp.Uow; |
|||
using Win_in.Sfs.Shared.Event; |
|||
using Win_in.Sfs.Wms.Store.Application.Contracts; |
|||
using Win_in.Sfs.Wms.Store.Domain; |
|||
|
|||
namespace Win_in.Sfs.Wms.Store.Event.DataExchanges; |
|||
|
|||
public class CustomerProductionReturnNoteEventHandler |
|||
: StoreDataExchangeEventHandlerBase<CustomerProductionReturnNote> |
|||
, ILocalEventHandler<SfsCreatedEntityEventData<CustomerProductionReturnNote>> |
|||
, ILocalEventHandler<SfsCreatedEntityEventData<List<CustomerProductionReturnNote>>> |
|||
|
|||
{ |
|||
private const EnumExchangeDataType ExchangeDataType = EnumExchangeDataType.CustomerReturn; |
|||
|
|||
[UnitOfWork] |
|||
public virtual async Task HandleEventAsync(SfsCreatedEntityEventData<CustomerProductionReturnNote> eventData) |
|||
{ |
|||
var entity = eventData.Entity; |
|||
await AddExchangeDataAsync(entity).ConfigureAwait(false); |
|||
} |
|||
|
|||
[UnitOfWork] |
|||
public virtual async Task HandleEventAsync(SfsCreatedEntityEventData<List<CustomerProductionReturnNote>> eventData) |
|||
{ |
|||
var entities = eventData.Entity; |
|||
await AddExchangeDataAsync(entities).ConfigureAwait(false); |
|||
} |
|||
|
|||
protected override async Task AddExchangeDataAsync(List<CustomerProductionReturnNote> entities) |
|||
{ |
|||
var dtos = ObjectMapper.Map<List<CustomerProductionReturnNote>, List<CustomerReturnNoteDTO>>(entities); |
|||
var exchangeData = await BuildExchangeDataAsync(StoreEventConsts.WMS, StoreEventConsts.ERP, ExchangeDataType, dtos).ConfigureAwait(false); |
|||
await AddManyAsync(exchangeData).ConfigureAwait(false); |
|||
} |
|||
|
|||
} |
Loading…
Reference in new issue