72 lines
2.3 KiB
PHP
72 lines
2.3 KiB
PHP
<?php
|
|
|
|
namespace app\common\command\live;
|
|
|
|
use think\console\Command;
|
|
use think\console\Input;
|
|
use think\console\Output;
|
|
use app\common\library\live\message\Manager;
|
|
|
|
/**
|
|
* 清理已删除课程对应的阿里云互动消息群组
|
|
*
|
|
* 用法：
|
|
* php think live:cleanup-group 执行清理
|
|
* php think live:cleanup-group --dry-run 仅预览，不实际删除
|
|
* php think live:cleanup-group --batch-size=100 指定批次大小
|
|
*
|
|
* 建议通过系统 crontab 每天执行一次：
|
|
* 0 3 * * * cd /path/to/project && php think live:cleanup-group >> /var/log/live-group-cleanup.log 2>&1
|
|
*/
|
|
class CleanupMessageGroup extends Command
|
|
{
|
|
protected function configure()
|
|
{
|
|
$this->setName('live:cleanup-group')
|
|
->setDescription('清理已删除课程对应的阿里云互动消息群组');
|
|
}
|
|
|
|
protected function execute(Input $input, Output $output)
|
|
{
|
|
$dryRun = $input->hasOption('dry-run');
|
|
$batchSize = 50;
|
|
|
|
// 解析 --batch-size
|
|
$options = $input->getOptions();
|
|
if (isset($options['batch-size']) && (int)$options['batch-size'] > 0) {
|
|
$batchSize = (int)$options['batch-size'];
|
|
}
|
|
|
|
$output->writeln($dryRun ? '[DRY-RUN] 预览模式，不实际删除' : '开始清理阿里云互动消息群组...');
|
|
$output->writeln('批次大小: ' . $batchSize);
|
|
|
|
$result = Manager::cleanupOrphanGroups($batchSize, $dryRun);
|
|
|
|
if (isset($result['msg'])) {
|
|
$output->writeln($result['msg']);
|
|
return;
|
|
}
|
|
|
|
if (empty($result['items'])) {
|
|
$output->writeln('没有需要清理的群组');
|
|
return;
|
|
}
|
|
|
|
foreach ($result['items'] as $item) {
|
|
$label = $dryRun ? 'PREVIEW' : strtoupper($item['action']);
|
|
$line = sprintf('[%s] room_id=%s course_id=%s group_id=%s', $label, $item['room_id'], $item['course_id'], $item['group_id']);
|
|
if (isset($item['error'])) {
|
|
$line .= ' error=' . $item['error'];
|
|
}
|
|
$output->writeln($line);
|
|
}
|
|
|
|
$output->writeln(sprintf(
|
|
'完成：删除 %d，失败 %d，跳过 %d',
|
|
$result['deleted'],
|
|
$result['failed'],
|
|
$result['skipped']
|
|
));
|
|
}
|
|
}
|