104 lines
6.4 KiB
JavaScript
104 lines
6.4 KiB
JavaScript
// Internal probes invoked only by the registered dropship matrix and its fresh fixtures.
|
|
// A failed expectation remains a deployment blocker. Continue other probes only when
|
|
// authoritative task/inventory snapshots prove the failed request changed no state.
|
|
const MODULE = 'dropship-pallet-matrix'
|
|
const OPTIONS = { scenario: 'dropship-outbound-edge-cases', deploymentBlocker: true }
|
|
const BASE = '/api/platform/v1/last-leg/outbound-orders'
|
|
|
|
function record(edge, name, response, passed, evidence = '') {
|
|
edge.context.assert(MODULE, `${edge.label}${name}`, response, passed, evidence, OPTIONS)
|
|
}
|
|
|
|
async function request(edge, method, path, body, pda = false) {
|
|
return edge.context.requestOverseas(method, path, body, {}, pda ? edge.token : edge.context.overseasToken)
|
|
}
|
|
|
|
async function candidates(edge) {
|
|
const rows = await edge.call('边界测试回查本轮库存候选', 'GET', edge.candidatePath)
|
|
return rows.filter(row => edge.group.some(x => x.source.inboundCode === row.inboundCode))
|
|
.map(row => ({ position: row.inventoryPositionId, sku: row.skuCode,
|
|
inbound: row.inboundCode, packages: row.availablePackages }))
|
|
.sort((a, b) => `${a.position}:${a.sku}`.localeCompare(`${b.position}:${b.sku}`))
|
|
}
|
|
|
|
async function taskSnapshot(edge) {
|
|
return edge.call('边界测试回查出库冻结事实', 'GET', `${BASE}/${edge.task.outboundNo}`)
|
|
}
|
|
|
|
export async function outboundCreationGuards(edge) {
|
|
const before = await candidates(edge)
|
|
const first = edge.body.items[0]
|
|
const cases = [
|
|
['超量创建', { ...first, packages: first.packages + 100, cartonMarks: [] }],
|
|
['错误SKU创建', { ...first, sku: `WRONG-${edge.context.marker}` }],
|
|
['不存在箱唛创建', { ...first, packages: 1, cartonMarks: [`MISSING-${edge.context.marker}`] }],
|
|
['重复箱唛创建', { ...first, packages: 2, cartonMarks: [first.cartonMarks[0], first.cartonMarks[0]] }],
|
|
['箱数与箱唛不符创建', { ...first, packages: first.packages + 1 }],
|
|
]
|
|
for (const [index, [name, input]] of cases.entries()) {
|
|
const response = await request(edge, 'POST', `${BASE}/one-click-dropship?customerId=${edge.customerId}`,
|
|
{ ...edge.body, items: [input], idempotencyKey: `${edge.body.idempotencyKey}-invalid-${index}` })
|
|
record(edge, `${name}返回A0409`, response, response.body?.code === 'A0409')
|
|
const after = await candidates(edge)
|
|
edge.check(`${edge.label}${name}后库存候选零漂移`, null, JSON.stringify(before) === JSON.stringify(after))
|
|
}
|
|
// Two real concurrent requests, same fixture and same key; no parallel fixture workers.
|
|
const body = { ...edge.body, idempotencyKey: `${edge.body.idempotencyKey}-race-cancel` }
|
|
const create = () => request(edge, 'POST', `${BASE}/one-click-dropship?customerId=${edge.customerId}`, body)
|
|
const responses = await Promise.all([create(), create()])
|
|
const tasks = responses.filter(r => r.body?.code === '200').map(r => r.body.data)
|
|
record(edge, '并发同键创建均成功且只生成一个任务', responses[1],
|
|
tasks.length === 2 && tasks[0].taskNo === tasks[1].taskNo && tasks[0].outboundNo === tasks[1].outboundNo)
|
|
edge.check(`${edge.label}并发创建至少一个可回查结果`, null, tasks.length > 0)
|
|
for (const outboundNo of new Set(tasks.map(t => t.outboundNo))) {
|
|
for (let replay = 0; replay < 2; replay++) {
|
|
const cancelled = await request(edge, 'POST', `${BASE}/${outboundNo}/cancel`, { reason: '本轮未拣取消及重放验收' })
|
|
edge.check(`${edge.label}未拣取消及重复取消成功`, cancelled, cancelled.body?.code === '200')
|
|
}
|
|
const detail = await edge.call('回查取消任务状态', 'GET', `${BASE}/${outboundNo}`)
|
|
edge.check(`${edge.label}取消后明细全部取消`, null, detail.outbound?.status === 'CANCELLED'
|
|
&& detail.pallets.every(p => p.status === 'CANCELLED' && Number(p.pickedPackageCount) === 0))
|
|
}
|
|
edge.check(`${edge.label}取消后逐票SKU可用箱数恢复`, null,
|
|
JSON.stringify(before) === JSON.stringify(await candidates(edge)))
|
|
}
|
|
|
|
export async function outboundTaskGuards(edge) {
|
|
const before = await taskSnapshot(edge)
|
|
const changed = await request(edge, 'POST', `${BASE}/one-click-dropship?customerId=${edge.customerId}`,
|
|
{ ...edge.body, recipient: `${edge.body.recipient}-changed` })
|
|
record(edge, '出库创建同键异载荷返回A0409', changed, changed.body?.code === 'A0409')
|
|
edge.check(`${edge.label}同键异载荷后出库事实零漂移`, null,
|
|
JSON.stringify(before) === JSON.stringify(await taskSnapshot(edge)))
|
|
const path = `/api/pda/v1/last-leg/outbound-tasks/${edge.task.taskNo}`
|
|
const incomplete = await request(edge, 'POST', `${path}/complete`,
|
|
{ idempotencyKey: `${edge.body.idempotencyKey}-incomplete` }, true)
|
|
record(edge, '未拣齐禁止完成出库', incomplete, incomplete.body?.code === 'A0409')
|
|
edge.check(`${edge.label}未拣齐完成失败后零漂移`, null,
|
|
JSON.stringify(before) === JSON.stringify(await taskSnapshot(edge)))
|
|
}
|
|
|
|
export async function probePartialPick(edge) {
|
|
const before = await taskSnapshot(edge)
|
|
const path = `/api/pda/v1/last-leg/outbound-tasks/${edge.task.taskNo}/pick`
|
|
const partial = { ...edge.pick, packages: 1, cartonMarks: edge.pick.cartonMarks.slice(0, 1),
|
|
idempotencyKey: `${edge.pick.idempotencyKey}-partial` }
|
|
const result = await request(edge, 'POST', path, partial, true)
|
|
record(edge, '四箱任务先拣一箱成功', result, result.body?.code === '200')
|
|
const after = await taskSnapshot(edge)
|
|
if (result.body?.code !== '200') {
|
|
edge.check(`${edge.label}分批拣货失败后无库存明细变化`, null, JSON.stringify(before) === JSON.stringify(after))
|
|
// Keep the failed assertion; whole-item picking below only continues later coverage.
|
|
return 0
|
|
}
|
|
edge.check(`${edge.label}分批首箱只累计一箱`, null,
|
|
after.pallets.reduce((sum, p) => sum + Number(p.pickedPackageCount), 0) === 1)
|
|
const replay = await request(edge, 'POST', path, partial, true)
|
|
record(edge, '分批首箱同键重放成功', replay, replay.body?.code === '200')
|
|
edge.check(`${edge.label}分批重放不重复扣减`, null, JSON.stringify(after) === JSON.stringify(await taskSnapshot(edge)))
|
|
const cancel = await request(edge, 'POST', `${BASE}/${edge.task.outboundNo}/cancel`, { reason: '已拣取消拦截验收' })
|
|
record(edge, '部分已拣禁止取消', cancel, cancel.body?.code === 'A0409')
|
|
edge.check(`${edge.label}已拣取消失败后零漂移`, null, JSON.stringify(after) === JSON.stringify(await taskSnapshot(edge)))
|
|
return 1
|
|
}
|