| | |
|---|
| | | import org.springframework.web.bind.annotation.*; |
|---|
| | | |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import java.util.Date; |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.concurrent.LinkedBlockingQueue; |
|---|
| | | import java.util.concurrent.ThreadPoolExecutor; |
|---|
| | | import java.util.concurrent.TimeUnit; |
|---|
| | |
|---|
| | | && mqttPublishDto.getCode()== 200){ |
|---|
| | | // 修改车子为接单状态 |
|---|
| | | xpVehicleClient.updateVehicleStatus(new UpdateVehicleStateDto(dto.getVin(), 1)); |
|---|
| | | |
|---|
| | | // TODO[流量接入] 通过设置的URL发送订单和导航路线给运力 |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(null != mqttPublishDto && mqttPublishDto.getCode() == 200){ |
|---|
| | |
|---|
| | | dto.setDistance(10.0); |
|---|
| | | dto.setDirection(60); |
|---|
| | | dto.setMessageType(PushMessageTypeEnum.ORDER_ROUTE.getDesc()); |
|---|
| | | xpPushMessageClient.pushOrderRoute(dto); |
|---|
| | | R<String> stringR = xpPushMessageClient.pushOrderRoute(dto); |
|---|
| | | |
|---|
| | | //存储历史轨迹 |
|---|
| | | OrderTrajectoryVo orderTrajectory = new OrderTrajectoryVo(); |
|---|
