| | |
|---|
| | | @PostMapping("/inner/pushOrder") |
|---|
| | | public R<Boolean> pushOrder(@RequestBody PushOrderDto dto) { |
|---|
| | | RTTask task = new RTTask(); |
|---|
| | | task.setOrder_id(dto.getOrderId().toString()); |
|---|
| | | task.setOrder_id(dto.getOrderId()); |
|---|
| | | task.setTask_id("MISSION_"+ IdUtil.fastUUID()); |
|---|
| | | if(dto.getOrderId().contains("XU")){ |
|---|
| | | task.setTask_type(TaskType.CRUISE); |
|---|
| | | }else { |
|---|
| | | task.setTask_type(TaskType.ROBOTAXI); |
|---|
| | | } |
|---|
| | | task.setStatus(TaskStatus.PENDING); |
|---|
| | | SnowFlake snowFlake = new SnowFlake(0, 0); |
|---|
| | | snowFlake.withStartTimestamp(1420041600000L); |
|---|
| | | long sequence = snowFlake.nextId(); |
|---|
| | | MqttPublishDto mqttPublishDto = xpuUtil.cloudCreateOrder(task, dto.getVin(),sequence); |
|---|
| | | if (mqttPublishDto.getCode()== 200) { |
|---|
| | | |
|---|
| | | // 正常单子才修改 巡游单子不修改状态 |
|---|
| | | if (!dto.getOrderId().contains("XU") && mqttPublishDto.getCode()== 200) { |
|---|
| | | // 修改车子为接单状态 |
|---|
| | | xpVehicleClient.updateVehicleStatus(new UpdateVehicleStateDto(dto.getVin(),1)); |
|---|
| | | |
|---|
