feat: 支付闭环 + 运营助手 Tool Calling + 管理后台完善

- 支付系统：微信支付 mock 自动完成、NATIVE 扫码支付、JSAPI 集成 - 运营助手：Tool Calling 架构，19 个可执行工具，AI 驱动操作 - 角色管理：表格布局 + Dialog 表单 + 权限勾选 - 配置统一：config.ts 单一数据源 - API 审计：补齐 status toggle / comments 端点 - 暗黑模式硬件编码颜色全部替换为 CSS 变量
2026-05-20 18:29:00 +08:00
parent 728edc59ef
commit 23edb74bce
76 changed files with 1589 additions and 473 deletions
@@ -0,0 +1,309 @@
+import { Injectable } from '@nestjs/common';
+import { PrismaService } from '../../prisma/prisma.service';
+
+export interface ToolDefinition {
+  name: string;
+  description: string;
+  parameters: Record<string, any>;
+}
+
+export interface ToolCall {
+  tool: string;
+  params: Record<string, any>;
+  description?: string;
+}
+
+export interface ToolResult {
+  success: boolean;
+  data: any;
+  summary: string;
+}
+
+@Injectable()
+export class AdminAiAssistantService {
+  constructor(
+    private prisma: PrismaService,
+  ) {}
+
+  getAvailableTools(): ToolDefinition[] {
+    return [
+      {
+        name: 'navigate',
+        description: '跳转到管理后台的某个页面',
+        parameters: {
+          path: { type: 'string', description: '页面路径，如 /admin/users、/admin/orders、/admin/analytics、/admin/enterprise、/admin/operations/banners、/admin/operations/notifications、/admin/settings/roles、/admin/settings/config、/admin/comments、/admin/courses、/admin/prompts、/admin/contents、/admin/tools' },
+        },
+      },
+      {
+        name: 'get-dashboard',
+        description: '获取仪表盘概览数据（用户数、课程数、内容数、提示词数、订单数）',
+        parameters: {},
+      },
+      {
+        name: 'list-users',
+        description: '列出用户，可按关键词搜索',
+        parameters: {
+          search: { type: 'string', description: '搜索关键词（可选）' },
+          page: { type: 'number', description: '页码（可选，默认1）' },
+          pageSize: { type: 'number', description: '每页数量（可选，默认20）' },
+        },
+      },
+      {
+        name: 'get-user',
+        description: '查看某个用户的详细信息',
+        parameters: {
+          id: { type: 'number', description: '用户ID' },
+        },
+      },
+      {
+        name: 'update-user-status',
+        description: '修改用户状态（启用/禁用/封禁）',
+        parameters: {
+          id: { type: 'number', description: '用户ID' },
+          status: { type: 'string', enum: ['ACTIVE', 'INACTIVE', 'BANNED'], description: '新状态' },
+        },
+      },
+      {
+        name: 'list-orders',
+        description: '查看最近订单列表',
+        parameters: {},
+      },
+      {
+        name: 'get-analytics-overview',
+        description: '获取数据分析概览（用户增长、收入、趋势）',
+        parameters: {},
+      },
+      {
+        name: 'list-comments',
+        description: '查看评论列表，可按状态筛选',
+        parameters: {
+          status: { type: 'string', enum: ['PENDING_REVIEW', 'PUBLISHED', 'REJECTED'], description: '评论状态（可选）' },
+        },
+      },
+      {
+        name: 'approve-comment',
+        description: '通过一条待审核评论',
+        parameters: {
+          id: { type: 'number', description: '评论ID' },
+        },
+      },
+      {
+        name: 'reject-comment',
+        description: '拒绝一条评论并给出原因',
+        parameters: {
+          id: { type: 'number', description: '评论ID' },
+          reason: { type: 'string', description: '拒绝原因（可选）' },
+        },
+      },
+      {
+        name: 'list-banners',
+        description: '查看所有Banner列表',
+        parameters: {},
+      },
+      {
+        name: 'list-notifications',
+        description: '查看所有系统通知',
+        parameters: {},
+      },
+      {
+        name: 'list-config',
+        description: '查看系统配置项',
+        parameters: {},
+      },
+      {
+        name: 'list-roles',
+        description: '查看所有管理角色',
+        parameters: {},
+      },
+      {
+        name: 'list-admins',
+        description: '查看所有管理员账号',
+        parameters: {},
+      },
+      {
+        name: 'toggle-course-status',
+        description: '上架或下架一个课程',
+        parameters: {
+          id: { type: 'number', description: '课程ID' },
+        },
+      },
+      {
+        name: 'toggle-content-status',
+        description: '上架或下架一个内容',
+        parameters: {
+          id: { type: 'number', description: '内容ID' },
+        },
+      },
+      {
+        name: 'toggle-prompt-status',
+        description: '上架或下架一个提示词',
+        parameters: {
+          id: { type: 'number', description: '提示词ID' },
+        },
+      },
+      {
+        name: 'get-enterprise-orgs',
+        description: '查看所有企业版组织',
+        parameters: {},
+      },
+    ];
+  }
+
+  getToolsDescription(): string {
+    return this.getAvailableTools().map(t => {
+      const params = Object.entries(t.parameters)
+        .map(([k, v]: any) => `  - ${k}: ${v.type}${v.description ? ' (' + v.description + ')' : ''}${v.enum ? ' [' + v.enum.join('|') + ']' : ''}`)
+        .join('\n');
+      return `- **${t.name}**: ${t.description}\n${params}`;
+    }).join('\n\n');
+  }
+
+  async execute(call: ToolCall): Promise<ToolResult> {
+    try {
+      switch (call.tool) {
+        case 'navigate':
+          return { success: true, data: { path: call.params.path }, summary: `跳转到 ${call.params.path}` };
+
+        case 'get-dashboard': {
+          const data = await this.prisma.user.count({ where: { deletedAt: null } });
+          const courses = await this.prisma.course.count({ where: { deletedAt: null } });
+          const contents = await this.prisma.content.count({ where: { deletedAt: null, status: 'PUBLISHED' } });
+          const prompts = await this.prisma.prompt.count({ where: { deletedAt: null, status: 'PUBLISHED' } });
+          const orders = await this.prisma.order.count();
+          return { success: true, data: { userCount: data, courseCount: courses, contentCount: contents, promptCount: prompts, orderCount: orders }, summary: `总用户${data}，课程${courses}，内容${contents}，提示词${prompts}，订单${orders}` };
+        }
+
+        case 'list-users': {
+          const { search, page = 1, pageSize = 20 } = call.params;
+          const where: any = { deletedAt: null };
+          if (search) where.OR = [
+            { nickname: { contains: search } },
+            { phone: { contains: search } },
+            { email: { contains: search } },
+          ];
+          const [items, total] = await Promise.all([
+            this.prisma.user.findMany({ where, skip: (page - 1) * pageSize, take: pageSize, orderBy: { createdAt: 'desc' }, select: { id: true, nickname: true, phone: true, email: true, status: true, memberPlan: true, createdAt: true } }),
+            this.prisma.user.count({ where }),
+          ]);
+          return { success: true, data: { items, total, page, pageSize }, summary: `找到 ${total} 个用户` };
+        }
+
+        case 'get-user': {
+          const user = await this.prisma.user.findUnique({ where: { id: call.params.id }, include: { orders: { take: 5, orderBy: { createdAt: 'desc' } } } });
+          if (!user) throw new Error('用户不存在');
+          return { success: true, data: user, summary: `用户 ${user.nickname || user.phone || '未知'} (ID:${user.id})` };
+        }
+
+        case 'update-user-status': {
+          const { id, status } = call.params;
+          await this.prisma.user.update({ where: { id }, data: { status } });
+          return { success: true, data: { id, status }, summary: `用户 ${id} 状态已改为 ${status}` };
+        }
+
+        case 'list-orders': {
+          const items = await this.prisma.order.findMany({
+            take: 50, orderBy: { createdAt: 'desc' },
+            include: { user: { select: { id: true, nickname: true } } },
+          });
+          const total = items.length;
+          const revenue = items.filter(o => o.status === 'PAID').reduce((s, o) => s + o.amount, 0);
+          return { success: true, data: { items, total, revenue }, summary: `最近 ${total} 笔订单，已收金额 ¥${revenue}` };
+        }
+
+        case 'get-analytics-overview': {
+          const now = new Date();
+          const today = new Date(now.getFullYear(), now.getMonth(), now.getDate());
+          const [userTotal, ordersTotal, todayOrders, todayUsers, revenue] = await Promise.all([
+            this.prisma.user.count({ where: { deletedAt: null } }),
+            this.prisma.order.count(),
+            this.prisma.order.count({ where: { createdAt: { gte: today } } }),
+            this.prisma.user.count({ where: { deletedAt: null, createdAt: { gte: today } } }),
+            this.prisma.order.aggregate({ _sum: { amount: true }, where: { status: 'PAID' } }),
+          ]);
+          return {
+            success: true,
+            data: { users: userTotal, orders: ordersTotal, todayOrders, todayUsers, revenue: revenue._sum.amount || 0 },
+            summary: `总用户 ${userTotal}，今日新增 ${todayUsers}；总订单 ${ordersTotal}，今日 ${todayOrders}；总收入 ¥${revenue._sum.amount || 0}`,
+          };
+        }
+
+        case 'list-comments': {
+          const where: any = {};
+          if (call.params.status) where.status = call.params.status;
+          const items = await this.prisma.comment.findMany({
+            where, take: 50, orderBy: { createdAt: 'desc' },
+            include: { user: { select: { id: true, nickname: true } } },
+          });
+          return { success: true, data: { items, total: items.length }, summary: `共 ${items.length} 条评论` };
+        }
+
+        case 'approve-comment': {
+          await this.prisma.comment.update({ where: { id: call.params.id }, data: { status: 'PUBLISHED', reviewedAt: new Date() } });
+          return { success: true, data: { id: call.params.id }, summary: `评论 ${call.params.id} 已通过` };
+        }
+
+        case 'reject-comment': {
+          await this.prisma.comment.update({ where: { id: call.params.id }, data: { status: 'REJECTED', reviewNote: call.params.reason || '违规内容', reviewedAt: new Date() } });
+          return { success: true, data: { id: call.params.id }, summary: `评论 ${call.params.id} 已拒绝` };
+        }
+
+        case 'list-banners': {
+          const items = await this.prisma.banner.findMany({ orderBy: { createdAt: 'desc' }, take: 50 });
+          return { success: true, data: { items }, summary: `共 ${items.length} 个Banner` };
+        }
+
+        case 'list-notifications': {
+          const items = await this.prisma.notification.findMany({ orderBy: { createdAt: 'desc' }, take: 50 });
+          return { success: true, data: { items, total: items.length }, summary: `共 ${items.length} 条通知` };
+        }
+
+        case 'list-config': {
+          const items = await this.prisma.systemConfig.findMany();
+          return { success: true, data: { items }, summary: `共 ${items.length} 个配置项` };
+        }
+
+        case 'list-roles': {
+          const items = await this.prisma.adminRole.findMany();
+          return { success: true, data: { items }, summary: `共 ${items.length} 个角色` };
+        }
+
+        case 'list-admins': {
+          const items = await this.prisma.adminUser.findMany({ include: { role: { select: { name: true } } } });
+          return { success: true, data: { items }, summary: `共 ${items.length} 个管理员` };
+        }
+
+        case 'toggle-course-status': {
+          const course = await this.prisma.course.findUnique({ where: { id: call.params.id } });
+          if (!course) throw new Error('课程不存在');
+          const newStatus = course.status === 'PUBLISHED' ? 'INACTIVE' : 'PUBLISHED';
+          await this.prisma.course.update({ where: { id: call.params.id }, data: { status: newStatus as any } });
+          return { success: true, data: { id: call.params.id, status: newStatus }, summary: `课程 ${call.params.id} 状态已切换为 ${newStatus}` };
+        }
+        case 'toggle-content-status': {
+          const content = await this.prisma.content.findUnique({ where: { id: call.params.id } });
+          if (!content) throw new Error('内容不存在');
+          const newContentStatus = content.status === 'PUBLISHED' ? 'INACTIVE' : 'PUBLISHED';
+          await this.prisma.content.update({ where: { id: call.params.id }, data: { status: newContentStatus as any } });
+          return { success: true, data: { id: call.params.id, status: newContentStatus }, summary: `内容 ${call.params.id} 状态已切换为 ${newContentStatus}` };
+        }
+        case 'toggle-prompt-status': {
+          const prompt = await this.prisma.prompt.findUnique({ where: { id: call.params.id } });
+          if (!prompt) throw new Error('提示词不存在');
+          const newPromptStatus = prompt.status === 'PUBLISHED' ? 'INACTIVE' : 'PUBLISHED';
+          await this.prisma.prompt.update({ where: { id: call.params.id }, data: { status: newPromptStatus as any } });
+          return { success: true, data: { id: call.params.id, status: newPromptStatus }, summary: `提示词 ${call.params.id} 状态已切换为 ${newPromptStatus}` };
+        }
+
+        case 'get-enterprise-orgs': {
+          const items = await this.prisma.organization.findMany({ take: 50, orderBy: { createdAt: 'desc' } });
+          return { success: true, data: { items, total: items.length }, summary: `共 ${items.length} 个企业组织` };
+        }
+
+        default:
+          throw new Error(`未知工具: ${call.tool}`);
+      }
+    } catch (err: any) {
+      return { success: false, data: null, summary: `执行失败: ${err.message}` };
+    }
+  }
+}