From 69db7506d300d39c2273ab24da38fce4e5d8cbb6 Mon Sep 17 00:00:00 2001
From: xuhy <3313886187@qq.com>
Date: 星期五, 13 二月 2026 21:04:42 +0800
Subject: [PATCH] 订单改派

---
 xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java |   31 ++++++++++++++++---------------
 1 files changed, 16 insertions(+), 15 deletions(-)

diff --git a/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java b/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java
index b142708..865ca65 100644
--- a/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java
+++ b/xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java
@@ -311,22 +311,23 @@
 //            cancelTaxiPassengerVo.setAppId();
                 userVehicleClient.cancelTaxiPassenger(cancelTaxiPassengerVo);
             }
-
             // 取消订单
-
-
-            // 重新派单
-            ReassignOrderDTO reassignOrderDTO = new ReassignOrderDTO();
-            reassignOrderDTO.setUid(xpOrder.getAppUserId().toString());
-            reassignOrderDTO.setOrderNo(xpOrder.getOrderNumber());
-            reassignOrderDTO.setCount(10);
-            RealtimePose pose = systemRuntimeStatus.getPose();
-            Wgs naviPose = pose.getNavi_pose();
-            Double latitude = naviPose.getLatitude();
-            Double longitude = naviPose.getLongitude();
-            reassignOrderDTO.setLongitude(longitude);
-            reassignOrderDTO.setLatitude(latitude);
-            reassignOrderClient.reassignOrder(reassignOrderDTO);
+            R<?> r = xpOrderClient.cancelOrder(String.valueOf(xpOrder.getId()));
+            if (r.getCode() == R.SUCCESS){
+                log.info("取消订单成功");
+                // 重新派单
+                ReassignOrderDTO reassignOrderDTO = new ReassignOrderDTO();
+                reassignOrderDTO.setUid(xpOrder.getAppUserId().toString());
+                reassignOrderDTO.setOrderNo(xpOrder.getOrderNumber());
+                reassignOrderDTO.setCount(10);
+                RealtimePose pose = systemRuntimeStatus.getPose();
+                Wgs naviPose = pose.getNavi_pose();
+                Double latitude = naviPose.getLatitude();
+                Double longitude = naviPose.getLongitude();
+                reassignOrderDTO.setLongitude(longitude);
+                reassignOrderDTO.setLatitude(latitude);
+                reassignOrderClient.reassignOrder(reassignOrderDTO);
+            }
         }
     }
 

--
Gitblit v1.7.1