refactor(KafkaConsumerService): 优化推单和取消订单处理逻辑

liujie

2026-02-13 92f584e91d0e6bb1c3b1004af6ba358198803431

 xp-robotaxi-automaticPilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java

@@ -184,16 +184,20 @@
                Object sequence = redisTemplate.opsForValue().get(requestSeq);
                if(sequence!=null){
                    String[] split = sequence.toString().split("_");

                    String typeStr = split[0];
                    // 推单处理
                    if(split[0].equals("pushOrder")){
                    if(typeStr.equals("pushOrder")){
                        PopOrderDto dto = new PopOrderDto();
                        dto.setOrderId(Long.valueOf(split[1]));
                        dto.setXpVehicleVin(split[2]);
                        xpOrderClient.popOrder(dto);
                    }else if(typeStr.equals("cancelOrder")){
                        xpOrderClient.cancelOrder(split[1]);
                    }




                    // 取消订单处理
                }
            }