同城上门家政系统开发实践：多技师派单与服务流程设计

 用户小程序
 |
技师端 ---- API服务层 ---- 平台管理后台
 |
数据库（MySQL + Redis）

CREATE TABLE technician (
 id INT PRIMARY KEY AUTO_INCREMENT,
 name VARCHAR(50) COMMENT '技师姓名',
 phone VARCHAR(20) COMMENT '联系电话',
 avatar VARCHAR(255) COMMENT '头像',
 skill_tags VARCHAR(200) COMMENT '技能标签，逗号分隔',
 service_radius INT COMMENT '可服务半径(公里)',
 lat DECIMAL(10,6) COMMENT '当前位置纬度',
 lng DECIMAL(10,6) COMMENT '当前位置经度',
 avg_score DECIMAL(3,2) COMMENT '平均服务评分',
 status TINYINT DEFAULT 0 COMMENT '0待审核 1正常接单 2禁用',
 is_online TINYINT DEFAULT 0 COMMENT '0离线 1在线接单',
 create_time DATETIME
);

router.get('/service/list', async(req,res)=>{
    const serviceList = await ServiceItem.findAll({
        where:{
            status:1
        }
    })
    res.json({
        code:200,
        data:serviceList
    })
})

function calculateWorkOrderAmount(serviceItem, params){
    let total = serviceItem.price;
    // 加急费、夜间服务费附加计算
    if(params.is_urgent){
        total += params.urgent_fee;
    }
    return total;
}

async function createWorkOrder(userId,serviceItem,params){
    const amount = calculateWorkOrderAmount(serviceItem,params);
    const workOrder = await WorkOrder.create({
        user_id:userId,
        service_id:serviceItem.id,
        appoint_time:params.appointTime,
        address:params.address,
        remark:params.remark,
        user_lat:params.userLat,
        user_lng:params.userLng,
        amount:amount,
        status:'待支付'
    })
    return workOrder;
}

待支付
 |
已支付
 |
待派单
 |
技师已接单
 |
技师出发上门
 |
上门签到
 |
服务进行中
 |
待用户验收
 |
已完成

const dispatchStatus = {
    WAIT_DISPATCH:1,    //待派单
    AUTO_PUSH:2,        //系统已推送
    GRAB_ORDER_POOL:3,  //抢单池中
    TECH_ACCEPT:4,      //技师已接单
    ON_THE_WAY:5,       //正在前往
    ARRIVED:6,          //已上门签到
    SERVICING:7,        //服务进行中
    WAIT_CHECK:8,      //待用户验收
    FINISH:9            //订单完成
}

router.post('/technician/grabOrder',async(req,res)=>{
    let orderId = req.body.orderId;
    let techId = req.body.techId;
    const orderInfo = await WorkOrder.findByPk(orderId);
    if(orderInfo.dispatch_status !== dispatchStatus.GRAB_ORDER_POOL){
        return res.json({code:500,message:"该工单不可抢单"})
    }
    await WorkOrder.update({
        technician_id:techId,
        dispatch_status:dispatchStatus.TECH_ACCEPT
    },{
        where:{id:orderId}
    })
    res.json({message:"抢单接单成功"})
})

// 简化版自动派单，筛选周边符合条件技师
async function autoDispatch(workOrder){
    //从Redis获取用户地址周边在线、技能匹配技师列表
    const techList = await getNearAvailableTechnician(workOrder.user_lat,workOrder.user_lng,workOrder.service_id);
    if(techList.length === 0){
        //无匹配技师，转入抢单池
        await WorkOrder.update({dispatch_status:dispatchStatus.GRAB_ORDER_POOL},{where:{id:workOrder.id}});
        return false;
    }
    //业务中可增加加权打分，此处取列表首位技师演示
    const targetTech = techList[0];
    await WorkOrder.update({
        technician_id:targetTech.id,
        dispatch_status:dispatchStatus.TECH_ACCEPT
    },{where:{id:workOrder.id}});
    return true;
}

function getServiceRoute(start,end){
    return axios.get(
        "[https://api.map.com/direction](https://api.map.com/direction)",
        {
            params:{
                origin:start,
                destination:end
            }
        }
    )
}

用户提交预约工单
↓
生成业务工单记录
↓
调用微信支付接口
↓
用户完成小程序支付
↓
接收微信异步回调
↓
更新工单状态为待派单，触发派单任务

router.post('/pay/notify', async(req,res)=>{
    let orderId=req.body.orderId;
    await WorkOrder.update({
        status:"待派单"
    },{
        where:{
            id:orderId
        }
    });
    res.send("success");
})

SELECT 
DATE(create_time) AS day, COUNT(*) AS order_count
FROM work_order
GROUP BY day;

SELECT 
SUM(amount) AS total_income
FROM work_order
WHERE dispatch_status=9;

SELECT technician_id,COUNT(id) AS service_num,AVG(score) AS avg_score
FROM work_order
WHERE dispatch_status=9
GROUP BY technician_id;

housekeeping‑system

├── user            用户模块
├── service         家政服务项目模块
├── technician      技师人员管理模块
├── workorder       预约工单核心模块
├── dispatch        多技师派单调度模块
├── payment         支付模块
└── admin           平台后台