Laravel中单个控制器调用两个服务的事务实现方案及异常处理位置咨询

我来帮你拆解这个问题，先解决事务回滚的核心痛点，再聊聊try-catch在不同层级的使用场景。

一、解决事务嵌套报错+原子回滚的方案 #

你遇到的问题本质是内层事务（X/Y Service里的事务）和外层事务（Controller里的全局事务）冲突，导致Y失败时X无法回滚。这里有两种优雅的解决思路：

方案1：统一外层事务，让Service适配事务共享 #

最推荐的做法是把全局事务放在Controller层，同时修改Service的方法，让它们能在已有事务中运行，避免重复开启事务。

步骤1：修改ZController的store方法，开启全局事务

public function store(Request $request): JsonResponse {
    // 用DB::transaction闭包自动处理提交/回滚
    return DB::transaction(function () use ($request) {
        $x = $this->XService->create();
        $y = $this->YService->create();
        
        return response()->json(['x' => $x, 'y' => $y]);
    });
}

步骤2：调整X/Y Service的create方法，支持事务共享

如果X/Y Service的create方法原本有自己的事务，我们可以判断当前是否已处于事务中，避免嵌套：

// XService.php示例
public function create() {
    // 检查当前是否已有事务在运行
    $hasActiveTransaction = DB::transactionLevel() > 0;
    
    if (!$hasActiveTransaction) {
        // 单独调用时，开启自己的事务
        return DB::transaction(function () {
            return $this->performCreate();
        });
    }
    
    // 已有外层事务时，直接执行核心逻辑，共享外层事务
    return $this->performCreate();
}

// 把核心创建逻辑抽成私有方法，复用代码
private function performCreate() {
    $x = new X();
    // 填充属性、关联数据等逻辑
    $x->save();
    return $x;
}

这样一来，当ZController调用时，X和Y的create逻辑都在同一个全局事务里，任何一个抛出异常，整个事务都会回滚，X的数据也不会被保留；而当其他地方单独调用XService的create时，依然会有自己的事务保障。

方案2：手动管理事务（适合特殊场景） #

如果你不想修改Service的现有逻辑，可以手动控制事务的开启和回滚，但要注意避免嵌套冲突：

public function store(Request $request): JsonResponse {
    DB::beginTransaction();
    try {
        $x = $this->XService->create();
        $y = $this->YService->create();
        
        DB::commit();
        return response()->json(['x' => $x, 'y' => $y]);
    } catch (Exception $e) {
        DB::rollBack();
        // 可以在这里记录日志，或者返回友好错误
        throw $e;
    }
}

⚠️ 注意：这种方式要求X/Y Service的create方法不能再开启独立事务，否则会导致嵌套报错或回滚不彻底。

二、try-catch在Repository/Service层的使用场景 #

try-catch可以在这两层使用，但要遵循分层职责，不能滥用：

1. Repository层：捕获数据库异常，转换为业务异常 #

Repository的核心职责是数据访问，适合在这里捕获数据库层面的异常（比如唯一约束冲突、外键关联错误），然后转换为更易理解的业务异常，避免上层处理底层数据库细节：

// XRepository.php示例
public function create(array $data) {
    try {
        return X::create($data);
    } catch (QueryException $e) {
        // 捕获唯一约束违反的错误（MySQL错误码23000）
        if ($e->getCode() === '23000') {
            throw new DuplicateXException("X的某个属性已存在，请检查");
        }
        // 其他数据库异常重新抛出，让上层处理
        throw $e;
    }
}

2. Service层：处理业务逻辑异常，协调多资源操作 #

Service层负责业务规则的实现，适合在这里捕获Repository抛出的业务异常，或者处理多资源操作时的异常补偿：

// ZService.php（如果后续把Z的逻辑抽成Service）示例
public function createXY(array $data) {
    try {
        $x = $this->xRepository->create($data['x']);
        $y = $this->yRepository->create(['x_id' => $x->id] + $data['y']);
        return ['x' => $x, 'y' => $y];
    } catch (DuplicateXException $e) {
        // 针对业务异常做特殊处理，比如返回错误提示
        throw new BusinessException("创建失败：{$e->getMessage()}");
    }
}

如果Service方法涉及多个原子操作，也可以在这里开启事务，但要注意和外层事务的兼容性（参考方案1的事务层级判断）。

3. Controller层：处理异常并返回HTTP响应 #

Controller的职责是对接HTTP请求，适合在这里捕获所有上层抛出的异常，转换为对应的HTTP响应：

public function store(Request $request) {
    try {
        $result = $this->zService->createXY($request->all());
        return response()->json($result, 201);
    } catch (BusinessException $e) {
        return response()->json(['error' => $e->getMessage()], 400);
    } catch (Exception $e) {
        Log::error("创建XY失败：{$e->getMessage()}");
        return response()->json(['error' => '服务器内部错误'], 500);
    }
}

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