From ecf6428833866295669b58aa0e84d3bf1a6f0f4a Mon Sep 17 00:00:00 2001 From: "as2252258@163.com" Date: Fri, 16 Apr 2021 00:47:13 +0800 Subject: [PATCH] modify --- System/Crontab/Producer.php | 2 +- System/Crontab/Zookeeper.php | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/System/Crontab/Producer.php b/System/Crontab/Producer.php index ca3de3bf..f78fe921 100644 --- a/System/Crontab/Producer.php +++ b/System/Crontab/Producer.php @@ -37,7 +37,7 @@ class Producer extends Component $tickTime = time() + $crontab->getTickTime(); $redis->del('stop:crontab:' . $name, 120); - $result = $redis->zAdd(self::CRONTAB_KEY, $tickTime, $name); + $result = $redis->zAdd(self::CRONTAB_KEY, 0, $tickTime, $name); var_dump($redis->zCard(self::CRONTAB_KEY)); if ($result) { $redis->set('crontab:' . $name, swoole_serialize($crontab)); diff --git a/System/Crontab/Zookeeper.php b/System/Crontab/Zookeeper.php index d4a25317..36d51abd 100644 --- a/System/Crontab/Zookeeper.php +++ b/System/Crontab/Zookeeper.php @@ -90,7 +90,7 @@ class Zookeeper extends Process $startTime = time(); - $range = $redis->zRemRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime); + $range = $redis->zRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime); var_dump($startTime, $range); // $redis->zRemRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime);