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;
}
/**
* 发送乘客导航路径数据
*
* @param appUserId
* @param keyStr
*/
public void sendRoute(String appUserId, Long orderId, String keyStr, String vin) {
VehiclePosition vehiclePosition = mongoTemplate.findOne(new Query(Criteria.where("vin").is(vin)), VehiclePosition.class);
Object cacheObject = redisService.getCacheObject(keyStr + ":" + appUserId);
if (null != cacheObject) {
RouteVo routeVo = JSON.parseObject(cacheObject.toString(), RouteVo.class);
JSONObject jsonObject = new JSONObject();
jsonObject.put("type", "ORDER_ROUTE");
jsonObject.put("timestamp", System.currentTimeMillis());
JSONObject content = new JSONObject();
content.put("orderId", orderId.toString());
content.put("routeType", "ORDER_NAVIGATION_START_DATA".equals(keyStr) ? 1 : 2);
content.put("direction", null != vehiclePosition ? vehiclePosition.getCourse() : 90);
JSONObject route = new JSONObject();
route.put("distance", routeVo.getDistance());
route.put("duration", routeVo.getDuration());
route.put("routeID", routeVo.getRouteID());
List collect = routeVo.getPolyline().stream().map(item -> {
JSONObject point = new JSONObject();
point.put("latitude", item.getLatitude());
point.put("longitude", item.getLongitude());
return point;
}).collect(Collectors.toList());
route.put("polyline", JSON.toJSONString(collect));
content.put("route", route.toJSONString());
jsonObject.put("content", content.toJSONString());
SendMessageDTO messageDTO = new SendMessageDTO();
messageDTO.setAppUserId(appUserId);
messageDTO.setMessage(jsonObject.toJSONString());
R stringR = xpPushMessageClient.sendRoute(messageDTO);
XpTestOrder xpOrder = this.getById(orderId);
//推送失败，重试3次
if(stringR.getCode() != Constants.SUCCESS){
ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>());
executor.execute(() -> {
for (int i = 0; i < 3; i++) {
R stringR1 = xpPushMessageClient.sendStatus(messageDTO);
if(stringR1.getCode() == Constants.SUCCESS){
break;
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
log.info("推送乘客端导航数据消息失败：{} {} {}", stringR1.getMsg(), JSON.toJSONString(messageDTO), xpOrder.getOrderNumber());
}
});
}
}
}
@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);
}
}
}