From bfa0b11dfbfe5b71e11f4544e688e4d9f325d1b5 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期一, 09 六月 2025 10:26:51 +0800
Subject: [PATCH] 修改bug和管理后台报表

---
 DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java |   51 +++++++++++++++++++++++++++++++++++++--------------
 1 files changed, 37 insertions(+), 14 deletions(-)

diff --git a/DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java b/DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java
index 766aee4..2c52b37 100644
--- a/DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java
+++ b/DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java
@@ -232,8 +232,7 @@
         Driver driver = driverService.selectById(uid);
         orderPrivateCar.setDriverId(uid);
         orderPrivateCar.setCarId(driver.getCarId());
-        orderPrivateCar.setCompanyId(driver.getFranchiseeId() != null && driver.getFranchiseeId() != 0 ? driver.getFranchiseeId() : (
-                driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
+        orderPrivateCar.setCompanyId(driver.getCompanyId());
         orderPrivateCar.setState(2);
         orderPrivateCar.setSnatchOrderTime(new Date());
         if(!StringUtils.hasLength(orderPrivateCar.getTripId())){
@@ -444,8 +443,8 @@
         new Thread(new Runnable() {
             @Override
             public void run() {
-                pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, "");
-                pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, "");
+                pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, "", "driver");
+                pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, "", "driver");
                 if(orderPrivateCar.getType() == 2){
                     pushUtil.pushFerryOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, 2);
                 }
@@ -596,6 +595,9 @@
                 }
                 break;
             case 6://结束服务(专车可以返回继续服务)不修改状态
+                if(null == lon || null == lat){
+                    return ResultUtil.error(language == 1 ? "无效的经纬度" : language == 2 ? "Invalid longitude and latitude" : "Longitude et latitude non valides");
+                }
                 orderPrivateCar.setState(6);
                 orderPrivateCar.setGetoffLon(lon);
                 orderPrivateCar.setGetoffLat(lat);
@@ -643,8 +645,8 @@
         new Thread(new Runnable() {
             @Override
             public void run() {
-                pushUtil.pushOrderState(1, finalOrderPrivateCar.getUserId(), finalOrderPrivateCar.getId(), 1, finalOrderPrivateCar.getState(), 0, "");
-                pushUtil.pushOrderState(2, finalOrderPrivateCar.getDriverId(), finalOrderPrivateCar.getId(), 1, finalOrderPrivateCar.getState(), 0, "");
+                pushUtil.pushOrderState(1, finalOrderPrivateCar.getUserId(), finalOrderPrivateCar.getId(), 1, finalOrderPrivateCar.getState(), 0, "", "driver");
+                pushUtil.pushOrderState(2, finalOrderPrivateCar.getDriverId(), finalOrderPrivateCar.getId(), 1, finalOrderPrivateCar.getState(), 0, "", "driver");
             }
         }).start();
         return ResultUtil.success(audioUrl);
@@ -674,7 +676,26 @@
             orderPrivateCar.setArriveTime(orderPrivateCar.getStartServiceTime());
         }
         
+        //使用原始里程计算费用
         orderPrivateCar = this.setMoney(orderPrivateCar, 0D, 0D);//计算费用
+        Double mileage = orderPrivateCar.getMileage();
+        Double orderMoney1 = orderPrivateCar.getOrderMoney();
+        //使用预估里程计算费用
+        Double startLat = orderPrivateCar.getStartLat();
+        Double startLon = orderPrivateCar.getStartLon();
+        Double getoffLon = orderPrivateCar.getGetoffLon();
+        Double getoffLat = orderPrivateCar.getGetoffLat();
+        DistancematrixVo distancematrix = GoogleMapUtil.getDistancematrix(startLat, startLon, getoffLat, getoffLon, orderPrivateCar.getTripId());
+        orderPrivateCar.setMileage(distancematrix.getDistance().doubleValue());
+        orderPrivateCar = this.setMoney(orderPrivateCar, 0D, 0D);
+        Double orderMoney2 = orderPrivateCar.getOrderMoney();
+        //如果原始金额小于预估金额,且比例小于95%,则使用预估金额
+        if(orderMoney1.compareTo(orderMoney2) >= 0 || orderMoney1 / orderMoney2 >= 0.95){
+            //原始金额大于预估金额或者比例大于0.95,则使用原始里程重新计算费用
+            orderPrivateCar.setMileage(mileage);
+            orderPrivateCar = this.setMoney(orderPrivateCar, 0D, 0D);//计算费用
+        }
+        
         orderPrivateCar.setPayManner(type);
         orderPrivateCar.setParkMoney(null == parkingFee ? 0D : parkingFee);
         orderPrivateCar.setRoadTollMoney(null == crossingFee ? 0D : crossingFee);
@@ -732,6 +753,11 @@
 //        }
         this.updateById(orderPrivateCar);
         
+        //回滚司机状态为空闲
+        Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
+        driver.setState(2);
+        driverService.updateById(driver);
+        
         //修改行程数据
         Car car = carService.selectById(orderPrivateCar.getCarId());
         boolean updateTrip = fleetEngineUtil.updateTrip("COMPLETE", car.getVehicleId(), null, orderPrivateCar.getTripId(), null, null, null, null, orderPrivateCar.getId(), 1);
@@ -746,7 +772,7 @@
                 try {
                     Thread.sleep(3000L);
                 } catch (InterruptedException e) {
-                    throw new RuntimeException(e);
+                    e.printStackTrace();
                 }
             }
         }else{
@@ -765,7 +791,7 @@
                 try {
                     Thread.sleep(3000L);
                 } catch (InterruptedException e) {
-                    throw new RuntimeException(e);
+                    e.printStackTrace();
                 }
             }
         }
@@ -777,17 +803,14 @@
         systemNoticeService.addSystemNotice(1, language1 == 1 ? "司机已结束本次行程,谢谢使用" : language1 == 2 ?
                 "The driver has finished the trip,thank you for using I-GO" : "Le chauffeur a terminé le trajet, merci d'utiliser I-GO", orderPrivateCar.getUserId());
 
-        //回滚司机状态为空闲
-        Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
-        driver.setState(2);
-        driverService.updateById(driver);
+        
 
         OrderPrivateCar finalOrderTaxi = orderPrivateCar;
         new Thread(new Runnable() {
             @Override
             public void run() {
-                pushUtil.pushOrderState(1, finalOrderTaxi.getUserId(), finalOrderTaxi.getId(), 1, finalOrderTaxi.getState(), 0, "");
-                pushUtil.pushOrderState(2, finalOrderTaxi.getDriverId(), finalOrderTaxi.getId(), 1, finalOrderTaxi.getState(), 0, "");
+                pushUtil.pushOrderState(1, finalOrderTaxi.getUserId(), finalOrderTaxi.getId(), 1, finalOrderTaxi.getState(), 0, "", "driver");
+                pushUtil.pushOrderState(2, finalOrderTaxi.getDriverId(), finalOrderTaxi.getId(), 1, finalOrderTaxi.getState(), 0, "", "driver");
             }
         }).start();
     

--
Gitblit v1.7.1