From db7fa6a91b9534ac90e219b6f554c54c43c83a5a Mon Sep 17 00:00:00 2001 From: liujie <liujie> Date: 星期三, 16 八月 2023 09:28:15 +0800 Subject: [PATCH] update --- driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderPositionServiceImpl.java | 43 ++++++++++++++++++++++++++++++++++++------- 1 files changed, 36 insertions(+), 7 deletions(-) diff --git a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderPositionServiceImpl.java b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderPositionServiceImpl.java index 45792f6..00b1cd2 100644 --- a/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderPositionServiceImpl.java +++ b/driver/guns-admin/src/main/java/com/supersavedriving/driver/modular/system/service/impl/OrderPositionServiceImpl.java @@ -48,8 +48,12 @@ @Override public void saveOrderPosition(DriverPositionWarpper driverPositionWarpper) throws Exception { Integer orderId = driverPositionWarpper.getOrderId(); + Integer driverId = driverPositionWarpper.getDriverId(); Order order = orderService.selectById(orderId); - if(order.getState() != 105){ + if(null == order.getDriverId() || order.getDriverId().compareTo(driverId) != 0){ + return; + } + if(order.getState() != 105 && order.getState() != 401){ return; } Integer orderType = driverPositionWarpper.getOrderType(); @@ -70,7 +74,15 @@ String toLonLat = orderPositionWarpper1.getLon() + "," + orderPositionWarpper1.getLat(); Map<String, Double> distance = GeodesyUtil.getDistance(fromLonLat, toLonLat); Double wgs84 = distance.get("WGS84"); - if(wgs84 >= 50 && wgs84 <= 165){//5秒165米 + +// long timeMillis = System.currentTimeMillis(); +// long time = orderPositionWarpper1.getInsertTime().getTime(); +// long t = timeMillis - time; +// if(wgs84 >= 200 && t <= 8){//排除位置漂移 +// return; +// } + + if(wgs84 >= 50){//5秒165米 OrderPositionWarpper orderPositionWarpper = new OrderPositionWarpper(); BeanUtils.copyProperties(driverPositionWarpper, orderPositionWarpper); orderPositionWarpper.setInsertTime(new Date()); @@ -103,7 +115,15 @@ Order order = orderService.selectById(driverPositionWarpper.getOrderId()); Double wgs84 = distance.get("WGS84"); Integer num = map.get(order.getId().toString()); - if(50 < wgs84 && wgs84 <= 165){//5秒165米 + +// long timeMillis = System.currentTimeMillis(); +// long time = orderPositionWarpper.getInsertTime().getTime(); +// long t = timeMillis - time; +// if(wgs84 >= 200 && t <= 8){//排除位置漂移 +// return; +// } + + if(50 < wgs84){//5秒165米 order.setActualMileage(order.getActualMileage() + wgs84.intValue()); orderService.updateById(order); map.put(order.getId().toString(), 0); @@ -119,10 +139,14 @@ } } } - if(50 >= wgs84 && 12 <= (null == num ? 0 : num)){//1分钟(5秒上传一次数据) + + if(50 >= wgs84 && 6 <= (null == num ? 0 : num)){//30秒(5秒上传一次数据) Integer integer = map.get(order.getId().toString()); - map.put(order.getId().toString(), null == integer ? 0 : integer++); + map.put(order.getId().toString(), null == integer ? 0 : integer + 1); //进入等待状态 + if(order.getState() == 401){ + return; + } ProcessOperationsWarpper processOperationsWarpper = new ProcessOperationsWarpper(); processOperationsWarpper.setOrderId(order.getId()); processOperationsWarpper.setState(401); @@ -132,9 +156,9 @@ e.printStackTrace(); } } - if(50 >= wgs84 && 12 > (null == num ? 0 : num)){ + if(50 >= wgs84 && 6 > (null == num ? 0 : num)){ Integer integer = map.get(order.getId().toString()); - map.put(order.getId().toString(), null == integer ? 0 : integer++); + map.put(order.getId().toString(), null == integer ? 0 : integer + 1); } } @@ -172,4 +196,9 @@ } + @Override + public void initMap(Long orderId) throws Exception { + map.put(orderId.toString(), 0); + } + } -- Gitblit v1.7.1