From af5ffb2c572c3188052b0d4b37c4bcec43f11c7d Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期一, 20 四月 2026 21:41:58 +0800
Subject: [PATCH] 增加修改目的地后的XPU消息下发
---
xp-robotaxi-maintenance-boot/src/main/java/com/xiaopeng/maintenance/schedule/VehicleCollectionScheduleTask.java | 6 ++++++
1 files changed, 6 insertions(+), 0 deletions(-)
diff --git a/xp-robotaxi-maintenance-boot/src/main/java/com/xiaopeng/maintenance/schedule/VehicleCollectionScheduleTask.java b/xp-robotaxi-maintenance-boot/src/main/java/com/xiaopeng/maintenance/schedule/VehicleCollectionScheduleTask.java
index 3347216..eff34c9 100644
--- a/xp-robotaxi-maintenance-boot/src/main/java/com/xiaopeng/maintenance/schedule/VehicleCollectionScheduleTask.java
+++ b/xp-robotaxi-maintenance-boot/src/main/java/com/xiaopeng/maintenance/schedule/VehicleCollectionScheduleTask.java
@@ -1,5 +1,6 @@
package com.xiaopeng.maintenance.schedule;
+import cn.hutool.core.lang.Snowflake;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.xiaopeng.api.feignClient.automaticPilot.OrderMissionClient;
import com.xiaopeng.api.feignClient.operation.XpCruisePlanClient;
@@ -21,6 +22,7 @@
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
+import javax.annotation.Resource;
import java.time.LocalTime;
import java.util.Collections;
import java.util.List;
@@ -62,6 +64,9 @@
@Autowired
private XpCruisePlanClient xpCruisePlanClient;
+
+ @Resource(name = "hutoolSnowflake")
+ private Snowflake snowflake;
/**
* 每分钟检查一次是否需要执行收车任务
@@ -217,6 +222,7 @@
xpCruiseOrder.setOrderReverse(1);
xpCruiseOrder.setLastOrderId(r.getData());
xpCruiseOrder.setOrderReverse(1);
+ xpCruiseOrder.setXpuTaskId(snowflake.nextId() + "");
// 找到收车站点
R<XpCruiseOrder> returnCruisePoint = xpCruisePlanClient.findReturnCruisePoint(xpCruiseOrder);
--
Gitblit v1.7.1