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/system/service/impl/OrderServiceImpl.java |  142 +++++++++++++++++++++++-----------------------
 1 files changed, 71 insertions(+), 71 deletions(-)

diff --git a/DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/OrderServiceImpl.java b/DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/OrderServiceImpl.java
index 245f79a..9d8d1a9 100644
--- a/DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/OrderServiceImpl.java
+++ b/DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/OrderServiceImpl.java
@@ -799,31 +799,31 @@
      */
     @Override
     public void taskMidAxbUnBindSend() throws Exception {
-        List<OrderTaxi> list = orderTaxiService.taskMidAxbUnBindSend();
-        for(OrderTaxi orderTaxi : list){
-            Map<String, String> map = chinaMobileUtil.midAxbUnBindSend(orderTaxi.getBindId(),orderTaxi.getTelX());
-            if(!String.valueOf(map.get("code")).equals("200")){
-                System.err.println(String.valueOf(map.get("msg")));
-            }
-            orderTaxi.setTelX("");
-            orderTaxi.setBindId("");
-        }
-        if(list.size() > 0){
-            orderTaxiService.updateBatchById(list);
-        }
-
-        List<OrderPrivateCar> list1 = orderPrivateCarService.taskMidAxbUnBindSend();
-        for(OrderPrivateCar orderPrivateCar : list1){
-            Map<String, String> map = chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(),orderPrivateCar.getTelX());
-            if(!String.valueOf(map.get("code")).equals("200")){
-                System.err.println(String.valueOf(map.get("msg")));
-            }
-            orderPrivateCar.setTelX("");
-            orderPrivateCar.setBindId("");
-        }
-        if(list1.size() > 0){
-            orderPrivateCarService.updateBatchById(list1);
-        }
+//        List<OrderTaxi> list = orderTaxiService.taskMidAxbUnBindSend();
+//        for(OrderTaxi orderTaxi : list){
+//            Map<String, String> map = chinaMobileUtil.midAxbUnBindSend(orderTaxi.getBindId(),orderTaxi.getTelX());
+//            if(!String.valueOf(map.get("code")).equals("200")){
+//                System.err.println(String.valueOf(map.get("msg")));
+//            }
+//            orderTaxi.setTelX("");
+//            orderTaxi.setBindId("");
+//        }
+//        if(list.size() > 0){
+//            orderTaxiService.updateBatchById(list);
+//        }
+//
+//        List<OrderPrivateCar> list1 = orderPrivateCarService.taskMidAxbUnBindSend();
+//        for(OrderPrivateCar orderPrivateCar : list1){
+//            Map<String, String> map = chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(),orderPrivateCar.getTelX());
+//            if(!String.valueOf(map.get("code")).equals("200")){
+//                System.err.println(String.valueOf(map.get("msg")));
+//            }
+//            orderPrivateCar.setTelX("");
+//            orderPrivateCar.setBindId("");
+//        }
+//        if(list1.size() > 0){
+//            orderPrivateCarService.updateBatchById(list1);
+//        }
     }
 
 
@@ -839,57 +839,57 @@
             case 1:
                 OrderPrivateCar orderPrivateCar = orderPrivateCarService.selectById(orderId);
                 if(ToolUtil.isNotEmpty(orderPrivateCar.getBindId())){
-                    Map<String, String> map1 = chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(),orderPrivateCar.getTelX());
-                    if(!String.valueOf(map1.get("code")).equals("200")){
-                        System.err.println(String.valueOf(map1.get("msg")));
-                    }
+//                    Map<String, String> map1 = chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(),orderPrivateCar.getTelX());
+//                    if(!String.valueOf(map1.get("code")).equals("200")){
+//                        System.err.println(String.valueOf(map1.get("msg")));
+//                    }
                     //调用移动的小号接口
-                    Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
-                    Region region = regionMapper.query(geocode.get("districtCode"));
-                    Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
-                    Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), Integer.valueOf(region.getCitycode().substring(1)));
-                    if(String.valueOf(map.get("code")).equals("200")){
-                        orderPrivateCar.setTelX(map.get("telX"));
-                        orderPrivateCar.setBindId(map.get("bindId"));
-                    }
+//                    Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
+//                    Region region = regionMapper.query(geocode.get("districtCode"));
+//                    Driver driver = driverService.selectById(orderPrivateCar.getDriverId());
+//                    Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), Integer.valueOf(region.getCitycode().substring(1)));
+//                    if(String.valueOf(map.get("code")).equals("200")){
+//                        orderPrivateCar.setTelX(map.get("telX"));
+//                        orderPrivateCar.setBindId(map.get("bindId"));
+//                    }
                     orderPrivateCarService.updateById(orderPrivateCar);
                 }
                 break;
             case 2:
                 OrderTaxi orderTaxi = orderTaxiService.selectById(orderId);
                 if(ToolUtil.isNotEmpty(orderTaxi.getBindId())){
-                    Map<String, String> map1 = chinaMobileUtil.midAxbUnBindSend(orderTaxi.getBindId(),orderTaxi.getTelX());
-                    if(!String.valueOf(map1.get("code")).equals("200")){
-                        System.err.println(String.valueOf(map1.get("msg")));
-                    }
+//                    Map<String, String> map1 = chinaMobileUtil.midAxbUnBindSend(orderTaxi.getBindId(),orderTaxi.getTelX());
+//                    if(!String.valueOf(map1.get("code")).equals("200")){
+//                        System.err.println(String.valueOf(map1.get("msg")));
+//                    }
                     //调用移动的小号接口
-                    Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderTaxi.getStartLon().toString(), orderTaxi.getStartLat().toString());
-                    Region region = regionMapper.query(geocode.get("districtCode"));
-                    Driver driver = driverService.selectById(orderTaxi.getDriverId());
-                    Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderTaxi.getPassengersPhone(), driver.getPhone(), Integer.valueOf(region.getCitycode().substring(1)));
-                    if(String.valueOf(map.get("code")).equals("200")){
-                        orderTaxi.setTelX(map.get("telX"));
-                        orderTaxi.setBindId(map.get("bindId"));
-                    }
+//                    Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderTaxi.getStartLon().toString(), orderTaxi.getStartLat().toString());
+//                    Region region = regionMapper.query(geocode.get("districtCode"));
+//                    Driver driver = driverService.selectById(orderTaxi.getDriverId());
+//                    Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderTaxi.getPassengersPhone(), driver.getPhone(), Integer.valueOf(region.getCitycode().substring(1)));
+//                    if(String.valueOf(map.get("code")).equals("200")){
+//                        orderTaxi.setTelX(map.get("telX"));
+//                        orderTaxi.setBindId(map.get("bindId"));
+//                    }
                     orderTaxiService.updateById(orderTaxi);
                 }
                 break;
             case 3:
                 OrderCrossCity orderCrossCity = orderCrossCityService.selectById(orderId);
                 if(ToolUtil.isNotEmpty(orderCrossCity.getBindId())){
-                    Map<String, String> map1 = chinaMobileUtil.midAxbUnBindSend(orderCrossCity.getBindId(),orderCrossCity.getTelX());
-                    if(!String.valueOf(map1.get("code")).equals("200")){
-                        System.err.println(String.valueOf(map1.get("msg")));
-                    }
+//                    Map<String, String> map1 = chinaMobileUtil.midAxbUnBindSend(orderCrossCity.getBindId(),orderCrossCity.getTelX());
+//                    if(!String.valueOf(map1.get("code")).equals("200")){
+//                        System.err.println(String.valueOf(map1.get("msg")));
+//                    }
                     //调用移动的小号接口
-                    Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderCrossCity.getStartLon().toString(), orderCrossCity.getStartLat().toString());
-                    Region region = regionMapper.query(geocode.get("districtCode"));
-                    Driver driver = driverService.selectById(orderCrossCity.getDriverId());
-                    Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderCrossCity.getPassengersPhone(), driver.getPhone(), Integer.valueOf(region.getCitycode().substring(1)));
-                    if(String.valueOf(map.get("code")).equals("200")){
-                        orderCrossCity.setTelX(map.get("telX"));
-                        orderCrossCity.setBindId(map.get("bindId"));
-                    }
+//                    Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderCrossCity.getStartLon().toString(), orderCrossCity.getStartLat().toString());
+//                    Region region = regionMapper.query(geocode.get("districtCode"));
+//                    Driver driver = driverService.selectById(orderCrossCity.getDriverId());
+//                    Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderCrossCity.getPassengersPhone(), driver.getPhone(), Integer.valueOf(region.getCitycode().substring(1)));
+//                    if(String.valueOf(map.get("code")).equals("200")){
+//                        orderCrossCity.setTelX(map.get("telX"));
+//                        orderCrossCity.setBindId(map.get("bindId"));
+//                    }
                     orderCrossCityService.updateById(orderCrossCity);
                 }
                 break;
@@ -1050,8 +1050,8 @@
         new Thread(new Runnable() {
             @Override
             public void run() {
-                pushUtil.pushOrderState(1, finalUserId, orderId, orderType, finalState, 0, "");
-                pushUtil.pushOrderState(2, finalDriverId, orderId, orderType, finalState, 0, "");
+                pushUtil.pushOrderState(1, finalUserId, orderId, orderType, finalState, 0, "", "driver");
+                pushUtil.pushOrderState(2, finalDriverId, orderId, orderType, finalState, 0, "", "driver");
             }
         }).start();
         return ResultUtil.success();
@@ -1304,12 +1304,12 @@
     @Override
     public void overGoogleOrder() {
         List<OrderPrivateCar> privateCars = orderPrivateCarService.selectList(new EntityWrapper<OrderPrivateCar>().isNotNull("tripId")
-                .eq("isover", 0).in("state", Arrays.asList(7, 8, 9, 10)).eq("isDelete", 1));
+                .eq("isover", 0).in("state", Arrays.asList(6, 7, 8, 9, 10, 12)).eq("isDelete", 1));
         for (OrderPrivateCar privateCar : privateCars) {
             Integer state = privateCar.getState();
             String tripId = privateCar.getTripId();
             String trip = fleetEngineUtil.getTrip(tripId);
-            if("" == trip){
+            if(null != trip && "" == trip){
                 privateCar.setIsover(1);
                 orderPrivateCarService.updateById(privateCar);
                 continue;
@@ -1332,7 +1332,7 @@
                             try {
                                 Thread.sleep(3000L);
                             } catch (InterruptedException e) {
-                                throw new RuntimeException(e);
+                                e.printStackTrace();
                             }
                         }
                     }else{
@@ -1354,7 +1354,7 @@
                             try {
                                 Thread.sleep(3000L);
                             } catch (InterruptedException e) {
-                                throw new RuntimeException(e);
+                                e.printStackTrace();
                             }
                         }
                     }else{
@@ -1365,12 +1365,12 @@
             }
         }
         List<OrderLogistics> orderLogisticsList = orderLogisticsService.selectList(new EntityWrapper<OrderLogistics>().isNotNull("tripId")
-                .eq("isover", 0).in("state", Arrays.asList(7, 8, 9, 10)).eq("isDelete", 1));
+                .eq("isover", 0).in("state", Arrays.asList(6, 7, 8, 9, 10, 12)).eq("isDelete", 1));
         for (OrderLogistics orderLogistics : orderLogisticsList) {
             Integer state = orderLogistics.getState();
             String tripId = orderLogistics.getTripId();
             String trip = fleetEngineUtil.getTrip(tripId);
-            if("" == trip){
+            if(null != trip && "" == trip){
                 orderLogistics.setIsover(1);
                 orderLogisticsService.updateById(orderLogistics);
                 continue;
@@ -1393,7 +1393,7 @@
                             try {
                                 Thread.sleep(3000L);
                             } catch (InterruptedException e) {
-                                throw new RuntimeException(e);
+                                e.printStackTrace();
                             }
                         }
                     }else{
@@ -1415,7 +1415,7 @@
                             try {
                                 Thread.sleep(3000L);
                             } catch (InterruptedException e) {
-                                throw new RuntimeException(e);
+                                e.printStackTrace();
                             }
                         }
                     }else{

--
Gitblit v1.7.1