149 lines
15 KiB
TypeScript
149 lines
15 KiB
TypeScript
import type { PlatformProcurement } from '../procurementTypes'
|
|
import { http, unwrapApiResponse, type ApiEnvelope } from '@/shared/api/http'
|
|
|
|
import type {
|
|
CreateLocalLooseboardOrderRequest, CreateLocalTransportOrderRequest, LocalLooseboardDetail, LocalLooseboardOrder,
|
|
LocalLooseboardQuery, LocalTransportDetail, LocalTransportOrder, LocalTransportPallet, LocalTransportQuery,
|
|
OverseasBusinessHistory, OverseasBusinessPage, OverseasPurchaseCustomerOption,
|
|
OverseasPurchaseQuery, OverseasPurchaseSummary, OverseasPurchaseWarehouseOption, UpdateLocalLooseboardOrderRequest,
|
|
UpdateLocalTransportOrderRequest, UpdateOverseasPurchaseRequest,
|
|
OverseasPurchaseEditorDetail,
|
|
} from '../types'
|
|
|
|
const procurementBasePath = '/platform/v1/last-leg/overseas-procurements'
|
|
const truckBasePath = '/platform/v1/last-leg/us-truck-orders'
|
|
const looseboardBasePath = '/platform/v1/last-leg/local-looseboard-orders'
|
|
type Numeric = number | string
|
|
interface PagePayload<T> { records?: T[]; page: Numeric; size: Numeric; total: Numeric; pages: Numeric }
|
|
interface ProcurementSummaryPayload extends Omit<OverseasPurchaseSummary, 'id' | 'purchaseWarehouseId' | 'budgetUnitPrice'> { id: Numeric; purchaseWarehouseId?: Numeric | null; budgetUnitPrice?: Numeric | null }
|
|
interface ProcurementDetailPayload { summary: ProcurementSummaryPayload }
|
|
interface TruckSummaryPayload extends Omit<LocalTransportOrder, 'id' | 'budgetAmount' | 'totalWeightKg' | 'totalVolumeCbm'> { id: Numeric; budgetAmount?: Numeric | null; totalWeightKg: Numeric; totalVolumeCbm: Numeric }
|
|
interface TruckPalletPayload extends Omit<LocalTransportPallet, 'id' | 'warehousePalletId'> { id: Numeric; warehousePalletId?: Numeric | null }
|
|
interface TruckDetailPayload {
|
|
summary: TruckSummaryPayload; originAddress?: string | null; destinationAddress?: string | null
|
|
remark?: string | null; createdBy?: string | null; pallets?: TruckPalletPayload[]; histories?: OverseasBusinessHistory[]
|
|
}
|
|
interface LooseboardSummaryPayload extends Omit<LocalLooseboardOrder, 'id' | 'budgetAmount' | 'totalWeightKg' | 'totalVolumeCbm'> { id: Numeric; budgetAmount?: Numeric | null; totalWeightKg: Numeric; totalVolumeCbm: Numeric }
|
|
interface LooseboardDetailPayload {
|
|
summary: LooseboardSummaryPayload; originAddress?: string | null; destinationAddress?: string | null
|
|
remark?: string | null; createdBy?: string | null; histories?: OverseasBusinessHistory[]
|
|
}
|
|
|
|
function normalizePage<TPayload, TResult>(payload: PagePayload<TPayload>, normalize: (value: TPayload) => TResult): OverseasBusinessPage<TResult> {
|
|
return { records: (payload.records || []).map(normalize), page: Number(payload.page), size: Number(payload.size), total: Number(payload.total), pages: Number(payload.pages) }
|
|
}
|
|
function procurementInteger(value: unknown): number {
|
|
if ((typeof value !== 'number' && typeof value !== 'string') || !/^\d+$/.test(String(value)) || !Number.isSafeInteger(Number(value))) throw new Error('采购数据中的数量或版本无效，请刷新后重试')
|
|
return Number(value)
|
|
}
|
|
function procurementSummary(value: ProcurementSummaryPayload): OverseasPurchaseSummary {
|
|
return { ...value, version: procurementInteger(value.version), purchaseQuantity: procurementInteger(value.purchaseQuantity), id: String(value.id), purchaseWarehouseId: value.purchaseWarehouseId == null ? null : String(value.purchaseWarehouseId), budgetUnitPrice: value.budgetUnitPrice == null ? null : String(value.budgetUnitPrice) }
|
|
}
|
|
function truckSummary(value: TruckSummaryPayload): LocalTransportOrder {
|
|
return { ...value, id: String(value.id), totalWeightKg: String(value.totalWeightKg), totalVolumeCbm: String(value.totalVolumeCbm), budgetAmount: value.budgetAmount == null ? null : String(value.budgetAmount) }
|
|
}
|
|
function truckDetail(value: TruckDetailPayload): LocalTransportDetail {
|
|
return { ...truckSummary(value.summary), originAddress: value.originAddress || null, destinationAddress: value.destinationAddress || null, remark: value.remark || null, createdBy: value.createdBy || null, pallets: (value.pallets || []).map((item) => ({ ...item, id: String(item.id), warehousePalletId: item.warehousePalletId == null ? null : String(item.warehousePalletId) })), histories: value.histories || [] }
|
|
}
|
|
function looseboardSummary(value: LooseboardSummaryPayload): LocalLooseboardOrder {
|
|
return { ...value, id: String(value.id), totalWeightKg: String(value.totalWeightKg), totalVolumeCbm: String(value.totalVolumeCbm), budgetAmount: value.budgetAmount == null ? null : String(value.budgetAmount) }
|
|
}
|
|
function looseboardDetail(value: LooseboardDetailPayload): LocalLooseboardDetail {
|
|
return { ...looseboardSummary(value.summary), originAddress: value.originAddress || null, destinationAddress: value.destinationAddress || null, remark: value.remark || null, createdBy: value.createdBy || null, histories: value.histories || [] }
|
|
}
|
|
|
|
export async function listOverseasPurchaseCustomerOptions(keyword = '', limit = 200) {
|
|
const response = await http.get<ApiEnvelope<OverseasPurchaseCustomerOption[]>, ApiEnvelope<OverseasPurchaseCustomerOption[]>>(`${procurementBasePath}/customer-options`, { params: { keyword: keyword.trim() || undefined, limit } })
|
|
return unwrapApiResponse(response)
|
|
}
|
|
export async function listOverseasPurchaseWarehouseOptions() {
|
|
const response = await http.get<ApiEnvelope<OverseasPurchaseWarehouseOption[]>, ApiEnvelope<OverseasPurchaseWarehouseOption[]>>(`${procurementBasePath}/warehouse-options`)
|
|
return unwrapApiResponse(response).map((item) => ({ ...item, warehouseId: String(item.warehouseId) }))
|
|
}
|
|
export async function listOverseasPurchases(query: OverseasPurchaseQuery = {}) {
|
|
const response = await http.get<ApiEnvelope<PagePayload<ProcurementSummaryPayload>>, ApiEnvelope<PagePayload<ProcurementSummaryPayload>>>(procurementBasePath, { params: { ...query, customerId: query.customerId || undefined, orderNo: query.orderNo?.trim() || undefined, customerKeyword: query.customerKeyword?.trim() || undefined, purchaseCategory: query.purchaseCategory?.trim() || undefined, productName: query.productName?.trim() || undefined, status: query.status || undefined, purchaseWarehouseId: query.purchaseWarehouseId || undefined } })
|
|
return normalizePage(unwrapApiResponse(response), procurementSummary)
|
|
}
|
|
export async function getOverseasPurchase(orderNo: string, customerId: string) {
|
|
const response = await http.get<ApiEnvelope<PlatformProcurement>, ApiEnvelope<PlatformProcurement>>(`${procurementBasePath}/${encodeURIComponent(orderNo)}`, { params: { customerId } })
|
|
const detail = unwrapApiResponse(response)
|
|
detail.customerView.order.version = procurementInteger(detail.customerView.order.version)
|
|
detail.customerView.order.purchaseQuantity = procurementInteger(detail.customerView.order.purchaseQuantity)
|
|
for (const row of [...detail.customerView.boxes, ...detail.customerView.shipments]) row.quantity = procurementInteger(row.quantity)
|
|
for (const fee of detail.customerView.fees) if (fee.version != null) fee.version = procurementInteger(fee.version)
|
|
if (detail.purchaseFacts?.purchased_quantity != null) detail.purchaseFacts.purchased_quantity = procurementInteger(detail.purchaseFacts.purchased_quantity)
|
|
if (detail.physical.packingVersion != null) detail.physical.packingVersion = procurementInteger(detail.physical.packingVersion)
|
|
for (const row of detail.physical.receipts) {
|
|
row.goodQuantity = procurementInteger(row.goodQuantity); row.damagedQuantity = procurementInteger(row.damagedQuantity); row.extraQuantity = procurementInteger(row.extraQuantity)
|
|
}
|
|
for (const row of [...detail.physical.dispositions, ...detail.controls.remaining, ...detail.controls.closureItems]) row.quantity = procurementInteger(row.quantity)
|
|
for (const row of [...detail.physical.cartons, ...detail.transport.overseasCargo, ...detail.transport.domesticCargo]) {
|
|
row.quantity = procurementInteger(row.quantity)
|
|
for (const source of row.sources) source.quantity = procurementInteger(source.quantity)
|
|
}
|
|
for (const fee of detail.fees) fee.feeVersion = procurementInteger(fee.feeVersion)
|
|
for (const file of detail.files) file.sizeBytes = procurementInteger(file.sizeBytes)
|
|
if (detail.purchaseFacts?.actual_warehouse_id != null) detail.purchaseFacts.actual_warehouse_id = String(detail.purchaseFacts.actual_warehouse_id)
|
|
detail.physical.dispositions = detail.physical.dispositions.map(row => ({ ...row, id: String(row.id), source_carton_id: row.source_carton_id == null ? null : String(row.source_carton_id), receipt_id: row.receipt_id == null ? null : String(row.receipt_id), voucher_file_id: String(row.voucher_file_id) }))
|
|
detail.physical.receipts = detail.physical.receipts.map(row => ({ ...row, id: String(row.id), sourceCartonId: row.sourceCartonId == null ? null : String(row.sourceCartonId) }))
|
|
detail.physical.cartons = detail.physical.cartons.map(row => ({ ...row, id: String(row.id), sources: row.sources.map(source => ({ ...source, receiptId: String(source.receiptId) })) }))
|
|
detail.fees = detail.fees.map(fee => ({ ...fee, id: String(fee.id), parentFeeId: fee.parentFeeId == null ? null : String(fee.parentFeeId), sourceFeeId: fee.sourceFeeId == null ? null : String(fee.sourceFeeId), voucherFileId: fee.voucherFileId == null ? null : String(fee.voucherFileId), walletLedgerId: fee.walletLedgerId == null ? null : String(fee.walletLedgerId) }))
|
|
detail.transport.shipments = detail.transport.shipments.map(row => ({ ...row, id: String(row.id) }))
|
|
detail.controls.notes = detail.controls.notes.map(row => ({ ...row, id: String(row.id), target_id: row.target_id == null ? null : String(row.target_id), voucher_file_id: String(row.voucher_file_id), resolution_voucher_id: row.resolution_voucher_id == null ? null : String(row.resolution_voucher_id) }))
|
|
detail.controls.remaining = detail.controls.remaining.map(row => ({ ...row, sourceId: row.sourceId == null ? null : String(row.sourceId) }))
|
|
detail.controls.closures = detail.controls.closures.map(row => ({ ...row, id: String(row.id) }))
|
|
detail.controls.closureItems = detail.controls.closureItems.map(row => ({ ...row, id: String(row.id), closure_id: String(row.closure_id), source_id: row.source_id == null ? null : String(row.source_id), voucher_file_id: String(row.voucher_file_id) }))
|
|
detail.files = detail.files.map(file => ({ ...file, id: String(file.id), fileId: String(file.fileId) }))
|
|
for (const leg of ['overseasCargo', 'domesticCargo'] as const) detail.transport[leg] = detail.transport[leg].map(row => ({ ...row, cartonId: String(row.cartonId), packagingRecordId: row.packagingRecordId == null ? null : String(row.packagingRecordId), sources: row.sources.map(source => ({ ...source, receiptId: String(source.receiptId) })) }))
|
|
for (const labels of [detail.transport.overseasLabels, detail.transport.domesticLabels]) if (labels) {
|
|
labels.version = procurementInteger(labels.version)
|
|
for (const label of labels.labels) label.page = procurementInteger(label.page)
|
|
labels.id = String(labels.id); labels.manifestId = String(labels.manifestId)
|
|
labels.labels = labels.labels.map(row => ({ ...row, cartonId: String(row.cartonId), fileId: String(row.fileId) }))
|
|
}
|
|
return detail
|
|
}
|
|
export async function getOverseasPurchaseEditor(orderNo: string, customerId: string) {
|
|
const response = await http.get<ApiEnvelope<OverseasPurchaseEditorDetail>, ApiEnvelope<OverseasPurchaseEditorDetail>>(`${procurementBasePath}/${encodeURIComponent(orderNo)}`, { params: { customerId } })
|
|
const detail = unwrapApiResponse(response)
|
|
detail.customerView.order.version = procurementInteger(detail.customerView.order.version)
|
|
detail.customerView.order.purchaseQuantity = procurementInteger(detail.customerView.order.purchaseQuantity)
|
|
return detail
|
|
}
|
|
export async function updateOverseasPurchase(orderNo: string, customerId: string, payload: UpdateOverseasPurchaseRequest) {
|
|
const response = await http.patch<ApiEnvelope<ProcurementDetailPayload>, ApiEnvelope<ProcurementDetailPayload>>(`${procurementBasePath}/${encodeURIComponent(orderNo)}`, { version: payload.version, remark: payload.remark }, { params: { customerId } })
|
|
return procurementSummary(unwrapApiResponse(response).summary)
|
|
}
|
|
export async function listUsTruckOrders(query: LocalTransportQuery = {}) {
|
|
const response = await http.get<ApiEnvelope<PagePayload<TruckSummaryPayload>>, ApiEnvelope<PagePayload<TruckSummaryPayload>>>(truckBasePath, { params: { ...query, orderNo: query.orderNo?.trim() || undefined, routeKeyword: query.routeKeyword?.trim() || undefined, status: query.status || undefined, vehicleType: query.vehicleType || undefined, customerId: query.customerId || undefined } })
|
|
return normalizePage(unwrapApiResponse(response), truckSummary)
|
|
}
|
|
export async function getUsTruckOrder(orderNo: string, customerId: string) {
|
|
const response = await http.get<ApiEnvelope<TruckDetailPayload>, ApiEnvelope<TruckDetailPayload>>(`${truckBasePath}/${encodeURIComponent(orderNo)}`, { params: { customerId } })
|
|
return truckDetail(unwrapApiResponse(response))
|
|
}
|
|
export async function createUsTruckOrder(customerId: string, payload: CreateLocalTransportOrderRequest) {
|
|
const response = await http.post<ApiEnvelope<TruckDetailPayload>, ApiEnvelope<TruckDetailPayload>>(truckBasePath, payload, { params: { customerId } })
|
|
return truckDetail(unwrapApiResponse(response))
|
|
}
|
|
export async function updateUsTruckOrder(orderNo: string, customerId: string, payload: UpdateLocalTransportOrderRequest) {
|
|
const response = await http.patch<ApiEnvelope<TruckDetailPayload>, ApiEnvelope<TruckDetailPayload>>(`${truckBasePath}/${encodeURIComponent(orderNo)}`, payload, { params: { customerId } })
|
|
return truckDetail(unwrapApiResponse(response))
|
|
}
|
|
export async function listLocalLooseboardOrders(query: LocalLooseboardQuery = {}) {
|
|
const response = await http.get<ApiEnvelope<PagePayload<LooseboardSummaryPayload>>, ApiEnvelope<PagePayload<LooseboardSummaryPayload>>>(looseboardBasePath, { params: { ...query, customerId: query.customerId || undefined, orderNo: query.orderNo?.trim() || undefined, routeKeyword: query.routeKeyword?.trim() || undefined, status: query.status || undefined } })
|
|
return normalizePage(unwrapApiResponse(response), looseboardSummary)
|
|
}
|
|
export async function getLocalLooseboardOrder(orderNo: string, customerId: string) {
|
|
const response = await http.get<ApiEnvelope<LooseboardDetailPayload>, ApiEnvelope<LooseboardDetailPayload>>(`${looseboardBasePath}/${encodeURIComponent(orderNo)}`, { params: { customerId } })
|
|
return looseboardDetail(unwrapApiResponse(response))
|
|
}
|
|
export async function createLocalLooseboardOrder(customerId: string, payload: CreateLocalLooseboardOrderRequest) {
|
|
const response = await http.post<ApiEnvelope<LooseboardDetailPayload>, ApiEnvelope<LooseboardDetailPayload>>(looseboardBasePath, payload, { params: { customerId } })
|
|
return looseboardDetail(unwrapApiResponse(response))
|
|
}
|
|
export async function updateLocalLooseboardOrder(orderNo: string, customerId: string, payload: UpdateLocalLooseboardOrderRequest) {
|
|
const response = await http.put<ApiEnvelope<LooseboardDetailPayload>, ApiEnvelope<LooseboardDetailPayload>>(`${looseboardBasePath}/${encodeURIComponent(orderNo)}`, payload, { params: { customerId } })
|
|
return looseboardDetail(unwrapApiResponse(response))
|
|
}
|