| | |
|---|
| | | // 获取电子围栏的禁行区域点位 |
|---|
| | | GeoPoint startPoint = new GeoPoint(dto.getOrigin().getLongitude(),dto.getOrigin().getLatitude()); |
|---|
| | | List<String> operatingArea = xpGeoFencingPolygonService.findFencesContainingPoint(startPoint, "operating_area", "points"); |
|---|
| | | String fenceId = operatingArea.get(0); |
|---|
| | | List<Document> pointsInFence = xpGeoFencingPolygonService.findPointsByParentId(fenceId, "parentId", "prohibited_area"); |
|---|
| | | // 避让区域 |
|---|
| | | ArrayList<String> pointStrParam = new ArrayList<>(); |
|---|
| | | for (Document document : pointsInFence) { |
|---|
| | | List<GeoPoint> points = document.getList("points", GeoPoint.class); |
|---|
| | | // 一个区域的点位 |
|---|
| | | ArrayList<String> pointStr = new ArrayList<>(); |
|---|
| | | for (GeoPoint point : points) { |
|---|
| | | pointStr.add( point.getLongitude()+","+point.getLatitude()); |
|---|
| | | ArrayList<String> pointStrParam = null; |
|---|
| | | String fenceId = null; |
|---|
| | | if(!operatingArea.isEmpty()){ |
|---|
| | | fenceId = operatingArea.get(0); |
|---|
| | | List<Document> pointsInFence = xpGeoFencingPolygonService.findPointsByParentId(fenceId, "parentId", "prohibited_area"); |
|---|
| | | if(!pointsInFence.isEmpty()){ |
|---|
| | | pointStrParam = new ArrayList<>(); |
|---|
| | | } |
|---|
| | | if(!pointStr.isEmpty()){ |
|---|
| | | pointStrParam.add(String.join(";", pointStr)); |
|---|
| | | for (Document document : pointsInFence) { |
|---|
| | | List<GeoPoint> points = document.getList("points", GeoPoint.class); |
|---|
| | | // 一个区域的点位 |
|---|
| | | ArrayList<String> pointStr = new ArrayList<>(); |
|---|
| | | for (GeoPoint point : points) { |
|---|
| | | pointStr.add( point.getLongitude()+","+point.getLatitude()); |
|---|
| | | } |
|---|
| | | if(!pointStr.isEmpty()){ |
|---|
| | | pointStrParam.add(String.join(";", pointStr)); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | RouteVo routeVo = gdMapGeocodingUtil.getDistanceAndTime(dto.getOrigin(), dto.getDestination(), String.join("|", pointStrParam), fenceId,dto.getRoutePlanRule()); |
|---|
| | | if(routeVo==null){ |
|---|
| | | return R.fail("没有找到路线"); |
|---|
| | |
|---|
| | | |
|---|
| | | // 存储redis |
|---|
| | | redisService.setCacheObject(CacheConstants.ORDER_ROUTE + "_" + dto.getOrderId() + "_" +dto.getRouteType(), routeVo); |
|---|
| | | // 查询订单信息 |
|---|
| | | XpOrder xpOrder = xpOrderClient.queryOrderById(dto.getOrderId()).getData(); |
|---|
| | | // 封装消息内容 |
|---|
| | | Integer routeType = dto.getRouteType(); |
|---|
| | | if(routeType == 2){ |
|---|
| | | routeType = 3; |
|---|
| | | }else { |
|---|
| | | routeType = xpOrder.getStatus() == 4 ? 1 : 2; |
|---|
| | | } |
|---|
| | | // 存储路线偏离缓存，后续进行轨迹截取 |
|---|
| | | redisService.setCacheObject(CacheConstants.ORDER_ROUTE_CAPTURE + "_" + dto.getOrderId() + "_" +routeType, routeVo); |
|---|
| | | // redisService.setCacheObject(CacheConstants.ORDER_ROUTE_CAPTURE + "_" + dto.getOrderId() + "_" +dto.getRouteType(), routeVo); |
|---|
| | | |
|---|
| | | return R.ok(routeVo); |
|---|
| | | } |
|---|
