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) {