- 按 BACKEND-PLAN.md 将项目重构为 4 层架构: config/ -> common/ -> infrastructure/ -> modules/ - 15 个业务模块,遵循 Controller → Service → Repository 分层 - infrastructure: PrismaService / RedisService / QueueService / AiService / StorageService - common: guards / interceptors / filters / pipes / decorators / dto / types / utils - Prisma schema 含 27 张表,MySQL 8.0 服务器 db push 成功 - Redis 7 接入: 限流/任务状态/分布式锁/队列预留 - ai-analysis 模块: 每日 50 次限流 + 重复提交锁 + 异步任务状态追踪 - document-import 模块: 异步导入流程 + 进度追踪 - notifications 模块: BullMQ notification 队列预留 - /health 端点实时返回 database + redis 连接状态 - Swagger 注册 15 个 tag,67 个路由全部映射
32 lines
954 B
TypeScript
32 lines
954 B
TypeScript
import { Injectable, NotFoundException } from '@nestjs/common';
|
|
import { FocusItemsRepository } from './focus-items.repository';
|
|
import { FocusItem } from './types/focus-item.types';
|
|
|
|
@Injectable()
|
|
export class FocusItemsService {
|
|
constructor(private readonly repository: FocusItemsRepository) {}
|
|
|
|
async findAll(): Promise<FocusItem[]> {
|
|
return this.repository.findAll();
|
|
}
|
|
|
|
async create(dto: any): Promise<FocusItem> {
|
|
return this.repository.create(dto);
|
|
}
|
|
|
|
async update(id: string, dto: any): Promise<FocusItem> {
|
|
const item = await this.repository.update(id, dto);
|
|
if (!item) throw new NotFoundException(`Focus item ${id} not found`);
|
|
return item;
|
|
}
|
|
|
|
async complete(id: string): Promise<FocusItem> {
|
|
const item = await this.repository.update(id, {
|
|
status: 'completed',
|
|
completedAt: new Date(),
|
|
});
|
|
if (!item) throw new NotFoundException(`Focus item ${id} not found`);
|
|
return item;
|
|
}
|
|
}
|