From caadb52788bb1ad4ed04a0bdb0ec2fa5fe3df03b Mon Sep 17 00:00:00 2001
From: zhibing.pu <393733352@qq.com>
Date: 星期二, 13 八月 2024 17:50:23 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 UserZYTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java |  277 +++++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 228 insertions(+), 49 deletions(-)

diff --git a/UserZYTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java b/UserZYTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java
index 6df50ec..66d8037 100644
--- a/UserZYTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java
+++ b/UserZYTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java
@@ -43,7 +43,12 @@
 import java.io.FileInputStream;
 import java.io.InputStreamReader;
 import java.math.BigDecimal;
+import java.math.MathContext;
+import java.math.RoundingMode;
+import java.text.SimpleDateFormat;
+import java.time.LocalDateTime;
 import java.util.*;
+import java.util.stream.Collectors;
 
 
 @Service
@@ -118,8 +123,8 @@
     @Autowired
     private ITransactionDetailsService transactionDetailsService;
 
-    @Autowired
-    private ChinaMobileUtil chinaMobileUtil;
+//    @Autowired
+//    private ChinaMobileUtil chinaMobileUtil;
 
     @Autowired
     private IIncomeService incomeService;
@@ -160,11 +165,8 @@
     @Autowired
     private IAssignOrderService assignOrderService;
 
-    @Autowired
-    private ALiSendSms aLiSendSms;
-
-    @Autowired
-    private SMSUtil smsUtil;
+//    @Autowired
+//    private ALiSendSms aLiSendSms;
 
 
     @Value("${filePath}")
@@ -315,18 +317,19 @@
             orderPrivateCar.setSnatchOrderTime(new Date());
 
             //调用高德创建轨迹
-            String s = gdFalconUtil.selectTerminal(driver.getPhone());
-            String track = gdFalconUtil.createTrack(s);
-            orderPrivateCar.setTrackId(track);
+//            String s = gdFalconUtil.selectTerminal(driver.getPhone());
+//            String track = gdFalconUtil.createTrack(s);
+//            JSONObject jsonObject = JSONObject.parseObject(track);
+//            orderPrivateCar.setTrackId(String.valueOf(jsonObject.getInteger("trid")));
 
             //调用移动的小号接口
            /* Map<String, String> geocode1 = gdMapGeocodingUtil.geocode(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString());
             Region region = regionMapper.query(geocode1.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"));
-            }
+//            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"));
+//            }
 
             driver.setState(3);
             driverService.updateById(driver);
@@ -516,8 +519,8 @@
         }
         double amount = 0;
         CancleOrder query = cancleOrderService.query(orderPrivateCar.getOrderType(), 1, orderPrivateCar.getCompanyId());
-        if(null != orderPrivateCar.getDriverId() && orderPrivateCar.getArriveTime()!=null &&
-                (orderPrivateCar.getArriveTime().getTime() + query.getMinuteNum() * 60 * 1000) < new Date().getTime()){//收费的情况
+        if(null != orderPrivateCar.getDriverId() && orderPrivateCar.getSnatchOrderTime()!=null &&
+                (orderPrivateCar.getSnatchOrderTime().getTime() + query.getMinuteNum() * 60 * 1000) < new Date().getTime()){//收费的情况
             if(null != query){
                 amount += query.getMoney();
             }
@@ -645,14 +648,62 @@
 
         CancleOrder query = cancleOrderService.query(orderPrivateCar.getOrderType(), 1, orderPrivateCar.getCompanyId());
         if(null != query){
+            String code = id + "_1_" + UUIDUtil.getRandomCode(3);
             if(payType == 1){//微信支付
+                if(ToolUtil.isEmpty(userInfo.getAppletsOpenId())){
+                    return ResultUtil.error("未授权微信,无法完成支付");
+                }
                 orderCancel.setPayType(1);
                 orderCancelService.updateById(orderCancel);
-                resultUtil =  payMoneyUtil.weixinpay("订单取消",id +"",id + "_1_fei",query.getMoney()+"","/base/wxCancelOrderTaxi","JSAPI",userInfo.getAppletsOpenId());
-                //Map<String, String> map = icbcPayUtil.placeAnOrder(id + ",1", 9, 5, uid.toString(), "订单取消", query.getMoney(), callbackPath + "/base/wxCancelOrderTaxi", "", type, userInfo.getAppletsOpenId());
+                resultUtil =  payMoneyUtil.weixinpay("订单取消",id +"",code,query.getMoney()+"","/base/wxCancelOrderTaxi","JSAPI",userInfo.getAppletsOpenId());
                 if(resultUtil.getCode()==200){
-                    paymentRecordService.saveData(1, null, null, id, 1, 1, query.getMoney(), null, 1);//添加预支付数据
-                    resultUtil = resultUtil;
+                    paymentRecordService.saveData(1, null, null, id, 1, 1, query.getMoney(), null, 1, code);//添加预支付数据
+                    new Thread(()->{
+                        int num = 1;
+                        int min = 5000;
+                        int w = 0;
+                        while (num <= 10) {
+                            try {
+                                w += min * num;
+                                OrderPrivateCar orderPrivateCar1 = orderPrivateCarMapper.selectById(id);
+                                if (orderPrivateCar1.getState() == 10) {
+                                    break;
+                                }
+                                ResultUtil<Map<String, Object>> resultUtil1 = payMoneyUtil.queryWXOrder("", code, "JSAPI");
+                                if (resultUtil1.getCode() == 200) {
+                                    /**
+                                     * SUCCESS--支付成功
+                                     * REFUND--转入退款
+                                     * NOTPAY--未支付
+                                     * CLOSED--已关闭
+                                     * REVOKED--已撤销(刷卡支付)
+                                     * USERPAYING--用户支付中
+                                     * PAYERROR--支付失败(其他原因,如银行返回失败)
+                                     * ACCEPT--已接收,等待扣款
+                                     */
+                                    String s = resultUtil1.getData().get("trade_state").toString();
+                                    if ("REFUND".equals(s) || "CLOSED".equals(s) || "REVOKED".equals(s) || "PAYERROR".equals(s) || num == 10) {
+                                        break;
+                                    }
+                                    if ("SUCCESS".equals(s) || "ACCEPT".equals(s)) {
+                                        String transaction_id = resultUtil1.getData().get("transaction_id").toString();
+                                        payCancelOrderPrivateCar(id, transaction_id, 1);
+                                        break;
+                                    }
+                                    if ("NOTPAY".equals(s) || "USERPAYING".equals(s)) {
+                                        Thread.sleep(w);
+                                        num++;
+                                    }
+                                } else {
+                                    Thread.sleep(w);
+                                    num++;
+                                }
+                            }catch (Exception e){
+                                e.printStackTrace();
+                            }
+                        }
+                    }).start();
+
                 }else{
                     resultUtil = ResultUtil.error("支付失败", "");
                 }
@@ -661,9 +712,9 @@
             if(payType == 2){//支付宝支付
                 orderCancel.setPayType(2);
                 orderCancelService.updateById(orderCancel);
-                resultUtil =  payMoneyUtil.alipay("订单取消","订单取消",id + "_1_fei",query.getMoney()+"","/base/aliCancelOrderTaxi");
+                resultUtil =  payMoneyUtil.alipay("订单取消","订单取消", "",code,query.getMoney()+"","/base/aliCancelOrderTaxi");
                 if(resultUtil.getCode()==200){
-                    paymentRecordService.saveData(1, null, null, id, 1, 2, query.getMoney(), null, 1);//添加预支付数据
+                    paymentRecordService.saveData(1, null, null, id, 1, 2, query.getMoney(), null, 1, code);//添加预支付数据
                     resultUtil = resultUtil;
                 }else{
                     resultUtil = ResultUtil.error("支付失败", "");
@@ -680,9 +731,9 @@
                 userInfoService.updateById(userInfo);
 
                 //解除小号绑定
-                if(orderPrivateCar.getBindId() != null){
-                    chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(),orderPrivateCar.getTelX());
-                }
+//                if(orderPrivateCar.getBindId() != null){
+//                    chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(),orderPrivateCar.getTelX());
+//                }
 
                 orderPrivateCar.setState(10);
                 orderPrivateCar.setTelX("");
@@ -746,10 +797,20 @@
                         //获取空闲司机
                         List<Driver> list = driverService.queryIdleDriver(1, orderPrivateCar.getServerCarModelId(), orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat(), pushOrder.getPushDistance(), null);//所有附近空闲司机
                         if(list.size() > 0){
+                            // 查询预约单
+                            List<Integer> driverIds = list.stream().map(Driver::getId).collect(Collectors.toList());
+                            List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryOrderByState(driverIds, 2, 1, 1, 2, 3, 4, 5, 6,  11);
                             double driverProportion = pushOrder.getDriverProportion() / 100;//推送占比计算成小数
                             int lastIndex = Double.valueOf(list.size() * driverProportion).intValue();//计算占比转成整数(下标截取)
                             list = list.subList(0, lastIndex);//获取空闲司机中占比数据
                             for(Driver driver : list){//开始进行推送
+                                // 判断该司机是否有30分钟内预约单
+                                long count = orderPrivateCars.stream().filter(orderPrivateCar1 -> driver.getId().equals(orderPrivateCar1.getDriverId())
+                                        && DateUtil.dateToLocalDateTime(orderPrivateCar1.getTravelTime()).minusMinutes(30).isBefore(LocalDateTime.now())
+                                        && DateUtil.dateToLocalDateTime(orderPrivateCar1.getTravelTime()).isAfter(LocalDateTime.now())).count();
+                                if(count > 0){
+                                    continue;
+                                }
                                 boolean bo = false;
                                 for(Integer integer : integers){
                                     if(integer.compareTo(driver.getId()) == 0){
@@ -814,8 +875,25 @@
         UserInfo userInfo = userInfoService.selectById(uid);
         map.put("balance", userInfo.getBalance());
         OrderPrivateCar orderPrivateCar = this.selectById(orderId);
-        int i = userCouponRecordService.queryAvailable(uid, orderPrivateCar.getCompanyId(), 1, 1, orderPrivateCar.getOrderMoney());
-        i = i + userCouponRecordService.queryAvailable(uid, orderPrivateCar.getCompanyId(), 1, 0, orderPrivateCar.getOrderMoney());
+        Double orderMoney = orderPrivateCar.getOrderMoney();
+        //计算折扣
+        UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(orderPrivateCar.getCompanyId());
+        if(null != query2){
+            Integer orderNum=this.selectCount(new EntityWrapper<OrderPrivateCar>().eq("userId",orderPrivateCar.getUserId()).eq("activityId",query2.getId()).last(" and to_days(getoffTime) = to_days(now())"));
+            if(query2.getDistance()*1000>orderPrivateCar.getMileage() && query2.getOrderNum()>orderNum){
+                Double special = query2.getSpecial();
+                orderPrivateCar.setDiscount(special);
+                double v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
+                if(orderMoney.compareTo(v) > 0){
+                    orderPrivateCar.setDiscountMoney(orderMoney - v);
+                    orderPrivateCar.setActivityId(query2.getId());
+                    orderMoney = v;
+                }
+            }
+
+        }
+        int i = userCouponRecordService.queryAvailable(uid, orderPrivateCar.getCompanyId(), 1, 1, orderMoney);
+        i = i + userCouponRecordService.queryAvailable(uid, orderPrivateCar.getCompanyId(), 1, 0, orderMoney);
         map.put("coupon", i);
         return map;
     }
@@ -823,11 +901,31 @@
     @Override
     public List<Map<String, Object>> queryCoupon(Integer orderId, Integer uid, Integer pageNum, Integer size) throws Exception {
         OrderPrivateCar orderPrivateCar = this.selectById(orderId);
-        List<Map<String, Object>> list = userCouponRecordService.queryCoupon(uid, orderPrivateCar.getCompanyId(), 1, 1, orderPrivateCar.getOrderMoney(), pageNum, size);
-        List<Map<String, Object>> list1 = userCouponRecordService.queryCoupon(uid, orderPrivateCar.getCompanyId(), 1, 0, orderPrivateCar.getOrderMoney(), pageNum, size);
+        Double orderMoney = orderPrivateCar.getOrderMoney();
+        //计算折扣
+        UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(orderPrivateCar.getCompanyId());
+        if(null != query2){
+            Integer orderNum=this.selectCount(new EntityWrapper<OrderPrivateCar>().eq("userId",orderPrivateCar.getUserId()).eq("activityId",query2.getId()).last(" and to_days(getoffTime) = to_days(now())"));
+            if(query2.getDistance()*1000>orderPrivateCar.getMileage() && query2.getOrderNum()>orderNum){
+                Double special = query2.getSpecial();
+                orderPrivateCar.setDiscount(special);
+                double v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue();
+                if(orderMoney.compareTo(v) > 0){
+                    orderPrivateCar.setDiscountMoney(orderMoney - v);
+                    orderPrivateCar.setActivityId(query2.getId());
+                    orderMoney = v;
+                }
+            }
+
+        }
+        List<Map<String, Object>> list = userCouponRecordService.queryCoupon(uid, orderPrivateCar.getCompanyId(), 1, 1, orderMoney, pageNum, size);
+        List<Map<String, Object>> list1 = userCouponRecordService.queryCoupon(uid, orderPrivateCar.getCompanyId(), 1, 0, orderMoney, pageNum, size);
         list.addAll(list1);
         return list;
     }
+    
+    
+    
 
     @Override
     public ResultUtil payPrivateCarOrder(Integer payType, Integer orderId, Integer couponId, Integer type) throws Exception {
@@ -838,6 +936,39 @@
         if(orderPrivateCar.getState() != 7){
             return ResultUtil.error("订单不在待支付状态,不允许支付", "");
         }
+        String code = orderId + "_1_" + UUIDUtil.getRandomCode(5);
+        PaymentRecord query3 = paymentRecordService.query(1, null, null, orderId, 1, payType, null);
+        if(null != query3){
+            ResultUtil<Map<String, Object>> resultUtil1 = payMoneyUtil.queryWXOrder("", query3.getSerialNumber(), "JSAPI");
+            if (resultUtil1.getCode() == 200) {
+                /**
+                 * SUCCESS--支付成功
+                 * REFUND--转入退款
+                 * NOTPAY--未支付
+                 * CLOSED--已关闭
+                 * REVOKED--已撤销(刷卡支付)
+                 * USERPAYING--用户支付中
+                 * PAYERROR--支付失败(其他原因,如银行返回失败)
+                 * ACCEPT--已接收,等待扣款
+                 */
+                String result_code = resultUtil1.getData().get("result_code").toString();
+                if("SUCCESS".equals(result_code)){
+                    String s = resultUtil1.getData().get("trade_state").toString();
+                    if ("REFUND".equals(s) || "CLOSED".equals(s) || "REVOKED".equals(s) || "PAYERROR".equals(s)) {
+                        payMoneyUtil.closeWXOrder(query3.getSerialNumber());
+                    }
+                    if ("SUCCESS".equals(s) || "ACCEPT".equals(s)) {
+                        return ResultUtil.error("不允许重复支付");
+                    }
+                    if ("NOTPAY".equals(s) || "USERPAYING".equals(s)) {
+                        payMoneyUtil.closeWXOrder(query3.getSerialNumber());
+                    }
+                }
+            }
+        }
+        
+        
+        
         Integer uid = orderPrivateCar.getUserId();
         Double orderMoney = orderPrivateCar.getOrderMoney();
         UserInfo userInfo = userInfoService.selectById(uid);
@@ -893,25 +1024,67 @@
             }
 
         }
-
+        if(ToolUtil.isEmpty(userInfo.getAppletsOpenId())){
+            return ResultUtil.error("未授权微信,无法完成支付");
+        }
         if(payType == 1){//微信支付
-            //Map<String, String> map = icbcPayUtil.placeAnOrder(orderId + ",1", 9, 5, uid.toString(), "完成订单", orderMoney, callbackPath + "/base/wxPayOrderTaxi", "", type, userInfo.getAppletsOpenId());
-            resultUtil =  payMoneyUtil.weixinpay("完成订单",orderId +"",orderId + "_1_fei",orderMoney+"","/base/wxPayOrderTaxi","JSAPI",userInfo.getAppletsOpenId());
-
+            resultUtil = payMoneyUtil.weixinpay("完成订单",orderId +"", code,orderMoney+"","/base/wxPayOrderTaxi","JSAPI",userInfo.getAppletsOpenId());
             if(resultUtil.getCode()==200){
-                paymentRecordService.saveData(1, null, null, orderId, 1, 1, orderMoney, null, 1);//添加预支付数据
-                resultUtil = resultUtil;
+                paymentRecordService.saveData(1, null, null, orderId, 1, 1, orderMoney, null, 1, code);//添加预支付数据
+                new Thread(()->{
+                    int num = 1;
+                    int min = 5000;
+                    int w = 0;
+                    while (num <= 10) {
+                        try {
+                            w += min * num;
+                            OrderPrivateCar orderPrivateCar1 = orderPrivateCarMapper.selectById(orderId);
+                            if (orderPrivateCar1.getState() != 7) {
+                                break;
+                            }
+                            ResultUtil<Map<String, Object>> resultUtil2 = payMoneyUtil.queryWXOrder("", code, "JSAPI");
+                            if (resultUtil2.getCode() == 200) {
+                                /**
+                                 * SUCCESS--支付成功
+                                 * REFUND--转入退款
+                                 * NOTPAY--未支付
+                                 * CLOSED--已关闭
+                                 * REVOKED--已撤销(刷卡支付)
+                                 * USERPAYING--用户支付中
+                                 * PAYERROR--支付失败(其他原因,如银行返回失败)
+                                 * ACCEPT--已接收,等待扣款
+                                 */
+                                String s = resultUtil2.getData().get("trade_state").toString();
+                                if ("REFUND".equals(s) || "CLOSED".equals(s) || "REVOKED".equals(s) || "PAYERROR".equals(s) || num == 10) {
+                                    break;
+                                }
+                                if ("SUCCESS".equals(s) || "ACCEPT".equals(s)) {
+                                    String transaction_id = resultUtil2.getData().get("transaction_id").toString();
+                                    payOrderPrivateCarCallback(orderId, transaction_id, 1);
+                                    break;
+                                }
+                                if ("NOTPAY".equals(s) || "USERPAYING".equals(s)) {
+                                    Thread.sleep(w);
+                                    num++;
+                                }
+                            } else {
+                                Thread.sleep(w);
+                                num++;
+                            }
+                        }catch (Exception e){
+                            e.printStackTrace();
+                        }
+                    }
+                }).start();
             }else{
                 resultUtil = ResultUtil.error("支付失败", "");
             }
 
         }
         if(payType == 2) {//支付宝支付
-            resultUtil =  payMoneyUtil.alipay("完成订单","完成订单",orderId + "_1_fei",orderMoney+"","/base/aliPayOrderTaxi");
-            //Map<String, String> map = icbcPayUtil.placeAnOrder(orderId + ",1", 10, 5, uid.toString(), "完成订单", orderMoney, callbackPath + "/base/aliPayOrderTaxi", "", type, null);
+            resultUtil =  payMoneyUtil.alipay("完成订单","完成订单", "",code,orderMoney+"","/base/aliPayOrderTaxi");
             if (resultUtil.getCode()==200) {
-                paymentRecordService.saveData(1, null, null, orderId, 1, 2, orderMoney, null, 1);//添加预支付数据
-                resultUtil = resultUtil;
+                paymentRecordService.saveData(1, null, null, orderId, 1, 2, orderMoney, null, 1, code);//添加预支付数据
             } else {
                 resultUtil = ResultUtil.error("支付失败", "");
             }
@@ -958,7 +1131,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))).setScale(2, BigDecimal.ROUND_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());
@@ -1085,15 +1258,18 @@
     @Override
     public void payCancelOrderPrivateCar(Integer id, String order_id, Integer type) throws Exception {
         OrderPrivateCar orderPrivateCar = this.selectById(id);
+        if(orderPrivateCar.getState() == 10){
+            return;
+        }
         PaymentRecord query = paymentRecordService.query(1, null, null, Integer.valueOf(id), 1, type, 1);
         if(null != query){
             //添加交易明细
             transactionDetailsService.saveData(orderPrivateCar.getUserId(), "取消订单", query.getAmount(), 2, 1, 1, 1, query.getOrderId());
             orderPrivateCar.setState(10);
             //解除小号绑定
-            if(orderPrivateCar.getBindId() != null){
-                chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(),orderPrivateCar.getTelX());
-            }
+//            if(orderPrivateCar.getBindId() != null){
+//                chinaMobileUtil.midAxbUnBindSend(orderPrivateCar.getBindId(),orderPrivateCar.getTelX());
+//            }
             orderPrivateCar.setBindId("");
             orderPrivateCar.setTelX("");
             this.updateById(orderPrivateCar);
@@ -1140,6 +1316,9 @@
     @Override
     public void payOrderPrivateCarCallback(Integer id, String order_id, Integer type) throws Exception {
         OrderPrivateCar orderPrivateCar = this.selectById(id);
+        if(orderPrivateCar.getState() != 7){
+            return;
+        }
         PaymentRecord query = paymentRecordService.query(1, null, null, Integer.valueOf(id), 1, type, 1);
         if(null != query){
             //添加交易明细
@@ -1185,7 +1364,7 @@
                 }
                 if(company.getIsSpeFixedOrProportional() == 1){//比例
                     Double price = orderPrivateCar.getStartMoney() + orderPrivateCar.getMileageMoney() + orderPrivateCar.getWaitMoney() + orderPrivateCar.getDurationMoney() + orderPrivateCar.getLongDistanceMoney();
-                    d = new BigDecimal(price).multiply(new BigDecimal(taxi).divide(new BigDecimal(100))).setScale(2, BigDecimal.ROUND_HALF_EVEN);
+                    d = new BigDecimal(price).multiply(new BigDecimal(taxi).divide(new BigDecimal(100), new MathContext(2, RoundingMode.HALF_EVEN))).setScale(2, BigDecimal.ROUND_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());
@@ -1310,8 +1489,8 @@
         if(null == distance){
             System.err.println("查询距离出错了");
         }else{
-            d = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000)).setScale(2, BigDecimal.ROUND_HALF_EVEN).toString();
-            t = new BigDecimal(distance.get("duration")).divide(new BigDecimal(60)).setScale(2, BigDecimal.ROUND_HALF_EVEN).intValue() + "";
+            d = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000), new MathContext(2, RoundingMode.HALF_EVEN)).setScale(2, BigDecimal.ROUND_HALF_EVEN).toString();
+            t = new BigDecimal(distance.get("duration")).divide(new BigDecimal(60), new MathContext(2, RoundingMode.HALF_EVEN)).setScale(2, BigDecimal.ROUND_HALF_EVEN).intValue() + "";
         }
         OrderServerWarpper orderServerWarpper = new OrderServerWarpper();
         orderServerWarpper.setOrderId(orderPrivateCar.getId());
@@ -1333,8 +1512,8 @@
             if(null == distance){
                 System.err.println("查询距离出错了");
             }else{
-                d = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000)).setScale(2, BigDecimal.ROUND_HALF_EVEN).toString();
-                t = new BigDecimal(distance.get("duration")).divide(new BigDecimal(60)).setScale(2, BigDecimal.ROUND_HALF_EVEN).intValue() + "";
+                d = new BigDecimal(distance.get("distance")).divide(new BigDecimal(1000), new MathContext(2, RoundingMode.HALF_EVEN)).setScale(2, BigDecimal.ROUND_HALF_EVEN).toString();
+                t = new BigDecimal(distance.get("duration")).divide(new BigDecimal(60), new MathContext(2, RoundingMode.HALF_EVEN)).setScale(2, BigDecimal.ROUND_HALF_EVEN).intValue() + "";
             }
             orderServerWarpper.setReservationMileage("0");
             orderServerWarpper.setReservationTime("0");

--
Gitblit v1.7.1