as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2021-04-28 11:51:57 +08:00
parent 2833d41bd8
commit b690158a58
1 changed files with 14 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
HttpServer/Events/OnPipeMessage.php
+14 -16
View File
@@ -48,23 +48,21 @@ class OnPipeMessage extends Callback
} }
/** @var Crontab $handler */ /** @var Crontab $handler */
$handler = swoole_unserialize($message['handler']); $handler = swoole_unserialize($message['handler']);
defer(function () use ($handler) {
if ($handler->isRecover() !== 999) {
return;
}
$redis = Snowflake::app()->getRedis();
$name = $handler->getName();
if (!$redis->exists('stop:crontab:' . $name)) {
$redis->set('crontab:' . $name, swoole_serialize($handler));
$tickTime = time() + $handler->getTickTime();
$redis->zAdd(Producer::CRONTAB_KEY, $tickTime, $name);
} else {
$redis->del('crontab:' . $name);
$redis->del('stop:crontab:' . $name);
}
});
$handler->increment()->execute(); $handler->increment()->execute();
if ($handler->isRecover() !== 999) {
return 'success';
}
$redis = Snowflake::app()->getRedis();
$name = $handler->getName();
if (!$redis->exists('stop:crontab:' . $name)) {
$redis->set('crontab:' . $name, swoole_serialize($handler));
$tickTime = time() + $handler->getTickTime();
$redis->zAdd(Producer::CRONTAB_KEY, $tickTime, $name);
} else {
$redis->del('crontab:' . $name);
$redis->del('stop:crontab:' . $name);
}
return 'success'; return 'success';
} }