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

liujie

2026-02-13 54e23d819a3668b70a2e8669f799fac4f48f948c

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

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

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


                    // 取消订单处理
                }
            }
        }