52 lines
1.9 KiB
PHP
52 lines
1.9 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace app\common\command;
|
|
|
|
use app\adminapi\logic\tcm\DiagnosisLogic;
|
|
use think\console\Command;
|
|
use think\console\Input;
|
|
use think\console\input\Option;
|
|
use think\console\Output;
|
|
use think\facade\Log;
|
|
|
|
/**
|
|
* 从腾讯云 IM 拉取诊单单聊漫游消息并写入本地归档表（建议 cron 每几小时执行）
|
|
*/
|
|
class SyncImChatArchive extends Command
|
|
{
|
|
protected function configure()
|
|
{
|
|
$this->setName('sync_im_chat_archive')
|
|
->setDescription('同步诊单腾讯云 IM 聊天记录到数据库归档')
|
|
->addOption('since-days', null, Option::VALUE_OPTIONAL, '仅处理最近 N 天内更新过的诊单；0 表示不限制', '7')
|
|
->addOption('limit', 'l', Option::VALUE_OPTIONAL, '本轮最多处理的诊单数量（1-500）', '50')
|
|
->addOption('diagnosis-id', null, Option::VALUE_OPTIONAL, '只同步指定诊单 ID，设置后忽略 since-days', '0');
|
|
}
|
|
|
|
protected function execute(Input $input, Output $output)
|
|
{
|
|
$sinceDays = (int)$input->getOption('since-days');
|
|
$sinceDays = max(0, $sinceDays);
|
|
$limit = (int)$input->getOption('limit');
|
|
$onlyId = (int)$input->getOption('diagnosis-id');
|
|
$only = $onlyId > 0 ? $onlyId : null;
|
|
|
|
if ($only !== null) {
|
|
$output->writeln("同步诊单 ID={$only} ...");
|
|
} else {
|
|
$output->writeln('同步 IM 归档：since-days=' . ($sinceDays > 0 ? $sinceDays : '不限制') . ", limit={$limit}");
|
|
}
|
|
|
|
$stats = DiagnosisLogic::syncImChatArchiveBatch($sinceDays, $limit, $only);
|
|
$output->writeln("处理诊单数: {$stats['diagnoses']}，新插入行数(INSERT IGNORE 成功数): {$stats['inserted']}");
|
|
if (!empty($stats['errors'])) {
|
|
foreach ($stats['errors'] as $e) {
|
|
$output->writeln("<error>{$e}</error>");
|
|
Log::error('sync_im_chat_archive: ' . $e);
|
|
}
|
|
}
|
|
}
|
|
}
|