modify

2021-04-16 01:00:46 +08:00
parent 827e599f1b
commit 0354ce4062
1 changed files with 1 additions and 2 deletions
@@ -88,9 +88,8 @@ class Zookeeper extends Process
    {
        $redis = Snowflake::app()->getRedis();

-        $startTime = time();
+        $range = $redis->zRangeByScore(Producer::CRONTAB_KEY, '0', (string)time());

-        $range = $redis->zRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime);
        $redis->zRem(Producer::CRONTAB_KEY, ...$range);

        return [$range, $redis];