CFDivePlatform/app/Http/Controllers/API/ReviewController.php

<?php

namespace App\Http\Controllers\API;

use App\Enums\BookingStatus;
use App\Http\Controllers\Controller;
use App\Models\Booking;
use App\Models\DivingOffer;
use App\Models\Review;
use App\Models\ReviewEdit;
use App\Models\ReviewVote;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;

class ReviewController extends Controller
{
    // ── 公開列表 ──────────────────────────────────────────────

    public function publicList(Request $request, int $offerId)
    {
        $offer = DivingOffer::findOrFail($offerId);
        $user  = $request->user();

        $sort = $request->query('sort', 'helpful');
        $query = Review::where('diving_offer_id', $offer->id);

        match ($sort) {
            'rating'  => $query->orderByDesc('rating')->orderByDesc('created_at'),
            'newest'  => $query->orderByDesc('created_at'),
            default   => $query->orderByDesc('helpful_count')->orderByDesc('created_at'),
        };

        $reviews = $query->get();

        // 批次查詢 has_voted
        $votedIds = $user
            ? ReviewVote::where('member_id', $user->id)
                ->whereIn('review_id', $reviews->pluck('id'))
                ->pluck('review_id')
                ->flip()
            : collect();

        // summary
        $distRaw = Review::where('diving_offer_id', $offer->id)
            ->selectRaw('rating, COUNT(*) as cnt')
            ->groupBy('rating')
            ->pluck('cnt', 'rating');
        $distribution = collect([1 => 0, 2 => 0, 3 => 0, 4 => 0, 5 => 0])->merge($distRaw);

        $total   = $reviews->count();
        $average = $total > 0 ? round($reviews->avg('rating'), 1) : 0;

        $formatted = $reviews->map(function ($r) use ($user, $votedIds) {
            $item = [
                'id'            => $r->id,
                'reviewer_name' => '匿名潛水者',
                'rating'        => $r->rating,
                'comment'       => $r->comment,
                'helpful_count' => $r->helpful_count,
                'is_edited'     => $r->is_edited,
                'created_at'    => $r->created_at?->toISOString(),
                'has_voted'     => $votedIds->has($r->id),
            ];
            if ($user) {
                $item['is_mine'] = $r->member_id === $user->id;
            }
            return $item;
        });

        return response()->json([
            'status' => true,
            'data'   => [
                'summary' => [
                    'average'      => $average,
                    'total'        => $total,
                    'distribution' => $distribution,
                ],
                'reviews' => $formatted,
            ],
        ]);
    }

    // ── Member CRUD ───────────────────────────────────────────

    public function store(Request $request)
    {
        $data = $request->validate([
            'diving_offer_id' => 'required|integer|exists:diving_offers,id',
            'rating'          => 'required|integer|min:1|max:5',
            'comment'         => 'required|string|min:1',
        ]);

        $memberId = $request->user()->id;
        $offerId  = $data['diving_offer_id'];

        // 資格驗證：有 completed booking
        $eligible = Booking::where('member_id', $memberId)
            ->whereHas('schedule', fn($q) => $q->where('diving_offer_id', $offerId))
            ->where('status', BookingStatus::Completed->value)
            ->exists();

        if (!$eligible) {
            return response()->json(['status' => false, 'message' => '須完成此課程後才能評價'], 403);
        }

        // 重複評價檢查
        if (Review::where('member_id', $memberId)->where('diving_offer_id', $offerId)->exists()) {
            return response()->json(['status' => false, 'message' => '已評價，如需修改請使用編輯功能'], 422);
        }

        $review = DB::transaction(function () use ($data, $memberId, $offerId) {
            $review = Review::create([
                'diving_offer_id' => $offerId,
                'member_id'       => $memberId,
                'rating'          => $data['rating'],
                'comment'         => $data['comment'],
            ]);
            $this->recalculateOfferRating($offerId);
            return $review;
        });

        return response()->json(['status' => true, 'message' => '評價已送出', 'data' => $this->formatReview($review)], 201);
    }

    public function update(Request $request, int $id)
    {
        $review = Review::findOrFail($id);
        if ($review->member_id !== $request->user()->id) {
            return response()->json(['status' => false, 'message' => '無權修改此評價'], 403);
        }

        $data = $request->validate([
            'rating'  => 'sometimes|integer|min:1|max:5',
            'comment' => 'sometimes|string|min:1',
        ]);

        DB::transaction(function () use ($review, $data) {
            ReviewEdit::updateOrCreate(
                ['review_id' => $review->id],
                ['old_rating' => $review->rating, 'old_comment' => $review->comment, 'edited_at' => now()]
            );
            $review->update(array_merge($data, ['is_edited' => true]));
            $this->recalculateOfferRating($review->diving_offer_id);
        });

        return response()->json(['status' => true, 'message' => '評價已更新', 'data' => $this->formatReview($review->fresh())]);
    }

    public function destroy(Request $request, int $id)
    {
        $review = Review::findOrFail($id);
        if ($review->member_id !== $request->user()->id) {
            return response()->json(['status' => false, 'message' => '無權刪除此評價'], 403);
        }

        $offerId = $review->diving_offer_id;
        DB::transaction(function () use ($review, $offerId) {
            $review->delete();
            $this->recalculateOfferRating($offerId);
        });

        return response()->json(['status' => true, 'message' => '評價已刪除']);
    }

    // ── 有幫助投票 ────────────────────────────────────────────

    public function toggleHelpful(Request $request, int $id)
    {
        if (!$request->user()->isMember()) {
            return response()->json(['status' => false, 'message' => '只有會員可以投票'], 403);
        }

        $review = Review::findOrFail($id);
        $memberId = $request->user()->id;

        if ($review->member_id === $memberId) {
            return response()->json(['status' => false, 'message' => '不可對自己的評價投票'], 422);
        }

        DB::transaction(function () use ($review, $memberId) {
            $vote = ReviewVote::where('review_id', $review->id)
                ->where('member_id', $memberId)
                ->first();

            if ($vote) {
                $vote->delete();
                DB::table('reviews')
                    ->where('id', $review->id)
                    ->where('helpful_count', '>', 0)
                    ->decrement('helpful_count');
            } else {
                ReviewVote::create(['review_id' => $review->id, 'member_id' => $memberId, 'created_at' => now()]);
                $review->increment('helpful_count');
            }
        });

        $review->refresh();
        $hasVoted = ReviewVote::where('review_id', $review->id)->where('member_id', $memberId)->exists();

        return response()->json(['status' => true, 'data' => ['helpful_count' => $review->helpful_count, 'has_voted' => $hasVoted]]);
    }

    // ── 私有方法 ──────────────────────────────────────────────

    private function recalculateOfferRating(int $offerId): void
    {
        $stats = Review::where('diving_offer_id', $offerId)
            ->selectRaw('ROUND(AVG(rating), 1) as avg_rating, COUNT(*) as total')
            ->first();

        DivingOffer::where('id', $offerId)->update([
            'rating'  => $stats->total > 0 ? $stats->avg_rating : 0,
            'reviews' => $stats->total,
        ]);
    }

    private function formatReview(Review $r): array
    {
        return [
            'id'            => $r->id,
            'reviewer_name' => '匿名潛水者',
            'rating'        => $r->rating,
            'comment'       => $r->comment,
            'helpful_count' => $r->helpful_count,
            'is_edited'     => $r->is_edited,
            'created_at'    => $r->created_at?->toISOString(),
        ];
    }
}