当前位置：首页 > news >正文

家政维修平台实战25：工人接单

news 来源：原创 2025/6/14 7:09:02

1 创建接单API

打开订单管理，点击+号创建新方法
在这里插入图片描述
添加接单的方法

输入如下代码：

/*** ErrorCode 定义* 统一管理系统可能返回的错误码和消息。*/
const ErrorCode = {SUCCESS: 0,PARAM_ERROR: 1001,           // 参数缺失或无效NOT_FOUND: 1002,             // 订单或派工记录未找到INVALID_ORDER_STATUS: 1004,  // 订单当前主状态不允许接单INVALID_WORKER_STATUS: 1007, // 工人派工记录状态不允许接单SYSTEM_ERROR: 1003,          // 通用系统错误// 更多错误码可以按需添加
};/*** 订单在 `jz_orders` (订单主表) 中可能的主状态枚举。* (与 dispatchOrder 中的定义一致)*/
const ORDER_STATUS_ENUM = {PENDING_PAYMENT: '1',PENDING_ACCEPTANCE: '2', // 待接单 (已支付，等待派发；或已派发但工人尚未接单/已拒绝)ACCEPTED: '3',           // 已接单 (工人已接受订单)IN_SERVICE: '4',PENDING_REVIEW: '5',COMPLETED: '6',CANCELED: '7',REFUNDED: '8',
};/*** 工人在 `order_assignments` (订单派工历史表) 中可能的操作状态枚举。* (与 dispatchOrder 中的定义一致)*/
const WORKER_STATUS_ENUM = {PENDING_ACCEPTANCE: '1',  // 待接单ACCEPTED: '2',            // 已接单REJECTED: '3',            // 已拒单ON_THE_WAY: '4',IN_PROGRESS: '5',COMPLETED: '6',
};/*** 订单主表 `jz_orders` 中 `dispatchStatus` 字段的枚举。* (与 dispatchOrder 中的定义一致)*/
const DISPATCH_STATUS_ENUM = {PENDING_DISPATCH: '1',DISPATCHED_PENDING_ACCEPTANCE: '2',// 已派发待接单DISPATCHED_ACCEPTED: '3',          // 已派发已接单DISPATCHED_REJECTED: '4',          // 已派发已拒单
};/*** 工人接单函数* 工人通过此函数接受派发给他们的订单。** @param {object} params - 入参* @param {string} params.orderId - 订单ID (主键 _id)* @param {string} params.workerId - 执行此操作的工人ID (当前登录工人)* @param {object} context - 微搭云函数上下文对象* @returns {Promise<object>} 接单结果，包含 code, message, data (更新后的订单信息)*/
module.exports = async function (params, context) {const { orderId, workerId } = params;// 1. 参数验证if (!orderId || !workerId) {return { code: ErrorCode.PARAM_ERROR, message: '必填参数缺失: orderId, workerId' };}try {// 2. 查找订单的当前状态和派单状态const order = await context.callModel({dataSourceName: "jz_orders", // 订单表模型标识methodName: "wedaGetItemV2",params: {filter: {where: {_id: { $eq: orderId }}},select: { "$master": true, "dispatchStatus": true, "assignedWorkerId": true } // 获取主状态、派单状态和当前指派工人}});if (!order || Object.keys(order).length === 0) {return { code: ErrorCode.NOT_FOUND, message: '订单未找到' };}// 3. 验证订单的主状态 (`orders.status`) 是否允许接单// 只有当订单主状态为 '2' (待接单) 时，才允许工人接单。// 如果订单已是 '3' (已接单) 或其他状态，则不能重复接单。if (order.status !== ORDER_STATUS_ENUM.PENDING_ACCEPTANCE) {return {code: ErrorCode.INVALID_ORDER_STATUS,message: `订单当前主状态不允许接单。订单必须处于“待接单”状态。当前状态码: ${order.status}`};}// 4. 验证订单的派单状态 (`orders.dispatchStatus`)// 只有当订单的派单状态是“已派发待接单”时，才能执行接单操作。const currentDispatchStatus = order.dispatchStatus;if (currentDispatchStatus !== DISPATCH_STATUS_ENUM.DISPATCHED_PENDING_ACCEPTANCE) {return {code: ErrorCode.INVALID_DISPATCH_STATUS,message: `订单当前派单状态不允许接单。订单派单状态必须为“已派发待接单”。当前状态码: ${currentDispatchStatus}`};}// 5. 查找对应的 `order_assignments` 派工记录// 确保是该工人被派发且处于“待接单”状态的记录const assignment = await context.callModel({dataSourceName: "order_assignments", // 订单派工表模型标识methodName: "wedaGetItemV2",params: {filter: {relateWhere: {order_id: { where: { _id: { $eq: orderId } } },worker_id: { where: { _id: { $eq: workerId } } } // 确保是当前工人对应的派工记录},where: {worker_status: { $eq: WORKER_STATUS_ENUM.PENDING_ACCEPTANCE } // 派工记录必须是“待接单”}},select: { "$master": true } // 获取派工记录所有字段}});if (!assignment || Object.keys(assignment).length === 0) {return {code: ErrorCode.NOT_FOUND,message: '未找到该订单的有效派工记录（可能未派发给您或已处理）'};}// 6. 更新 `order_assignments` 表中的派工记录状态const updateAssignmentParams = {worker_status: WORKER_STATUS_ENUM.ACCEPTED, // 更新为 '2' (已接单)accepted_at: Date.now(),                 // 记录接单时间};await context.callModel({dataSourceName: "order_assignments",methodName: "wedaUpdateV2",params: {data: updateAssignmentParams,filter: {where: { _id: { $eq: assignment._id } } // 根据派工记录ID更新}}});// 7. 更新 `jz_orders` (订单主表) 的状态和派单状态const updateOrderParams = {status: ORDER_STATUS_ENUM.ACCEPTED,           // 订单主状态更新为 '3' (已接单)dispatchStatus: DISPATCH_STATUS_ENUM.DISPATCHED_ACCEPTED, // 派单状态更新为 '3' (已派发已接单)acceptanceTime: Date.now(),                   // 订单的接单时间 (主表的字段)};await context.callModel({dataSourceName: "jz_orders",methodName: "wedaUpdateV2",params: {data: updateOrderParams,filter: {where: { _id: { $eq: orderId } }}}});// 8. 在 `order_status_logs` (订单状态日志表) 插入日志记录const logDescription = `工人 (ID: ${workerId}) 已接单。订单主状态由 "${order.status}" 变为 "${ORDER_STATUS_ENUM.ACCEPTED}"，派单状态由 "${currentDispatchStatus}" 变为 "${DISPATCH_STATUS_ENUM.DISPATCHED_ACCEPTED}"。`;await context.callModel({dataSourceName: "order_status_logs", // 订单状态日志表模型标识methodName: "wedaCreateV2",params: {data: {orderId: { _id: orderId },eventType: '接单', // 事件类型eventDescription: logDescription,operatorRole: '工人', // 操作角色为工人operatorId: workerId, // 操作人ID为工人IDfssj: Date.now(), // 发生时间// old_status: order.status, // 记录旧的订单主状态// new_status: ORDER_STATUS_ENUM.ACCEPTED, // 记录新的订单主状态// additionalInfo: JSON.stringify({ oldDispatchStatus: currentDispatchStatus, newDispatchStatus: DISPATCH_STATUS_ENUM.DISPATCHED_ACCEPTED })}}});// 9. 通知客服或其他相关方订单已被接单console.log(`订单 ${orderId} 已被工人 ${workerId} 接单。`);// 实际应用中可能需要发送消息通知客服或客户// 10. 返回接单结果const updatedOrder = await context.callModel({dataSourceName: "jz_orders",methodName: "wedaGetItemV2",params: {filter: {where: { _id: { $eq: orderId } }},select: { "$master": true, "assignedWorkerId": true, "dispatchStatus": true }}});return {code: ErrorCode.SUCCESS,message: '订单接单成功',data: updatedOrder // 返回更新后的订单信息};} catch (error) {console.error("acceptOrder error:", error);return {code: ErrorCode.SYSTEM_ERROR,message: `系统错误: ${error.message}`};}
};