zhuml4
2026-03-06 49f2db0691d7fbb849fd46eb44d43e200e8632f1
添加日志
1个文件已修改
7 ■■■■■ 已修改文件
xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java 7 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/service/KafkaConsumerService.java
@@ -100,7 +100,9 @@
    @Resource
    private XpCruisePlanClient xpCruisePlanClient;
    private static final com.google.protobuf.util.JsonFormat.Printer jsonPrinter = com.google.protobuf.util.JsonFormat.printer()
            .printingEnumsAsInts()
            .preservingProtoFieldNames();
    /**
@@ -223,12 +225,15 @@
            StatusCode code = response.getCode();
            long requestSeq = response.getRequestSeq();
            if(code == StatusCode.OK){
                log.info("收到XPU消息的响应,code: {}, message: {}", code.getNumber(), message);
                Object sequence = redisTemplate.opsForValue().get(requestSeq);
                if(sequence!=null){
                    log.info("收到XPU消息的响应,sequence: {}", sequence);
                    JSONObject jsonObject = JSON.parseObject(sequence.toString());
                    String event = jsonObject.getString("event");
                    //推送导航的响应消息
                    if(SystemEventType.PUSH_NAVIGATION.equals(event)){
                        log.info("推送导航的响应消息,{}", jsonObject.toJSONString());
                        String orderId = jsonObject.getString("orderId");
                        String vin = jsonObject.getString("vin");
                        String orderType = jsonObject.getString("orderType");