From 4906b704e5111654a0ea16fcfe9d591bc8e10b93 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Fri, 19 Mar 2021 18:40:46 +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/Crontab.php | 2 +- System/Process/CrontabProcess.php | 5 +++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/System/Crontab.php b/System/Crontab.php index 205118d1..dfe015ed 100644 --- a/System/Crontab.php +++ b/System/Crontab.php @@ -35,7 +35,7 @@ class Crontab extends Component $crontab = ['isLoop' => $isLoop, 'handler' => $handler, 'tick' => $tickTime, 'params' => $params]; - $redis->zAdd('system:crontab', $executeTime, serialize($crontab)); + $redis->zAdd('system:crontab', (string)$executeTime, serialize($crontab)); } } diff --git a/System/Process/CrontabProcess.php b/System/Process/CrontabProcess.php index e0005ecc..d147b7a1 100644 --- a/System/Process/CrontabProcess.php +++ b/System/Process/CrontabProcess.php @@ -73,8 +73,9 @@ class CrontabProcess extends Process $score = time(); $redis = Snowflake::app()->getRedis(); - $lists = $redis->zRangeByScore('system:crontab', (string)$score, (string)$score); - $redis->zRemRangeByScore('system:crontab', (string)$score, (string)$score); + $lists = $redis->zRangeByScore('system:crontab', '0', (string)$score); + var_dump($lists); + $redis->zRemRangeByScore('system:crontab', '0', (string)$score); $barrier = Barrier::make(); foreach ($lists as $list) {