同城外卖平台源码：用户端+商家端+骑手端+后台整体架构设计方案

/**
 * 统一权限校验切面示例
 */
@Aspect
@Component
public class AuthAspect {
    @Autowired
    private TokenService tokenService;

    @Before("@annotation(authCheck)")
    public void before(JoinPoint point, AuthCheck authCheck) {
        HttpServletRequest request = ServletUtil.getRequest();
        String token = request.getHeader("token");
        LoginUser loginUser = tokenService.parseToken(token);
        if (loginUser == null) {
            throw new BizException("请先登录");
        }
        // 校验角色
        if (!authCheck.role().contains(loginUser.getRole())) {
            throw new BizException("无访问权限");
        }
        // 存入上下文，业务层用于数据隔离
        UserContextHolder.set(loginUser);
    }
}

@Service
public class OrderService {
    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private OrderItemMapper orderItemMapper;
    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    @Transactional(rollbackFor = Exception.class)
    public OrderVO submitOrder(OrderSubmitDTO dto) {
        // 校验门店配送范围
        ScopeCheckVO scopeVo = shopScopeService.check(dto.getShopId(), dto.getAddressLng(), dto.getAddressLat());
        if (!scopeVo.isPass()) {
            throw new BizException(scopeVo.getMsg());
        }
        // 生成订单主记录
        OrderDO order = new OrderDO();
        order.setOrderNo(OrderNoUtil.gen());
        order.setUserId(dto.getUserId());
        order.setShopId(dto.getShopId());
        order.setTotalAmount(dto.getTotalAmount());
        order.setDeliveryFee(scopeVo.getDeliveryFee());
        order.setStatus(OrderStatusEnum.WAIT_PAY.getCode());
        order.setPayDeadline(LocalDateTime.now().plusMinutes(15));
        orderMapper.insert(order);
        // 写入订单明细
        List<OrderItemDO> itemList = buildItem(order.getId(), dto.getCartList());
        orderItemMapper.insertBatch(itemList);
        // 投递订单创建事件
        OrderCreateMsg msg = new OrderCreateMsg();
        msg.setOrderId(order.getId());
        rocketMQTemplate.send("order-create-topic", MessageBuilder.withPayload(msg).build());
        return convertor.toVO(order);
    }
}

@Service
public class DispatchService {
    @Autowired
    private RedisTemplate<String,Object> redisTemplate;
    @Autowired
    private RiderMapper riderMapper;

    /**
     * 检索附近空闲骑手
     */
    public List<RiderMatchVO> matchRider(BigDecimal shopLng, BigDecimal shopLat, LocalDateTime orderTime) {
        Set<Long> busyRiderIds = scheduleRedisService.getBusyRider(orderTime);
        Circle circle = new Circle(new Point(shopLng.doubleValue(), shopLat.doubleValue()), new Distance(5, Metrics.KILOMETERS));
        GeoResults<RedisGeoCommands.GeoLocation<String>> geoRes = redisTemplate.opsForGeo()
                .radius("rider:geo", circle, RedisGeoCommands.GeoRadiusCommandArgs.newGeoRadiusArgs().includeDistance());
        if (geoRes == null) {
            return Collections.emptyList();
        }
        List<Long> riderIds = new ArrayList<>();
        Map<Long,Double> distMap = new HashMap<>();
        for (GeoResult<RedisGeoCommands.GeoLocation<String>> res : geoRes) {
            Long riderId = Long.valueOf(res.getContent().getName());
            if (busyRiderIds.contains(riderId)) continue;
            riderIds.add(riderId);
            distMap.put(riderId, res.getDistance().getValue());
        }
        List<RiderDO> riders = riderMapper.selectByIds(riderIds);
        return riders.stream().map(rider -> {
            RiderMatchVO vo = new RiderMatchVO();
            vo.setRiderId(rider.getId());
            vo.setName(rider.getRealName());
            vo.setScore(rider.getScore());
            vo.setDistance(distMap.get(rider.getId()));
            return vo;
        }).sorted(Comparator.comparing(RiderMatchVO::getDistance)).toList();
    }
}