refactor: wrap in transaction

src/controllers/07-task-controller.ts

@@ -512,39 +512,37 @@ export class TaskActionController extends Controller {
 
     if (!record) throw notFoundError("Task Order");
 
-    await prisma.$transaction([
+    await prisma.$transaction(async (tx) => {
-      prisma.taskOrder.update({
+      await Promise.all([
-        where: { id: taskOrderId },
+        tx.taskOrder.update({
-        data: { taskOrderStatus: TaskOrderStatus.Complete },
+          where: { id: taskOrderId },
-      }),
+          data: { taskOrderStatus: TaskOrderStatus.Complete },
-      prisma.requestWorkStepStatus.updateMany({
+        }),
+        tx.requestWorkStepStatus.updateMany({
+          where: {
+            task: {
+              some: { taskOrderId, taskStatus: TaskStatus.Redo },
+            },
+          },
+          data: { workStatus: RequestWorkStatus.Ready },
+        }),
+        tx.task.updateMany({
+          where: {
+            taskOrderId: taskOrderId,
+            taskStatus: TaskStatus.Validate,
+            requestWorkStep: { responsibleUserId: submitUserId },
+          },
+          data: { taskStatus: TaskStatus.Complete },
+        }),
+      ]);
+      await tx.requestWorkStepStatus.updateMany({
         where: {
           task: {
-            some: { taskOrderId, taskStatus: TaskStatus.Redo },
+            some: { taskOrderId, taskStatus: TaskStatus.Complete },
           },
         },
-        data: { workStatus: RequestWorkStatus.Ready },
+        data: { workStatus: RequestWorkStatus.Completed },
-      }),
+      });
-      prisma.task.updateMany({
-        where: {
-          taskOrderId: taskOrderId,
-          taskStatus: TaskStatus.Validate,
-          requestWorkStep: { responsibleUserId: submitUserId },
-        },
-        data: { taskStatus: TaskStatus.Complete },
-      }),
-    ]);
-
-    await prisma.requestWorkStepStatus.updateMany({
-      where: {
-        task: {
-          some: { taskOrderId, taskStatus: TaskStatus.Complete },
-        },
-      },
-      data: { workStatus: RequestWorkStatus.Completed },
-    });
-
-    await prisma.$transaction(async (tx) => {
       const requestList = await tx.requestData.findMany({
         include: {
           requestWork: {
@@ -578,7 +576,6 @@ export class TaskActionController extends Controller {
       const completed: string[] = [];
 
       requestList.forEach((item) => {
-        console.log(item);
         const completeCheck = item.requestWork.every((work) => {
           const stepCount =
             work.productService.work?.productOnWork.find(