[Java] 纯文本查看 复制代码
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.ToString;
import net.sf.geographiclib.Geodesic;
import org.apache.commons.lang3.StringUtils;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.function.Function;
import java.util.stream.Collectors;
/**
* @ClassName: DPUtil
* @Package: tos-product
* @Description: 点位数优化
* @Author: [email]sen.yang@youhualin.com[/email]
* @Date: 2021/6/25 9:25
* @Copyright: 悠桦林信息科技（上海）有限公司
*/
public class DpUtil {
/**
* 默认的点到轨迹线最大距离误差阈值（单位：米）
*/
private static final double DEFAULTD_MAX = 30.0;
/**
* @param dis 经纬度字符串
* @param range 控制数据经度压缩的极差
*/
public static String smooth(String dis, double range) {
String[] points = dis.split(";");
List<String> strings = Arrays.asList(points);
//拆分list，这里的意思是每10条算一条曲线，利用道格拉斯-普克算法对这条曲线进行优化
List<List<String>> lists = CollectionUtils.splitList(strings, strings.size() / 2);
List<TyPoint> tyPointList = new ArrayList<>();
int id = 0;
for (List<String> stringList : lists) {
List<TyPoint> list = new ArrayList<>();
for (int i = 0; i < stringList.size(); i++) {
if (StringUtils.isNotBlank(stringList.get(i))) {
TyPoint data = new TyPoint();
data.setId(id);
String[] split = stringList.get(i).split(",");
data.setX(Double.parseDouble(split[0]));
data.setY(Double.parseDouble(split[1]));
list.add(data);
id++;
}
}
List<TyPoint> list1 = dpAlgorithm(list, range);
tyPointList.addAll(list1);
}
StringBuilder res = new StringBuilder();
Map<Integer, TyPoint> collect = tyPointList.stream().distinct().collect(Collectors.toMap(TyPoint::getId, Function.identity(), (k1, k2) -> k2));
for (int i = 0; i < strings.size(); i++) {
TyPoint tyPoint = collect.get(i);
if (tyPoint != null) {
res.append(tyPoint.getX()).append(",").append(tyPoint.getY()).append(";");
}
}
res.deleteCharAt(res.lastIndexOf(";"));
return res.toString();
}
/**
* DP算法入口
* 传入压缩前的轨迹点集合
* 输出压缩后的结果轨迹点集合
*
* @param originPoints 压缩前的轨迹点集合
* @param dMax 点到轨迹线最大距离误差阈值
* @return 优化结果
*/
public static List<TyPoint> dpAlgorithm(List<TyPoint> originPoints, Double dMax) {
List<TyPoint> resultPoints = new ArrayList<>();
resultPoints.add(originPoints.get(0));//获取第一个原始经纬度点坐标并添加到过滤后的数组中
resultPoints.add(originPoints.get(originPoints.size() - 1));//获取最后一个原始经纬度点坐标并添加到过滤后的数组中
//最大距离误差阈值
if (dMax == null) {
dMax = DEFAULTD_MAX;
}
int start = 0;
int end = originPoints.size() - 1;
compression(originPoints, resultPoints, start, end, dMax);
return resultPoints;
}
/**
* 函数功能：根据最大距离限制，采用DP方法递归的对原始轨迹进行采样，得到压缩后的轨迹
*
* @param originPoints：原始经纬度坐标点数组
* @param resultPoints：保持过滤后的点坐标数组
* @param start：起始下标
* @param end：终点下标
* @param dMax：预先指定好的最大距离误差 计算
*/
public static void compression(List<TyPoint> originPoints, List<TyPoint> resultPoints,
int start, int end, double dMax) {
if (start < end) {//递归进行的条件
double maxDist = 0;//最大距离
int curPt = 0;//当前下标
for (int i = start + 1; i < end; i++) {
//当前点到对应线段的距离
double curDist = distToSegment(originPoints.get(start), originPoints.get(end), originPoints.get(i));
if (curDist > maxDist) {
maxDist = curDist;
curPt = i;
}//求出最大距离及最大距离对应点的下标
}
//若当前最大距离大于最大距离误差
if (maxDist >= dMax) {
resultPoints.add(originPoints.get(curPt));//将当前点加入到过滤数组中
//将原来的线段以当前点为中心拆成两段，分别进行递归处理
compression(originPoints, resultPoints, start, curPt, dMax);
compression(originPoints, resultPoints, curPt, end, dMax);
}
}
}
/**
* 函数功能：使用三角形面积（使用海伦公式求得）相等方法计算点pX到点pA和pB所确定的直线的距离
*
* @param pA：起始点
* @param pB：结束点
* @param pX：第三个点
* @return distance：点pX到pA和pB所在直线的距离
*/
public static double distToSegment(TyPoint pA, TyPoint pB, TyPoint pX) {
double a = Math.abs(Geodesic.WGS84.Inverse(pA.y, pA.x, pB.y, pB.x).s12);
double b = Math.abs(Geodesic.WGS84.Inverse(pA.y, pA.x, pX.y, pX.x).s12);
double c = Math.abs(Geodesic.WGS84.Inverse(pB.y, pB.x, pX.y, pX.x).s12);
double p = (a + b + c) / 2.0;
double s = Math.sqrt(Math.abs(p * (p - a) * (p - b) * (p - c)));
return s * 2.0 / a;
}
/**
* 返回一个点是否在一个多边形边界上
*
* @param polygon 多边形坐标点列表
* @param point1 待判断点
* @return true 点在多边形边上,false 点不在多边形边上。
*/
public static boolean isPointInPolygonBoundary(String point1, String polygon) {
String[] split = point1.split(",");
TyPoint point = new TyPoint(0, Double.parseDouble(split[0]), Double.parseDouble(split[1]));
List<TyPoint> mPoints = new ArrayList<>();
String[] split1 = polygon.split(";");
for (int i = 0; i < split1.length; i++) {
String[] split2 = split1[i].split(",");
mPoints.add(new TyPoint(i, Double.parseDouble(split2[0]), Double.parseDouble(split2[1])));
}
for (int i = 0; i < mPoints.size(); i++) {
TyPoint p1 = mPoints.get(i);
TyPoint p2 = mPoints.get((i + 1) % mPoints.size());
// 取多边形任意一个边,做点point的水平延长线,求解与当前边的交点个数
// point 在p1p2 底部 --> 无交点
if (point.y < Math.min(p1.y, p2.y))
continue;
// point 在p1p2 顶部 --> 无交点
if (point.y > Math.max(p1.y, p2.y))
continue;
// p1p2是水平线段,要么没有交点,要么有无限个交点
if (p1.y == p2.y) {
double minX = Math.min(p1.x, p2.x);
double maxX = Math.max(p1.x, p2.x);
// point在水平线段p1p2上,直接return true
if ((point.y == p1.y) && (point.x >= minX && point.x <= maxX)) {
return true;
}
} else { // 求解交点
double x = (point.y - p1.y) * (p2.x - p1.x) / (p2.y - p1.y) + p1.x;
if (x == point.x) // 当x=point.x时,说明point在p1p2线段上
return true;
}
}
return false;
}
}
@Data
@NoArgsConstructor
@AllArgsConstructor
@ToString
class TyPoint {
public int id;//点ID
public double x;//经度
public double y;//纬度
}
[复制链接]
发表于 2021-6-24 17:10
|
发表于 2021-7-2 16:04
