task-65(ASIN 数据中心): 实现去重汇总导入任务创建
dedupe-import-model.ts 纯解析 importId + isAllowedImportFile(xlsx/xls);dedupe-import-api.ts startDedupeImport 以 FormData(file+groupId) multipart POST /api/admin/dedupe-total-data/import。 8 用例全过,475 单测 + build 绿。
This commit is contained in:
@@ -0,0 +1,13 @@
|
|||||||
|
/** 去重汇总导入启动适配(任务 65):multipart POST /import(file+groupId) → importId。 */
|
||||||
|
import { http } from '@/api/http'
|
||||||
|
import { parseDedupeImportStart } from './dedupe-import-model'
|
||||||
|
|
||||||
|
export const DEDUPE_IMPORT_ENDPOINT = '/api/admin/dedupe-total-data/import'
|
||||||
|
|
||||||
|
export async function startDedupeImport(file: File, groupId: number): Promise<string> {
|
||||||
|
const form = new FormData()
|
||||||
|
form.append('file', file, file.name)
|
||||||
|
form.append('groupId', String(groupId))
|
||||||
|
const { data } = await http.post<unknown>(DEDUPE_IMPORT_ENDPOINT, form)
|
||||||
|
return parseDedupeImportStart(data)
|
||||||
|
}
|
||||||
@@ -0,0 +1,18 @@
|
|||||||
|
/** 去重汇总导入模型(任务 65):启动结果解析 + xlsx 文件校验,纯逻辑。 */
|
||||||
|
import { unwrap } from '../../api/envelope.ts'
|
||||||
|
|
||||||
|
export const DEDUPE_IMPORT_ALLOWED_EXT = /\.(xlsx|xls)$/i
|
||||||
|
|
||||||
|
/** 是否为允许导入的 Excel 文件。 */
|
||||||
|
export function isAllowedImportFile(fileName: unknown): boolean {
|
||||||
|
return typeof fileName === 'string' && DEDUPE_IMPORT_ALLOWED_EXT.test(fileName.trim())
|
||||||
|
}
|
||||||
|
|
||||||
|
/** 解包导入启动结果并取回 importId;缺省抛可读错误。 */
|
||||||
|
export function parseDedupeImportStart(payload: unknown): string {
|
||||||
|
const data = unwrap<unknown>(payload)
|
||||||
|
const record = data && typeof data === 'object' ? (data as Record<string, unknown>) : null
|
||||||
|
const importId = typeof record?.importId === 'string' ? record.importId.trim() : ''
|
||||||
|
if (!importId) throw new Error('导入任务响应异常:缺少任务 ID')
|
||||||
|
return importId
|
||||||
|
}
|
||||||
@@ -0,0 +1,55 @@
|
|||||||
|
import test from 'node:test'
|
||||||
|
import assert from 'node:assert/strict'
|
||||||
|
import { readSource } from './helpers.ts'
|
||||||
|
import { isAllowedImportFile, parseDedupeImportStart } from '../src/pages/asin/dedupe-import-model.ts'
|
||||||
|
|
||||||
|
test('test_task_065_dedupe_import_start_normal_primary_path', () => {
|
||||||
|
// 正常主路径:启动结果 {importId} 解析出任务 id。
|
||||||
|
assert.equal(parseDedupeImportStart({ success: true, data: { importId: 'job_123' } }), 'job_123')
|
||||||
|
})
|
||||||
|
|
||||||
|
test('test_task_065_dedupe_import_start_normal_variant_input', () => {
|
||||||
|
// 正常变体:已解包对象直传同样解析。
|
||||||
|
assert.equal(parseDedupeImportStart({ importId: 'job_456' }), 'job_456')
|
||||||
|
})
|
||||||
|
|
||||||
|
test('test_task_065_dedupe_import_start_normal_repeated_operation_is_idempotent', () => {
|
||||||
|
// 正常重复:解析纯函数稳定。
|
||||||
|
const payload = { success: true, data: { importId: 'job_abc' } }
|
||||||
|
assert.equal(parseDedupeImportStart(payload), parseDedupeImportStart(payload))
|
||||||
|
})
|
||||||
|
|
||||||
|
test('test_task_065_dedupe_import_start_boundary_empty_input', () => {
|
||||||
|
// 边界空值:缺 importId → 可读错误。
|
||||||
|
assert.throws(() => parseDedupeImportStart({ success: true, data: {} }), /导入任务/)
|
||||||
|
assert.throws(() => parseDedupeImportStart({}), /导入任务/)
|
||||||
|
})
|
||||||
|
|
||||||
|
test('test_task_065_dedupe_import_start_boundary_single_item', () => {
|
||||||
|
// 边界单元素:.xlsx 文件名合法。
|
||||||
|
assert.equal(isAllowedImportFile('import.xlsx'), true)
|
||||||
|
})
|
||||||
|
|
||||||
|
test('test_task_065_dedupe_import_start_boundary_limit_or_missing_field', () => {
|
||||||
|
// 边界上限:非 xlsx(xls 允许)被拒;空文件名被拒。
|
||||||
|
assert.equal(isAllowedImportFile('data.csv'), false)
|
||||||
|
assert.equal(isAllowedImportFile('data.xls'), true)
|
||||||
|
assert.equal(isAllowedImportFile(''), false)
|
||||||
|
assert.equal(isAllowedImportFile(undefined as never), false)
|
||||||
|
})
|
||||||
|
|
||||||
|
test('test_task_065_dedupe_import_start_invalid_input_rejected', () => {
|
||||||
|
// 异常输入:success=false 抛后端 message。
|
||||||
|
assert.throws(() => parseDedupeImportStart({ success: false, message: '文件不合法或缺少 ASIN 列' }), /文件不合法/)
|
||||||
|
})
|
||||||
|
|
||||||
|
test('test_task_065_dedupe_import_start_dependency_failure_returns_actionable_message', () => {
|
||||||
|
// 依赖失败/导入走 adapter:multipart POST /import(file+groupId),页面不内联。
|
||||||
|
const api = readSource('src/pages/asin/dedupe-import-api.ts')
|
||||||
|
assert.match(api, /startDedupeImport/)
|
||||||
|
assert.match(api, /http\.post/)
|
||||||
|
assert.match(api, /\/import/)
|
||||||
|
assert.match(api, /FormData/)
|
||||||
|
const mod = readSource('src/pages/asin/dedupe-import-model.ts')
|
||||||
|
assert.equal(/axios|http\./.test(mod), false, '导入模型保持纯逻辑')
|
||||||
|
})
|
||||||
Reference in New Issue
Block a user