From 7e6951504e2f65a101b52f15f225a4625e9d8b83 Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期五, 13 二月 2026 16:48:58 +0800
Subject: [PATCH] feat(order): 添加订单任务下发功能
---
xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/util/XPUUtil.java | 13 ++++++++-----
1 files changed, 8 insertions(+), 5 deletions(-)
diff --git a/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/util/XPUUtil.java b/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/util/XPUUtil.java
index 6b9da4c..971dd31 100644
--- a/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/util/XPUUtil.java
+++ b/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/util/XPUUtil.java
@@ -36,14 +36,14 @@
* @param task
* @return
*/
- public MqttPublishDto cloudCreateOrder(RTTask task, String vin) {
+ public MqttPublishDto cloudCreateOrder(RTTask task, String vin, Long sequence) {
MsgContent msgContent = new MsgContent();
// 消息头
RtMsgHeader header = new RtMsgHeader();
header.setMsg_id(UUID.randomUUID().toString());
header.setTimestamp(System.currentTimeMillis());
header.setCmd(RTCmdType.CLOUD_CREATE_ORDER);
- header.setSequence(1L);
+ header.setSequence(sequence);
header.setType(MessageType.MESSAGE_TYPE_RESPONSE);
msgContent.setHeader(header);
// 消息内容
@@ -67,15 +67,14 @@
* @param operation
* @return
*/
- public MqttPublishDto cloudOrderOperation(OrderOperation operation, String vin) {
+ public MqttPublishDto cloudOrderOperation(OrderOperation operation, String vin,Long sequence) {
MsgContent msgContent = new MsgContent();
// 消息头
RtMsgHeader header = new RtMsgHeader();
header.setMsg_id(UUID.randomUUID().toString());
header.setTimestamp(System.currentTimeMillis());
header.setCmd(RTCmdType.CLOUD_ORDER_OPERATION);
- Snowflake snowflake = IdUtil.getSnowflake(0, 0);
- header.setSequence(snowflake.nextId());
+ header.setSequence(sequence);
header.setType(MessageType.MESSAGE_TYPE_REQUEST);
msgContent.setHeader(header);
// 消息内容
@@ -87,6 +86,10 @@
MqttPublishVo vo = new MqttPublishVo();
vo.setTopic("topic-prod-xpu-robotaxi-high/" + vin);
vo.setPayload(JSON.toJSONString(msgContent));
+
+
+
+
return xpuClient.publish(vo);
}
--
Gitblit v1.7.1