admin-web/src/modules/trucking/api/platformTrucking.ts

import { http, unwrapApiResponse, type ApiEnvelope } from '@/shared/api/http'
import type {
  SaveTruckAppointmentRequest,
  TruckAppointmentPage,
  TruckAppointmentQuery,
  TruckAppointmentResource,
} from '../types'

const basePath = '/platform/v1/truck-appointments'
function dtoPayload(payload: SaveTruckAppointmentRequest) {
  const { attachmentRefs: _attachmentRefs, ...dto } = payload
  return dto
}

type PagePayload = Omit<TruckAppointmentPage, 'page' | 'size' | 'total' | 'pages'> & {
  page: number | string
  size: number | string
  total: number | string
  pages?: number | string
}

function normalizePage(payload: PagePayload): TruckAppointmentPage {
  const page = Number(payload.page || 1)
  const size = Number(payload.size || 20)
  const total = Number(payload.total || 0)
  return { records: (payload.records || []).map(normalizeResource), page, size, total, pages: Number(payload.pages || Math.max(Math.ceil(total / size), 1)) }
}

function normalizeResource(resource: TruckAppointmentResource): TruckAppointmentResource {
  const idKeys = ['id', 'outboundOrderId', 'oceanBookingId', 'containerBookingId', 'loadingPlanId', 'warehouseId', 'customerId', 'carrierId']
  const normalized = { ...resource } as Record<string, unknown>
  for (const key of idKeys) {
    if (normalized[key] !== null && normalized[key] !== undefined) normalized[key] = String(normalized[key])
  }
  return normalized as unknown as TruckAppointmentResource
}

export async function listTruckAppointments(query: TruckAppointmentQuery = {}) {
  const response = await http.get<ApiEnvelope<PagePayload>, ApiEnvelope<PagePayload>>(basePath, {
    params: {
      ...query,
      keyword: query.keyword?.trim() || undefined,
      status: query.status || undefined,
      containerBookingId: query.containerBookingId || undefined,
    },
  })
  return normalizePage(unwrapApiResponse(response))
}

export async function getTruckAppointment(id: string | number) {
  const response = await http.get<ApiEnvelope<TruckAppointmentResource>, ApiEnvelope<TruckAppointmentResource>>(`${basePath}/${id}`)
  return normalizeResource(unwrapApiResponse(response))
}

export async function createTruckAppointment(payload: SaveTruckAppointmentRequest) {
  const response = await http.post<ApiEnvelope<TruckAppointmentResource>, ApiEnvelope<TruckAppointmentResource>>(basePath, dtoPayload(payload))
  return normalizeResource(unwrapApiResponse(response))
}

export async function updateTruckAppointment(id: string | number, payload: SaveTruckAppointmentRequest) {
  const response = await http.put<ApiEnvelope<TruckAppointmentResource>, ApiEnvelope<TruckAppointmentResource>>(`${basePath}/${id}`, dtoPayload(payload))
  return unwrapApiResponse(response)
}

export type TruckAppointmentAction = 'SUBMIT' | 'DISPATCH' | 'PICKUP' | 'ARRIVE' | 'LOAD' | 'DEPART' | 'COMPLETE' | 'EXCEPTION' | 'CANCEL'

export async function performTruckAppointmentAction(
  id: string | number,
  action: TruckAppointmentAction,
  expectedVersion: number,
  reason?: string,
  idempotencyKey?: string,
  requestHash?: string,
) {
  const response = await http.post<ApiEnvelope<TruckAppointmentResource>, ApiEnvelope<TruckAppointmentResource>>(`${basePath}/${id}/${action.toLowerCase()}`, { expectedVersion, reason: reason || null }, {
    headers: { ...(idempotencyKey ? { 'Idempotency-Key': idempotencyKey } : {}), ...(requestHash ? { 'X-Request-Hash': requestHash } : {}) },
  })
  return unwrapApiResponse(response)
}

export async function rescheduleTruckAppointment(id: string | number, plannedLoadingAt: string, expectedVersion: number, reason?: string) {
  const response = await http.post<ApiEnvelope<TruckAppointmentResource>, ApiEnvelope<TruckAppointmentResource>>(`${basePath}/${id}/reschedule`, { expectedVersion, reason: reason || null }, { params: { plannedLoadingAt } })
  return unwrapApiResponse(response)
}