From 22b1b80b1eaf56821735a62555c6a21a0a196f2b Mon Sep 17 00:00:00 2001
From: zhou keda <1315948824@qq.com>
Date: Thu, 27 Jun 2024 17:11:06 +0800
Subject: [PATCH] =?UTF-8?q?=E7=94=9F=E4=BA=A7=E6=8F=90=E6=8A=A5=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Tnb.ProductionMgr/PrdMoTaskService.cs       | 17 ++++++++++++-----
 .../Tnb.ProductionMgr/TimeWorkService.cs        |  2 +-
 2 files changed, 13 insertions(+), 6 deletions(-)

diff --git a/ProductionMgr/Tnb.ProductionMgr/PrdMoTaskService.cs b/ProductionMgr/Tnb.ProductionMgr/PrdMoTaskService.cs
index 0772557a..bae05527 100644
--- a/ProductionMgr/Tnb.ProductionMgr/PrdMoTaskService.cs
+++ b/ProductionMgr/Tnb.ProductionMgr/PrdMoTaskService.cs
@@ -1076,8 +1076,9 @@ namespace Tnb.ProductionMgr
                 throw new ArgumentException($"{nameof(input.Behavior)} not be null or empty");
             }
             ISqlSugarClient db = _repository.AsSugarClient();
-            DbResult<bool> result = await db.Ado.UseTranAsync(async () =>
+            try
             {
+                await db.Ado.BeginTranAsync();
                 List<PrdMoTask> prdTaskList = new List<PrdMoTask>();
                 //var taskList = await _db.Queryable<PrdMoTask>().Where(it => input.TaskIds.Contains(it.id) && it.mo_task_status == DictConst.ToBeScheduledEncode).ToListAsync();
                 //if (taskList?.Count > 0)
@@ -1477,11 +1478,17 @@ namespace Tnb.ProductionMgr
                         }
                     }
                 }
-            });
 
-            if (!result.IsSuccess)
-                throw Oops.Bah(result.ErrorMessage);
-            return result.IsSuccess ? "保存成功" : result.ErrorMessage;
+                await db.Ado.CommitTranAsync();
+            }
+            catch (Exception e)
+            {
+                Log.Error(e.Message,e);
+                await db.Ado.RollbackTranAsync();
+                throw Oops.Bah(e.Message);
+            }
+                
+            return "保存成功";
         }
 
         /// <summary>
diff --git a/ProductionMgr/Tnb.ProductionMgr/TimeWorkService.cs b/ProductionMgr/Tnb.ProductionMgr/TimeWorkService.cs
index fb14e393..6e94a14b 100644
--- a/ProductionMgr/Tnb.ProductionMgr/TimeWorkService.cs
+++ b/ProductionMgr/Tnb.ProductionMgr/TimeWorkService.cs
@@ -295,7 +295,7 @@ namespace Tnb.ProductionMgr
                          )
                         ))
                 {
-                    Log.Error($"{equipment.name}存在待下发的任务");
+                    Log.Error($"{equipment.name}存在未完成的任务");
                     continue;
                 }
                 bool? value = await _redisData.TryGetValueByKeyField<bool?>(eqpDaq.equip_code, eqpDaq.label_name);