From e2d01b2009c30173ff8e9f77d5c065f4d38fa49d Mon Sep 17 00:00:00 2001
From: 44323 <443237572@qq.com>
Date: 星期五, 17 五月 2024 17:56:07 +0800
Subject: [PATCH] Merge branch '2.0' of http://120.76.84.145:10101/gitblit/r/java/IgoTravel into 2.0

---
 DriverIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java |  347 ++++++++++++++++++++++++++++++++++-----------------------
 1 files changed, 208 insertions(+), 139 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 ef646b4..2337ffb 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
@@ -4,6 +4,7 @@
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.baomidou.mybatisplus.service.impl.ServiceImpl;
+import com.stylefeng.guns.core.util.ToolUtil;
 import com.stylefeng.guns.modular.specialTrain.dao.OrderPrivateCarMapper;
 import com.stylefeng.guns.modular.specialTrain.model.OrderPrivateCar;
 import com.stylefeng.guns.modular.specialTrain.server.IOrderPrivateCarService;
@@ -13,8 +14,11 @@
 import com.stylefeng.guns.modular.system.model.*;
 import com.stylefeng.guns.modular.system.service.*;
 import com.stylefeng.guns.modular.system.util.*;
+import com.stylefeng.guns.modular.system.util.quartz.QuartzUtil;
+import com.stylefeng.guns.modular.system.util.quartz.jobs.OrderTimeOutJob;
 import com.stylefeng.guns.modular.taxi.model.OrderTaxi;
 import com.stylefeng.guns.modular.taxi.service.IOrderTaxiService;
+import org.quartz.JobDataMap;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
@@ -24,6 +28,9 @@
 import java.io.FileWriter;
 import java.io.PrintWriter;
 import java.math.BigDecimal;
+import java.math.MathContext;
+import java.math.RoundingMode;
+import java.text.SimpleDateFormat;
 import java.util.*;
 
 
@@ -64,13 +71,7 @@
     private GDMapElectricFenceUtil gdMapElectricFenceUtil;
 
     @Autowired
-    private PushMinistryOfTransportUtil pushMinistryOfTransportUtil;
-
-    @Autowired
     private IOrderTaxiService orderTaxiService;
-
-    @Value("${pushMinistryOfTransport}")
-    private boolean pushMinistryOfTransport;
 
 
     @Resource
@@ -82,9 +83,18 @@
     @Autowired
     private IIncomeService incomeService;
 
+    @Autowired
+    private IPaymentRecordService paymentRecordService;
+
+    @Autowired
+    private ITransactionDetailsService transactionDetailsService;
+
 
     @Value("${filePath}")
     private String filePath;
+    
+    @Autowired
+    private IReminderRulesService reminderRulesService;
 
 
 
@@ -98,8 +108,15 @@
      * @throws Exception
      */
     @Override
-    public List<Map<String, Object>> queryOrderList(Integer state, Integer driverId) throws Exception {
-        return orderPrivateCarMapper.queryOrderList(state, driverId);
+    public List<Map<String, Object>> queryOrderList(Integer state, Integer driverId, Integer language) throws Exception {
+        List<Map<String, Object>> list = orderPrivateCarMapper.queryOrderList(state, driverId, language);
+        for (Map<String, Object> map : list) {
+            if(null != map.get("time")){
+                String time = map.get("time").toString();
+                map.put("time", DateUtil.conversionFormat(language, time));
+            }
+        }
+        return list;
     }
 
     /**
@@ -110,8 +127,15 @@
      * @throws Exception
      */
     @Override
-    public List<Map<String, Object>> queryMyAllOrder(Integer state, Integer uid) throws Exception {
-        return orderPrivateCarMapper.queryMyAllOrder(state, uid);
+    public List<Map<String, Object>> queryMyAllOrder(Integer state, Integer uid, Integer language) throws Exception {
+        List<Map<String, Object>> list = orderPrivateCarMapper.queryMyAllOrder(state, uid, language);
+        for (Map<String, Object> map : list) {
+            if(null != map.get("time")){
+                String time = map.get("time").toString();
+                map.put("time", DateUtil.conversionFormat(language, time));
+            }
+        }
+        return list;
     }
 
 
@@ -122,8 +146,13 @@
      * @throws Exception
      */
     @Override
-    public Map<String, Object> queryPushOrder(Integer orderId) throws Exception {
-        return orderPrivateCarMapper.queryPushOrder(orderId);
+    public Map<String, Object> queryPushOrder(Integer orderId, Integer language) throws Exception {
+        Map<String, Object> map = orderPrivateCarMapper.queryPushOrder(orderId, language);
+        if(null != map.get("travelTime")){
+            String travelTime = map.get("travelTime").toString();
+            map.put("travelTime", DateUtil.conversionFormat1(language, travelTime));
+        }
+        return map;
     }
 
 
@@ -136,7 +165,7 @@
      * @throws Exception
      */
     @Override
-    public synchronized ResultUtil grabOrder(Integer orderId, Integer uid) throws Exception {
+    public synchronized ResultUtil grabOrder(Integer orderId, Integer uid, Integer language) throws Exception {
         OrderPrivateCar orderPrivateCar = this.selectById(orderId);
         //处理摆渡车的情况
         if(orderPrivateCar.getType() == 2){
@@ -158,15 +187,15 @@
                             .eq("place", orderPrivateCar.getPlace())
             );
             if(list.size() > 0 || list1.size() > 0){
-                return ResultUtil.error("手速有点慢哦,订单已被抢啦!");
+                return ResultUtil.error(language == 1 ? "手速有点慢哦,订单已被抢啦" : language == 2 ? "Too slow, order was snatched!" : "Trop lent, l’ordre a été arraché!");
             }
         }
 
-        if(orderPrivateCar.getState() == 9){
-            return ResultUtil.error("订单已取消");
+        if(orderPrivateCar.getState() == 10){
+            return ResultUtil.error(language == 1 ? "订单已取消" : language == 2 ? "Order cancelled" : "Commande annulée");
         }
         if(orderPrivateCar.getState() != 1){
-            return ResultUtil.error("手速有点慢哦,订单已被抢啦!");
+            return ResultUtil.error(language == 1 ? "手速有点慢哦,订单已被抢啦" : language == 2 ? "Too slow, order was snatched!" : "Trop lent, l’ordre a été arraché!");
         }
         Driver driver = driverService.selectById(uid);
         orderPrivateCar.setDriverId(uid);
@@ -175,21 +204,6 @@
                 driver.getCompanyId() != null && driver.getCompanyId() != 0 ? driver.getCompanyId() : 1));
         orderPrivateCar.setState(2);
         orderPrivateCar.setSnatchOrderTime(new Date());
-
-        //调用高德创建轨迹
-//        String s = gdFalconUtil.selectTerminal(driver.getPhone());
-//        String track = gdFalconUtil.createTrack(s);
-//        orderPrivateCar.setTrackId(track);
-
-        //调用移动的小号接口
-        /*Map<String, String> geocode = gdMapGeocodingUtil.geocode(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
-        Region region = regionMapper.query(geocode.get("districtCode"));*/
-//        Map<String, String> map = chinaMobileUtil.midAxbBindSend(orderPrivateCar.getPassengersPhone(), driver.getPhone(), null);
-//        if(String.valueOf(map.get("code")).equals("200")){
-//            orderPrivateCar.setTelX(map.get("telX"));
-//            orderPrivateCar.setBindId(map.get("bindId"));
-//        }
-//        System.out.println(map);
         this.updateById(orderPrivateCar);
 
         //如果是预约单,则不修改司机为服务中
@@ -198,7 +212,52 @@
             driver.setState(3);
             driverService.updateById(driver);
         }
-
+        
+        
+        //todo 待翻译
+        //添加定时任务(普通任务)
+        ReminderRules reminderRules = reminderRulesService.selectOne(new EntityWrapper<ReminderRules>().eq("companyId", driver.getCompanyId()));
+        if(null != reminderRules){
+            JSONObject jsonObject = JSON.parseObject(reminderRules.getContent());
+            //预约单
+            if(orderPrivateCar.getOrderType() == 1){
+                long specialCarTimeoutReminderInterval = jsonObject.getInteger("specialCarTimeoutReminderInterval") * 60000L;
+                long m = (System.currentTimeMillis() - orderPrivateCar.getSnatchOrderTime().getTime()) / 60000;
+                JobDataMap jobDataMap = new JobDataMap();
+                jobDataMap.put("driverId", uid);
+                jobDataMap.put("orderId", orderPrivateCar.getId());
+                jobDataMap.put("orderType", 1);
+                jobDataMap.put("describe", "您的打车订单已超时" + m + "分钟,请抓紧!");
+                QuartzUtil.addSimpleQuartzTask(
+                        new OrderTimeOutJob().buildQuartzJob(UUIDUtil.getRandomCode(5) + "_" + orderPrivateCar.getId() + "_1", "ORDER_TIME_OUT", jobDataMap)
+                        , new Date(specialCarTimeoutReminderInterval), specialCarTimeoutReminderInterval, -1);
+            }else{
+                UserInfo userInfo = userInfoMapper.selectById(orderPrivateCar.getUserId());
+                JSONObject reservationOrder = jsonObject.getJSONObject("reservationOrder");
+                long appointmentReminder = reservationOrder.getInteger("appointmentReminder") * 60000L;
+                long appointmentTimeoutReminderInterval = reservationOrder.getInteger("appointmentTimeoutReminderInterval") * 60000L;
+                SimpleDateFormat sdf = new SimpleDateFormat("");
+                JobDataMap jobDataMap = new JobDataMap();
+                jobDataMap.put("driverId", uid);
+                jobDataMap.put("orderId", orderPrivateCar.getId());
+                jobDataMap.put("orderType", 1);
+                jobDataMap.put("describe", "您将于" + sdf.format(orderPrivateCar.getTravelTime()) + "去接" + userInfo.getFirstName() + " " + userInfo.getLastName() + ",请准时!");
+                QuartzUtil.addSimpleQuartzTask(
+                        new OrderTimeOutJob().buildQuartzJob(UUIDUtil.getRandomCode(5) + "_" + orderPrivateCar.getId() + "_1", "ORDER_TIME_OUT", jobDataMap)
+                        , new Date(appointmentReminder), appointmentReminder, 0);
+    
+                
+                jobDataMap = new JobDataMap();
+                jobDataMap.put("driverId", uid);
+                jobDataMap.put("orderId", orderPrivateCar.getId());
+                jobDataMap.put("orderType", 1);
+                jobDataMap.put("describe", "您将于" + sdf.format(orderPrivateCar.getTravelTime()) + "去接" + userInfo.getFirstName() + " " + userInfo.getLastName() + ",请准时!");
+                QuartzUtil.addSimpleQuartzTask(
+                        new OrderTimeOutJob().buildQuartzJob(UUIDUtil.getRandomCode(5) + "_" + orderPrivateCar.getId() + "_1", "ORDER_TIME_OUT", jobDataMap)
+                        , new Date(appointmentReminder + appointmentTimeoutReminderInterval), appointmentTimeoutReminderInterval, -1);
+            }
+        }
+        
         //推送相关代码------------------start----------------
         new Thread(new Runnable() {
             @Override
@@ -211,27 +270,13 @@
             }
         }).start();
 
-        new Thread(new Runnable() {
-            @Override
-            public void run() {
-                pushUtil.pushDriverPosition(orderId, 1);
-            }
-        }).start();
 
-        systemNoticeService.addSystemNotice(2, "您已成功抢得专车订单,请及时联系客户!", orderPrivateCar.getDriverId());
-        systemNoticeService.addSystemNotice(1, "您的订单已指派给" + driver.getName().substring(0, 1) + "师傅,请保持电话畅通!", orderPrivateCar.getUserId());
-
-        new Thread(new Runnable() {
-            @Override
-            public void run() {
-                if(pushMinistryOfTransport){
-                    //上传数据
-                    pushMinistryOfTransportUtil.orderCreate(orderId);
-                    pushMinistryOfTransportUtil.orderMatch(orderId);
-                }
-            }
-        }).start();
-
+        systemNoticeService.addSystemNotice(2, language == 1 ? "您已成功抢得打车订单,请及时联系客户!" :
+                language == 2 ? "You have grabbed the ride order, please contact the client timely."
+                        : "Vous avez saisi la commande de course, veuillez contacter le client en temps opportun.", orderPrivateCar.getDriverId());
+        systemNoticeService.addSystemNotice(1, language == 1 ? "您的订单已指派给" + driver.getFirstName() + "师傅,请保持电话畅通!" :
+                language == 2 ? "Your order has been assigned to the driver- " + driver.getFirstName() + ", please keep your line on."
+                        : "Votre commande a été attribuée au chauffeur- " + driver.getFirstName() + ", S'il vous plaît, restez en ligne.", orderPrivateCar.getUserId());
         return ResultUtil.success();
     }
 
@@ -244,8 +289,14 @@
      * @throws Exception
      */
     @Override
-    public Map<String, Object> queryOrderInfo(Integer orderId) throws Exception {
-        return orderPrivateCarMapper.queryOrderInfo(orderId);
+    public Map<String, Object> queryOrderInfo(Integer language, Integer orderId) throws Exception {
+        Map<String, Object> map = orderPrivateCarMapper.queryOrderInfo(orderId);
+        if(null != map.get("travelTime_")){
+            String travelTime_ = map.get("travelTime_").toString();
+            map.put("travelTime_", DateUtil.conversionFormat1(language, travelTime_));
+        }
+        map.put("cancelUser", language == 1 ? "用户" : language == 2 ? "The client" : "Le client");
+        return map;
     }
 
 
@@ -258,33 +309,30 @@
      * @throws Exception
      */
     @Override
-    public ResultUtil process(Integer orderId, Integer state, Double lon, Double lat, String address,String phone) throws Exception {
+    public ResultUtil process(Integer orderId, Integer state, Double lon, Double lat, String address,String phone, Integer language) throws Exception {
         OrderPrivateCar orderPrivateCar = this.selectById(orderId);
-        if(state==5){
-            UserInfo userInfo = userInfoMapper.selectById(orderPrivateCar.getUserId());
-            if(!userInfo.getPhone().substring(7, userInfo.getPhone().length()).equals(phone)){
-                return ResultUtil.error("手机号错误");
-            }
+        if(orderPrivateCar.getState().compareTo(state) == 0){
+            return ResultUtil.error(language == 1 ? "不能重复操作" : language == 2 ? "Unable to recur operate" : "Impossible de récurrence des opérer");
         }
         if(state==3 && orderPrivateCar.getState()!=2){
-            return ResultUtil.error("当前订单不能触发前往预约地点");
+            return ResultUtil.error(language == 1 ? "当前订单不能触发前往预约地点" : language == 2 ? "The current order cannot trigger travel to the reservation" : "La commande en cours ne peut pas déclencher une visite au lieu de rendez-vous");
         }
         if(state==4 && orderPrivateCar.getState()!=3){
-            return ResultUtil.error("当前订单不能到达预约地点");
+            return ResultUtil.error(language == 1 ? "当前订单不能到达预约地点" : language == 2 ? "The current order cannot arrive at the reservation" : "La commande en cours ne peut pas atteindre le rendez-vous");
         }
-        /*if(state==5 && orderPrivateCar.getState()!=4){
-            return ResultUtil.error("当前订单不能开始服务");
-        }*/
         switch (state){
             case 3://出发前往预约点
                 orderPrivateCar.setState(3);
                 orderPrivateCar.setSetOutTime(new Date());
-                systemNoticeService.addSystemNotice(1, "司机已出发,请耐心等待", orderPrivateCar.getUserId());
+                systemNoticeService.addSystemNotice(1, language == 1 ? "司机已出发,请耐心等待" : language == 2 ? "The driver is on the way, please wait." : "Le chauffeur est en route. Veuillez patienter.", orderPrivateCar.getUserId());
+                pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);//主动推送司机定位
                 break;
             case 4://到达预约点,等待客户上车
                 orderPrivateCar.setState(4);
                 orderPrivateCar.setArriveTime(new Date());
-                systemNoticeService.addSystemNotice(1, "司机已到达您设置的预约地点,请及时上车", orderPrivateCar.getUserId());
+                systemNoticeService.addSystemNotice(1, language == 1 ? "司机已到达您设置的预约地点,请及时上车" : language == 2 ?
+                        "The driver has arrived at the reserved location, please get in timely." :
+                        "Le chauffeur est arrivé à l'endroit prévu, veuillez monter dans la voiture à temps.", orderPrivateCar.getUserId());
                 break;
             case 5://开始服务
                 orderPrivateCar.setBoardingLon(lon);
@@ -294,16 +342,6 @@
                 orderPrivateCar.setState(5);
                 orderPrivateCar.setStartServiceTime(new Date());
 
-                pushUtil.pushDriverPosition(orderPrivateCar.getId(), 1);//主动推送司机定位
-
-                new Thread(new Runnable() {
-                    @Override
-                    public void run() {
-                        if(pushMinistryOfTransport){//上传数据
-                            pushMinistryOfTransportUtil.operateDepart(orderId);
-                        }
-                    }
-                }).start();
                 OrderPosition orderPosition = new OrderPosition();
                 orderPosition.setOrderId(orderId);
                 orderPosition.setOrderType(1);
@@ -329,6 +367,7 @@
                 out.close();
                 break;
             case 6://结束服务(专车可以返回继续服务)不修改状态
+                orderPrivateCar.setState(6);
                 orderPrivateCar.setGetoffLon(lon);
                 orderPrivateCar.setGetoffLat(lat);
                 orderPrivateCar.setGetoffAddress(address);
@@ -362,7 +401,7 @@
      * @throws Exception
      */
     @Override
-    public ResultUtil confirmFees(Integer orderId, Integer type, Double parkingFee, Double crossingFee) throws Exception {
+    public ResultUtil confirmFees(Integer language, Integer orderId, Integer type, Double parkingFee, Double crossingFee) throws Exception {
         OrderPrivateCar orderPrivateCar = this.selectById(orderId);
         if(orderPrivateCar.getArriveTime()==null){
             orderPrivateCar.setArriveTime(orderPrivateCar.getStartServiceTime());
@@ -393,7 +432,7 @@
                     }
                     if(company.getIsSpeFixedOrProportional() == 1){//比例
                         Double price = orderPrivateCar.getStartMoney() + orderPrivateCar.getMileageMoney() + orderPrivateCar.getWaitMoney() + orderPrivateCar.getDurationMoney() + orderPrivateCar.getLongDistanceMoney();
-                        d = new BigDecimal(price).multiply(new BigDecimal(speMoney).divide(new BigDecimal(100))).setScale(2, BigDecimal.ROUND_HALF_EVEN);
+                        d = new BigDecimal(price).multiply(new BigDecimal(speMoney).divide(new BigDecimal(100), new MathContext(2, RoundingMode.HALF_EVEN)));
                         c = new BigDecimal(orderPrivateCar.getOrderMoney()).subtract(d).setScale(2, BigDecimal.ROUND_HALF_EVEN);
                     }
                     incomeService.saveData(1, orderPrivateCar.getCompanyId(), 2, orderPrivateCar.getId(), 1, d.doubleValue());
@@ -427,7 +466,8 @@
 
 
         pushUtil.removeTask(orderId, 1);//删除定时任务,结束推送数据
-        systemNoticeService.addSystemNotice(1, "司机已结束本次行程,谢谢使用", orderPrivateCar.getUserId());
+        systemNoticeService.addSystemNotice(1, language == 1 ? "司机已结束本次行程,谢谢使用" : language == 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());
@@ -442,19 +482,6 @@
                 pushUtil.pushOrderState(2, finalOrderTaxi.getDriverId(), finalOrderTaxi.getId(), 1, finalOrderTaxi.getState());
             }
         }).start();
-
-        OrderPrivateCar finalOrderPrivateCar = orderPrivateCar;
-        new Thread(new Runnable() {
-            @Override
-            public void run() {
-                if(pushMinistryOfTransport){//上传交通数据
-                    pushMinistryOfTransportUtil.baseInfoVehicleTotalMile(finalOrderPrivateCar.getCarId());
-                    pushMinistryOfTransportUtil.operateArrive(orderId);
-                }
-            }
-        }).start();
-
-
         return ResultUtil.success();
     }
 
@@ -590,54 +617,56 @@
 
 
         //夜间服务处理逻辑
-        Calendar s = Calendar.getInstance();
-        s.setTime(date);
-        s.set(Calendar.HOUR_OF_DAY, Integer.valueOf(num16.split(" - ")[0].split(":")[0]));
-        s.set(Calendar.MINUTE, Integer.valueOf(num16.split(" - ")[0].split(":")[1]));
+        if(ToolUtil.isNotEmpty(num16)){
+            Calendar s = Calendar.getInstance();
+            s.setTime(date);
+            s.set(Calendar.HOUR_OF_DAY, Integer.valueOf(num16.split(" - ")[0].split(":")[0]));
+            s.set(Calendar.MINUTE, Integer.valueOf(num16.split(" - ")[0].split(":")[1]));
 
-        Calendar e = Calendar.getInstance();
-        e.setTime(date);
-        e.set(Calendar.HOUR_OF_DAY, Integer.valueOf(num16.split(" - ")[1].split(":")[0]));
-        e.set(Calendar.MINUTE, Integer.valueOf(num16.split(" - ")[1].split(":")[1]));
+            Calendar e = Calendar.getInstance();
+            e.setTime(date);
+            e.set(Calendar.HOUR_OF_DAY, Integer.valueOf(num16.split(" - ")[1].split(":")[0]));
+            e.set(Calendar.MINUTE, Integer.valueOf(num16.split(" - ")[1].split(":")[1]));
 
-        if(date.getTime() > s.getTimeInMillis() && date.getTime() < e.getTimeInMillis()){
-            if(d > num8.doubleValue() && d <= num9.doubleValue()){
-                yt1 = num20 * (d - num8);
+            if(date.getTime() > s.getTimeInMillis() && date.getTime() < e.getTimeInMillis()){
+                if(d > num8.doubleValue() && d <= num9.doubleValue()){
+                    yt1 = num20 * (d - num8);
+                }
+                if(d > num9.doubleValue()){
+                    yt1 = num20 * (num9 - num8);
+                }
+                if(d > num11.doubleValue() && d <= num12.doubleValue()){
+                    yt2 = num21 * (d - num11);
+                }
+                if(d > num12.doubleValue()){
+                    yt2 = num21 * (num12 - num11);
+                }
+                if(d > num14.doubleValue()){
+                    yt3 = num22 * (d - num14);
+                }
+                amount = num17 + (d1 * num18) + (t1 * num19) + (w1 * num7) + yt1 + yt2 + yt3;
+                orderPrivateCar.setStartMileage(num2);
+                orderPrivateCar.setStartMoney(num17);//起步价
+                orderPrivateCar.setStartDuration((int)(num3.doubleValue()));
+                orderPrivateCar.setMileageKilometers(new BigDecimal(d1).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
+                orderPrivateCar.setMileageMoney(new BigDecimal(d1 * num18).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());//里程费
+                orderPrivateCar.setDuration(new BigDecimal(t1).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
+                orderPrivateCar.setDurationMoney(new BigDecimal(t1 * num19).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());//时长费
+                orderPrivateCar.setWait(new BigDecimal(w1).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
+                orderPrivateCar.setWaitMoney(new BigDecimal(w1 * num7).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());//等待费
+                orderPrivateCar.setLongDistance(new BigDecimal((d > num8) ? d - num8 : 0).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
+                orderPrivateCar.setLongDistanceMoney(new BigDecimal(yt1 + yt2 + yt3).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());//远途费
+                orderPrivateCar.setParkMoney(parkingFee);//停车费
+                orderPrivateCar.setRoadTollMoney(crossingFee);//过路费
+                orderPrivateCar.setRedPacketMoney(0D);//红包抵扣
+                orderPrivateCar.setCouponMoney(0D);//优惠券抵扣
+                orderPrivateCar.setDiscount(0D);//优惠抵扣
+                orderPrivateCar.setPayMoney(0D);//支付金额
+                orderPrivateCar.setOrderMoney(new BigDecimal(amount + parkingFee + crossingFee).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
+                orderPrivateCar.setMoneyType(2);
+                orderPrivateCar.setMoneyTime(num16);
+                return orderPrivateCar;
             }
-            if(d > num9.doubleValue()){
-                yt1 = num20 * (num9 - num8);
-            }
-            if(d > num11.doubleValue() && d <= num12.doubleValue()){
-                yt2 = num21 * (d - num11);
-            }
-            if(d > num12.doubleValue()){
-                yt2 = num21 * (num12 - num11);
-            }
-            if(d > num14.doubleValue()){
-                yt3 = num22 * (d - num14);
-            }
-            amount = num17 + (d1 * num18) + (t1 * num19) + (w1 * num7) + yt1 + yt2 + yt3;
-            orderPrivateCar.setStartMileage(num2);
-            orderPrivateCar.setStartMoney(num17);//起步价
-            orderPrivateCar.setStartDuration((int)(num3.doubleValue()));
-            orderPrivateCar.setMileageKilometers(new BigDecimal(d1).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
-            orderPrivateCar.setMileageMoney(new BigDecimal(d1 * num18).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());//里程费
-            orderPrivateCar.setDuration(new BigDecimal(t1).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
-            orderPrivateCar.setDurationMoney(new BigDecimal(t1 * num19).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());//时长费
-            orderPrivateCar.setWait(new BigDecimal(w1).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
-            orderPrivateCar.setWaitMoney(new BigDecimal(w1 * num7).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());//等待费
-            orderPrivateCar.setLongDistance(new BigDecimal((d > num8) ? d - num8 : 0).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
-            orderPrivateCar.setLongDistanceMoney(new BigDecimal(yt1 + yt2 + yt3).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());//远途费
-            orderPrivateCar.setParkMoney(parkingFee);//停车费
-            orderPrivateCar.setRoadTollMoney(crossingFee);//过路费
-            orderPrivateCar.setRedPacketMoney(0D);//红包抵扣
-            orderPrivateCar.setCouponMoney(0D);//优惠券抵扣
-            orderPrivateCar.setDiscount(0D);//优惠抵扣
-            orderPrivateCar.setPayMoney(0D);//支付金额
-            orderPrivateCar.setOrderMoney(new BigDecimal(amount + parkingFee + crossingFee).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());
-            orderPrivateCar.setMoneyType(2);
-            orderPrivateCar.setMoneyTime(num16);
-            return orderPrivateCar;
         }
 
 
@@ -757,4 +786,44 @@
     public List<OrderPrivateCar> getSmsOrderList() {
         return this.baseMapper.getSmsOrderList();
     }
+
+
+    @Override
+    public void payOrderPrivateCarCallback(Integer id, String order_id, Integer language) throws Exception {
+        OrderPrivateCar orderPrivateCar = this.selectById(id);
+        PaymentRecord query = paymentRecordService.query(1, orderPrivateCar.getDriverId(), 2, id, 1, null, 1);
+        if(null != query){
+            //添加交易明细
+            transactionDetailsService.saveData(orderPrivateCar.getDriverId(), language == 1 ? "现金收款代付" : language == 2 ? "Cash collection on behalf of payment" : "Paiement en espèces", query.getAmount(), 2, 1, 2, 1, id);
+            orderPrivateCar.setDriverPay(2);
+            this.updateById(orderPrivateCar);
+
+            query.setState(2);
+            query.setCode(order_id);
+            paymentRecordService.updateById(query);
+        }else{
+            System.err.println("预支付数据异常(orderId = "  + id + ")");
+        }
+    }
+    
+    
+    /**
+     * 处理乘客修改终点
+     * @param orderId
+     * @param status
+     */
+    @Override
+    public void updateEndAddress(Integer orderId, Integer status) {
+        OrderPrivateCar orderPrivateCar = this.selectById(orderId);
+        if(2 == status){
+            orderPrivateCar.setEndLon(Double.valueOf(orderPrivateCar.getDestinationLon()));
+            orderPrivateCar.setEndLat(Double.valueOf(orderPrivateCar.getDestinationLat()));
+            orderPrivateCar.setEndAddress(orderPrivateCar.getDestination());
+        }
+        orderPrivateCar.setDestinationLon("");
+        orderPrivateCar.setDestination("");
+        orderPrivateCar.setDestinationLat("");
+        this.updateById(orderPrivateCar);
+        pushUtil.pushModifyAddress(1, orderPrivateCar.getUserId(), orderId, 1, status);
+    }
 }

--
Gitblit v1.7.1