发表新帖

多个模型如何进行事务异常回退？

### 问题描述
多个模型继承一个数据库基础模型。例如 users、pre_stocks、stocks。
业务层 users、pre_stocks、stocks。代码在 pre_stock和stocks写后在users业务层里调用，如果其中一个流程执行失败后要退回所有的流程。
目前测试后只有users模型会回退。

手撸了一个swoole 框架  数据库的PDO连接池
### Swoole版本，PHP版本，以及操作系统版本信息
swoole 4.8.6 php8.0.15

### 相关代码
```php
class Users
{
    public $model = null;
    public function __construct()
    {
        $this->model = new Db();
    }
    public function set_pre_stock(int $user_id, array $pre_stock)
    {
        if (empty($pre_stock)) {
            return false;
        }
        try {
            $this->model->startTrans();
            $preStocks = (new PreStocks());
            $getAll_by_user_id = $preStocks->getAll_by_user_id($user_id);

$lists = [];
            $not_exists_list = [];

if (empty($getAll_by_user_id)) {
                for ($i = 0; $i < count($pre_stock); $i++) {
                    $item = $pre_stock[$i];
                    $lists[] = ['user_id' => $user_id, 'stock_id' => $item['id'], 'number' => $item['stock']];
                }
                if (!$preStocks->saveAll($lists)) {
                    throw new Exception('保存失败');
                }
            } else {
                $pre_stock_key_lists = array_column($getAll_by_user_id, 'number', 'stock_id');
                $stock_update_lists = [];
                for ($i = 0; $i < count($pre_stock); $i++) {
                    $item = $pre_stock[$i];
                    if (!array_key_exists($item['id'], $pre_stock_key_lists)) {
                        array_push($not_exists_list, ['user_id' => $user_id, 'stock_id' => $item['id'], 'number' => $item['stock']]);
                    } else {
                        $pre_stock_number = $pre_stock_key_lists[$item['id']];
                        if ($item['stock'] > $pre_stock_number) {
                            throw new Exception('件数已超');
                            break;
                        }
                        $pre_stock_key_lists[$item['id']] = $pre_stock_number + $item['stock'];
                    }
                    $stock_update_lists[] = $item;
                }

for ($i = 0; $i < count($stock_update_lists); $i++) {
                    $item = $stock_update_lists[$i];
                    $stock = $pre_stock_key_lists[$item['id']];
                    $stock_update_lists[$i]['stock'] =  $stock;
                }

$update_stock_lists = array_column($stock_update_lists, 'stock', 'id');

for ($i = 0; $i < count($getAll_by_user_id); $i++) {
                    $item = $getAll_by_user_id[$i];
                    $getAll_by_user_id[$i]['update'] = false;
                    if (array_key_exists($item['stock_id'], $update_stock_lists)) {
                        $getAll_by_user_id[$i]['number'] = $update_stock_lists[$item['stock_id']];
                        $getAll_by_user_id[$i]['update'] = true;
                    }
                }
               
                
                 if (!$preStocks->updateAll($getAll_by_user_id)) {
                     throw new Exception('预存失败');
                 }

if (!empty($not_exists_list)) {
                     if (!$preStocks->saveAll($not_exists_list)) {
                         throw new Exception('未存在的预存保存失败');
                     }
                 }
           
                $stock_ids = array_column($pre_stock, 'id');
                $stock_numbers=array_column($pre_stock, 'stock','id');
                $stocksbus = (new Stocks());
                if (!$stocksbus->stock_subtract_update($stock_ids, $stock_numbers)) {
                    throw new Exception('库存更新失败');
                }
            }
            $this->model->commit();
        } catch (\Exception $e) {
            $this->model->rollBack();
            Log::error($e->getMessage() . ' Line:' . $e->getLine());
            return false;
        }
        return true;
    }
}

```

### 你期待的结果是什么？
只要一个出错，所有的流程都要回退

发布于3年前 · 13 次浏览 · 来自提问