外卖配送系统开发搭建从0到1：小程序、App与后台如何联动

用户下单
   ↓
接口服务接收订单
   ↓
订单系统生成订单
   ↓
消息系统通知商家
   ↓
商家接单出餐
   ↓
骑手接单配送
   ↓
后台统一监控订单状态

async function createOrder(data) {
    return request({
        url: '/api/order/create',
        method: 'POST',
        data
    })
}

{
  "shop_id": 1001,
  "goods": [
    {
      "goods_id": 1,
      "num": 2
    }
  ],
  "address_id": 88,
  "remark": "不要香菜"
}

@PostMapping("/create")
public Result create(@RequestBody OrderDTO dto){

    // 校验商品
    orderService.checkGoods(dto);

    // 计算订单金额
    BigDecimal amount = orderService.calcAmount(dto);

    // 创建订单
    Order order = orderService.create(dto, amount);

    // 通知商家
    websocketService.sendToShop(order);

    return Result.success(order);
}

待支付
→ 已支付
→ 商家接单
→ 制作中
→ 配送中
→ 已完成

@ServerEndpoint("/ws/shop/{shopId}")
public class ShopWebSocket {

    private static ConcurrentHashMap<Long, Session> sessions = new ConcurrentHashMap<>();

    @OnOpen
    public void onOpen(Session session, @PathParam("shopId") Long shopId){
        sessions.put(shopId, session);
    }

    public static void send(Long shopId, String message) throws IOException {
        Session session = sessions.get(shopId);

        if(session != null){
            session.getBasicRemote().sendText(message);
        }
    }
}

const ws = new WebSocket("wss://api.xxx.com/ws/shop/1001")

ws.onmessage = (msg)=>{
   const data = JSON.parse(msg.data)

   if(data.type === 'new_order'){
       playVoice()
       refreshOrderList()
   }
}

setInterval(()=>{
   navigator.geolocation.getCurrentPosition((pos)=>{
      uploadLocation({
          lat: pos.coords.latitude,
          lng: pos.coords.longitude
      })
   })
},5000)

public void updateRiderLocation(Long riderId, Double lat, Double lng){

    redisTemplate.opsForGeo().add(
        "rider_geo",
        new Point(lng, lat),
        riderId.toString()
    );
}

GeoResults<RedisGeoCommands.GeoLocation<String>> results =
    redisTemplate.opsForGeo().radius(
        "rider_geo",
        new Circle(new Point(lng, lat), new Distance(5, Metrics.KILOMETERS))
    );

SELECT
    order_no,
    user_name,
    shop_name,
    status,
    amount
FROM orders
ORDER BY create_time DESC
LIMIT 20;

String goodsCache = redisTemplate.opsForValue().get("goods:1001");

rabbitTemplate.convertAndSend(
    "order.exchange",
    "order.create",
    order
);

long orderId = snowflake.nextId();