feat: add DepartmentsModule with DTO, Service, and stub controller

2026-07-05 23:47:41 +08:00
parent ad24c9ef23
commit 0e08770cf4
5 changed files with 175 additions and 2 deletions
--- a/apps/server/src/departments/departments.service.ts
+++ b/apps/server/src/departments/departments.service.ts
@@ -0,0 +1,111 @@
+import { Injectable, NotFoundException, ConflictException } from '@nestjs/common';
+import { InjectRepository } from '@nestjs/typeorm';
+import { Repository } from 'typeorm';
+import { Department } from '../entities/department.entity';
+import { UserDepartment } from '../entities/user-department.entity';
+import { CreateDepartmentDto, UpdateDepartmentDto, AssignUserDto } from './dto/department.dto';
+
+@Injectable()
+export class DepartmentsService {
+  constructor(
+    @InjectRepository(Department)
+    private deptRepo: Repository<Department>,
+    @InjectRepository(UserDepartment)
+    private userDeptRepo: Repository<UserDepartment>,
+  ) {}
+
+  async findAll(): Promise<Department[]> {
+    return this.deptRepo.find({
+      where: { status: 'active' },
+      order: { sortOrder: 'ASC', name: 'ASC' },
+    });
+  }
+
+  async findTree(): Promise<Department[]> {
+    const all = await this.deptRepo.find({
+      where: { status: 'active' },
+      order: { sortOrder: 'ASC', name: 'ASC' },
+      relations: ['children'],
+    });
+    return all.filter((d) => d.parentId === null);
+  }
+
+  async findOne(id: number): Promise<Department> {
+    const dept = await this.deptRepo.findOne({ where: { id } });
+    if (!dept) throw new NotFoundException('部门不存在');
+    return dept;
+  }
+
+  async create(dto: CreateDepartmentDto): Promise<Department> {
+    const dept = this.deptRepo.create(dto);
+    return this.deptRepo.save(dept);
+  }
+
+  async update(id: number, dto: UpdateDepartmentDto): Promise<Department> {
+    const dept = await this.findOne(id);
+    Object.assign(dept, dto);
+    return this.deptRepo.save(dept);
+  }
+
+  async remove(id: number): Promise<void> {
+    const children = await this.deptRepo.count({ where: { parentId: id } });
+    if (children > 0) throw new ConflictException('该部门下存在子部门，无法删除');
+
+    const users = await this.userDeptRepo.count({ where: { departmentId: id } });
+    if (users > 0) throw new ConflictException('该部门下有用户关联，无法删除');
+
+    await this.deptRepo.update(id, { status: 'archived' });
+  }
+
+  /** 获取部门的所有子部门 ID（递归，含自身） */
+  async getDescendantIds(departmentId: number): Promise<number[]> {
+    const ids = [departmentId];
+    const children = await this.deptRepo.find({
+      where: { parentId: departmentId, status: 'active' },
+    });
+    for (const child of children) {
+      const childIds = await this.getDescendantIds(child.id);
+      ids.push(...childIds);
+    }
+    return ids;
+  }
+
+  /** 获取用户可访问的部门 ID 列表 */
+  async getUserDepartments(userId: number): Promise<number[]> {
+    const records = await this.userDeptRepo.find({
+      where: { userId },
+    });
+    return records.map((r) => r.departmentId);
+  }
+
+  /** 获取用户默认校区 ID */
+  async getUserDefaultDepartmentId(userId: number): Promise<number | null> {
+    const record = await this.userDeptRepo.findOne({
+      where: { userId, isDefault: true },
+    });
+    return record?.departmentId ?? null;
+  }
+
+  /** 获取部门下的用户 */
+  async getUsers(departmentId: number): Promise<UserDepartment[]> {
+    return this.userDeptRepo.find({
+      where: { departmentId },
+      relations: ['user'],
+    });
+  }
+
+  /** 为用户分配部门 */
+  async assignUser(departmentId: number, dto: AssignUserDto): Promise<UserDepartment> {
+    const record = this.userDeptRepo.create({
+      userId: dto.userId,
+      departmentId,
+      isDefault: dto.isDefault ?? false,
+    });
+    return this.userDeptRepo.save(record);
+  }
+
+  /** 移除用户-部门关联 */
+  async removeUser(departmentId: number, userId: number): Promise<void> {
+    await this.userDeptRepo.delete({ departmentId, userId });
+  }
+}