| | |
| | | import com.xiaopeng.api.feignClient.automaticPilot.VmpOpenServiceClient; |
| | | import com.xiaopeng.api.feignClient.automaticPilot.XPUClient; |
| | | import com.xiaopeng.api.vo.automaticPilot.MqttPublishVo; |
| | | import com.xiaopeng.api.vo.automaticPilot.proto.down.*; |
| | | import com.xiaopeng.api.vo.automaticPilot.proto.down.cloudCreateOrder.RTTask; |
| | | import com.xiaopeng.api.vo.automaticPilot.proto.down.cloudOrderOperation.OrderOperation; |
| | | import com.xiaopeng.api.vo.automaticPilot.proto.down.cloudPushNavigation.RestoreNavigationData; |
| | | import com.xiaopeng.api.vo.automaticPilot.proto.up.RTCmdType; |
| | | import com.xiaopeng.api.vo.automaticPilot.protobuf.RtTaskList; |
| | | import com.xiaopeng.common.core.utils.StringUtils; |
| | | import com.xiaopeng.common.core.utils.uuid.UUID; |
| | |
| | | // 查询车管 车辆xpuid信息返回字段,用于按需返回字段 |
| | | public static final List<String> TYPE_LIST = Collections.singletonList("1"); |
| | | |
| | | private static final com.google.protobuf.util.JsonFormat.Printer jsonPrinter = com.google.protobuf.util.JsonFormat.printer().printingEnumsAsInts(); |
| | | |
| | | /** |
| | | * Robotaxi创建订单推送给XPU |
| | | * |
| | |
| | | MqttPublishVo vo = new MqttPublishVo(); |
| | | vo.setTopic(buildTopicByVin(vin)); |
| | | try { |
| | | vo.setPayload(com.google.protobuf.util.JsonFormat.printer().print(msgContentBuilder.build())); |
| | | vo.setPayload(jsonPrinter.print(msgContentBuilder.build())); |
| | | } catch (Exception e) { |
| | | log.error("Protobuf转JSON失败", e); |
| | | throw new RuntimeException("Protobuf转JSON失败", e); |
| | |
| | | MqttPublishVo vo = new MqttPublishVo(); |
| | | vo.setTopic(buildTopicByVin(vin)); |
| | | try { |
| | | vo.setPayload(com.google.protobuf.util.JsonFormat.printer().print(msgContentBuilder.build())); |
| | | vo.setPayload(jsonPrinter.print(msgContentBuilder.build())); |
| | | } catch (Exception e) { |
| | | log.error("Protobuf转JSON失败", e); |
| | | throw new RuntimeException("Protobuf转JSON失败", e); |
| | |
| | | MqttPublishVo vo = new MqttPublishVo(); |
| | | vo.setTopic(buildTopicByVin(vin)); |
| | | try { |
| | | vo.setPayload(com.google.protobuf.util.JsonFormat.printer().print(msgContentBuilder.build())); |
| | | vo.setPayload(jsonPrinter.print(msgContentBuilder.build())); |
| | | } catch (Exception e) { |
| | | log.error("Protobuf转JSON失败", e); |
| | | throw new RuntimeException("Protobuf转JSON失败", e); |
| | |
| | | MqttPublishVo vo = new MqttPublishVo(); |
| | | vo.setTopic(buildTopicByXpuId(xpuId)); |
| | | try { |
| | | vo.setPayload(com.google.protobuf.util.JsonFormat.printer().print(msgContentBuilder.build())); |
| | | vo.setPayload(jsonPrinter.print(msgContentBuilder.build())); |
| | | } catch (Exception e) { |
| | | log.error("Protobuf转JSON失败", e); |
| | | throw new RuntimeException("Protobuf转JSON失败", e); |