From 441042b3c6c0bc85aa4b02ebb1e79eb139327291 Mon Sep 17 00:00:00 2001 From: jkcdev Date: Mon, 12 May 2025 17:24:42 +0800 Subject: [PATCH] =?UTF-8?q?=E9=AA=91=E8=A1=8C=E8=BD=A8=E8=BF=B9=E5=A2=9E?= =?UTF-8?q?=E5=8A=A0=E6=98=AF=E5=90=A6=E8=B6=85=E5=87=BA=E4=B8=AD=E5=9B=BD?= =?UTF-8?q?=E8=8C=83=E5=9B=B4=E5=88=A4=E6=96=AD=EF=BC=8C=E8=BF=87=E6=BB=A4?= =?UTF-8?q?=E6=97=B6=E5=BA=8F=E6=95=B0=E6=8D=AE=E5=BA=93=E4=B8=AD=E7=9A=84?= =?UTF-8?q?=E5=BC=82=E5=B8=B8=E8=BD=A8=E8=BF=B9=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/cdzy/common/utils/CoordinateUtil.java | 2 +- .../ebikeoperate/service/impl/EbikeTrackingServiceImpl.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/ebike-common/src/main/java/com/cdzy/common/utils/CoordinateUtil.java b/ebike-common/src/main/java/com/cdzy/common/utils/CoordinateUtil.java index b3940588..b9037810 100644 --- a/ebike-common/src/main/java/com/cdzy/common/utils/CoordinateUtil.java +++ b/ebike-common/src/main/java/com/cdzy/common/utils/CoordinateUtil.java @@ -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; } diff --git a/ebike-operate/src/main/java/com/cdzy/ebikeoperate/service/impl/EbikeTrackingServiceImpl.java b/ebike-operate/src/main/java/com/cdzy/ebikeoperate/service/impl/EbikeTrackingServiceImpl.java index 744e6bb1..c84c2e63 100644 --- a/ebike-operate/src/main/java/com/cdzy/ebikeoperate/service/impl/EbikeTrackingServiceImpl.java +++ b/ebike-operate/src/main/java/com/cdzy/ebikeoperate/service/impl/EbikeTrackingServiceImpl.java @@ -86,7 +86,7 @@ public class EbikeTrackingServiceImpl implements EbikeTrackingService { fluxQuery.add(" |> pivot(rowKey: [\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")"); QueryApi queryApi = influxDBClient.getQueryApi(); List 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(); BeanUtils.copyProperties(point, ebikeTrackingDto); Instant _time = point.get_time();