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-14 15:07:04 +08:00
parent e142226d8d
commit 9f2e017871
1 changed files with 38 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Crontab/Producer.php
+8 -5
View File
@@ -4,9 +4,9 @@
namespace Snowflake\Crontab; namespace Snowflake\Crontab;
use Exception;
use Snowflake\Abstracts\Component; use Snowflake\Abstracts\Component;
use Snowflake\Snowflake; use Snowflake\Snowflake;
use Exception;
/** /**
@@ -16,7 +16,7 @@ use Exception;
class Producer extends Component class Producer extends Component
{ {
const CRONTAB_KEY = 'system:crontab'; const CRONTAB_KEY = '_application:system:crontab';
/** /**
@@ -28,14 +28,17 @@ class Producer extends Component
$redis = Snowflake::app()->getRedis(); $redis = Snowflake::app()->getRedis();
$name = $crontab->getName(); $name = $crontab->getName();
var_dump($name);
$redis->set('crontab:' . $name, swoole_serialize($crontab)); if ($redis->type(self::CRONTAB_KEY) !== \Redis::REDIS_ZSET) {
throw new Exception('Cache key ' . self::CRONTAB_KEY . ' types error.');
}
$tickTime = time() + $crontab->getTickTime(); $tickTime = time() + $crontab->getTickTime();
$result = $redis->zAdd(self::CRONTAB_KEY, $tickTime, $name); $result = $redis->zAdd(self::CRONTAB_KEY, $tickTime, $name);
var_dump($result, $crontab); if ($result) {
$redis->set('crontab:' . $name, swoole_serialize($crontab));
}
} }