NestJS中能否在Service服务函数内使用UsePipes验证管道？

NestJS内置的@UsePipes装饰器以及管道体系，是仅针对Controller层的HTTP请求处理链路设计的，只会在接口请求进入Controller方法、解析参数前触发执行，普通Provider（包括Service）的类方法上添加该装饰器不会被Nest的请求拦截体系识别，因此不会生效。

Nest的ValidationPipe底层基于class-validator和class-transformer实现，你可以直接基于这两个库实现Service层的参数校验，常用方案有以下三种：

方案1：手动调用校验逻辑 #

适合单次校验的场景，直接在方法内完成数据转换和校验：

import { validate } from 'class-validator';
import { plainToInstance } from 'class-transformer';
import { BadRequestException } from '@nestjs/common';

async create(createMemberData: Record<string, any>, temp: boolean=false) {
    // 将普通入参对象转换为Dto类实例
    const createMemberDto = plainToInstance(CreateMemberDto, createMemberData);
    // 触发校验规则
    const errors = await validate(createMemberDto);
    if (errors.length > 0) {
        // 抛出和Controller层格式一致的异常
        throw new BadRequestException(errors);
    }
    // 后续业务逻辑
}

方案2：封装通用校验工具 #

适合多场景复用校验能力，避免重复写校验代码：

// 公共校验工具
import { validate } from 'class-validator';
import { plainToInstance, ClassType } from 'class-transformer';
import { BadRequestException } from '@nestjs/common';

export async function validateDto<T extends object>(dtoClass: ClassType<T>, plain: object): Promise<T> {
    const instance = plainToInstance(dtoClass, plain);
    const errors = await validate(instance);
    if (errors.length > 0) {
        throw new BadRequestException(errors);
    }
    return instance;
}

// Service中使用
async create(createMemberData: Record<string, any>, temp: boolean=false) {
    const createMemberDto = await validateDto(CreateMemberDto, createMemberData);
    // 后续业务逻辑
}

方案3：自定义方法装饰器 #

如果你希望保持和Controller层类似的装饰器写法，可以自己实现AOP拦截能力的校验装饰器：

// 自定义校验装饰器
import { validate } from 'class-validator';
import { plainToInstance } from 'class-transformer';
import { BadRequestException } from '@nestjs/common';

export function ValidateDto(paramIndex: number, dtoClass: any) {
    return function (target: any, propertyKey: string, descriptor: PropertyDescriptor) {
        const originalMethod = descriptor.value;
        descriptor.value = async function (...args: any[]) {
            const plain = args[paramIndex];
            const instance = plainToInstance(dtoClass, plain);
            const errors = await validate(instance);
            if (errors.length > 0) {
                throw new BadRequestException(errors);
            }
            args[paramIndex] = instance;
            return originalMethod.apply(this, args);
        };
        return descriptor;
    };
}

// Service中使用
@ValidateDto(0, CreateMemberDto)
async create(createMemberDto: CreateMemberDto, temp: boolean=false) {
    // 入参已完成校验，直接使用即可
    // 后续业务逻辑
}

内容的提问来源于stack exchange，提问作者Alexy