架构设计与技术选型

# pnpm-workspace.yaml
packages:
  - 'apps/*'
  - 'packages/*'

// package.json
{
  "scripts": {
    "dev:web": "pnpm --filter @ai-video/web dev",
    "dev:admin": "pnpm --filter @ai-video/admin dev",
    "build:web": "pnpm --filter @ai-video/web build",
    "build:admin": "pnpm --filter @ai-video/admin build",
    "db:migrate": "pnpm --filter @ai-video/database migrate",
    "db:seed": "pnpm --filter @ai-video/database seed"
  }
}

// packages/database/schema/users.ts
import { pgTable, text, timestamp, boolean } from 'drizzle-orm/pg-core'
 
export const users = pgTable('users', {
  id: text('id').primaryKey().$defaultFn(() => createId()),
  email: text('email').notNull().unique(),
  name: text('name').notNull(),
  avatar: text('avatar'),
  role: text('role', { enum: ['user', 'admin', 'moderator'] }).default('user').notNull(),
  banned: boolean('banned').default(false).notNull(),
  createdAt: timestamp('created_at').defaultNow().notNull(),
  updatedAt: timestamp('updated_at').defaultNow().notNull(),
})
 
// packages/database/schema/videos.ts
export const videos = pgTable('videos', {
  id: text('id').primaryKey().$defaultFn(() => createId()),
  title: text('title').notNull(),
  description: text('description'),
  userId: text('user_id').notNull().references(() => users.id),
  status: text('status', {
    enum: ['draft', 'processing', 'ready', 'failed', 'reviewing', 'published', 'rejected'],
  }).default('draft').notNull(),
  sourceType: text('source_type', { enum: ['upload', 'ai_generated'] }).notNull(),
  sourceUrl: text('source_url'),           // 原始文件 URL
  hlsUrl: text('hls_url'),                 // HLS 播放地址
  thumbnailUrl: text('thumbnail_url'),     // 封面图
  duration: integer('duration'),            // 时长（秒）
  width: integer('width'),
  height: integer('height'),
  fileSize: bigint('file_size', { mode: 'number' }),
  viewCount: integer('view_count').default(0).notNull(),
  likeCount: integer('like_count').default(0).notNull(),
  tags: text('tags').array(),
  createdAt: timestamp('created_at').defaultNow().notNull(),
  publishedAt: timestamp('published_at'),
})
 
// packages/database/schema/ai-tasks.ts
export const aiTasks = pgTable('ai_tasks', {
  id: text('id').primaryKey().$defaultFn(() => createId()),
  userId: text('user_id').notNull().references(() => users.id),
  videoId: text('video_id').references(() => videos.id),
  prompt: text('prompt').notNull(),
  model: text('model').notNull(),           // 'kling', 'sora', 'runway'
  style: text('style'),                     // 'realistic', 'anime', 'cinematic'
  status: text('status', {
    enum: ['pending', 'running', 'completed', 'failed', 'cancelled'],
  }).default('pending').notNull(),
  progress: integer('progress').default(0), // 0-100
  result: jsonb('result'),                  // AI API 返回的原始结果
  errorMessage: text('error_message'),
  retryCount: integer('retry_count').default(0),
  createdAt: timestamp('created_at').defaultNow().notNull(),
  completedAt: timestamp('completed_at'),
})

// packages/database/schema/relations.ts
import { relations } from 'drizzle-orm'
 
export const usersRelations = relations(users, ({ many }) => ({
  videos: many(videos),
  aiTasks: many(aiTasks),
}))
 
export const videosRelations = relations(videos, ({ one, many }) => ({
  user: one(users, { fields: [videos.userId], references: [users.id] }),
  comments: many(comments),
}))

// server/api/videos/index.get.ts
export default defineEventHandler(async (event) => {
  const query = getQuery(event)
  const { page = 1, limit = 20, tag, sort = 'latest' } = query
 
  const db = useDB()
 
  const where = and(
    eq(videos.status, 'published'),
    tag ? arrayContains(videos.tags, [tag as string]) : undefined,
  )
 
  const orderBy = sort === 'popular'
    ? desc(videos.viewCount)
    : desc(videos.publishedAt)
 
  const [items, [{ count }]] = await Promise.all([
    db.select()
      .from(videos)
      .where(where)
      .orderBy(orderBy)
      .limit(Number(limit))
      .offset((Number(page) - 1) * Number(limit)),
    db.select({ count: sql<number>`count(*)` })
      .from(videos)
      .where(where),
  ])
 
  return {
    items,
    pagination: {
      page: Number(page),
      limit: Number(limit),
      total: count,
    },
  }
})

// server/api/ai/generate.post.ts
import { z } from 'zod'
 
const generateSchema = z.object({
  prompt: z.string().min(10).max(500),
  model: z.enum(['kling', 'sora', 'runway']),
  style: z.enum(['realistic', 'anime', 'cinematic']).optional(),
  duration: z.number().min(3).max(60).default(10),
})
 
export default defineEventHandler(async (event) => {
  const session = await requireAuth(event)
  const body = await readValidatedBody(event, generateSchema.parse)
 
  const task = await createAiTask({
    userId: session.user.id,
    prompt: body.prompt,
    model: body.model,
    style: body.style,
  })
 
  return { taskId: task.id }
})

// apps/web/nuxt.config.ts
export default defineNuxtConfig({
  routeRules: {
    '/': { swr: 60 },                       // 首页缓存 60s
    '/videos/**': { swr: 30 },              // 视频列表缓存 30s
    '/video/:id': { ssr: true },            // 视频详情 SSR
    '/search': { ssr: true },               // 搜索页 SSR
    '/create/**': { ssr: false },           // AI 生成页 CSR
    '/dashboard/**': { ssr: false },        // 个人中心 CSR
    '/api/**': { cors: true },              // API 允许跨域
  },
})

<!-- pages/video/[id].vue -->
<script setup>
const route = useRoute()
const { data: video } = await useFetch(`/api/videos/${route.params.id}`)
 
useSeoMeta({
  title: video.value?.title,
  description: video.value?.description,
  ogTitle: video.value?.title,
  ogDescription: video.value?.description,
  ogImage: video.value?.thumbnailUrl,
  ogVideo: video.value?.hlsUrl,
  ogType: 'video.other',
})
 
useHead({
  script: [
    {
      type: 'application/ld+json',
      innerHTML: JSON.stringify({
        '@context': 'https://schema.org',
        '@type': 'VideoObject',
        name: video.value?.title,
        description: video.value?.description,
        thumbnailUrl: video.value?.thumbnailUrl,
        uploadDate: video.value?.createdAt,
        duration: `PT${video.value?.duration}S`,
      }),
    },
  ],
})
</script>