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;