diff --git a/ds-wms-service/DS.WMS.Core/TaskPlat/Other/TaskFlowRuner.cs b/ds-wms-service/DS.WMS.Core/TaskPlat/Other/TaskFlowRuner.cs index c70a634e..1a8e9145 100644 --- a/ds-wms-service/DS.WMS.Core/TaskPlat/Other/TaskFlowRuner.cs +++ b/ds-wms-service/DS.WMS.Core/TaskPlat/Other/TaskFlowRuner.cs @@ -309,7 +309,7 @@ namespace DS.WMS.Core.TaskPlat flowLogDetail.ElapsedMillisecond = stopwatch.ElapsedMilliseconds; flowLogDetail.IsComplete = true; - await tenantDb.Insertable(flowLogDetail).ExecuteCommandAsync(); + await tenantDb.CopyNew().Insertable(flowLogDetail).ExecuteCommandAsync(); } catch (Exception ex) { @@ -329,7 +329,7 @@ namespace DS.WMS.Core.TaskPlat flowLogDetail.IsComplete = false; flowLogDetail.IsSuccess = false; - await tenantDb.Insertable(flowLogDetail).ExecuteCommandAsync(); + await tenantDb.CopyNew().Insertable(flowLogDetail).ExecuteCommandAsync(); if (executeConfig.IsExceptionContinue) { @@ -342,7 +342,7 @@ namespace DS.WMS.Core.TaskPlat } } - await tenantDb.Insertable(flowLog).ExecuteCommandAsync(); + await tenantDb.CopyNew().Insertable(flowLog).ExecuteCommandAsync(); return (flowLog.Id, flowLog.IsComplete, flowLog.IsSuccess); }