完善以运输单创建轨迹的功能逻辑，新增路径规划、轨迹点解析及轨迹点上传功能

alexyang
1 parent 8a764994
Showing 1 changed file with 138 additions and 27 deletions
sl-express-ms-track-service/src/main/java/com/sl/ms/track/service/impl/TrackServiceImpl.java
 package com.sl.ms.track.service.impl;
+import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.convert.Convert;
 import cn.hutool.core.map.MapUtil;
 import cn.hutool.core.util.StrUtil;
@@ -18,9 +19,15 @@ import com.sl.ms.track.service.TrackService;
 import com.sl.ms.work.api.TransportOrderFeign;
 import com.sl.ms.work.domain.dto.TransportOrderDTO;
 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.GeoJsonLineString;
+import org.springframework.data.mongodb.core.geo.GeoJsonPoint;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
@@ -39,49 +46,115 @@ public class TrackServiceImpl implements TrackService {
     @Autowired
     private EagleMapTemplate eagleMapTemplate;
+    /**
+     * 创建运输轨迹
+     * 根据运输单ID获取起止位置，调用高德地图API规划路线，并保存轨迹信息到MongoDB
+     *
+     * @param transportOrderId 运输单ID
+     * @return 创建成功返回true，失败返回false
+     */
     @Override
     public boolean create(String transportOrderId) {
+        // 1. 获取运输单和订单位置信息
         TransportOrderDTO transportOrderDTO = transportOrderFeign.findById(transportOrderId);
-
         OrderLocationDTO orderLocationDTO = orderFeign.findOrderLocationByOrderId(transportOrderDTO.getOrderId());
-        TrackEntity trackEntity = new TrackEntity();
-        trackEntity.setTransportOrderId(transportOrderId);
-
-        String sendLocation = orderLocationDTO.getSendLocation();
-        String receiveLocation = orderLocationDTO.getReceiveLocation();
+        // 2. 解析起止坐标（格式：经度,纬度）
+        Coordinate origin = parseCoordinate(orderLocationDTO.getSendLocation());
+        Coordinate destination = parseCoordinate(orderLocationDTO.getReceiveLocation());
-        double sendLnt = Double.parseDouble(sendLocation.split(",")[0]);
-        double sendLat = Double.parseDouble(sendLocation.split(",")[1]);
+        // 3. 调用高德地图API进行路径规划
+        Map<String, Object> param = MapUtil.<String, Object>builder()
+                .put("show_fields", "polyline") // 返回详细路径坐标
+                .build();
+        String driving = this.eagleMapTemplate.opsForDirection()
+                .driving(ProviderEnum.AMAP, origin, destination, param);
-
-        double receiveLnt = Double.parseDouble(receiveLocation.split(",")[0]);
-        double receiveLat = Double.parseDouble(receiveLocation.split(",")[1]);
-
-        Coordinate origin = new Coordinate(sendLnt, sendLat);
-        Coordinate destination = new Coordinate(receiveLnt, receiveLat);
-
-        //设置高德地图参数，默认是不返回预计耗时的，需要额外设置参数
-        Map<String, Object> param = MapUtil.<String, Object>builder().put("show_fields", "polyline").build();
-        String driving = this.eagleMapTemplate.opsForDirection().driving(ProviderEnum.AMAP, origin, destination, param);
+        // 如果路径规划失败，直接返回
         if (StrUtil.isEmpty(driving)) {
             return false;
         }
-        JSONObject jsonObject = JSONUtil.parseObj(driving);
-        //距离，单位：米
-        Double distance = Convert.toDouble(jsonObject.getByPath("route.paths[0].distance"), -1d);
+        // 4. 解析高德地图返回的路径数据
+        JSONObject routeData = JSONUtil.parseObj(driving);
+        Double distance = Convert.toDouble(routeData.getByPath("route.paths[0].distance"), -1d);
+        JSONArray steps = routeData.getByPath("route.paths[0].steps", JSONArray.class);
+
+        // 5. 从路径数据中提取所有轨迹点
+        List<Point> trackPoints = collectTrackPoints(steps);
+
+        // 6. 构建轨迹实体对象
+        TrackEntity trackEntity = new TrackEntity();
+        trackEntity.setTransportOrderId(transportOrderId);
         trackEntity.setDistance(distance);
         trackEntity.setStatus(TrackStatusEnum.NEW);
         trackEntity.setType(TrackTypeEnum.COURIER);
-        JSONArray steps = jsonObject.getByPath("route.paths[0].steps", JSONArray.class);
+        // 7. 如果轨迹点足够（至少2个点），设置规划路线
+        if (trackPoints.size() >= 2) {
+            trackEntity.setPlanGeoJsonLine(new GeoJsonLineString(trackPoints));
+            trackEntity.setLastPoint((GeoJsonPoint) trackPoints.get(0));
+        }
+
+        // 8. 保存轨迹信息到MongoDB
+        mongoTemplate.save(trackEntity);
+        return true;
+    }
+
+    /**
+     * 解析坐标字符串
+     * 将"经度,纬度"格式的字符串转换为Coordinate对象
+     *
+     * @param location 位置字符串，格式：经度,纬度（例如：116.397128,39.916527）
+     * @return Coordinate对象
+     */
+    private Coordinate parseCoordinate(String location) {
+        String[] parts = location.split(",");
+        double lng = Double.parseDouble(parts[0]);
+        double lat = Double.parseDouble(parts[1]);
+        return new Coordinate(lng, lat);
+    }
+
+    /**
+     * 从高德地图路径steps中收集所有轨迹点
+     * 遍历每个step的polyline字段，解析出所有坐标点
+     *
+     * @param steps 高德地图返回的路径步骤数组
+     * @return 轨迹点列表
+     */
+    private List<Point> collectTrackPoints(JSONArray steps) {
+        List<Point> points = new ArrayList<>();
+
         for (int i = 0; i < steps.size(); i++) {
-            JSONObject entries = steps.getJSONObject(i);
-            String polyline = entries.getStr("polyline");
+            JSONObject step = steps.getJSONObject(i);
+            String polyline = step.getStr("polyline");
+
+            if (StrUtil.isEmpty(polyline)) {
+                continue;
+            }
+
+            // polyline格式：经度1,纬度1;经度2,纬度2;经度3,纬度3...
+            String[] coordPairs = polyline.split(";");
+            for (String coordPair : coordPairs) {
+                if (StrUtil.isEmpty(coordPair)) {
+                    continue;
+                }
+
+                // 解析单个坐标点
+                String[] coords = coordPair.split(",");
+                if (coords.length == 2) {
+                    try {
+                        double lng = Double.parseDouble(coords[0].trim());
+                        double lat = Double.parseDouble(coords[1].trim());
+                        points.add(new GeoJsonPoint(lng, lat));
+                    } catch (NumberFormatException e) {
+                        // 忽略无法解析的坐标点
+                    }
+                }
+            }
         }
-        return false;
+        return points;
     }
     @Override
@@ -91,16 +164,54 @@ public class TrackServiceImpl implements TrackService {
     @Override
     public TrackEntity queryByTransportOrderId(String transportOrderId) {
-        return null;
+        Query query = Query.query(Criteria.where("transportOrderId").is(transportOrderId));
+        return mongoTemplate.findOne(query, TrackEntity.class);
     }
+    /**
+     * 上传车辆轨迹点信息
+     *
+     * @param transportTaskId 运输任务id
+     * @param lng            经度
+     * @param lat           纬度
+     * @return 上传成功返回true，失败返回false
+     */
     @Override
     public boolean uploadFromTruck(Long transportTaskId, double lng, double lat) {
         return false;
     }
+    /**
+     * 从快递员上传轨迹点信息
+     *
+     * @param transportOrderIds 运输单ID列表
+     * @param lng 经度
+     * @param lat 纬度
+     * @return 上传成功返回true，失败返回false
+     */
     @Override
     public boolean uploadFromCourier(List<String> transportOrderIds, double lng, double lat) {
-        return false;
+        // 1. 校验运输单ID列表是否为空
+        if (CollUtil.isEmpty(transportOrderIds)) {
+            return false;
+        }
+
+        // 2. 查询运输单对应的轨迹信息
+        Query query = Query.query(Criteria.where("transportOrderId").in(transportOrderIds));
+        List<TrackEntity> tracks = mongoTemplate.find(query, TrackEntity.class);
+
+        // 3. 如果没有找到对应的轨迹信息，返回false
+        if (tracks.isEmpty()) {
+            return false;
+        }
+
+        // 4. 创建新的轨迹点并更新所有轨迹的最新位置
+        GeoJsonPoint newPoint = new GeoJsonPoint(lng, lat);
+        for (TrackEntity track : tracks) {
+            track.setLastPoint(newPoint);
+            mongoTemplate.save(track);
+        }
+
+        return true;
     }
 }