math_cms/app/Filament/Pages/OCRRecordView.php

<?php

namespace App\Filament\Pages;

use App\Models\OCRRecord;
use App\Models\OCRQuestionResult;
use App\Jobs\ProcessOCRRecord;
use Filament\Notifications\Notification;
use Filament\Pages\Page;
use Livewire\Attributes\Computed;

class OCRRecordView extends Page
{
    protected static ?string $title = 'OCR记录详情';
    protected static ?string $slug = 'ocr-record-view/{recordId}';
    protected string $view = 'filament.pages.ocr-record-view-new';

    public static function shouldRegisterNavigation(): bool
    {
        return false;
    }

    public string $recordId = '';
    public array $manualAnswers = [];
    public bool $hasAnalysisResults = false;
    
    // 新增：判卷相关
    public array $questionGrades = []; // 存储每道题的评分 [question_id => ['score' => x, 'is_correct' => true/false]]

    #[Computed]
    public function record(): ?OCRRecord
    {
        return OCRRecord::with(['student', 'questions'])->find($this->recordId);
    }

    public function mount(string $recordId): void
    {
        $this->recordId = $recordId;
        $record = $this->record();
        
        if ($record) {
            // Fix stuck processing status: if status is processing but we have questions, it's actually completed
            if ($record->status === 'processing' && $record->questions()->count() > 0) {
                $record->update([
                    'status' => 'completed',
                    'processed_at' => $record->processed_at ?? now(),
                    'total_questions' => $record->questions()->count(),
                    'processed_questions' => $record->questions()->count(),
                ]);
                // Refresh record to get updated status
                $record = $this->record();
            }

            foreach ($record->questions as $question) {
                if ($question->manual_answer) {
                    $this->manualAnswers[$question->id] = $question->manual_answer;
                }
                
                // 加载已有的评分
                if ($question->ai_score !== null || $question->score_value !== null) {
                    $this->questionGrades[$question->id] = [
                        'score' => $question->ai_score ?? $question->score_value,
                        'is_correct' => $question->is_correct,
                    ];
                }
            }

            // 检查是否已有AI分析结果
            $this->checkAnalysisResults($record);
        }
    }

    /**
     * Check if record already has AI analysis results
     */
    private function checkAnalysisResults(OCRRecord $record): void
    {
        // Only consider analyzed if ai_analyzed_at is set AND we have scores
        $this->hasAnalysisResults = $record->ai_analyzed_at && $record->questions()
            ->whereNotNull('ai_score')
            ->exists();
    }

    /**
     * Submit all questions for AI analysis.
     * Updates manual answers in batch, then sends data to LearningAnalytics using unified interface.
     */
    public function submitForAnalysis(): void
    {
        $record = $this->record();
        if (! $record) {
            Notification::make()
                ->title('记录不存在')
                ->danger()
                ->send();
            return;
        }

        $updatedCount = 0;
        foreach ($record->questions as $question) {
            $manualAnswer = $this->manualAnswers[$question->id] ?? null;
            if ($manualAnswer && trim($manualAnswer) !== '') {
                $question->update([
                    'manual_answer'   => trim($manualAnswer),
                    'answer_verified' => true,
                ]);
                $updatedCount++;
            }
        }

        // 使用统一接口提交分析
        try {
            $learningService = app(\App\Services\LearningAnalyticsService::class);

            // 准备答题数据（与系统卷子格式一致）
            $answers = [];
            foreach ($record->questions as $question) {
                // 使用校准后的答案（manual_answer），如果没有则使用OCR识别的答案
                $studentAnswer = !empty(trim($question->manual_answer ?? ''))
                    ? trim($question->manual_answer)
                    : trim($question->student_answer ?? '');

                $answers[] = [
                    'question_bank_id' => 'ocr_q' . $question->question_number,
                    'question_text' => $question->question_text ?? '',
                    'student_answer' => $studentAnswer,
                    'is_correct' => null,  // 让AI判断
                    'score' => null,
                    'max_score' => $question->score_total ?? null,
                    'kp_code' => $question->kp_code ?? null,
                ];
            }

            // 提交到统一接口
            $submissionData = [
                'paper_id' => 'ocr_' . $record->id,
                'answers' => $answers,
            ];

            \Log::info('OCRRecordView提交分析（统一接口）', [
                'record_id' => $record->id,
                'student_id' => $record->student_id,
                'question_count' => count($answers)
            ]);

            $response = $learningService->submitBatchAttempts($record->student_id, $submissionData);

            if (!empty($response) && !isset($response['error'])) {
                // 从响应中获取analysis_id
                $analysisId = $response['analysis_id'] ?? $response['data']['analysis_id'] ?? ('batch_' . $record->id . '_' . time());

                // 更新OCR记录的analysis_id和状态
                $record->update([
                    'analysis_id' => $analysisId,
                    'ai_analyzed_at' => now(),
                    'ai_analysis_count' => count($answers),
                ]);

                \Log::info('OCR分析提交成功', [
                    'record_id' => $record->id,
                    'analysis_id' => $analysisId
                ]);

                // 重新检查分析结果状态
                $this->checkAnalysisResults($record);

                Notification::make()
                    ->title('分析完成')
                    ->body("已更新 {$updatedCount} 道题的答案，已提交 " . count($answers) . " 道题目进行AI分析")
                    ->success()
                    ->send();

                // 跳转到分析页面
                $this->redirect("/admin/exam-analysis?recordId={$record->id}");
            } else {
                \Log::error('OCR分析提交失败', [
                    'record_id' => $record->id,
                    'response' => $response
                ]);

                Notification::make()
                    ->title('分析失败')
                    ->body('提交AI分析失败：' . ($response['message'] ?? '未知错误'))
                    ->danger()
                    ->send();
            }
        } catch (\Exception $e) {
            \Log::error('提交OCR分析异常', [
                'record_id' => $record->id,
                'error' => $e->getMessage(),
                'trace' => $e->getTraceAsString()
            ]);

            Notification::make()
                ->title('分析失败')
                ->body('提交分析时发生异常：' . $e->getMessage())
                ->danger()
                ->send();
        }
    }

    public function startRecognition(): void
    {
        $record = $this->record();
        if (! $record) {
            Notification::make()
                ->title('记录不存在')
                ->danger()
                ->send();
            return;
        }

        if ($record->status === 'processing') {
            Notification::make()
                ->title('正在处理中')
                ->warning()
                ->send();
            return;
        }

        ProcessOCRRecord::dispatch($record);
        $record->update(['status' => 'processing']);

        Notification::make()
            ->title('开始识别')
            ->body('OCR识别任务已启动，请稍后刷新查看结果')
            ->success()
            ->send();
    }
    
    public function getStatusBadgeConfig(string $status): array
    {
        return match ($status) {
            'pending'    => ['class' => 'badge-warning', 'text' => '待处理'],
            'processing' => ['class' => 'badge-info',    'text' => '处理中'],
            'completed'  => ['class' => 'badge-success', 'text' => '已完成'],
            'failed'     => ['class' => 'badge-error',   'text' => '失败'],
            default      => ['class' => 'badge-ghost',   'text' => $status],
        };
    }
}