modify

System/Crontab/Crontab.php

@@ -203,11 +203,11 @@ class Crontab extends BaseObject
     {
         $redis = Snowflake::app()->getRedis();
 
-        $redis->set('crontab:' . md5($this->getName()), swoole_serialize($this));
+        $redis->set('crontab:' . ($name = md5($this->getName())), swoole_serialize($this));
 
         $tickTime = time() + $this->getTickTime();
 
-        $redis->zAdd(Producer::CRONTAB_KEY, $tickTime, $this->getName());
+        $redis->zAdd(Producer::CRONTAB_KEY, $tickTime, $name);
     }
 
 

System/Crontab/Producer.php

@@ -33,7 +33,7 @@ class Producer extends Component
 
         $tickTime = time() + $crontab->getTickTime();
 
-        $redis->zAdd(self::CRONTAB_KEY, $tickTime, $crontab->getName());
+        $redis->zAdd(self::CRONTAB_KEY, $tickTime, $name);
     }
 
 
@@ -59,7 +59,7 @@ class Producer extends Component
         $data = $redis->zRange(self::CRONTAB_KEY, 0, -1);
         $redis->del(self::CRONTAB_KEY);
         foreach ($data as $datum) {
-            $redis->del('crontab:' . md5($datum));
+            $redis->del('crontab:' . $datum);
         }
         $redis->release();
     }

System/Crontab/Zookeeper.php

@@ -62,9 +62,9 @@ class Zookeeper extends Process
     private function dispatch($server, $redis, $setting, $value)
     {
         $server->sendMessage(swoole_serialize([
-            'action' => 'crontab', 'handler' => swoole_unserialize($redis->get('crontab:' . md5($value)))
+            'action' => 'crontab', 'handler' => swoole_unserialize($redis->get('crontab:' . $value))
         ]), random_int(0, $setting - 1));
-        $redis->del('crontab:' . md5($value));
+        $redis->del('crontab:' . $value);
     }