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());
}
}
/**
* WIN创建监听进程
* @login true
*/
public function start()
{
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());
}
}
/**
* 检查任务状态
* @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 "已启动";
} else {
echo "未启动";
}
} catch (Exception $exception) {
echo "异 常";
} else {
echo "无权限";
}
}
/**
* 任务进度查询
* @login true
* @throws \think\admin\Exception
*/
public function progress()
{
$input = $this->_vali(['code.require' => '任务编号不能为空！']);
$queue = QueueService::instance()->initialize($input['code']);
$this->success('获取任务进度成功！', $queue->progress());
}
}