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

modify

Browse Source
This commit is contained in:
as2252258@163.com
2021-04-16 00:47:13 +08:00
parent de17f5d4a7
commit ecf6428833
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Crontab/Producer.php
+1 -1
View File
@@ -37,7 +37,7 @@ class Producer extends Component
$tickTime = time() + $crontab->getTickTime();
$redis->del('stop:crontab:' . $name, 120);
$result = $redis->zAdd(self::CRONTAB_KEY, $tickTime, $name);
$result = $redis->zAdd(self::CRONTAB_KEY, 0, $tickTime, $name);
var_dump($redis->zCard(self::CRONTAB_KEY));
if ($result) {
$redis->set('crontab:' . $name, swoole_serialize($crontab));
System/Crontab/Zookeeper.php
+1 -1
View File
@@ -90,7 +90,7 @@ class Zookeeper extends Process
$startTime = time();
$range = $redis->zRemRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime);
$range = $redis->zRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime);
var_dump($startTime, $range);
// $redis->zRemRangeByScore(Producer::CRONTAB_KEY, '0', (string)$startTime);