test(phase3): verify fulfillment aggregates and update schedule gaps
This commit is contained in:
@@ -1,36 +1,111 @@
|
||||
const MODULE = 'phase3-order-splitting'
|
||||
const SCENARIO = 'parent-child-multi-container-consolidation'
|
||||
const OPTIONS = { scenario: SCENARIO, deploymentBlocker: true }
|
||||
|
||||
function id(value) { return value == null ? '' : String(value) }
|
||||
function codeOf(response) { return response?.body?.code == null ? 'missing' : String(response.body.code) }
|
||||
function failure(response) {
|
||||
return [400, 401, 403, 404, 409, 503].includes(response?.http)
|
||||
|| (response?.http === 200 && codeOf(response) !== '200')
|
||||
}
|
||||
|
||||
function isPositiveId(value) { return /^[1-9][0-9]*$/.test(id(value)) }
|
||||
|
||||
function treeShape(tree, orderId) {
|
||||
if (!tree || !isPositiveId(tree.parentOrderId) || id(tree.parentOrderId) !== orderId
|
||||
|| typeof tree.parentOrderNo !== 'string' || !Number.isInteger(Number(tree.parentVersion))
|
||||
|| !Array.isArray(tree.children) || !Number.isInteger(Number(tree.allocatedPackageCount))
|
||||
|| !Number.isInteger(Number(tree.remainingPackageCount))) return false
|
||||
return tree.children.every((child) => isPositiveId(child.orderId)
|
||||
&& typeof child.orderNo === 'string'
|
||||
&& Number.isInteger(Number(child.splitSequence))
|
||||
&& ['LOADED', 'REMAINDER'].includes(child.splitRole)
|
||||
&& Number.isInteger(Number(child.packageCount)) && Number(child.packageCount) >= 0
|
||||
&& isPositiveId(child.sourceOrderId) && isPositiveId(child.loadingPlanId)
|
||||
&& isPositiveId(child.containerBookingId))
|
||||
}
|
||||
|
||||
function sliceShape(row, containerBookingId, tenantId) {
|
||||
return row && isPositiveId(row.containerBookingId) && id(row.containerBookingId) === containerBookingId
|
||||
&& isPositiveId(row.tenantId) && id(row.tenantId) === tenantId
|
||||
&& isPositiveId(row.parentOrderId) && typeof row.parentOrderNo === 'string'
|
||||
&& isPositiveId(row.childOrderId) && typeof row.childOrderNo === 'string'
|
||||
&& isPositiveId(row.sourceOrderId) && typeof row.sourceOrderNo === 'string'
|
||||
&& ['LOADED', 'REMAINDER'].includes(row.splitRole)
|
||||
&& Number.isInteger(Number(row.packageCount)) && Number(row.packageCount) >= 0
|
||||
&& isPositiveId(row.loadingPlanId)
|
||||
}
|
||||
|
||||
export async function run(context) {
|
||||
const fixture = context.createdResources?.phase3Loading
|
||||
|| context.createdResources?.phase3ContainerLoading
|
||||
const metadata = {
|
||||
fixture: {
|
||||
available: Boolean(fixture?.inboundId && fixture?.containerBookingId),
|
||||
marker: fixture?.marker || null,
|
||||
inboundId: fixture?.inboundId || null,
|
||||
containerBookingId: fixture?.containerBookingId || null,
|
||||
},
|
||||
activation: {
|
||||
state: 'pending-public-contract',
|
||||
assertions: [
|
||||
'父单与自动剩余子单关系可由 HTTP 查询',
|
||||
'一单多柜关系由 container aggregate 返回',
|
||||
'一柜多单关系由 container aggregate 返回',
|
||||
'已装数量 + 自动子单剩余数量 = 拆分前数量',
|
||||
'同一 Idempotency-Key 与相同参数重放返回同一拆分结果',
|
||||
'同一 Idempotency-Key 与不同参数被冲突拒绝且无部分写入',
|
||||
'旧 expectedVersion 被冲突拒绝且父子订单数量不变',
|
||||
'平台与客户 fulfillment-tree 均隔离其他客户数据',
|
||||
'子订单继续拆分被拒绝，不产生嵌套层级',
|
||||
'已消费 REMAINDER 再次消费被拒绝且数量不变',
|
||||
],
|
||||
},
|
||||
const tenantId = id(fixture?.tenantId)
|
||||
const inboundId = id(fixture?.inboundId)
|
||||
const containerBookingId = id(fixture?.containerBookingId)
|
||||
if (!tenantId || !inboundId || !containerBookingId || fixture?.marker !== context.marker) {
|
||||
context.addCoverageGap(MODULE, SCENARIO, '父子订单与柜次聚合真实验收 fixture',
|
||||
'本轮未取得 marker 隔离的 phase3Loading 入库单和柜次，未使用历史资源；需要先运行 phase3-loading 生成真实 fixture',
|
||||
'fixture', { fixture: { available: false, marker: fixture?.marker || null, inboundId: inboundId || null, containerBookingId: containerBookingId || null } })
|
||||
return
|
||||
}
|
||||
context.addCoverageGap(MODULE, SCENARIO, '父/子订单拆分、装载数量守恒与剩余自动子订单',
|
||||
'PDA partial/skip 内部结算已实现，但公开 InboundOrderSummary/Detail 未返回 inboundRole、parentInboundId、rootInboundId、splitStatus 或拆分批次，HTTP 总控无法证明父子关系和守恒，不能用同 orderId 的记录数量伪造成功',
|
||||
'contract-gap', metadata)
|
||||
context.addCoverageGap(MODULE, SCENARIO, '一单多柜与多单拼柜',
|
||||
'SmartLoadingController 支持按明细分配，但当前公开契约没有订单-多柜/柜次-多订单关系聚合，也没有本轮安全 fixture 一次生成两个可装柜入库单；待真实查询 DTO 与专用 fixture 接口公开后转为断言',
|
||||
'contract-gap', metadata)
|
||||
|
||||
const inboundPath = `/api/platform/inbounds/${encodeURIComponent(inboundId)}?tenantId=${encodeURIComponent(tenantId)}`
|
||||
const inboundResponse = await context.request('GET', inboundPath)
|
||||
const inbound = context.apiSuccess(MODULE, '读取本轮入库单以解析来源订单', inboundResponse,
|
||||
`tenantId=${tenantId}, inboundId=${inboundId}`, OPTIONS)
|
||||
const orderId = id(inbound?.summary?.orderId)
|
||||
context.assert(MODULE, '入库单返回可查询的来源订单 ID', inboundResponse,
|
||||
isPositiveId(orderId) && id(inbound?.summary?.tenantId) === tenantId,
|
||||
`orderId=${orderId || 'missing'}, tenantId=${id(inbound?.summary?.tenantId) || 'missing'}`, OPTIONS)
|
||||
if (!orderId) return
|
||||
|
||||
const treePath = `/api/platform/v1/orders/${encodeURIComponent(orderId)}/fulfillment-tree?tenantId=${encodeURIComponent(tenantId)}`
|
||||
const treeResponse = await context.request('GET', treePath)
|
||||
const tree = context.apiSuccess(MODULE, '平台查询真实父子订单履约树', treeResponse,
|
||||
`orderId=${orderId}, tenantId=${tenantId}`, OPTIONS)
|
||||
context.assert(MODULE, '父子订单履约树字段和客户归属完整', treeResponse,
|
||||
treeShape(tree, orderId),
|
||||
`parent=${id(tree?.parentOrderId) || 'missing'}, children=${tree?.children?.length ?? 'n/a'}, allocated=${tree?.allocatedPackageCount ?? 'n/a'}, remaining=${tree?.remainingPackageCount ?? 'n/a'}`, OPTIONS)
|
||||
if (!tree) return
|
||||
|
||||
const slicesPath = `/api/platform/v1/orders/container-bookings/${encodeURIComponent(containerBookingId)}/fulfillment-slices?tenantId=${encodeURIComponent(tenantId)}`
|
||||
const slicesResponse = await context.request('GET', slicesPath)
|
||||
const slices = context.apiSuccess(MODULE, '平台按柜次查询真实履约分片聚合', slicesResponse,
|
||||
`containerBookingId=${containerBookingId}, tenantId=${tenantId}`, OPTIONS)
|
||||
context.assert(MODULE, '柜次分片响应为客户隔离数组且字段完整', slicesResponse,
|
||||
Array.isArray(slices) && slices.every((row) => sliceShape(row, containerBookingId, tenantId)),
|
||||
`rows=${Array.isArray(slices) ? slices.length : 'n/a'}`, OPTIONS)
|
||||
|
||||
if (Array.isArray(slices) && slices.length > 0) {
|
||||
const loaded = slices.filter((row) => row.splitRole === 'LOADED')
|
||||
.reduce((sum, row) => sum + Number(row.packageCount), 0)
|
||||
const remainder = slices.filter((row) => row.splitRole === 'REMAINDER')
|
||||
.reduce((sum, row) => sum + Number(row.packageCount), 0)
|
||||
context.assert(MODULE, '柜次分片按角色聚合数量可解释且与父树一致', slicesResponse,
|
||||
loaded === Number(tree.allocatedPackageCount)
|
||||
&& remainder >= 0 && Number(tree.remainingPackageCount) >= remainder,
|
||||
`loaded=${loaded}, treeAllocated=${tree.allocatedPackageCount}, remainder=${remainder}, treeRemaining=${tree.remainingPackageCount}`, OPTIONS)
|
||||
} else {
|
||||
context.addCoverageGap(MODULE, SCENARIO, '一单多柜与多单拼柜数量守恒',
|
||||
'真实柜次分片查询端点已公开并完成字段/客户隔离验证，但本轮 phase3Loading 仅生成单来源订单且未通过公开接口生成跨订单分片，无法伪造一单多柜或一柜多单数量守恒 fixture',
|
||||
'fixture', { fixture: { available: true, marker: context.marker, inboundId, containerBookingId, orderId } })
|
||||
}
|
||||
|
||||
const wrongTenant = (BigInt(tenantId) + 1n).toString()
|
||||
const wrongTreePath = `/api/platform/v1/orders/${encodeURIComponent(orderId)}/fulfillment-tree?tenantId=${encodeURIComponent(wrongTenant)}`
|
||||
const wrongTree = await context.request('GET', wrongTreePath)
|
||||
context.addStep(MODULE, '父子履约树跨客户归属拒绝', wrongTree,
|
||||
failure(wrongTree), `HTTP=${wrongTree.http}, code=${codeOf(wrongTree)}, tenantId=${wrongTenant}`, OPTIONS)
|
||||
|
||||
const wrongSlicesPath = `/api/platform/v1/orders/container-bookings/${encodeURIComponent(containerBookingId)}/fulfillment-slices?tenantId=${encodeURIComponent(wrongTenant)}`
|
||||
const wrongSlices = await context.request('GET', wrongSlicesPath)
|
||||
const wrongSlicesData = context.apiSuccess(MODULE, '柜次分片跨客户查询返回隔离结果', wrongSlices,
|
||||
`containerBookingId=${containerBookingId}, tenantId=${wrongTenant}`, OPTIONS)
|
||||
context.assert(MODULE, '柜次分片不泄露其他客户数据', wrongSlices,
|
||||
Array.isArray(wrongSlicesData) && wrongSlicesData.length === 0,
|
||||
`rows=${Array.isArray(wrongSlicesData) ? wrongSlicesData.length : 'n/a'}`, OPTIONS)
|
||||
|
||||
context.addCoverageGap(MODULE, SCENARIO, '父子订单拆分、装载数量守恒与剩余自动子订单',
|
||||
'真实 fulfillment-tree 已可查询父订单、子订单字段和数量摘要，但当前公开平台契约只有查询端点，没有受权限保护的拆分创建/消费 fixture；本轮不能证明自动生成余量子单、幂等重放、版本冲突及禁止嵌套拆分',
|
||||
'contract-gap', { fixture: { available: true, marker: context.marker, inboundId, containerBookingId, orderId } })
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user