改名
This commit is contained in:
+1
-1
@@ -35,7 +35,7 @@ class Crontab extends Component
|
||||
|
||||
$crontab = ['isLoop' => $isLoop, 'handler' => $handler, 'tick' => $tickTime, 'params' => $params];
|
||||
|
||||
$redis->zAdd('system:crontab', $executeTime, serialize($crontab));
|
||||
$redis->zAdd('system:crontab', (string)$executeTime, serialize($crontab));
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -73,8 +73,9 @@ class CrontabProcess extends Process
|
||||
$score = time();
|
||||
$redis = Snowflake::app()->getRedis();
|
||||
|
||||
$lists = $redis->zRangeByScore('system:crontab', (string)$score, (string)$score);
|
||||
$redis->zRemRangeByScore('system:crontab', (string)$score, (string)$score);
|
||||
$lists = $redis->zRangeByScore('system:crontab', '0', (string)$score);
|
||||
var_dump($lists);
|
||||
$redis->zRemRangeByScore('system:crontab', '0', (string)$score);
|
||||
|
||||
$barrier = Barrier::make();
|
||||
foreach ($lists as $list) {
|
||||
|
||||
Reference in New Issue
Block a user