import { NextRequest, NextResponse } from 'next/server';
import { verifyAdminToken, unauthorizedResponse } from '@/lib/admin-auth';
import { prisma } from '@/lib/db';
import { getGroup } from '@/lib/sub2api/client';

export async function GET(request: NextRequest) {
  if (!(await verifyAdminToken(request))) return unauthorizedResponse(request);

  try {
    const plans = await prisma.subscriptionPlan.findMany({
      orderBy: { sortOrder: 'asc' },
    });

    // 并发检查每个套餐对应的 Sub2API 分组是否仍然存在，并获取分组名称
    const results = await Promise.all(
      plans.map(async (plan) => {
        let groupExists = false;
        let groupName: string | null = null;
        let group: Awaited<ReturnType<typeof getGroup>> | null = null;
        try {
          group = await getGroup(plan.groupId);
          groupExists = group !== null;
          groupName = group?.name ?? null;
        } catch {
          groupExists = false;
        }
        return {
          id: plan.id,
          groupId: String(plan.groupId),
          groupName,
          name: plan.name,
          description: plan.description,
          price: Number(plan.price),
          originalPrice: plan.originalPrice ? Number(plan.originalPrice) : null,
          validDays: plan.validityDays,
          validityUnit: plan.validityUnit,
          features: plan.features ? JSON.parse(plan.features) : [],
          sortOrder: plan.sortOrder,
          enabled: plan.forSale,
          groupExists,
          groupPlatform: group?.platform ?? null,
          groupRateMultiplier: group?.rate_multiplier ?? null,
          groupDailyLimit: group?.daily_limit_usd ?? null,
          groupWeeklyLimit: group?.weekly_limit_usd ?? null,
          groupMonthlyLimit: group?.monthly_limit_usd ?? null,
          groupModelScopes: group?.supported_model_scopes ?? null,
          createdAt: plan.createdAt,
          updatedAt: plan.updatedAt,
        };
      }),
    );

    return NextResponse.json({ plans: results });
  } catch (error) {
    console.error('Failed to list subscription plans:', error);
    return NextResponse.json({ error: '获取订阅套餐列表失败' }, { status: 500 });
  }
}

export async function POST(request: NextRequest) {
  if (!(await verifyAdminToken(request))) return unauthorizedResponse(request);

  try {
    const body = await request.json();
    const { group_id, name, description, price, original_price, validity_days, validity_unit, features, for_sale, sort_order } = body;

    if (!group_id || !name || price === undefined) {
      return NextResponse.json({ error: '缺少必填字段: group_id, name, price' }, { status: 400 });
    }

    if (typeof price !== 'number' || price <= 0 || price > 99999999.99) {
      return NextResponse.json({ error: 'price 必须是 0.01 ~ 99999999.99 之间的数值' }, { status: 400 });
    }
    if (original_price !== undefined && original_price !== null && (typeof original_price !== 'number' || original_price <= 0 || original_price > 99999999.99)) {
      return NextResponse.json({ error: 'original_price 必须是 0.01 ~ 99999999.99 之间的数值' }, { status: 400 });
    }
    if (validity_days !== undefined && (!Number.isInteger(validity_days) || validity_days <= 0)) {
      return NextResponse.json({ error: 'validity_days 必须是正整数' }, { status: 400 });
    }
    if (sort_order !== undefined && (!Number.isInteger(sort_order) || sort_order < 0)) {
      return NextResponse.json({ error: 'sort_order 必须是非负整数' }, { status: 400 });
    }

    // 验证 group_id 唯一性
    const existing = await prisma.subscriptionPlan.findUnique({
      where: { groupId: Number(group_id) },
    });

    if (existing) {
      return NextResponse.json(
        { error: `分组 ID ${group_id} 已被套餐「${existing.name}」使用` },
        { status: 409 },
      );
    }

    const plan = await prisma.subscriptionPlan.create({
      data: {
        groupId: Number(group_id),
        name,
        description: description ?? null,
        price,
        originalPrice: original_price ?? null,
        validityDays: validity_days ?? 30,
        validityUnit: ['day', 'week', 'month'].includes(validity_unit) ? validity_unit : 'day',
        features: features ? JSON.stringify(features) : null,
        forSale: for_sale ?? false,
        sortOrder: sort_order ?? 0,
      },
    });

    return NextResponse.json(
      {
        id: plan.id,
        groupId: String(plan.groupId),
        groupName: null,
        name: plan.name,
        description: plan.description,
        price: Number(plan.price),
        originalPrice: plan.originalPrice ? Number(plan.originalPrice) : null,
        validDays: plan.validityDays,
        validityUnit: plan.validityUnit,
        features: plan.features ? JSON.parse(plan.features) : [],
        sortOrder: plan.sortOrder,
        enabled: plan.forSale,
        createdAt: plan.createdAt,
        updatedAt: plan.updatedAt,
      },
      { status: 201 },
    );
  } catch (error) {
    console.error('Failed to create subscription plan:', error);
    return NextResponse.json({ error: '创建订阅套餐失败' }, { status: 500 });
  }
}