🚀 NestJS + Prisma + BullMQ

// user.controller.ts

// @Controller('users') - 我是 users 模块的控制器
// 访问路径前缀是 /users
@Controller('users')
export class UsersController {

  // @Get() - 处理 GET 请求
  // 完整路径: GET /users
  @Get()
  findAll() {
    return [
      { id: 1, name: '张三' },
      { id: 2, name: '李四' },
    ];
  }

  // @Get(':id') - :id 是路由参数
  // 完整路径: GET /users/123
  @Get(':id')
  findOne(@Param('id') id: string) {
    return { id, name: '用户' + id };
  }
}

// user.service.ts

// @Injectable() - 表示此类可以被依赖注入
// NestJS 会自动创建这个类的实例
@Injectable()
export class UsersService {

  // 模拟数据库中的用户
  private users = [
    { id: 1, name: '张三', email: 'zhangsan@example.com' },
    { id: 2, name: '李四', email: 'lisi@example.com' },
  ];

  findAll() {
    return this.users;
  }

  findById(id: number) {
    return this.users.find(u => u.id === id);
  }

  create(data: { name: string; email: string }) {
    const newUser = { id: this.users.length + 1, ...data };
    this.users.push(newUser);
    return newUser;
  }
}

// users.module.ts
@Module({
  controllers: [UsersController],   // 控制器
  providers: [UsersService],       // 服务（可注入的）
  exports: [UsersService],         // 导出给其他模块用
})
export class UsersModule {}

// app.module.ts - 根模块
@Module({
  imports: [UsersModule],        // 引入子模块
})
export class AppModule {}

// prisma/schema.prisma

// generator - 指定生成什么客户端
generator client {
  provider = "prisma-client-js"
}

// datasource - 指定用什么数据库
datasource db {
  provider = "postgresql"
  url      = env("DATABASE_URL")
}

// model User - 定义 User 表
// @id = 主键，@default(autoincrement()) = 自动增长
// String + ? = 可选字段
model User {
  id        Int      @id @default(autoincrement())
  name      String
  email     String  @unique  // 唯一索引，不能重复
  age       Int??              // ? = 可选字段
  createdAt DateTime @default(now())
  
  // relation - 一对多关系
  // 一个 User 可以有多篇 Post
  posts     Post[]
}

model Post {
  id        Int      @id @default(autoincrement())
  title     String
  content   String??
  published Boolean @default(false)
  
  // 外键关联到 User
  authorId  Int
  author    User     @relation(fields: [authorId], references: [id])
}

// 查询用户的同时，把关联的文章也查出来
const user = await prisma.user.findUnique({
  where: { id: 1 },
  include: {
    posts: true  // 把这个用户的文章也一起查出来
  }
});

// user.posts 就是这个用户的所有文章
console.log(user.posts);

// 同时创建用户和用户的文章，要么全成功，要么全失败
const result = await prisma.$transaction([
  prisma.user.create({ data: { name: '张三', email: 'zhangsan@example.com' } }),
  prisma.post.create({ data: { title: '你好', authorId: 1 } })
]);

// 执行原生 SQL
const result = await prisma.$queryRaw<User>`
  SELECT * FROM users WHERE age > ${minAge}
`;

// 5 分钟后再执行（适合：延时提醒、定时任务）
await emailQueue.add('reminder', {
  to: 'user@example.com',
  message: '该打卡了！'
}, {
  delay: 5 * 60 * 1000  // 5 分钟（毫秒）
});

const worker = new Worker('api', async (job) => {
  
  // 模拟可能失败的操作
  if (Math.random() > 0.7) {
    throw new Error('网络错误');
  }
  
  return { success: true };
  
}, {
  connection: { host: 'localhost', port: 6379 },
  
  // 重试配置
  limiter: {
    max: 3,        // 最多重试 3 次
    duration: 5000   // 每次间隔 5 秒
  }
});

// 添加任务时指定优先级（数字越小优先级越高）
await emailQueue.add('vip-notify', { userId: 1 }, { priority: 1 }); // 高优先
await emailQueue.add('daily-digest', { userId: 2 }, { priority: 5 }); // 普通

// 每小时执行一次
await emailQueue.add(
  'report',
  { type: 'daily' },
  {
    repeat: {
      every: 60 * 60 * 1000  // 每小时（毫秒）
    }
  }
);