在laravel中实现事务回滚

小咪咪 2022-06-10 08:10 176阅读 0赞

之前做项目用到了事务回滚这个机制。我把代码贴出来多多交流给点意见，我用的是laravel 5.1bane版本的，

public static function createDeal($to_status, $params, $new_balance, $update = true)
        {
            \DB::beginTransaction();
    
    
            try {
                $update_order_status = \DB::table('wallet_order')
                                        ->where('order_id', $params['order_id'])
                                        ->update(['to_status' => $to_status, 'update_time' => $params['pay_time']]);
                if (!$update_order_status) {
                    throw new \Exception("update order error");
                }
    
    
                $create_deal_status = \DB::table('wallet_deal')
                                        ->insert($params);
                if (!$create_deal_status) {
                    throw new \Exception("create deal error");
                    
                }
    
    
                if ($update) {               
                    $update_manage_status = self::updateManage(['balance' => $new_balance, 'update_time' => $params['pay_time']], $params['from_user']);
                    if (!$update_manage_status) {
                        throw new \Exception("update manage error");
                    }
                } else {
                    $manage_params = [
                        'user_id' => intval($params['from_user']),
                        'balance' => $new_balance,
                        'add_time' => $params['pay_time'],
                        'update_time' => $params['pay_time'],
                    ];
                    $create_manage_status = self::createManage($manage_params);
                    if (!$create_manage_status) {
                        throw new \Exception("create manage error");
                    }
                }
                \DB::commit();
            } catch (\Exception $e) {

//异常处理进行回滚，自己想对应的业务
                \DB::rollback();
                $trouble_params = [
                    'order_id' => $params['order_id'],
                    'deal_id' => $params['deal_id'],
                    'from_user' => $params['from_user'],
                    'to_user' => $params['to_user'],
                    'total_amount' => $params['total_amount'],
                    'add_time' => $params['pay_time'],
                    'type' => $params['type'],
                    'to_status' => $to_status
                ];
                \DB::connection('mongodb')
                    ->table('wallet_trouble')
                    ->insert($trouble_params);
            } finally {
                self::createLog($params, $to_status);
            }
        }