attiya/ebike-share
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

骑行轨迹增加是否超出中国范围判断，过滤时序数据库中的异常轨迹数据

Browse Source
This commit is contained in:
jkcdev 2025-05-12 17:24:42 +08:00
parent 2fa824bcec
commit 441042b3c6
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ebike-common/src/main/java/com/cdzy/common/utils/CoordinateUtil.java
View File

@ -58,7 +58,7 @@ public class CoordinateUtil {
} }
// 国内范围判断 // 国内范围判断
private static boolean outOfChina(double lon, double lat) { public static boolean outOfChina(double lon, double lat) {
return lon < 72.004 || lon > 137.8347 || lat < 0.8293 || lat > 55.8271; return lon < 72.004 || lon > 137.8347 || lat < 0.8293 || lat > 55.8271;
} }

2
ebike-operate/src/main/java/com/cdzy/ebikeoperate/service/impl/EbikeTrackingServiceImpl.java
View File

@ -86,7 +86,7 @@ public class EbikeTrackingServiceImpl implements EbikeTrackingService {
fluxQuery.add(" |> pivot(rowKey: [\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")"); fluxQuery.add(" |> pivot(rowKey: [\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")");
QueryApi queryApi = influxDBClient.getQueryApi(); QueryApi queryApi = influxDBClient.getQueryApi();
List<EbikeTracking> points = queryApi.query(fluxQuery.toString(), EbikeTracking.class); List<EbikeTracking> points = queryApi.query(fluxQuery.toString(), EbikeTracking.class);
return points.stream().map(point -> { return points.stream().filter(point -> !CoordinateUtil.outOfChina(point.getLongitude(), point.getLatitude())).map(point -> {
EbikeTrackingDto ebikeTrackingDto = new EbikeTrackingDto(); EbikeTrackingDto ebikeTrackingDto = new EbikeTrackingDto();
BeanUtils.copyProperties(point, ebikeTrackingDto); BeanUtils.copyProperties(point, ebikeTrackingDto);
Instant _time = point.get_time(); Instant _time = point.get_time();