php教程

超轻量级php框架startmvc

在laravel中实现事务回滚的方法

更新时间:2020-04-09 21:55:57 作者:startmvc
之前做项目用到了事务回滚这个机制。我把代码贴出来多多交流给点意见,我用的是laravel5.

之前做项目用到了事务回滚这个机制。我把代码贴出来多多交流给点意见,我用的是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);
 }
 }

以上这篇在laravel中实现事务回滚的方法就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持脚本之家。

laravel 事务 回滚