pda-uniapp/tests/picking-evidence-stage.test.mjs

import test from 'node:test'
import assert from 'node:assert/strict'
import { readFile } from 'node:fs/promises'

const page = await readFile(new URL('../pages/picking/picking.vue', import.meta.url), 'utf8')

test('picking and photo workspaces are independently selectable', () => {
	assert.match(page, /v-if="activeStage === 'evidence' && loadingStageReady" class="loading-evidence-section"/)
	assert.match(page, /isPickingCompleteTask\(task\)[\s\S]*?AWAITING_REVIEW[\s\S]*?COMPLETED/)
	assert.match(page, /pickingCompleted\(\)[\s\S]*?this\.remoteTaskId \|\| this\.currentBox\.taskId[\s\S]*?if \(!this\.remotePick\) return false[\s\S]*?hasServerPending[\s\S]*?isPickingCompleteTask\(this\.remotePick\) && !hasServerPending/)
	assert.match(page, /请先处理并提交全部待拣明细/)
})

test('a server task never inherits a completed marker from the previously opened local cabinet', () => {
	assert.match(page, /pickingCompleted\(\) \{[\s\S]*?this\.remoteTaskId \|\| this\.currentBox\.taskId[\s\S]*?if \(!this\.remotePick\) return false[\s\S]*?hasServerPending/)
	assert.match(page, /if \(options\.taskId\) \{[\s\S]*?this\.completedBoxes = \{\}[\s\S]*?this\.boxes = \[/)
	assert.match(page, /:disabled="submitting \|\| \(!pickingCompleted && !summary\.canSubmit\)"/)
	assert.match(page, /submitButtonText\(\)[\s\S]*?return this\.pickingCompleted \? '继续装柜取证'/)
	assert.match(page, /submitStatusHint\(\)[\s\S]*?if \(this\.pickingCompleted\) return '拣货已完成，请继续装柜取证'/)
	const submit = page.match(/async submitPicking\(\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.doesNotMatch(submit, /completedBoxes/)
})

test('loading evidence is not requested before picking completion', () => {
	assert.match(page, /if \(this\.loadingStageReady\) \{[\s\S]*?await this\.loadLoadingEvidence\(\)/)
	const loader = page.match(/async loadLoadingEvidence\(\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(loader, /if \(!this\.loadingStageReady/)
	assert.match(loader, /await getEvidence\(/)
	assert.match(page, /this\.completedBoxes = \{[\s\S]*?this\.loadLoadingEvidence\(\)/)
})

test('operators receive actionable refresh guidance without internal version wording', () => {
	assert.match(page, /状态尚未同步，请刷新重试/)
	assert.doesNotMatch(page, /缺少拣货版本号|提供装柜版本号/)
	const complete = page.match(/async completeLoadingTask\(\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(complete, /if \(!this\.requireEvidenceStage\(\)\) return/)
	assert.match(complete, /completeContainerPickingTask\(this\.remoteTaskId/)
	assert.match(complete, /expectedTaskVersion/)
	assert.doesNotMatch(complete, /completeLoading\(inboundId/)
})

test('AWAITING_REVIEW alone cannot request or mutate server evidence without a server loading version', () => {
	assert.match(page, /loadingStageReady\(\)[\s\S]*?this\.pickingCompleted[\s\S]*?this\.loadingVersion !== null[\s\S]*?Number\.isFinite/)
	assert.match(page, /拣货已完成，装柜状态尚未同步，请刷新重试/)
	assert.match(page, /if \(!this\.loadingStageReady \|\| !this\.evidenceIdentity/)
	assert.doesNotMatch(page, /if \(this\.pickingCompleted\) await this\.loadLoadingEvidence\(\)/)
})

test('dynamic pending items withdraw evidence until the server task is picking-complete again', () => {
	assert.match(page, /class="stage-switch" role="tablist"/)
	assert.match(page, /@tap="selectStage\('picking'\)"/)
	assert.match(page, /@tap="selectStage\('evidence'\)"/)
	assert.match(page, /selectStage\(stage\) \{[\s\S]*?stage === 'evidence' && !this\.loadingStageReady[\s\S]*?请先完成新增待拣明细[\s\S]*?return[\s\S]*?this\.activeStage = stage/)
	assert.match(page, /class="stage-tab"[\s\S]*?:disabled="!loadingStageReady"[\s\S]*?装柜取证/)
	assert.match(page, /activeStage === 'picking'/)
	assert.match(page, /:disabled="submitting \|\| !loadingStageReady \|\| pickingVersion === null/)
})

test('incremental refresh merges new pending items without overwriting submitted server results', () => {
	const restore = page.match(/restoreRemoteDraft\(\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(restore, /const serverStates = \{ \.\.\.this\.itemStates \}/)
	assert.match(restore, /serverStates\[id\] !== ITEM_STATUS\.PENDING/)
	assert.match(restore, /status === ITEM_STATUS\.PARTIAL[\s\S]*?partial >= Number\(item\?\.qty/)
	assert.match(restore, /this\.remotePick && !isPickingCompleteTask\(this\.remotePick\)[\s\S]*?delete completedBoxes\[this\.currentBoxIndex\]/)
	assert.match(page, /const previousTaskVersion = this\.pickingVersion/)
	assert.match(page, /const previousItemIds = new Set/)
	assert.match(page, /previousEvidenceState[\s\S]*?isSameEvidenceIdentity\(previousEvidenceState\.identity, this\.evidenceIdentity\)[\s\S]*?this\.evidenceFiles = \{ \.\.\.this\.evidenceFiles, \.\.\.previousEvidenceState\.files \}/)
	assert.match(page, /if \(!this\.pickingCompleted\)[\s\S]*?delete completedBoxes\[this\.currentBoxIndex\][\s\S]*?this\.activeStage = 'picking'/)
	assert.match(page, /refresh\.incremental[\s\S]*?addedItemIds/)
})

test('incremental batch submits only current server-pending items and refreshes stale inventory conflicts', () => {
	const submit = page.match(/async performSubmit\([^)]*\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(submit, /item\.itemStatus && !\['PENDING', 'PICKING'\]\.includes\(item\.itemStatus\)\) return null/)
	assert.match(submit, /const versionConflict = this\.isTaskConflict\(error\)/)
	assert.match(submit, /await this\.refreshAfterTaskConflict\(conflictMessage\)/)
	assert.match(submit, /const inventorySnapshot = await this\.refreshInventorySnapshot\(\)/)
	assert.match(page, /refreshAfterTaskConflict\(message\)[\s\S]*?this\.submitId = ''[\s\S]*?await this\.syncRemoteTask\(\)[\s\S]*?await this\.refreshInventorySnapshot\(\)/)
	assert.match(page, /refreshInventorySnapshot\(\)[\s\S]*?getPickingInventorySnapshot\(this\.remoteTaskId, warehouseId\)[\s\S]*?String\(snapshot\.version\) !== String\(this\.pickingVersion\)[\s\S]*?error\.code = 'A0409'/)
	assert.match(page, /this\.pickingVersion = this\.remotePick\.pickingVersion \?\? this\.remotePick\.version/)
})

test('completed detail overrides stale local state and an empty batch refreshes into evidence instead of submitting', () => {
	assert.match(page, /if \(item\.itemStatus === 'PICKED'\) serverStates\[item\.id\] = ITEM_STATUS\.PICKED/)
	assert.match(page, /if \(!this\.pickingCompleted\) this\.restoreRemoteDraft\(\)/)
	assert.match(page, /if \(this\.loadingStageReady\) \{[\s\S]*?this\.activeStage = 'evidence'[\s\S]*?await this\.loadLoadingEvidence\(\)/)
	const submit = page.match(/async submitPicking\(\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(submit, /if \(this\.pickingCompleted\)[\s\S]*?await this\.syncRemoteTask\(\)[\s\S]*?this\.activeStage = 'evidence'[\s\S]*?return/)
	const perform = page.match(/async performSubmit\([^)]*\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(perform, /if \(!actions\.length\) \{[\s\S]*?submit\.empty-refresh[\s\S]*?await this\.syncRemoteTask\(\)[\s\S]*?return/)
	assert.ok(perform.indexOf('if (!actions.length)') < perform.indexOf('submitContainerPickingBatch('))
})

test('final completion preserves backend gate errors and refreshes after an atomic A0409', () => {
	const complete = page.match(/async completeLoadingTask\(\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(complete, /this\.isTaskConflict\(error\)[\s\S]*?await this\.refreshAfterTaskConflict\(error\.message \|\| '订舱、装柜关联或证据状态已变化，请刷新后重试'\)/)
	assert.doesNotMatch(complete, /拖车|trucking/i)
	const save = page.match(/async saveEvidence\([^)]*\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(save, /this\.isTaskConflict\(error\)[\s\S]*?refreshAfterTaskConflict/)
	const flush = page.match(/async flushPendingEvidence\(\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(flush, /!entry\.id && entry\.localPath/)
	assert.match(flush, /if \(item\.fileId && item\.type !== 'SEAL'\) await this\.saveEvidence\(item\.type, null, item\.path\)/)
	assert.match(flush, /else if \(item\.fileId\) continue/)
	assert.match(flush, /else await this\.queueEvidenceUpload\(item\.type, item\.path\)/)
})

test('seal photo upload waits for an explicit seal-number save', () => {
	const queue = page.match(/async queueEvidenceUpload\([^)]*\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	const retry = page.match(/async retryEvidence\([^)]*\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	const save = page.match(/async saveEvidence\([^)]*\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(queue, /if \(type === 'SEAL'\)[\s\S]*?rememberEvidenceDraft\(identity\)[\s\S]*?return[\s\S]*?saveEvidence\(type, null, path\)/)
	assert.match(retry, /if \(type === 'SEAL'\)[\s\S]*?rememberEvidenceDraft\(identity\)[\s\S]*?return[\s\S]*?saveEvidence\(type\)/)
	assert.match(save, /type === 'SEAL' && !String\(this\.sealNo \|\| ''\)\.trim\(\)[\s\S]*?请输入封签号后点击保存封签/)
	assert.match(page, /async saveSealNo\(\)[\s\S]*?await this\.saveEvidence\('SEAL'/)
	assert.match(page, /hasUnboundUploadedEvidence\(slot\.type\)[\s\S]*?照片已上传，请输入封签号并保存/)
})

test('evidence identity is bound to task, inbound, loading plan and container booking', () => {
	assert.match(page, /captureEvidenceIdentity\(\)[\s\S]*?taskId:[\s\S]*?inboundId:[\s\S]*?loadingPlanId:[\s\S]*?containerBookingId:/)
	assert.match(page, /isSameEvidenceIdentity\(left, right\)[\s\S]*?taskId[\s\S]*?inboundId[\s\S]*?loadingPlanId[\s\S]*?containerBookingId/)
	assert.match(page, /this\.currentBox\.inboundId = task\.inboundId/)
	assert.match(page, /String\(detailTaskId \|\| ''\) !== String\(requestedTaskId\)/)
	assert.match(page, /!task\.inboundId \|\| !task\.loadingPlanId \|\| !task\.containerBookingId/)
	assert.match(page, /evidenceItem[\s\S]*?String\(task\.inboundId\)/)
	assert.match(page, /this\.evidenceIdentity = this\.captureEvidenceIdentity\(\)/)
})

test('merged or non-active cabinet details are rejected before claim and clear stale local state', () => {
	const sync = page.match(/async syncRemoteTask\(\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(sync, /if \(this\.isMergedContainerRecord\(task\)\)[\s\S]*?this\.clearMergedTask\(task, previousIdentity\)[\s\S]*?return[\s\S]*?task\.recordStatus !== 'ACTIVE'[\s\S]*?claimContainerPickingTask/)
	const clear = page.match(/clearMergedTask\(task, previousIdentity\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(clear, /taskId: previousIdentity\?\.taskId \?\? task\?\.taskId/)
	assert.match(clear, /inboundId: previousIdentity\?\.inboundId \?\? task\?\.inboundId/)
	assert.match(clear, /loadingPlanId: previousIdentity\?\.loadingPlanId \?\? task\?\.loadingPlanId/)
	assert.match(clear, /containerBookingId: previousIdentity\?\.containerBookingId \?\? task\?\.containerBookingId/)
	assert.match(clear, /clearPickingDraft\(staleIdentity\)/)
	assert.match(clear, /this\.evidenceDrafts = Object\.fromEntries/)
	assert.match(clear, /this\.evidencePreviewCache = Object\.fromEntries/)
	for (const reset of ['remoteLoading = false', 'submitting = false', 'remoteTaskId = null', 'loadingVersion = null', 'scanHistory = []', 'currentBox.containerBookingId = null', 'currentBox.currentContainerNo = null', 'resetEvidenceState()']) assert.match(clear, new RegExp(reset.replace(/[.()[\]]/g, '\\$&')))
})

test('server evidence mutations remain closed before the loading stage is ready', () => {
	assert.match(page, /requireEvidenceStage\(\)[\s\S]*?if \(!this\.pickingCompleted\)[\s\S]*?请先提交拣货完成[\s\S]*?if \(!this\.loadingStageReady\)/)
	const queue = page.match(/async queueEvidenceUpload\([^)]*\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(queue, /if \(!this\.loadingStageReady\) return/)
	for (const method of ['retryEvidence', 'saveEvidence', 'voidEvidencePhoto', 'completeLoadingTask']) {
		const body = page.match(new RegExp(`(?:async )?${method}\\([^)]*\\) \\{[\\s\\S]*?\\n\\t\\t\\t\\},`))?.[0] || ''
		assert.match(body, /if \(!this\.requireEvidenceStage\(\)\)(?: return| \{)/, `${method} should guard the evidence stage`)
	}
})

test('refresh preserves local photos for the same evidence identity and flushes them after loading readiness', () => {
	assert.match(page, /this\.rememberEvidenceDraft\(\)/)
	assert.match(page, /this\.restoreEvidenceDraft\(\)/)
	assert.match(page, /async flushPendingEvidence\(\)[\s\S]*?queueEvidenceUpload/)
	assert.match(page, /const localFiles = Object\.fromEntries/)
})

test('evidence photos render thumbnails and support full-screen preview', () => {
	assert.match(page, /class="evidence-thumbnail" :src="evidencePreviewSource\(photo\)"/)
	assert.match(page, /class="work-content" :class="\{ 'evidence-active': activeStage === 'evidence' && loadingStageReady \}"/)
	assert.match(page, /class="evidence-photo-grid"/)
	assert.match(page, /class="evidence-count"/)
	assert.match(page, /@tap="previewEvidencePhoto\(photo, slot\.type\)"/)
	assert.match(page, /evidencePreviewSource\(photo\)[\s\S]*?localPath[\s\S]*?fileUrl/)
	assert.match(page, /previewEvidencePhoto\(photo, type\)[\s\S]*?uni\.previewImage\([\s\S]*?current[\s\S]*?urls/)
	assert.match(page, /cacheEvidencePreview\(fileId, localPath/)
	assert.match(page, /withCachedEvidencePreview\(photo[\s\S]*?evidencePreviewCache/)
	assert.match(page, /item\.previewUrl \|\| getEvidencePreviewUrl\(identity\.inboundId, item\.id, this\.currentBox\.tenantId\)/)
	assert.match(page, /['"]list\.loaded['"]/)
	assert.match(page, /loadEvidencePreviews\(contextId, identity\)[\s\S]*?downloadEvidencePreview\(item\.previewUrl\)/)
	assert.match(page, /['"]preview\.downloaded['"]/)
	assert.match(page, /已上传并保存/)
})

test('switching cabinets invalidates old sync and evidence upload state', () => {
	const selector = page.match(/selectBox\(index\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(selector, /this\.taskRequestId \+= 1/)
	assert.match(selector, /this\.pickingVersion = null/)
	assert.match(selector, /this\.loadingVersion = null/)
	assert.match(selector, /this\.submitting = false/)
	assert.match(selector, /this\.resetEvidenceState\(\)/)
	assert.match(page, /!this\.isEvidenceContextActive\(contextId, identity\) \|\| queue !== this\.evidenceQueue/)
	const loader = page.match(/async loadLoadingEvidence\(\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.ok((loader.match(/isEvidenceContextActive\(contextId, identity\)/g) || []).length >= 2)
})

test('camera callbacks cannot append evidence after switching cabinets', () => {
	const chooser = page.match(/chooseEvidence\(slot\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(chooser, /const contextId = this\.evidenceContextId/)
	assert.match(chooser, /const identity = \{ \.\.\.this\.evidenceIdentity \}/)
	assert.equal((chooser.match(/isEvidenceContextActive\(contextId, identity\)/g) || []).length, 2)
	assert.match(chooser, /isEvidenceContextActive\(contextId, identity\)[\s\S]*?this\.evidenceFiles =/)
})

test('returning from the camera does not refresh and invalidate the active evidence context', () => {
	assert.match(page, /cameraPicking: false/)
	assert.match(page, /onShow\(\) \{[\s\S]*?if \(this\.cameraPicking\)[\s\S]*?choose\.resume[\s\S]*?return[\s\S]*?this\.syncRemoteTask\(\)/)
	const chooser = page.match(/chooseEvidence\(slot\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(chooser, /this\.cameraPicking = true/)
	assert.match(chooser, /success: \(result\) => \{[\s\S]*?this\.cameraPicking = false/)
	assert.match(chooser, /fail: \(error\) => \{[\s\S]*?this\.cameraPicking = false/)
})

test('returning from an image preview does not refresh the picking task', () => {
	assert.match(page, /evidencePreviewOpening: false, evidencePreviewReturning: false/)
	assert.match(page, /onShow\(\) \{[\s\S]*?if \(this\.evidencePreviewReturning\)[\s\S]*?preview\.resume[\s\S]*?return[\s\S]*?this\.syncRemoteTask\(\)/)
	assert.match(page, /onHide\(\) \{[\s\S]*?if \(this\.evidencePreviewOpening\)[\s\S]*?this\.evidencePreviewReturning = true/)
	const preview = page.match(/previewEvidencePhoto\(photo, type\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(preview, /this\.evidencePreviewOpening = true/)
	assert.match(preview, /uni\.previewImage\(\{ current, urls, fail:/)
})

test('evidence save, void and loading completion ignore stale cabinet responses', () => {
	for (const [method, awaitedCall] of [
		['saveEvidence', 'upsertEvidence'],
		['voidEvidencePhoto', 'voidEvidence'],
		['completeLoadingTask', 'completeContainerPickingTask']
	]) {
		const body = page.match(new RegExp(`async ${method}\\([^)]*\\) \\{[\\s\\S]*?\\n\\t\\t\\t\\},`))?.[0] || ''
		assert.match(body, /const contextId = this\.evidenceContextId/, `${method} should capture the evidence context`)
		assert.match(body, /const identity = \{ \.\.\.this\.evidenceIdentity \}/, `${method} should capture stable evidence identity`)
		assert.match(body, new RegExp(`await ${awaitedCall}\\([\\s\\S]*?if \\(!this\\.isEvidenceContextActive\\(contextId, identity\\)\\) return`), `${method} should guard the success writeback`)
		assert.ok((body.match(/isEvidenceContextActive\(contextId, identity\)/g) || []).length >= 2, `${method} should guard success and error writebacks`)
	}
	const complete = page.match(/async completeLoadingTask\([^)]*\) \{[\s\S]*?\n\t\t\t\},/)?.[0] || ''
	assert.match(complete, /finally \{[\s\S]*?isEvidenceContextActive\(contextId, identity\)[\s\S]*?this\.submitting = false/)
})

test('completed server tasks restore evidence stage without being claimed again', () => {
	assert.match(page, /const remoteTask = normalizePickingTask\(task\)/)
	assert.match(page, /remoteTask\.workflowStatus !== 'AWAITING_REVIEW' && this\.assignmentVersion === null/)
	assert.match(page, /if \(remoteTask\.workflowStatus === 'UNASSIGNED'\) \{[\s\S]*?claimContainerPickingTask/)
	assert.match(page, /else if \(!isPickingCompleteTask\(remoteTask\)\)/)
	assert.match(page, /if \(this\.loadingStageReady\) \{[\s\S]*?this\.activeStage = 'evidence'[\s\S]*?await this\.loadLoadingEvidence\(\)/)
})

test('picking mutations stay closed until the canonical task has been claimed', () => {
	assert.match(page, /pickingOperationReady\(\)[\s\S]*?workflowStatus === 'IN_PROGRESS'[\s\S]*?remoteTaskId[\s\S]*?inboundId[\s\S]*?loadingPlanId[\s\S]*?containerBookingId/)
	assert.match(page, /requirePickingOperation\(\)[\s\S]*?任务尚未领取完成/)
	for (const method of ['processScannedValue', 'pickItem', 'openSkip', 'openPartial', 'submitPicking']) {
		const body = page.match(new RegExp(`${method}\\([^)]*\\) \\{[\\s\\S]*?\\n\\t\\t\\t\\},`))?.[0] || ''
		assert.match(body, /if \(!this\.requirePickingOperation\(\)\) return/, `${method} should wait for claim`)
	}
})

test('completion shows a Chinese server failure with a request correlation id', () => {
	assert.match(page, /remoteFailureMessage\(error, fallback = '操作失败'\)/)
	assert.match(page, /\^internal server error\$\/i/)
	assert.match(page, /服务端处理异常，请联系管理员/)
	assert.match(page, /请求编号/)
	assert.match(page, /requestIdFromServer: error\.requestId/)
	assert.match(page, /this\.remoteFailureMessage\(error, '装柜完成失败'\)/)
})