diff --git a/scripts/admin-test-env-modules/phase3-pda-convergence.mjs b/scripts/admin-test-env-modules/phase3-pda-convergence.mjs index b5b809ae6..d560028b9 100644 --- a/scripts/admin-test-env-modules/phase3-pda-convergence.mjs +++ b/scripts/admin-test-env-modules/phase3-pda-convergence.mjs @@ -57,7 +57,14 @@ export async function run(context) { const pendingTasks = context.apiSuccess(MODULE, '读取当前操作员 PDA pending 列表', pendingResponse, '', OPTIONS) const pendingRecords = Array.isArray(pendingTasks) ? pendingTasks : pendingTasks?.records || pendingTasks?.items || [] - const pendingTask = pendingRecords.find((item) => id(item?.taskId || item?.id) === taskId) + let pendingTask = pendingRecords.find((item) => id(item?.taskId || item?.id) === taskId) + if (!pendingTask) { + const broadPendingResponse = await request(context, 'GET', + `/api/platform/v1/first-leg/pda-loading/tasks/pending?warehouseId=${encodeURIComponent(warehouseId)}`) + const broadPending = context.apiSuccess(MODULE, '无关键词回查当前操作员 PDA pending 列表', broadPendingResponse, '', OPTIONS) + const broadRecords = Array.isArray(broadPending) ? broadPending : broadPending?.records || broadPending?.items || [] + pendingTask = broadRecords.find((item) => id(item?.taskId || item?.id) === taskId) + } const unresolvedItems = (taskDetail?.items || []).filter((item) => ['PENDING', 'PICKING'].includes(item?.itemStatus)) context.assert(MODULE, 'pending 与 detail 使用同一 workflowStatus 和未完成数量事实', pendingResponse,