app->console->call('xadmin:queue', ['stop'])->fetch();
if (stripos($message, 'sent end signal to process')) {
sysoplog('系统运维管理', '尝试停止任务监听服务');
$this->success('停止任务监听服务成功！');
} elseif (stripos($message, 'processes to stop')) {
$this->success('没有找到需要停止的服务！');
} else {
$this->error(nl2br($message));
}
} catch (HttpResponseException $exception) {
throw $exception;
} catch (\Exception $exception) {
trace_file($exception);
$this->error($exception->getMessage());
} else {
$this->error('请使用超管账号操作！');
}
}
/**
* 启动监听服务
* @login true
*/
public function start()
{
if (AdminService::isSuper()) try {
$message = $this->app->console->call('xadmin:queue', ['start'])->fetch();
if (stripos($message, 'daemons started successfully for pid')) {
sysoplog('系统运维管理', '尝试启动任务监听服务');
$this->success('任务监听服务启动成功！');
} elseif (stripos($message, 'daemons already exist for pid')) {
$this->success('任务监听服务已经启动！');
} else {
$this->error(nl2br($message));
}
} catch (HttpResponseException $exception) {
throw $exception;
} catch (\Exception $exception) {
trace_file($exception);
$this->error($exception->getMessage());
} else {
$this->error('请使用超管账号操作！');
}
}
/**
* 检查监听服务
* @login true
*/
public function status()
{
if (AdminService::isSuper()) try {
$message = $this->app->console->call('xadmin:queue', ['status'])->fetch();
if (preg_match('/process.*?\d+.*?running/', $message)) {
echo "{$this->app->lang->get('已启动')}";
} else {
echo "{$this->app->lang->get('未启动')}";
}
} catch (\Error|\Exception $exception) {
echo "{$this->app->lang->get('异 常')}";
} else {
$message = lang('只有超级管理员才能操作！');
echo "{$this->app->lang->get('无权限')}";
}
}
/**
* 查询任务进度
* @login true
* @throws \think\admin\Exception
*/
public function progress()
{
$input = $this->_vali(['code.require' => '任务编号不能为空！']);
$result = QueueService::instance()->initialize($input['code'])->progress();
if (empty($result) || count($result['history']) < 2) {
$message = SystemQueue::mk()->where($input)->value('message', '');
$this->success('获取任务进度成功d！', json_decode($message, true));
} else {
$this->success('获取任务进度成功c！', $result);
}
}
}