技术支持工单

2026-07-26 07:31:49 +08:00
parent ac1e0a9f13
commit 959e0b66cb
15 changed files with 906 additions and 4 deletions
@@ -0,0 +1,161 @@
+import {
+  BadRequestException,
+  Injectable,
+  NotFoundException,
+} from '@nestjs/common';
+import type { SupportTicketStatus, SupportTicketType } from '@prisma/client';
+import { Prisma } from '@prisma/client';
+import { PrismaService } from '../../common/prisma/prisma.module';
+import { serializeBigInt } from '../../common/decorators/current-user.decorator';
+import type {
+  CreateSupportTicketDto,
+  RejectSupportTicketDto,
+  SupportTicketListQueryDto,
+  SupportTicketRemarkDto,
+} from './dto/support-ticket.dto';
+
+function generateSupportTicketNo() {
+  return `ST${Date.now()}${Math.floor(Math.random() * 900 + 100)}`;
+}
+
+@Injectable()
+export class SupportTicketService {
+  constructor(private readonly prisma: PrismaService) {}
+
+  async create(
+    dto: CreateSupportTicketDto,
+    creator: { id: bigint; name: string },
+  ) {
+    const ticket = await this.prisma.commonSupportTicket.create({
+      data: {
+        ticketNo: generateSupportTicketNo(),
+        ticketType: dto.ticketType as SupportTicketType,
+        status: 'PENDING_REVIEW',
+        title: dto.title.trim(),
+        content: dto.content?.trim() || null,
+        remark: dto.remark?.trim() || null,
+        creatorId: creator.id,
+        creatorName: creator.name,
+      },
+    });
+    return serializeBigInt(ticket);
+  }
+
+  async list(query: SupportTicketListQueryDto) {
+    const page = query.page ?? 1;
+    const pageSize = query.pageSize ?? 20;
+    const where: Prisma.CommonSupportTicketWhereInput = {};
+    if (query.ticketType) {
+      where.ticketType = query.ticketType as SupportTicketType;
+    }
+    if (query.status) {
+      where.status = query.status as SupportTicketStatus;
+    }
+
+    const [items, total] = await Promise.all([
+      this.prisma.commonSupportTicket.findMany({
+        where,
+        orderBy: { createdAt: 'desc' },
+        skip: (page - 1) * pageSize,
+        take: pageSize,
+      }),
+      this.prisma.commonSupportTicket.count({ where }),
+    ]);
+    return serializeBigInt({ items, total, page, pageSize });
+  }
+
+  async detail(id: bigint) {
+    const ticket = await this.prisma.commonSupportTicket.findUnique({ where: { id } });
+    if (!ticket) throw new NotFoundException('技术支持工单不存在');
+    return serializeBigInt(ticket);
+  }
+
+  private async getOrThrow(id: bigint) {
+    const ticket = await this.prisma.commonSupportTicket.findUnique({ where: { id } });
+    if (!ticket) throw new NotFoundException('技术支持工单不存在');
+    return ticket;
+  }
+
+  /** 最高管理员评审通过 → 进入开发 */
+  async approve(
+    id: bigint,
+    reviewer: { id: bigint; name: string },
+    dto?: SupportTicketRemarkDto,
+  ) {
+    const ticket = await this.getOrThrow(id);
+    if (ticket.status !== 'PENDING_REVIEW') {
+      throw new BadRequestException('仅待评审工单可通过评审');
+    }
+    const updated = await this.prisma.commonSupportTicket.update({
+      where: { id },
+      data: {
+        status: 'DEVELOPING',
+        reviewerId: reviewer.id,
+        reviewerName: reviewer.name,
+        reviewedAt: new Date(),
+        remark: dto?.remark?.trim() || ticket.remark,
+      },
+    });
+    return serializeBigInt(updated);
+  }
+
+  /** 最高管理员评审驳回 */
+  async reject(
+    id: bigint,
+    reviewer: { id: bigint; name: string },
+    dto: RejectSupportTicketDto,
+  ) {
+    const ticket = await this.getOrThrow(id);
+    if (ticket.status !== 'PENDING_REVIEW') {
+      throw new BadRequestException('仅待评审工单可驳回');
+    }
+    const reason = dto.rejectReason.trim();
+    if (!reason) throw new BadRequestException('请填写驳回理由');
+
+    const updated = await this.prisma.commonSupportTicket.update({
+      where: { id },
+      data: {
+        status: 'REJECTED',
+        rejectReason: reason,
+        reviewerId: reviewer.id,
+        reviewerName: reviewer.name,
+        reviewedAt: new Date(),
+        completedAt: new Date(),
+      },
+    });
+    return serializeBigInt(updated);
+  }
+
+  /** 开发完成 → 测试 */
+  async startTesting(id: bigint, dto?: SupportTicketRemarkDto) {
+    const ticket = await this.getOrThrow(id);
+    if (ticket.status !== 'DEVELOPING') {
+      throw new BadRequestException('仅开发中工单可转入测试');
+    }
+    const updated = await this.prisma.commonSupportTicket.update({
+      where: { id },
+      data: {
+        status: 'TESTING',
+        remark: dto?.remark?.trim() || ticket.remark,
+      },
+    });
+    return serializeBigInt(updated);
+  }
+
+  /** 测试通过 */
+  async pass(id: bigint, dto?: SupportTicketRemarkDto) {
+    const ticket = await this.getOrThrow(id);
+    if (ticket.status !== 'TESTING') {
+      throw new BadRequestException('仅测试中工单可标记通过');
+    }
+    const updated = await this.prisma.commonSupportTicket.update({
+      where: { id },
+      data: {
+        status: 'PASSED',
+        remark: dto?.remark?.trim() || ticket.remark,
+        completedAt: new Date(),
+      },
+    });
+    return serializeBigInt(updated);
+  }
+}