优化撤单处理方式

apps/backend/src/repositories/worker-platform/work-order-repo.ts

@@ -1295,9 +1295,106 @@ export async function unassignWorkOrder(input: {
   })
 }
 
+export async function returnAssignedWorkOrderToHall(input: {
+  workOrderId: number
+  now: string
+  reason?: string
+}): Promise<{
+  order: WorkOrderRow | null
+  failureReason: 'work_order_not_in_progress' | 'work_order_no_worker' | null
+}> {
+  return withTransaction(async (client) => {
+    const currentResult = await client.query<WorkOrderRow>(
+      `
+        SELECT *
+        FROM work_orders
+        WHERE id = $1
+        FOR UPDATE
+      `,
+      [input.workOrderId],
+    )
+    const workOrder = currentResult.rows[0] || null
+    if (!workOrder || workOrder.status !== 'in_progress') {
+      return { order: null, failureReason: 'work_order_not_in_progress' }
+    }
+    const workerId = Number(workOrder.assigned_worker_id || 0)
+    if (!workerId) {
+      return { order: null, failureReason: 'work_order_no_worker' }
+    }
+
+    await ensureWorkerWalletWithClient(client, workerId, input.now)
+    const wallet = await getWorkerWalletWithClient(client, workerId)
+    const releaseAmount = Math.min(
+      await getOutstandingDepositAmountWithClient(client, workerId, input.workOrderId),
+      Number(wallet?.frozen_deposit_amount || 0),
+    )
+
+    await client.query(
+      `
+        UPDATE work_orders
+        SET
+          status = 'open',
+          assigned_worker_id = NULL,
+          assigned_at = NULL,
+          deadline_at = NULL,
+          published_at = $1,
+          updated_at = $1
+        WHERE id = $2
+      `,
+      [input.now, input.workOrderId],
+    )
+
+    if (releaseAmount > 0) {
+      const nextAvailable = Number(wallet?.available_amount || 0) + releaseAmount
+      const nextFrozen = Math.max(
+        0,
+        Number(wallet?.frozen_deposit_amount || 0) - releaseAmount,
+      )
+      await client.query(
+        `
+          UPDATE worker_wallets
+          SET available_amount = $1, frozen_deposit_amount = $2, updated_at = $3
+          WHERE worker_id = $4
+        `,
+        [nextAvailable, nextFrozen, input.now, workerId],
+      )
+      await client.query(
+        `
+          INSERT INTO worker_wallet_ledgers (
+            worker_id, ledger_type, amount, balance_after, frozen_after,
+            related_work_order_id, note, payload_json, created_at
+          ) VALUES ($1, 'deposit_release', $2, $3, $4, $5, '后台退回大厅退还押金', '{}'::jsonb, $6)
+        `,
+        [workerId, releaseAmount, nextAvailable, nextFrozen, input.workOrderId, input.now],
+      )
+    }
+
+    await createWorkOrderEventWithClient(client, {
+      workOrderId: input.workOrderId,
+      actorType: 'admin',
+      actorId: '',
+      eventType: 'returned_to_hall_by_admin',
+      fromStatus: 'in_progress',
+      toStatus: 'open',
+      payloadJson: JSON.stringify({
+        workerId,
+        releaseAmount,
+        reason: String(input.reason || '').trim(),
+      }),
+      now: input.now,
+    })
+
+    return {
+      order: await getWorkOrderByIdWithClient(client, input.workOrderId),
+      failureReason: null,
+    }
+  })
+}
+
 export async function cancelAssignedWorkOrder(input: {
   workOrderId: number
   now: string
+  reason?: string
 }): Promise<{
   order: WorkOrderRow | null
   failureReason: 'work_order_not_in_progress' | 'work_order_no_worker' | null
@@ -1375,7 +1472,11 @@ export async function cancelAssignedWorkOrder(input: {
       eventType: 'cancelled_by_admin',
       fromStatus: 'in_progress',
       toStatus: 'cancelled',
-      payloadJson: JSON.stringify({ workerId, releaseAmount }),
+      payloadJson: JSON.stringify({
+        workerId,
+        releaseAmount,
+        reason: String(input.reason || '').trim(),
+      }),
       now: input.now,
     })
 

apps/backend/src/routes/admin/worker-platform.ts

@@ -386,12 +386,15 @@ router.post(
 router.post(
   '/worker-platform/orders/:workOrderId/cancel',
   requireAdminRoles(['admin', 'operator', 'support']),
-  createJsonHandler((req) => cancelAdminWorkOrder(String(req.params.workOrderId || '')), {
-    successMessage: '订单已撤单，打手额度已恢复',
+  createJsonHandler((req) => cancelAdminWorkOrder(String(req.params.workOrderId || ''), req.body || {}), {
+    successMessage: '撤单处理完成，打手额度已恢复',
     errorMessage: '撤单失败',
     scope: '[admin/worker-platform/orders/:workOrderId/cancel]',
     audit: (req, data) => ({
-      action: 'work_order_cancelled',
+      action:
+        String(req.body?.action || '').trim() === 'return_to_hall'
+          ? 'work_order_returned_to_hall'
+          : 'work_order_cancelled',
       targetType: 'work_order',
       targetId: String(req.params.workOrderId || ''),
       data: data && typeof data === 'object' ? (data as Record<string, unknown>) : {},

apps/backend/src/services/worker-platform/admin-service.ts

@@ -7,6 +7,7 @@ import {
   addWorkerWalletCredit,
   assignWorkOrderToWorker,
   cancelAssignedWorkOrder,
+  returnAssignedWorkOrderToHall,
   unassignWorkOrder,
   countWorkerAcceptedOrders,
   countWorkerActiveOrders,
@@ -1258,7 +1259,10 @@ export async function unassignAdminWorkOrder(workOrderId: number | string) {
   return { order: mapWorkOrderAdmin(updated) }
 }
 
-export async function cancelAdminWorkOrder(workOrderId: number | string) {
+export async function cancelAdminWorkOrder(
+  workOrderId: number | string,
+  payload: JsonObject = {},
+) {
   const workOrder = await getRequiredWorkOrder(workOrderId)
   if (
     workOrder.status !== WORK_ORDER_STATUS.IN_PROGRESS ||
@@ -1269,10 +1273,29 @@ export async function cancelAdminWorkOrder(workOrderId: number | string) {
       errorCode: 'work_order_cancel_status_invalid',
     })
   }
-  const { order: updated, failureReason } = await cancelAssignedWorkOrder({
+  const action = String(payload.action || '').trim()
+  if (!['return_to_hall', 'cancel_order'].includes(action)) {
+    throw createHttpError('请选择撤单处理方式', {
+      statusCode: 400,
+      errorCode: 'work_order_cancel_action_required',
+    })
+  }
+  const reason = String(payload.reason || '').trim()
+  if (action === 'cancel_order' && !reason) {
+    throw createHttpError('取消订单时请填写退款或撤单原因', {
+      statusCode: 400,
+      errorCode: 'work_order_cancel_reason_required',
+    })
+  }
+  const input = {
     workOrderId: workOrder.id,
     now: nowIso(),
-  })
+    reason,
+  }
+  const { order: updated, failureReason } =
+    action === 'return_to_hall'
+      ? await returnAssignedWorkOrderToHall(input)
+      : await cancelAssignedWorkOrder(input)
   if (failureReason === 'work_order_not_in_progress') {
     throw createHttpError('订单状态已变化，无法撤单', {
       statusCode: 409,
@@ -1291,7 +1314,7 @@ export async function cancelAdminWorkOrder(workOrderId: number | string) {
       errorCode: 'work_order_cancel_conflict',
     })
   }
-  return { order: mapWorkOrderAdmin(updated) }
+  return { order: mapWorkOrderAdmin(updated), action }
 }
 
 export async function getAdminWorkerPlatformSummary() {