From 175a5d5ec957c4ce860bc833455fa5b21834506f Mon Sep 17 00:00:00 2001
From: "as2252258@163.com" <as22522582>
Date: Fri, 16 Apr 2021 01:07:19 +0800
Subject: [PATCH] modify

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

diff --git a/System/Crontab/Producer.php b/System/Crontab/Producer.php
index a69e5128..568622c7 100644
--- a/System/Crontab/Producer.php
+++ b/System/Crontab/Producer.php
@@ -32,11 +32,8 @@ class Producer extends Component
             throw new Exception('Cache key ' . self::CRONTAB_KEY . ' types error.');
         }
 
-        $redis->setex('stop:crontab:' . $name, 120, 1);
+        $redis->del('crontab:' . $name);
         $redis->zRem(static::CRONTAB_KEY, $name);
-        if ($redis->exists('crontab:' . $name)) {
-            $redis->del('crontab:' . $name);
-        }
 
         $redis->zAdd(self::CRONTAB_KEY, time() + $crontab->getTickTime(), $name);
         $redis->set('crontab:' . $name, swoole_serialize($crontab));
diff --git a/System/Crontab/Zookeeper.php b/System/Crontab/Zookeeper.php
index 9ce4db39..af075ee5 100644
--- a/System/Crontab/Zookeeper.php
+++ b/System/Crontab/Zookeeper.php
@@ -64,7 +64,10 @@ class Zookeeper extends Process
     {
         try {
             $params['action'] = 'crontab';
-            $params['handler'] = swoole_unserialize($redis->get('crontab:' . $value));
+            if (($handler = $redis->exists('crontab:' . $value)) === false) {
+                return;
+            }
+            $params['handler'] = swoole_unserialize($handler);
 
             $result = $server->sendMessage($params, $workerId = random_int(0, $setting - 1));