import {
  FLOCK_LIMITS,
  FLOCK_VALIDATION_MESSAGES,
  fitsFlockTrailerCargo,
} from "@/lib/constants/flock-limits";
import {
  dimValueToIn,
  normalizeDimUnit,
  normalizeWeightUnit,
  toAxelWholeInches,
  toAxelWholePounds,
  weightUnitAmbiguousMessage,
  weightValueToLb,
} from "@/modules/quote/unit-converter";
import {
  defaultFlockPickupDateIso,
  flockPickupDateValidationMessageFromDisplay,
  flockPickupDisplayFromIso,
} from "@/lib/flock/pickup-date";
import { ValidationError } from "@/modules/quote/types";
import type {
  FlockQuoteInput,
  FlockRegistrationOverride,
} from "@/workers/rpa/flock/types";

const DATE_RE = /^\d{2}\/\d{2}\/\d{4}$/;
const EMAIL_RE = /^[^\s@]+@[^\s@]+\.[^\s@]+$/;
const SHIPMENTS_OPTIONS = new Set(["1-25", "26-50", "51-100", "101+"]);

function optionalTrim(value: unknown): string | undefined {
  if (typeof value !== "string") {
    return undefined;
  }
  const trimmed = value.trim();
  return trimmed || undefined;
}

function parseRegistrationBlock(
  raw: unknown,
): FlockRegistrationOverride | undefined {
  if (!raw || typeof raw !== "object") {
    return undefined;
  }
  const r = raw as Record<string, unknown>;
  const firstName = optionalTrim(r.first_name ?? r.firstName);
  const lastName = optionalTrim(r.last_name ?? r.lastName);
  const company = optionalTrim(r.company ?? r.company_name ?? r.companyName);
  const email = optionalTrim(r.email ?? r.work_email ?? r.workEmail);
  const phoneRaw = optionalTrim(r.phone ?? r.phone_number ?? r.phoneNumber);
  const shipmentsPerMonth = optionalTrim(
    r.shipments_per_month ?? r.shipmentsPerMonth,
  );

  if (
    !firstName &&
    !lastName &&
    !company &&
    !email &&
    !phoneRaw &&
    !shipmentsPerMonth
  ) {
    return undefined;
  }

  if (email && !EMAIL_RE.test(email)) {
    throw new ValidationError("请填写有效的工作邮箱");
  }

  let phone: string | undefined;
  if (phoneRaw) {
    const digits = phoneRaw.replace(/\D/g, "").slice(-10);
    if (digits.length !== 10) {
      throw new ValidationError("请填写有效的 10 位美国电话号码");
    }
    phone = digits;
  }

  if (shipmentsPerMonth && !SHIPMENTS_OPTIONS.has(shipmentsPerMonth)) {
    throw new ValidationError("月出货量选项无效");
  }

  return {
    firstName,
    lastName,
    company,
    email,
    phone,
    shipmentsPerMonth,
  };
}

function asObject(body: unknown): Record<string, unknown> {
  if (!body || typeof body !== "object") {
    throw new ValidationError("请求体格式无效");
  }
  return body as Record<string, unknown>;
}

function reqString(value: unknown, message: string): string {
  if (typeof value !== "string" || !value.trim()) {
    throw new ValidationError(message);
  }
  return value.trim();
}

function parsePositiveNumber(value: unknown, label: string): number {
  const n =
    typeof value === "number"
      ? value
      : typeof value === "string"
        ? Number(value.trim())
        : NaN;
  if (!Number.isFinite(n) || n <= 0) {
    throw new ValidationError(`请填写有效的${label}`);
  }
  return n;
}

function normalizeZip(raw: string, emptyMessage: string): string {
  const zip = raw.trim();
  if (!zip) {
    throw new ValidationError(emptyMessage);
  }
  if (!FLOCK_LIMITS.zipPattern.test(zip)) {
    throw new ValidationError(FLOCK_VALIDATION_MESSAGES.zipFormat);
  }
  return zip.slice(0, 5);
}

/** 默认取货日（下一工作日），供前端预填 */
export function defaultFlockPickupDate(): string {
  return flockPickupDisplayFromIso(defaultFlockPickupDateIso());
}

/**
 * 校验 Flock 询价入参；重量/尺寸支持 kg/cm，换算为 lb/in 后小数进一（ceil）
 * 例：500 kg → 1102.31 → 1103 lb
 */
export function validateFlockQuoteInput(
  body: unknown,
): FlockQuoteInput & { request_id: string; customer_id: string } {
  const o = asObject(body);
  const requestId = reqString(o.request_id, "请填写请求标识");
  const customerId = reqString(o.customer_id, "请填写客户标识");
  const rawInput = o.flock_input;
  if (!rawInput || typeof rawInput !== "object") {
    throw new ValidationError("请填写 Flock 表单参数");
  }
  const f = rawInput as Record<string, unknown>;

  const pickupDate = reqString(
    f.pickup_date ?? f.pickupDate,
    FLOCK_VALIDATION_MESSAGES.pickupDate,
  );
  if (!DATE_RE.test(pickupDate)) {
    throw new ValidationError("取货日期格式须为 MM/DD/YYYY");
  }
  const pickupDateError =
    flockPickupDateValidationMessageFromDisplay(pickupDate);
  if (pickupDateError) {
    throw new ValidationError(pickupDateError);
  }

  const pickupZip = normalizeZip(
    reqString(
      f.pickup_zip ?? f.pickupZip,
      FLOCK_VALIDATION_MESSAGES.pickupZip,
    ),
    FLOCK_VALIDATION_MESSAGES.pickupZip,
  );
  const deliveryZip = normalizeZip(
    reqString(
      f.delivery_zip ?? f.deliveryZip,
      FLOCK_VALIDATION_MESSAGES.deliveryZip,
    ),
    FLOCK_VALIDATION_MESSAGES.deliveryZip,
  );
  if (pickupZip === deliveryZip) {
    throw new ValidationError("提货与派送邮编不能相同");
  }

  const formModeRaw = f.form_mode ?? f.formMode;
  const formMode =
    formModeRaw === "logged_in_quick" ? ("logged_in_quick" as const) : undefined;

  const palletRaw = f.pallet_count ?? f.palletCount;
  const palletCount =
    typeof palletRaw === "number"
      ? palletRaw
      : Number(String(palletRaw ?? "").trim());
  const qtyMin = formMode === "logged_in_quick" ? 1 : FLOCK_LIMITS.palletCount.min;
  const qtyMax =
    formMode === "logged_in_quick" ? 999 : FLOCK_LIMITS.palletCount.max;
  if (
    !Number.isInteger(palletCount) ||
    palletCount < qtyMin ||
    palletCount > qtyMax
  ) {
    throw new ValidationError(
      formMode === "logged_in_quick"
        ? "货物数量须为 1–999 的整数"
        : FLOCK_VALIDATION_MESSAGES.palletCount,
    );
  }

  const weightObj =
    f.total_weight && typeof f.total_weight === "object"
      ? (f.total_weight as Record<string, unknown>)
      : null;
  const weightValue = parsePositiveNumber(
    weightObj?.value ?? f.total_weight_lb ?? f.totalWeightLb,
    "总运输重量",
  );
  const weightUnitRaw =
    weightObj && typeof weightObj.unit === "string"
      ? weightObj.unit
      : "lb";
  const weightAmbiguous = weightUnitAmbiguousMessage(weightUnitRaw);
  if (weightAmbiguous) {
    throw new ValidationError(weightAmbiguous);
  }
  const weightUnit = normalizeWeightUnit(weightUnitRaw);
  if (!weightUnit) {
    throw new ValidationError("重量单位须为 lb、kg 或 t/tonne（公制吨）");
  }
  const totalWeightLb = toAxelWholePounds(
    weightValueToLb(weightValue, weightUnit),
  );
  if (totalWeightLb > FLOCK_LIMITS.totalWeightLbMax) {
    throw new ValidationError(FLOCK_VALIDATION_MESSAGES.totalWeight);
  }

  const dimObj =
    f.dimensions && typeof f.dimensions === "object"
      ? (f.dimensions as Record<string, unknown>)
      : null;
  const dimUnitRaw =
    dimObj && typeof dimObj.unit === "string" ? dimObj.unit : "in";
  const dimUnit = normalizeDimUnit(dimUnitRaw);
  if (!dimUnit) {
    throw new ValidationError("尺寸单位须为 in、cm 或 m");
  }
  const lengthRaw = parsePositiveNumber(
    dimObj?.length ?? f.length_in ?? f.lengthIn ?? FLOCK_LIMITS.defaultDimsIn.length,
    "长度",
  );
  const widthRaw = parsePositiveNumber(
    dimObj?.width ?? f.width_in ?? f.widthIn ?? FLOCK_LIMITS.defaultDimsIn.width,
    "宽度",
  );
  const heightRaw = parsePositiveNumber(
    dimObj?.height ?? f.height_in ?? f.heightIn ?? FLOCK_LIMITS.defaultDimsIn.height,
    "高度",
  );
  const toIn = (v: number) => toAxelWholeInches(dimValueToIn(v, dimUnit));
  const lengthIn = toIn(lengthRaw);
  const widthIn = toIn(widthRaw);
  const heightIn = toIn(heightRaw);

  if (lengthIn > FLOCK_LIMITS.dimIn.lengthMax) {
    throw new ValidationError(FLOCK_VALIDATION_MESSAGES.length);
  }
  if (widthIn > FLOCK_LIMITS.dimIn.widthMax) {
    throw new ValidationError(FLOCK_VALIDATION_MESSAGES.width);
  }
  if (heightIn > FLOCK_LIMITS.dimIn.heightMax) {
    throw new ValidationError(FLOCK_VALIDATION_MESSAGES.height);
  }
  if (
    formMode !== "logged_in_quick" &&
    !fitsFlockTrailerCargo({ palletCount, lengthIn, widthIn })
  ) {
    throw new ValidationError(FLOCK_VALIDATION_MESSAGES.linearFeet);
  }

  const registration = parseRegistrationBlock(f.registration ?? f.account);

  const optionalStr = (v: unknown): string | undefined => {
    if (typeof v !== "string") return undefined;
    const t = v.trim();
    return t || undefined;
  };

  const optionalBool = (v: unknown): boolean | undefined =>
    typeof v === "boolean" ? v : undefined;

  return {
    request_id: requestId,
    customer_id: customerId,
    pickupDate,
    pickupZip,
    deliveryZip,
    palletCount,
    totalWeightLb,
    lengthIn,
    widthIn,
    heightIn,
    registration,
    formMode,
    pickupLocationType: optionalStr(
      f.pickup_location_type ?? f.pickupLocationType,
    ),
    deliveryLocationType: optionalStr(
      f.delivery_location_type ?? f.deliveryLocationType,
    ),
    packagingType: optionalStr(f.packaging_type ?? f.packagingType),
    freightClass: optionalStr(f.freight_class ?? f.freightClass),
    description: optionalStr(f.description),
    stackable:
      typeof f.stackable === "boolean" ? f.stackable : undefined,
    turnable: typeof f.turnable === "boolean" ? f.turnable : undefined,
    additionalServices: Array.isArray(f.additional_services ?? f.additionalServices)
      ? ((f.additional_services ?? f.additionalServices) as unknown[])
          .filter((x): x is string => typeof x === "string" && x.trim().length > 0)
          .map((x) => x.trim())
      : undefined,
    vehicleTypes: Array.isArray(f.vehicle_types ?? f.vehicleTypes)
      ? ((f.vehicle_types ?? f.vehicleTypes) as unknown[])
          .filter((x): x is string => typeof x === "string" && x.trim().length > 0)
          .map((x) => x.trim())
      : undefined,
    callBeforePickup:
      typeof f.call_before_pickup === "boolean"
        ? f.call_before_pickup
        : typeof f.callBeforePickup === "boolean"
          ? f.callBeforePickup
          : undefined,
    callBeforeDelivery:
      typeof f.call_before_delivery === "boolean"
        ? f.call_before_delivery
        : typeof f.callBeforeDelivery === "boolean"
          ? f.callBeforeDelivery
          : undefined,
    pickupLiftgate: optionalBool(
      f.pickup_liftgate ?? f.pickupLiftgate,
    ),
    pickupInside: optionalBool(f.pickup_inside ?? f.pickupInside),
    pickupPalletJack: optionalBool(
      f.pickup_pallet_jack ?? f.pickupPalletJack,
    ),
    deliveryLiftgate: optionalBool(
      f.delivery_liftgate ?? f.deliveryLiftgate,
    ),
    deliveryInside: optionalBool(f.delivery_inside ?? f.deliveryInside),
    deliveryPalletJack: optionalBool(
      f.delivery_pallet_jack ?? f.deliveryPalletJack,
    ),
    pickupService: optionalStr(f.pickup_service ?? f.pickupService),
    deliveryService: optionalStr(f.delivery_service ?? f.deliveryService),
    pickupWindowStartTime: optionalStr(
      f.pickup_window_start_time ?? f.pickupWindowStartTime,
    ),
    pickupWindowEndTime: optionalStr(
      f.pickup_window_end_time ?? f.pickupWindowEndTime,
    ),
    pickupAppointmentTime: optionalStr(
      f.pickup_appointment_time ?? f.pickupAppointmentTime,
    ),
    deliveryWindowStartTime: optionalStr(
      f.delivery_window_start_time ?? f.deliveryWindowStartTime,
    ),
    deliveryWindowEndTime: optionalStr(
      f.delivery_window_end_time ?? f.deliveryWindowEndTime,
    ),
    deliveryWindowDate: optionalStr(
      f.delivery_window_date ?? f.deliveryWindowDate,
    ),
    deliveryAppointmentTime: optionalStr(
      f.delivery_appointment_time ?? f.deliveryAppointmentTime,
    ),
    deliveryAppointmentDate: optionalStr(
      f.delivery_appointment_date ?? f.deliveryAppointmentDate,
    ),
    deliveryMustArriveByDate: optionalStr(
      f.delivery_must_arrive_by_date ?? f.deliveryMustArriveByDate,
    ),
    callForDeliveryAppointment: optionalBool(
      f.call_for_delivery_appointment ?? f.callForDeliveryAppointment,
    ),
  };
}