diff --git a/System/Crontab/Producer.php b/System/Crontab/Producer.php index a501afc1..20aa1eec 100644 --- a/System/Crontab/Producer.php +++ b/System/Crontab/Producer.php @@ -28,7 +28,6 @@ class Producer extends Component $redis = Snowflake::app()->getRedis(); $name = $crontab->getName(); - if ( $redis->exists(self::CRONTAB_KEY) && $redis->type(self::CRONTAB_KEY) !== \Redis::REDIS_ZSET) { @@ -37,6 +36,8 @@ class Producer extends Component $tickTime = time() + $crontab->getTickTime(); + $redis->del('stop:crontab:' . $name, 120); + $result = $redis->zAdd(self::CRONTAB_KEY, $tickTime, $name); if ($result) { $redis->set('crontab:' . $name, swoole_serialize($crontab));