From 45f48096a6e1adeec51ed0ef001220991dfcafc4 Mon Sep 17 00:00:00 2001
From: xuhy <3313886187@qq.com>
Date: 星期一, 20 四月 2026 22:00:13 +0800
Subject: [PATCH] Merge branch '1.0' of http://120.76.84.145:10101/gitblit/r/java/Robotaxi into 1.0
---
xp-robotaxi-order-boot/src/main/java/com/xiaopeng/order/service/impl/XpOrderServiceImpl.java | 11 +++++++++++
1 files changed, 11 insertions(+), 0 deletions(-)
diff --git a/xp-robotaxi-order-boot/src/main/java/com/xiaopeng/order/service/impl/XpOrderServiceImpl.java b/xp-robotaxi-order-boot/src/main/java/com/xiaopeng/order/service/impl/XpOrderServiceImpl.java
index 1c9f8a7..383e50c 100644
--- a/xp-robotaxi-order-boot/src/main/java/com/xiaopeng/order/service/impl/XpOrderServiceImpl.java
+++ b/xp-robotaxi-order-boot/src/main/java/com/xiaopeng/order/service/impl/XpOrderServiceImpl.java
@@ -2,6 +2,7 @@
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.util.IdUtil;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
@@ -181,6 +182,9 @@
@Value("${robotaxi.appId:xp_robotaxi_api}")
private String appid;
+
+ @Resource(name = "hutoolSnowflake")
+ private Snowflake snowflake;
@Override
@@ -1104,6 +1108,7 @@
// 11.2 下发订单到新车辆
PushOrderDto pushOrderDto = new PushOrderDto();
+ pushOrderDto.setTaskId(order.getXpuTaskId());
pushOrderDto.setVin(newVehicle.getVehicleVin());
pushOrderDto.setOrderId(order.getId().toString());
pushOrderDto.setStartLatitude(order.getStartLat());
@@ -1182,6 +1187,7 @@
returnOrder.setLastOrderId(lastCruise.getId());
returnOrder.setCreateTime(LocalDateTime.now());
returnOrder.setMissionId(lastCruise.getMissionId());
+ returnOrder.setXpuTaskId(snowflake.nextId() + "");
// 返程起点 = 当前订单的终点（车辆当前位置附近）
returnOrder.setStartPointId(order.getEndPointId());
@@ -1220,6 +1226,7 @@
// 下发巡游订单到原车辆
PushOrderDto pushOrderDto = new PushOrderDto();
+ pushOrderDto.setTaskId(returnOrder.getXpuTaskId());
pushOrderDto.setVin(oldVehicle.getVehicleVin());
pushOrderDto.setOrderId("XU" + returnOrder.getId());
pushOrderDto.setStartLatitude(returnOrder.getStartLat());
@@ -2557,6 +2564,7 @@
xpCruiseOrder.setStartPointName(order.getEndPointName());
xpCruiseOrder.setStartLon(order.getEndLon());
xpCruiseOrder.setStartLat(order.getEndLat());
+ xpCruiseOrder.setXpuTaskId(snowflake.nextId() + "");
// 完成的直接走终点 终止的走起点
if(null != xpCruiseOrders){
@@ -2617,6 +2625,7 @@
log.info("添加巡游单成功 {}", xpCruiseOrder.getId());
//下发XUP巡游订单报文
PushOrderDto pushOrderDto = new PushOrderDto();
+ pushOrderDto.setTaskId(xpCruiseOrder.getXpuTaskId());
pushOrderDto.setVin(xpCruiseOrder.getVehicleVin());
pushOrderDto.setOrderId("XU" + xpCruiseOrder.getId());
pushOrderDto.setStartLatitude(xpCruiseOrder.getStartLat());
@@ -2664,6 +2673,7 @@
xpCruiseOrder.setFleetId(vehicle.getFleetId());
xpCruiseOrder.setVehicleVin(vehicle.getVehicleVin());
xpCruiseOrder.setOrderType(2);
+ xpCruiseOrder.setXpuTaskId(snowflake.nextId() + "");
// 返程起点是当前正常订单的终点
xpCruiseOrder.setStartPointId(null);
xpCruiseOrder.setStartPointName(null);
@@ -2733,6 +2743,7 @@
//下发XPU消息报文
PushOrderDto pushOrderDto = new PushOrderDto();
+ pushOrderDto.setTaskId(xpCruiseOrder.getXpuTaskId());
pushOrderDto.setVin(xpCruiseOrder.getVehicleVin());
pushOrderDto.setOrderId("XU" + xpCruiseOrder.getId());
pushOrderDto.setStartLatitude(xpCruiseOrder.getStartLat());
--
Gitblit v1.7.1