feat: 只允许聚合一次

canyon-project · Oct 10, 2023 · fccf129 · fccf129
1 parent 5fbdd17
commit fccf129
Showing 1 changed file with 32 additions and 17 deletions.
diff --git a/packages/app-backend/src/coverage/services/trigger-agg-coverage.service.ts b/packages/app-backend/src/coverage/services/trigger-agg-coverage.service.ts
@@ -9,6 +9,15 @@ export class TriggerAggCoverageService {
   async invoke(params) {
     let { report_id } = params;
     const { pkgId } = params;
+    const tasks = await this.prisma.task
+      .findMany({
+        where: {
+          type: 'coverageagg',
+        },
+      })
+      .then((res) =>
+        res.filter((i: any) => i.data.report_id === params.report_id),
+      );
     if (pkgId) {
       try {
         report_id = await axios
@@ -39,24 +48,30 @@ export class TriggerAggCoverageService {
         code: 0,
       };
     }
-
-    await this.prisma.task.create({
-      data: {
-        name: `Coverage Agg Task ${report_id}`,
-        status: 'notstarted',
-        type: 'coverageagg',
+    if (tasks.length > 0) {
+      return {
+        msg: '该报告已聚合',
+        data: [],
+        code: -1,
+      };
+    } else {
+      await this.prisma.task.create({
         data: {
-          report_id: report_id,
+          name: `Coverage Agg Task ${report_id}`,
+          status: 'notstarted',
+          type: 'coverageagg',
+          data: {
+            report_id: report_id,
+          },
+          result: {},
+          logs: [],
         },
-        result: {},
-        logs: [],
-      },
-    });
-
-    return {
-      msg: '聚合中',
-      data: [],
-      code: 1,
-    };
+      });
+      return {
+        msg: '聚合中',
+        data: [],
+        code: 1,
+      };
+    }
   }
 }