app\core\traits\FixDataTrait::migrate()

Complexity

Conditions	8
Paths	26

Size

Total Lines	26
Code Lines	19

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    private function migrate($query, \Closure $existCallback, \Closure $callback, $userTransaction = true): array
    {
        $transaction = $userTransaction ? \Yii::$app->db->beginTransaction() : null;
        $count = $query->count();
        try {
            for ($i = 0; $i <= (int)ceil($count / $this->onceCount); $i++) {
                $items = $query
                    ->orderBy(['id' => SORT_ASC])
                    ->limit($this->onceCount)
                    ->offset($i * $this->onceCount)
                    ->all();
                // item is array
                foreach ($items as $item) {
                    if (!call_user_func($existCallback, $item)) {
                        // todo batch insert
                        $ids[] = call_user_func($callback, $item);
                    }
                }
            }
            $userTransaction ? $transaction->commit() : null;

The method commit() does not exist on null.

            sleep($this->sleepSecond);
            return $ids ?? [];
        } catch (\Exception $e) {
            $userTransaction ? $transaction->rollBack() : null;
            \Yii::error('修复数据失败', ['query' => $query, (string)$e]);

array('query' => $query, (string)$e) of type array<integer|string,string|yii\db\ActiveQuery> is incompatible with the type string expected by parameter $category of yii\BaseYii::error().

            throw $e;
        }