| | |
|---|
| | | import com.xiaopeng.operation.service.XpPointService; |
|---|
| | | import com.xiaopeng.operation.utils.mango.VehiclePositionService; |
|---|
| | | import com.xiaopeng.api.vo.operation.VehiclePositionVo; |
|---|
| | | import lombok.SneakyThrows; |
|---|
| | | import org.redisson.api.RLock; |
|---|
| | | import org.redisson.api.RedissonClient; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | |
|---|
| | | * @param orderNo 订单号 |
|---|
| | | * @param xpTradingStrategy 规则 |
|---|
| | | */ |
|---|
| | | @SneakyThrows |
|---|
| | | private void processPushOrder(String quoteName, int count, String uid, String[] split, String orderNo, XpTradingStrategy xpTradingStrategy, String distance, String duration, String planRule) { |
|---|
| | | System.out.println("进入推单环环节"); |
|---|
| | | if(count==0){ |
|---|
| | | count=1; |
|---|
| | | } |
|---|
| | | // 订单状态 |
|---|
| | | R<XpOrder> xpOrderR = xpOrderClient.queryOrderByOrderNo(orderNo); |
|---|
| | | if (xpOrderR.getCode() != 200) { |
|---|
| | |
|---|
| | | |
|---|
| | | // 找出围栏id |
|---|
| | | Long xpElectronicFenceAreaId = xpOrder.getXpElectronicFenceAreaId(); |
|---|
| | | XpElectronicFence xpElectronicFence = xpElectronicFenceMapper.selectById(xpElectronicFenceAreaId); |
|---|
| | | Long electronicId = xpElectronicFenceAreaService.getById(xpElectronicFenceAreaId).getElectronicId(); |
|---|
| | | XpElectronicFence xpElectronicFence = xpElectronicFenceMapper.selectById(electronicId); |
|---|
| | | |
|---|
| | | for (int i = 0; i < count; i++) { |
|---|
| | | |
|---|
| | |
|---|
| | | // 根据距离找车 |
|---|
| | | // 车多则根据配置找具体车数量 根据距离最近 |
|---|
| | | // 更改 暂不限制数量 |
|---|
| | | |
|---|
| | | List<VehiclePosition> positionList = vehiclePositionService.findAvailableVehiclesNearby(Double.parseDouble(split[0]), Double.parseDouble(split[1]), xpTradingStrategy.getOnePushDistance(), xpTradingStrategy.getSimultaneouslyOrderCount()); |
|---|
| | | |
|---|
| | | // 获取车辆的区域信息 |
|---|
