ソースを参照

事务异步整理

Murphy 2 年 前
コミット
4631199741

+ 0 - 1
MicroServices/Business/Business.Application/ReplenishmentManagement/ReplenishmentAppService.cs

@@ -5506,7 +5506,6 @@ namespace Business.Replenishment
                     {
                         _businessBangDbContext.BulkInsert(purchaseoccupyList);
                     }
-                    _businessBangDbContext.SaveChanges();
                     await unitOfWork.CompleteAsync();
                 }
                 catch (Exception e)

+ 5 - 4
MicroServices/Business/Business.Application/ResourceExamineManagement/ResourceExamineAppService.cs

@@ -1345,7 +1345,7 @@ namespace Business.ResourceExamineManagement
                         {
                             _businessDbContext.BulkUpdate(occupylist);
                         }
-                        unitOfWork.CompleteAsync();
+                       await unitOfWork.CompleteAsync();
                     }
                     catch (Exception e)
                     {
@@ -5024,7 +5024,6 @@ namespace Business.ResourceExamineManagement
                             _businessDbContext.BulkInsert(dlist);
                         }
                         await unitOfWork.CompleteAsync();
-                        return "ok";
                     }
                     catch (Exception e)
                     {
@@ -5033,6 +5032,7 @@ namespace Business.ResourceExamineManagement
                         return "保存失败,请联系管理员。";
                     }
                 }
+                return "ok";
             }
             else
             {
@@ -5087,7 +5087,7 @@ namespace Business.ResourceExamineManagement
                             {
                                 _businessDbContext.BulkInsert(dlist);
                             }
-                            return "ok";
+                            await unitOfWork.CompleteAsync();
                         }
                         catch (Exception e)
                         {
@@ -5096,6 +5096,7 @@ namespace Business.ResourceExamineManagement
                             return "保存失败,请联系管理员。";
                         }
                     }
+                    return "ok";
                 }
                 else
                 {
@@ -6482,7 +6483,7 @@ namespace Business.ResourceExamineManagement
                         {
                             _businessDbContext.BulkUpdate(occupylist);
                         }
-                        unitOfWork.CompleteAsync();
+                       await unitOfWork.CompleteAsync();
                     }
                     catch (Exception e)
                     {