50 lines
1.5 KiB
PHP
50 lines
1.5 KiB
PHP
<?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;
|
|
}
|
|
}
|
|
} |