后端迁移Agiso解析模块

This commit is contained in:
yml
2026-05-21 15:09:03 +08:00
parent a2d029c7da
commit 0da7666aa0
2 changed files with 16 additions and 6 deletions
@@ -1,6 +1,8 @@
import { parseJsonObject } from '../../utils/json.js' import { parseJsonObject } from '../../utils/json.js'
export function extractAgisoTradePayload(body) { type JsonObject = Record<string, unknown>
export function extractAgisoTradePayload(body: unknown): JsonObject {
const normalizedBody = normalizeRecord(body) const normalizedBody = normalizeRecord(body)
const rawJson = String(normalizedBody.json || normalizedBody.JSON || '').trim() const rawJson = String(normalizedBody.json || normalizedBody.JSON || '').trim()
@@ -11,7 +13,7 @@ export function extractAgisoTradePayload(body) {
return normalizedBody return normalizedBody
} }
export function resolveAgisoTradePlatformOrderId(payload) { export function resolveAgisoTradePlatformOrderId(payload: unknown): string {
const normalizedPayload = normalizeRecord(payload) const normalizedPayload = normalizeRecord(payload)
const firstItem = extractAgisoTradeOrderItemSources(normalizedPayload)[0] || {} const firstItem = extractAgisoTradeOrderItemSources(normalizedPayload)[0] || {}
@@ -28,7 +30,7 @@ export function resolveAgisoTradePlatformOrderId(payload) {
]) ])
} }
export function extractAgisoTradeOrderItemSources(payload) { export function extractAgisoTradeOrderItemSources(payload: unknown): JsonObject[] {
const normalizedPayload = normalizeRecord(payload) const normalizedPayload = normalizeRecord(payload)
const candidates = [ const candidates = [
normalizedPayload.items, normalizedPayload.items,
@@ -52,11 +54,11 @@ export function extractAgisoTradeOrderItemSources(payload) {
return [] return []
} }
function normalizeRecord(value) { function normalizeRecord(value: unknown): JsonObject {
return value && typeof value === 'object' && !Array.isArray(value) ? value : {} return value && typeof value === 'object' && !Array.isArray(value) ? value as JsonObject : {}
} }
function pickFirstNonEmpty(values) { function pickFirstNonEmpty(values: unknown[]): string {
for (const value of values) { for (const value of values) {
if (typeof value === 'string' && value.trim()) { if (typeof value === 'string' && value.trim()) {
return value.trim() return value.trim()
@@ -381,6 +381,14 @@
- `npm run typecheck` - `npm run typecheck`
- `npm run build` - `npm run build`
- `npm test` 共 139 个用例通过 - `npm test` 共 139 个用例通过
68. Agiso webhook 解析基础模块迁移到 `.ts`
- `src/services/order/agiso-trade-parsing.ts`
69. Agiso webhook 原始 payload、订单号解析、商品来源数组提取已显式类型化
70. Docker 内验证通过:
- `src/services/order/agiso-trade-parsing.test.js``src/services/order/webhook-service.test.js` 共 12 个用例通过
- `npm run typecheck`
- `npm run build`
- `npm test` 共 139 个用例通过
## 下一步建议 ## 下一步建议