查选redis值
This commit is contained in:
@@ -33,7 +33,7 @@ class Queueinfo extends Base
|
|||||||
$redis->select($config['select']);
|
$redis->select($config['select']);
|
||||||
|
|
||||||
// 获取不同队列类型的任务数
|
// 获取不同队列类型的任务数
|
||||||
$aQueue = ['ArticleAiCreateContent','WechatMaterial','WechatDraft','WechatQueryStatus'];
|
$aQueue = empty($aParam['queue_name']) ? ['ArticleAiCreateContent','WechatMaterial','WechatDraft','WechatQueryStatus'] : [$aParam['queue_name']];
|
||||||
foreach ($aQueue as $key => $value) {
|
foreach ($aQueue as $key => $value) {
|
||||||
$types[$value] = [
|
$types[$value] = [
|
||||||
'pending' => 'queues:'.$value,
|
'pending' => 'queues:'.$value,
|
||||||
|
|||||||
Reference in New Issue
Block a user