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

Java 同城跑腿小程序源码解析：代买代送服务流程实现

news 2026/5/11 21:02:21

以下基于Java同城跑腿小程序源码，深度解析代买代送服务流程的核心实现逻辑，结合技术架构与代码示例展开说明：

一、用户下单与需求解析

需求接收与校验：用户通过小程序选择“代买”或“代送”，填写取件地址、收件地址、物品类型、备注等参数。后端Controller层接收JSON请求，Service层执行必填项校验（如地址非空、物品合规性）及合理性校验（如同城范围、重量限制）。

订单生成：校验通过后，生成唯一订单编号，订单状态设为“待接单”，并存入MySQL数据库。示例代码：

java

@PostMapping("/order/create") public Result create(@RequestBody RunOrderDTO dto) { RunOrder order = new RunOrder(); order.setUserId(dto.getUserId()); order.setPickupAddress(dto.getPickupAddress()); order.setDeliveryAddress(dto.getDeliveryAddress()); order.setType(dto.getType()); order.setStatus(OrderStatus.WAITING); runOrderService.save(order); // MyBatis-Plus持久化 return Result.success(order.getId()); }

二、订单调度与骑手匹配

智能调度算法：基于距离、骑手评分、负载等多因子评分，筛选3公里内空闲骑手。通过高德地图API计算实际骑行距离，结合Redis缓存骑手实时位置，排序后推送订单至骑手端。

防并发抢单：采用Redis分布式锁或数据库行锁（SELECT ... FOR UPDATE），确保订单唯一接单。示例逻辑：

java

@Transactional public boolean acceptOrder(Long orderId, Long riderId) { RunOrder order = runOrderMapper.selectForUpdate(orderId); // 悲观锁 if (!OrderStatus.WAITING.equals(order.getStatus())) return false; order.setStatus(OrderStatus.ACCEPTED); order.setRiderId(riderId); runOrderMapper.update(order); return true; }

三、配送跟踪与状态流转

实时位置追踪：骑手上报位置至Redis，系统通过WebSocket推送至用户端，结合高德地图API规划最优路线，更新预计送达时间。

状态联动：订单状态按“已接单→已取件→配送中→已完成”流转，每次变更触发消息推送（微信模板消息/订阅消息）。示例状态更新：

java

public void updateStatus(Long orderId, OrderStatus status) { RunOrder order = runOrderMapper.selectById(orderId); order.setStatus(status); order.setUpdateTime(LocalDateTime.now()); runOrderMapper.update(order); // 触发消息推送逻辑 }

四、支付与核销闭环

支付集成：调用微信支付“统一下单”接口生成预支付会话，支付成功后回调更新订单状态为“已支付”，并通过RabbitMQ异步通知调度模块。

核销验证：生成6位随机核销码关联订单，用户输入核销码后，系统校验合法性，更新订单为“已完成”，结算骑手佣金。示例核销逻辑：

java

@PostMapping("/order/verify") public Result verify(@RequestParam String code) { Order order = orderService.getByCode(code); if (order == null || order.getStatus() != OrderStatus.DELIVERED) return Result.error("无效核销码"); order.setStatus(OrderStatus.COMPLETED); orderService.update(order); // 结算骑手佣金 return Result.success(); }

五、异常处理与数据一致性

异常场景覆盖：订单取消、物品损坏、支付失败等场景，通过事务管理（@Transactional）和消息队列保障数据一致性。例如支付失败自动回滚订单，释放运力资源。
限流降级：Sentinel限流组件应对高峰期高并发，避免系统崩溃；Redis缓存热点数据（如骑手位置），降低数据库压力。