From 0345e84303cbb1d7a6809764133cf3af7d5eff61 Mon Sep 17 00:00:00 2001 From: "mingliang.tang" Date: Tue, 4 Jul 2023 08:46:20 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E9=9B=B6=E4=BB=B6=E5=90=8C?= =?UTF-8?q?=E6=97=B6=E6=9B=B4=E6=96=B0=E5=BA=93=E5=AD=98=E4=BD=99=E9=A2=9D?= =?UTF-8?q?=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../IncomingToWmsExtensions.cs | 22 ++++++++++++++++++- 1 file changed, 21 insertions(+), 1 deletion(-) 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)