改名
This commit is contained in:
@@ -28,7 +28,6 @@ class Producer extends Component
|
|||||||
$redis = Snowflake::app()->getRedis();
|
$redis = Snowflake::app()->getRedis();
|
||||||
|
|
||||||
$name = $crontab->getName();
|
$name = $crontab->getName();
|
||||||
|
|
||||||
if (
|
if (
|
||||||
$redis->exists(self::CRONTAB_KEY) &&
|
$redis->exists(self::CRONTAB_KEY) &&
|
||||||
$redis->type(self::CRONTAB_KEY) !== \Redis::REDIS_ZSET) {
|
$redis->type(self::CRONTAB_KEY) !== \Redis::REDIS_ZSET) {
|
||||||
@@ -37,6 +36,8 @@ class Producer extends Component
|
|||||||
|
|
||||||
$tickTime = time() + $crontab->getTickTime();
|
$tickTime = time() + $crontab->getTickTime();
|
||||||
|
|
||||||
|
$redis->del('stop:crontab:' . $name, 120);
|
||||||
|
|
||||||
$result = $redis->zAdd(self::CRONTAB_KEY, $tickTime, $name);
|
$result = $redis->zAdd(self::CRONTAB_KEY, $tickTime, $name);
|
||||||
if ($result) {
|
if ($result) {
|
||||||
$redis->set('crontab:' . $name, swoole_serialize($crontab));
|
$redis->set('crontab:' . $name, swoole_serialize($crontab));
|
||||||
|
|||||||
Reference in New Issue
Block a user