From 4fe4a4616b3c762eafabe238acf40fac30fd25a3 Mon Sep 17 00:00:00 2001
From: zhouhn <zhouhn@xiaopeng.com>
Date: 星期六, 07 三月 2026 20:57:57 +0800
Subject: [PATCH] snowflake雪花算法的实现改为使用hutool工具库里面的实现
---
xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/OrderMissionController.java | 39 ++++++++++++++-------------------------
1 files changed, 14 insertions(+), 25 deletions(-)
diff --git a/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/OrderMissionController.java b/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/OrderMissionController.java
index 526dc11..67aea93 100644
--- a/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/OrderMissionController.java
+++ b/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/OrderMissionController.java
@@ -1,12 +1,11 @@
package com.xiaopeng.automaticPilot.controller;
+import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.util.IdUtil;
import com.xiaopeng.api.dto.automaticPilot.MqttPublishDto;
import com.xiaopeng.api.dto.automaticPilot.PushOrderDto;
import com.xiaopeng.api.dto.vehicleConvoy.UpdateVehicleStateDto;
import com.xiaopeng.api.feignClient.vehicleConvoy.XpVehicleClient;
-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;
import com.xiaopeng.api.vo.automaticPilot.proto.down.cloudCreateOrder.TaskStatus;
import com.xiaopeng.api.vo.automaticPilot.proto.down.cloudCreateOrder.TaskType;
@@ -14,7 +13,6 @@
import com.xiaopeng.api.vo.automaticPilot.proto.down.cloudOrderOperation.OrderOperationType;
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;
@@ -28,52 +26,43 @@
@Api(tags = "订单任务Api")
public class OrderMissionController {
-
private final XPUUtil xpuUtil;
private final RedisService redisService;
private final XpVehicleClient xpVehicleClient;
+ private final Snowflake snowflake;
- public OrderMissionController(XPUUtil xpuUtil, RedisService redisService, XpVehicleClient xpVehicleClient) {
+ public OrderMissionController(XPUUtil xpuUtil, RedisService redisService, XpVehicleClient xpVehicleClient, Snowflake snowflake) {
this.xpuUtil = xpuUtil;
this.redisService = redisService;
this.xpVehicleClient = xpVehicleClient;
+ this.snowflake = snowflake;
}
-
-
-
@PostMapping("/inner/pushOrder")
public R<Boolean> pushOrder(@RequestBody PushOrderDto dto) {
RTTask task = new RTTask();
task.setOrder_id(dto.getOrderId().toString());
- task.setTask_id("MISSION_"+ IdUtil.fastUUID());
+ 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();
- MqttPublishDto mqttPublishDto = xpuUtil.cloudCreateOrder(task, dto.getVin(),sequence);
- if (mqttPublishDto.getCode()== 200) {
- // 修改车子为微单状态
- xpVehicleClient.updateVehicleStatus(new UpdateVehicleStateDto(dto.getVin(),1));
-
+ long sequence = snowflake.nextId();
+ MqttPublishDto mqttPublishDto = xpuUtil.cloudCreateOrder(task, dto.getVin(), sequence);
+ if (mqttPublishDto.getCode() == 200) {
+ xpVehicleClient.updateVehicleStatus(new UpdateVehicleStateDto(dto.getVin(), 1));
return R.ok(true);
}
return R.ok(false);
}
-
@PostMapping("/inner/cancelOrder")
- R<Boolean> cancelOrder(@RequestBody PushOrderDto dto){
+ R<Boolean> cancelOrder(@RequestBody PushOrderDto dto) {
OrderOperation operation = new OrderOperation();
operation.setOrder_id(dto.getOrderId().toString());
- operation.setTask_id("CANCEL_MISSION_"+ IdUtil.fastUUID());
+ operation.setTask_id("CANCEL_MISSION_" + IdUtil.fastUUID());
operation.setOperation_type(dto.getOperation_type());
- SnowFlake snowFlake = new SnowFlake(0, 0);
- snowFlake.withStartTimestamp(1420041600000L);
- long sequence = snowFlake.nextId();
- xpuUtil.cloudOrderOperation(operation,dto.getVin(),sequence);
- redisService.setCacheObject(String.valueOf(sequence),"cancelOrder_"+dto.getOrderId()+"_"+ dto.getVin(),30l, TimeUnit.MINUTES);
+ long sequence = snowflake.nextId();
+ xpuUtil.cloudOrderOperation(operation, dto.getVin(), sequence);
+ redisService.setCacheObject(String.valueOf(sequence), "cancelOrder_" + dto.getOrderId() + "_" + dto.getVin(), 30L, TimeUnit.MINUTES);
return R.ok(true);
}
}
--
Gitblit v1.7.1