Merge branch 'master' of http://120.76.84.145:10101/gitblit/r/java/Robotaxi
| | |
| | | |
| | | import java.util.List; |
| | | |
| | | @FeignClient(contextId = "XpTestPointClient", value = ServiceNameConstantsEnum.XP_OPERATION_SERVICE, fallbackFactory = XpTestPointClientFallbackFactory.class) |
| | | @FeignClient(contextId = "XpTestPointClient", value = ServiceNameConstantsEnum.XP_MAP_SERVICE, fallbackFactory = XpTestPointClientFallbackFactory.class) |
| | | public interface XpTestPointClient { |
| | | |
| | | |
| | |
| | | * @param pointId |
| | | * @return |
| | | */ |
| | | @PostMapping("/inner/v1/testPoint/nowInTimePoint") |
| | | @GetMapping("/inner/v1/testPoint/nowInTimePoint") |
| | | R<Boolean> nowInTimePoint(@RequestParam Long pointId); |
| | | } |
| | |
| | | private static final long serialVersionUID = 1L; |
| | | |
| | | @ApiModelProperty(value = "自增id") |
| | | @TableId(value = "id", type = IdType.NONE) |
| | | @TableId(value = "id", type = IdType.AUTO) |
| | | private Long id; |
| | | |
| | | @ApiModelProperty(value = "测试计划ID") |
| | |
| | | .eq(XpOpenCity::getDistrictCode, districtCode)); |
| | | if (Objects.isNull(xpOpenCity)) { |
| | | xpOpenCity = this.baseMapper.selectOne(new LambdaQueryWrapper<XpOpenCity>() |
| | | .eq(XpOpenCity::getCityCode, cityCode).isNull(XpOpenCity::getDistrictCode)); |
| | | .eq(XpOpenCity::getCityCode, cityCode).eq(XpOpenCity::getDistrictCode, "")); |
| | | } |
| | | if (Objects.isNull(xpOpenCity)) { |
| | | xpOpenCity = this.baseMapper.selectOne(new LambdaQueryWrapper<XpOpenCity>() |
| | | .eq(XpOpenCity::getProvinceCode, provinceCode) |
| | | .isNull(XpOpenCity::getCityCode).isNull(XpOpenCity::getDistrictCode)); |
| | | .eq(XpOpenCity::getCityCode, "") |
| | | .eq(XpOpenCity::getDistrictCode, "")); |
| | | } |
| | | return xpOpenCity; |
| | | } |
| | |
| | | Map<Long, List<XpTestPlanVehicle>> vehicleMap = CollUtil.isNotEmpty(planIds) ? xpTestPlanVehicleService.lambdaQuery().in(XpTestPlanVehicle::getTestPlanId, planIds) |
| | | .list().stream().collect(Collectors.groupingBy(XpTestPlanVehicle::getTestPlanId)) : Collections.emptyMap(); |
| | | page.getRecords().forEach(plan -> { |
| | | plan.setPointNum(pointMap.get(plan.getId()).size()); |
| | | plan.setVehicleNum(vehicleMap.get(plan.getId()).size()); |
| | | if(pointMap.size() > 0){ |
| | | plan.setPointNum(pointMap.get(plan.getId()).size()); |
| | | }else{ |
| | | plan.setPointNum(0); |
| | | } |
| | | if(vehicleMap.size() > 0){ |
| | | plan.setVehicleNum(vehicleMap.get(plan.getId()).size()); |
| | | }else{ |
| | | plan.setVehicleNum(0); |
| | | } |
| | | Long testOrder = xpTestOrderClient.queryCountByTestPlanId(plan.getId()).getData(); |
| | | plan.setOrderNum(testOrder.intValue()); |
| | | }); |
| | |
| | | @ApiModel(value = "订单分页查询请求", description = "订单分页查询参数") |
| | | public class XpTestOrderPageQuery extends BasePage { |
| | | |
| | | @ApiModelProperty(value = "测试计划id") |
| | | private Long testPlanId; |
| | | |
| | | @ApiModelProperty(value = "订单号") |
| | | private String orderNumber; |
| | | |
| | |
| | | xpOrder.setMileageKilometers(0.0); |
| | | xpOrder.setOrderNumber("XP" + System.currentTimeMillis()); |
| | | xpOrder.setCityId(openCity.getId()); |
| | | xpOrder.setPlacementLat(xpPoint.getPointLat()); |
| | | xpOrder.setPlacementLon(xpPoint.getPointLon()); |
| | | xpOrder.setPlacementAddress(xpPoint.getPointAddress()); |
| | | xpOrder.setStartLon(xpPoint.getPointLon()); |
| | | xpOrder.setStartLat(xpPoint.getPointLat()); |
| | | xpOrder.setBoardingLon(xpPoint.getPointLon()); |
| | |
| | | } |
| | | // 1. 构建查询条件 |
| | | LambdaQueryWrapper<XpTestOrder> wrapper = buildQueryWrapper(query); |
| | | wrapper.eq(XpTestOrder::getTestPlanId, query.getTestPlanId()); |
| | | if (CollUtil.isNotEmpty(vehicleIdsFilter)) { |
| | | wrapper.in(XpTestOrder::getVehicleId, vehicleIdsFilter); |
| | | } |
| | |
| | | Map<Long, XpFleet> fleetMap) { |
| | | XpTestOrderPageVO vo = new XpTestOrderPageVO(); |
| | | vo.setId(order.getId()); |
| | | vo.setOrderType(order.getOrderType()); |
| | | vo.setOrderNumber(order.getOrderNumber()); |
| | | vo.setCreateTime(order.getCreateTime()); |
| | | vo.setOrderSource(order.getOrderSource()); |