From 2d78233dc589188fce0fac0631836069f4ab94d0 Mon Sep 17 00:00:00 2001 From: "as2252258@163.com" Date: Fri, 16 Apr 2021 00:56:11 +0800 Subject: [PATCH] modify --- System/Crontab/Producer.php | 4 ++++ System/Crontab/Zookeeper.php | 1 + 2 files changed, 5 insertions(+) diff --git a/System/Crontab/Producer.php b/System/Crontab/Producer.php index 00b4454c..e185dc0f 100644 --- a/System/Crontab/Producer.php +++ b/System/Crontab/Producer.php @@ -42,6 +42,10 @@ class Producer extends Component $tickTime = time() + $crontab->getTickTime(); $redis->zAdd(self::CRONTAB_KEY, $tickTime, $name); + + var_dump($redis->zCard(self::CRONTAB_KEY), $tickTime); + + $redis->set('crontab:' . $name, swoole_serialize($crontab)); } diff --git a/System/Crontab/Zookeeper.php b/System/Crontab/Zookeeper.php index 52b2448a..822db104 100644 --- a/System/Crontab/Zookeeper.php +++ b/System/Crontab/Zookeeper.php @@ -91,6 +91,7 @@ class Zookeeper extends Process $startTime = time(); $range = $redis->zRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime); + var_dump($startTime, $range); $redis->zRem(Producer::CRONTAB_KEY, ...$range); return [$range, $redis];