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/controller/OrderMissionController.java | 27 +++++++++++++++------------
1 files changed, 15 insertions(+), 12 deletions(-)
diff --git a/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/OrderMissionController.java b/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/OrderMissionController.java
index 9387716..42d3ba1 100644
--- a/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/OrderMissionController.java
+++ b/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/OrderMissionController.java
@@ -1,5 +1,8 @@
package com.xiaopeng.automaticPilot.controller;
+import cn.hutool.core.util.IdUtil;
+import com.xiaopeng.api.dto.automaticPilot.MqttPublishDto;
+import com.xiaopeng.api.dto.automaticPilot.PushOrderDto;
import com.xiaopeng.api.vo.automaticPilot.proto.down.ResponseMessage;
import com.xiaopeng.api.vo.automaticPilot.proto.down.StatusCode;
import com.xiaopeng.api.vo.automaticPilot.proto.down.cloudCreateOrder.RTTask;
@@ -8,12 +11,12 @@
import com.xiaopeng.automaticPilot.util.XPUUtil;
import com.xiaopeng.common.core.domain.R;
import com.xiaopeng.common.core.utils.SnowFlake;
+import com.xiaopeng.common.redis.service.RedisService;
import io.swagger.annotations.Api;
import lombok.extern.slf4j.Slf4j;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.concurrent.TimeUnit;
@Slf4j
@RestController
@@ -23,28 +26,28 @@
private final XPUUtil xpuUtil;
+ private final RedisService redisService;
- public OrderMissionController(XPUUtil xpuUtil) {
+ public OrderMissionController(XPUUtil xpuUtil, RedisService redisService) {
this.xpuUtil = xpuUtil;
+ this.redisService = redisService;
}
@PostMapping("/inner/pushOrder")
- public R<Boolean> pushOrder(@RequestParam Long orderId) {
-
+ public R<Boolean> pushOrder(@RequestBody PushOrderDto dto) {
RTTask task = new RTTask();
- task.setOrder_id(orderId.toString());
- // TODO id处理 已经数据是否存储
- task.setTask_id(System.currentTimeMillis()+ "");
+ task.setOrder_id(dto.getOrderId().toString());
+ task.setTask_id("MISSION_"+ IdUtil.fastUUID());
task.setTask_type(TaskType.ROBOTAXI);
task.setStatus(TaskStatus.PENDING);
SnowFlake snowFlake = new SnowFlake(0, 0);
snowFlake.withStartTimestamp(1420041600000L);
long sequence = snowFlake.nextId();
- ResponseMessage responseMessage = xpuUtil.cloudCreateOrder(task,sequence);
- if (responseMessage.getCode()== StatusCode.OK) {
+ MqttPublishDto mqttPublishDto = xpuUtil.cloudCreateOrder(task, dto.getVin(),sequence);
+ if (mqttPublishDto.getCode()== 200) {
return R.ok(true);
}
return R.ok(false);
--
Gitblit v1.7.1