From 2f8852273c3f9be8c3e01799ee6d9a4ed692ab63 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期五, 06 三月 2026 17:10:36 +0800
Subject: [PATCH] 添加车端消息推送重试机制
---
xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/utils/TaskOrderUtil.java | 31 +++++++++++++++----------------
1 files changed, 15 insertions(+), 16 deletions(-)
diff --git a/xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/utils/TaskOrderUtil.java b/xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/utils/TaskOrderUtil.java
index bf7424f..036fbe6 100644
--- a/xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/utils/TaskOrderUtil.java
+++ b/xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/utils/TaskOrderUtil.java
@@ -52,35 +52,38 @@
@Resource
private RedisService redisService;
- @Autowired
+ @Resource
private XpPointService xpPointService;
- @Autowired
+ @Resource
private IXpElectronicFenceAreaService xpElectronicFenceAreaService;
- @Autowired
+ @Resource
private XpOrderClient xpOrderClient;
- @Autowired
+ @Resource
private VehiclePositionService vehiclePositionService;
- @Autowired
+ @Resource
private IXpTradingStrategyService xpTradingStrategyService;
- @Autowired
+ @Resource
private XpCruiseOrderClient xpCruiseOrderClient;
- @Autowired
+ @Resource
private XpVehicleClient xpVehicleClient;
- @Autowired
+ @Resource
private RedissonClient redissonClient;
- @Autowired
+ @Resource
private XpMapClient xpMapClient;
//
- @Autowired
+ @Resource
private OrderMissionClient orderMissionClient;
+
+ @Resource
+ private XpElectronicFenceMapper xpElectronicFenceMapper;
// 自定义线程池
@@ -94,9 +97,6 @@
threadPoolTaskExecutor.setThreadNamePrefix("taskOrder-");
threadPoolTaskExecutor.initialize();
}
-
- @Autowired
- private XpElectronicFenceMapper xpElectronicFenceMapper;
/**
* 5秒执行一次
@@ -235,7 +235,8 @@
*/
@SneakyThrows
private void processPushOrder(String quoteName, int count, String uid, String[] split, String orderNo, XpTradingStrategy xpTradingStrategy, String distance, String duration, String planRule) {
-
+ // 卡住3秒
+ Thread.sleep(3000);
System.out.println("进入推单环环节");
if (count == 0) {
count = 1;
@@ -256,8 +257,6 @@
XpElectronicFence xpElectronicFence = xpElectronicFenceMapper.selectById(electronicId);
for (int i = 0; i < count; i++) {
- // 卡住3秒
- Thread.sleep(3000);
System.out.println("进入找车环节");
// 根据距离找车
// 车多则根据配置找具体车数量 根据距离最近
--
Gitblit v1.7.1