oldFleetIdResult = xpFleetVehicleClient.getFleetIdByVehicleId(oldVehicleId);
if (Objects.nonNull(oldFleetIdResult) && Objects.nonNull(oldFleetIdResult.getData())) {
oldFleetId = oldFleetIdResult.getData();
log.info("补充查询到旧车辆ID: {} 关联的车队ID: {}", oldVehicleId, oldFleetId);
}
} catch (Exception e) {
log.warn("查询旧车辆关联的车队ID失败，车辆ID: {}，错误: {}", oldVehicleId, e.getMessage());
}
}
// 9. 更新订单的车辆和车队信息
order.setVehicleId(newVehicleId);
if (Objects.nonNull(newFleetId)) {
order.setFleetId(newFleetId);
}
this.updateById(order);
// 10. 保存改派记录
XpOrderReassign orderReassign = new XpOrderReassign();
orderReassign.setOrderId(orderId);
orderReassign.setUserId(SecurityUtils.getUserId());
orderReassign.setOperationTime(LocalDateTime.now());
orderReassign.setOldVehicleId(oldVehicleId);
orderReassign.setNewVehicleId(newVehicleId);
orderReassign.setOldFleetId(oldFleetId);
orderReassign.setNewFleetId(newFleetId);
orderReassign.setReassignReason(
StringUtils.isNotBlank(reassignReason) ? reassignReason : "运营人员改派订单"
);
orderReassign.setCreateBy(SecurityUtils.getLoginUser().getSysUser().getNickName());
xpOrderReassignService.save(orderReassign);
log.info("订单改派成功，订单ID: {}, 原车辆ID: {}, 新车辆ID: {}, 原车队ID: {}, 新车队ID: {}, 操作人: {}",
orderId, oldVehicleId, newVehicleId, oldFleetId, newFleetId, SecurityUtils.getUsername());
// 11. 处理新车辆：绑定乘客、下发订单、更新状态
try {
// 11.1 绑定乘客与新车辆关系
if (Objects.nonNull(order.getAppUserId())) {
AddTaxiPassengerVo addVo = new AddTaxiPassengerVo();
addVo.setVin(newVehicle.getVehicleVin());
addVo.setUid(order.getAppUserId().toString());
addVo.setOrderNo(order.getOrderNumber());
addVo.setAppId(appid); // TODO 获取appId
userVehicleClient.addTaxiPassenger(addVo);
log.info("已绑定乘客与新车辆关系，用户ID: {}, VIN: {}", order.getAppUserId(), newVehicle.getVehicleVin());
}
// 11.2 下发订单到新车辆
PushOrderDto pushOrderDto = new PushOrderDto();
pushOrderDto.setVin(newVehicle.getVehicleVin());
pushOrderDto.setOrderId(order.getId().toString());
pushOrderDto.setStartLatitude(order.getStartLat());
pushOrderDto.setStartLongitude(order.getStartLon());
pushOrderDto.setEndLatitude(order.getEndLat());
pushOrderDto.setEndLongitude(order.getEndLon());
pushOrderDto.setOrderType(OrderType.USER_ORDER);
pushOrderDto.setStage(1);
// 调用推送服务 orderId + carVin
orderMissionClient.pushOrder(pushOrderDto);
log.info("已下发订单到新车辆，订单ID: {}, VIN: {}", orderId, newVehicle.getVehicleVin());
// 11.3 更新新车辆状态为已接单
newVehicle.setState(1);
xpVehicleClient.updateVehicleById(newVehicle);
log.info("已将新车辆状态设为已接单，车辆ID: {}", newVehicleId);
} catch (Exception e) {
log.error("处理新车辆失败，车辆ID: {}，错误: {}", newVehicleId, e.getMessage());
}
}
/**
* 为原车辆创建返程巡游订单
*
* 改派时，原车辆需要返回巡游路线：
* - 若最新巡游订单状态为已终止(status=2)，返回原出发点
* - 若最新巡游订单状态为已完成(status=3)，返回原终点
* - 其他状态，默认返回原出发点
*
*
* @param oldVehicle 原车辆信息
* @param order 当前订单信息
*/
private void createReturnCruiseOrder(XpVehicle oldVehicle, XpOrder order) {
try {
// 查询该车辆最新的一条巡游订单
XpCruiseOrder lastCruise = xpCruiseOrderMapper.selectOne(
new LambdaQueryWrapper()
.eq(XpCruiseOrder::getVehicleId, oldVehicle.getId())
.orderByDesc(BaseModel::getCreateTime)
.last("limit 1")
);
if (lastCruise == null) {
log.warn("原车辆没有巡游订单记录，跳过创建返程订单，车辆ID: {}", oldVehicle.getId());
return;
}
XpCruiseOrder returnOrder = new XpCruiseOrder();
returnOrder.setVehicleId(oldVehicle.getId());
returnOrder.setVehicleVin(oldVehicle.getVehicleVin());
returnOrder.setFleetId(oldVehicle.getFleetId());
returnOrder.setOrderType(2); // 返程单
returnOrder.setStatus(1); // 进行中
returnOrder.setLastOrderId(lastCruise.getId());
returnOrder.setCreateTime(LocalDateTime.now());
returnOrder.setMissionId(lastCruise.getMissionId());
// 返程起点 = 当前订单的终点（车辆当前位置附近）
returnOrder.setStartPointId(order.getEndPointId());
returnOrder.setStartPointName(order.getEndPointName());
returnOrder.setStartLon(order.getEndLon());
returnOrder.setStartLat(order.getEndLat());
// 根据最新巡游订单状态决定返程终点
if (lastCruise.getStatus() != null && lastCruise.getStatus() == 2) {
// 已终止(status=2) -> 返回原出发点
returnOrder.setEndPointId(lastCruise.getStartPointId());
returnOrder.setEndPointName(lastCruise.getStartPointName());
returnOrder.setEndLon(lastCruise.getStartLon());
returnOrder.setEndLat(lastCruise.getStartLat());
returnOrder.setOrderReverse(lastCruise.getOrderReverse());
log.info("巡游订单状态为已终止，返回原出发点");
} else if (lastCruise.getStatus() != null && lastCruise.getStatus() == 3) {
// 已完成(status=3) -> 返回原终点
returnOrder.setEndPointId(lastCruise.getEndPointId());
returnOrder.setEndPointName(lastCruise.getEndPointName());
returnOrder.setEndLon(lastCruise.getEndLon());
returnOrder.setEndLat(lastCruise.getEndLat());
returnOrder.setOrderReverse(lastCruise.getOrderReverse());
log.info("巡游订单状态为已完成，返回原终点");
} else {
// 其他状态（进行中等），默认返回原出发点
returnOrder.setEndPointId(lastCruise.getStartPointId());
returnOrder.setEndPointName(lastCruise.getStartPointName());
returnOrder.setEndLon(lastCruise.getStartLon());
returnOrder.setEndLat(lastCruise.getStartLat());
returnOrder.setOrderReverse(lastCruise.getOrderReverse());
log.info("巡游订单状态为{}，默认返回原出发点", lastCruise.getStatus());
}
xpCruiseOrderMapper.insert(returnOrder);
// 下发巡游订单到原车辆
PushOrderDto pushOrderDto = new PushOrderDto();
pushOrderDto.setVin(oldVehicle.getVehicleVin());
pushOrderDto.setOrderId("XU" + returnOrder.getId());
pushOrderDto.setStartLatitude(returnOrder.getStartLat());
pushOrderDto.setStartLongitude(returnOrder.getStartLon());
pushOrderDto.setEndLatitude(returnOrder.getEndLat());
pushOrderDto.setEndLongitude(returnOrder.getEndLon());
pushOrderDto.setOrderType(OrderType.CRUISE_ORDER);
pushOrderDto.setStage(2);
// 调用推送服务 orderId + carVin
orderMissionClient.pushOrder(pushOrderDto);
log.info("为原车辆创建返程巡游订单成功，订单ID: {}, 车辆ID: {}", returnOrder.getId(), oldVehicle.getId());
} catch (Exception e) {
log.error("创建返程巡游订单失败，车辆ID: {}，错误: {}", oldVehicle.getId(), e.getMessage());
}
}
@Override
public XpPointInfoVo getUserQuickCapsule(String uid) {
try {
// 使用Redis的sorted set（排行榜）获取第一个元素
// 获取分数最高的元素（默认按分数从高到低排序）
Set