| | |
| | | uid = driverService.getUserIdFormRedis(request); |
| | | if(null == uid){ |
| | | return ResultUtil.tokenErr(); |
| | | |
| | | } |
| | | |
| | | } catch (Exception e) { |
| | |
| | | .eq("authState", 2).eq("state", 2)); |
| | | Integer finalUid = uid; |
| | | collect = drivers.stream().map(driver -> { |
| | | String value = (String) redisTemplate.opsForValue().get("dache:DRIVER" + driver.getId()); |
| | | if(ToolUtil.isNotEmpty(value)){ |
| | | /* String value = (String) redisTemplate.opsForValue().get("dache:DRIVER" + driver.getId()); |
| | | if(ToolUtil.isNotEmpty(value)){*/ |
| | | Optional<DriverPosition> driverPosition = driverPositions.stream().filter(position -> position.getDriverId().equals(driver.getId())).findFirst(); |
| | | Map<String, Object> map = new HashMap<>(); |
| | | map.put("driverId", driver.getId()); |
| | |
| | | map.put("lot", driverPosition.isPresent() ? driverPosition.get().getPoint().getX() : ""); |
| | | map.put("lat", driverPosition.isPresent() ? driverPosition.get().getPoint().getY() : ""); |
| | | return map; |
| | | } |
| | | return null; |
| | | /* } |
| | | return null;*/ |
| | | }).filter(s -> Objects.nonNull(s) && !finalUid.equals(s.get("driverId"))).collect(Collectors.toList()); |
| | | } |
| | | // addMockNearbyDrivers(collect); |
| | | return ResultUtil.success(collect); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 司机端首页订单热力图。 |
| | | * 热力图统计的是订单起点位置,不统计司机位置;订单坐标统一取 startLon/startLat。 |