kknongchang_2506/app/Module/Mex/Commands/MexMatchCommand.php

<?php

namespace App\Module\Mex\Commands;

use App\Module\Mex\Services\MexMatchService;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\Log;

/**
 * 农贸市场撮合计划任务
 * 
 * 定时执行撮合任务，处理待撮合的买入订单
 */
class MexMatchCommand extends Command
{
    /**
     * 命令签名
     *
     * @var string
     */
    protected $signature = 'mex:match 
                            {--item= : 指定商品ID，不指定则处理所有商品}
                            {--batch=100 : 批处理大小，默认100}
                            {--dry-run : 试运行模式，不执行实际撮合}';

    /**
     * 命令描述
     *
     * @var string
     */
    protected $description = '执行农贸市场撮合任务';

    /**
     * 执行命令
     *
     * @return int
     */
    public function handle(): int
    {
        $startTime = microtime(true);
        
        $this->info('开始执行农贸市场撮合任务...');
        
        // 获取命令参数
        $itemId = $this->option('item') ? (int)$this->option('item') : null;
        $batchSize = (int)$this->option('batch');
        $dryRun = $this->option('dry-run');
        
        if ($dryRun) {
            $this->warn('试运行模式：不会执行实际的撮合操作');
            return $this->handleDryRun($itemId, $batchSize);
        }
        
        try {
            // 显示撮合前统计
            $this->showPreMatchStats();
            
            // 执行撮合
            $result = MexMatchService::executeMatch($itemId, $batchSize);
            
            // 显示撮合结果
            $this->showMatchResult($result);
            
            // 显示撮合后统计
            $this->showPostMatchStats();
            
            $endTime = microtime(true);
            $totalTime = round(($endTime - $startTime) * 1000, 2);
            
            $this->info("撮合任务执行完成，总耗时: {$totalTime}ms");
            
            return $result['success'] ? Command::SUCCESS : Command::FAILURE;
            
        } catch (\Exception $e) {
            $this->error('撮合任务执行失败: ' . $e->getMessage());
            Log::error('MexMatchCommand执行失败', [
                'error' => $e->getMessage(),
                'trace' => $e->getTraceAsString(),
            ]);
            
            return Command::FAILURE;
        }
    }
    
    /**
     * 处理试运行模式
     *
     * @param int|null $itemId
     * @param int $batchSize
     * @return int
     */
    private function handleDryRun(?int $itemId, int $batchSize): int
    {
        $this->info('=== 试运行模式 ===');
        
        // 显示当前统计
        $stats = MexMatchService::getMatchStats();
        
        $this->table([
            '待撮合订单数',
            '涉及商品数',
            '待撮合数量',
            '待撮合金额',
            '有库存商品数'
        ], [[
            $stats['pending_orders'],
            $stats['pending_items'],
            $stats['pending_quantity'],
            $stats['pending_amount'],
            $stats['available_items']
        ]]);
        
        if ($itemId) {
            $this->info("指定处理商品ID: {$itemId}");
            $conditionCheck = MexMatchService::checkMatchConditions($itemId);
            
            if ($conditionCheck['can_match']) {
                $this->info("✓ 商品 {$itemId} 满足撮合条件");
                $this->info("  - 待撮合订单: {$conditionCheck['pending_orders']} 个");
            } else {
                $this->warn("✗ 商品 {$itemId} 不满足撮合条件: {$conditionCheck['message']}");
            }
        } else {
            $this->info('将处理所有符合条件的商品');
        }
        
        $this->info("批处理大小: {$batchSize}");
        $this->info('试运行完成，未执行实际撮合操作');
        
        return Command::SUCCESS;
    }
    
    /**
     * 显示撮合前统计
     */
    private function showPreMatchStats(): void
    {
        $this->info('=== 撮合前统计 ===');
        
        $stats = MexMatchService::getMatchStats();
        
        $this->table([
            '待撮合订单数',
            '涉及商品数',
            '待撮合数量',
            '待撮合金额',
            '有库存商品数'
        ], [[
            $stats['pending_orders'],
            $stats['pending_items'],
            $stats['pending_quantity'],
            $stats['pending_amount'],
            $stats['available_items']
        ]]);
    }
    
    /**
     * 显示撮合结果
     *
     * @param array $result
     */
    private function showMatchResult(array $result): void
    {
        $this->info('=== 撮合结果 ===');
        
        if ($result['success']) {
            $this->info("✓ 撮合成功");
            $this->info("  - 处理商品: " . count($result['processed_items']) . " 个");
            $this->info("  - 撮合订单: {$result['total_matched']} 个");
            $this->info("  - 成交金额: {$result['total_amount']}");
            $this->info("  - 执行时间: {$result['execution_time_ms']}ms");
            
            if (!empty($result['processed_items'])) {
                $this->info("  - 处理的商品ID: " . implode(', ', $result['processed_items']));
            }
            
            if (!empty($result['errors'])) {
                $this->warn('部分商品处理出现错误:');
                foreach ($result['errors'] as $error) {
                    $this->warn("  - {$error}");
                }
            }
        } else {
            $this->error("✗ 撮合失败: {$result['message']}");
        }
    }
    
    /**
     * 显示撮合后统计
     */
    private function showPostMatchStats(): void
    {
        $this->info('=== 撮合后统计 ===');
        
        $stats = MexMatchService::getMatchStats();
        
        $this->table([
            '剩余待撮合订单',
            '今日撮合订单',
            '今日成交数量',
            '今日成交金额'
        ], [[
            $stats['pending_orders'],
            $stats['today_matched'],
            $stats['today_quantity'],
            $stats['today_amount']
        ]]);
    }
}