setName('split:sync-tickets')
->addOption('ticket', 't', Option::VALUE_OPTIONAL, '指定工单 ID(强制同步,忽略周期)', '')
->setDescription('同步分流工单云控数据');
}
protected function execute(Input $input, Output $output): void
{
set_time_limit(0);
SplitTicketSyncLogger::log('cli', 'command start', [
'ticketOption' => trim((string) $input->getOption('ticket')),
'appDebug' => SplitTicketSyncLogger::isEnabled(),
]);
$service = new SplitTicketSyncService();
$ticketId = trim((string) $input->getOption('ticket'));
if ($ticketId !== '' && ctype_digit($ticketId)) {
$result = $service->syncOne((int) $ticketId, true);
if (!empty($result['skipped'])) {
$output->writeln('跳过: ' . ($result['message'] ?? '') . '');
return;
}
if ($result['success']) {
$output->writeln('工单 #' . $ticketId . ' 同步成功');
} else {
$output->writeln('工单 #' . $ticketId . ' 同步失败: ' . ($result['message'] ?? '') . '');
}
return;
}
$count = $service->syncDueTickets();
$output->writeln('本次处理工单数: ' . $count . '');
if (SplitTicketSyncLogger::isEnabled()) {
$output->writeln('调试日志已写入 runtime/log/split_sync.log');
}
}
}