本地外卖配送系统开发教程：订单调度与商户入驻模块实现

 用户小程序
 |
商户端 ---- API服务层 ---- 平台管理后台
 |
骑手端
 |
MySQL + Redis

CREATE TABLE merchant (
 id INT PRIMARY KEY AUTO_INCREMENT,
 shop_name VARCHAR(100) COMMENT '店铺名称',
 contact_name VARCHAR(50) COMMENT '联系人',
 phone VARCHAR(20) COMMENT '联系电话',
 license_img VARCHAR(255) COMMENT '营业执照图片',
 food_license_img VARCHAR(255) COMMENT '食品经营许可证',
 shop_address VARCHAR(255) COMMENT '门店地址',
 lat DECIMAL(10,6) COMMENT '门店纬度',
 lng DECIMAL(10,6) COMMENT '门店经度',
 commission_rate DECIMAL(5,2) COMMENT '平台佣金比例',
 apply_status TINYINT DEFAULT 0 COMMENT '0待审核 1审核通过 2审核驳回',
 status TINYINT DEFAULT 0 COMMENT '0未营业 1营业中',
 create_time DATETIME
);

router.post('/merchant/apply', async(req,res)=>{
    const merchant = await Merchant.create({
        shop_name:req.body.shopName,
        contact_name:req.body.contactName,
        phone:req.body.phone,
        license_img:req.body.licenseImg,
        food_license_img:req.body.foodLicenseImg,
        shop_address:req.body.shopAddress,
        lat:req.body.lat,
        lng:req.body.lng,
        apply_status:0
    })
    res.json({
        code:200,
        message:"入驻申请提交成功，等待平台审核",
        data:merchant
    })
})

router.post('/merchant/audit',async(req,res)=>{
    let merchantId = req.body.merchantId;
    let applyStatus = req.body.applyStatus;
    await Merchant.update({
        apply_status:applyStatus
    },{
        where:{
            id:merchantId
        }
    })
    res.json({
        message:applyStatus===1?"审核通过":"审核驳回"
    })
})

function calculateCartAmount(cart){
    let total = 0;
    cart.forEach(item=>{
        total += item.price * item.number;
    })
    return total;
}

async function createOrder(userId,cart,shopId){
    const goodsAmount = calculateCartAmount(cart);
    //查询商户佣金比例
    const merchantInfo = await Merchant.findByPk(shopId);
    const commission = goodsAmount * merchantInfo.commission_rate /100;
    const order = await Order.create({
        user_id:userId,
        shop_id:shopId,
        goods_amount:goodsAmount,
        commission:commission,
        status:'待支付'
    });
    return order;
}

待支付
 |
已支付
 |
商户接单
 |
调度分配骑手
 |
配送中
 |
订单完成

const dispatchStatus={
    WAIT_DISPATCH:1,  //待调度
    AUTO_ASSIGN:2,    //已自动派单
    GRAB_ORDER:3,     //抢单中
    RIDER_ACCEPT:4,   //骑手已接单
    DELIVERING:5,     //配送中
    FINISH:6          //已完成
}

router.post('/rider/grabOrder',async(req,res)=>{
    let orderId = req.body.orderId;
    let riderId = req.body.riderId;
    const orderInfo = await Order.findByPk(orderId);
    if(orderInfo.dispatch_status !== dispatchStatus.GRAB_ORDER){
        return res.json({code:500,message:"该订单不可抢单"})
    }
    await Order.update({
        rider_id:riderId,
        dispatch_status:dispatchStatus.RIDER_ACCEPT
    },{
        where:{id:orderId}
    })
    res.json({message:"抢单成功"})
})

// 获取门店周边在线骑手，简化版自动派单
async function autoDispatchOrder(orderId,shopLat,shopLng){
    //查询周边在线空闲骑手（位置数据存储在Redis）
    const nearRiderList = await getNearOnlineRider(shopLat,shopLng);
    if(nearRiderList.length ===0){
        //无可用骑手，切换到抢单模式
        await Order.update({dispatch_status:dispatchStatus.GRAB_ORDER},{where:{id:orderId}});
        return false;
    }
    //选取距离最近骑手
    const targetRider = nearRiderList[0];
    await Order.update({
        rider_id:targetRider.id,
        dispatch_status:dispatchStatus.RIDER_ACCEPT
    },{where:{id:orderId}});
    return true;
}

function getDeliveryRoute(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 Order.update({
        status:"已支付"
    },{
        where:{
            id:orderId
        }
    });
    res.send("success");
})

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

SELECT 
SUM(commission) AS total_commission
FROM orders
WHERE status='已完成';

SELECT shop_id,COUNT(*) AS order_num,SUM(goods_amount) AS shop_sales
FROM orders
WHERE status='已完成'
GROUP BY shop_id;

local‑food‑system

├── user          用户模块
├── merchant      商户入驻与商户管理
├── goods         商品模块
├── order         订单基础模块
├── dispatch      订单调度派单核心
├── rider         骑手管理模块
├── payment       支付模块
└── admin         平台后台