| | |
| | | * @param task |
| | | * @return |
| | | */ |
| | | //TODO 没有处理feign调用的异常 |
| | | public MqttPublishDto cloudCreateOrder(RTTask task, String vin, Long sequence) { |
| | | MsgContent msgContent = new MsgContent(); |
| | | // 消息头 |
| | |
| | | String xpuId = getXpuIdByVin(vin); |
| | | //组装请求消息体 |
| | | MqttPublishVo vo = new MqttPublishVo(); |
| | | //TODO 这里的topic组装有问题 |
| | | vo.setTopic(topic + "/" + xpuId); |
| | | vo.setPayload(JSON.toJSONString(msgContent)); |
| | | return xpuClient.publish(vo); |
| | |
| | | * @param operation |
| | | * @return |
| | | */ |
| | | //TODO 没有处理feign调用的异常 |
| | | public MqttPublishDto cloudOrderOperation(OrderOperation operation, String vin,Long sequence) { |
| | | MsgContent msgContent = new MsgContent(); |
| | | // 消息头 |