| | |
|---|
| | | package com.xiaopeng.automaticPilot.controller; |
|---|
| | | |
|---|
| | | import cn.hutool.core.lang.Snowflake; |
|---|
| | | import cn.hutool.core.util.IdUtil; |
|---|
| | | import com.alibaba.fastjson2.JSON; |
|---|
| | | import com.alibaba.fastjson2.JSONObject; |
|---|
| | | import com.xiaopeng.api.dto.automaticPilot.MqttPublishDto; |
|---|
| | | import com.xiaopeng.api.dto.automaticPilot.PushOrderDto; |
|---|
| | | import com.xiaopeng.api.dto.automaticPilot.VehicleEventDTO; |
|---|
| | | import com.xiaopeng.api.dto.map.OrderRouteAndFareDto; |
|---|
| | | import com.xiaopeng.api.dto.operation.LonLatDto; |
|---|
| | | import com.xiaopeng.api.dto.order.PopOrderDto; |
|---|
| | |
|---|
| | | import com.xiaopeng.api.feignClient.vehicleConvoy.XpVehicleClient; |
|---|
| | | import com.xiaopeng.api.model.order.XpOrder; |
|---|
| | | import com.xiaopeng.api.model.vehicleConvoy.XpVehicle; |
|---|
| | | import com.xiaopeng.api.model.order.XpOrder;import com.xiaopeng.api.model.vehicleConvoy.XpVehicle; |
|---|
| | | import com.xiaopeng.api.vo.SystemEventType; |
|---|
| | | import com.xiaopeng.api.vo.automaticPilot.VehiclePosition; |
|---|
| | | import com.xiaopeng.api.vo.automaticPilot.protobuf.*; |
|---|
| | |
|---|
| | | import com.xiaopeng.common.redis.service.RedisService; |
|---|
| | | import io.swagger.annotations.Api; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.data.geo.Point; |
|---|
| | | import org.springframework.data.mongodb.core.MongoTemplate; |
|---|
| | | import org.springframework.data.mongodb.core.geo.GeoJsonPoint; |
|---|
| | |
|---|
| | | import org.springframework.web.bind.annotation.*; |
|---|
| | | |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.Date; |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Map; |
|---|
| | | import java.util.concurrent.LinkedBlockingQueue; |
|---|
| | | import java.util.concurrent.ThreadPoolExecutor; |
|---|
| | | import java.util.concurrent.TimeUnit; |
|---|
| | |
|---|
| | | |
|---|
| | | long sequence = snowflake.nextId(); |
|---|
| | | MqttPublishDto mqttPublishDto = xpuUtil.cloudCreateOrder(taskListBuilder.build(), dto.getVin(),sequence); |
|---|
| | | |
|---|
| | | //先将车辆修改状态，防止在异步通知之前被其他订单选中 |
|---|
| | | if(!dto.getOrderType().equals(com.xiaopeng.api.vo.OrderType.CRUISE_ORDER) && |
|---|
| | | !dto.getOrderType().equals(com.xiaopeng.api.vo.OrderType.TEST_CRUISE_ORDER) |
|---|
| | | && mqttPublishDto.getCode()== 200){ |
|---|
| | | // 修改车子为接单状态 |
|---|
| | | xpVehicleClient.updateVehicleStatus(new UpdateVehicleStateDto(dto.getVin(), 1)); |
|---|
| | | |
|---|
| | | // TODO[流量接入] 通过设置的URL发送订单和导航路线给运力 |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(null != mqttPublishDto && mqttPublishDto.getCode() == 200){ |
|---|
