trajectories = mongoTemplate.find(
new Query(Criteria.where("orderId").is(orderId))
.with(Sort.by(Sort.Direction.ASC, "locatetime")),
OrderTrajectory.class
);
return trajectories;
}
/**
* 订单费用明细聚合：按 detail_type 汇总 money
*
* detail_type：1=起步价 2=里程费 3=时长费 4=远途费
*/
private Map sumOrderDetailMoneyByDetailType(Long orderId) {
if (orderId == null) {
return Collections.emptyMap();
}
List detailList = xpTestOrderDetailMapper.selectList(
new LambdaQueryWrapper()
.eq(XpTestOrderDetail::getOrderId, orderId)
.ne(XpTestOrderDetail::getIsDeleted, true)
);
if (CollectionUtils.isEmpty(detailList)) {
return Collections.emptyMap();
}
Map sumMap = new HashMap<>();
for (XpTestOrderDetail detail : detailList) {
if (detail == null || detail.getDetailType() == null) {
continue;
}
BigDecimal money = detail.getMoney() == null ? BigDecimal.ZERO : detail.getMoney();
sumMap.put(detail.getDetailType(), sumMap.getOrDefault(detail.getDetailType(), BigDecimal.ZERO).add(money));
}
return sumMap;
}
/**
* 将轨迹点转换为订单经纬度列表
*/
private List convertTrajectoriesToPositions(List trajectories) {
if (CollectionUtils.isEmpty(trajectories)) {
return new ArrayList<>();
}
List positions = new ArrayList<>();
for (OrderTrajectory trajectory : trajectories) {
if (trajectory == null || StringUtils.isBlank(trajectory.getLocation())) {
continue;
}
String[] parts = trajectory.getLocation().split(",");
if (parts.length != 2) {
continue;
}
try {
double longitude = Double.parseDouble(parts[0].trim());
double latitude = Double.parseDouble(parts[1].trim());
XpTestOrderDetailVO.OrderPosition position = new XpTestOrderDetailVO.OrderPosition();
position.setLongitude(longitude);
position.setLatitude(latitude);
positions.add(position);
} catch (Exception e) {
// ignore invalid point
}
}
return positions;
}
@Override
public void changeAmount(Long id, BigDecimal amount) {
if (Objects.isNull(id)) {
throw new ServiceException("订单ID不能为空", I18nKeyConstant.ORDER_CHANGE_AMOUNT_ID_REQUIRED);
}
if (Objects.isNull(amount)) {
throw new ServiceException("订单金额不能为空", I18nKeyConstant.ORDER_CHANGE_AMOUNT_AMOUNT_REQUIRED);
}
if (amount.compareTo(BigDecimal.ZERO) < 0) {
throw new ServiceException("订单金额不能小于0", I18nKeyConstant.ORDER_CHANGE_AMOUNT_AMOUNT_INVALID);
}
XpTestOrder order = this.getById(id);
if (Objects.isNull(order)) {
throw new ServiceException("订单不存在", I18nKeyConstant.ORDER_NOT_EXISTS);
}
final Integer pendingPaymentStatus = 8;
if (!Objects.equals(order.getStatus(), pendingPaymentStatus)) {
throw new ServiceException("当前订单状态不允许改价，只有待付款状态的订单可以改价", I18nKeyConstant.ORDER_CHANGE_AMOUNT_STATUS_INVALID);
}
if (Objects.nonNull(order.getOrderMoney()) && order.getOrderMoney().compareTo(amount) == 0) {
return;
}
boolean updated = this.lambdaUpdate()
.set(XpTestOrder::getOrderMoney, amount)
.set(XpTestOrder::getChangeMoneyFlag, Boolean.TRUE)
.eq(XpTestOrder::getId, id)
.eq(XpTestOrder::getStatus, pendingPaymentStatus)
.update();
if (!updated) {
throw new ServiceException("订单改价失败，请稍后重试", I18nKeyConstant.ORDER_CHANGE_AMOUNT_FAILED);
}
}
@Override
public R cancelTestOrderById(Long orderId) {
XpTestOrder xpTestOrder = this.getById(orderId);
if (xpTestOrder != null) {
xpTestOrder.setStatus(0);
xpTestOrder.setStartTestPointId(null);
this.updateById(xpTestOrder);
XpVehicle xpVehicle = xpVehicleClient.queryById(xpTestOrder.getVehicleId()).getData();
PushOrderDto pushOrderDto = new PushOrderDto();
pushOrderDto.setVin(xpVehicle.getVehicleVin());
pushOrderDto.setOrderId("TEST" + xpTestOrder.getId());
pushOrderDto.setOperation_type(OrderOperationType.CLOUD_CANCEL_ORDER);
R booleanR = orderMissionClient.cancelOrder(pushOrderDto);
if(booleanR==null || !booleanR.getData()){
log.error("XPU取消测试巡游订单失败");
return R.fail("XPU取消测试巡游订单失败");
}
return R.ok();
}
return R.fail("获取订单失败");
}
}