运营区数据

This commit is contained in:
attiya 2025-04-15 10:11:59 +08:00
parent 9dab4c7e24
commit ddf00a82b6
2 changed files with 6 additions and 2 deletions

View File

@ -13,6 +13,7 @@ import lombok.NoArgsConstructor;
@NoArgsConstructor @NoArgsConstructor
public class RspBikeDto { public class RspBikeDto {
private String ecuSn; private String ecuSn;
private Integer soc;
private Double longitude; private Double longitude;
private Double latitude; private Double latitude;
} }

View File

@ -143,7 +143,10 @@ public class UserOrdersServiceImpl extends ServiceImpl<UserOrdersMapper, UserOrd
@Override @Override
public List<RspBikeDto> bikeList(ReqBikeDto bikeDto) { public List<RspBikeDto> bikeList(ReqBikeDto bikeDto) {
List<RedisPoint> nearbyMembers = redisUtil.findNearbyMembers(bikeDto.getLongitude(), bikeDto.getLatitude(), bikeDto.getRadius()==null?3.0:bikeDto.getRadius()); List<RedisPoint> nearbyMembers = redisUtil.findNearbyMembers(bikeDto.getLongitude(), bikeDto.getLatitude(), bikeDto.getRadius()==null?3.0:bikeDto.getRadius());
return nearbyMembers.stream().filter(Objects::nonNull).map(redisPoint -> new RspBikeDto(redisPoint.getMember(), redisPoint.getPoint().getX(), redisPoint.getPoint().getY()) return nearbyMembers.stream().filter(Objects::nonNull).map(redisPoint -> {
).toList(); String jsonString = JSONObject.toJSONString(redisUtil.get(redisPoint.getMember()));
ResGPSDto resGpsDto = JSONObject.parseObject(jsonString, ResGPSDto.class);
return new RspBikeDto(redisPoint.getMember(), resGpsDto.getSoc(),redisPoint.getPoint().getX(), redisPoint.getPoint().getY());
}).toList();
} }
} }