<?php

namespace common\components\jqueue\db;

use Yii;
use yii\base\Component;
use common\components\jqueue\base\IFailedProvider;
use function is_array;
use function time;

/**
 * Class DatabaseFailedProvider
 * @package common\components\jqueue\db
 */
class FailedProvider extends Component implements IFailedProvider
{
    /**
     * 数据库链接实例
     * @var \Yii\db\Connection
     */
    public $db;
    
    /**
     * 记录错误信息的表
     * @var string
     */
    public $table = 'failed_jobs';

    public function init()
    {
        parent::init();
        if (is_array($this->db)) {
            $this->db = Yii::createObject($this->db);
        }
    }

    /**
     * 将失败日志写入数据库
     * @param $connector 链接器名称，目前只支持数据库
     * @param $queueName
     * @param $payload
     * @return int
     */
    public function log($queueName, $payload)
    {
        return $this->db->createCommand()->insert($this->table, [
            'queue'     => $queueName,
            'payload'   => $payload,
            'failed_at' => time()
        ])->execute();
    }
}