From 5687d9014cd68d5e405a9cd4ad96b76c43c44b7e Mon Sep 17 00:00:00 2001
From: zhuml4 <zhuml4@xiaopeng.com>
Date: 星期六, 07 三月 2026 21:00:57 +0800
Subject: [PATCH] 增加派单流程日志
---
xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/utils/TaskOrderUtil.java | 14 +++++++-------
1 files changed, 7 insertions(+), 7 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 c9fb160..96d603b 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
@@ -102,7 +102,7 @@
*/
@Scheduled(cron = "0/5 * * * * ?")
public void taskOrder() {
- System.out.println("5秒执行一次");
+ log.info("5秒执行一次");
Set<String> quoteMatchName = redisService.getQuoteMatchName(CacheConstants.QUEUE_POINT_ID);
for (String name : quoteMatchName) {
String firstElement = redisService.getFirstElement(name);
@@ -128,7 +128,7 @@
* @param firstElement 队列第一个元素
*/
private void orderProcess(String quoteName, String firstElement) {
- System.out.println("进入处理环节");
+ log.info("进入处理环节 quoteName:{} firstElement:{}", quoteName, firstElement);
XpTradingStrategy xpTradingStrategy = xpTradingStrategyService.getOne(null);
String orderId = firstElement.split("_")[0];
String lonLat = firstElement.split("_")[1];
@@ -227,7 +227,7 @@
*/
@SneakyThrows
private void processPushOrder(String quoteName, int count, String uid, String[] split, String orderNo, XpTradingStrategy xpTradingStrategy, String distance, String duration, String planRule) {
- System.out.println("进入推单环环节");
+ log.info("进入推单环环节 orderNo: {}, quoteName:{} distance:{} duration:{} planRule:{}", orderNo, quoteName, distance, duration, planRule);
if (count == 0) {
count = 1;
}
@@ -248,7 +248,7 @@
for (int i = 0; i < count; i++) {
- System.out.println("进入找车环节");
+ log.info("进入找车环节 orderNo: {}", orderNo);
// 根据距离找车
// 车多则根据配置找具体车数量 根据距离最近
// 更改 暂不限制数量
@@ -759,7 +759,7 @@
RLock lock = redissonClient.getLock("FIND_CAR_" + vehiclePositionVo.getVin());
lock.lock(10, TimeUnit.SECONDS);
- System.err.println("队列：" + quoteName + " 车辆：" + vehiclePositionVo.getVin() + "订单" + orderNo);
+ log.error("队列：" + quoteName + " 车辆：" + vehiclePositionVo.getVin() + "订单" + orderNo);
try {
// VehiclePosition vehiclePosition = vehiclePositionService.findByVehicleId(vehiclePositionVo.getVehicle_id());
R<XpVehicle> vehiclePositionR = xpVehicleClient.findByVehicleVin(vehiclePositionVo.getVin());
@@ -851,7 +851,7 @@
*/
@SneakyThrows
public void reassignPushOrder(int count, String uid, Double longitude, Double latitude, String orderNo) {
- System.out.println("进入推单环环节");
+ log.info("进入推单环环节 orderNo:{} longitude:{} latitude:{}", orderNo, longitude, latitude);
if (count == 0) {
count = 1;
}
@@ -866,7 +866,7 @@
XpOrder data = xpOrderR.getData();
XpTradingStrategy xpTradingStrategy = xpTradingStrategyService.getOne(null);
for (int i = 0; i < count; i++) {
- log.info("进入找车环节");
+ log.info("进入找车环节 orderNo:{} longitude:{} latitude:{}", orderNo, longitude, latitude);
List<VehiclePosition> positionList = vehiclePositionService.findAvailableVehiclesNearby(longitude, latitude, xpTradingStrategy.getOnePushDistance(), xpTradingStrategy.getSimultaneouslyOrderCount());
// 获取车辆的区域信息
--
Gitblit v1.7.1