feat: 首页全新改版

packages/ui/certd-server/src/controller/dashboard/statistic-controller.ts

@@ -0,0 +1,68 @@
+import { ALL, Body, Controller, Inject, Post, Provide } from '@midwayjs/core';
+import { BaseController, Constants } from '@certd/lib-server';
+import { UserService } from '../../modules/sys/authority/service/user-service.js';
+import { RoleService } from '../../modules/sys/authority/service/role-service.js';
+import { PipelineService } from '../../modules/pipeline/service/pipeline-service.js';
+import { HistoryService } from '../../modules/pipeline/service/history-service.js';
+
+export type ChartItem = {
+  name: string;
+  value: number;
+};
+export type UserStatisticCount = {
+  pipelineCount?: number;
+  pipelineStatusCount?: ChartItem[];
+  runningCount: ChartItem[];
+  expiringList: any[];
+};
+/**
+ */
+@Provide()
+@Controller('/api/statistic/')
+export class StatisticController extends BaseController {
+  @Inject()
+  userService: UserService;
+  @Inject()
+  roleService: RoleService;
+
+  @Inject()
+  pipelineService: PipelineService;
+  @Inject()
+  historyService: HistoryService;
+
+  @Post('/count', { summary: Constants.per.authOnly })
+  public async count() {
+    const pipelineCount = await this.pipelineService.count({ userId: this.getUserId() });
+    let pipelineStatusCount = await this.pipelineService.statusCount({ userId: this.getUserId() });
+    pipelineStatusCount = pipelineStatusCount.map(item => {
+      return {
+        name: item.status,
+        value: item.count,
+      };
+    });
+
+    const historyCount = await this.historyService.dayCount({ userId: this.getUserId(), days: 7 });
+    const runningCount = historyCount.map(item => {
+      return {
+        name: item.date,
+        value: item.count,
+      };
+    });
+
+    const expiringList = await this.pipelineService.latestExpiringList({ userId: this.getUserId(), count: 5 });
+    const count: UserStatisticCount = {
+      pipelineCount,
+      pipelineStatusCount,
+      runningCount,
+      expiringList,
+    };
+    return this.ok(count);
+  }
+
+  @Post('/changePassword', { summary: Constants.per.authOnly })
+  public async changePassword(@Body(ALL) body: any) {
+    const userId = this.getUserId();
+    await this.userService.changePassword(userId, body);
+    return this.ok({});
+  }
+}

packages/ui/certd-server/src/modules/pipeline/service/history-service.ts

@@ -1,6 +1,6 @@
 import { Config, Inject, Provide, Scope, ScopeEnum } from '@midwayjs/core';
 import { InjectEntityModel } from '@midwayjs/typeorm';
-import { In, Repository } from 'typeorm';
+import { In, MoreThan, Repository } from 'typeorm';
 import { BaseService, PageReq } from '@certd/lib-server';
 import { HistoryEntity } from '../entity/history.js';
 import { PipelineEntity } from '../entity/pipeline.js';
@@ -9,7 +9,7 @@ import { HistoryLogService } from './history-log-service.js';
 import { FileItem, Pipeline, RunnableCollection } from '@certd/pipeline';
 import { FileStore } from '@certd/pipeline';
 import { logger } from '@certd/pipeline';
-
+import dayjs from 'dayjs';
 /**
  * 证书申请
  */
@@ -174,4 +174,21 @@ export class HistoryService extends BaseService<HistoryEntity> {
       logger.error('删除文件失败', e);
     }
   }
+
+  async dayCount(param: { days: number; userId: any }) {
+    const todayEnd = dayjs().endOf('day');
+    const result = await this.getRepository()
+      .createQueryBuilder('main')
+      .select('date(main.createTime)  AS date') // 将UNIX时间戳转换为日期
+      .addSelect('COUNT(*) AS count')
+      .where({
+        // 0点
+        userId: param.userId,
+        createTime: MoreThan(todayEnd.add(-param.days, 'day').toDate()),
+      })
+      .groupBy('date')
+      .getRawMany();
+
+    return result;
+  }
 }

packages/ui/certd-server/src/modules/pipeline/service/pipeline-service.ts

@@ -71,11 +71,18 @@ export class PipelineService extends BaseService<PipelineEntity> {
 
   async page(pageReq: PageReq<PipelineEntity>) {
     const result = await super.page(pageReq);
+    await this.fillLastVars(result.records);
+
+    return result;
+  }
+
+  private async fillLastVars(records: PipelineEntity[]) {
     const pipelineIds: number[] = [];
     const recordMap = {};
-    for (const record of result.records) {
+    for (const record of records) {
       pipelineIds.push(record.id);
       recordMap[record.id] = record;
+      record.title = record.title + '';
     }
     if (pipelineIds?.length > 0) {
       const vars = await this.storageService.findPipelineVars(pipelineIds);
@@ -87,8 +94,6 @@ export class PipelineService extends BaseService<PipelineEntity> {
         }
       }
     }
-
-    return result;
   }
 
   public async registerTriggerById(pipelineId) {
@@ -467,4 +472,48 @@ export class PipelineService extends BaseService<PipelineEntity> {
     logEntity.logs = JSON.stringify(history.logs);
     await this.historyLogService.addOrUpdate(logEntity);
   }
+
+  async count(param: { userId: any }) {
+    const count = await this.repository.count({
+      where: {
+        userId: param.userId,
+      },
+    });
+    return count;
+  }
+
+  async statusCount(param: { userId: any }) {
+    const statusCount = await this.repository
+      .createQueryBuilder()
+      .select('status')
+      .addSelect('count(1)', 'count')
+      .where({
+        userId: param.userId,
+      })
+      .groupBy('status')
+      .getRawMany();
+    return statusCount;
+  }
+
+  async latestExpiringList({ userId }: any) {
+    let list = await this.repository.find({
+      select: {
+        id: true,
+        title: true,
+        status: true,
+      },
+      where: {
+        userId,
+      },
+    });
+    await this.fillLastVars(list);
+    list = list.filter(item => {
+      return item.lastVars?.certExpiresTime != null;
+    });
+    list = list.sort((a, b) => {
+      return a.lastVars.certExpiresTime - b.lastVars.certExpiresTime;
+    });
+
+    return list.slice(0, 5);
+  }
 }