同步飞飞核销券状态

apps/backend/src/services/fulfillment/kuaishou-feifei/index.ts

@@ -1,6 +1,7 @@
 import { createTaskEvent } from '../../../repositories/task-event-repo.js'
 import { updateTask } from '../../../repositories/task-repo.js'
 import { createHttpError } from '../../../utils/http.js'
+import { logIntegration } from '../../../utils/logger.js'
 import { parseTaskContext } from '../../../utils/task-json.js'
 import { nowIso } from '../../../utils/time.js'
 import { TASK_STATUS } from '../../../domain/task-status.js'
@@ -9,6 +10,7 @@ import {
   queryKuaishouFeifeiOrder,
 } from '../../platforms/kuaishou-feifei/order-service.js'
 import { consumeKuaishouIndustryVouchersForTask } from '../../platforms/kuaishou-industry/voucher-service.js'
+import { buildKuaishouIndustryVoucherContext } from '../../platforms/kuaishou-industry/voucher-binding-service.js'
 import type { TaskRow } from '../../../types/repository/rows.js'
 
 type JsonObject = Record<string, any>
@@ -127,6 +129,7 @@ export async function syncKuaishouFeifeiTaskStatus(task: TaskRow) {
     syncedAt: now,
     claimUrl: resolveKuaishouFeifeiOrderClaimUrl(order) || resolveKuaishouFeifeiClaimUrl(flow),
   })
+  let nextIndustryVoucher = taskContext.kuaishouIndustryVoucher
 
   if (order.rechargeStatus === 30) {
     const consumeResult = await consumeKuaishouIndustryVouchersForTask(task, {
@@ -134,6 +137,7 @@ export async function syncKuaishouFeifeiTaskStatus(task: TaskRow) {
       consumeType: 'delivery',
       consumeTime: Date.now(),
     })
+    const consumedVoucher = consumeResult.consumed[0] || null
 
     if (consumeResult.ok || consumeResult.vouchers.length === 0) {
       nextTaskStatus = TASK_STATUS.COMPLETED
@@ -143,12 +147,35 @@ export async function syncKuaishouFeifeiTaskStatus(task: TaskRow) {
       resultMessage = order.rechargeStatusLabel || 'kuaishou-feifei 履约成功'
       lastError = ''
       nextFlow.consumeStatus = consumeResult.vouchers.length > 0 ? 'success' : 'not_required'
+      if (consumedVoucher) {
+        nextIndustryVoucher = buildKuaishouIndustryVoucherContext(
+          consumedVoucher,
+          taskContext.kuaishouIndustryVoucher,
+          now,
+        )
+      }
+      logIntegration('[kuaishou-feifei]', '飞飞履约完成，行业电子凭证核销处理完成', {
+        taskId: task.id,
+        platformOrderNo: nextFlow.platformOrderNo,
+        orderNo: nextFlow.orderNo,
+        voucherCount: consumeResult.vouchers.length,
+        consumedCount: consumeResult.consumed.length,
+        consumeStatus: nextFlow.consumeStatus,
+      })
     } else {
       nextTaskStatus = TASK_STATUS.MANUAL_REVIEW
       resultCode = 'kuaishou_feifei_industry_consume_failed'
       resultMessage = consumeResult.failed[0]?.errorMessage || '电子凭证核销失败，请人工处理'
       lastError = resultMessage
       nextFlow.consumeStatus = 'failed'
+      logIntegration('[kuaishou-feifei]', '飞飞履约完成，但行业电子凭证核销失败', {
+        taskId: task.id,
+        platformOrderNo: nextFlow.platformOrderNo,
+        orderNo: nextFlow.orderNo,
+        voucherCount: consumeResult.vouchers.length,
+        failedCount: consumeResult.failed.length,
+        errorMessage: resultMessage,
+      }, { level: 'warn' })
     }
   } else if ([40, 50, 60].includes(order.rechargeStatus)) {
     nextTaskStatus = order.rechargeStatus === 60 ? TASK_STATUS.CLOSED : TASK_STATUS.MANUAL_REVIEW
@@ -167,6 +194,7 @@ export async function syncKuaishouFeifeiTaskStatus(task: TaskRow) {
     context_json: JSON.stringify({
       ...taskContext,
       kuaishouFeifei: nextFlow,
+      kuaishouIndustryVoucher: nextIndustryVoucher,
     }),
     updated_at: now,
   })