From a070ff4409252d028b2e7957557059814bf1f862 Mon Sep 17 00:00:00 2001 From: FanLian Date: Fri, 8 Sep 2023 12:10:27 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E8=BD=BD=E5=85=B7=E5=AF=BC?= =?UTF-8?q?=E5=85=A5=E5=92=8C=E5=AF=BC=E5=85=A5=E8=BF=94=E5=9B=9E=E5=80=BC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Tnb.WarehouseMgr/WmsCarryLedgerService.cs | 15 ++++++++++++++- .../Tnb.VisualDev/VisualDevModelDataService.cs | 2 +- 2 files changed, 15 insertions(+), 2 deletions(-) diff --git a/WarehouseMgr/Tnb.WarehouseMgr/WmsCarryLedgerService.cs b/WarehouseMgr/Tnb.WarehouseMgr/WmsCarryLedgerService.cs index 7a455402..991c2dbd 100644 --- a/WarehouseMgr/Tnb.WarehouseMgr/WmsCarryLedgerService.cs +++ b/WarehouseMgr/Tnb.WarehouseMgr/WmsCarryLedgerService.cs @@ -96,7 +96,20 @@ namespace Tnb.WarehouseMgr x.modify_id = null; x.modify_time = null; }); - row = await _db.Insertable(carrys).ExecuteCommandAsync(); + if (carrys.Count > 1000) + { + await _db.Fastest().BulkCopyAsync(carrys); + } + else if (carrys.Count > 400) + { + _db.Utilities.PageEach(carrys, 100, async pageList => { + await _db.Insertable(pageList).ExecuteCommandAsync(); + }); + } + else + { + row = await _db.Insertable(carrys).ExecuteCommandAsync(); + } } catch (Exception ex) { diff --git a/visualdev/Tnb.VisualDev/VisualDevModelDataService.cs b/visualdev/Tnb.VisualDev/VisualDevModelDataService.cs index adc31b40..66b953c8 100644 --- a/visualdev/Tnb.VisualDev/VisualDevModelDataService.cs +++ b/visualdev/Tnb.VisualDev/VisualDevModelDataService.cs @@ -800,7 +800,7 @@ namespace JNPF.VisualDev var overideSvc = OverideVisualDevManager.GetOrDefault(modelId); if (overideSvc != null && overideSvc.OverideFuncs.ImportDataAsync != null) { - await overideSvc.OverideFuncs.ImportDataAsync(list); + result = await overideSvc.OverideFuncs.ImportDataAsync(list); } else {