setName('traffic_pool:rfm-daily') ->setDescription('流量池每日 RFM 重算与画像叠加(不扣算力)') ->addOption('companyId', null, Option::VALUE_OPTIONAL, '公司 ID,0=全部', 0) ->addOption('limit', null, Option::VALUE_OPTIONAL, '每公司最多处理条数,0=全量', 0); } protected function execute(Input $input, Output $output) { $companyId = max(0, (int)$input->getOption('companyId')); $limit = max(0, (int)$input->getOption('limit')); $stats = TrafficPoolDailyRfmService::run($companyId, $limit); $output->writeln(sprintf( 'traffic_pool:rfm-daily done companyId=%d processed=%d updated=%d skipped=%d', $companyId, $stats['processed'], $stats['updated'], $stats['skipped'] )); return 0; } }