test: cover merchant phase 5 delivery

scripts/admin-test-env-modules/phase5-overseas-fulfillment.mjs

@@ -6,6 +6,7 @@ const OPTIONS = { scenario: SCENARIO, deploymentBlocker: true }
 const DISPATCH_BASE = '/api/platform/v1/last-leg/dispatches'
 const LASTLEG_BASE = '/api/platform/v1/last-leg'
 const PDA_DISPATCH_BASE = '/api/pda/v1/last-leg/dispatches'
+const MERCHANT_DELIVERY_BASE = '/api/merchant/v1/last-leg/delivery-orders'
 
 function id(value) { return value == null ? '' : String(value) }
 function nonBlank(value) { return typeof value === 'string' && value.trim() !== '' }
@@ -41,6 +42,37 @@ async function pda(context, token, method, name, path, body = undefined) {
   context.addStep(MODULE, name, response, success(response), trace(response), OPTIONS)
   return { response, data: success(response) ? response.body?.data : null }
 }
+async function merchant(context, token, method, name, path, body = undefined) {
+  const response = await context.requestOverseas(method, path, body, {}, token)
+  const data = context.apiSuccess(MODULE, name, response, trace(response), OPTIONS)
+  return { response, data }
+}
+
+async function loginMerchant(context, customerId) {
+  const merchantFixture = context.context?.merchantQualificationFixture
+  const credentials = nonBlank(merchantFixture?.username) && nonBlank(merchantFixture?.password)
+    ? { username: merchantFixture.username, password: merchantFixture.password }
+    : { username: context.options?.merchantUsername, password: context.options?.merchantPassword }
+  if (!nonBlank(credentials.username) || !nonBlank(credentials.password)) {
+    blocker(context, '取得本轮客户工作台账号', '既无本轮动态客户凭据，也未配置开发验收客户凭据')
+    return null
+  }
+  const response = await context.request('POST', '/api/auth/login', {
+    loginId: credentials.username,
+    password: credentials.password,
+  }, '')
+  const auth = context.apiSuccess(MODULE, '本轮客户工作台账号登录', response, trace(response), OPTIONS)
+  context.assert(MODULE, '客户登录返回海外访问Token', response, nonBlank(auth?.overseasAccessToken),
+    `tokenPresent=${Boolean(auth?.overseasAccessToken)}; ${trace(response)}`, OPTIONS)
+  if (!nonBlank(auth?.accessToken) || !nonBlank(auth?.overseasAccessToken)) return null
+  const profileResponse = await context.request('GET', '/api/merchant/v1/iam/tenant/profile', undefined, auth.accessToken)
+  const profile = context.apiSuccess(MODULE, '回查客户工作台企业身份', profileResponse,
+    trace(profileResponse), OPTIONS)
+  context.assert(MODULE, '客户工作台企业与五期履约客户严格一致', profileResponse,
+    id(profile?.id) === customerId,
+    `merchantCustomer=${id(profile?.id) || 'missing'}, fulfillmentCustomer=${customerId}; ${trace(profileResponse)}`, OPTIONS)
+  return id(profile?.id) === customerId ? auth.overseasAccessToken : null
+}
 
 function fixture(context) {
   const dispatch = context.createdResources?.phase4OverseasDispatch
@@ -123,6 +155,8 @@ export async function run(context) {
   const customerId = id(source.receiving.customerId)
   const warehouseId = id(source.receiving.overseasWarehouseId)
   context.createdResources.phase5OverseasFulfillment.dispatchNo = dispatchNo
+  const merchantToken = await loginMerchant(context, customerId)
+  if (!merchantToken) return
 
   const updateBody = {
     vehiclePlate: `DEV-${context.marker.slice(-8)}`.slice(0, 64),
@@ -140,15 +174,15 @@ export async function run(context) {
 
   const transferBody = {
     idempotencyKey: key(context, 'TRANSFER'), plannedDeliveryAt: new Date(Date.now() + 172_800_000).toISOString(),
-    deliveryMethod: 'SELF_DELIVERY', waybillNo: `${context.marker}-WAYBILL`.slice(0, 64),
+    deliveryMethod: 'TRUCK_PALLET', waybillNo: `${context.marker}-WAYBILL`.slice(0, 64),
     carrierName: updateBody.carrierName, pickupMethod: 'WAREHOUSE_PICKUP', loadingType: 'PALLET',
     vehicleType: 'TRUCK', vehicleSize: 'MEDIUM', driverName: updateBody.driverName,
     driverPhone: updateBody.driverPhone, vehiclePlate: updateBody.vehiclePlate,
     appointmentAccount: 'SELF', sellerName: null, remark: `${context.marker}-phase5-transfer`,
-    fees: [{ feeType: 'DELIVERY_FEE', currency: 'USD', amount: 0, remark: `${context.marker}-acceptance` }],
+    fees: [{ feeType: 'DELIVERY_FEE', currency: 'USD', amount: 10, remark: `${context.marker}-acceptance` }],
   }
-  const transferred = await platform(context, 'POST', '排车原子转出库与派送单',
-    `${LASTLEG_BASE}/dispatches/${encodeURIComponent(dispatchNo)}/transfer-delivery`, transferBody)
+  const transferred = await merchant(context, merchantToken, 'POST', '客户创建派送并原子转出库单',
+    query(MERCHANT_DELIVERY_BASE, { dispatchNo }), transferBody)
   const outboundNo = id(transferred.data?.outboundNo)
   const deliveryNo = id(transferred.data?.deliveryNo)
   context.assert(MODULE, '转派送同时生成WAIT_OUTBOUND与WAIT_DELIVERY单据', transferred.response,
@@ -157,18 +191,33 @@ export async function run(context) {
     `outboundNo=${outboundNo || 'missing'}, deliveryNo=${deliveryNo || 'missing'}; ${trace(transferred.response)}`, OPTIONS)
   if (!success(transferred.response) || !outboundNo || !deliveryNo) return
   Object.assign(context.createdResources.phase5OverseasFulfillment, { outboundNo, deliveryNo })
-  const transferReplay = await platform(context, 'POST', '排车转派送同键重放',
-    `${LASTLEG_BASE}/dispatches/${encodeURIComponent(dispatchNo)}/transfer-delivery`, transferBody)
+  const transferReplay = await merchant(context, merchantToken, 'POST', '客户创建派送同键重放',
+    query(MERCHANT_DELIVERY_BASE, { dispatchNo }), transferBody)
   context.assert(MODULE, '转派送重放复用同一业务单据', transferReplay.response,
     transferReplay.data?.replayed === true && id(transferReplay.data?.outboundNo) === outboundNo
       && id(transferReplay.data?.deliveryNo) === deliveryNo, trace(transferReplay.response), OPTIONS)
-  const transferConflict = await context.requestOverseas('POST',
-    `${LASTLEG_BASE}/dispatches/${encodeURIComponent(dispatchNo)}/transfer-delivery`,
-    { ...transferBody, idempotencyKey: key(context, 'TRANSFER-DIFFERENT') })
+  const transferConflict = await context.requestOverseas('POST', query(MERCHANT_DELIVERY_BASE, { dispatchNo }),
+    { ...transferBody, idempotencyKey: key(context, 'TRANSFER-DIFFERENT') }, {}, merchantToken)
   context.addStep(MODULE, '同一排车使用另一幂等键仍返回既有单据', transferConflict,
     success(transferConflict) && id(transferConflict.body?.data?.outboundNo) === outboundNo
       && transferConflict.body?.data?.replayed === true, trace(transferConflict), OPTIONS)
 
+  const merchantPage = await merchant(context, merchantToken, 'GET', '客户分页回查自身派送单',
+    query(MERCHANT_DELIVERY_BASE, { page: 1, size: 20, dispatchNo }))
+  const merchantRows = Array.isArray(merchantPage.data?.records) ? merchantPage.data.records : []
+  context.assert(MODULE, '客户派送列表包含本轮单据且不依赖customerId参数', merchantPage.response,
+    merchantRows.some((value) => id(value?.deliveryNo) === deliveryNo && id(value?.dispatchNo) === dispatchNo),
+    `records=${merchantRows.length}; ${trace(merchantPage.response)}`, OPTIONS)
+  const merchantDetail = await merchant(context, merchantToken, 'GET', '客户读取自身派送详情',
+    `${MERCHANT_DELIVERY_BASE}/${encodeURIComponent(deliveryNo)}`)
+  context.assert(MODULE, '客户派送详情返回订单、货物、费用与操作四段正式契约', merchantDetail.response,
+    id(merchantDetail.data?.order?.deliveryNo) === deliveryNo
+      && id(merchantDetail.data?.order?.dispatchNo) === dispatchNo
+      && Array.isArray(merchantDetail.data?.skus) && merchantDetail.data.skus.length > 0
+      && Array.isArray(merchantDetail.data?.fees) && Array.isArray(merchantDetail.data?.operations),
+    `skus=${merchantDetail.data?.skus?.length ?? 'missing'}, fees=${merchantDetail.data?.fees?.length ?? 'missing'}, operations=${merchantDetail.data?.operations?.length ?? 'missing'}; ${trace(merchantDetail.response)}`,
+    OPTIONS)
+
   const access = await resolvePickerAccess(context)
   const picker = access ? await createPicker(context, 5, warehouseId, access) : null
   try {