PHP中发票支付场景复杂SQL事务的合理构建方案咨询

你的核心问题是事务原子性和锁性能的冲突：原大事务锁表、死锁是因为锁持有时间太长、锁范围过大；拆分小事务则会破坏数据一致性，出现部分成功无法回滚的问题。优先推荐优化原事务，而非拆分，以下是具体方案：

一、优化原事务的核心思路：缩短锁持有时间+减少锁冲突 #

1. 把非数据库操作移出事务 #

如果updateInvoice()、addJournals()、setUpReport()里包含外部API调用、文件读写、复杂计算等耗时操作，全部移到事务开启前完成。事务只做纯数据库写操作，能大幅缩短锁的持有时间。

示例代码：

// 事务外提前准备好所有需要的数据
$invoiceUpdateParams = $this->calculateInvoiceChanges($paymentInfo);
$journalEntries = $this->buildJournalRecords($paymentAmount);
$reportPayload = $this->prepareReportData($paymentDetails);

try {
    $this->conn->beginTransaction();
    
    // 事务内只执行数据库操作，无额外耗时逻辑
    $this->updateInvoice($invoiceUpdateParams);
    $this->addJournals($journalEntries);
    $this->setUpReport($reportPayload);
    
    $this->conn->commit();
} catch (Exception $ex) {
    $this->conn->rollback();
    // 记录错误日志或触发告警
    throw $ex;
}

2. 统一数据库操作顺序，避免死锁 #

死锁的本质是两个事务互相持有对方需要的锁。确保所有涉及这些表的事务，都遵循相同的操作顺序（比如先操作发票表，再日记账表，最后报表相关表），就能从根源避免循环等待导致的死锁。

3. 优化SQL语句，缩小锁范围 #

检查三个函数内的SQL：

• 所有UPDATE/DELETE语句必须用主键或唯一索引作为WHERE条件，确保InnoDB使用行级锁而非表级锁；
• 避免在事务内执行无索引的全表查询，必要的查询移到事务外，或用SELECT ... FOR UPDATE时严格限制范围；
• 移除事务内不必要的锁操作，比如不需要加锁的查询不要用排他锁。

4. 调整事务隔离级别（谨慎操作） #

如果业务允许，可将事务隔离级别从默认的REPEATABLE READ调整为READ COMMITTED，能减少幻读带来的锁冲突，但需确认业务逻辑不受影响（比如不需要重复读取一致的数据）。

二、拆分事务的补偿方案（仅当原事务优化无效时使用） #

如果必须拆分事务，需引入补偿机制保证最终一致性，流程如下：

1. 新增一张operation_log表，记录每个操作的ID、类型（发票更新/日记账插入/报表设置）、关联数据ID、状态（待执行/成功/失败/已回滚）。
2. 分步执行事务并记录日志：

// 第一步：更新发票
$invoiceSuccess = false;
try {
    $this->conn->beginTransaction();
    $invoiceId = $this->updateInvoice($invoiceUpdateParams);
    // 记录成功日志
    $this->logOperation('invoice_update', $invoiceId, 'success');
    $this->conn->commit();
    $invoiceSuccess = true;
} catch (Exception $ex) {
    $this->conn->rollback();
    $this->logOperation('invoice_update', null, 'fail', $ex->getMessage());
    throw $ex;
}

// 第二步：插入日记账
$journalSuccess = false;
if ($invoiceSuccess) {
    try {
        $this->conn->beginTransaction();
        $journalId = $this->addJournals($journalEntries);
        $this->logOperation('journal_add', $journalId, 'success');
        $this->conn->commit();
        $journalSuccess = true;
    } catch (Exception $ex) {
        $this->conn->rollback();
        $this->logOperation('journal_add', null, 'fail', $ex->getMessage());
        // 回滚第一步的发票更新
        $this->rollbackInvoiceUpdate($invoiceId);
        throw $ex;
    }
}

// 第三步：设置报表
if ($journalSuccess) {
    try {
        $this->conn->beginTransaction();
        $reportId = $this->setUpReport($reportPayload);
        $this->logOperation('report_setup', $reportId, 'success');
        $this->conn->commit();
    } catch (Exception $ex) {
        $this->conn->rollback();
        $this->logOperation('report_setup', null, 'fail', $ex->getMessage());
        // 回滚前两步操作
        $this->rollbackJournalAdd($journalId);
        $this->rollbackInvoiceUpdate($invoiceId);
        throw $ex;
    }
}

3. 实现回滚方法：比如rollbackInvoiceUpdate()把发票状态改回支付前的状态，rollbackJournalAdd()删除对应的日记账记录，且这些回滚方法要保证幂等性（重复执行不会出错）。

注意：这种方案复杂度高，需要处理回滚失败、重试等异常场景，仅适合业务允许短时间数据不一致的情况。

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