Yii2開發技巧 使用相似閉包的方式封裝事務

在控制器中執行事務的時候,通常的代碼以下:閉包

$transaction = Yii::$app->db->beginTransaction();
try {
    //一些業務代碼
    $transaction->commit();
} catch (\Exception $e) {
    $transaction->rollBack();
    throw $e;
}

因而我在想,這個代碼結構,只有//一些業務代碼 這一部分是不同,卻要重複不少遍,這一不是很冗餘嗎? 並且 不!好!看!,因而我試着尋找解決方法,一開始在stackflow找到一個相似的提問,有方案是在model裏作封裝,可是這樣作有必定問題,如產生嵌套事務等,有興趣的能夠點擊這裏查看該問答app

咱們的Yii框架給出了一個方法transaction,乍一看好像不能解決傳參的問題,咱們先無論,往下看,該方法調用方式以下:框架

Yii::$app->db->transaction(function() {
    //一些業務代碼
});

咱們來看一下這個方法的源碼ide

/**
 * Executes callback provided in a transaction.
 *
 * @param callable $callback a valid PHP callback that performs the job. Accepts connection instance as parameter.
 * @param string|null $isolationLevel The isolation level to use for this transaction.
 * See [[Transaction::begin()]] for details.
 * @throws \Exception|\Throwable if there is any exception during query. In this case the transaction will be rolled back.
 * @return mixed result of callback function
 */
public function transaction(callable $callback, $isolationLevel = null)
{
    $transaction = $this->beginTransaction($isolationLevel);
    $level = $transaction->level;

    try {
        $result = call_user_func($callback, $this);
        if ($transaction->isActive && $transaction->level === $level) {
            $transaction->commit();
        }
    } catch (\Exception $e) {
        $this->rollbackTransactionOnLevel($transaction, $level);
        throw $e;
    } catch (\Throwable $e) {
        $this->rollbackTransactionOnLevel($transaction, $level);
        throw $e;
    }

    return $result;
}

這個方法接受一個回調函數和事務的隔離級別,
從這裏咱們看出,這個方法雖然解決重複代碼,卻還有幾個問題沒有解決:
第一,這個方法拋出的異常咱們須要在接收外面處理,咱們不可能直接拋出,這樣對客戶端很不友好。
第二:沒有記錄日誌的行爲,即便出了問題也不容易排除。
第三:其實仍是第一個問題,若是咱們須要對每一個異常作處理,在transaction方法外再嵌套一層try...catch...,那麼和沒有封裝好像沒什麼區別?函數

根據方法可擴展不可修改的原則,咱們應該在本身公共方法裏對這個方法進行重載,重載代碼以下:post

public static function TransactionExecute(callable $function,$level=null)
{
    try{
        \Yii::$app->db->transaction($function,$level);
}catch (\Exception $e){
        //記錄日誌
        \Yii::error($e->getMessage());
        //這裏能夠理解成拋出自定義的異常類。
        (new self())->returnWayTip(1004, 'trans異常錯誤');
    }
}

而後回到如何傳參的問題,咱們可使用閉包,貼一段僞代碼,以下:this

//執行事務
PublicFunction::TransactionExecute(function () use ($token_reward, $reward_info) {
        //業務代碼
        $token_reward->save(0);
    MsgHelper::send($reward_info['post_id'], MsgHelper::SOMEONE_FINISH_REWARD, $reward_info);

    });

大功告成,代碼看起來有沒有更好看呢? 日誌

若有問題,歡迎指教。code

相關文章
相關標籤/搜索