1.

王通
1 parent 6d293f6b
Showing 3 changed files with 112 additions and 2 deletions
src/main/java/com/bsth/controller/LsStationRouteController.java
src/main/java/com/bsth/service/LsStationRouteService.java
src/main/java/com/bsth/service/impl/LsStationRouteServiceImpl.java
@@ -201,4 +201,19 @@ public class LsStationRouteController extends BaseController&lt;LsStationRoute, Int
         return result;
     }
+
+    @RequestMapping(value = "/analyzeRoutes")
+    public Map<String, Object> analyzeRoutes(Integer lineId, Integer version, Integer direction) {
+        Map<String, Object> result = new HashMap<>();
+        try {
+            result.putAll(lsStationRouteService.analyzeRoutes(lineId, version, direction));
+            result.put("status", ResponseCode.SUCCESS);
+        } catch (Exception e) {
+            result.put("status", ResponseCode.ERROR);
+            result.put("msg", e.getMessage());
+            log.error("", e);
+        }
+
+        return result;
+    }
 }
@@ -79,4 +79,12 @@ public interface LsStationRouteService extends BaseService&lt;LsStationRoute, Integ
 	 * @return
 	 */
 	Map<String, Object> circularRouteHandle(Integer lineId, Integer version);
+
+	/**
+	 * 分析路由
+	 * @param lineId
+	 * @param version
+	 * @param direction
+	 */
+	Map<String, Object> analyzeRoutes(Integer lineId, Integer version, Integer direction);
 }
@@ -5,12 +5,15 @@ import com.bsth.entity.*;
 import com.bsth.entity.search.CustomerSpecs;
 import com.bsth.repository.*;
 import com.bsth.service.LsStationRouteService;
-import com.bsth.util.CoordinateConverter;
 import com.bsth.util.CustomBeanUtils;
+import com.bsth.util.Geo.GeoUtils;
+import com.bsth.util.Geo.Point;
 import com.bsth.util.GeoConverter;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import org.geolatte.geom.LineString;
-import org.geolatte.geom.Point;
 import org.geolatte.geom.Polygon;
+import org.geolatte.geom.Position;
 import org.geolatte.geom.codec.Wkt;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.Sort;
@@ -327,6 +330,90 @@ public class LsStationRouteServiceImpl extends BaseServiceImpl&lt;LsStationRoute, I
         return new HashMap<>();
     }
+    @Override
+    public Map<String, Object> analyzeRoutes(Integer lineId, Integer version, Integer direction) {
+        Map<String, Object>  result = new HashMap<>(), params = new HashMap<>();
+        params.put("line.id_eq", lineId);
+        params.put("versions_eq", version);
+        params.put("directions_eq", direction);
+        List<Sort.Order> orders1 = new ArrayList<>(), orders2 = new ArrayList<>();
+        orders1.add(new Sort.Order(Sort.Direction.ASC, "directions"));
+        orders1.add(new Sort.Order(Sort.Direction.ASC, "stationRouteCode"));
+        orders2.add(new Sort.Order(Sort.Direction.ASC, "directions"));
+        orders2.add(new Sort.Order(Sort.Direction.ASC, "sectionrouteCode"));
+
+        boolean isCircularRoute = false;
+        List<LsStationRoute> stationRoutes = lsStationRouteRepository.findAll(new CustomerSpecs<>(params), Sort.by(orders1));
+        List<LsSectionRoute> sectionRoutes = lsSectionRouteRepository.findAll(new CustomerSpecs<>(params), Sort.by(orders2));
+        List<String> indexes = new ArrayList<>();
+        if (stationRoutes.get(0).getStationCode().equals(stationRoutes.get(stationRoutes.size() - 1).getStationCode())) {
+            isCircularRoute = true;
+        }
+        for (LsSectionRoute sectionRoute : sectionRoutes) {
+            LineString lineString = sectionRoute.getSection().getGsectionVector();
+            for (int i = 0;i < lineString.getNumPositions() - 1;i++) {
+                List<Point> points = new ArrayList<>();
+                Position start = lineString.getPositionN(i), end = lineString.getPositionN(i + 1);
+                Point point1 = new Point(start.getCoordinate(0), start.getCoordinate(1));
+                Point point2 = new Point(end.getCoordinate(0), end.getCoordinate(1));
+                int size = (int) (GeoUtils.getDistance(point1, point2) / 5) + 1;
+                points.add(point1);
+                if (size > 1) {
+                    double offsetLon = (point2.getLon() - point1.getLon()) / size;
+                    double offsetLat = (point2.getLat() - point1.getLat()) / size;
+                    for (int j = 1;j < size;j++) {
+                        Point mid = new Point(point1.getLon() + offsetLon * j, point1.getLat() + offsetLat * j);
+                        points.add(mid);
+                    }
+                }
+                points.add(point2);
+                for (Point p : points) {
+                    for (int j = 0;j < stationRoutes.size();j++) {
+                        LsStationRoute stationRoute = stationRoutes.get(j);
+                        if ("r".equals(stationRoute.getShapedType())) {
+                            org.geolatte.geom.Point center = stationRoute.getStation().getCenterPointWgs();
+                            if (GeoUtils.getDistance(p, new Point(center.getPositionN(0).getCoordinate(0), center.getPositionN(0).getCoordinate(1))) <= stationRoute.getRadius()) {
+                                if (indexes.size() == 0 || !indexes.get(indexes.size() - 1).endsWith("-" + j)) {
+                                    indexes.add(stationRoute.getStationCode() + "-" + j);
+                                }
+                                break;
+                            }
+                        } else {
+                            Polygon polygon = stationRoute.getBufferPolygonWgs();
+                            List<com.bsth.util.Geo.Point> polygonPoint = new ArrayList<>();
+                            for (int k = 0;k < polygon.getNumPositions();k++) {
+                                polygonPoint.add(new Point(polygon.getPositionN(k).getCoordinate(0), polygon.getPositionN(k).getCoordinate(1)));
+                            }
+                            com.bsth.util.Geo.Polygon polygon1 = new com.bsth.util.Geo.Polygon(polygonPoint);
+                            if (GeoUtils.isPointInPolygon(p, polygon1)) {
+                                if (indexes.size() == 0 || !indexes.get(indexes.size() - 1).endsWith("-" + j)) {
+                                    indexes.add(stationRoute.getStationCode() + "-" + j);
+                                }
+                                break;
+                            }
+                        }
+                    }
+                }
+            }
+        }
+        List<String> specialStations = new ArrayList<>();
+        result.put("data", specialStations);
+        for (int i = 0;i < stationRoutes.size();) {
+            String lastMatch = null;
+            for (int j = 0;j < indexes.size();j++) {
+                String index = indexes.get(j), suffix = String.format("-%d", i);
+                if (index.endsWith(suffix) || isCircularRoute && i == stationRoutes.size() - 1 && index.endsWith("-0")) {
+                    lastMatch = index;
+                    i++;
+                } else {
+                    specialStations.add(String.format("%s, %s", index, lastMatch));
+                }
+            }
+        }
+
+        return result;
+    }
+
     protected void centerPoint(Station station) {
         // 中心点坐标信息
         String wkt = station.getCenterPointWkt();