From 0001861cc63fc670646a103284b9eaefb193e91f Mon Sep 17 00:00:00 2001 From: 无关风月 <443237572@qq.com> Date: 星期六, 10 八月 2024 17:31:48 +0800 Subject: [PATCH] Merge branch '2.0' of http://120.76.84.145:10101/gitblit/r/java/IgoTravel into 2.0 --- UserIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/smallLogistics/server/impl/OrderLogisticsServiceImpl.java | 1233 ++++++++++++++++++++++++++++++++++++++++++++++++---------- 1 files changed, 1,019 insertions(+), 214 deletions(-) diff --git a/UserIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/smallLogistics/server/impl/OrderLogisticsServiceImpl.java b/UserIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/smallLogistics/server/impl/OrderLogisticsServiceImpl.java index 3337fa0..29e067b 100644 --- a/UserIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/smallLogistics/server/impl/OrderLogisticsServiceImpl.java +++ b/UserIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/smallLogistics/server/impl/OrderLogisticsServiceImpl.java @@ -30,6 +30,8 @@ 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.system.warpper.EndPushWarpper; +import com.stylefeng.guns.modular.system.warpper.OrderServerWarpper; import com.stylefeng.guns.modular.taxi.model.OrderTaxi; import com.stylefeng.guns.modular.taxi.model.PaymentRecord; import com.stylefeng.guns.modular.taxi.service.IPaymentRecordService; @@ -47,13 +49,11 @@ import org.springframework.stereotype.Service; import org.springframework.util.LinkedMultiValueMap; import org.springframework.util.MultiValueMap; +import org.springframework.util.StringUtils; import org.springframework.web.client.RestTemplate; import javax.annotation.Resource; -import java.io.File; -import java.io.FileInputStream; -import java.io.FileOutputStream; -import java.io.FileWriter; +import java.io.*; import java.math.BigDecimal; import java.math.MathContext; import java.math.RoundingMode; @@ -198,6 +198,22 @@ @Autowired private IUserActivityRedenvelopeService userActivityRedenvelopeService; + + @Autowired + private FleetEngineUtil fleetEngineUtil; + + @Resource + private CarModelMapper carModelMapper; + + @Autowired + private ICarService carService; + + @Resource + private DriverWorkMapper driverWorkMapper; + + + @Value("${filePath}") + private String filePath; @@ -546,7 +562,50 @@ if(bo){ continue; } - pushUtil.pushOrderState(2, driver.getId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), pushOrder.getPushTime()); + + Driver driver1 = driverService.selectById(driver.getId()); + DriverWork driverWork = driverWorkMapper.selectOne(new EntityWrapper<DriverWork>().eq("driverId", driver1.getId()) + .eq("state", 1).like("type", "4").getEntity()); + if(null == driverWork || driver1.getState() != 2){ + continue; + } + String text = ""; + Integer language1 = driver.getLanguage(); + switch (language1){ + case 1: + text = "收到新的包裹订单,从" + orderLogistics.getStartAddress() + "出发,全程约" + orderLogistics.getEstimatedMileage() + "公里"; + break; + case 2: + text = "Received a new delivery order, starting from " + orderLogistics.getStartAddress() + ", the whole journey is about " + orderLogistics.getEstimatedMileage() + "kilometre"; + break; + case 3: + text = "J'ai reçu une nouvelle commande de livraison, à partir de " + orderLogistics.getStartAddress() + ", le trajet complet est d’environ " + orderLogistics.getEstimatedMileage() + "kilométrage"; + break; + + } + String audioUrl = ""; + String fileName = "pushOrder" + orderLogistics.getDriverId() + UUIDUtil.getRandomCode(5) + ".mp3"; + try { + audioUrl = TextToSpeechUtil.create(language1 == 1 ? "cmn-CN" : language1 == 2 ? "en-US" : "fr-FR", text, fileName); + } catch (Exception e) { + throw new RuntimeException(e); + } + //定时任务删除语音文件 + new Timer().schedule(new TimerTask() { + @Override + public void run() { + Process process = null; + try { + process = Runtime.getRuntime().exec("rm -rf /usr/local/nginx/html/files/audio/" + fileName); + } catch (IOException e) { + throw new RuntimeException(e); + } + if (process != null) { + process.destroy(); + } + } + }, 30000); + pushUtil.pushOrderState(2, driver.getId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), pushOrder.getPushTime(), audioUrl); } } Thread.sleep(pushOrder.getPushTime() * 1000);//设置等待时间 @@ -595,12 +654,12 @@ * 1.下了即时单就不能下预约单和即时单 * 2.下了预约单和再下一张即时单不能再下预约单 */ - List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryByState(uid, 1, 1, 1, 2, 3, 4, 5, 6, 11); + List<OrderPrivateCar> orderPrivateCars = orderPrivateCarMapper.queryByState(uid, 1, 1, 1, 2, 3, 4, 5, 6, 7, 11, 12); if(orderPrivateCars.size() > 0){ return ResultUtil.error(language == 1 ? "有未完成的订单" : language == 2 ? "Uncompleted order(s)" : "Commande(s) non complétée(s)"); } int selectCount = this.selectCount(new EntityWrapper<OrderLogistics>().eq("userId", uid).eq("isDelete", 1) - .in("state", Arrays.asList(1, 2, 3, 4, 5, 7, 11, 12))); + .in("state", Arrays.asList(1, 2, 3, 4, 5, 6, 7, 11, 12))); if(0 < selectCount){ return ResultUtil.error(language == 1 ? "有未完成的订单" : language == 2 ? "Uncompleted order(s)" : "Commande(s) non complétée(s)"); } @@ -637,6 +696,7 @@ orderLogistics.setInsertTime(new Date()); orderLogistics.setTravelTime(new Date()); orderLogistics.setOrderSource(orderSource); + orderLogistics.setRemark(remark); if(orderSource == 2){//扫码下单 Driver driver = driverService.selectById(driverId); if(null == driver){ @@ -674,21 +734,103 @@ CarService query1 = carServiceMapper.query(1, driver.getCarId()); orderLogistics.setServerCarModelId(query1.getServerCarModelId()); orderLogistics.setSnatchOrderTime(new Date()); - + String value = redisUtil.getValue("DRIVER" + driver.getId()); + if(ToolUtil.isNotEmpty(value)) { + String[] split = value.split(","); + DistancematrixVo distancematrix = GoogleMapUtil.getDistancematrix(orderLogistics.getStartLat(), orderLogistics.getStartLon(), Double.valueOf(split[1]), Double.valueOf(split[0])); + //超时时间 + long timeOut = System.currentTimeMillis() + (distancematrix.getDuration() * 1000); + orderLogistics.setEstimateArriveTime(new Date(timeOut)); + orderLogistics.setEstimateArriveMileage(distancematrix.getDistance()); + } driver.setState(3); driverService.updateById(driver); } orderLogistics.setIsReassign(1); orderLogistics.setIsDelete(1); + orderLogistics.setTripId(UUIDUtil.getRandomCode()); + DistancematrixVo distancematrix1 = GoogleMapUtil.getDistancematrix(orderLogistics.getStartLat(), orderLogistics.getStartLon(), orderLogistics.getEndLat(), orderLogistics.getEndLon()); + Long distance1 = distancematrix1.getDistance(); + orderLogistics.setEstimatedMileage(new BigDecimal(distance1).divide(new BigDecimal(1000)).setScale(2, RoundingMode.HALF_EVEN).doubleValue()); this.insert(orderLogistics); + UserInfo userInfo = userInfoService.selectById(uid); + userInfo.setLanguage(language); + userInfoService.updateById(userInfo); + + new Thread(() -> { + try { + String vehicleId = null; + if(null != orderLogistics.getDriverId()){ + Driver driver = driverService.selectById(orderLogistics.getDriverId()); + Car car = carMapper.selectById(driver.getCarId()); + if(!StringUtils.hasLength(car.getVehicleId())){ + car.setVehicleId(UUIDUtil.getRandomCode()); + carMapper.updateById(car); + } + //查询车辆信息,没有则创建信息 + String vehicles = fleetEngineUtil.getVehicles(car.getVehicleId()); + if(ToolUtil.isEmpty(vehicles)){ + CarModel carModel = carModelMapper.selectById(car.getCarModelId()); + fleetEngineUtil.createVehicles(carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + fleetEngineUtil.updateVehicles("ONLINE", carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + } + + } + //创建行程数据 + fleetEngineUtil.createTrip(vehicleId, 1, orderLogistics.getTripId(), + orderLogistics.getStartLat().toString(), orderLogistics.getStartLon().toString(), orderLogistics.getEndLat().toString(), orderLogistics.getEndLon().toString()); + + }catch (Exception e){ + e.printStackTrace(); + } + }).start(); + if(orderSource == 2){//扫码下单 + Driver driver = driverService.selectById(orderLogistics.getDriverId()); + String text = ""; + Integer language1 = driver.getLanguage(); + switch (language1){ + case 1: + text = "收到新的包裹订单,从" + orderLogistics.getStartAddress() + "出发,全程约" + orderLogistics.getEstimatedMileage() + "公里"; + break; + case 2: + text = "Received a new delivery order, starting from " + orderLogistics.getStartAddress() + ", the whole journey is about " + orderLogistics.getEstimatedMileage() + "kilometre"; + break; + case 3: + text = "J'ai reçu une nouvelle commande de livraison, à partir de " + orderLogistics.getStartAddress() + ", le trajet complet est d’environ " + orderLogistics.getEstimatedMileage() + "kilométrage"; + break; + + } + String audioUrl = ""; + String fileName = "pushOrder" + orderLogistics.getDriverId() + UUIDUtil.getRandomCode(5) + ".mp3"; + try { + audioUrl = TextToSpeechUtil.create(language1 == 1 ? "cmn-CN" : language1 == 2 ? "en-US" : "fr-FR", text, fileName); + } catch (Exception e) { + throw new RuntimeException(e); + } + //定时任务删除语音文件 + new Timer().schedule(new TimerTask() { + @Override + public void run() { + Process process = null; + try { + process = Runtime.getRuntime().exec("rm -rf /usr/local/nginx/html/files/audio/" + fileName); + } catch (IOException e) { + throw new RuntimeException(e); + } + if (process != null) { + process.destroy(); + } + } + }, 30000); + String finalAudioUrl = audioUrl; new Thread(new Runnable() { @Override public void run() { - pushUtil.pushOrderState(1, uid, orderLogistics.getId(), 4, 2, 0); - pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), 4, 2, 0); + pushUtil.pushOrderState(1, uid, orderLogistics.getId(), 4, 2, 0, ""); + pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), 4, 2, 0, finalAudioUrl); } }).start(); } @@ -747,26 +889,68 @@ dr = drivers.get(0); } - orderLogistics.setDriverId(dr.getId()); - orderLogistics.setCompanyId(dr.getFranchiseeId() != null && dr.getFranchiseeId() != 0 ? dr.getFranchiseeId() : ( - dr.getCompanyId() != null && dr.getCompanyId() != 0 ? dr.getCompanyId() : 1)); - orderLogistics.setState(2); - orderLogistics.setCarId(dr.getCarId()); - CarService query1 = carServiceMapper.query(1, dr.getCarId()); - orderLogistics.setServerCarModelId(query1.getServerCarModelId()); - orderLogistics.setSnatchOrderTime(new Date()); - - dr.setState(3); - driverService.updateById(dr); - this.updateById(orderLogistics); - - new Thread(new Runnable() { - @Override - public void run() { - pushUtil.pushOrderState(1, uid, orderLogistics.getId(), 4, 2, 0); - pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), 4, 2, 0); + Driver driver1 = driverService.selectById(dr.getId()); + DriverWork driverWork = driverWorkMapper.selectOne(new EntityWrapper<DriverWork>().eq("driverId", driver1.getId()) + .eq("state", 1).like("type", "4").getEntity()); + if(driver1.getState() == 2 || null != driverWork){ + orderLogistics.setDriverId(dr.getId()); + orderLogistics.setCompanyId(dr.getFranchiseeId() != null && dr.getFranchiseeId() != 0 ? dr.getFranchiseeId() : ( + dr.getCompanyId() != null && dr.getCompanyId() != 0 ? dr.getCompanyId() : 1)); + orderLogistics.setState(2); + orderLogistics.setCarId(dr.getCarId()); + CarService query1 = carServiceMapper.query(1, dr.getCarId()); + orderLogistics.setServerCarModelId(query1.getServerCarModelId()); + orderLogistics.setSnatchOrderTime(new Date()); + + dr.setState(3); + driverService.updateById(dr); + this.updateById(orderLogistics); + + String text = ""; + Integer language1 = dr.getLanguage(); + switch (language1){ + case 1: + text = "收到新的包裹订单,从" + orderLogistics.getStartAddress() + "出发,全程约" + orderLogistics.getEstimatedMileage() + "公里"; + break; + case 2: + text = "Received a new delivery order, starting from " + orderLogistics.getStartAddress() + ", the whole journey is about " + orderLogistics.getEstimatedMileage() + "kilometre"; + break; + case 3: + text = "J'ai reçu une nouvelle commande de livraison, à partir de " + orderLogistics.getStartAddress() + ", le trajet complet est d’environ " + orderLogistics.getEstimatedMileage() + "kilométrage"; + break; + } - }).start(); + String audioUrl = ""; + String fileName = "pushOrder" + orderLogistics.getDriverId() + UUIDUtil.getRandomCode(5) + ".mp3"; + try { + audioUrl = TextToSpeechUtil.create(language1 == 1 ? "cmn-CN" : language1 == 2 ? "en-US" : "fr-FR", text, fileName); + } catch (Exception e) { + throw new RuntimeException(e); + } + //定时任务删除语音文件 + new Timer().schedule(new TimerTask() { + @Override + public void run() { + Process process = null; + try { + process = Runtime.getRuntime().exec("rm -rf /usr/local/nginx/html/files/audio/" + fileName); + } catch (IOException e) { + throw new RuntimeException(e); + } + if (process != null) { + process.destroy(); + } + } + }, 30000); + String finalAudioUrl = audioUrl; + new Thread(new Runnable() { + @Override + public void run() { + pushUtil.pushOrderState(1, uid, orderLogistics.getId(), 4, 2, 0, ""); + pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), 4, 2, 0, finalAudioUrl); + } + }).start(); + } } } } @@ -775,22 +959,6 @@ //推单操作 if(orderLogistics.getState() == 1){ this.pushOrder(orderLogistics); - }else{ - //接单后定时任务判断司机是否去接乘客,没有则推送提醒 - CancleOrder cancleOrder = cancleOrderService.query(orderLogistics.getCompanyId()); - if(null != cancleOrder){ - JSONObject object = JSON.parseObject(cancleOrder.getContent()); - long time = object.getInteger("driverTimeout") * 60000L; - new Timer().schedule(new TimerTask() { - @Override - public void run() { - OrderLogistics orderLogistics1 = OrderLogisticsServiceImpl.this.selectById(orderLogistics.getId()); - if(orderLogistics1.getState() == 2){ - pushUtil.pushDriverTimeOut(1, orderLogistics1.getUserId(), orderLogistics1.getId(), 4); - } - } - }, time); - } } @@ -802,6 +970,7 @@ BaseWarpper baseWarpper = new BaseWarpper(); baseWarpper.setState(orderLogistics.getState()); baseWarpper.setId(orderLogistics.getId()); + baseWarpper.setContent(orderLogistics.getTripId()); return ResultUtil.success(baseWarpper); } @@ -820,15 +989,28 @@ return ResultUtil.error(language == 1 ? "订单已完成支付,不允许重复支付" : language == 2 ? "The order has been paid, recurring payments is not allowed." : "La commande a été payée, les paiements récurrents ne sont pas autorisés.", ""); } Integer uid = orderLogistics.getUserId(); - Double orderMoney = orderLogistics.getOrderMoney(); + BigDecimal orderMoney = new BigDecimal(orderLogistics.getOrderMoney()); if(orderLogistics.getUrgent() == 2){ // orderMoney += null != orderLogistics.getTipMoney() ? orderLogistics.getTipMoney() : 0; } UserInfo userInfo = userInfoService.selectById(uid); ResultUtil resultUtil = ResultUtil.success(""); - //折扣 - if(null != orderLogistics.getActivityId()){ - orderMoney = orderMoney - orderLogistics.getDiscountMoney(); + //计算折扣 + UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(orderLogistics.getCompanyId()); + if(null != query2){ + Integer orderNum=this.selectCount(new EntityWrapper<OrderLogistics>().eq("userId",orderLogistics.getUserId()).eq("activityId",query2.getId()).last(" and to_days(getoffTime) = to_days(now())")); + if(query2.getDistance()*1000>orderLogistics.getMileage() && query2.getOrderNum()>orderNum){ + Double special = query2.getLogistics(); + if(null != special){ + orderLogistics.setDiscount(special); + BigDecimal v = orderMoney.multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN); + if(orderMoney.compareTo(v) > 0){ + orderLogistics.setDiscountMoney(orderMoney.subtract(v).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); + orderLogistics.setActivityId(query2.getId()); + orderMoney = v; + } + } + } } //计算优惠券 @@ -836,7 +1018,7 @@ if(null != couponId){ //TODO 待翻译 if(null != redDeduction && 1 == redDeduction){ - return ResultUtil.error(language == 1 ? "优惠券和红包不能同时使用" : language == 2 ? "" : "", ""); + return ResultUtil.error(language == 1 ? "优惠券和红包不能同时使用" : language == 2 ? "Coupons and lucky-promo cannot be used at the same time." : "Les coupons et les bonus ne peuvent pas être utilisés en même temps", ""); } userCouponRecord = userCouponRecordService.selectById(couponId); if(userCouponRecord.getCompanyId() != orderLogistics.getCompanyId()){ @@ -851,10 +1033,10 @@ if(userCouponRecord.getCouponUseType() != 0 && userCouponRecord.getCouponUseType() != 4){ return ResultUtil.error(language == 1 ? "优惠券不能用于此订单" : language == 2 ? "Coupon cannot be used for this order." : "Le coupon ne peut pas être utilisé pour cette commande.", ""); } - if(userCouponRecord.getCouponType() == 2 && orderMoney.compareTo(userCouponRecord.getFullMoney()) < 0){ + if(userCouponRecord.getCouponType() == 2 && orderMoney.compareTo(new BigDecimal(userCouponRecord.getFullMoney())) < 0){ return ResultUtil.error(language == 1 ? "优惠券不能用于此订单" : language == 2 ? "Coupon cannot be used for this order." : "Le coupon ne peut pas être utilisé pour cette commande.", ""); } - orderMoney = orderMoney - userCouponRecord.getMoney(); + orderMoney = orderMoney.subtract(new BigDecimal(userCouponRecord.getMoney())).setScale(2, RoundingMode.HALF_EVEN); orderLogistics.setCouponMoney(userCouponRecord.getMoney()); orderLogistics.setCouponId(couponId); } @@ -866,11 +1048,12 @@ Double total = userRedPacketRecordService.queryRemainingAmount(uid); List<UserRedPacketRecord> userRedPacketRecords = userRedPacketRecordService.selectList(new EntityWrapper<UserRedPacketRecord>().eq("userId", uid) .eq("state", 1).eq("companyId", orderLogistics.getCompanyId()).gt("remainingAmount", 0).orderBy("insertTime", false)); - if(total.compareTo(orderMoney) >= 0){ - BigDecimal deductionRatio = redEnvelopePaymentSettings.getDeductionRatio(); - BigDecimal multiply = new BigDecimal(orderMoney).multiply(deductionRatio.divide(new BigDecimal(100))); - orderLogistics.setRedPacketMoney(multiply.doubleValue()); - orderMoney = orderMoney - multiply.doubleValue(); + + BigDecimal deductionRatio = redEnvelopePaymentSettings.getDeductionRatio(); + BigDecimal multiply1 = orderMoney.multiply(deductionRatio.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_EVEN); + if(total > 0 && multiply1.doubleValue() > 0 && total.compareTo(multiply1.doubleValue()) >= 0){ + orderLogistics.setRedPacketMoney(multiply1.doubleValue()); + orderMoney = orderMoney.subtract(multiply1).setScale(2, RoundingMode.HALF_EVEN); //获取红包id JSONArray jsonArray = new JSONArray(); @@ -878,21 +1061,30 @@ JSONObject jsonObject = new JSONObject(); jsonObject.put("id", userRedPacketRecord.getId()); BigDecimal remainingAmount = new BigDecimal(userRedPacketRecord.getRemainingAmount()); - if(multiply.compareTo(remainingAmount) >= 0){ - multiply = multiply.subtract(remainingAmount); + if(multiply1.compareTo(BigDecimal.ZERO) == 0){ + break; + } + if(multiply1.compareTo(remainingAmount) >= 0){ + userRedPacketRecord.setRemainingAmount(0D); + userRedPacketRecord.setEndTime(new Date()); + userRedPacketRecord.setState(2); + multiply1 = multiply1.subtract(remainingAmount).setScale(2, RoundingMode.HALF_EVEN); jsonObject.put("money", remainingAmount); jsonArray.add(jsonObject); - }else{ - userRedPacketRecord.setRemainingAmount(remainingAmount.subtract(multiply).doubleValue()); - jsonObject.put("money", multiply); + userRedPacketRecordService.updateById(userRedPacketRecord); + }else if(remainingAmount.compareTo(multiply1) > 0){ + userRedPacketRecord.setRemainingAmount(remainingAmount.subtract(multiply1).setScale(2, RoundingMode.HALF_EVEN).doubleValue()); + jsonObject.put("money", multiply1); jsonArray.add(jsonObject); - break; + userRedPacketRecordService.updateById(userRedPacketRecord); + multiply1 = BigDecimal.ZERO; } } orderLogistics.setRedPacketId(jsonArray.toJSONString()); - }else{ + } + if(total > 0 && total.compareTo(multiply1.doubleValue()) < 0){ orderLogistics.setRedPacketMoney(total); - orderMoney = orderMoney - total; + orderMoney = orderMoney.subtract(new BigDecimal(total)).setScale(2, RoundingMode.HALF_EVEN); //获取红包id JSONArray jsonArray = new JSONArray(); BigDecimal multiply = new BigDecimal(total); @@ -900,15 +1092,23 @@ JSONObject jsonObject = new JSONObject(); jsonObject.put("id", userRedPacketRecord.getId()); BigDecimal remainingAmount = new BigDecimal(userRedPacketRecord.getRemainingAmount()); + if(multiply.compareTo(BigDecimal.ZERO) == 0){ + break; + } if(multiply.compareTo(remainingAmount) >= 0){ - multiply = multiply.subtract(remainingAmount); + userRedPacketRecord.setRemainingAmount(0D); + userRedPacketRecord.setEndTime(new Date()); + userRedPacketRecord.setState(2); + multiply = multiply.subtract(remainingAmount).setScale(2, RoundingMode.HALF_EVEN); jsonObject.put("money", remainingAmount); jsonArray.add(jsonObject); - }else{ - userRedPacketRecord.setRemainingAmount(remainingAmount.subtract(multiply).doubleValue()); + userRedPacketRecordService.updateById(userRedPacketRecord); + }else if(remainingAmount.compareTo(multiply) > 0){ + userRedPacketRecord.setRemainingAmount(remainingAmount.subtract(multiply).setScale(2, RoundingMode.HALF_EVEN).doubleValue()); jsonObject.put("money", multiply); jsonArray.add(jsonObject); - break; + userRedPacketRecordService.updateById(userRedPacketRecord); + multiply = BigDecimal.ZERO; } } orderLogistics.setRedPacketId(jsonArray.toJSONString()); @@ -916,8 +1116,6 @@ } } - orderMoney=new BigDecimal(orderMoney).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue(); - if(payType == 1) {//手机支付 SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); String merchantTransactionId = sdf.format(new Date()) + "4" + language + orderId; @@ -927,7 +1125,7 @@ checkoutRequest.setAccountNumber(userInfo.getPhone()); checkoutRequest.setCustomerFirstName(userInfo.getFirstName()); checkoutRequest.setCustomerLastName(userInfo.getLastName()); - checkoutRequest.setRequestAmount(orderMoney); + checkoutRequest.setRequestAmount(orderMoney.setScale(2, RoundingMode.HALF_EVEN).doubleValue()); checkoutRequest.setMerchantTransactionId(merchantTransactionId); checkoutRequest.setRequestDescription("Travel completion payment"); checkoutRequest.setCallbackUrl(callbackPath + "/base/wxPayOrderTaxi"); @@ -936,7 +1134,8 @@ checkoutRequest.setFailRedirectUrl("http://182.160.16.251:81/payMoney/pages/fail.html"); resultUtil = TinggPayUtil.checkoutRequest(checkoutRequest); if(resultUtil.getCode()==200){ - paymentRecordService.saveData(1, null, null, orderId, 4, 1, orderMoney, null, 1);//添加预支付数据 + paymentRecordService.saveData(1, null, null, orderId, 4, 1, + orderMoney.setScale(2, RoundingMode.HALF_EVEN).doubleValue(), null, 1);//添加预支付数据 }else{ resultUtil = ResultUtil.error(language == 1 ? "支付失败" : language == 2 ? "Payment failure" : "Paiement échoué", ""); } @@ -953,7 +1152,7 @@ checkoutRequest.setAccountNumber(bankCard.getCode()); checkoutRequest.setCustomerFirstName(bankCard.getFirstName()); checkoutRequest.setCustomerLastName(bankCard.getLastName()); - checkoutRequest.setRequestAmount(orderMoney); + checkoutRequest.setRequestAmount(orderMoney.setScale(2, RoundingMode.HALF_EVEN).doubleValue()); checkoutRequest.setMerchantTransactionId(merchantTransactionId); checkoutRequest.setRequestDescription("Travel completion payment"); checkoutRequest.setCallbackUrl(callbackPath + "/base/wxPayOrderTaxi"); @@ -963,7 +1162,8 @@ resultUtil = TinggPayUtil.checkoutRequest(checkoutRequest); if(resultUtil.getCode()==200){ - paymentRecordService.saveData(1, null, null, orderId, 4, 2, orderMoney, null, 1);//添加预支付数据 + paymentRecordService.saveData(1, null, null, orderId, 4, 2, + orderMoney.setScale(2, RoundingMode.HALF_EVEN).doubleValue(), null, 1);//添加预支付数据 }else{ resultUtil = ResultUtil.error(language == 1 ? "支付失败" : language == 2 ? "Payment failure" : "Paiement échoué", ""); } @@ -971,11 +1171,11 @@ } if(payType == 3){//余额支付 - if(userInfo.getBalance() == null || userInfo.getBalance() < orderMoney){ + if(userInfo.getBalance() == null || new BigDecimal(userInfo.getBalance()).compareTo(orderMoney) < 0){ return ResultUtil.error(language == 1 ? "账户余额不足" : language == 2 ? "Insufficient balance" : "Solde insuffisant", ""); } - userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(new BigDecimal(orderMoney)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); + userInfo.setBalance(new BigDecimal(userInfo.getBalance()).subtract(orderMoney).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); SysIntegral query1 = sysIntegralMapper.query(orderLogistics.getCompanyId()); userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分 @@ -986,30 +1186,15 @@ userCouponRecord.setEndTime(new Date()); userCouponRecordService.updateById(userCouponRecord); } - if(null != orderLogistics.getRedPacketId()){ - JSONArray jsonArray = JSON.parseArray(orderLogistics.getRedPacketId()); - for (int i = 0; i < jsonArray.size(); i++) { - JSONObject jsonObject = jsonArray.getJSONObject(i); - Integer id1 = jsonObject.getInteger("id"); - Double money = jsonObject.getDouble("money"); - UserRedPacketRecord userRedPacketRecord = userRedPacketRecordService.selectById(id1); - userRedPacketRecord.setRemainingAmount(userRedPacketRecord.getRemainingAmount() - money); - if(0 == userRedPacketRecord.getRemainingAmount()){ - userRedPacketRecord.setState(2); - userRedPacketRecord.setEndTime(new Date()); - } - userRedPacketRecordService.updateById(userRedPacketRecord); - } - } //添加交易明细 - transactionDetailsService.saveData(uid, "包裹下单支付", orderMoney, 2, 1, 1, 4, orderId); + transactionDetailsService.saveData(uid, "包裹下单支付", + orderMoney.setScale(2, RoundingMode.HALF_EVEN).doubleValue(), 2, 1, 1, 4, orderId); userInfoService.updateById(userInfo); orderLogistics.setState(8); orderLogistics.setPayType(3); - orderLogistics.setPayMoney(orderMoney); - orderLogistics.setOrderMoney(orderLogistics.getOrderMoney()+orderLogistics.getFreeMoney().doubleValue()); + orderLogistics.setPayMoney(orderMoney.setScale(2, RoundingMode.HALF_EVEN).doubleValue()); //处理优惠券和红包 if(null != userCouponRecord){ @@ -1061,7 +1246,8 @@ new Thread(new Runnable() { @Override public void run() { - pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0); + pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0, ""); + pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0, ""); } }).start(); @@ -1098,8 +1284,50 @@ document.getElementsByTag("title").get(0).text("I-GO电子收据"); Element title_chinese = document.getElementById("title_chinese"); title_chinese.text(DateUtil.conversionFormat(language, sdf2.format(orderLogistics.getTravelTime())) + ",您在I-GO此订单消费GHS " + orderLogistics.getPayMoney()); - Element xcf_chinese = document.getElementById("xcf_chinese"); - xcf_chinese.text("GHS " + new BigDecimal(orderLogistics.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_chinese = document.getElementById("qbj_chinese"); + qbj_chinese.text("GHS " + new BigDecimal(orderLogistics.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_chinese = document.getElementById("scf_chinese"); + if(null != orderLogistics.getDurationMoney() && orderLogistics.getDurationMoney() > 0){ + scf_chinese.text("GHS " + new BigDecimal(orderLogistics.getDurationMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element scf_chinese_div = document.getElementById("scf_chinese_div"); + scf_chinese_div.remove(); + } + Element lcf_chinese = document.getElementById("lcf_chinese"); + if(null != orderLogistics.getMileageMoney() && orderLogistics.getMileageMoney() > 0){ + lcf_chinese.text("GHS " + new BigDecimal(orderLogistics.getMileageMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element lcf_chinese_div = document.getElementById("lcf_chinese_div"); + lcf_chinese_div.remove(); + } + Element ddf_chinese = document.getElementById("ddf_chinese"); + if(null != orderLogistics.getWaitMoney() && orderLogistics.getWaitMoney() > 0){ + ddf_chinese.text("GHS " + new BigDecimal(orderLogistics.getWaitMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element ddf_chinese_div = document.getElementById("ddf_chinese_div"); + ddf_chinese_div.remove(); + } + Element glf_chinese = document.getElementById("glf_chinese"); + if(null != orderLogistics.getRoadTollMoney() && orderLogistics.getRoadTollMoney() > 0){ + glf_chinese.text("GHS " + new BigDecimal(orderLogistics.getRoadTollMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element glf_chinese_div = document.getElementById("glf_chinese_div"); + glf_chinese_div.remove(); + } + Element tcf_chinese = document.getElementById("tcf_chinese"); + if(null != orderLogistics.getParkMoney() && orderLogistics.getParkMoney() > 0){ + tcf_chinese.text("GHS " + new BigDecimal(orderLogistics.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_chinese_div = document.getElementById("tcf_chinese_div"); + tcf_chinese_div.remove(); + } + Element bcj_chinese = document.getElementById("bcj_chinese"); + if(null != orderLogistics.getPriceDifference() && orderLogistics.getPriceDifference() > 0){ + bcj_chinese.text("GHS " + new BigDecimal(orderLogistics.getPriceDifference()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element bcj_chinese_div = document.getElementById("bcj_chinese_div"); + bcj_chinese_div.remove(); + } if(null != orderLogistics.getCouponMoney() && orderLogistics.getCouponMoney() > 0){ Element yhq_chinese = document.getElementById("yhq_chinese"); yhq_chinese.text("GHS -" + new BigDecimal(orderLogistics.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -1158,8 +1386,50 @@ document.getElementsByTag("title").get(0).text("Receipt"); Element title_english = document.getElementById("title_english"); title_english.text(DateUtil.conversionFormat(language, sdf2.format(orderLogistics.getTravelTime())) + ",You spent GHS " + orderLogistics.getPayMoney() + " on the trip "); - Element xcf_english = document.getElementById("xcf_english"); - xcf_english.text("GHS " + new BigDecimal(orderLogistics.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_english = document.getElementById("qbj_english"); + qbj_english.text("GHS " + new BigDecimal(orderLogistics.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_english = document.getElementById("scf_english"); + if(null != orderLogistics.getDurationMoney() && orderLogistics.getDurationMoney() > 0){ + scf_english.text("GHS " + new BigDecimal(orderLogistics.getDurationMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element scf_english_div = document.getElementById("scf_english_div"); + scf_english_div.remove(); + } + Element lcf_english = document.getElementById("lcf_english"); + if(null != orderLogistics.getMileageMoney() && orderLogistics.getMileageMoney() > 0){ + lcf_english.text("GHS " + new BigDecimal(orderLogistics.getMileageMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element lcf_english_div = document.getElementById("lcf_english_div"); + lcf_english_div.remove(); + } + Element ddf_english = document.getElementById("ddf_english"); + if(null != orderLogistics.getWaitMoney() && orderLogistics.getWaitMoney() > 0){ + ddf_english.text("GHS " + new BigDecimal(orderLogistics.getWaitMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element ddf_english_div = document.getElementById("ddf_english_div"); + ddf_english_div.remove(); + } + Element glf_english = document.getElementById("glf_english"); + if(null != orderLogistics.getRoadTollMoney() && orderLogistics.getRoadTollMoney() > 0){ + glf_english.text("GHS " + new BigDecimal(orderLogistics.getRoadTollMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element glf_english_div = document.getElementById("glf_english_div"); + glf_english_div.remove(); + } + Element tcf_english = document.getElementById("tcf_english"); + if(null != orderLogistics.getParkMoney() && orderLogistics.getParkMoney() > 0){ + tcf_english.text("GHS " + new BigDecimal(orderLogistics.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_english_div = document.getElementById("tcf_english_div"); + tcf_english_div.remove(); + } + Element bcj_english = document.getElementById("bcj_english"); + if(null != orderLogistics.getPriceDifference() && orderLogistics.getPriceDifference() > 0){ + bcj_english.text("GHS " + new BigDecimal(orderLogistics.getPriceDifference()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element bcj_english_div = document.getElementById("bcj_english_div"); + bcj_english_div.remove(); + } if(null != orderLogistics.getCouponMoney() && orderLogistics.getCouponMoney() > 0){ Element yhq_english = document.getElementById("yhq_english"); yhq_english.text("GHS -" + new BigDecimal(orderLogistics.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -1218,8 +1488,50 @@ document.getElementsByTag("title").get(0).text("Reçu"); Element title_french = document.getElementById("title_french"); title_french.text(DateUtil.conversionFormat(language, 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 " + new BigDecimal(orderLogistics.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_french = document.getElementById("qbj_french"); + qbj_french.text("GHS " + new BigDecimal(orderLogistics.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_french = document.getElementById("scf_french"); + if(null != orderLogistics.getDurationMoney() && orderLogistics.getDurationMoney() > 0){ + scf_french.text("GHS " + new BigDecimal(orderLogistics.getDurationMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element scf_french_div = document.getElementById("scf_french_div"); + scf_french_div.remove(); + } + Element lcf_french = document.getElementById("lcf_french"); + if(null != orderLogistics.getMileageMoney() && orderLogistics.getMileageMoney() > 0){ + lcf_french.text("GHS " + new BigDecimal(orderLogistics.getMileageMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element lcf_french_div = document.getElementById("lcf_french_div"); + lcf_french_div.remove(); + } + Element ddf_french = document.getElementById("ddf_french"); + if(null != orderLogistics.getWaitMoney() && orderLogistics.getWaitMoney() > 0){ + ddf_french.text("GHS " + new BigDecimal(orderLogistics.getWaitMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element ddf_french_div = document.getElementById("ddf_french_div"); + ddf_french_div.remove(); + } + Element glf_french = document.getElementById("glf_french"); + if(null != orderLogistics.getRoadTollMoney() && orderLogistics.getRoadTollMoney() > 0){ + glf_french.text("GHS " + new BigDecimal(orderLogistics.getRoadTollMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element glf_french_div = document.getElementById("glf_french_div"); + glf_french_div.remove(); + } + Element tcf_french = document.getElementById("tcf_french"); + if(null != orderLogistics.getParkMoney() && orderLogistics.getParkMoney() > 0){ + tcf_french.text("GHS " + new BigDecimal(orderLogistics.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_french_div = document.getElementById("tcf_french_div"); + tcf_french_div.remove(); + } + Element bcj_french = document.getElementById("bcj_french"); + if(null != orderLogistics.getPriceDifference() && orderLogistics.getPriceDifference() > 0){ + bcj_french.text("GHS " + new BigDecimal(orderLogistics.getPriceDifference()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element bcj_french_div = document.getElementById("bcj_french_div"); + bcj_french_div.remove(); + } if(null != orderLogistics.getCouponMoney() && orderLogistics.getCouponMoney() > 0){ Element yhq_french = document.getElementById("yhq_french"); yhq_french.text("GHS -" + new BigDecimal(orderLogistics.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -1333,14 +1645,14 @@ userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分 //添加交易明细 - transactionDetailsService.saveData(uid, "包裹下单支付", orderMoney, 2, 1, 1, 4, orderId); + transactionDetailsService.saveData(uid, "包裹下单支付", + orderMoney.setScale(2, RoundingMode.HALF_EVEN).doubleValue(), 2, 1, 1, 4, orderId); userInfoService.updateById(userInfo); - orderLogistics.setState(1);//小件物流先支付后司机抢单 + orderLogistics.setState(8);//小件物流先支付后司机抢单 orderLogistics.setDriverPay(1); orderLogistics.setPayType(4); - orderLogistics.setPayMoney(orderMoney); - orderLogistics.setOrderMoney(orderLogistics.getOrderMoney()+orderLogistics.getFreeMoney().doubleValue()); + orderLogistics.setPayMoney(orderMoney.setScale(2, RoundingMode.HALF_EVEN).doubleValue()); //处理优惠券和红包 if(null != userCouponRecord){ @@ -1356,19 +1668,6 @@ driverService.updateById(driver); } if(null != orderLogistics.getRedPacketId()){ - JSONArray jsonArray = JSON.parseArray(orderLogistics.getRedPacketId()); - for (int i = 0; i < jsonArray.size(); i++) { - JSONObject jsonObject = jsonArray.getJSONObject(i); - Integer id1 = jsonObject.getInteger("id"); - Double money = jsonObject.getDouble("money"); - UserRedPacketRecord userRedPacketRecord = userRedPacketRecordService.selectById(id1); - userRedPacketRecord.setRemainingAmount(userRedPacketRecord.getRemainingAmount() - money); - if(0 == userRedPacketRecord.getRemainingAmount()){ - userRedPacketRecord.setState(2); - userRedPacketRecord.setEndTime(new Date()); - } - userRedPacketRecordService.updateById(userRedPacketRecord); - } Double money = orderLogistics.getRedPacketMoney(); incomeService.saveData(2, orderLogistics.getDriverId(), 7, orderLogistics.getId(), 4, money); driver.setBusinessMoney(new BigDecimal(null != driver.getBusinessMoney() ? driver.getBusinessMoney() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); @@ -1446,7 +1745,7 @@ settlementRecord.setInsertTime(new Date()); settlementRecordService.insert(settlementRecord); }else{ - settlementRecord.setPayMoney(total.doubleValue()); + settlementRecord.setPayMoney(settlementRecord.getPayMoney() + total.doubleValue()); settlementRecordService.updateById(settlementRecord); } for (SettlementDetail detail : settlementDetailList) { @@ -1466,8 +1765,9 @@ new Thread(new Runnable() { @Override public void run() { - pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0); - pushUtil.pushOfflinePayment(2, orderLogistics.getDriverId(), orderLogistics.getId(), 4); + pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0, ""); + pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0, ""); + pushUtil.pushOfflinePayment(2, orderLogistics.getDriverId(), orderLogistics.getId(), 4, orderLogistics.getPayMoney()); } }).start(); @@ -1501,8 +1801,50 @@ document.getElementsByTag("title").get(0).text("I-GO电子收据"); Element title_chinese = document.getElementById("title_chinese"); title_chinese.text(DateUtil.conversionFormat(language, sdf2.format(orderLogistics.getTravelTime())) + ",您在I-GO此订单消费GHS " + orderLogistics.getPayMoney()); - Element xcf_chinese = document.getElementById("xcf_chinese"); - xcf_chinese.text("GHS " + new BigDecimal(orderLogistics.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_chinese = document.getElementById("qbj_chinese"); + qbj_chinese.text("GHS " + new BigDecimal(orderLogistics.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_chinese = document.getElementById("scf_chinese"); + if(null != orderLogistics.getDurationMoney() && orderLogistics.getDurationMoney() > 0){ + scf_chinese.text("GHS " + new BigDecimal(orderLogistics.getDurationMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element scf_chinese_div = document.getElementById("scf_chinese_div"); + scf_chinese_div.remove(); + } + Element lcf_chinese = document.getElementById("lcf_chinese"); + if(null != orderLogistics.getMileageMoney() && orderLogistics.getMileageMoney() > 0){ + lcf_chinese.text("GHS " + new BigDecimal(orderLogistics.getMileageMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element lcf_chinese_div = document.getElementById("lcf_chinese_div"); + lcf_chinese_div.remove(); + } + Element ddf_chinese = document.getElementById("ddf_chinese"); + if(null != orderLogistics.getWaitMoney() && orderLogistics.getWaitMoney() > 0){ + ddf_chinese.text("GHS " + new BigDecimal(orderLogistics.getWaitMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element ddf_chinese_div = document.getElementById("ddf_chinese_div"); + ddf_chinese_div.remove(); + } + Element glf_chinese = document.getElementById("glf_chinese"); + if(null != orderLogistics.getRoadTollMoney() && orderLogistics.getRoadTollMoney() > 0){ + glf_chinese.text("GHS " + new BigDecimal(orderLogistics.getRoadTollMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element glf_chinese_div = document.getElementById("glf_chinese_div"); + glf_chinese_div.remove(); + } + Element tcf_chinese = document.getElementById("tcf_chinese"); + if(null != orderLogistics.getParkMoney() && orderLogistics.getParkMoney() > 0){ + tcf_chinese.text("GHS " + new BigDecimal(orderLogistics.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_chinese_div = document.getElementById("tcf_chinese_div"); + tcf_chinese_div.remove(); + } + Element bcj_chinese = document.getElementById("bcj_chinese"); + if(null != orderLogistics.getPriceDifference() && orderLogistics.getPriceDifference() > 0){ + bcj_chinese.text("GHS " + new BigDecimal(orderLogistics.getPriceDifference()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element bcj_chinese_div = document.getElementById("bcj_chinese_div"); + bcj_chinese_div.remove(); + } if(null != orderLogistics.getCouponMoney() && orderLogistics.getCouponMoney() > 0){ Element yhq_chinese = document.getElementById("yhq_chinese"); yhq_chinese.text("GHS -" + new BigDecimal(orderLogistics.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -1561,8 +1903,50 @@ document.getElementsByTag("title").get(0).text("Receipt"); Element title_english = document.getElementById("title_english"); title_english.text(DateUtil.conversionFormat(language, sdf2.format(orderLogistics.getTravelTime())) + ",You spent GHS " + orderLogistics.getPayMoney() + " on the trip "); - Element xcf_english = document.getElementById("xcf_english"); - xcf_english.text("GHS " + new BigDecimal(orderLogistics.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_english = document.getElementById("qbj_english"); + qbj_english.text("GHS " + new BigDecimal(orderLogistics.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_english = document.getElementById("scf_english"); + if(null != orderLogistics.getDurationMoney() && orderLogistics.getDurationMoney() > 0){ + scf_english.text("GHS " + new BigDecimal(orderLogistics.getDurationMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element scf_english_div = document.getElementById("scf_english_div"); + scf_english_div.remove(); + } + Element lcf_english = document.getElementById("lcf_english"); + if(null != orderLogistics.getMileageMoney() && orderLogistics.getMileageMoney() > 0){ + lcf_english.text("GHS " + new BigDecimal(orderLogistics.getMileageMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element lcf_english_div = document.getElementById("lcf_english_div"); + lcf_english_div.remove(); + } + Element ddf_english = document.getElementById("ddf_english"); + if(null != orderLogistics.getWaitMoney() && orderLogistics.getWaitMoney() > 0){ + ddf_english.text("GHS " + new BigDecimal(orderLogistics.getWaitMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element ddf_english_div = document.getElementById("ddf_english_div"); + ddf_english_div.remove(); + } + Element glf_english = document.getElementById("glf_english"); + if(null != orderLogistics.getRoadTollMoney() && orderLogistics.getRoadTollMoney() > 0){ + glf_english.text("GHS " + new BigDecimal(orderLogistics.getRoadTollMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element glf_english_div = document.getElementById("glf_english_div"); + glf_english_div.remove(); + } + Element tcf_english = document.getElementById("tcf_english"); + if(null != orderLogistics.getParkMoney() && orderLogistics.getParkMoney() > 0){ + tcf_english.text("GHS " + new BigDecimal(orderLogistics.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_english_div = document.getElementById("tcf_english_div"); + tcf_english_div.remove(); + } + Element bcj_english = document.getElementById("bcj_english"); + if(null != orderLogistics.getPriceDifference() && orderLogistics.getPriceDifference() > 0){ + bcj_english.text("GHS " + new BigDecimal(orderLogistics.getPriceDifference()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element bcj_english_div = document.getElementById("bcj_english_div"); + bcj_english_div.remove(); + } if(null != orderLogistics.getCouponMoney() && orderLogistics.getCouponMoney() > 0){ Element yhq_english = document.getElementById("yhq_english"); yhq_english.text("GHS -" + new BigDecimal(orderLogistics.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -1621,8 +2005,50 @@ document.getElementsByTag("title").get(0).text("Reçu"); Element title_french = document.getElementById("title_french"); title_french.text(DateUtil.conversionFormat(language, 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 " + new BigDecimal(orderLogistics.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_french = document.getElementById("qbj_french"); + qbj_french.text("GHS " + new BigDecimal(orderLogistics.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_french = document.getElementById("scf_french"); + if(null != orderLogistics.getDurationMoney() && orderLogistics.getDurationMoney() > 0){ + scf_french.text("GHS " + new BigDecimal(orderLogistics.getDurationMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element scf_french_div = document.getElementById("scf_french_div"); + scf_french_div.remove(); + } + Element lcf_french = document.getElementById("lcf_french"); + if(null != orderLogistics.getMileageMoney() && orderLogistics.getMileageMoney() > 0){ + lcf_french.text("GHS " + new BigDecimal(orderLogistics.getMileageMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element lcf_french_div = document.getElementById("lcf_french_div"); + lcf_french_div.remove(); + } + Element ddf_french = document.getElementById("ddf_french"); + if(null != orderLogistics.getWaitMoney() && orderLogistics.getWaitMoney() > 0){ + ddf_french.text("GHS " + new BigDecimal(orderLogistics.getWaitMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element ddf_french_div = document.getElementById("ddf_french_div"); + ddf_french_div.remove(); + } + Element glf_french = document.getElementById("glf_french"); + if(null != orderLogistics.getRoadTollMoney() && orderLogistics.getRoadTollMoney() > 0){ + glf_french.text("GHS " + new BigDecimal(orderLogistics.getRoadTollMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element glf_french_div = document.getElementById("glf_french_div"); + glf_french_div.remove(); + } + Element tcf_french = document.getElementById("tcf_french"); + if(null != orderLogistics.getParkMoney() && orderLogistics.getParkMoney() > 0){ + tcf_french.text("GHS " + new BigDecimal(orderLogistics.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_french_div = document.getElementById("tcf_french_div"); + tcf_french_div.remove(); + } + Element bcj_french = document.getElementById("bcj_french"); + if(null != orderLogistics.getPriceDifference() && orderLogistics.getPriceDifference() > 0){ + bcj_french.text("GHS " + new BigDecimal(orderLogistics.getPriceDifference()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element bcj_french_div = document.getElementById("bcj_french_div"); + bcj_french_div.remove(); + } if(null != orderLogistics.getCouponMoney() && orderLogistics.getCouponMoney() > 0){ Element yhq_french = document.getElementById("yhq_french"); yhq_french.text("GHS -" + new BigDecimal(orderLogistics.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -1842,8 +2268,8 @@ new Thread(new Runnable() { @Override public void run() { - pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0); - pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0); + pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0, ""); + pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0, ""); } }).start(); @@ -1900,8 +2326,8 @@ new Thread(new Runnable() { @Override public void run() { - pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0); - pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0); + pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0, ""); + pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0, ""); } }).start(); @@ -1941,21 +2367,6 @@ userCouponRecord.setEndTime(new Date()); userCouponRecordService.updateById(userCouponRecord); } - if(null != orderLogistics.getRedPacketId()){ - JSONArray jsonArray = JSON.parseArray(orderLogistics.getRedPacketId()); - for (int i = 0; i < jsonArray.size(); i++) { - JSONObject jsonObject = jsonArray.getJSONObject(i); - Integer id1 = jsonObject.getInteger("id"); - Double money = jsonObject.getDouble("money"); - UserRedPacketRecord userRedPacketRecord = userRedPacketRecordService.selectById(id1); - userRedPacketRecord.setRemainingAmount(userRedPacketRecord.getRemainingAmount() - money); - if(0 == userRedPacketRecord.getRemainingAmount()){ - userRedPacketRecord.setState(2); - userRedPacketRecord.setEndTime(new Date()); - } - userRedPacketRecordService.updateById(userRedPacketRecord); - } - } query.setState(2); query.setCode(order_id); @@ -1965,7 +2376,8 @@ new Thread(new Runnable() { @Override public void run() { - pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0); + pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0, ""); + pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0, ""); } }).start(); @@ -2006,8 +2418,50 @@ document.getElementsByTag("title").get(0).text("I-GO电子收据"); Element title_chinese = document.getElementById("title_chinese"); title_chinese.text(DateUtil.conversionFormat(language, sdf2.format(orderLogistics.getTravelTime())) + ",您在I-GO此订单消费GHS " + orderLogistics.getPayMoney()); - Element xcf_chinese = document.getElementById("xcf_chinese"); - xcf_chinese.text("GHS " + new BigDecimal(orderLogistics.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_chinese = document.getElementById("qbj_chinese"); + qbj_chinese.text("GHS " + new BigDecimal(orderLogistics.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_chinese = document.getElementById("scf_chinese"); + if(null != orderLogistics.getDurationMoney() && orderLogistics.getDurationMoney() > 0){ + scf_chinese.text("GHS " + new BigDecimal(orderLogistics.getDurationMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element scf_chinese_div = document.getElementById("scf_chinese_div"); + scf_chinese_div.remove(); + } + Element lcf_chinese = document.getElementById("lcf_chinese"); + if(null != orderLogistics.getMileageMoney() && orderLogistics.getMileageMoney() > 0){ + lcf_chinese.text("GHS " + new BigDecimal(orderLogistics.getMileageMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element lcf_chinese_div = document.getElementById("lcf_chinese_div"); + lcf_chinese_div.remove(); + } + Element ddf_chinese = document.getElementById("ddf_chinese"); + if(null != orderLogistics.getWaitMoney() && orderLogistics.getWaitMoney() > 0){ + ddf_chinese.text("GHS " + new BigDecimal(orderLogistics.getWaitMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element ddf_chinese_div = document.getElementById("ddf_chinese_div"); + ddf_chinese_div.remove(); + } + Element glf_chinese = document.getElementById("glf_chinese"); + if(null != orderLogistics.getRoadTollMoney() && orderLogistics.getRoadTollMoney() > 0){ + glf_chinese.text("GHS " + new BigDecimal(orderLogistics.getRoadTollMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element glf_chinese_div = document.getElementById("glf_chinese_div"); + glf_chinese_div.remove(); + } + Element tcf_chinese = document.getElementById("tcf_chinese"); + if(null != orderLogistics.getParkMoney() && orderLogistics.getParkMoney() > 0){ + tcf_chinese.text("GHS " + new BigDecimal(orderLogistics.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_chinese_div = document.getElementById("tcf_chinese_div"); + tcf_chinese_div.remove(); + } + Element bcj_chinese = document.getElementById("bcj_chinese"); + if(null != orderLogistics.getPriceDifference() && orderLogistics.getPriceDifference() > 0){ + bcj_chinese.text("GHS " + new BigDecimal(orderLogistics.getPriceDifference()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element bcj_chinese_div = document.getElementById("bcj_chinese_div"); + bcj_chinese_div.remove(); + } if(null != orderLogistics.getCouponMoney() && orderLogistics.getCouponMoney() > 0){ Element yhq_chinese = document.getElementById("yhq_chinese"); yhq_chinese.text("GHS -" + new BigDecimal(orderLogistics.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -2066,8 +2520,50 @@ document.getElementsByTag("title").get(0).text("Receipt"); Element title_english = document.getElementById("title_english"); title_english.text(DateUtil.conversionFormat(language, sdf2.format(orderLogistics.getTravelTime())) + ",You spent GHS " + orderLogistics.getPayMoney() + " on the trip "); - Element xcf_english = document.getElementById("xcf_english"); - xcf_english.text("GHS " + new BigDecimal(orderLogistics.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_english = document.getElementById("qbj_english"); + qbj_english.text("GHS " + new BigDecimal(orderLogistics.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_english = document.getElementById("scf_english"); + if(null != orderLogistics.getDurationMoney() && orderLogistics.getDurationMoney() > 0){ + scf_english.text("GHS " + new BigDecimal(orderLogistics.getDurationMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element scf_english_div = document.getElementById("scf_english_div"); + scf_english_div.remove(); + } + Element lcf_english = document.getElementById("lcf_english"); + if(null != orderLogistics.getMileageMoney() && orderLogistics.getMileageMoney() > 0){ + lcf_english.text("GHS " + new BigDecimal(orderLogistics.getMileageMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element lcf_english_div = document.getElementById("lcf_english_div"); + lcf_english_div.remove(); + } + Element ddf_english = document.getElementById("ddf_english"); + if(null != orderLogistics.getWaitMoney() && orderLogistics.getWaitMoney() > 0){ + ddf_english.text("GHS " + new BigDecimal(orderLogistics.getWaitMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element ddf_english_div = document.getElementById("ddf_english_div"); + ddf_english_div.remove(); + } + Element glf_english = document.getElementById("glf_english"); + if(null != orderLogistics.getRoadTollMoney() && orderLogistics.getRoadTollMoney() > 0){ + glf_english.text("GHS " + new BigDecimal(orderLogistics.getRoadTollMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element glf_english_div = document.getElementById("glf_english_div"); + glf_english_div.remove(); + } + Element tcf_english = document.getElementById("tcf_english"); + if(null != orderLogistics.getParkMoney() && orderLogistics.getParkMoney() > 0){ + tcf_english.text("GHS " + new BigDecimal(orderLogistics.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_english_div = document.getElementById("tcf_english_div"); + tcf_english_div.remove(); + } + Element bcj_english = document.getElementById("bcj_english"); + if(null != orderLogistics.getPriceDifference() && orderLogistics.getPriceDifference() > 0){ + bcj_english.text("GHS " + new BigDecimal(orderLogistics.getPriceDifference()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element bcj_english_div = document.getElementById("bcj_english_div"); + bcj_english_div.remove(); + } if(null != orderLogistics.getCouponMoney() && orderLogistics.getCouponMoney() > 0){ Element yhq_english = document.getElementById("yhq_english"); yhq_english.text("GHS -" + new BigDecimal(orderLogistics.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -2126,8 +2622,50 @@ document.getElementsByTag("title").get(0).text("Reçu"); Element title_french = document.getElementById("title_french"); title_french.text(DateUtil.conversionFormat(language, 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 " + new BigDecimal(orderLogistics.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_french = document.getElementById("qbj_french"); + qbj_french.text("GHS " + new BigDecimal(orderLogistics.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_french = document.getElementById("scf_french"); + if(null != orderLogistics.getDurationMoney() && orderLogistics.getDurationMoney() > 0){ + scf_french.text("GHS " + new BigDecimal(orderLogistics.getDurationMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element scf_french_div = document.getElementById("scf_french_div"); + scf_french_div.remove(); + } + Element lcf_french = document.getElementById("lcf_french"); + if(null != orderLogistics.getMileageMoney() && orderLogistics.getMileageMoney() > 0){ + lcf_french.text("GHS " + new BigDecimal(orderLogistics.getMileageMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element lcf_french_div = document.getElementById("lcf_french_div"); + lcf_french_div.remove(); + } + Element ddf_french = document.getElementById("ddf_french"); + if(null != orderLogistics.getWaitMoney() && orderLogistics.getWaitMoney() > 0){ + ddf_french.text("GHS " + new BigDecimal(orderLogistics.getWaitMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element ddf_french_div = document.getElementById("ddf_french_div"); + ddf_french_div.remove(); + } + Element glf_french = document.getElementById("glf_french"); + if(null != orderLogistics.getRoadTollMoney() && orderLogistics.getRoadTollMoney() > 0){ + glf_french.text("GHS " + new BigDecimal(orderLogistics.getRoadTollMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element glf_french_div = document.getElementById("glf_french_div"); + glf_french_div.remove(); + } + Element tcf_french = document.getElementById("tcf_french"); + if(null != orderLogistics.getParkMoney() && orderLogistics.getParkMoney() > 0){ + tcf_french.text("GHS " + new BigDecimal(orderLogistics.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_french_div = document.getElementById("tcf_french_div"); + tcf_french_div.remove(); + } + Element bcj_french = document.getElementById("bcj_french"); + if(null != orderLogistics.getPriceDifference() && orderLogistics.getPriceDifference() > 0){ + bcj_french.text("GHS " + new BigDecimal(orderLogistics.getPriceDifference()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element bcj_french_div = document.getElementById("bcj_french_div"); + bcj_french_div.remove(); + } if(null != orderLogistics.getCouponMoney() && orderLogistics.getCouponMoney() > 0){ Element yhq_french = document.getElementById("yhq_french"); yhq_french.text("GHS -" + new BigDecimal(orderLogistics.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -2297,8 +2835,8 @@ new Thread(new Runnable() { @Override public void run() { - pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0); - pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0); + pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0, ""); + pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), orderLogistics.getType(), orderLogistics.getState(), 0, ""); } }).start(); @@ -2355,10 +2893,37 @@ map.put("receipt", ""); } if(state == 7){ - Double discountMoney = Double.valueOf(map.get("discountMoney").toString()); + Double discountMoney = 0D; + OrderLogistics orderLogistics = this.selectById(orderId); + UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(Integer.valueOf(String.valueOf(map.get("companyId")))); + if(null != query2){ + Integer orderNum=this.selectCount(new EntityWrapper<OrderLogistics>().eq("userId",orderLogistics.getUserId()).eq("activityId",query2.getId()).last(" and to_days(getoffTime) = to_days(now())")); + if(query2.getDistance()*1000>orderLogistics.getMileage() && query2.getOrderNum()>orderNum){ + Double special = query2.getLogistics(); + Double orderMoney = orderLogistics.getOrderMoney(); + double v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue(); + if(orderMoney.compareTo(v) > 0){ + discountMoney = orderMoney - v; + } + } + + } Double orderMoney = Double.valueOf(map.get("orderMoney").toString()); map.put("orderMoney", orderMoney - discountMoney); } + + OrderLogistics orderLogistics = this.selectById(orderId); + long timeOutCancel = 0L; + long driverTimeOut = 0L; + if(null != orderLogistics.getEstimateArriveTime()){ + CancleOrder cancleOrder = cancleOrderService.selectOne(new EntityWrapper<CancleOrder>().eq("companyId", orderLogistics.getCompanyId())); + JSONObject jsonObject = JSON.parseObject(cancleOrder.getContent()); + int driverTimeout = jsonObject.getIntValue("driverTimeout") * 60000; + timeOutCancel = orderLogistics.getEstimateArriveTime().getTime() + driverTimeout; + driverTimeOut = orderLogistics.getEstimateArriveTime().getTime(); + } + map.put("driverTimeOut", driverTimeOut); + map.put("timeOutCancel", timeOutCancel); } return maps; } @@ -2416,7 +2981,7 @@ if(null == orderLogistics){ return ResultUtil.error(language == 1 ? "取消订单失败,订单信息有误" : language == 2 ? "Failed to cancel order, order-information error." : "Échec de l’annulation de la commande, erreur d’information de commande."); } - if(orderLogistics.getState() > 5 && orderLogistics.getState() != 11){ + if(orderLogistics.getState() > 5 && orderLogistics.getState() != 12){ return ResultUtil.error(language == 1 ? "取消订单失败,不合法的操作" : language == 2 ? "Failed to cancel order, illegal operation." : "Échec de l’annulation de la commande, opération illégale."); } @@ -2456,20 +3021,39 @@ integer = orderCancelService.saveData(id, 4, reason, remark, null, amount, 1, 1, uid); } this.deleteTask(id);//删除定时任务 - + + + //修改司机为空闲 + Driver driver = driverService.selectById(orderLogistics.getDriverId()); new Thread(new Runnable() { @Override public void run() { - pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), 4, orderLogistics.getState(), 0); + Integer language1 = driver.getLanguage(); + String audioUrl = ""; + switch (language1){ + case 1: + audioUrl = "http://182.160.16.251:81/files/audio/system/UserCancelledOrder-CN.mp3"; + break; + case 2: + audioUrl = "http://182.160.16.251:81/files/audio/system/UserCancelledOrder-EN.mp3"; + break; + case 3: + audioUrl = "http://182.160.16.251:81/files/audio/system/UserCancelledOrder-FR.mp3"; + break; + } + pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), 4, orderLogistics.getState(), 0, ""); + pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), 4, orderLogistics.getState() == 12 ? orderLogistics.getState() : 10, 0, audioUrl); } }).start(); - - //修改司机为空闲 - Driver driver = driverService.selectById(orderLogistics.getDriverId()); driver.setState(2); driverService.updateById(driver); } - + + if(orderLogistics.getState() == 10 || orderLogistics.getState() == 12){ + //修改行程信息 + fleetEngineUtil.updateTrip("CANCELED", null, null, orderLogistics.getTripId(), null, null, null, null); + } + //添加消息 systemNoticeService.addSystemNotice(1, language == 1 ? "您已成功取消包裹订单,谢谢使用!" : language == 2 ? "You've cancelled the delivery order successfully, thank you for using I-GO " : "Vous avez annulé la commande de livraison avec succès, merci d’utiliser I-GO", orderLogistics.getUserId(), 1); @@ -2561,15 +3145,37 @@ if(state == 11){ map.put("state", map.get("oldState")); } - Map<String, String> geocode = gdMapGeocodingUtil.geocode(map.get("startLon").toString(), map.get("startLat").toString()); - map.put("startCity", geocode.get("city")); - geocode = gdMapGeocodingUtil.geocode(map.get("endLon").toString(), map.get("endLat").toString()); - map.put("endCity", geocode.get("city")); + if(state == 12){ + OrderCancel query = orderCancelService.query(orderId, 4, null, null, 1); + map.put("cancelPayMoney", null == query ? 0 : query.getMoney()); + map.put("cancelMoney", null == query ? 0 : query.getMoney()); + } + if(Integer.valueOf(String.valueOf(map.get("state"))) != 8 && Integer.valueOf(String.valueOf(map.get("state"))) != 9){ + map.put("redPacketMoney", null); + map.put("couponMoney", null); + } + if(Integer.valueOf(String.valueOf(map.get("state"))) == 7){ + UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(Integer.valueOf(String.valueOf(map.get("companyId")))); + if(null != query2){ + Integer orderNum=this.selectCount(new EntityWrapper<OrderLogistics>().eq("userId",orderLogistics.getUserId()).eq("activityId",query2.getId()).last(" and to_days(getoffTime) = to_days(now())")); + if(query2.getDistance()*1000>orderLogistics.getMileage() && query2.getOrderNum()>orderNum){ + Double special = query2.getLogistics(); + map.put("discount", special); + orderLogistics.setDiscount(special); + Double orderMoney = orderLogistics.getOrderMoney(); + double v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue(); + if(orderMoney.compareTo(v) > 0){ + map.put("discountMoney",orderMoney - v); + } + } + + } + } String driverId = redisUtil.getValue("DEVICE_" + map.get("driverId")); map.put("device", ToolUtil.isNotEmpty(driverId) ? 2 : 1); map.put("orderType", orderLogistics.getType()); - if(state == 6){ + if(state == 8 || state == 9){ map.put("receipt", "http://182.160.16.251:81/files/html/parcel_receipt_" + orderId + ".html"); }else{ map.put("receipt", ""); @@ -2578,9 +3184,16 @@ if(null != map.get("driverId")){ companyId = Integer.valueOf(String.valueOf(map.get("companyId"))); } - CancleOrder cancleOrder = cancleOrderService.selectOne(new EntityWrapper<CancleOrder>().eq("companyId", companyId)); - JSONObject jsonObject = JSON.parseObject(cancleOrder.getContent()); - map.put("timeOutCancel", jsonObject.getIntValue("driverTimeout")); + map.put("timeOutCancel", 0); + map.put("driverTimeOut", 0); + if(null != orderLogistics.getEstimateArriveTime()){ + CancleOrder cancleOrder = cancleOrderService.selectOne(new EntityWrapper<CancleOrder>().eq("companyId", companyId)); + JSONObject jsonObject = JSON.parseObject(cancleOrder.getContent()); + int driverTimeout = jsonObject.getIntValue("driverTimeout"); + long timeOutCancel = orderLogistics.getEstimateArriveTime().getTime() + driverTimeout; + map.put("timeOutCancel", timeOutCancel); + map.put("driverTimeOut", orderLogistics.getEstimateArriveTime().getTime()); + } return map; } @@ -2593,8 +3206,19 @@ @Override public List<Map<String, Object>> queryCoupon(Integer language, Integer orderId, Integer uid, Integer pageNum, Integer size) throws Exception { OrderLogistics orderLogistics = this.selectById(orderId); - List<Map<String, Object>> list = userCouponRecordService.queryCoupon(language, uid, orderLogistics.getCompanyId(), 1, 4, orderLogistics.getOrderMoney() - orderLogistics.getDiscountMoney(), pageNum, size); - List<Map<String, Object>> list1 = userCouponRecordService.queryCoupon(language, uid, orderLogistics.getCompanyId(), 1, 0, orderLogistics.getOrderMoney() - orderLogistics.getDiscountMoney(), pageNum, size); + UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(orderLogistics.getCompanyId()); + double v = orderLogistics.getOrderMoney(); + if(null != query2){ + Integer orderNum=this.selectCount(new EntityWrapper<OrderLogistics>().eq("userId",orderLogistics.getUserId()).eq("activityId",query2.getId()).last(" and to_days(getoffTime) = to_days(now())")); + if(query2.getDistance()*1000>orderLogistics.getMileage() && query2.getOrderNum()>orderNum){ + Double special = query2.getLogistics(); + orderLogistics.setDiscount(special); + Double orderMoney = orderLogistics.getOrderMoney(); + v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue(); + } + } + List<Map<String, Object>> list = userCouponRecordService.queryCoupon(language, uid, orderLogistics.getCompanyId(), 1, 4, v, pageNum, size); + List<Map<String, Object>> list1 = userCouponRecordService.queryCoupon(language, uid, orderLogistics.getCompanyId(), 1, 0, v, pageNum, size); list.addAll(list1); return list; } @@ -2624,25 +3248,26 @@ JSONObject object = JSON.parseObject(query.getContent()); long t = object.getInteger("driverTimeout") * 60000L; //司机超时未到达起点,免费取消 - if(orderLogistics.getState() < 3 && orderLogistics.getSnatchOrderTime().getTime() + t < System.currentTimeMillis()){ + if(orderLogistics.getState() <= 3 && orderLogistics.getEstimateArriveTime().getTime() + t <= System.currentTimeMillis()){ baseWarpper.setAmount(amount); return ResultUtil.success(baseWarpper); } - JSONObject order = object.getJSONObject("order"); - long m = order.getInteger("orderAcceptanceTime") * 60000L; - //超过免费时间,计算费用 - if(orderLogistics.getSnatchOrderTime().getTime() + m < System.currentTimeMillis()){ - BigDecimal money = order.getBigDecimal("money"); - if(null != orderLogistics.getSetOutTime()){ + //非服务中且未超时 + if(orderLogistics.getState() != 5){ + JSONObject order = object.getJSONObject("order"); + long m = order.getInteger("orderAcceptanceTime") * 60000L; + //超过免费时间,且没有超时,计算费用 + if(orderLogistics.getSnatchOrderTime().getTime() + m < System.currentTimeMillis() && orderLogistics.getEstimateArriveTime().getTime() + t > System.currentTimeMillis()){ + BigDecimal money = order.getBigDecimal("money"); //里程费 - BigDecimal mileageFee = order.getBigDecimal("mileageFee").multiply(new BigDecimal(orderLogistics.getMileage() / 1000)); + BigDecimal mileageFee = order.getBigDecimal("mileageFee").multiply(new BigDecimal(orderLogistics.getToStartPointMileage() / 1000)); //时长费 - int s = Double.valueOf((System.currentTimeMillis() - orderLogistics.getSetOutTime().getTime()) / 60000).intValue(); + int s = Double.valueOf((System.currentTimeMillis() - orderLogistics.getSnatchOrderTime().getTime()) / 60000).intValue(); BigDecimal durationFee = order.getBigDecimal("durationFee").multiply(new BigDecimal(s)); money = money.add(durationFee).add(mileageFee); + amount = money.setScale(2, RoundingMode.HALF_EVEN).doubleValue(); } - amount = money.setScale(2, RoundingMode.HALF_EVEN).doubleValue(); } baseWarpper.setAmount(amount); return ResultUtil.success(baseWarpper); @@ -2690,7 +3315,7 @@ if(null == orderLogistics){ return ResultUtil.error(language == 1 ? "取消订单失败,订单信息有误" : language == 2 ? "Failed to cancel order, order-information error." : "Échec de l’annulation de la commande, erreur d’information de commande.", ""); } - if(orderLogistics.getState() != 13){ + if(orderLogistics.getState() != 12){ return ResultUtil.error(language == 1 ? "取消订单失败,不合法的操作" : language == 2 ? "Failed to cancel order, illegal operation." : "Échec de l’annulation de la commande, opération illégale.", ""); } OrderCancel orderCancel = null; @@ -2700,7 +3325,7 @@ orderCancel = orderCancelService.selectById(cancleId); } - Double amount = queryCancleAmount(id, language).getData().getAmount(); + Double amount = orderCancel.getMoney(); if(0 < amount){ if(payType == 1){//手机支付 orderCancel.setPayType(1); @@ -2780,18 +3405,35 @@ orderCancelService.updateById(orderCancel); if(null != orderLogistics.getDriverId()){ - BigDecimal c =new BigDecimal(amount);//司机收入 - incomeService.saveData(2, orderLogistics.getDriverId(), 3, 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); + //添加已收入明细 + Company company = companyService.selectById(orderLogistics.getCompanyId()); + Double speMoney = company.getSameLogisticsMoney(); + BigDecimal d = null;//企业收入 + BigDecimal c = null;//司机收入 + if(company.getIsSpeFixedOrProportional() == 2){//固定 + d = new BigDecimal(speMoney); + c = new BigDecimal(amount).subtract(d);//只有出行金额参与抽成,其余归属司机 + } + if(company.getIsSpeFixedOrProportional() == 1){//比例 + d = new BigDecimal(amount).multiply(new BigDecimal(speMoney).divide(new BigDecimal(100), new MathContext(2, RoundingMode.HALF_EVEN))); + c = new BigDecimal(amount).subtract(d).setScale(2, BigDecimal.ROUND_HALF_EVEN); + } + incomeService.saveData(1, orderLogistics.getCompanyId(), 3, orderLogistics.getId(), 4, d.doubleValue()); + if(c.doubleValue() > 0){ + incomeService.saveData(2, orderLogistics.getDriverId(), 3, 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); + } this.deleteTask(id);//删除定时任务 - pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), 4, orderLogistics.getState(), 0); + pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), 4, orderLogistics.getState(), 0, ""); + }else{ + incomeService.saveData(1, orderLogistics.getCompanyId(), 3, orderLogistics.getId(), 4, amount.doubleValue()); } - pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), 4, orderLogistics.getState(), 0); + pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), 4, orderLogistics.getState(), 0, ""); //添加消息 @@ -2841,21 +3483,38 @@ query1.setState(2); orderCancelService.updateById(query1); } - - + + Double amount = query.getAmount(); if(null != orderLogistics.getDriverId()){ - BigDecimal c =new BigDecimal(query.getAmount());//司机收入 - incomeService.saveData(2, orderLogistics.getDriverId(), 3, 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); + //添加已收入明细 + Company company = companyService.selectById(orderLogistics.getCompanyId()); + Double speMoney = company.getSameLogisticsMoney(); + BigDecimal d = null;//企业收入 + BigDecimal c = null;//司机收入 + if(company.getIsSpeFixedOrProportional() == 2){//固定 + d = new BigDecimal(speMoney); + c = new BigDecimal(amount).subtract(d);//只有出行金额参与抽成,其余归属司机 + } + if(company.getIsSpeFixedOrProportional() == 1){//比例 + d = new BigDecimal(amount).multiply(new BigDecimal(speMoney).divide(new BigDecimal(100), new MathContext(2, RoundingMode.HALF_EVEN))); + c = new BigDecimal(amount).subtract(d).setScale(2, BigDecimal.ROUND_HALF_EVEN); + } + incomeService.saveData(1, orderLogistics.getCompanyId(), 3, orderLogistics.getId(), 4, d.doubleValue()); + if(c.doubleValue() > 0){ + incomeService.saveData(2, orderLogistics.getDriverId(), 3, 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); + } this.deleteTask(orderLogistics.getId());//删除定时任务 - pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), 4, orderLogistics.getState(), 0); + pushUtil.pushOrderState(2, orderLogistics.getDriverId(), orderLogistics.getId(), 4, orderLogistics.getState(), 0, ""); + }else{ + incomeService.saveData(1, orderLogistics.getCompanyId(), 3, orderLogistics.getId(), 4, amount.doubleValue()); } - pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), 4, orderLogistics.getState(), 0); + pushUtil.pushOrderState(1, orderLogistics.getUserId(), orderLogistics.getId(), 4, orderLogistics.getState(), 0, ""); //添加消息 systemNoticeService.addSystemNotice(1, language == 1 ? "您已使用余额成功支付取消订单费用,谢谢使用!" : language == 2 @@ -2882,7 +3541,22 @@ orderLogistics.setDestinationLat(endLat); orderLogistics.setDestinationLon(endLon); this.updateById(orderLogistics); - pushUtil.pushModifyAddress(2, orderLogistics.getDriverId(), orderId, 1, 1); + + Driver driver = driverService.selectById(orderLogistics.getDriverId()); + Integer language1 = driver.getLanguage(); + String audioUrl = ""; + switch (language1){ + case 1: + audioUrl = "http://182.160.16.251:81/files/audio/system/ChangeAddress-CN.mp3"; + break; + case 2: + audioUrl = "http://182.160.16.251:81/files/audio/system/ChangeAddress-EN.mp3"; + break; + case 3: + audioUrl = "http://182.160.16.251:81/files/audio/system/ChangeAddress-FR.mp3"; + break; + } + pushUtil.pushModifyAddress(2, orderLogistics.getDriverId(), orderId, 4, 1, audioUrl); }else{ orderLogistics.setEndAddress(endAddress); orderLogistics.setEndLat(Double.valueOf(endLat)); @@ -2924,10 +3598,6 @@ UserRedPacketRecord userRedPacketRecord = new UserRedPacketRecord(); userRedPacketRecord.setMoney(money); userRedPacketRecord.setRemainingAmount(money); - Calendar calendar = Calendar.getInstance(); - calendar.setTime(new Date()); - calendar.set(Calendar.DAY_OF_MONTH, calendar.get(Calendar.DAY_OF_MONTH) + Integer.valueOf(String.valueOf(query.get("effective")))); - userRedPacketRecord.setExpirationTime(calendar.getTime()); userRedPacketRecord.setInsertTime(new Date()); userRedPacketRecord.setCompanyId(Integer.valueOf(String.valueOf(query.get("companyId")))); userRedPacketRecord.setState(0); @@ -2980,7 +3650,7 @@ Element user_chinese = document.getElementById("user_chinese"); user_chinese.text("您好 " + userInfo.getNickName() + ","); Element time_chinese = document.getElementById("time_chinese"); - time_chinese.text("此活动有效期在 " + DateUtil.conversionFormat(language, sdf.format(query.getInsertTime())) + " 至 " + DateUtil.conversionFormat(language, sdf.format(query.getExpirationTime())) + ",详情请查看I-GO平台"); + time_chinese.text("此活动有效期在 " + DateUtil.conversionFormat(language, sdf.format(id.getStartTime())) + " 至 " + DateUtil.conversionFormat(language, sdf.format(id.getEndTime())) + ",详情请查看I-GO平台"); } if(2 == language){ document.getElementById("chinese").remove(); @@ -2989,7 +3659,7 @@ Element user_english = document.getElementById("user_english"); user_english.text("Hello " + userInfo.getNickName() + ","); Element time_english = document.getElementById("time_english"); - time_english.text("You could use it from " + DateUtil.conversionFormat(language, sdf.format(query.getInsertTime())) + " to " + DateUtil.conversionFormat(language, sdf.format(query.getExpirationTime())) + ",check more details on the app."); + time_english.text("You could use it from " + DateUtil.conversionFormat(language, sdf.format(id.getStartTime())) + " to " + DateUtil.conversionFormat(language, sdf.format(id.getEndTime())) + ",check more details on the app."); } if(3 == language){ document.getElementById("chinese").remove(); @@ -2998,7 +3668,7 @@ Element user_french = document.getElementById("user_french"); user_french.text("Bonjour " + userInfo.getNickName() + ","); Element time_french = document.getElementById("time_french"); - time_french.text("Cette promotion est valable du " + DateUtil.conversionFormat(language, sdf.format(query.getInsertTime())) + " au " + DateUtil.conversionFormat(language, sdf.format(query.getExpirationTime())) + ". Veuillez consulter la plateforme i-go pour plus de détails."); + time_french.text("Cette promotion est valable du " + DateUtil.conversionFormat(language, sdf.format(id.getStartTime())) + " au " + DateUtil.conversionFormat(language, sdf.format(id.getEndTime())) + ". Veuillez consulter la plateforme i-go pour plus de détails."); } EmailUtil.send(userInfo.getEmail(), language == 1 ? "红包活动" : language == 2 ? "Lucky-promo activities" : "Activités bonus", document.html()); @@ -3060,4 +3730,139 @@ } return list; } + + + /** + * 获取服务中的订单数据 + * @param uid + * @return + * @throws Exception + */ + @Override + public OrderServerWarpper queryOrderServer(Integer orderId, Integer uid) throws Exception { + OrderLogistics orderLogistics = this.selectById(orderId); + //计算预计距离和剩余时间 + String value = redisUtil.getValue("DRIVER" + orderLogistics.getDriverId()); + String d = "0"; + String t = "0"; + if(null == value || "".equals(value)){ + System.err.println("司机没有上传位置信息"); + + //调用获取轨迹中的数据 + File file = new File(filePath + orderId + "_4.txt"); + if(file.exists()){ + //读取文件(字符流) + BufferedReader in = new BufferedReader(new InputStreamReader(new FileInputStream(file),"UTF-8")); + //循环取出数据 + String str = null; + StringBuffer sb = new StringBuffer(); + while ((str = in.readLine()) != null) { + sb.append(str); + } + List<OrderPosition> list = JSONArray.parseArray(sb.toString(), OrderPosition.class); + if(list.size() > 0){ + OrderPosition orderPosition = list.get(list.size() - 1); + value = orderPosition.getLon() + "," + orderPosition.getLat(); + } + } + } + + String lnt = "0"; + String lat = "0"; + if(ToolUtil.isNotEmpty(value)){ + lnt = value.split(",")[0]; + lat = value.split(",")[1]; + DistancematrixVo distancematrix = GoogleMapUtil.getDistancematrix(orderLogistics.getStartLat(), orderLogistics.getStartLon(), Double.valueOf(lat), Double.valueOf(lnt)); + + if(null == distancematrix){ + System.err.println("查询距离出错了"); + }else if(distancematrix.getDistance() == 0){ + System.err.println("未获取到有效的距离"); + }else{ + d = new BigDecimal(distancematrix.getDistance()).divide(new BigDecimal(1000), new MathContext(2, RoundingMode.HALF_EVEN)).toString(); + t = new BigDecimal(distancematrix.getDuration()).divide(new BigDecimal(60), new MathContext(2, RoundingMode.HALF_EVEN)).intValue() + ""; + } + } + + OrderServerWarpper orderServerWarpper = new OrderServerWarpper(); + orderServerWarpper.setOrderId(orderLogistics.getId()); + orderServerWarpper.setOrderType(4); + orderServerWarpper.setState(orderLogistics.getState()); + orderServerWarpper.setLon(lnt); + orderServerWarpper.setLat(lat); + orderServerWarpper.setReassignNotice(orderLogistics.getReassignNotice()); + if(orderLogistics.getState() == 2 || orderLogistics.getState() == 3){//前往预约地 + orderServerWarpper.setReservationMileage(d); + orderServerWarpper.setReservationTime(t); + orderServerWarpper.setServedMileage("0"); + orderServerWarpper.setServedTime("0"); + orderServerWarpper.setLaveMileage("0"); + orderServerWarpper.setLaveTime("0"); + } + if(orderLogistics.getState() == 5 || orderLogistics.getState() == 6){//服务中 + DistancematrixVo distancematrix = GoogleMapUtil.getDistancematrix(Double.valueOf(lat), Double.valueOf(lnt), orderLogistics.getEndLat(), orderLogistics.getEndLon()); + if(null == distancematrix){ + System.err.println("查询距离出错了"); + }else if(distancematrix.getDistance() == 0){ + System.err.println("未获取到有效的距离"); + }else{ + d = new BigDecimal(distancematrix.getDistance()).divide(new BigDecimal(1000), new MathContext(2, RoundingMode.HALF_EVEN)).toString(); + t = new BigDecimal(distancematrix.getDuration()).divide(new BigDecimal(60), new MathContext(2, RoundingMode.HALF_EVEN)).intValue() + ""; + } + orderServerWarpper.setReservationMileage("0"); + orderServerWarpper.setReservationTime("0"); + orderServerWarpper.setServedMileage(String.valueOf((null == orderLogistics.getMileage() ? 0 : orderLogistics.getMileage()) / 1000)); + orderServerWarpper.setServedTime("0"); + if(null != orderLogistics.getStartServiceTime()){ + orderServerWarpper.setServedTime(Long.valueOf((new Date().getTime() - orderLogistics.getStartServiceTime().getTime()) / 60000).intValue() + ""); + } + orderServerWarpper.setLaveMileage(d); + orderServerWarpper.setLaveTime(t); + } + File file = new File(filePath + orderId + "_4.txt"); + if(file.exists()){ + //读取文件(字符流) + BufferedReader in = new BufferedReader(new InputStreamReader(new FileInputStream(file),"UTF-8")); + //循环取出数据 + String str = null; + StringBuffer sb = new StringBuffer(); + while ((str = in.readLine()) != null) { + sb.append(str); + } + List<OrderPosition> list = JSONArray.parseArray(sb.toString(), OrderPosition.class); + orderServerWarpper.setOrderPositionList(JSONObject.toJSONString(list)); + } + return orderServerWarpper; + } + + + /** + * 获取下单推送完后没有司机接单的提醒 + * @return + * @throws Exception + */ + @Override + public EndPushWarpper queryEndPush(Integer uid) throws Exception { + List<OrderLogistics> list = orderLogisticsMapper.queryByState(uid, null, null, 1); + EndPushWarpper endPushWarpper = new EndPushWarpper(); + if(list.size() > 0){ + OrderLogistics orderPrivateCar = list.get(0); + if(!orderIds.contains(orderPrivateCar.getId())){ + endPushWarpper.setOrderId(orderPrivateCar.getId()); + endPushWarpper.setOrderType(4); + endPushWarpper.setState(1); + List<PushOrder> querys = pushOrderService.querys(null, 2, orderPrivateCar.getCompanyId());//获取需要推送的次数 + int time = 0; + for(int i = 1; i <= querys.size(); i++){ + PushOrder pushOrder = pushOrderService.querys(i, 2, orderPrivateCar.getCompanyId()).get(0); + time += pushOrder.getPushTime() * 1000; + } + //当前时间减去推单总时间大于下单时间 + if((System.currentTimeMillis() - time) > orderPrivateCar.getInsertTime().getTime()){ + endPushWarpper.setState(2); + } + } + } + return endPushWarpper; + } } -- Gitblit v1.7.1