igo出行
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
puzhibing
2023-08-22 00caef45a8833dc58919e23eb88a3484cfacdaa4 
 UserIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/smallLogistics/server/impl/OrderLogisticsServiceImpl.java


@@ -22,6 +22,7 @@


import com.stylefeng.guns.modular.system.util.Tingg.model.CheckoutRequest;


import com.stylefeng.guns.modular.system.util.Tingg.model.PayoutResponse;


import com.stylefeng.guns.modular.system.util.Tingg.model.Results;


import com.stylefeng.guns.modular.system.util.itextpdf.HtmlToPdfUtils;


import com.stylefeng.guns.modular.system.warpper.BaseWarpper;


import com.stylefeng.guns.modular.taxi.model.PaymentRecord;


import com.stylefeng.guns.modular.taxi.service.IPaymentRecordService;


@@ -37,6 +38,9 @@




import javax.annotation.Resource;


import java.io.File;


import java.io.FileInputStream;


import java.io.FileOutputStream;


import java.io.FileWriter;


import java.math.BigDecimal;


import java.math.MathContext;


import java.math.RoundingMode;


@@ -560,91 +564,28 @@


            orderLogistics.setPayMoney(orderMoney);








            if(ToolUtil.isNotEmpty(userInfo.getEmail())){


                String path = templatePath + "user/receiptLogistics.html";


                Document document = Jsoup.parse(new File(path), "UTF-8");


                SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy年MM月dd日");


                SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy/MM/dd HH:mm");


                Driver driver = driverService.selectById(orderLogistics.getDriverId());


                if(1 == language){


                    document.getElementById("english").remove();


                    document.getElementById("french").remove();


                    Element title_chinese = document.getElementById("title_chinese");


                    title_chinese.text(sdf2.format(orderLogistics.getTravelTime()) + "，您在I-GO1个订单消费GHS " + orderLogistics.getPayMoney());


                    Element xcf_chinese = document.getElementById("xcf_chinese");


                    xcf_chinese.text("GHS " + orderLogistics.getOrderMoney());


                    Element xj_chinese = document.getElementById("xj_chinese");


                    xj_chinese.text("GHS " + orderLogistics.getOrderMoney());


                    Element pay_type_chinese = document.getElementById("pay_type_chinese");


                    pay_type_chinese.text("余额");


                    Element pay_money_chinese = document.getElementById("pay_money_chinese");


                    pay_money_chinese.text("GHS " + orderLogistics.getPayMoney());


                    Element pay_time_chinese = document.getElementById("pay_time_chinese");


                    pay_time_chinese.text(sdf1.format(orderLogistics.getTravelTime()));


                    Elements driver_chinese = document.getElementsByClass("driver_chinese");


                    for (int i = 0; i < driver_chinese.size(); i++) {


                        Element element = driver_chinese.get(i);


                        element.text(driver.getFirstName() + "." + driver.getLastName());


                    }


                    Element start_address_chinese = document.getElementById("start_address_chinese");


                    start_address_chinese.text(orderLogistics.getStartAddress());


                    Element end_address_chinese = document.getElementById("end_address_chinese");


                    end_address_chinese.text(orderLogistics.getEndAddress());


                }


                if(2 == language){


                    document.getElementById("chinese").remove();


                    document.getElementById("french").remove();


                    Element title_english = document.getElementById("title_english");


                    title_english.text(sdf2.format(orderLogistics.getTravelTime()) + "，You spent GHS " + orderLogistics.getPayMoney() + " on the trip ");


                    Element xcf_english = document.getElementById("xcf_english");


                    xcf_english.text("GHS " + orderLogistics.getOrderMoney());


                    Element xj_english = document.getElementById("xj_english");


                    xj_english.text("GHS " + orderLogistics.getOrderMoney());


                    Element pay_type_english = document.getElementById("pay_type_english");


                    pay_type_english.text("balance");


                    Element pay_money_english = document.getElementById("pay_money_english");


                    pay_money_english.text("GHS " + orderLogistics.getPayMoney());


                    Element pay_time_english = document.getElementById("pay_time_english");


                    pay_time_english.text(sdf1.format(orderLogistics.getTravelTime()));


                    Elements driver_english = document.getElementsByClass("driver_english");


                    for (int i = 0; i < driver_english.size(); i++) {


                        Element element = driver_english.get(i);


                        element.text(driver.getFirstName() + "." + driver.getLastName());


                    }


                    Element start_address_english = document.getElementById("start_address_english");


                    start_address_english.text(orderLogistics.getStartAddress());


                    Element end_address_english = document.getElementById("end_address_english");


                    end_address_english.text(orderLogistics.getEndAddress());


                }


                if(3 == language){


                    document.getElementById("chinese").remove();


                    document.getElementById("english").remove();


                    Element title_french = document.getElementById("title_french");


                    title_french.text(sdf2.format(orderLogistics.getTravelTime()) + "，Vous consommez GHS " + orderLogistics.getPayMoney() + " sur votre commande i-go1 le ");


                    Element xcf_french = document.getElementById("xcf_french");


                    xcf_french.text("GHS " + orderLogistics.getOrderMoney());


                    Element xj_french = document.getElementById("xj_french");


                    xj_french.text("GHS " + orderLogistics.getOrderMoney());


                    Element pay_type_french = document.getElementById("pay_type_french");


                    pay_type_french.text("Le solde");


                    Element pay_money_french = document.getElementById("pay_money_french");


                    pay_money_french.text("GHS " + orderLogistics.getPayMoney());


                    Element pay_time_french = document.getElementById("pay_time_french");


                    pay_time_french.text(sdf1.format(orderLogistics.getTravelTime()));


                    Elements driver_french = document.getElementsByClass("driver_french");


                    for (int i = 0; i < driver_french.size(); i++) {


                        Element element = driver_french.get(i);


                        element.text(driver.getFirstName() + "." + driver.getLastName());


                    }


                    Element start_address_french = document.getElementById("start_address_french");


                    start_address_french.text(orderLogistics.getStartAddress());


                    Element end_address_french = document.getElementById("end_address_french");


                    end_address_french.text(orderLogistics.getEndAddress());


                }




                EmailUtil.send(userInfo.getEmail(), language == 1 ? "包裹收据" : language == 2 ? "Parcel receipt" : "Réception de colis",  document.html());


            //添加已收入明细


            Company company = companyService.selectById(orderLogistics.getCompanyId());


            Double speMoney = company.getCrossLogisticsMoney();


            BigDecimal d = null;//企业收入


            BigDecimal c = null;//司机收入


            if(company.getIsCrossLogisticsFixedOrProportional() == 2){//固定


                d = new BigDecimal(speMoney);


                c = new BigDecimal(orderLogistics.getOrderMoney()).subtract(d);//只有出行金额参与抽成，其余归属司机


            }


            if(company.getIsSpeFixedOrProportional() == 1){//比例


                Double price = orderLogistics.getOrderMoney();


                d = new BigDecimal(price).multiply(new BigDecimal(speMoney).divide(new BigDecimal(100), new MathContext(2, RoundingMode.HALF_EVEN)));


                c = new BigDecimal(orderLogistics.getOrderMoney()).subtract(d).setScale(2, BigDecimal.ROUND_HALF_EVEN);


            }


            incomeService.saveData(1, orderLogistics.getCompanyId(), 2, orderLogistics.getId(), 4, d.doubleValue());


            incomeService.saveData(2, orderLogistics.getDriverId(), 2, orderLogistics.getId(), 4, c.doubleValue());


            Driver driver = driverService.selectById(orderLogistics.getDriverId());


            driver.setBusinessMoney(new BigDecimal(null != driver.getBusinessMoney() ? driver.getBusinessMoney() : 0).add(c).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());


            driver.setLaveBusinessMoney(new BigDecimal(null != driver.getLaveBusinessMoney() ? driver.getLaveBusinessMoney() : 0).add(c).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());


            driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0).add(c).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());


            driverService.updateById(driver);






            // TODO: 2020/5/24 这里需要给司机和用户推送订单状态


            new Thread(new Runnable() {


@@ -675,7 +616,7 @@


            if(ToolUtil.isNotEmpty(userInfo.getEmail())){


                String path = templatePath + "user/receiptLogistics.html";


                Document document = Jsoup.parse(new File(path), "UTF-8");


                SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy年MM月dd日");


                SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd");


                SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy/MM/dd HH:mm");


                Driver driver = driverService.selectById(orderLogistics.getDriverId());


                if(1 == language){


@@ -691,6 +632,12 @@


                    pay_type_chinese.text("现金");


                    Element pay_money_chinese = document.getElementById("pay_money_chinese");


                    pay_money_chinese.text("GHS " + orderLogistics.getPayMoney());


                    Element pdf_chinese = document.getElementById("pdf_chinese");


                    pdf_chinese.attr("href", "http://182.160.16.251:80/user/base/order/uploadReceiptPdf?orderId=" + orderId + "&orderType=4");


                    Element lost_item_chinese = document.getElementById("lost_item_chinese");


                    lost_item_chinese.attr("href", "http://182.160.16.251:81/mailbox/user/lossGoods.html?language=" + language + "&orderId=" + orderId + "&orderType=4");


//                    Element track_chinese = document.getElementById("track_chinese");


//                    track_chinese.attr("href", "http://182.160.16.251:81/mailbox/user/location.html");


                    Element pay_time_chinese = document.getElementById("pay_time_chinese");


                    pay_time_chinese.text(sdf1.format(orderLogistics.getTravelTime()));


                    Elements driver_chinese = document.getElementsByClass("driver_chinese");


@@ -716,6 +663,12 @@


                    pay_type_english.text("cash");


                    Element pay_money_english = document.getElementById("pay_money_english");


                    pay_money_english.text("GHS " + orderLogistics.getPayMoney());


                    Element pdf_english = document.getElementById("pdf_english");


                    pdf_english.attr("href", "http://182.160.16.251:80/user/base/order/uploadReceiptPdf?orderId=" + orderId + "&orderType=4");


                    Element lost_item_english = document.getElementById("lost_item_english");


                    lost_item_english.attr("href", "http://182.160.16.251:81/mailbox/user/lossGoods.html?language=" + language + "&orderId=" + orderId + "&orderType=4");


//                    Element track_english = document.getElementById("track_english");


//                    track_english.attr("href", "http://182.160.16.251:81/mailbox/user/location.html");


                    Element pay_time_english = document.getElementById("pay_time_english");


                    pay_time_english.text(sdf1.format(orderLogistics.getTravelTime()));


                    Elements driver_english = document.getElementsByClass("driver_english");


@@ -741,6 +694,12 @@


                    pay_type_french.text("espèces");


                    Element pay_money_french = document.getElementById("pay_money_french");


                    pay_money_french.text("GHS " + orderLogistics.getPayMoney());


                    Element pdf_french = document.getElementById("pdf_french");


                    pdf_french.attr("href", "http://182.160.16.251:80/user/base/order/uploadReceiptPdf?orderId=" + orderId + "&orderType=4");


                    Element lost_item_french = document.getElementById("lost_item_french");


                    lost_item_french.attr("href", "http://182.160.16.251:81/mailbox/user/lossGoods.html?language=" + language + "&orderId=" + orderId + "&orderType=4");


//                    Element track_french = document.getElementById("track_french");


//                    track_french.attr("href", "http://182.160.16.251:81/mailbox/user/location.html");


                    Element pay_time_french = document.getElementById("pay_time_french");


                    pay_time_french.text(sdf1.format(orderLogistics.getTravelTime()));


                    Elements driver_french = document.getElementsByClass("driver_french");


@@ -755,6 +714,31 @@


                }




                EmailUtil.send(userInfo.getEmail(), language == 1 ? "包裹收据" : language == 2 ? "Parcel receipt" : "Réception de colis",  document.html());




                //开始生成pdf收据和html收据


                File file = new File("/usr/local/nginx/html/files/html/");


                if(!file.exists()){


                    file.mkdirs();


                }


                file = new File("/usr/local/nginx/html/files/html/parcel_receipt_" + orderId + ".html");


                if(!file.exists()){


                    file.createNewFile();


                }


                FileWriter fileWriter = new FileWriter(file);


                fileWriter.write(document.html());


                fileWriter.flush();


                fileWriter.close();


                FileInputStream fileInputStream = new FileInputStream(file);


                File file1 = new File("/usr/local/nginx/html/files/pdf/");


                if(!file1.exists()){


                    file1.mkdirs();


                }


                file1 = new File("/usr/local/nginx/html/files/pdf/parcel_receipt_" + orderId + ".pdf");


                if(!file1.exists()){


                    file1.createNewFile();


                }


                FileOutputStream fileOutputStream = new FileOutputStream(file1);


                HtmlToPdfUtils.convertToPdf(fileInputStream, "IGO", fileOutputStream);


            }






@@ -982,91 +966,27 @@


            query.setCode(order_id);


            paymentRecordService.updateById(query);




            if(ToolUtil.isNotEmpty(userInfo.getEmail())){


                String path = templatePath + "user/receiptLogistics.html";


                Document document = Jsoup.parse(new File(path), "UTF-8");


                SimpleDateFormat sdf = new SimpleDateFormat("yyyy年MM月dd日");


                SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy/MM/dd HH:mm");


                Driver driver = driverService.selectById(orderLogistics.getDriverId());


                if(1 == language){


                    document.getElementById("english").remove();


                    document.getElementById("french").remove();


                    Element title_chinese = document.getElementById("title_chinese");


                    title_chinese.text(sdf.format(orderLogistics.getTravelTime()) + "，您在I-GO1个订单消费GHS " + orderLogistics.getPayMoney());


                    Element xcf_chinese = document.getElementById("xcf_chinese");


                    xcf_chinese.text("GHS " + orderLogistics.getOrderMoney());


                    Element xj_chinese = document.getElementById("xj_chinese");


                    xj_chinese.text("GHS " + orderLogistics.getOrderMoney());


                    Element pay_type_chinese = document.getElementById("pay_type_chinese");


                    pay_type_chinese.text("余额");


                    Element pay_money_chinese = document.getElementById("pay_money_chinese");


                    pay_money_chinese.text("GHS " + orderLogistics.getPayMoney());


                    Element pay_time_chinese = document.getElementById("pay_time_chinese");


                    pay_time_chinese.text(sdf1.format(orderLogistics.getTravelTime()));


                    Elements driver_chinese = document.getElementsByClass("driver_chinese");


                    for (int i = 0; i < driver_chinese.size(); i++) {


                        Element element = driver_chinese.get(i);


                        element.text(driver.getFirstName() + "." + driver.getLastName());


                    }


                    Element start_address_chinese = document.getElementById("start_address_chinese");


                    start_address_chinese.text(orderLogistics.getStartAddress());


                    Element end_address_chinese = document.getElementById("end_address_chinese");


                    end_address_chinese.text(orderLogistics.getEndAddress());


                }


                if(2 == language){


                    document.getElementById("chinese").remove();


                    document.getElementById("french").remove();


                    Element title_english = document.getElementById("title_english");


                    title_english.text(sdf.format(orderLogistics.getTravelTime()) + "，You spent GHS " + orderLogistics.getPayMoney() + " on the trip ");


                    Element xcf_english = document.getElementById("xcf_english");


                    xcf_english.text("GHS " + orderLogistics.getOrderMoney());


                    Element xj_english = document.getElementById("xj_english");


                    xj_english.text("GHS " + orderLogistics.getOrderMoney());


                    Element pay_type_english = document.getElementById("pay_type_english");


                    pay_type_english.text("balance");


                    Element pay_money_english = document.getElementById("pay_money_english");


                    pay_money_english.text("GHS " + orderLogistics.getPayMoney());


                    Element pay_time_english = document.getElementById("pay_time_english");


                    pay_time_english.text(sdf1.format(orderLogistics.getTravelTime()));


                    Elements driver_english = document.getElementsByClass("driver_english");


                    for (int i = 0; i < driver_english.size(); i++) {


                        Element element = driver_english.get(i);


                        element.text(driver.getFirstName() + "." + driver.getLastName());


                    }


                    Element start_address_english = document.getElementById("start_address_english");


                    start_address_english.text(orderLogistics.getStartAddress());


                    Element end_address_english = document.getElementById("end_address_english");


                    end_address_english.text(orderLogistics.getEndAddress());


                }


                if(3 == language){


                    document.getElementById("chinese").remove();


                    document.getElementById("english").remove();


                    Element title_french = document.getElementById("title_french");


                    title_french.text(sdf.format(orderLogistics.getTravelTime()) + "，Vous consommez GHS " + orderLogistics.getPayMoney() + " sur votre commande i-go1 le ");


                    Element xcf_french = document.getElementById("xcf_french");


                    xcf_french.text("GHS " + orderLogistics.getOrderMoney());


                    Element xj_french = document.getElementById("xj_french");


                    xj_french.text("GHS " + orderLogistics.getOrderMoney());


                    Element pay_type_french = document.getElementById("pay_type_french");


                    pay_type_french.text("Le solde");


                    Element pay_money_french = document.getElementById("pay_money_french");


                    pay_money_french.text("GHS " + orderLogistics.getPayMoney());


                    Element pay_time_french = document.getElementById("pay_time_french");


                    pay_time_french.text(sdf1.format(orderLogistics.getTravelTime()));


                    Elements driver_french = document.getElementsByClass("driver_french");


                    for (int i = 0; i < driver_french.size(); i++) {


                        Element element = driver_french.get(i);


                        element.text(driver.getFirstName() + "." + driver.getLastName());


                    }


                    Element start_address_french = document.getElementById("start_address_french");


                    start_address_french.text(orderLogistics.getStartAddress());


                    Element end_address_french = document.getElementById("end_address_french");


                    end_address_french.text(orderLogistics.getEndAddress());


                }




                EmailUtil.send(userInfo.getEmail(), language == 1 ? "包裹收据" : language == 2 ? "Parcel receipt" : "Réception de colis",  document.html());


            //添加已收入明细


            Company company = companyService.selectById(orderLogistics.getCompanyId());


            Double speMoney = company.getCrossLogisticsMoney();


            BigDecimal d = null;//企业收入


            BigDecimal c = null;//司机收入


            if(company.getIsCrossLogisticsFixedOrProportional() == 2){//固定


                d = new BigDecimal(speMoney);


                c = new BigDecimal(orderLogistics.getOrderMoney()).subtract(d);//只有出行金额参与抽成，其余归属司机


            }




            if(company.getIsSpeFixedOrProportional() == 1){//比例


                Double price = orderLogistics.getOrderMoney();


                d = new BigDecimal(price).multiply(new BigDecimal(speMoney).divide(new BigDecimal(100), new MathContext(2, RoundingMode.HALF_EVEN)));


                c = new BigDecimal(orderLogistics.getOrderMoney()).subtract(d).setScale(2, BigDecimal.ROUND_HALF_EVEN);


            }


            incomeService.saveData(1, orderLogistics.getCompanyId(), 2, orderLogistics.getId(), 4, d.doubleValue());


            incomeService.saveData(2, orderLogistics.getDriverId(), 2, orderLogistics.getId(), 4, c.doubleValue());


            Driver driver = driverService.selectById(orderLogistics.getDriverId());


            driver.setBusinessMoney(new BigDecimal(null != driver.getBusinessMoney() ? driver.getBusinessMoney() : 0).add(c).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());


            driver.setLaveBusinessMoney(new BigDecimal(null != driver.getLaveBusinessMoney() ? driver.getLaveBusinessMoney() : 0).add(c).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());


            driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0).add(c).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue());


            driverService.updateById(driver);






            // TODO: 2020/5/24 这里需要给司机和用户推送订单状态


@@ -1189,6 +1109,15 @@


    public List<Map<String, Object>> queryMyOrderList(Integer uid, Integer pageNum, Integer size, Integer language) throws Exception {


        pageNum = (pageNum - 1) * size;


        List<Map<String, Object>> maps = orderLogisticsMapper.queryMyOrderList(uid, pageNum, size, language);


        for (Map<String, Object> map : maps) {


            Integer orderId = Integer.valueOf(String.valueOf(map.get("orderId")));


            Integer state = Integer.valueOf(String.valueOf(map.get("state")));


            if(state == 6){


                map.put("receipt", "http://182.160.16.251:81/files/html/parcel_receipt_" + orderId + ".html");


            }else{


                map.put("receipt", "");


            }


        }


        return maps;


    }




@@ -1403,12 +1332,13 @@


    @Override


    public Map<String, Object> queryOrderInfo(Integer orderId) throws Exception {


        Map<String, Object> map = orderLogisticsMapper.queryOrderInfo(orderId);


        Integer state = Integer.valueOf(String.valueOf(map.get("state")));


        OrderLogistics orderLogistics = this.selectById(orderId);


        if(null != map.get("reassignNotice") && Integer.valueOf(String.valueOf(map.get("reassignNotice"))) == 2){//改派完成，重新获取了新的司机数据，开始修改数据防止继续调用


            orderLogistics.setReassignNotice(0);


            this.updateById(orderLogistics);


        }


        if(Integer.valueOf(String.valueOf(map.get("state"))) == 11){


        if(state == 11){


            map.put("state", map.get("oldState"));


        }


        Map<String, String> geocode = gdMapGeocodingUtil.geocode(map.get("startLon").toString(), map.get("startLat").toString());


@@ -1419,6 +1349,11 @@


        String driverId = redisUtil.getValue("DEVICE_" + map.get("driverId"));


        map.put("device", ToolUtil.isNotEmpty(driverId) ? 2 : 1);


        map.put("orderType", orderLogistics.getType());


        if(state == 6){


            map.put("receipt", "http://182.160.16.251:81/files/html/parcel_receipt_" + orderId + ".html");


        }else{


            map.put("receipt", "");


        }


        return map;


    }