添加事务

3 years ago · 2d4bf9bb2d
1 changed files with 14 additions and 3 deletions
--- a/app/controller/User.php
+++ b/app/controller/User.php
@ -239,11 +239,22 @@ class User extends BaseController
    {
        $userData = $this->request->userInfo;

-        $result = UserModel::transferBalance($userData['id']);
+        $connection = Db::connect();
+
+        try {

+            # 开启事务
+            $connection->startTrans();
+
+            $result = UserModel::transferBalance($userData['id']);
            if (!$result['status']) return $this->renderError($result['msg']);

+            $connection->commit();
            return $this->renderSuccess('成功');
+        } catch (\Exception $e) {
+            $connection->rollback();
+            return $this->renderError('操作失败');
+        }
    }

    /**