| | |
| | | * @param key 缓存的键值 |
| | | * @return 缓存的对象 |
| | | */ |
| | | public Long addToHead(String key, Long value) { |
| | | public Long addToHead(String key, Object value) { |
| | | return redisTemplate.opsForList().leftPush(key, value); |
| | | } |
| | | /** |
| | |
| | | if (v < maxPushDistance) { |
| | | if (isPriorityDispatch) { |
| | | // 头部 value 订单_经纬度_状态_用户id_订单编号_距离_时间 |
| | | redisService.addToTail(s, orderId + "_" + xpPoint.getPointLon() + "," + xpPoint.getPointLat() + "_0" + "_" + uid + "_" + xpOrder.getOrderNumber() + "_" + distance + "_" + duration + "_" + routeAndFareDto.getRoutePlanRule()); |
| | | redisService.addToHead(s, orderId + "_" + xpPoint.getPointLon() + "," + xpPoint.getPointLat() + "_0" + "_" + uid + "_" + xpOrder.getOrderNumber() + "_" + distance + "_" + duration + "_" + routeAndFareDto.getRoutePlanRule()); |
| | | } else { |
| | | // 尾部 |
| | | redisService.addToTail(s, orderId + "_" + xpPoint.getPointLon() + "," + xpPoint.getPointLat() + "_0" + "_" + uid + "_" + xpOrder.getOrderNumber() + "_" + distance + "_" + duration + "_" + routeAndFareDto.getRoutePlanRule()); |
| | |
| | | // 保留2位数小数 |
| | | Double distance = datum.getDistance(); |
| | | datum.setDistance(BigDecimal.valueOf(distance).setScale(2, RoundingMode.HALF_UP).doubleValue()); |
| | | xpOrders.stream().filter(e->e.getEndPointId().equals(datum.getId())).findFirst().ifPresent( |
| | | xpOrders.stream().filter(e->e.getStartPointId().equals(datum.getId())).findFirst().ifPresent( |
| | | order->{ |
| | | datum.setNum(order.getNum()); |
| | | } |