From c903a3606fa825e5ecb9eaefa4127f6f9cd1fc07 Mon Sep 17 00:00:00 2001
From: xuhy <3313886187@qq.com>
Date: 星期五, 17 四月 2026 11:53:51 +0800
Subject: [PATCH] [feat] 交易策略配置管理
---
xp-robotaxi-map-boot/src/main/java/com/xiaopeng/map/controller/XpMapController.java | 116 +++++++++++++++++++++++++++++++++++++++++++---------------
1 files changed, 86 insertions(+), 30 deletions(-)
diff --git a/xp-robotaxi-map-boot/src/main/java/com/xiaopeng/map/controller/XpMapController.java b/xp-robotaxi-map-boot/src/main/java/com/xiaopeng/map/controller/XpMapController.java
index 26f640a..c08b40a 100644
--- a/xp-robotaxi-map-boot/src/main/java/com/xiaopeng/map/controller/XpMapController.java
+++ b/xp-robotaxi-map-boot/src/main/java/com/xiaopeng/map/controller/XpMapController.java
@@ -1,34 +1,46 @@
package com.xiaopeng.map.controller;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.xiaopeng.api.dto.map.HistoryPointDto;
import com.xiaopeng.api.dto.map.OrderRouteAndFareDto;
import com.xiaopeng.api.dto.map.RouteAndFareDto;
import com.xiaopeng.api.feignClient.order.XpOrderClient;
+import com.xiaopeng.api.dto.WeatherDTO;
import com.xiaopeng.api.vo.map.PointByIpVo;
import com.xiaopeng.api.vo.operation.RouteVo;
-import com.xiaopeng.common.core.constant.CacheConstants;
import com.xiaopeng.common.core.domain.R;
import com.xiaopeng.common.redis.service.RedisService;
import com.xiaopeng.map.mangodb.model.GeoPoint;
import com.xiaopeng.map.mangodb.service.XpGeoFencingPolygonService;
import com.xiaopeng.map.utils.AmapWalkingRouteUtil;
import com.xiaopeng.map.utils.GDMapGeocodingUtil;
+import com.xiaopeng.unifiedverification.interceptor.XpClientCheck;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
+import org.apache.http.HttpEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.util.EntityUtils;
import org.bson.Document;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
+import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.List;
@Slf4j
@RestController
-@RequestMapping("/base/v1/mini-program")
+@RequestMapping("")
@Api(tags = "地图调用服务")
public class XpMapController {
@@ -48,31 +60,49 @@
}
- @PostMapping("/map/getDistanceAndDuration")
+ @PostMapping("/base/v1/map/getDistanceAndDuration")
public R<RouteVo> getDistanceAndDuration(@RequestBody RouteAndFareDto dto){
// 获取电子围栏的禁行区域点位
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");
+ List<Document> pointsInFence = xpGeoFencingPolygonService.findPointsByParentId(fenceId, "fenceId", "prohibited_area");
// 避让区域
ArrayList<String> pointStrParam = new ArrayList<>();
try {
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));
- }
+ // 获取points字段（它是GeoJSON对象）
+ Document geoJsonDoc = document.get("points", Document.class);
+ if (geoJsonDoc != null && "Polygon".equals(geoJsonDoc.getString("type"))) {
+ // 获取coordinates数组
+ List<List<List<Double>>> coordinates = (List<List<List<Double>>>) geoJsonDoc.get("coordinates");
+
+ if (coordinates != null && !coordinates.isEmpty()) {
+ // 获取第一个多边形环（通常只有一个）
+ List<List<Double>> polygonPoints = coordinates.get(0);
+
+ // 转换为经纬度字符串
+ for (List<Double> point : polygonPoints) {
+ if (point.size() >= 2) {
+ pointStrParam.add(point.get(0) + "," + point.get(1));
+ }
+ }
+ }
+ }
}
- RouteVo routeVo = gdMapGeocodingUtil.getDistanceAndTime(dto.getOrigin(), dto.getDestination(), String.join("|", pointStrParam), fenceId,dto.getRoutePlanRule());
+
+ List<HistoryPointDto> history = new ArrayList<>();
+ if(null != dto.getVehicleId()){
+ history = redisService.getCacheList("VEHICLE_HISTORY_POINT_LIST:" + dto.getVehicleId());
+ }
+ if(history.size() > 10){
+ history = history.subList(history.size() - 10, history.size());
+ }
+ redisService.setCacheList("VEHICLE_HISTORY_POINT_LIST:" + dto.getVehicleId(), history);
+ RouteVo routeVo = gdMapGeocodingUtil.getDistanceAndTime(dto.getOrigin(), dto.getDestination(), pointStrParam, fenceId,dto.getRoutePlanRule(), history);
if(routeVo==null){
return R.fail("没有找到路线");
}
@@ -92,7 +122,7 @@
* @param dto
* @return
*/
- @PostMapping("/map/getOrderDistanceAndDuration")
+ @PostMapping("/base/v1/map/getOrderDistanceAndDuration")
public R<RouteVo> getOrderDistanceAndDuration(@Validated @RequestBody OrderRouteAndFareDto dto){
// 获取电子围栏的禁行区域点位
GeoPoint startPoint = new GeoPoint(dto.getOrigin().getLongitude(),dto.getOrigin().getLatitude());
@@ -106,26 +136,23 @@
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));
+ pointStrParam.add(point.getLongitude()+","+point.getLatitude());
}
}
}
-
- RouteVo routeVo = gdMapGeocodingUtil.getDistanceAndTime(dto.getOrigin(), dto.getDestination(), String.join("|", pointStrParam), fenceId,dto.getRoutePlanRule());
+ List<HistoryPointDto> history = new ArrayList<>();
+ if(null != dto.getVehicleId()){
+ history = redisService.getCacheList("VEHICLE_HISTORY_POINT_LIST:" + dto.getVehicleId());
+ }
+ if(history.size() > 10){
+ history = history.subList(history.size() - 10, history.size());
+ }
+ redisService.setCacheList("VEHICLE_HISTORY_POINT_LIST:" + dto.getVehicleId(), history);
+ RouteVo routeVo = gdMapGeocodingUtil.getDistanceAndTime(dto.getOrigin(), dto.getDestination(), pointStrParam, fenceId,dto.getRoutePlanRule(), history);
if(routeVo==null){
return R.fail("没有找到路线");
}
-
- // 存储redis
- redisService.setCacheObject(CacheConstants.ORDER_ROUTE + "_" + dto.getOrderId() + "_" +dto.getRouteType(), routeVo);
- // 存储路线偏离缓存，后续进行轨迹截取
-// redisService.setCacheObject(CacheConstants.ORDER_ROUTE_CAPTURE + "_" + dto.getOrderId() + "_" +dto.getRouteType(), routeVo);
-
return R.ok(routeVo);
}
@@ -134,7 +161,7 @@
* @param routedID
* @return
*/
- @PostMapping("/map/queryRouted")
+ @PostMapping("/base/v1/map/queryRouted")
public R<String> getOrderDistanceAndDuration(@RequestParam("routedID") String routedID){
return R.ok(gdMapGeocodingUtil.routed(routedID));
}
@@ -144,11 +171,40 @@
* 根据ip获取点位
*/
@ApiOperation(value = "根据ip获取点位", tags = {"小程序-站点导航"})
- @GetMapping("/point/getPointByIp")
+ @GetMapping("/base/v1/mini-program/point/getPointByIp")
+ @XpClientCheck(checkToken = false, checkOtpToken = true)
public R<PointByIpVo> getPointByIp(HttpServletRequest request) throws IOException {
String ip = request.getRemoteAddr();
PointByIpVo pointByIpVo = AmapWalkingRouteUtil.ipLocation(ip);
return R.ok(pointByIpVo);
}
+
+ @Value("${map.urls.weather:https://restapi.amap.com/v3/weather/weatherInfo?key=%s&city=%s}")
+ String WEATHER_URL;
+
+ @Autowired
+ ObjectMapper om;
+
+ @Value("${map.apikey:66ae577f63898dae3016d599fda57221}")
+ String key;
+
+ @ApiOperation(value = "获取天气信息", tags = {"内部-调价"})
+ @GetMapping("/logan/inner/weatherInfo")
+ public R<WeatherDTO> weather(@RequestParam String city) throws IOException {
+
+ try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
+ HttpGet httpGet = new HttpGet(String.format(WEATHER_URL, key, city));
+ try (CloseableHttpResponse response = httpClient.execute(httpGet)) {
+ HttpEntity entity = response.getEntity();
+ if (entity != null) {
+ String resp = EntityUtils.toString(entity, StandardCharsets.UTF_8);
+ System.out.println(resp);
+ return R.ok(om.readValue(resp, WeatherDTO.class));
+ }
+ return R.fail("获取天气信息失败");
+ }
+ }
+ }
+
}
--
Gitblit v1.7.1