diff --git a/be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/IncomingToWmsExtensions.cs b/be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/IncomingToWmsExtensions.cs index e5d108a13..cbaa74062 100644 --- a/be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/IncomingToWmsExtensions.cs +++ b/be/DataExchange/src/Win_in.Sfs.Wms.DataExchange.Agent/IncomingToWmsExtensions.cs @@ -1,5 +1,7 @@ +using System; using System.Collections.Generic; using System.Text.Json; +using System.Threading; using System.Threading.Tasks; using Microsoft.Extensions.DependencyInjection; using Volo.Abp.BackgroundWorkers; @@ -8,7 +10,6 @@ using Win_in.Sfs.Auth.Users; using Win_in.Sfs.Auth.Users.Inputs; using Win_in.Sfs.Basedata.Application.Contracts; using Win_in.Sfs.Label.Application.Contracts; -using Win_in.Sfs.Shared.Domain.Shared; using Win_in.Sfs.Wms.DataExchange.Domain; using Win_in.Sfs.Wms.Inventory.Application.Contracts; using Win_in.Sfs.Wms.Store.Application.Contracts; @@ -54,6 +55,25 @@ public static class IncomingToWmsExtensions var item = JsonSerializer.Deserialize(incomingConverted.DataContent); var itemBasicAppService = workerContext.ServiceProvider.GetRequiredService(); await itemBasicAppService.UpsertAsyncByInterface(item).ConfigureAwait(false); + + try + { + + var BalanceAppService = workerContext.ServiceProvider.GetRequiredService(); + BalanceUpdateItemBasicInfoDto balan = new BalanceUpdateItemBasicInfoDto(); + BalanceUpdateItemBasicInfo bala = new BalanceUpdateItemBasicInfo(); + bala.ItemCode = item.Code; + bala.ItemDesc1 = item.Desc1; + bala.ItemDesc2 = item.Desc2; + balan.BalanceUpdateItemBasicInfos.Add(bala); + await BalanceAppService.UpdateItemBasicInfoAsync(balan).ConfigureAwait(false); + } + catch (Exception e) + { + + + } + } public static async Task HandleErpLocationsAsync(this IncomingToWms incomingConverted, PeriodicBackgroundWorkerContext workerContext)