From c675d60dcd0fc85b07cbb01d909e2199385a7277 Mon Sep 17 00:00:00 2001 From: "qianhao.xu" Date: Fri, 30 Aug 2024 14:55:43 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A4=9A=E7=BA=BF=E7=A8=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- DOAN.Service/MES/ERP/InteractERPService.cs | 17 +++++++++-------- 1 file changed, 9 insertions(+), 8 deletions(-) diff --git a/DOAN.Service/MES/ERP/InteractERPService.cs b/DOAN.Service/MES/ERP/InteractERPService.cs index db66108..e7f55c9 100644 --- a/DOAN.Service/MES/ERP/InteractERPService.cs +++ b/DOAN.Service/MES/ERP/InteractERPService.cs @@ -234,7 +234,7 @@ namespace DOAN.Service.MES.ERP List ERPInventories = Context.AsTenant() .QueryableWithAttr().ToList(); - + //清空表 @@ -258,10 +258,10 @@ namespace DOAN.Service.MES.ERP material.Id = XueHua; material.CreatedBy = "ERP"; material.CreatedTime = DateTime.Now; - + } - // return Context.AsTenant().InsertableWithAttr(materialLists).ExecuteCommand(); + // return Context.AsTenant().InsertableWithAttr(materialLists).ExecuteCommand(); return childDb.Fastest().PageSize(100000).BulkCopy(materialLists); } @@ -272,14 +272,15 @@ namespace DOAN.Service.MES.ERP /// public int SynchERPBOM() { - + //ERP中的BOM List ERPBoms = Context.AsTenant().QueryableWithAttr().ToList(); - //清空表 耗时17s + var childDb = Context.AsTenant().GetConnectionWithAttr(); + Task.Run(() => { - Context.AsTenant().DeleteableWithAttr().ExecuteCommand(); - var childDb = Context.AsTenant().GetConnectionWithAttr();//线程安全用GetConnectionWithAttrScope + //清空表 耗时17s + childDb.Deleteable().ExecuteCommand(); childDb.Ado.ExecuteCommand("ALTER TABLE base_material_bom AUTO_INCREMENT = 1"); // 配置局部映射规则 TypeAdapterConfig.NewConfig() @@ -305,7 +306,7 @@ namespace DOAN.Service.MES.ERP } // return Context.AsTenant().InsertableWithAttr(baseMaterialBoms).ExecuteCommand(); - childDb.Fastest().PageSize(100000).BulkCopy(baseMaterialBoms); + childDb.Fastest().PageSize(100000).BulkCopy(baseMaterialBoms); }); return 1;