upd

packages/canyon-backend/src/coverage/coverage.module.ts

@@ -13,6 +13,7 @@ import {
 import { CoverageDataAdapterService } from './services/coverage-data-adapter.service';
 import { ConsumerCoverageService } from './services/consumer-coverage.service';
 import { PullChangeCodeAndInsertDbService } from './services/pull-change-code-and-insert-db.service';
+import { CoverageLog, CoverageLogSchema } from './schemas/coverage-log.schema';
 
 @Module({
   imports: [
@@ -22,6 +23,11 @@ import { PullChangeCodeAndInsertDbService } from './services/pull-change-code-an
         schema: CoverageDataSchema,
         collection: 'canyon_coverage_data',
       },
+      {
+        name: CoverageLog.name,
+        schema: CoverageLogSchema,
+        collection: 'canyon_coverage_log',
+      },
     ]),
   ],
   controllers: [CoverageController],

packages/canyon-backend/src/coverage/schemas/coverage-log.schema.ts

@@ -0,0 +1,17 @@
+import { Prop, Schema, SchemaFactory } from '@nestjs/mongoose';
+// 定义 'ant' 类型
+// 定义 antType 类型
+// type CoverageType = {
+//   [key: string]: object;
+// };
+
+@Schema()
+export class CoverageLog {
+  @Prop()
+  coverageID: string;
+
+  @Prop({ type: Object })
+  coverage: any;
+}
+
+export const CoverageLogSchema = SchemaFactory.createForClass(CoverageLog);

packages/canyon-backend/src/coverage/services/coverage-client.service.ts

@@ -10,6 +10,10 @@ import { CoverageClientDto } from '../dto/coverage-client.dto';
 import { formatReportObject } from '../../utils/coverage';
 import { Coverage } from '@prisma/client';
 import { pushQueue } from '../../queues/coverage';
+import { InjectModel } from '@nestjs/mongoose';
+// import { CoverageData } from '../schemas/coverage-data.schema';
+import { Model } from 'mongoose';
+import { CoverageLog } from '../schemas/coverage-log.schema';
 /**
  * 上传覆盖率，十分重要的服务
  */
@@ -26,7 +30,11 @@ function checkUserID(id) {
 
 @Injectable()
 export class CoverageClientService {
-  constructor(private readonly prisma: PrismaService) {}
+  constructor(
+    private readonly prisma: PrismaService,
+    @InjectModel(CoverageLog.name)
+    private coverageLogModel: Model<CoverageLog>,
+  ) {}
 
   async invoke(currentUser, coverageClientDto: CoverageClientDto) {
     if (coverageClientDto.projectID === '98620') {
@@ -100,7 +108,13 @@ export class CoverageClientService {
       //后加的
       coverage: coverageReport.coverage,
     };
-
+    await this.coverageLogModel.create({
+      coverageID: cov.id,
+      coverage: {
+        ...cov,
+        coverage: 1,
+      },
+    });
     pushQueue(cov);
     return {
       msg: 'ok',