From 7ed4d43a9a3ff004a03ae9ae361e8cc49e649abb Mon Sep 17 00:00:00 2001
From: "as2252258@163.com" <as22522582>
Date: Fri, 16 Apr 2021 00:54:54 +0800
Subject: [PATCH] modify

---
 System/Crontab/Producer.php  | 13 +++++++------
 System/Crontab/Zookeeper.php |  3 +--
 2 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/System/Crontab/Producer.php b/System/Crontab/Producer.php
index 7393999c..00b4454c 100644
--- a/System/Crontab/Producer.php
+++ b/System/Crontab/Producer.php
@@ -34,14 +34,15 @@ class Producer extends Component
             throw new Exception('Cache key ' . self::CRONTAB_KEY . ' types error.');
         }
 
-        $tickTime = time() + $crontab->getTickTime();
         $redis->del('stop:crontab:' . $name, 120);
-
-        $result = $redis->zAdd(self::CRONTAB_KEY, $tickTime, $name);
-        var_dump($result, $redis->zCard(self::CRONTAB_KEY));
-        if ($result) {
-            $redis->set('crontab:' . $name, swoole_serialize($crontab));
+        if ($redis->exists('crontab:' . $name)) {
+            $redis->del('crontab:' . $name);
         }
+
+        $tickTime = time() + $crontab->getTickTime();
+
+        $redis->zAdd(self::CRONTAB_KEY, $tickTime, $name);
+        $redis->set('crontab:' . $name, swoole_serialize($crontab));
     }
 
 
diff --git a/System/Crontab/Zookeeper.php b/System/Crontab/Zookeeper.php
index 36d51abd..52b2448a 100644
--- a/System/Crontab/Zookeeper.php
+++ b/System/Crontab/Zookeeper.php
@@ -91,8 +91,7 @@ class Zookeeper extends Process
         $startTime = time();
 
         $range = $redis->zRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime);
-        var_dump($startTime, $range);
-//        $redis->zRemRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime);
+        $redis->zRem(Producer::CRONTAB_KEY, ...$range);
 
         return [$range, $redis];
     }