本地化外卖平台设计方案：用户端、商户端、骑手端三端协同开发

 用户小程序
      |
商户端 ---- API服务层 + 消息推送 ---- 管理后台
      |
骑手端
      |
MySQL + Redis + MQ消息队列

CREATE TABLE goods (
 id INT PRIMARY KEY AUTO_INCREMENT,
 shop_id INT COMMENT '所属商户ID',
 name VARCHAR(100) COMMENT '商品名称',
 image VARCHAR(255) COMMENT '商品图片',
 price DECIMAL(10,2) COMMENT '售价',
 stock INT COMMENT '库存',
 status TINYINT DEFAULT 1 COMMENT '1上架 0下架'
);

router.get('/goods/list', async(req,res)=>{
    const goods = await Goods.findAll({
        where:{
            shop_id:req.query.shopId,
            status:1
        }
    })
    res.json({
        code:200,
        data:goods
    })
})

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

async function createOrder(userId,cart,shopId,deliveryFee){
    const goodsAmount = calculateCartAmount(cart);
    const payAmount = goodsAmount + deliveryFee;
    const order = await Order.create({
        user_id:userId,
        shop_id:shopId,
        goods_amount:goodsAmount,
        delivery_fee:deliveryFee,
        pay_amount:payAmount,
        status:'待支付'
    })
    //支付成功后推送消息给商户端，提醒有新订单
    await mqProducer.send("order-new-topic",JSON.stringify(order));
    return order;
}

【用户端】提交订单→待支付
 ↓用户完成支付
【用户端】状态：已支付 →【商户端】收到新订单提醒
 ↓商户端接单
【商户端】状态：已接单 →【调度服务】分配骑手 →【骑手端】收到订单推送
 ↓骑手端取餐
【骑手端】状态：配送中 →【用户端】同步看到配送中
 ↓骑手端确认送达
【骑手端】状态：已完成 →【用户端、商户端】同步更新订单完成

const orderStatus={
    WAIT_PAY:1,     //待支付
    PAID:2,         //已支付
    SHOP_ACCEPT:3,  //商户已接单
    DELIVERING:4,   //配送中
    FINISH:5        //订单完成
}

router.post('/rider/updateOrderStatus',async(req,res)=>{
    const {orderId,status,riderId}=req.body;
    const orderInfo = await Order.findByPk(orderId);
    //校验订单属于当前骑手
    if(orderInfo.rider_id !== riderId){
        return res.json({code:500,message:"无权操作该订单"})
    }
    await Order.update({status:status},{where:{id:orderId}});
    //推送状态变更事件，同步更新用户端、商户端页面
    await mqProducer.send("order-status-change",JSON.stringify({orderId,status}));
    res.json({message:"状态更新成功"})
})

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

【用户端】提交订单
↓
生成业务订单记录
↓
用户端调起微信支付
↓
微信异步回调后端
↓
后端更新订单状态为已支付
↓
MQ推送事件，【商户端】收到新订单提醒

router.post('/pay/notify', async(req,res)=>{
    let orderNo=req.body.out_trade_no;
    const order = await Order.findOne({where:{order_no:orderNo}})
    await Order.update({
        status:"已支付"
    },{
        where:{
            id:order.id
        }
    });
    //推送新订单消息给到商户端
    await mqProducer.send("order-new-topic",JSON.stringify(order));
    res.send("success");
})

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

SELECT shop_id,sum(pay_amount) AS shop_income
FROM orders
WHERE status=5
GROUP BY shop_id;

SELECT rider_id,COUNT(id) AS finish_num
FROM orders
WHERE status=5
GROUP BY rider_id;

local‑takeout‑system

├── user          用户端业务模块
├── merchant      商户端业务模块
├── rider         骑手端业务模块
├── order         订单核心模块
├── dispatch      订单调度模块
├── message‑push  多端消息推送模块
├── payment       支付模块
└── admin         平台后台