From f44ead3dddfd78226d33d1ae59b95ddb0cc802c1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Fri, 19 Mar 2021 18:15:02 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- System/Process/CrontabProcess.php | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/System/Process/CrontabProcess.php b/System/Process/CrontabProcess.php index 6ce6c255..e0005ecc 100644 --- a/System/Process/CrontabProcess.php +++ b/System/Process/CrontabProcess.php @@ -48,7 +48,7 @@ class CrontabProcess extends Process while (true) { $list = $this->channel->pop(-1); if (isset($list['isLoop']) && isset($list['tick']) && $list['isLoop'] == 1) { - $redis->zAdd('system:crontab', 0, time() + $list['tick'], serialize($list)); + $redis->zAdd('system:crontab', time() + $list['tick'], serialize($list)); } try { call_user_func($list['handler'], $list['params'] ?? null); @@ -73,8 +73,8 @@ class CrontabProcess extends Process $score = time(); $redis = Snowflake::app()->getRedis(); - $lists = $redis->zRangeByScore('system:crontab', $score, $score); - $redis->zRemRangeByScore('system:crontab', $score, $score); + $lists = $redis->zRangeByScore('system:crontab', (string)$score, (string)$score); + $redis->zRemRangeByScore('system:crontab', (string)$score, (string)$score); $barrier = Barrier::make(); foreach ($lists as $list) {