空数组容错

This commit is contained in:
attiya 2025-04-14 10:57:19 +08:00
parent a838e16c09
commit 36442eccea
2 changed files with 19 additions and 16 deletions

View File

@ -254,21 +254,25 @@ public class EbikeRegionServiceImpl extends ServiceImpl<EbikeRegionMapper, Ebike
} }
private List<RspBikeInfo> getRspBikeInfos(List<RedisPoint> points) { private List<RspBikeInfo> getRspBikeInfos(List<RedisPoint> points) {
List<String> sns = points.stream().map(RedisPoint::getMember).toList(); if (points != null && !points.isEmpty()) {
JsonResult<List<RspBikeInfo>> bike = maintenanceFeignClient.getBikeByEcuSn(new ReqEcuSnDto(sns)); List<String> sns = points.stream().map(RedisPoint::getMember).toList();
if (bike.getCode() != Code.SUCCESS) { JsonResult<List<RspBikeInfo>> bike = maintenanceFeignClient.getBikeByEcuSn(new ReqEcuSnDto(sns));
throw new RuntimeException("获取车辆信息失败"); if (bike.getCode() != Code.SUCCESS) {
} throw new RuntimeException("获取车辆信息失败");
List<RspBikeInfo> bikeInfos = bike.getData(); }
for (RspBikeInfo rspBikeInfo : bikeInfos) { List<RspBikeInfo> bikeInfos = bike.getData();
points.forEach(redisPoint -> { for (RspBikeInfo rspBikeInfo : bikeInfos) {
if (redisPoint.getMember().equals(rspBikeInfo.getEcuSn())) { points.forEach(redisPoint -> {
rspBikeInfo.setLongitude(redisPoint.getPoint().getX()); if (redisPoint.getMember().equals(rspBikeInfo.getEcuSn())) {
rspBikeInfo.setLatitude(redisPoint.getPoint().getY()); rspBikeInfo.setLongitude(redisPoint.getPoint().getX());
} rspBikeInfo.setLatitude(redisPoint.getPoint().getY());
}); }
} });
return bikeInfos; }
return bikeInfos;
}else {
return List.of();
}
} }
private void saveRegion(List<ReqEbikePointDto> points, EbikeRegion region, Integer type) { private void saveRegion(List<ReqEbikePointDto> points, EbikeRegion region, Integer type) {

View File

@ -7,7 +7,6 @@ import com.cdzy.user.service.RolesService;
import com.mybatisflex.core.paginate.Page; import com.mybatisflex.core.paginate.Page;
import com.mybatisflex.core.query.QueryWrapper; import com.mybatisflex.core.query.QueryWrapper;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import jakarta.validation.Valid;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;