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("{$e}"); Log::error('sync_im_chat_archive: ' . $e); } } } }