Shopware 6多实体仓库数据库事务实现方法问询

在Shopware 6中处理跨多张表的原子操作（避免竞态条件、保证数据一致性），主要有两种可靠的实现方式，完全覆盖你涉及voucher_pool、voucher_code、voucher_code_transaction三张表的业务需求：

一、直接使用Doctrine Connection管理事务 #

这是最直接可控的方案，和你提到的思路一致，所有仓库操作会自动纳入同一个事务上下文：

完整示例代码 #

<?php

use Doctrine\DBAL\Connection;
use Shopware\Core\Framework\Context;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;

// 通过构造函数注入依赖
public function __construct(
    private readonly Connection $connection,
    private readonly VoucherPoolRepository $voucherPoolRepository,
    private readonly VoucherCodeRepository $voucherCodeRepository
) {}

public function redeemVoucher(Context $context): void
{
    $this->connection->beginTransaction();
    try {
        // 关键：查询可用券时加悲观锁，彻底避免竞态条件
        $criteria = new Criteria();
        $criteria->addFilter(new EqualsFilter('redeemed', false));
        // 加行锁，防止其他并发请求读取同一条未兑换记录
        $criteria->setLockMode(Criteria::LOCK_MODE_PESSIMISTIC_WRITE);
        
        $availableCode = $this->voucherPoolRepository->search($criteria, $context)->first();
        if (!$availableCode) {
            throw new \RuntimeException('无可用优惠券');
        }

        // 插入voucher_code及关联的transaction
        $this->voucherCodeRepository->upsert([
            [
                'code'         => $availableCode->getCode(),
                'active'       => true,
                'value'        => 20,
                'valid_until'  => new \DateTime('2025-01-01'),
                'transactions' => [
                    ['value' => 20]
                ]
            ]
        ], $context);

        // 更新voucher_pool的兑换状态
        $this->voucherPoolRepository->update([
            [
                'id'       => $availableCode->getId(),
                'redeemed' => true
            ]
        ], $context);

        // 提交事务
        $this->connection->commit();
    } catch (\Throwable $e) {
        // 回滚所有操作
        $this->connection->rollBack();
        throw $e;
    }
}

核心说明 #

• 所有仓库的upsert/update/search操作会自动复用当前Connection开启的事务，无需额外配置
• 必须添加悲观锁：在查询voucher_pool时使用LOCK_MODE_PESSIMISTIC_WRITE，防止高并发下多个请求同时获取同一张未兑换优惠券

二、利用Shopware上下文事务（进阶方案） #

Shopware 6的Context对象支持事务嵌套，适合在多服务方法间传递统一的事务上下文：

示例代码 #

<?php

use Shopware\Core\Framework\Context;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;

public function redeemVoucher(Context $originalContext): void
{
    // 创建带事务的上下文
    $transactionContext = Context::createWithTransaction($originalContext);
    
    try {
        // 同样添加悲观锁查询可用券
        $criteria = new Criteria();
        $criteria->addFilter(new EqualsFilter('redeemed', false));
        $criteria->setLockMode(Criteria::LOCK_MODE_PESSIMISTIC_WRITE);
        
        $availableCode = $this->voucherPoolRepository->search($criteria, $transactionContext)->first();
        if (!$availableCode) {
            throw new \RuntimeException('无可用优惠券');
        }

        // 执行仓库操作
        $this->voucherCodeRepository->upsert([/* 同上述配置 */], $transactionContext);
        $this->voucherPoolRepository->update([/* 同上述配置 */], $transactionContext);

        // 提交事务
        $transactionContext->commit();
    } catch (\Throwable $e) {
        // 回滚事务
        $transactionContext->rollBack();
        throw $e;
    }
}

适用场景 #

• 需要在多个服务方法间传递同一事务上下文时，这种方式更优雅
• 底层仍基于Doctrine Connection实现，和第一种方案本质逻辑一致

常见问题解答 #

• Q：Shopware 6有没有类似Magento的批量事务对象？
  A：没有专门的"批量事务对象"，但通过上述两种方式，完全可以实现跨多张表的原子操作。仓库的所有CRUD操作会自动绑定到当前开启的事务中，无需额外的批量保存对象。
• Q：为什么原始代码没有事务效果？
  A：Shopware 6默认仓库操作是自动提交的（每次操作单独一个事务），必须手动开启事务并包裹所有需要原子执行的操作，才能保证数据一致性。

内容的提问来源于stack exchange，提问作者ts-mothership