多平台工作流变现PRD
多平台工作流变现系统是基于BuildingAI平台扩展的开发者变现解决方案，支持Coze、n8n等主流工作流平台的源码交易。系统包含工作流商城、开发者中心和管理后台三大模块，实现工作流展示、交易、审核等全流程管理。采用Nuxt3+NestJS技术架构，与现有系统无缝集成，提供完整的开发者变现通道。核心功能包括：工作流分类展示、智能搜索、在线预览、支付下载、开发者收益统计等，形成从创作到变现的完整生
·
1. 产品概述
多平台工作流变现系统是基于现有BuildingAI平台的扩展功能，旨在为开发者提供工作流源码销售和变现的综合平台。系统支持Coze、n8n、Zapier、Dify等主流工作流平台的源码交易，通过工作流商城模式实现开发者与用户的双赢。
- 解决问题：工作流开发者缺乏变现渠道，用户难以找到高质量的工作流模板
- 目标用户：工作流开发者、企业用户、个人开发者、自动化需求方
- 市场价值：打造工作流生态闭环，预计年交易额突破1000万元
2. 核心功能
2.1 用户角色
| 角色 | 注册方式 | 核心权限 |
|---|---|---|
| 普通用户 | 邮箱注册/第三方登录 | 浏览、购买、下载工作流，评价反馈 |
| 开发者 | 实名认证升级 | 上传工作流、管理商品、查看收益、提现 |
| 平台管理员 | 内部分配 | 审核工作流、管理用户、财务管理、数据分析 |
2.2 功能模块
我们的多平台工作流变现系统包含以下主要页面：
- 工作流商城：工作流展示、分类筛选、搜索推荐、热门排行
- 工作流详情页：详细介绍、预览演示、用户评价、购买下载
- 开发者中心：工作流上传、商品管理、收益统计、提现申请
- 用户中心：购买记录、下载管理、收藏夹、个人设置
- 平台管理后台：审核管理、用户管理、财务管理、数据统计
- 工作流类型管理：业务分类管理、类型配置、图标设置、排序管理
- 工作流平台类型管理：平台配置、Logo管理、格式支持、API配置
2.3 页面详情
| 页面名称 | 模块名称 | 功能描述 |
|---|---|---|
| 工作流商城 | 商品展示区 | 展示工作流卡片，包含标题、价格、评分、下载量、平台标识 |
| 工作流商城 | 分类筛选器 | 按平台类型（Coze/n8n/Zapier等）、工作流类型、应用场景、价格区间筛选 |
| 工作流商城 | 搜索推荐 | 智能搜索、热门推荐、个性化推荐算法 |
| 工作流详情页 | 详情展示 | 工作流介绍、功能说明、使用教程、技术要求 |
| 工作流详情页 | 预览演示 | 工作流截图、视频演示、在线预览（部分支持） |
| 工作流详情页 | 评价系统 | 用户评分、评论展示、问答互动 |
| 工作流详情页 | 购买下载 | 价格展示、立即购买、下载链接、使用授权 |
| 开发者中心 | 工作流上传 | 文件上传、信息填写、分类标签、价格设定 |
| 开发者中心 | 商品管理 | 已上传工作流管理、编辑更新、销售数据、用户反馈 |
| 开发者中心 | 收益统计 | 销售报表、收入明细、提现记录、税务信息 |
| 用户中心 | 购买记录 | 历史订单、支付状态、下载权限、售后服务 |
| 用户中心 | 下载管理 | 已购工作流、重新下载、版本更新、使用指南 |
| 平台管理后台 | 审核管理 | 工作流审核、质量检查、违规处理、审核流程 |
| 平台管理后台 | 财务管理 | 交易统计、分成结算、提现审批、财务报表 |
| 工作流类型管理 | 类型列表 | 显示所有工作流业务类型，支持搜索、筛选、排序 |
| 工作流类型管理 | 类型编辑 | 新增、编辑、删除工作流类型，设置名称、描述、图标、排序 |
| 工作流类型管理 | 状态管理 | 启用/禁用类型、批量操作、状态统计 |
| 工作流平台类型管理 | 平台列表 | 显示所有支持的工作流平台，包含Logo、状态、配置信息 |
| 工作流平台类型管理 | 平台配置 | 新增、编辑平台信息，设置Logo、API配置、支持格式 |
| 工作流平台类型管理 | 格式管理 | 管理平台支持的文件格式、导入导出规则、兼容性设置 |
3. 核心流程
开发者流程
开发者注册认证 → 上传工作流源码 → 填写商品信息 → 平台审核 → 商城上架 → 用户购买 → 获得收益 → 申请提现
用户流程
用户浏览商城 → 筛选搜索工作流 → 查看详情和评价 → 购买支付 → 下载使用 → 评价反馈
平台管理流程
工作流提交 → 质量审核 → 合规检查 → 上架发布 → 交易监控 → 收益分成 → 数据分析
4. 用户界面设计
4.1 设计风格
- 主色调：#3B82F6（科技蓝）、#10B981（成功绿）
- 辅助色：#6B7280（中性灰）、#F59E0B（警告橙）
- 按钮风格：圆角矩形，渐变背景，悬停动效
- 字体：Inter（英文）、思源黑体（中文），主要字号14px-16px
- 布局风格：卡片式设计，左侧导航，响应式网格布局
- 图标风格：线性图标，统一使用Lucide图标库，支持平台特色图标
4.2 页面设计概览
| 页面名称 | 模块名称 | UI元素 |
|---|---|---|
| 工作流商城 | 商品卡片 | 卡片阴影效果，悬停放大，价格标签醒目，平台Logo标识，评分星级显示 |
| 工作流商城 | 筛选侧栏 | 折叠式分类树，多选标签，价格滑块，清除筛选按钮 |
| 工作流详情页 | 主要信息区 | 大图轮播，标题突出，价格醒目，购买按钮CTA设计 |
| 工作流详情页 | 评价区域 | 星级评分，评论卡片，分页加载，点赞互动 |
| 开发者中心 | 上传界面 | 拖拽上传区域，进度条显示，表单验证提示，预览功能 |
| 开发者中心 | 数据面板 | 图表可视化，关键指标卡片，趋势分析，导出功能 |
4.3 响应式设计
- 桌面优先：主要面向PC端开发者和企业用户
- 移动适配：支持平板和手机浏览，触摸优化
- 断点设置：1200px（大屏）、768px（平板）、480px（手机）
5. 技术架构
5.1 整体架构设计
基于现有BuildingAI平台的Monorepo架构，工作流变现功能将作为新的业务模块无缝集成到现有系统中。
5.2 技术栈选择
完全复用现有BuildingAI项目的技术栈，确保架构一致性和开发效率：
- 前端框架：Nuxt.js 3.x + Vue.js 3.x + TypeScript
- UI框架：Tailwind CSS 3.x + Headless UI
- 状态管理：Pinia + VueUse
- 后端框架：NestJS 10.x + Node.js 18+
- 数据库：PostgreSQL 17.x + TypeORM 0.3.x
- 文件存储：本地存储 + 云存储（阿里云OSS）
- 支付系统：复用现有微信支付 + 支付宝支付
- 缓存系统：Redis 7.x
- 容器化：Docker + Docker Compose
- 开发工具：pnpm + Turborepo + ESLint + Prettier
5.3 前端架构集成
工作流变现功能将集成到现有的控制台系统中，复用现有的布局、组件和路由结构：
| 路由路径 | 页面功能 | 集成位置 |
|---|---|---|
| /console/workflow-market | 工作流商城管理 | 控制台主菜单 |
| /console/workflow-audit | 工作流审核管理 | 控制台 - 内容管理 |
| /console/workflow-orders | 工作流订单管理 | 控制台 - 订单管理 |
| /console/workflow-finance | 工作流财务管理 | 控制台 - 财务中心 |
| /console/workflow-types | 工作流类型管理 | 控制台 - 内容管理 |
| /console/workflow-platforms | 工作流平台类型管理 | 控制台 - 系统管理 |
| /web/workflow-market | 用户工作流商城 | 前台用户中心 |
| /web/developer-center | 开发者中心 | 前台用户中心 |
| /web/workflow-orders | 用户订单记录 | 前台用户中心 |
5.4 后端服务架构
基于现有的NestJS模块化架构，新增工作流相关服务模块：
apps/server/src/modules/
├── console/ # 控制台模块
│ ├── workflow-market/ # 工作流商城管理
│ │ ├── controllers/
│ │ ├── services/
│ │ ├── entities/
│ │ └── dto/
│ ├── workflow-audit/ # 工作流审核管理
│ └── workflow-finance/ # 工作流财务管理
├── web/ # 前台模块
│ ├── workflow-market/ # 用户工作流商城
│ ├── developer-center/ # 开发者中心
│ └── workflow-orders/ # 用户订单管理
└── common/ # 共享模块
├── workflow/ # 工作流核心服务
└── file-storage/ # 文件存储服务
5.5 数据库架构设计
基于现有的PostgreSQL + TypeORM架构，新增工作流相关数据表：
5.6 API接口设计
遵循现有项目的RESTful API设计规范和响应格式：
5.6.1 控制台API（管理端）
工作流商品管理
// 获取工作流列表
GET /api/console/workflow-products
Query: PaginationDto & {
platform?: string;
status?: string;
keyword?: string;
}
Response: PaginationResult<WorkflowProduct>
// 审核工作流
POST /api/console/workflow-products/:id/audit
Body: {
status: 'approved' | 'rejected';
reason?: string;
}
Response: ApiResponse<WorkflowProduct>
订单管理
// 获取工作流订单列表
GET /api/console/workflow-orders
Query: PaginationDto & {
status?: string;
paymentStatus?: string;
startDate?: string;
endDate?: string;
}
Response: PaginationResult<WorkflowOrder>
工作流类型管理
// 获取工作流类型列表
GET /api/console/workflow-types
Query: PaginationDto & {
keyword?: string;
is_active?: boolean;
}
Response: PaginationResult<WorkflowType>
// 创建工作流类型
POST /api/console/workflow-types
Body: {
name: string;
description?: string;
icon_url?: string;
color?: string;
sort_order?: number;
is_active?: boolean;
}
Response: ApiResponse<WorkflowType>
// 更新工作流类型
PUT /api/console/workflow-types/:id
Body: Partial<CreateWorkflowTypeDto>
Response: ApiResponse<WorkflowType>
// 删除工作流类型
DELETE /api/console/workflow-types/:id
Response: ApiResponse<void>
// 批量更新排序
PUT /api/console/workflow-types/sort
Body: {
items: Array<{id: string; sort_order: number}>;
}
Response: ApiResponse<void>
工作流平台类型管理
// 获取工作流平台列表
GET /api/console/workflow-platforms
Query: PaginationDto & {
keyword?: string;
is_active?: boolean;
}
Response: PaginationResult<WorkflowPlatform>
// 创建工作流平台
POST /api/console/workflow-platforms
Body: {
name: string;
description?: string;
logo_url?: string;
supported_formats?: string[];
api_config?: object;
official_website?: string;
is_active?: boolean;
sort_order?: number;
}
Response: ApiResponse<WorkflowPlatform>
// 更新工作流平台
PUT /api/console/workflow-platforms/:id
Body: Partial<CreateWorkflowPlatformDto>
Response: ApiResponse<WorkflowPlatform>
// 删除工作流平台
DELETE /api/console/workflow-platforms/:id
Response: ApiResponse<void>
// 批量更新排序
PUT /api/console/workflow-platforms/sort
Body: {
items: Array<{id: string; sort_order: number}>;
}
Response: ApiResponse<void>
5.6.2 前台API（用户端）
工作流商城
// 获取工作流商城列表（更新支持类型和平台筛选）
GET /api/web/workflow-market
Query: {
platform?: string;
platform_id?: string; // 新增：按平台ID筛选
type_id?: string; // 新增：按类型ID筛选
category?: string;
keyword?: string;
priceRange?: string;
sortBy?: 'latest' | 'popular' | 'rating' | 'price';
page?: number;
limit?: number;
}
Response: PaginationResult<WorkflowProduct>
// 获取工作流详情
GET /api/web/workflow-market/:id
Response: ApiResponse<WorkflowProduct & {
creator: User;
reviews: WorkflowReview[];
relatedProducts: WorkflowProduct[];
platform: WorkflowPlatform; // 新增：平台信息
type: WorkflowType; // 新增：类型信息
}>
// 获取工作流类型列表（前台）
GET /api/web/workflow-types
Response: ApiResponse<WorkflowType[]>
// 获取工作流平台列表（前台）
GET /api/web/workflow-platforms
Response: ApiResponse<WorkflowPlatform[]>
开发者中心
// 上传工作流
POST /api/web/developer/workflows
Body: {
title: string;
description: string;
platform: string;
categoryId: string;
price: number;
files: File[];
screenshots?: File[];
demoVideo?: File;
}
Response: ApiResponse<WorkflowProduct>
// 获取开发者收益统计
GET /api/web/developer/earnings
Query: {
startDate?: string;
endDate?: string;
}
Response: ApiResponse<{
totalEarnings: number;
monthlyEarnings: number;
orderCount: number;
productCount: number;
chartData: any[];
}>
5.7 文件存储架构
复用现有的文件存储服务，支持本地存储和云存储：
// 文件存储服务接口
interface FileStorageService {
// 上传工作流文件
uploadWorkflowFiles(files: File[], workflowId: string): Promise<string[]>;
// 上传截图
uploadScreenshots(files: File[], workflowId: string): Promise<string[]>;
// 上传演示视频
uploadDemoVideo(file: File, workflowId: string): Promise<string>;
// 生成下载链接（带权限验证）
generateDownloadUrl(fileId: string, userId: string): Promise<string>;
}
5.8 支付系统集成
完全复用现有的支付系统架构，扩展支持工作流订单：
// 扩展现有的订单类型
enum OrderType {
COZE_PACKAGE = 'coze-package',
RECHARGE = 'recharge',
WORKFLOW = 'workflow' // 新增工作流订单类型
}
// 工作流订单服务
@Injectable()
export class WorkflowOrderService extends BaseService<WorkflowOrder> {
constructor(
@InjectRepository(WorkflowOrder)
private readonly workflowOrderRepository: Repository<WorkflowOrder>,
private readonly payFactoryService: PayFactoryService,
private readonly accountLogService: AccountLogService
) {
super(workflowOrderRepository);
}
// 创建工作流订单
async createOrder(dto: CreateWorkflowOrderDto): Promise<WorkflowOrder> {
// 复用现有订单创建逻辑
}
// 处理支付回调
async handlePaymentCallback(orderNo: string): Promise<void> {
// 复用现有支付回调处理逻辑
}
}
5.9 权限控制系统
基于现有的RBAC权限系统，新增工作流相关权限：
// 工作流权限定义
const WORKFLOW_PERMISSIONS = {
// 控制台权限
CONSOLE_WORKFLOW_VIEW: 'console:workflow:view',
CONSOLE_WORKFLOW_AUDIT: 'console:workflow:audit',
CONSOLE_WORKFLOW_MANAGE: 'console:workflow:manage',
CONSOLE_WORKFLOW_FINANCE: 'console:workflow:finance',
// 开发者权限
DEVELOPER_WORKFLOW_CREATE: 'developer:workflow:create',
DEVELOPER_WORKFLOW_MANAGE: 'developer:workflow:manage',
DEVELOPER_EARNINGS_VIEW: 'developer:earnings:view',
// 用户权限
USER_WORKFLOW_PURCHASE: 'user:workflow:purchase',
USER_WORKFLOW_DOWNLOAD: 'user:workflow:download',
USER_WORKFLOW_REVIEW: 'user:workflow:review'
};
5.10 部署架构
完全复用现有的Docker容器化部署架构：
# docker-compose.yml 扩展
services:
# 复用现有服务
web:
# 现有前端服务配置
server:
# 现有后端服务配置
environment:
# 新增工作流相关环境变量
- WORKFLOW_FILE_STORAGE_PATH=/app/uploads/workflows
- WORKFLOW_MAX_FILE_SIZE=100MB
postgres:
# 现有数据库服务配置
redis:
# 现有缓存服务配置
# 新增文件存储服务（如需要）
minio:
image: minio/minio:latest
ports:
- "9000:9000"
- "9001:9001"
environment:
- MINIO_ROOT_USER=minioadmin
- MINIO_ROOT_PASSWORD=minioadmin
volumes:
- minio_data:/data
command: server /data --console-address ":9001"
volumes:
minio_data:
5.11 开发规范
严格遵循现有项目的开发规范：
- 代码规范：使用现有的ESLint + Prettier配置
- Git规范：遵循现有的Git Flow和提交信息规范
- API规范：遵循现有的RESTful API设计规范
- 数据库规范：遵循现有的实体设计和命名规范
- 测试规范：使用现有的Jest测试框架和覆盖率要求
5.12 性能优化
基于现有项目的性能优化策略：
- 前端优化：复用现有的代码分割、懒加载、CDN配置
- 后端优化：复用现有的数据库连接池、查询优化、缓存策略
- 文件优化：实现文件压缩、CDN分发、断点续传
- 数据库优化：基于现有索引策略，新增工作流相关索引
6. 数据模型
6.1 数据模型定义
基于现有BuildingAI项目的数据库设计模式，工作流变现功能的数据模型将复用现有的用户系统、订单系统和权限系统：
6.2 数据定义语言
基于现有项目的实体设计模式，使用TypeORM装饰器和BuildingAI的标准字段：
工作流商品表 (workflow_products)
// 创建工作流类型表
CREATE TABLE workflow_types (
id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
name VARCHAR(100) NOT NULL COMMENT '类型名称',
description TEXT COMMENT '类型描述',
icon_url VARCHAR(500) COMMENT '图标URL',
color VARCHAR(20) DEFAULT '#3B82F6' COMMENT '主题色',
sort_order INTEGER DEFAULT 0 COMMENT '排序',
is_active BOOLEAN DEFAULT true COMMENT '是否启用',
created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() COMMENT '创建时间',
updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() COMMENT '更新时间'
);
// 创建工作流平台表
CREATE TABLE workflow_platforms (
id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
name VARCHAR(100) NOT NULL COMMENT '平台名称',
description TEXT COMMENT '平台描述',
logo_url VARCHAR(500) COMMENT '平台Logo URL',
supported_formats JSONB DEFAULT '[]' COMMENT '支持的文件格式',
api_config JSONB COMMENT 'API配置信息',
official_website VARCHAR(500) COMMENT '官方网站',
is_active BOOLEAN DEFAULT true COMMENT '是否启用',
sort_order INTEGER DEFAULT 0 COMMENT '排序',
created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() COMMENT '创建时间',
updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() COMMENT '更新时间'
);
// 创建工作流商品表
CREATE TABLE workflow_products (
id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
title VARCHAR(255) NOT NULL COMMENT '工作流标题',
description TEXT COMMENT '详细描述',
platform_id UUID NOT NULL COMMENT '平台ID',
type_id UUID COMMENT '工作流类型ID',
category_id UUID COMMENT '分类ID',
original_price DECIMAL(10,2) NOT NULL DEFAULT 0 COMMENT '原价',
current_price DECIMAL(10,2) NOT NULL DEFAULT 0 COMMENT '现价',
creator_id UUID NOT NULL COMMENT '创建者ID',
files JSONB NOT NULL COMMENT '工作流文件信息',
screenshots JSONB DEFAULT '[]' COMMENT '截图文件',
demo_video_url VARCHAR(500) COMMENT '演示视频URL',
download_count INTEGER DEFAULT 0 COMMENT '下载次数',
average_rating DECIMAL(3,2) DEFAULT 0 COMMENT '平均评分',
review_count INTEGER DEFAULT 0 COMMENT '评价数量',
status VARCHAR(20) DEFAULT 'pending' COMMENT '状态' CHECK (status IN ('pending', 'approved', 'rejected', 'offline')),
metadata JSONB COMMENT '扩展数据',
created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() COMMENT '创建时间',
updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() COMMENT '更新时间',
deleted_at TIMESTAMP WITH TIME ZONE COMMENT '删除时间',
CONSTRAINT fk_workflow_products_creator FOREIGN KEY (creator_id) REFERENCES users(id),
CONSTRAINT fk_workflow_products_platform FOREIGN KEY (platform_id) REFERENCES workflow_platforms(id),
CONSTRAINT fk_workflow_products_type FOREIGN KEY (type_id) REFERENCES workflow_types(id),
CONSTRAINT fk_workflow_products_category FOREIGN KEY (category_id) REFERENCES workflow_categories(id)
);
-- 创建工作流订单表（基于现有订单表结构）
CREATE TABLE workflow_orders (
id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
order_no VARCHAR(64) UNIQUE NOT NULL COMMENT '订单号',
workflow_id UUID NOT NULL COMMENT '工作流ID',
user_id UUID NOT NULL COMMENT '用户ID',
workflow_title VARCHAR(255) NOT NULL COMMENT '工作流标题（冗余字段）',
platform VARCHAR(50) NOT NULL COMMENT '平台类型',
total_amount DECIMAL(10,2) NOT NULL COMMENT '订单总金额',
discount_amount DECIMAL(10,2) DEFAULT 0 COMMENT '优惠金额',
paid_amount DECIMAL(10,2) NOT NULL COMMENT '实付金额',
platform_fee DECIMAL(10,2) NOT NULL COMMENT '平台手续费',
creator_amount DECIMAL(10,2) NOT NULL COMMENT '创作者收益',
payment_method VARCHER(20) COMMENT '支付方式' CHECK (payment_method IN ('wechat', 'alipay', 'bank', 'balance', 'other')),
order_status VARCHER(20) DEFAULT 'pending' COMMENT '订单状态' CHECK (order_status IN ('pending', 'paid', 'cancelled', 'expired', 'completed')),
payment_status VARCHER(20) DEFAULT 'unpaid' COMMENT '支付状态' CHECK (payment_status IN ('unpaid', 'paid', 'refunded', 'partialRefund')),
refund_status VARCHER(20) DEFAULT 'none' COMMENT '退款状态' CHECK (refund_status IN ('none', 'pending', 'approved', 'rejected', 'processing')),
transaction_id VARCHER(128) COMMENT '交易流水号',
paid_at TIMESTAMP WITH TIME ZONE COMMENT '支付时间',
expired_at TIMESTAMP WITH TIME ZONE COMMENT '过期时间',
refund_amount DECIMAL(10,2) DEFAULT 0 COMMENT '退款金额',
refund_reason VARCHER(255) COMMENT '退款原因',
refund_at TIMESTAMP WITH TIME ZONE COMMENT '退款时间',
remark TEXT COMMENT '备注信息',
metadata JSONB COMMENT '扩展数据',
created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() COMMENT '创建时间',
updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() COMMENT '更新时间',
CONSTRAINT fk_workflow_orders_workflow FOREIGN KEY (workflow_id) REFERENCES workflow_products(id),
CONSTRAINT fk_workflow_orders_user FOREIGN KEY (user_id) REFERENCES users(id)
);
-- 创建工作流评价表
CREATE TABLE workflow_reviews (
id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
workflow_id UUID NOT NULL COMMENT '工作流ID',
user_id UUID NOT NULL COMMENT '用户ID',
rating INTEGER NOT NULL COMMENT '评分' CHECK (rating >= 1 AND rating <= 5),
comment TEXT COMMENT '评价内容',
metadata JSONB COMMENT '扩展数据',
created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() COMMENT '创建时间',
updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() COMMENT '更新时间',
CONSTRAINT fk_workflow_reviews_workflow FOREIGN KEY (workflow_id) REFERENCES workflow_products(id),
CONSTRAINT fk_workflow_reviews_user FOREIGN KEY (user_id) REFERENCES users(id),
CONSTRAINT uk_workflow_reviews_user_workflow UNIQUE (workflow_id, user_id)
);
-- 创建工作流分类表
CREATE TABLE workflow_categories (
id UUID PRIMARY KEY DEFAULT gen_random_uuid(),
name VARCHAR(100) NOT NULL COMMENT '分类名称',
platform VARCHAR(50) NOT NULL COMMENT '平台类型',
description TEXT COMMENT '分类描述',
sort_order INTEGER DEFAULT 0 COMMENT '排序',
is_active BOOLEAN DEFAULT true COMMENT '是否启用',
created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() COMMENT '创建时间',
updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW() COMMENT '更新时间'
);
-- 创建索引（遵循现有项目的索引命名规范）
CREATE INDEX idx_workflow_types_sort_order ON workflow_types(sort_order);
CREATE INDEX idx_workflow_types_is_active ON workflow_types(is_active);
CREATE INDEX idx_workflow_platforms_sort_order ON workflow_platforms(sort_order);
CREATE INDEX idx_workflow_platforms_is_active ON workflow_platforms(is_active);
CREATE INDEX idx_workflow_products_platform ON workflow_products(platform_id);
CREATE INDEX idx_workflow_products_type ON workflow_products(type_id);
CREATE INDEX idx_workflow_products_category ON workflow_products(category_id);
CREATE INDEX idx_workflow_products_creator ON workflow_products(creator_id);
CREATE INDEX idx_workflow_products_status ON workflow_products(status);
CREATE INDEX idx_workflow_products_created_at ON workflow_products(created_at);
CREATE INDEX idx_workflow_products_rating ON workflow_products(average_rating DESC);
CREATE INDEX idx_workflow_orders_order_no ON workflow_orders(order_no);
CREATE INDEX idx_workflow_orders_user ON workflow_orders(user_id);
CREATE INDEX idx_workflow_orders_workflow ON workflow_orders(workflow_id);
CREATE INDEX idx_workflow_orders_status ON workflow_orders(order_status);
CREATE INDEX idx_workflow_orders_payment_status ON workflow_orders(payment_status);
CREATE INDEX idx_workflow_orders_created_at ON workflow_orders(created_at);
CREATE INDEX idx_workflow_reviews_workflow ON workflow_reviews(workflow_id);
CREATE INDEX idx_workflow_reviews_user ON workflow_reviews(user_id);
CREATE INDEX idx_workflow_reviews_rating ON workflow_reviews(rating DESC);
CREATE INDEX idx_workflow_categories_platform ON workflow_categories(platform);
CREATE INDEX idx_workflow_categories_sort_order ON workflow_categories(sort_order);
-- 初始化工作流类型数据
INSERT INTO workflow_types (name, description, icon_url, color, sort_order, is_active) VALUES
('情感分析', '情感识别、情绪分析、心理健康、情感咨询相关工作流', '/icons/emotion.svg', '#FF6B6B', 1, true),
('教育培训', '在线教育、培训管理、学习辅助、知识问答相关工作流', '/icons/education.svg', '#4ECDC4', 2, true),
('视频处理', '视频编辑、转码、剪辑、特效处理相关工作流', '/icons/video.svg', '#45B7D1', 3, true),
('数据分析', '数据收集、清洗、分析、可视化、报表生成相关工作流', '/icons/data.svg', '#96CEB4', 4, true),
('营销自动化', '邮件营销、社交媒体、广告投放、客户管理相关工作流', '/icons/marketing.svg', '#FFEAA7', 5, true),
('客服机器人', '智能客服、问答系统、客户服务自动化相关工作流', '/icons/chatbot.svg', '#DDA0DD', 6, true),
('办公自动化', '文档处理、会议管理、任务分配、流程审批相关工作流', '/icons/office.svg', '#98D8C8', 7, true),
('电商运营', '商品管理、订单处理、库存管理、价格监控相关工作流', '/icons/ecommerce.svg', '#F7DC6F', 8, true),
('财务管理', '发票处理、费用管理、财务报表、支付处理相关工作流', '/icons/finance.svg', '#BB8FCE', 9, true),
('人力资源', '招聘流程、员工管理、考勤统计、薪资处理相关工作流', '/icons/hr.svg', '#85C1E9', 10, true);
-- 初始化工作流平台数据
INSERT INTO workflow_platforms (name, description, logo_url, supported_formats, api_config, official_website, sort_order, is_active) VALUES
('Coze', '字节跳动推出的AI Bot开发平台，支持多模态AI应用开发', '/logos/coze.png', '["json", "yaml"]', '{"api_version": "v1", "auth_type": "token"}', 'https://www.coze.com', 1, true),
('n8n', '开源的工作流自动化工具，支持200+服务集成', '/logos/n8n.png', '["json", "n8n"]', '{"api_version": "v1", "auth_type": "webhook"}', 'https://n8n.io', 2, true),
('Zapier', '知名的自动化平台，连接5000+应用和服务', '/logos/zapier.png', '["zap", "json"]', '{"api_version": "v2", "auth_type": "oauth"}', 'https://zapier.com', 3, true),
('Dify', '开源的LLM应用开发平台，支持RAG和Agent开发', '/logos/dify.png', '["dsl", "yaml", "json"]', '{"api_version": "v1", "auth_type": "api_key"}', 'https://dify.ai', 4, true),
('Make', '原Integromat，可视化自动化平台', '/logos/make.png', '["blueprint", "json"]', '{"api_version": "v2", "auth_type": "oauth"}', 'https://www.make.com', 5, true),
('Microsoft Power Automate', '微软的云端自动化服务', '/logos/power-automate.png', '["zip", "json"]', '{"api_version": "v1", "auth_type": "oauth"}', 'https://powerautomate.microsoft.com', 6, true),
('Automation Anywhere', '企业级RPA平台', '/logos/automation-anywhere.png', '["atmx", "json"]', '{"api_version": "v3", "auth_type": "token"}', 'https://www.automationanywhere.com', 7, true),
('UiPath', '领先的RPA解决方案提供商', '/logos/uipath.png', '["xaml", "json"]', '{"api_version": "v1", "auth_type": "oauth"}', 'https://www.uipath.com', 8, true);
-- 初始化分类数据（更新为基于平台ID的关联）
INSERT INTO workflow_categories (name, platform, description, sort_order, is_active) VALUES
-- Coze 平台分类
('AI客服助手', 'coze', '智能客服、问答机器人、客户服务自动化', 1, true),
('数据处理分析', 'coze', '数据收集、清洗、分析、报表生成', 2, true),
('内容创作工具', 'coze', '文案生成、图片处理、视频制作、创意设计', 3, true),
('营销推广', 'coze', '社交媒体管理、邮件营销、广告投放', 4, true),
('办公自动化', 'coze', '文档处理、会议管理、任务分配', 5, true),
-- n8n 平台分类
('业务流程自动化', 'n8n', '订单处理、库存管理、财务自动化、审批流程', 1, true),
('数据集成同步', 'n8n', 'API集成、数据同步、ETL流程、数据迁移', 2, true),
('通知提醒系统', 'n8n', '邮件通知、短信提醒、消息推送、告警系统', 3, true),
('监控运维', 'n8n', '系统监控、日志分析、性能监控、故障处理', 4, true),
('电商运营', 'n8n', '商品管理、订单同步、库存更新、价格监控', 5, true),
-- Zapier 平台分类
('CRM集成', 'zapier', '客户关系管理、销售流程、客户数据同步', 1, true),
('项目管理', 'zapier', '任务分配、进度跟踪、团队协作、时间管理', 2, true),
('营销自动化', 'zapier', '邮件营销、社交媒体、线索管理、转化跟踪', 3, true),
('财务管理', 'zapier', '发票处理、费用管理、财务报表、支付处理', 4, true),
('人力资源', 'zapier', '招聘流程、员工管理、考勤统计、薪资处理', 5, true),
-- Dify 平台分类
('RAG知识库', 'dify', '知识库问答、文档检索、智能助手、专业咨询', 1, true),
('多模态AI', 'dify', '图文理解、语音处理、视觉分析、多媒体处理', 2, true),
('智能代理', 'dify', '任务执行、决策支持、自动化代理、流程优化', 3, true),
('对话系统', 'dify', '聊天机器人、语音助手、客服系统、交互界面', 4, true),
('内容生成', 'dify', '文本生成、图像创作、代码生成、创意辅助', 5, true),
-- Make 平台分类
('工作流自动化', 'make', '复杂业务流程、多步骤自动化、条件分支', 1, true),
('数据处理', 'make', '数据转换、格式处理、批量操作、数据清洗', 2, true),
('集成连接', 'make', '第三方服务集成、API连接、数据同步', 3, true),
('定时任务', 'make', '计划任务、定期执行、批处理作业', 4, true),
('错误处理', 'make', '异常处理、重试机制、错误恢复、监控告警', 5, true);
-- 创建触发器更新 updated_at 字段
CREATE OR REPLACE FUNCTION update_updated_at_column()
RETURNS TRIGGER AS $$
BEGIN
NEW.updated_at = NOW();
RETURN NEW;
END;
$$ language 'plpgsql';
CREATE TRIGGER update_workflow_types_updated_at BEFORE UPDATE ON workflow_types FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
CREATE TRIGGER update_workflow_platforms_updated_at BEFORE UPDATE ON workflow_platforms FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
CREATE TRIGGER update_workflow_products_updated_at BEFORE UPDATE ON workflow_products FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
CREATE TRIGGER update_workflow_orders_updated_at BEFORE UPDATE ON workflow_orders FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
CREATE TRIGGER update_workflow_reviews_updated_at BEFORE UPDATE ON workflow_reviews FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
CREATE TRIGGER update_workflow_categories_updated_at BEFORE UPDATE ON workflow_categories FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
## 7. 商业模式
### 7.1 收益分成
- **平台分成**：30%（包含支付手续费、服务器成本、运营成本）
- **开发者分成**：70%（激励优质内容创作）
- **推广分成**：额外5%给推荐用户（从平台分成中扣除）
### 7.2 定价策略
- **免费工作流**：支持开源贡献，提升平台活跃度
- **付费工作流**：10-500元区间，根据复杂度和价值定价
- **企业定制**：1000元以上，提供定制开发服务
### 7.3 增值服务
- **开发者认证**：99元/年，获得认证标识和优先推荐
- **技术支持**：付费工作流包含30天技术支持
- **定制开发**：平台撮合开发者与企业用户
## 8. 运营策略
### 8.1 冷启动策略
1. **邀请种子开发者**：邀请知名工作流开发者入驻，提供优质内容
2. **平台补贴**：前期对优质工作流提供流量扶持和收益补贴
3. **社区建设**：建立开发者交流群，定期举办技术分享活动
### 8.2 内容质量保障
1. **审核机制**：专业团队审核工作流质量和安全性
2. **评价体系**：用户评分和评论，建立信誉机制
3. **退款保障**：7天无理由退款，保障用户权益
### 8.3 推广营销
1. **SEO优化**：针对工作流相关关键词进行搜索优化
2. **内容营销**：发布工作流教程、最佳实践案例
3. **合作推广**：与各平台官方、技术社区建立合作关系
## 9. 风险控制
### 9.1 技术风险
- **文件安全**：工作流文件加密存储，防止盗版
- **系统稳定**：负载均衡、数据备份、容灾机制
- **API限制**：防止恶意调用，设置合理的频率限制
### 9.2 法律风险
- **知识产权**：建立版权保护机制，处理侵权投诉
- **合规审查**：确保工作流内容符合法律法规
- **用户协议**：完善的服务条款和隐私政策
### 9.3 商业风险
- **市场竞争**：持续创新，建立技术和生态壁垒
- **用户流失**：提升用户体验，增强用户粘性
- **收益波动**：多元化收入来源，降低单一依赖
## 10. 发展规划
### 10.1 第一阶段（1-3个月）
- 完成核心功能开发（商城、上传、购买）
- 上线Coze平台工作流支持
- 招募50个种子开发者，上架200个工作流
### 10.2 第二阶段（4-6个月）
- 扩展支持n8n、Zapier平台
- 完善评价和推荐系统
- 达到500个开发者，2000个工作流
### 10.3 第三阶段（7-12个月）
- 支持Dify、Make等更多平台
- 推出企业定制服务
- 建立开发者生态，月交易额突破100万
### 10.4 长期规划（1年以上）
- 国际化扩展，支持多语言
- AI辅助工作流生成和优化
- 打造工作流开发者社区和培训体系
有“AI”的1024 = 2048，欢迎大家加入2048 AI社区
更多推荐
8
0- 0
已为社区贡献46条内容
所有评论(0)