<?php
namespace common\jobs;

use common\core\BaseModel;
use common\models\OpLog;
use common\models\PrescriptionLog;
use common\models\ProductOrder;
use common\models\ProductOrderLog;
use common\forms\LedgerForm;

use yii\queue\JobInterface;
use yii\queue\Queue;

/**
 * 日志记录队列
 */
class LogJob extends BaseJob implements JobInterface
{
    public $params;

    /**
     * @param Queue $queue which pushed and is handling the job
     */
    public function execute($queue)
    {
        echo '日志队列开始：'. "\r\n";
        try {
            $this->setRequest();
            $param = $this->params;
            $opLogModel = new OpLog();
            $opLogModel->user_id = $param['user_id'];
            $opLogModel->url = $param['url'];
            $opLogModel->type = $param['type'];
            $opLogModel->ip = $param['ip'];
            $opLogModel->param = json_encode($param['param']);
            $opLogModel->result = json_encode($param['result']);
            $opLogModel->platform_type = $param['platform_type'];
            $opLogModel->platform_id = $param['platform_id'];
            $opLogModel->equipment = $param['equipment'];
            $opLogModel->browser = $param['browser'];
            $opLogModel->created_at = date('Y-m-d H:i:s');
            $opLogModel->saveOrFail();

            echo '日志队列结束：'. "\r\n";
        } catch (\Exception $exception) {
            echo '日志队列异常：'. $exception->getMessage(). "\r\n";
            return;
        }
    }
}