zhuravljov\yii\queue\monitor\migrations\M180222000000WorkerPing::safeUp()

Complexity

Conditions	3
Paths	2

Size

Total Lines	25
Code Lines	18

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function safeUp()
    {
        $this->addColumn(
            $this->env->workerTableName,
            'pinged_at',
            $this->integer()->notNull()->after('started_at')
        );

        $time = $this->beginCommand("update {$this->env->workerTableName}");
        $this->compact = true;
        $query = (new Query())->from($this->env->workerTableName);
        foreach ($query->all($this->db) as $row) {
            $this->update(
                $this->env->workerTableName,
                ['pinged_at' => $row['finished_at'] ?: time()],
                ['id' => $row['id']]
            );
        }
        $this->compact = false;
        $this->endCommand($time);

        $this->addColumn(
            $this->env->workerTableName,
            'stopped_at',
            $this->integer()->after('pinged_at')
        );