From 19d2b6427ebed89895b402d5e61ab78f4687b550 Mon Sep 17 00:00:00 2001 From: Pu Zhibing <393733352@qq.com> Date: 星期四, 10 十月 2024 11:31:11 +0800 Subject: [PATCH] 修改bug --- UserIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java | 1462 +++++++++++++++++++++++++++++++++++++++++++-------------- 1 files changed, 1,099 insertions(+), 363 deletions(-) diff --git a/UserIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java b/UserIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java index 673d31a..33db1ad 100644 --- a/UserIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java +++ b/UserIGOTravel/guns-admin/src/main/java/com/stylefeng/guns/modular/specialTrain/server/impl/OrderPrivateCarServiceImpl.java @@ -7,7 +7,6 @@ import com.baomidou.mybatisplus.service.impl.ServiceImpl; import com.stylefeng.guns.core.util.ToolUtil; import com.stylefeng.guns.modular.crossCity.dao.OrderCrossCityMapper; -import com.stylefeng.guns.modular.crossCity.model.OrderCrossCity; import com.stylefeng.guns.modular.crossCity.server.IOrderCrossCityService; import com.stylefeng.guns.modular.crossCity.server.impl.OrderCrossCityServiceImpl; import com.stylefeng.guns.modular.smallLogistics.model.OrderLogistics; @@ -20,6 +19,7 @@ import com.stylefeng.guns.modular.system.service.*; import com.stylefeng.guns.modular.system.util.*; import com.stylefeng.guns.modular.system.util.GoogleMap.DistancematrixVo; +import com.stylefeng.guns.modular.system.util.GoogleMap.FleetEngineUtil; import com.stylefeng.guns.modular.system.util.GoogleMap.GoogleMapUtil; import com.stylefeng.guns.modular.system.util.GoogleMap.ReverseGeocodeVo; import com.stylefeng.guns.modular.system.util.Tingg.TinggPayUtil; @@ -27,7 +27,6 @@ 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.OrderInfoWarpper; import com.stylefeng.guns.modular.system.warpper.OrderServerWarpper; import com.stylefeng.guns.modular.taxi.dao.OrderTaxiMapper; import com.stylefeng.guns.modular.taxi.model.OrderTaxi; @@ -38,7 +37,6 @@ import org.jsoup.Jsoup; import org.jsoup.nodes.Document; import org.jsoup.nodes.Element; -import org.jsoup.nodes.FormElement; import org.jsoup.select.Elements; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; @@ -48,6 +46,7 @@ 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; @@ -86,92 +85,92 @@ @Resource private RegionMapper regionMapper; - @Autowired + @Resource private DateUtil dateUtil; - @Autowired + @Resource private IUserInfoService userInfoService; - @Autowired + @Resource private IDriverService driverService; - @Autowired + @Resource private IDriverServiceService driverServiceService; - @Autowired + @Resource private PushUtil pushUtil; - @Autowired + @Resource private ICompanyCityService companyCityService; - @Autowired + @Resource private IPushOrderService pushOrderService; - @Autowired + @Resource private ISystemNoticeService systemNoticeService; - @Autowired + @Resource private ICancleOrderService cancleOrderService; - @Autowired + @Resource private IOrderCancelService orderCancelService; - @Autowired + @Resource private RestTemplate internalRestTemplate; - @Autowired + @Resource private IPaymentRecordService paymentRecordService; - @Autowired + @Resource private ITransactionDetailsService transactionDetailsService; - @Autowired + @Resource private ChinaMobileUtil chinaMobileUtil; - @Autowired + @Resource private IIncomeService incomeService; - @Autowired + @Resource private IUserCouponRecordService userCouponRecordService; - @Autowired + @Resource private IUserRedPacketRecordService userRedPacketRecordService; - @Autowired + @Resource private ICompanyService companyService; - @Autowired + @Resource private IUserActivityRedenvelopeService userActivityRedenvelopeService; - @Autowired + @Resource private RedisUtil redisUtil; - @Autowired + @Resource private IOrderPositionService orderPositionService; - @Autowired + @Resource private IOrderCrossCityService orderCrossCityService; - @Autowired + @Resource private IAssignOrderService assignOrderService; @Resource private CarMapper carMapper; - @Autowired + @Resource private IOrderEvaluateService orderEvaluateService; - @Autowired + @Resource private IOrderLogisticsService orderLogisticsService; - @Autowired + @Resource private IBankCardService bankCardService; @Value("${filePath}") private String filePath; - @Autowired + @Resource private IOrderTaxiService orderTaxiService; public static List<Integer> orderIds = new ArrayList<>(); @@ -182,23 +181,35 @@ @Value("${spring.mail.template-path}") private String templatePath; - @Autowired + @Resource private ISettlementDetailService settlementDetailService; - @Autowired + @Resource private ISettlementRecordService settlementRecordService; - @Autowired + @Resource private ISettlementAllocationService settlementAllocationService; - @Autowired + @Resource private TEmailService emailService; - @Autowired + @Resource private IPhoneService phoneService; - @Autowired + @Resource private IRedEnvelopePaymentSettingsService redEnvelopePaymentSettingsService; + + @Resource + private FleetEngineUtil fleetEngineUtil; + + @Resource + private CarModelMapper carModelMapper; + + @Resource + private ICarService carService; + + @Resource + private IDriverWorkService driverWorkService; @@ -236,30 +247,25 @@ if(orderPrivateCars.size() > 0){ return ResultUtil.error(language == 1 ? "有未完成的订单" : language == 2 ? "Uncompleted order(s)" : "Commande(s) non complétée(s)"); } - List<OrderTaxi> list = orderTaxiMapper.queryByState_(uid, 1, 1, 1, 2, 3, 4, 5, 6, 11); - if(list.size() > 0){ + int i1 = orderLogisticsService.selectCount(new EntityWrapper<OrderLogistics>().eq("userId", uid).in("state", Arrays.asList(1, 2, 3, 4, 5, 6, 7, 11, 12)).eq("isDelete", 1)); + if(i1 > 0){ return ResultUtil.error(language == 1 ? "有未完成的订单" : language == 2 ? "Uncompleted order(s)" : "Commande(s) non complétée(s)"); } - orderPrivateCars = orderPrivateCarMapper.queryByState(uid, 2, 1, 1, 2, 3, 4, 5, 6, 11); + orderPrivateCars = orderPrivateCarMapper.queryByState(uid, 2, 1, 1, 2, 3, 4, 5, 6, 11); if(orderPrivateCars.size() > 0 && reservation == 2){ return ResultUtil.error(language == 1 ? "有未完成的订单" : language == 2 ? "Uncompleted order(s)" : "Commande(s) non complétée(s)"); } - orderPrivateCars = orderPrivateCarMapper.queryByState(uid, 1, 1, 7,12); + orderPrivateCars = orderPrivateCarMapper.queryByState(uid, 1, 1, 7, 12); if(orderPrivateCars.size() > 0){ BaseWarpper baseWarpper = new BaseWarpper(); baseWarpper.setState(7); baseWarpper.setId(orderPrivateCars.get(0).getId()); return ResultUtil.success(baseWarpper); } - - - list = orderTaxiMapper.queryByState_(uid, 2, 1, 1, 2, 3, 4, 5, 6, 11); - if(list.size() > 0 && reservation == 2){ - return ResultUtil.error(language == 1 ? "有未完成的订单" : language == 2 ? "Uncompleted order(s)" : "Commande(s) non complétée(s)"); - } - + + String tripId = redisUtil.getValue("trip" + uid); startAddress = startAddress.replaceAll("& #40;", "("); startAddress = startAddress.replaceAll("& #41;", ")"); endAddress = endAddress.replaceAll("& #40;", "("); @@ -276,7 +282,7 @@ orderPrivateCar.setPlacementLon(Double.valueOf(placementLon)); orderPrivateCar.setPlacementLat(Double.valueOf(placementLat)); - ReverseGeocodeVo reverseGeocode = GoogleMapUtil.getReverseGeocode(Double.valueOf(placementLat), Double.valueOf(placementLon)); + ReverseGeocodeVo reverseGeocode = GoogleMapUtil.getReverseGeocode(Double.valueOf(placementLat), Double.valueOf(placementLon), tripId); orderPrivateCar.setPlacementAddress(reverseGeocode.getAddress()); orderPrivateCar.setStartLon(Double.valueOf(startLon)); orderPrivateCar.setStartLat(Double.valueOf(startLat)); @@ -337,21 +343,113 @@ CarService query1 = carServiceMapper.query(1, driver.getCarId()); orderPrivateCar.setServerCarModelId(query1.getServerCarModelId()); orderPrivateCar.setSnatchOrderTime(new Date()); - + if(orderPrivateCar.getOrderType() == 1){ + String value = redisUtil.getValue("DRIVER" + driver.getId()); + if(ToolUtil.isNotEmpty(value)) { + String[] split = value.split(","); + DistancematrixVo distancematrix = GoogleMapUtil.getDistancematrix(orderPrivateCar.getStartLat(), orderPrivateCar.getStartLon(), Double.valueOf(split[1]), Double.valueOf(split[0]), tripId); + //超时时间 + long timeOut = System.currentTimeMillis() + (distancematrix.getDuration() * 1000); + orderPrivateCar.setEstimateArriveTime(new Date(timeOut)); + orderPrivateCar.setEstimateArriveMileage(distancematrix.getDistance()); + } + } driver.setState(3); driverService.updateById(driver); } orderPrivateCar.setIsReassign(1); orderPrivateCar.setIsDelete(1); + orderPrivateCar.setTripId(tripId); + DistancematrixVo distancematrix1 = GoogleMapUtil.getDistancematrix(orderPrivateCar.getStartLat(), orderPrivateCar.getStartLon(), orderPrivateCar.getEndLat(), orderPrivateCar.getEndLon(), tripId); + Long distance1 = distancematrix1.getDistance(); + orderPrivateCar.setEstimatedMileage(new BigDecimal(distance1).divide(new BigDecimal(1000)).setScale(2, RoundingMode.HALF_EVEN).doubleValue()); this.insert(orderPrivateCar); + + UserInfo userInfo = userInfoService.selectById(uid); + userInfo.setLanguage(language); + userInfoService.updateById(userInfo); + + new Thread(() -> { + try { + if(null != orderPrivateCar.getDriverId()){ + Driver driver = driverService.selectById(orderPrivateCar.getDriverId()); + Car car = carMapper.selectById(driver.getCarId()); + if(!StringUtils.hasLength(car.getVehicleId())){ + car.setVehicleId(UUIDUtil.getRandomCode()); + carMapper.updateById(car); + } + String vehicleId = car.getVehicleId(); + //查询车辆信息,没有则创建信息 + 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, orderPrivateCar.getTripId(), + orderPrivateCar.getStartLat().toString(), orderPrivateCar.getStartLon().toString(), orderPrivateCar.getEndLat().toString(), orderPrivateCar.getEndLon().toString()); + } + + }catch (Exception e){ + e.printStackTrace(); + } + }).start(); + if(orderSource == 2){//扫码下单 + Driver driver = driverService.selectById(orderPrivateCar.getDriverId()); + Integer language1 = driver.getLanguage(); + String text = ""; + switch (language1){ + case 1: + text = "收到新的打车订单,从" + orderPrivateCar.getStartAddress() + "出发,全程约" + orderPrivateCar.getEstimatedMileage() + "公里"; + break; + case 2: + text = "Received a new ride order, starting from " + orderPrivateCar.getStartAddress() + ", the whole journey is about " + orderPrivateCar.getEstimatedMileage() + "kilometre"; + break; + case 3: + text = "J'ai reçu une nouvelle commande de course, à partir de " + orderPrivateCar.getStartAddress() + ", le trajet complet est d’environ " + orderPrivateCar.getEstimatedMileage() + "kilométrage"; + break; + + } + String audioUrl = ""; + String fileName = "pushOrder" + orderPrivateCar.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() { + try { + // 使用Runtime执行命令 + Process process = Runtime.getRuntime().exec("sudo rm -rf /home/igotechgh/nginx/html/files/audio/" + fileName); + // 读取命令的输出 + BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream())); + String line; + while ((line = reader.readLine()) != null) { + System.out.println(line); + } + // 等待命令执行完成 + process.waitFor(); + // 关闭流 + reader.close(); + } catch (IOException | InterruptedException e) { + e.printStackTrace(); + } + } + }, 30000); + String finalAudioUrl = audioUrl; new Thread(new Runnable() { @Override public void run() { - pushUtil.pushOrderState(1, uid, orderPrivateCar.getId(), 1, 2, 0); - pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 2, 0); + pushUtil.pushOrderState(1, uid, orderPrivateCar.getId(), 1, 2, 0, ""); + pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 2, 0, finalAudioUrl); } }).start(); } @@ -359,14 +457,14 @@ // TODO: 2021/5/11 修改,根据后台设定的派单范围查询范围内有无司机,将单子指派给距离最近的司机(距离相同随机取),范围内没有司机再进行推单流程 if(orderPrivateCar.getState() == 1){ - Company query = companyCityService.query1(orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString()); + Company query = companyCityService.query1(uid, orderPrivateCar.getStartLon().toString(), orderPrivateCar.getStartLat().toString()); if(null == query){ return ResultUtil.error(language == 1 ? "起点暂未企业提供服务" : language == 2 ? "Starting point no enterprise to provide services" : "Point de départ pas encore disponible pour les entreprises"); } AssignOrder assignOrder = assignOrderService.selectOne(new EntityWrapper<AssignOrder>().eq("companyId", query.getId()).eq("type", 1)); if(null != assignOrder && assignOrder.getPeople() > 0){//配置了指派规则才处理 //获取空闲司机 - List<Driver> drivers = driverService.queryIdleDriver(1, orderPrivateCar.getServerCarModelId(), orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat(), assignOrder.getDistance(), null);//获取范围内空闲司机 + List<Driver> drivers = driverService.queryIdleDriver(orderPrivateCar.getUserId(), 1, orderPrivateCar.getServerCarModelId(), orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat(), assignOrder.getDistance(), null);//获取范围内空闲司机 if(drivers.size() > 0){//有司机,直接指派给司机 Driver dr = null; if(drivers.size() > 1){ @@ -379,7 +477,7 @@ String value = redisUtil.getValue("DRIVER" + drivers.get(j).getId()); if(null != value){ String[] split = value.split(","); - DistancematrixVo distancematrix = GoogleMapUtil.getDistancematrix(orderPrivateCar.getStartLat(), orderPrivateCar.getStartLon(), Double.valueOf(split[1]), Double.valueOf(split[0])); + DistancematrixVo distancematrix = GoogleMapUtil.getDistancematrix(orderPrivateCar.getStartLat(), orderPrivateCar.getStartLon(), Double.valueOf(split[1]), Double.valueOf(split[0]), tripId); Long distance = distancematrix.getDistance(); if((0 == m && null == driver) || (distance < m)){ driver = drivers.get(j); @@ -398,7 +496,7 @@ String value = redisUtil.getValue("DRIVER" + driver.getId()); if(null != value){ String[] split = value.split(","); - DistancematrixVo distancematrix = GoogleMapUtil.getDistancematrix(orderPrivateCar.getStartLat(), orderPrivateCar.getStartLon(), Double.valueOf(split[1]), Double.valueOf(split[0])); + DistancematrixVo distancematrix = GoogleMapUtil.getDistancematrix(orderPrivateCar.getStartLat(), orderPrivateCar.getStartLon(), Double.valueOf(split[1]), Double.valueOf(split[0]), tripId); Long d = distancematrix.getDistance(); if((0 == m && null == dr) || (d.intValue() < m.intValue())){ dr = driver; @@ -409,27 +507,77 @@ }else{ dr = drivers.get(0); } - - orderPrivateCar.setDriverId(dr.getId()); - orderPrivateCar.setCompanyId(dr.getFranchiseeId() != null && dr.getFranchiseeId() != 0 ? dr.getFranchiseeId() : ( - dr.getCompanyId() != null && dr.getCompanyId() != 0 ? dr.getCompanyId() : 1)); - orderPrivateCar.setState(2); - orderPrivateCar.setCarId(dr.getCarId()); - CarService query1 = carServiceMapper.query(1, dr.getCarId()); - orderPrivateCar.setServerCarModelId(query1.getServerCarModelId()); - orderPrivateCar.setSnatchOrderTime(new Date()); - - dr.setState(3); - driverService.updateById(dr); - this.updateById(orderPrivateCar); - - new Thread(new Runnable() { - @Override - public void run() { - pushUtil.pushOrderState(1, uid, orderPrivateCar.getId(), 1, 2, 0); - pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 2, 0); + + Driver driver = driverService.selectById(dr.getId()); + DriverWork driverWork = driverWorkService.selectOne(new EntityWrapper<DriverWork>().eq("driverId", dr.getId()) + .eq("state", 1).like("type", "1")); + if(driver.getState() == 2 && null != driverWork){ + orderPrivateCar.setDriverId(dr.getId()); + orderPrivateCar.setCompanyId(dr.getFranchiseeId() != null && dr.getFranchiseeId() != 0 ? dr.getFranchiseeId() : ( + dr.getCompanyId() != null && dr.getCompanyId() != 0 ? dr.getCompanyId() : 1)); + orderPrivateCar.setState(2); + orderPrivateCar.setCarId(dr.getCarId()); + CarService query1 = carServiceMapper.query(1, dr.getCarId()); + orderPrivateCar.setServerCarModelId(query1.getServerCarModelId()); + orderPrivateCar.setSnatchOrderTime(new Date()); + + dr.setState(3); + driverService.updateById(dr); + this.updateById(orderPrivateCar); + + Integer language1 = dr.getLanguage(); + String text = ""; + switch (language1){ + case 1: + text = "收到新的打车订单,从" + orderPrivateCar.getStartAddress() + "出发,全程约" + orderPrivateCar.getEstimatedMileage() + "公里"; + break; + case 2: + text = "Received a new ride order, starting from " + orderPrivateCar.getStartAddress() + ", the whole journey is about " + orderPrivateCar.getEstimatedMileage() + "kilometre"; + break; + case 3: + text = "J'ai reçu une nouvelle commande de course, à partir de " + orderPrivateCar.getStartAddress() + ", le trajet complet est d’environ " + orderPrivateCar.getEstimatedMileage() + "kilométrage"; + break; + } - }).start(); + String audioUrl = ""; + String fileName = "pushOrder" + orderPrivateCar.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() { + try { + // 使用Runtime执行命令 + Process process = Runtime.getRuntime().exec("sudo rm -rf /home/igotechgh/nginx/html/files/audio/" + fileName); + // 读取命令的输出 + BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream())); + String line; + while ((line = reader.readLine()) != null) { + System.out.println(line); + } + // 等待命令执行完成 + process.waitFor(); + // 关闭流 + reader.close(); + } catch (IOException | InterruptedException e) { + e.printStackTrace(); + } + } + }, 30000); + + String finalAudioUrl = audioUrl; + new Thread(new Runnable() { + @Override + public void run() { + pushUtil.pushOrderState(1, uid, orderPrivateCar.getId(), 1, 2, 0, ""); + pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, 2, 0, finalAudioUrl); + } + }).start(); + } } } } @@ -438,22 +586,6 @@ //推单操作 if(orderPrivateCar.getState() == 1){ this.pushOrder(orderPrivateCar); - }else{ -// //接单后定时任务判断司机是否去接乘客,没有则推送提醒 -// CancleOrder cancleOrder = cancleOrderService.query(orderPrivateCar.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() { -// OrderPrivateCar orderPrivateCar1 = OrderPrivateCarServiceImpl.this.selectById(orderPrivateCar.getId()); -// if(orderPrivateCar1.getState() == 2){ -// pushUtil.pushDriverTimeOut(1, orderPrivateCar1.getUserId(), orderPrivateCar1.getId(), 1); -// } -// } -// }, time); -// } } @@ -465,6 +597,7 @@ BaseWarpper baseWarpper = new BaseWarpper(); baseWarpper.setState(orderPrivateCar.getState()); baseWarpper.setId(orderPrivateCar.getId()); + baseWarpper.setContent(orderPrivateCar.getTripId()); return ResultUtil.success(baseWarpper); } @@ -534,53 +667,60 @@ BaseWarpper baseWarpper = new BaseWarpper(); double amount = 0; CancleOrder query = cancleOrderService.query(orderPrivateCar.getCompanyId()); - if(null == query || null == orderPrivateCar.getDriverId()){ + if(null == query || null == orderPrivateCar.getDriverId() || orderPrivateCar.getState() == 11){ baseWarpper.setAmount(amount); return ResultUtil.success(baseWarpper); } JSONObject object = JSON.parseObject(query.getContent()); long t = object.getInteger("driverTimeout") * 60000L; //司机超时未到达起点,免费取消 - if(orderPrivateCar.getState() < 3 && orderPrivateCar.getSnatchOrderTime().getTime() + t < System.currentTimeMillis()){ - baseWarpper.setAmount(amount); - return ResultUtil.success(baseWarpper); - } - //普通单 - if(1 == orderPrivateCar.getOrderType()){ - JSONObject order = object.getJSONObject("order"); - long m = order.getInteger("orderAcceptanceTime") * 60000L; - //超过免费时间,计算费用 - if(orderPrivateCar.getSnatchOrderTime().getTime() + m < System.currentTimeMillis()){ - BigDecimal money = order.getBigDecimal("money"); - if(null != orderPrivateCar.getSetOutTime()){ - //里程费 - BigDecimal mileageFee = order.getBigDecimal("mileageFee").multiply(new BigDecimal(orderPrivateCar.getMileage() / 1000)); - //时长费 - int s = Double.valueOf((System.currentTimeMillis() - orderPrivateCar.getSetOutTime().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(); + if(orderPrivateCar.getOrderType() == 1){ + if(orderPrivateCar.getState() <= 3 && orderPrivateCar.getEstimateArriveTime().getTime() + t <= System.currentTimeMillis()){ + baseWarpper.setAmount(amount); + return ResultUtil.success(baseWarpper); + } + }else{ + if(orderPrivateCar.getState() <= 3 && orderPrivateCar.getTravelTime().getTime() + t <= System.currentTimeMillis()){ + baseWarpper.setAmount(amount); + return ResultUtil.success(baseWarpper); } } - //预约单 - if(2 == orderPrivateCar.getOrderType()){ - JSONObject order = object.getJSONObject("reservationOrder"); - long m = order.getInteger("orderAcceptanceTime") * 60000L; - //超过免费时间,计算费用 - if(System.currentTimeMillis() + m > orderPrivateCar.getTravelTime().getTime()){ - BigDecimal money = order.getBigDecimal("money"); - if(null != orderPrivateCar.getSetOutTime()){ + + //非服务中且未超时 + if(orderPrivateCar.getState() != 5){ + //普通单 + if(1 == orderPrivateCar.getOrderType()){ + JSONObject order = object.getJSONObject("order"); + long m = order.getInteger("orderAcceptanceTime") * 60000L; + //超过免费时间,且没有超时,计算费用 + if(orderPrivateCar.getSnatchOrderTime().getTime() + m < System.currentTimeMillis() && orderPrivateCar.getEstimateArriveTime().getTime() + t > System.currentTimeMillis()){ + BigDecimal money = order.getBigDecimal("money"); //里程费 - BigDecimal mileageFee = order.getBigDecimal("mileageFee").multiply(new BigDecimal(orderPrivateCar.getMileage() / 1000)); + BigDecimal mileageFee = order.getBigDecimal("mileageFee").multiply(new BigDecimal(orderPrivateCar.getToStartPointMileage() / 1000)); //时长费 - int s = Double.valueOf((System.currentTimeMillis() - orderPrivateCar.getSetOutTime().getTime()) / 60000).intValue(); + int s = Double.valueOf((System.currentTimeMillis() - orderPrivateCar.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(); + } + } + //预约单 + if(2 == orderPrivateCar.getOrderType()){ + JSONObject order = object.getJSONObject("reservationOrder"); + long m = order.getInteger("orderAcceptanceTime") * 60000L; + //超过免费时间,且没有超时,计算费用 + if(System.currentTimeMillis() + m > orderPrivateCar.getTravelTime().getTime() && orderPrivateCar.getTravelTime().getTime() + t > System.currentTimeMillis()){ + BigDecimal money = order.getBigDecimal("money"); + //里程费 + BigDecimal mileageFee = order.getBigDecimal("mileageFee").multiply(new BigDecimal(orderPrivateCar.getToStartPointMileage() / 1000)); + //时长费 + int s = Double.valueOf((System.currentTimeMillis() - orderPrivateCar.getSnatchOrderTime().getTime()) / 60000).intValue(); BigDecimal durationFee = order.getBigDecimal("durationFee").multiply(new BigDecimal(s)); //预定费用 BigDecimal reservationFee = order.getBigDecimal("reservationFee"); money = money.add(durationFee).add(mileageFee).add(reservationFee); + amount = money.setScale(2, RoundingMode.HALF_EVEN).doubleValue(); } - amount = money.setScale(2, RoundingMode.HALF_EVEN).doubleValue(); } } baseWarpper.setAmount(amount); @@ -615,7 +755,7 @@ if(null == orderPrivateCar){ 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(orderPrivateCar.getState() > 5 && orderPrivateCar.getState() != 11){ + if(orderPrivateCar.getState() > 5 && orderPrivateCar.getState() != 11 && orderPrivateCar.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."); } @@ -672,21 +812,52 @@ integer = orderCancelService.saveData(id, 1, reason, remark, null, amount, 1, 1, uid); } this.deleteTask(id);//删除定时任务 - + //修改司机为空闲 + Driver driver = driverService.selectById(orderPrivateCar.getDriverId()); new Thread(new Runnable() { @Override public void run() { - pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0); + Integer language1 = driver.getLanguage(); + String audioUrl = ""; + switch (language1){ + case 1: + if(orderPrivateCar.getState() == 6){ + audioUrl = "https://igo.i-go.group/files/audio/system/MidwayCancellation-CN.mp3"; + }else{ + audioUrl = "https://igo.i-go.group/files/audio/system/UserCancelledOrder-CN.mp3"; + } + break; + case 2: + if(orderPrivateCar.getState() == 6){ + audioUrl = "https://igo.i-go.group/files/audio/system/MidwayCancellation-EN.mp3"; + }else{ + audioUrl = "https://igo.i-go.group/files/audio/system/UserCancelledOrder-EN.mp3"; + } + break; + case 3: + if(orderPrivateCar.getState() == 6){ + audioUrl = "https://igo.i-go.group/files/audio/system/MidwayCancellation-FR.mp3"; + }else{ + audioUrl = "https://igo.i-go.group/files/audio/system/UserCancelledOrder-FR.mp3"; + } + break; + } + pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, ""); + pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState() == 12 ? orderPrivateCar.getState() : 10, 0, audioUrl); System.err.println("推送取消操作---------------------"); } }).start(); - //修改司机为空闲 - Driver driver = driverService.selectById(orderPrivateCar.getDriverId()); + driver.setState(2); driverService.updateById(driver); } - + + //修改行程信息 + if((orderPrivateCar.getState() == 10 || orderPrivateCar.getState() == 12) && null != orderPrivateCar.getDriverId()){ + fleetEngineUtil.updateTrip("CANCELED", null, null, orderPrivateCar.getTripId(), null, null, null, null); + } + //添加消息 systemNoticeService.addSystemNotice(1, language == 1 ? "您已成功取消出行订单,谢谢使用!" : language == 2 ? "You've cancelled the ride order successfully, thank you for using I-GO " : "Vous avez annulé la commande de course avec succès, merci d’utiliser I-GO", orderPrivateCar.getUserId(), 1); Map<String, Object> map = new HashMap<>(); @@ -722,6 +893,9 @@ } Double amount = queryCancleAmount(id, language).getData().getAmount(); + if(orderPrivateCar.getState() == 12){ + amount = orderCancel.getMoney(); + } if(0 < amount){ if(payType == 1){//手机支付 orderCancel.setPayType(1); @@ -739,8 +913,8 @@ checkoutRequest.setRequestDescription("Cancel a trip"); checkoutRequest.setCallbackUrl(callbackPath + "/base/wxCancelOrderTaxi"); checkoutRequest.setPendingRedirectUrl(""); - checkoutRequest.setSuccessRedirectUrl("http://182.160.16.251:81/payMoney/pages/success.html"); - checkoutRequest.setFailRedirectUrl("http://182.160.16.251:81/payMoney/pages/fail.html"); + checkoutRequest.setSuccessRedirectUrl("https://igo.i-go.group/payMoney/pages/success.html"); + checkoutRequest.setFailRedirectUrl("https://igo.i-go.group/payMoney/pages/fail.html"); resultUtil = TinggPayUtil.checkoutRequest(checkoutRequest); if(resultUtil.getCode()==200){ paymentRecordService.saveData(1, null, null, id, 1, 1, amount, null, 1);//添加预支付数据 @@ -764,8 +938,8 @@ checkoutRequest.setRequestDescription("Cancel a trip"); checkoutRequest.setCallbackUrl(callbackPath + "/base/wxCancelOrderTaxi"); checkoutRequest.setPendingRedirectUrl(""); - checkoutRequest.setSuccessRedirectUrl("http://182.160.16.251:81/payMoney/pages/success.html"); - checkoutRequest.setFailRedirectUrl("http://182.160.16.251:81/payMoney/pages/fail.html"); + checkoutRequest.setSuccessRedirectUrl("https://igo.i-go.group/payMoney/pages/success.html"); + checkoutRequest.setFailRedirectUrl("https://igo.i-go.group/payMoney/pages/fail.html"); resultUtil = TinggPayUtil.checkoutRequest(checkoutRequest); if(resultUtil.getCode()==200){ paymentRecordService.saveData(1, null, null, id, 1, 2, amount, null, 1);//添加预支付数据 @@ -801,18 +975,35 @@ orderCancelService.updateById(orderCancel); if(null != orderPrivateCar.getDriverId()){ - BigDecimal c =new BigDecimal(amount);//司机收入 - incomeService.saveData(2, orderPrivateCar.getDriverId(), 3, orderPrivateCar.getId(), 1, c.doubleValue()); - Driver driver = driverService.selectById(orderPrivateCar.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(orderPrivateCar.getCompanyId()); + Double speMoney = company.getSpeMoney(); + 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, orderPrivateCar.getCompanyId(), 3, orderPrivateCar.getId(), 1, d.doubleValue()); + if(c.doubleValue() > 0){ + incomeService.saveData(2, orderPrivateCar.getDriverId(), 3, orderPrivateCar.getId(), 1, c.doubleValue()); + Driver driver = driverService.selectById(orderPrivateCar.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, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0); + pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, ""); + }else{ + incomeService.saveData(1, orderPrivateCar.getCompanyId(), 3, orderPrivateCar.getId(), 1, amount.doubleValue()); } - pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0); + pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, ""); //添加消息 systemNoticeService.addSystemNotice(1, language == 1 ? "您已使用余额成功支付取消订单费用,谢谢使用!" : language == 2 @@ -840,12 +1031,12 @@ if(ToolUtil.isNotEmpty(vehicle)){ integers = JSON.parseArray(vehicle).toJavaList(Integer.class); } - Company query = companyCityService.query1(String.valueOf(orderPrivateCar.getStartLon()), String.valueOf(orderPrivateCar.getStartLat()));//获取起点所属分公司 + Company query = companyCityService.query1(orderPrivateCar.getUserId(), String.valueOf(orderPrivateCar.getStartLon()), String.valueOf(orderPrivateCar.getStartLat()));//获取起点所属分公司 List<PushOrder> querys = pushOrderService.querys(null, 1, query.getId());//获取需要推送的次数 for(int i = 1; i <= querys.size(); i++){ PushOrder pushOrder = pushOrderService.querys(i, 1, query.getId()).get(0); //获取空闲司机 - List<Driver> list = driverService.queryIdleDriver(1, orderPrivateCar.getServerCarModelId(), orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat(), pushOrder.getPushDistance(), null);//所有附近空闲司机 + List<Driver> list = driverService.queryIdleDriver(orderPrivateCar.getUserId(), 1, orderPrivateCar.getServerCarModelId(), orderPrivateCar.getStartLon(), orderPrivateCar.getStartLat(), pushOrder.getPushDistance(), null);//所有附近空闲司机 System.err.println("【" + orderPrivateCar.getId() + "】空闲司机:" + JSON.toJSONString(list)); if(list.size() > 0){ double driverProportion = pushOrder.getDriverProportion() / 100;//推送占比计算成小数 @@ -862,7 +1053,59 @@ if(bo){ continue; } - pushUtil.pushOrderState(2, driver.getId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), pushOrder.getPushTime()); + + Driver driver1 = driverService.selectById(driver.getId()); + DriverWork driverWork = driverWorkService.selectOne(new EntityWrapper<DriverWork>().eq("driverId", driver1.getId()) + .eq("state", 1).like("type", "1")); + if(driver1.getState() != 2 || null == driverWork){ + continue; + } + + String text = ""; + Integer language = driver.getLanguage(); + switch (language){ + case 1: + text = "收到新的打车订单,从" + orderPrivateCar.getStartAddress() + "出发,全程约" + orderPrivateCar.getEstimatedMileage() + "公里"; + break; + case 2: + text = "Received a new ride order, starting from " + orderPrivateCar.getStartAddress() + ", the whole journey is about " + orderPrivateCar.getEstimatedMileage() + "kilometre"; + break; + case 3: + text = "J'ai reçu une nouvelle commande de course, à partir de " + orderPrivateCar.getStartAddress() + ", le trajet complet est d’environ " + orderPrivateCar.getEstimatedMileage() + "kilométrage"; + break; + + } + String audioUrl = ""; + String fileName = "pushOrder" + orderPrivateCar.getDriverId() + UUIDUtil.getRandomCode(5) + ".mp3"; + try { + audioUrl = TextToSpeechUtil.create(language == 1 ? "cmn-CN" : language == 2 ? "en-US" : "fr-FR", text, fileName); + } catch (Exception e) { + throw new RuntimeException(e); + } + //定时任务删除语音文件 + new Timer().schedule(new TimerTask() { + @Override + public void run() { + try { + // 使用Runtime执行命令 + Process process = Runtime.getRuntime().exec("sudo rm -rf /home/igotechgh/nginx/html/files/audio/" + fileName); + // 读取命令的输出 + BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream())); + String line; + while ((line = reader.readLine()) != null) { + System.out.println(line); + } + // 等待命令执行完成 + process.waitFor(); + // 关闭流 + reader.close(); + } catch (IOException | InterruptedException e) { + e.printStackTrace(); + } + } + }, 30000); + + pushUtil.pushOrderState(2, driver.getId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), pushOrder.getPushTime(), audioUrl); } } Thread.sleep(pushOrder.getPushTime() * 1000);//设置等待时间 @@ -969,7 +1212,7 @@ return ResultUtil.error(language == 1 ? "订单不在待支付状态,不允许支付" : language == 2 ? "The order is no longer with Pending Payment, making payments is not allowed." : "La commande n’est plus en attente de paiement, il n’est pas permis d’effectuer des paiements.", ""); } Integer uid = orderPrivateCar.getUserId(); - Double orderMoney = orderPrivateCar.getOrderMoney(); + BigDecimal orderMoney = new BigDecimal(orderPrivateCar.getOrderMoney()); UserInfo userInfo = userInfoService.selectById(uid); ResultUtil resultUtil = ResultUtil.success(""); orderPrivateCar.setCouponMoney(0D);//初始化历史数据 @@ -981,12 +1224,14 @@ Integer orderNum=this.selectCount(new EntityWrapper<OrderPrivateCar>().eq("userId",orderPrivateCar.getUserId()).eq("activityId",query2.getId()).last(" and to_days(getoffTime) = to_days(now())")); if(query2.getDistance()*1000>orderPrivateCar.getMileage() && query2.getOrderNum()>orderNum){ Double special = query2.getSpecial(); - orderPrivateCar.setDiscount(special); - double v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue(); - if(orderMoney.compareTo(v) > 0){ - orderPrivateCar.setDiscountMoney(orderMoney - v); - orderPrivateCar.setActivityId(query2.getId()); - orderMoney = v; + if(null != special){ + orderPrivateCar.setDiscount(special); + BigDecimal v = orderMoney.multiply(new BigDecimal(special / 10)).setScale(2, RoundingMode.HALF_EVEN); + if(orderMoney.compareTo(v) > 0){ + orderPrivateCar.setDiscountMoney(orderMoney.subtract(v).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); + orderPrivateCar.setActivityId(query2.getId()); + orderMoney = v; + } } } } @@ -994,9 +1239,8 @@ //计算优惠券 UserCouponRecord userCouponRecord = null; 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().equals(orderPrivateCar.getCompanyId())){ @@ -1011,66 +1255,73 @@ if(userCouponRecord.getCouponUseType() != 0 && userCouponRecord.getCouponUseType() != 1){ 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); orderPrivateCar.setCouponMoney(userCouponRecord.getMoney()); orderPrivateCar.setCouponId(couponId); } - orderMoney=new BigDecimal(orderMoney).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue(); //计算红包 - if(null != redDeduction && 1 == redDeduction){ + if(null != redDeduction && 1 == redDeduction && null == orderPrivateCar.getRedPacketId()){ RedEnvelopePaymentSettings redEnvelopePaymentSettings = redEnvelopePaymentSettingsService.getRedEnvelopePaymentSettings(); if(null != redEnvelopePaymentSettings){ Double total = userRedPacketRecordService.queryRemainingAmount(uid); List<UserRedPacketRecord> userRedPacketRecords = userRedPacketRecordService.selectList(new EntityWrapper<UserRedPacketRecord>().eq("userId", uid) .eq("state", 1).eq("companyId", orderPrivateCar.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))); - orderPrivateCar.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){ + orderPrivateCar.setRedPacketMoney(multiply1.doubleValue()); + orderMoney = orderMoney.subtract(multiply1).setScale(2, RoundingMode.HALF_EVEN); //获取红包id JSONArray jsonArray = new JSONArray(); for (UserRedPacketRecord userRedPacketRecord : userRedPacketRecords) { + if(multiply1.compareTo(BigDecimal.ZERO) == 0){ + break; + } 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(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); + }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; + multiply1 = BigDecimal.ZERO; } } + if(userRedPacketRecords.size() > 0){ + userRedPacketRecordService.updateBatchById(userRedPacketRecords); + } orderPrivateCar.setRedPacketId(jsonArray.toJSONString()); - }else{ + } + if(total > 0 && total.compareTo(multiply1.doubleValue()) < 0){ orderPrivateCar.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); for (UserRedPacketRecord userRedPacketRecord : userRedPacketRecords) { JSONObject jsonObject = new JSONObject(); jsonObject.put("id", userRedPacketRecord.getId()); - BigDecimal remainingAmount = new BigDecimal(userRedPacketRecord.getRemainingAmount()); - if(multiply.compareTo(remainingAmount) >= 0){ - multiply = multiply.subtract(remainingAmount); - jsonObject.put("money", remainingAmount); - jsonArray.add(jsonObject); - }else{ - userRedPacketRecord.setRemainingAmount(remainingAmount.subtract(multiply).doubleValue()); - jsonObject.put("money", multiply); - jsonArray.add(jsonObject); - break; - } + jsonObject.put("money", userRedPacketRecord.getRemainingAmount()); + jsonArray.add(jsonObject); + + userRedPacketRecord.setRemainingAmount(0D); + userRedPacketRecord.setEndTime(new Date()); + userRedPacketRecord.setState(2); + } + if(userRedPacketRecords.size() > 0){ + userRedPacketRecordService.updateBatchById(userRedPacketRecords); } orderPrivateCar.setRedPacketId(jsonArray.toJSONString()); } @@ -1087,17 +1338,18 @@ 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"); checkoutRequest.setPendingRedirectUrl(""); - checkoutRequest.setSuccessRedirectUrl("http://182.160.16.251:81/payMoney/pages/success.html"); - checkoutRequest.setFailRedirectUrl("http://182.160.16.251:81/payMoney/pages/fail.html"); + checkoutRequest.setSuccessRedirectUrl("https://igo.i-go.group/payMoney/pages/success.html"); + checkoutRequest.setFailRedirectUrl("https://igo.i-go.group/payMoney/pages/fail.html"); resultUtil = TinggPayUtil.checkoutRequest(checkoutRequest); if(resultUtil.getCode()==200){ - paymentRecordService.saveData(1, null, null, orderId, 1, 1, orderMoney, null, 1);//添加预支付数据 + paymentRecordService.saveData(1, null, null, orderId, 1, 1, + orderMoney.setScale(2, RoundingMode.HALF_EVEN).doubleValue(), null, 1);//添加预支付数据 }else{ resultUtil = ResultUtil.error(language == 1 ? "支付失败" : language == 2 ? "Payment failure" : "Paiement échoué", ""); } @@ -1113,60 +1365,46 @@ 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"); checkoutRequest.setPendingRedirectUrl(""); - checkoutRequest.setSuccessRedirectUrl("http://182.160.16.251:81/payMoney/pages/success.html"); - checkoutRequest.setFailRedirectUrl("http://182.160.16.251:81/payMoney/pages/fail.html"); + checkoutRequest.setSuccessRedirectUrl("https://igo.i-go.group/payMoney/pages/success.html"); + checkoutRequest.setFailRedirectUrl("https://igo.i-go.group/payMoney/pages/fail.html"); resultUtil = TinggPayUtil.checkoutRequest(checkoutRequest); if(resultUtil.getCode()==200){ - paymentRecordService.saveData(1, null, null, orderId, 1, 2, orderMoney, null, 1);//添加预支付数据 + paymentRecordService.saveData(1, null, null, orderId, 1, 2, + orderMoney.setScale(2, RoundingMode.HALF_EVEN).doubleValue(), null, 1);//添加预支付数据 }else{ resultUtil = ResultUtil.error(language == 1 ? "支付失败" : language == 2 ? "Payment failure" : "Paiement échoué", ""); } } 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(orderPrivateCar.getCompanyId()); userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分 //添加交易明细 - transactionDetailsService.saveData(uid, "完成订单", orderMoney, 2, 1, 1, 1, orderId); + transactionDetailsService.saveData(uid, "完成订单", orderMoney.setScale(2, RoundingMode.HALF_EVEN).doubleValue(), + 2, 1, 1, 1, orderId); userInfoService.updateById(userInfo); orderPrivateCar.setState(8); orderPrivateCar.setPayType(3); - orderPrivateCar.setPayMoney(orderMoney); - orderPrivateCar.setOrderMoney(orderPrivateCar.getOrderMoney()+orderPrivateCar.getFreeMoney().doubleValue()); + orderPrivateCar.setPayMoney(orderMoney.setScale(2, RoundingMode.HALF_EVEN).doubleValue()); //处理优惠券和红包 if(null != userCouponRecord){ userCouponRecord.setState(2); userCouponRecord.setEndTime(new Date()); userCouponRecordService.updateById(userCouponRecord); - } - if(null != orderPrivateCar.getRedPacketId()){ - JSONArray jsonArray = JSON.parseArray(orderPrivateCar.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); - } } if(orderPrivateCar.getIsplatPay()==1){ @@ -1209,15 +1447,50 @@ if(null != orderPrivateCar.getDriverId()){ aDouble = orderEvaluateService.queryDriverScore(orderPrivateCar.getDriverId()); } - Double aDouble1 = Double.valueOf(orderPrivateCar.getMileage() / 1000); + Double aDouble1 = new BigDecimal(orderPrivateCar.getMileage()).divide(new BigDecimal(1000)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); if(1 == language){ document.getElementById("english").remove(); document.getElementById("french").remove(); - document.getElementsByTag("title").get(0).text("I-GO电子收据"); + document.getElementsByTag("title").get(0).text("打车收据"); Element title_chinese = document.getElementById("title_chinese"); title_chinese.text(DateUtil.conversionFormat(language, sdf.format(orderPrivateCar.getTravelTime())) + ",您在I-GO此订单消费GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); - Element xcf_chinese = document.getElementById("xcf_chinese"); - xcf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_chinese = document.getElementById("qbj_chinese"); + qbj_chinese.text("GHS " + new BigDecimal(orderPrivateCar.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_chinese = document.getElementById("scf_chinese"); + if(null != orderPrivateCar.getDurationMoney() && orderPrivateCar.getDurationMoney() > 0){ + scf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getMileageMoney() && orderPrivateCar.getMileageMoney() > 0){ + lcf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getWaitMoney() && orderPrivateCar.getWaitMoney() > 0){ + ddf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getRoadTollMoney() && orderPrivateCar.getRoadTollMoney() > 0){ + glf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getParkMoney() && orderPrivateCar.getParkMoney() > 0){ + tcf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_chinese_div = document.getElementById("tcf_chinese_div"); + tcf_chinese_div.remove(); + } if(null != orderPrivateCar.getCouponMoney() && orderPrivateCar.getCouponMoney() > 0){ Element yhq_chinese = document.getElementById("yhq_chinese"); yhq_chinese.text("GHS -" + new BigDecimal(orderPrivateCar.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -1245,12 +1518,18 @@ pay_type_chinese.text("余额支付"); Element pay_money_chinese = document.getElementById("pay_money_chinese"); pay_money_chinese.text("GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); + Element dispute_chinese = document.getElementById("dispute_chinese"); + if(null != orderPrivateCar.getIsDispute() && orderPrivateCar.getIsDispute() == 1){ + dispute_chinese.text("(注意: 争议订单,经过三方协商,平台最终定价为 GHS" + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN) + ")"); + }else{ + dispute_chinese.remove(); + } Element pdf_chinese = document.getElementById("pdf_chinese"); - pdf_chinese.attr("href", "http://182.160.16.251:80/user/base/order/uploadReceiptPdf?orderId=" + orderId + "&orderType=1"); + pdf_chinese.attr("href", "https://igo.i-go.group/user/base/order/uploadReceiptPdf?orderId=" + orderId + "&orderType=1"); 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=1"); + lost_item_chinese.attr("href", "https://igo.i-go.group/mailbox/user/lossGoods.html?language=" + language + "&orderId=" + orderId + "&orderType=1"); Element track_chinese = document.getElementById("track_chinese"); - track_chinese.attr("href", "http://182.160.16.251:81/mailbox/user/location.html?orderId=" + orderId); + track_chinese.attr("href", "https://igo.i-go.group/mailbox/user/location.html?orderId=" + orderId); Element pay_time_chinese = document.getElementById("pay_time_chinese"); pay_time_chinese.text(DateUtil.conversionFormat(language, sdf1.format(orderPrivateCar.getEndServiceTime()))); Elements driver_chinese = document.getElementsByClass("driver_chinese"); @@ -1279,11 +1558,46 @@ if(2 == language){ document.getElementById("chinese").remove(); document.getElementById("french").remove(); - document.getElementsByTag("title").get(0).text("Receipt"); + document.getElementsByTag("title").get(0).text("Ride receipt"); Element title_english = document.getElementById("title_english"); title_english.text(DateUtil.conversionFormat(language, sdf.format(orderPrivateCar.getTravelTime())) + ",You spent GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue() + " on the trip "); - Element xcf_english = document.getElementById("xcf_english"); - xcf_english.text("GHS " + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_english = document.getElementById("qbj_english"); + qbj_english.text("GHS " + new BigDecimal(orderPrivateCar.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_english = document.getElementById("scf_english"); + if(null != orderPrivateCar.getDurationMoney() && orderPrivateCar.getDurationMoney() > 0){ + scf_english.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getMileageMoney() && orderPrivateCar.getMileageMoney() > 0){ + lcf_english.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getWaitMoney() && orderPrivateCar.getWaitMoney() > 0){ + ddf_english.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getRoadTollMoney() && orderPrivateCar.getRoadTollMoney() > 0){ + glf_english.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getParkMoney() && orderPrivateCar.getParkMoney() > 0){ + tcf_english.text("GHS " + new BigDecimal(orderPrivateCar.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_english_div = document.getElementById("tcf_english_div"); + tcf_english_div.remove(); + } if(null != orderPrivateCar.getCouponMoney() && orderPrivateCar.getCouponMoney() > 0){ Element yhq_english = document.getElementById("yhq_english"); yhq_english.text("GHS -" + new BigDecimal(orderPrivateCar.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -1311,12 +1625,18 @@ pay_type_english.text("I-GO Wallet"); Element pay_money_english = document.getElementById("pay_money_english"); pay_money_english.text("GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); + Element dispute_english = document.getElementById("dispute_english"); + if(null != orderPrivateCar.getIsDispute() && orderPrivateCar.getIsDispute() == 1){ + dispute_english.text("(Note: Disputed order, after tripartite negotiation, the final pricing of the platform is GHS " + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN) + ")"); + }else{ + dispute_english.remove(); + } Element pdf_english = document.getElementById("pdf_english"); - pdf_english.attr("href", "http://182.160.16.251:80/user/base/order/uploadReceiptPdf?orderId=" + orderId + "&orderType=1"); + pdf_english.attr("href", "https://igo.i-go.group/user/base/order/uploadReceiptPdf?orderId=" + orderId + "&orderType=1"); 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=1"); + lost_item_english.attr("href", "https://igo.i-go.group/mailbox/user/lossGoods.html?language=" + language + "&orderId=" + orderId + "&orderType=1"); Element track_english = document.getElementById("track_english"); - track_english.attr("href", "http://182.160.16.251:81/mailbox/user/location.html?orderId=" + orderId); + track_english.attr("href", "https://igo.i-go.group/mailbox/user/location.html?orderId=" + orderId); Element pay_time_english = document.getElementById("pay_time_english"); pay_time_english.text(DateUtil.conversionFormat(language, sdf1.format(orderPrivateCar.getEndServiceTime()))); Elements driver_english = document.getElementsByClass("driver_english"); @@ -1345,11 +1665,46 @@ if(3 == language){ document.getElementById("chinese").remove(); document.getElementById("english").remove(); - document.getElementsByTag("title").get(0).text("Reçu"); + document.getElementsByTag("title").get(0).text("Reçu de course"); Element title_french = document.getElementById("title_french"); title_french.text("Le " + DateUtil.conversionFormat(language, sdf.format(orderPrivateCar.getTravelTime())) + ", vous avez dépensé GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue() + " sur le voyage"); - Element xcf_french = document.getElementById("xcf_french"); - xcf_french.text("GHS " + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_french = document.getElementById("qbj_french"); + qbj_french.text("GHS " + new BigDecimal(orderPrivateCar.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_french = document.getElementById("scf_french"); + if(null != orderPrivateCar.getDurationMoney() && orderPrivateCar.getDurationMoney() > 0){ + scf_french.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getMileageMoney() && orderPrivateCar.getMileageMoney() > 0){ + lcf_french.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getWaitMoney() && orderPrivateCar.getWaitMoney() > 0){ + ddf_french.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getRoadTollMoney() && orderPrivateCar.getRoadTollMoney() > 0){ + glf_french.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getParkMoney() && orderPrivateCar.getParkMoney() > 0){ + tcf_french.text("GHS " + new BigDecimal(orderPrivateCar.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_french_div = document.getElementById("tcf_french_div"); + tcf_french_div.remove(); + } if(null != orderPrivateCar.getCouponMoney() && orderPrivateCar.getCouponMoney() > 0){ Element yhq_french = document.getElementById("yhq_french"); yhq_french.text("GHS -" + new BigDecimal(orderPrivateCar.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -1377,12 +1732,18 @@ pay_type_french.text("Portefeuille I-GO"); Element pay_money_french = document.getElementById("pay_money_french"); pay_money_french.text("GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); + Element dispute_french = document.getElementById("dispute_french"); + if(null != orderPrivateCar.getIsDispute() && orderPrivateCar.getIsDispute() == 1){ + dispute_french.text("(Remarque: Il s’agit d’une commande contestée, et après des négociations entre trois parties, la plateforme l’a finalement tarifée à GHS " + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN) + ")"); + }else{ + dispute_french.remove(); + } Element pdf_french = document.getElementById("pdf_french"); - pdf_french.attr("href", "http://182.160.16.251:80/user/base/order/uploadReceiptPdf?orderId=" + orderId + "&orderType=1"); + pdf_french.attr("href", "https://igo.i-go.group/user/base/order/uploadReceiptPdf?orderId=" + orderId + "&orderType=1"); 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=1"); + lost_item_french.attr("href", "https://igo.i-go.group/mailbox/user/lossGoods.html?language=" + language + "&orderId=" + orderId + "&orderType=1"); Element track_french = document.getElementById("track_french"); - track_french.attr("href", "http://182.160.16.251:81/mailbox/user/location.html?orderId=" + orderId); + track_french.attr("href", "https://igo.i-go.group/mailbox/user/location.html?orderId=" + orderId); Element pay_time_french = document.getElementById("pay_time_french"); pay_time_french.text(DateUtil.conversionFormat(language, sdf1.format(orderPrivateCar.getEndServiceTime()))); Elements driver_french = document.getElementsByClass("driver_french"); @@ -1408,14 +1769,14 @@ Element server_tel_french = document.getElementById("server_tel_french"); server_tel_french.attr("href", "tel:" + (null != phone ? phone.getPhone() : "")); } - EmailUtil.send(userInfo.getEmail(), language == 1 ? "I-GO电子收据" : language == 2 ? "Receipt" : "Reçu", document.html()); + EmailUtil.send(userInfo.getEmail(), language == 1 ? "打车收据" : language == 2 ? "Ride receipt" : "Reçu de course", document.html()); //开始生成pdf收据和html收据 - File file = new File("/usr/local/nginx/html/files/html/"); + File file = new File("/home/igotechgh/nginx/html/files/html/"); if(!file.exists()){ file.mkdirs(); } - file = new File("/usr/local/nginx/html/files/html/ride_receipt_" + orderId + ".html"); + file = new File("/home/igotechgh/nginx/html/files/html/ride_receipt_" + orderId + ".html"); if(!file.exists()){ file.createNewFile(); } @@ -1424,27 +1785,27 @@ fileWriter.flush(); fileWriter.close(); - File file1 = new File("/usr/local/nginx/html/files/pdf/"); + File file1 = new File("/home/igotechgh/nginx/html/files/pdf/"); if(!file1.exists()){ file1.mkdirs(); } - file1 = new File("/usr/local/nginx/html/files/pdf/ride_receipt_" + orderId + ".pdf"); + file1 = new File("/home/igotechgh/nginx/html/files/pdf/ride_receipt_" + orderId + ".pdf"); if(!file1.exists()){ file1.createNewFile(); } try { FileOutputStream fileOutputStream = new FileOutputStream(file1); - HtmlToPdfUtils.convertToPdf("/usr/local/nginx/html/files/html/ride_receipt_" + orderId + ".html", "I-GO", fileOutputStream); + HtmlToPdfUtils.convertToPdf("/home/igotechgh/nginx/html/files/html/ride_receipt_" + orderId + ".html", "I-GO", fileOutputStream); }catch (Exception e){ e.printStackTrace(); System.out.println("html转pdf异常"); } - String link ="http://182.160.16.251:81/files/html/ride_receipt_" + orderId + ".html"; + String link ="https://igo.i-go.group/files/html/ride_receipt_" + orderId + ".html"; TEmail tEmail = new TEmail(); tEmail.setLink(link); tEmail.setUserId(uid); - tEmail.setName(language == 1 ? "I-GO电子收据" : language == 2 ? "Receipt" : "Reçu"); + tEmail.setName(language == 1 ? "打车收据" : language == 2 ? "Ride receipt" : "Reçu de course"); tEmail.setType(1); tEmail.setOrderId(orderId); tEmail.setCreateTime(new Date()); @@ -1473,8 +1834,8 @@ new Thread(new Runnable() { @Override public void run() { - pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0); - pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0); + pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, ""); + pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, ""); } }).start(); @@ -1489,14 +1850,14 @@ userInfo.setIntegral(userInfo.getIntegral() + (orderMoney.intValue() * query1.getIntegral()));//积分 //添加交易明细 - transactionDetailsService.saveData(uid, "完成订单", orderMoney, 2, 1, 1, 1, orderId); + transactionDetailsService.saveData(uid, "完成订单", orderMoney.setScale(2, RoundingMode.HALF_EVEN).doubleValue(), + 2, 1, 1, 1, orderId); userInfoService.updateById(userInfo); orderPrivateCar.setState(8); orderPrivateCar.setPayType(4); orderPrivateCar.setDriverPay(2); - orderPrivateCar.setPayMoney(orderMoney); - orderPrivateCar.setOrderMoney(orderPrivateCar.getOrderMoney()+orderPrivateCar.getFreeMoney().doubleValue()); + orderPrivateCar.setPayMoney(orderMoney.setScale(2, RoundingMode.HALF_EVEN).doubleValue()); Driver driver = driverService.selectById(orderPrivateCar.getDriverId()); @@ -1513,20 +1874,8 @@ driver.setBalance(new BigDecimal(null != driver.getBalance() ? driver.getBalance() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); driverService.updateById(driver); } + if(null != orderPrivateCar.getRedPacketId()){ - JSONArray jsonArray = JSON.parseArray(orderPrivateCar.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 = orderPrivateCar.getRedPacketMoney(); incomeService.saveData(2, orderPrivateCar.getDriverId(), 7, orderPrivateCar.getId(), 1, money); driver.setBusinessMoney(new BigDecimal(null != driver.getBusinessMoney() ? driver.getBusinessMoney() : 0).add(new BigDecimal(money)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); @@ -1585,13 +1934,14 @@ JSONObject jsonObject = JSON.parseObject(settlementAllocation.getContent()); Double maxPrice = jsonObject.getDouble("maxPrice"); Integer type1 = jsonObject.getInteger("type"); - if(1 == type1){ + if(null != maxPrice){ List<SettlementDetail> settlementDetailList = settlementDetailService.selectList(new EntityWrapper<SettlementDetail>().eq("driverId", driver.getId()) .isNull("settlementRecordId").last(" and DATE_FORMAT(now(), '%Y-%m-%d') = DATE_FORMAT(createTime, '%Y-%m-%d')")); BigDecimal total = new BigDecimal(0); for (SettlementDetail detail : settlementDetailList) { total = total.add(new BigDecimal(detail.getPrice())); } + //日结算 if(maxPrice.compareTo(total.doubleValue()) <= 0){ SettlementRecord settlementRecord = settlementRecordService.selectOne(new EntityWrapper<SettlementRecord>().eq("driverId", orderPrivateCar.getDriverId()) .eq("type", type1).eq("paymentStatus", 1).last(" and day = DATE_FORMAT(now(), '%Y-%m-%d')")); @@ -1605,12 +1955,43 @@ 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) { detail.setSettlementRecordId(settlementRecord.getId()); settlementDetailService.updateById(detail); + } + //强制司机下班 + DriverWork driverWork = driverWorkService.selectOne(new EntityWrapper<DriverWork>() + .eq("driverId", orderPrivateCar.getDriverId()).eq("state", 1)); + if(null != driverWork){ + driverWork.setEndTime(new Date()); + driverWork.setState(2); + driverWorkService.updateById(driverWork); + driver.setState(1); + driverService.updateById(driver); + Car car = carService.selectById(driver.getCarId()); + if(!org.apache.shiro.util.StringUtils.hasLength(car.getVehicleId())){ + car.setVehicleId(UUIDUtil.getRandomCode()); + carService.updateById(car); + } + + //司机下班,修改谷歌上的车辆信息 + new Thread(()->{ + try { + CarModel carModel = carModelMapper.selectById(car.getCarModelId()); + String vehicles = fleetEngineUtil.getVehicles(car.getVehicleId()); + if(ToolUtil.isEmpty(vehicles)){ + fleetEngineUtil.createVehicles(carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + fleetEngineUtil.updateVehicles("OFFLINE", carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + }else{ + fleetEngineUtil.updateVehicles("OFFLINE", carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); + } + }catch (Exception e){ + e.printStackTrace(); + } + }).start(); } } } @@ -1633,16 +2014,51 @@ if(null != orderPrivateCar.getDriverId()){ aDouble = orderEvaluateService.queryDriverScore(orderPrivateCar.getDriverId()); } - Double aDouble1 = Double.valueOf(orderPrivateCar.getMileage() / 1000); + Double aDouble1 = new BigDecimal(orderPrivateCar.getMileage()).divide(new BigDecimal(1000)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); Driver driver = driverService.selectById(orderPrivateCar.getDriverId()); if(1 == language){ document.getElementById("english").remove(); document.getElementById("french").remove(); - document.getElementsByTag("title").get(0).text("I-GO电子收据"); + document.getElementsByTag("title").get(0).text("打车收据"); Element title_chinese = document.getElementById("title_chinese"); title_chinese.text(DateUtil.conversionFormat(language, sdf.format(orderPrivateCar.getTravelTime())) + ",您在I-GO此订单消费GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); - Element xcf_chinese = document.getElementById("xcf_chinese"); - xcf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_chinese = document.getElementById("qbj_chinese"); + qbj_chinese.text("GHS " + new BigDecimal(orderPrivateCar.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_chinese = document.getElementById("scf_chinese"); + if(null != orderPrivateCar.getDurationMoney() && orderPrivateCar.getDurationMoney() > 0){ + scf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getMileageMoney() && orderPrivateCar.getMileageMoney() > 0){ + lcf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getWaitMoney() && orderPrivateCar.getWaitMoney() > 0){ + ddf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getRoadTollMoney() && orderPrivateCar.getRoadTollMoney() > 0){ + glf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getParkMoney() && orderPrivateCar.getParkMoney() > 0){ + tcf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_chinese_div = document.getElementById("tcf_chinese_div"); + tcf_chinese_div.remove(); + } if(null != orderPrivateCar.getCouponMoney() && orderPrivateCar.getCouponMoney() > 0){ Element yhq_chinese = document.getElementById("yhq_chinese"); yhq_chinese.text("GHS -" + new BigDecimal(orderPrivateCar.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -1670,12 +2086,18 @@ pay_type_chinese.text("现金"); Element pay_money_chinese = document.getElementById("pay_money_chinese"); pay_money_chinese.text("GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); + Element dispute_chinese = document.getElementById("dispute_chinese"); + if(null != orderPrivateCar.getIsDispute() && orderPrivateCar.getIsDispute() == 1){ + dispute_chinese.text("(注意: 争议订单,经过三方协商,平台最终定价为 GHS" + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN) + ")"); + }else{ + dispute_chinese.remove(); + } Element pdf_chinese = document.getElementById("pdf_chinese"); - pdf_chinese.attr("href", "http://182.160.16.251:80/user/base/order/uploadReceiptPdf?orderId=" + orderId + "&orderType=1"); + pdf_chinese.attr("href", "https://igo.i-go.group/user/base/order/uploadReceiptPdf?orderId=" + orderId + "&orderType=1"); 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=1"); + lost_item_chinese.attr("href", "https://igo.i-go.group/mailbox/user/lossGoods.html?language=" + language + "&orderId=" + orderId + "&orderType=1"); Element track_chinese = document.getElementById("track_chinese"); - track_chinese.attr("href", "http://182.160.16.251:81/mailbox/user/location.html?orderId=" + orderId); + track_chinese.attr("href", "https://igo.i-go.group/mailbox/user/location.html?orderId=" + orderId); Element pay_time_chinese = document.getElementById("pay_time_chinese"); pay_time_chinese.text(DateUtil.conversionFormat(language, sdf1.format(orderPrivateCar.getEndServiceTime()))); Elements driver_chinese = document.getElementsByClass("driver_chinese"); @@ -1704,11 +2126,46 @@ if(2 == language){ document.getElementById("chinese").remove(); document.getElementById("french").remove(); - document.getElementsByTag("title").get(0).text("Receipt"); + document.getElementsByTag("title").get(0).text("Ride receipt"); Element title_english = document.getElementById("title_english"); title_english.text(DateUtil.conversionFormat(language, sdf.format(orderPrivateCar.getTravelTime())) + ",You spent GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue() + " on the trip "); - Element xcf_english = document.getElementById("xcf_english"); - xcf_english.text("GHS " + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_english = document.getElementById("qbj_english"); + qbj_english.text("GHS " + new BigDecimal(orderPrivateCar.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_english = document.getElementById("scf_english"); + if(null != orderPrivateCar.getDurationMoney() && orderPrivateCar.getDurationMoney() > 0){ + scf_english.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getMileageMoney() && orderPrivateCar.getMileageMoney() > 0){ + lcf_english.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getWaitMoney() && orderPrivateCar.getWaitMoney() > 0){ + ddf_english.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getRoadTollMoney() && orderPrivateCar.getRoadTollMoney() > 0){ + glf_english.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getParkMoney() && orderPrivateCar.getParkMoney() > 0){ + tcf_english.text("GHS " + new BigDecimal(orderPrivateCar.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_english_div = document.getElementById("tcf_english_div"); + tcf_english_div.remove(); + } if(null != orderPrivateCar.getCouponMoney() && orderPrivateCar.getCouponMoney() > 0){ Element yhq_english = document.getElementById("yhq_english"); yhq_english.text("GHS -" + new BigDecimal(orderPrivateCar.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -1736,12 +2193,18 @@ pay_type_english.text("Cash"); Element pay_money_english = document.getElementById("pay_money_english"); pay_money_english.text("GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); + Element dispute_english = document.getElementById("dispute_english"); + if(null != orderPrivateCar.getIsDispute() && orderPrivateCar.getIsDispute() == 1){ + dispute_english.text("(Note: Disputed order, after tripartite negotiation, the final pricing of the platform is GHS " + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN) + ")"); + }else{ + dispute_english.remove(); + } Element pdf_english = document.getElementById("pdf_english"); - pdf_english.attr("href", "http://182.160.16.251:80/user/base/order/uploadReceiptPdf?orderId=" + orderId + "&orderType=1"); + pdf_english.attr("href", "https://igo.i-go.group/user/base/order/uploadReceiptPdf?orderId=" + orderId + "&orderType=1"); 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=1"); + lost_item_english.attr("href", "https://igo.i-go.group/mailbox/user/lossGoods.html?language=" + language + "&orderId=" + orderId + "&orderType=1"); Element track_english = document.getElementById("track_english"); - track_english.attr("href", "http://182.160.16.251:81/mailbox/user/location.html?orderId=" + orderId); + track_english.attr("href", "https://igo.i-go.group/mailbox/user/location.html?orderId=" + orderId); Element pay_time_english = document.getElementById("pay_time_english"); pay_time_english.text(DateUtil.conversionFormat(language, sdf1.format(orderPrivateCar.getEndServiceTime()))); Elements driver_english = document.getElementsByClass("driver_english"); @@ -1770,11 +2233,46 @@ if(3 == language){ document.getElementById("chinese").remove(); document.getElementById("english").remove(); - document.getElementsByTag("title").get(0).text("Reçu"); + document.getElementsByTag("title").get(0).text("Reçu de course"); Element title_french = document.getElementById("title_french"); title_french.text("Le " + DateUtil.conversionFormat(language, sdf.format(orderPrivateCar.getTravelTime())) + ", vous avez dépensé GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue() + " sur le voyage"); - Element xcf_french = document.getElementById("xcf_french"); - xcf_french.text("GHS " + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_french = document.getElementById("qbj_french"); + qbj_french.text("GHS " + new BigDecimal(orderPrivateCar.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_french = document.getElementById("scf_french"); + if(null != orderPrivateCar.getDurationMoney() && orderPrivateCar.getDurationMoney() > 0){ + scf_french.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getMileageMoney() && orderPrivateCar.getMileageMoney() > 0){ + lcf_french.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getWaitMoney() && orderPrivateCar.getWaitMoney() > 0){ + ddf_french.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getRoadTollMoney() && orderPrivateCar.getRoadTollMoney() > 0){ + glf_french.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getParkMoney() && orderPrivateCar.getParkMoney() > 0){ + tcf_french.text("GHS " + new BigDecimal(orderPrivateCar.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_french_div = document.getElementById("tcf_french_div"); + tcf_french_div.remove(); + } if(null != orderPrivateCar.getCouponMoney() && orderPrivateCar.getCouponMoney() > 0){ Element yhq_french = document.getElementById("yhq_french"); yhq_french.text("GHS -" + new BigDecimal(orderPrivateCar.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -1802,12 +2300,18 @@ pay_type_french.text("En espèces"); Element pay_money_french = document.getElementById("pay_money_french"); pay_money_french.text("GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); + Element dispute_french = document.getElementById("dispute_french"); + if(null != orderPrivateCar.getIsDispute() && orderPrivateCar.getIsDispute() == 1){ + dispute_french.text("(Remarque: Il s’agit d’une commande contestée, et après des négociations entre trois parties, la plateforme l’a finalement tarifée à GHS " + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN) + ")"); + }else{ + dispute_french.remove(); + } Element pdf_french = document.getElementById("pdf_french"); - pdf_french.attr("href", "http://182.160.16.251:80/user/base/order/uploadReceiptPdf?orderId=" + orderId + "&orderType=1"); + pdf_french.attr("href", "https://igo.i-go.group/user/base/order/uploadReceiptPdf?orderId=" + orderId + "&orderType=1"); 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=1"); + lost_item_french.attr("href", "https://igo.i-go.group/mailbox/user/lossGoods.html?language=" + language + "&orderId=" + orderId + "&orderType=1"); Element track_french = document.getElementById("track_french"); - track_french.attr("href", "http://182.160.16.251:81/mailbox/user/location.html?orderId=" + orderId); + track_french.attr("href", "https://igo.i-go.group/mailbox/user/location.html?orderId=" + orderId); Element pay_time_french = document.getElementById("pay_time_french"); pay_time_french.text(DateUtil.conversionFormat(language, sdf1.format(orderPrivateCar.getEndServiceTime()))); Elements driver_french = document.getElementsByClass("driver_french"); @@ -1834,14 +2338,14 @@ server_tel_french.attr("href", "tel:" + (null != phone ? phone.getPhone() : "")); } - EmailUtil.send(userInfo.getEmail(), language == 1 ? "I-GO电子收据" : language == 2 ? "Receipt" : "Reçu", document.html()); + EmailUtil.send(userInfo.getEmail(), language == 1 ? "打车收据" : language == 2 ? "Ride receipt" : "Reçu de course", document.html()); //开始生成pdf收据和html收据 - File file = new File("/usr/local/nginx/html/files/html/"); + File file = new File("/home/igotechgh/nginx/html/files/html/"); if(!file.exists()){ file.mkdirs(); } - file = new File("/usr/local/nginx/html/files/html/ride_receipt_" + orderId + ".html"); + file = new File("/home/igotechgh/nginx/html/files/html/ride_receipt_" + orderId + ".html"); if(!file.exists()){ file.createNewFile(); } @@ -1850,26 +2354,26 @@ fileWriter.flush(); fileWriter.close(); - File file1 = new File("/usr/local/nginx/html/files/pdf/"); + File file1 = new File("/home/igotechgh/nginx/html/files/pdf/"); if(!file1.exists()){ file1.mkdirs(); } - file1 = new File("/usr/local/nginx/html/files/pdf/ride_receipt_" + orderId + ".pdf"); + file1 = new File("/home/igotechgh/nginx/html/files/pdf/ride_receipt_" + orderId + ".pdf"); if(!file1.exists()){ file1.createNewFile(); } try { FileOutputStream fileOutputStream = new FileOutputStream(file1); - HtmlToPdfUtils.convertToPdf("/usr/local/nginx/html/files/html/ride_receipt_" + orderId + ".html", "I-GO", fileOutputStream); + HtmlToPdfUtils.convertToPdf("/home/igotechgh/nginx/html/files/html/ride_receipt_" + orderId + ".html", "I-GO", fileOutputStream); }catch (Exception e){ e.printStackTrace(); System.out.println("html转pdf异常"); } - String link ="http://182.160.16.251:81/files/html/ride_receipt_" + orderId + ".html"; + String link ="https://igo.i-go.group/files/html/ride_receipt_" + orderId + ".html"; TEmail tEmail = new TEmail(); tEmail.setLink(link); tEmail.setUserId(uid); - tEmail.setName(language == 1 ? "I-GO电子收据" : language == 2 ? "Receipt" : "Reçu"); + tEmail.setName(language == 1 ? "打车收据" : language == 2 ? "Ride receipt" : "Reçu de course"); tEmail.setType(1); tEmail.setOrderId(orderId); tEmail.setCreateTime(new Date()); @@ -1897,9 +2401,52 @@ new Thread(new Runnable() { @Override public void run() { - pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0); - pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0); - pushUtil.pushOfflinePayment(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1); + pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, ""); + pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, ""); + Integer language1 = driver.getLanguage(); + String text = ""; + switch (language1){ + case 1: + text = "客户已选择支付现金,因此您必须收款。确定您已收到此订单费用:现金GHS " + orderPrivateCar.getPayMoney(); + break; + case 2: + text = "The client chose to pay in cash, so you must collect the payment.Confirm if you received the charge for this order: Cash GHS " + orderPrivateCar.getPayMoney(); + break; + case 3: + text = "Le client a choisi de payer en espèces, vous devez donc encaisser le paiement.Confirmez si vous avez reçu les frais pour cette commande : Espèces GHS " + orderPrivateCar.getPayMoney(); + break; + + } + String audioUrl = ""; + String fileName = "offlinePayment" + orderPrivateCar.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() { + try { + // 使用Runtime执行命令 + Process process = Runtime.getRuntime().exec("sudo rm -rf /home/igotechgh/nginx/html/files/audio/" + fileName); + // 读取命令的输出 + BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream())); + String line; + while ((line = reader.readLine()) != null) { + System.out.println(line); + } + // 等待命令执行完成 + process.waitFor(); + // 关闭流 + reader.close(); + } catch (IOException | InterruptedException e) { + e.printStackTrace(); + } + } + }, 30000); + pushUtil.pushOfflinePayment(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getPayMoney(), audioUrl); } }).start(); @@ -1944,9 +2491,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.setInsertTime(new Date()); userRedPacketRecord.setCompanyId(Integer.valueOf(String.valueOf(query.get("companyId")))); userRedPacketRecord.setState(0); @@ -1985,8 +2529,7 @@ query.setRedPacketActivityId(id.getId()); userRedPacketRecordService.updateById(query); - // todo 待翻译 - String content = 1 == language ? ("您收到一个额度为GHS " + money + " 的红包,请查收") : 2 == language ? "" : ""; + String content = 1 == language ? ("您收到一个额度为GHS " + money + " 的红包,请查收") : 2 == language ? "You have received a lucky promo of GHS " + money + ", please check" : "Vous avez reçu un bonus de GHS " + money + ", veuillez vérifier"; systemNoticeService.addSystemNotice(1, content, query.getUserId(), 1); UserInfo userInfo = userInfoService.selectById(orderPrivateCar.getUserId()); @@ -2019,16 +2562,16 @@ 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(id.getStartTime())) + " au " + DateUtil.conversionFormat(language, sdf.format(id.getEndTime())) + ". 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()); //开始生成pdf收据和html收据 - File file = new File("/usr/local/nginx/html/files/html/"); + File file = new File("/home/igotechgh/nginx/html/files/html/"); if(!file.exists()){ file.mkdirs(); } - file = new File("/usr/local/nginx/html/files/html/redpacket_" + orderId + ".html"); + file = new File("/home/igotechgh/nginx/html/files/html/redpacket_" + orderId + ".html"); if(!file.exists()){ file.createNewFile(); } @@ -2037,7 +2580,7 @@ fileWriter.flush(); fileWriter.close(); - String link ="http://182.160.16.251:81/files/html/redpacket_" + orderId + ".html"; + String link ="https://igo.i-go.group/files/html/redpacket_" + orderId + ".html"; TEmail tEmail = new TEmail(); tEmail.setLink(link); tEmail.setUserId(userInfo.getId()); @@ -2097,20 +2640,38 @@ query1.setState(2); orderCancelService.updateById(query1); } - + + Double amount = query.getAmount(); if(null != orderPrivateCar.getDriverId()){ - BigDecimal c =new BigDecimal(query.getAmount());//司机收入 - incomeService.saveData(2, orderPrivateCar.getDriverId(), 3, orderPrivateCar.getId(), 1, c.doubleValue()); - Driver driver = driverService.selectById(orderPrivateCar.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(orderPrivateCar.getCompanyId()); + Double speMoney = company.getSpeMoney(); + 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, orderPrivateCar.getCompanyId(), 3, orderPrivateCar.getId(), 1, d.doubleValue()); + if(c.doubleValue() > 0){ + incomeService.saveData(2, orderPrivateCar.getDriverId(), 3, orderPrivateCar.getId(), 1, c.doubleValue()); + Driver driver = driverService.selectById(orderPrivateCar.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(orderPrivateCar.getId());//删除定时任务 - pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0); + pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, ""); + }else{ + incomeService.saveData(1, orderPrivateCar.getCompanyId(), 3, orderPrivateCar.getId(), 1, amount.doubleValue()); } - pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0); + pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, ""); //添加消息 systemNoticeService.addSystemNotice(1, language == 1 ? "您已使用余额成功支付取消订单费用,谢谢使用!" : language == 2 @@ -2146,22 +2707,6 @@ userCouponRecord.setEndTime(new Date()); userCouponRecordService.updateById(userCouponRecord); } - if(null != orderPrivateCar.getRedPacketId()){ - JSONArray jsonArray = JSON.parseArray(orderPrivateCar.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); @@ -2207,15 +2752,50 @@ if(null != orderPrivateCar.getDriverId()){ aDouble = orderEvaluateService.queryDriverScore(orderPrivateCar.getDriverId()); } - Double aDouble1 = Double.valueOf(orderPrivateCar.getMileage() / 1000); + Double aDouble1 = new BigDecimal(orderPrivateCar.getMileage()).divide(new BigDecimal(1000)).setScale(2, RoundingMode.HALF_EVEN).doubleValue(); if(1 == language){ document.getElementById("english").remove(); document.getElementById("french").remove(); - document.getElementsByTag("title").get(0).text("I-GO电子收据"); + document.getElementsByTag("title").get(0).text("打车收据"); Element title_chinese = document.getElementById("title_chinese"); title_chinese.text(DateUtil.conversionFormat(language, sdf.format(orderPrivateCar.getTravelTime())) + ",您在I-GO此订单消费GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); - Element xcf_chinese = document.getElementById("xcf_chinese"); - xcf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_chinese = document.getElementById("qbj_chinese"); + qbj_chinese.text("GHS " + new BigDecimal(orderPrivateCar.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_chinese = document.getElementById("scf_chinese"); + if(null != orderPrivateCar.getDurationMoney() && orderPrivateCar.getDurationMoney() > 0){ + scf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getMileageMoney() && orderPrivateCar.getMileageMoney() > 0){ + lcf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getWaitMoney() && orderPrivateCar.getWaitMoney() > 0){ + ddf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getRoadTollMoney() && orderPrivateCar.getRoadTollMoney() > 0){ + glf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getParkMoney() && orderPrivateCar.getParkMoney() > 0){ + tcf_chinese.text("GHS " + new BigDecimal(orderPrivateCar.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_chinese_div = document.getElementById("tcf_chinese_div"); + tcf_chinese_div.remove(); + } if(null != orderPrivateCar.getCouponMoney() && orderPrivateCar.getCouponMoney() > 0){ Element yhq_chinese = document.getElementById("yhq_chinese"); yhq_chinese.text("GHS -" + new BigDecimal(orderPrivateCar.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -2243,12 +2823,18 @@ pay_type_chinese.text(orderPrivateCar.getPayType() == 1 ? "手机支付" : (orderPrivateCar.getPayType() == 2?"银行卡支付":(orderPrivateCar.getPayType() == 3?"余额支付":"现金支付"))); Element pay_money_chinese = document.getElementById("pay_money_chinese"); pay_money_chinese.text("GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); + Element dispute_chinese = document.getElementById("dispute_chinese"); + if(null != orderPrivateCar.getIsDispute() && orderPrivateCar.getIsDispute() == 1){ + dispute_chinese.text("(注意: 争议订单,经过三方协商,平台最终定价为 GHS" + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN) + ")"); + }else{ + dispute_chinese.remove(); + } Element pdf_chinese = document.getElementById("pdf_chinese"); - pdf_chinese.attr("href", "http://182.160.16.251:80/user/base/order/uploadReceiptPdf?orderId=" + id + "&orderType=1"); + pdf_chinese.attr("href", "https://igo.i-go.group/user/base/order/uploadReceiptPdf?orderId=" + id + "&orderType=1"); 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=" + id + "&orderType=1"); + lost_item_chinese.attr("href", "https://igo.i-go.group/mailbox/user/lossGoods.html?language=" + language + "&orderId=" + id + "&orderType=1"); Element track_chinese = document.getElementById("track_chinese"); - track_chinese.attr("href", "http://182.160.16.251:81/mailbox/user/location.html?orderId=" + id); + track_chinese.attr("href", "https://igo.i-go.group/mailbox/user/location.html?orderId=" + id); Element pay_time_chinese = document.getElementById("pay_time_chinese"); pay_time_chinese.text(DateUtil.conversionFormat(language, sdf1.format(orderPrivateCar.getEndServiceTime()))); Elements driver_chinese = document.getElementsByClass("driver_chinese"); @@ -2277,11 +2863,46 @@ if(2 == language){ document.getElementById("chinese").remove(); document.getElementById("french").remove(); - document.getElementsByTag("title").get(0).text("Receipt"); + document.getElementsByTag("title").get(0).text("Ride receipt"); Element title_english = document.getElementById("title_english"); title_english.text(DateUtil.conversionFormat(language, sdf.format(orderPrivateCar.getTravelTime())) + ",You spent GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue() + " on the trip "); - Element xcf_english = document.getElementById("xcf_english"); - xcf_english.text("GHS " + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_english = document.getElementById("qbj_english"); + qbj_english.text("GHS " + new BigDecimal(orderPrivateCar.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_english = document.getElementById("scf_english"); + if(null != orderPrivateCar.getDurationMoney() && orderPrivateCar.getDurationMoney() > 0){ + scf_english.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getMileageMoney() && orderPrivateCar.getMileageMoney() > 0){ + lcf_english.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getWaitMoney() && orderPrivateCar.getWaitMoney() > 0){ + ddf_english.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getRoadTollMoney() && orderPrivateCar.getRoadTollMoney() > 0){ + glf_english.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getParkMoney() && orderPrivateCar.getParkMoney() > 0){ + tcf_english.text("GHS " + new BigDecimal(orderPrivateCar.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_english_div = document.getElementById("tcf_english_div"); + tcf_english_div.remove(); + } if(null != orderPrivateCar.getCouponMoney() && orderPrivateCar.getCouponMoney() > 0){ Element yhq_english = document.getElementById("yhq_english"); yhq_english.text("GHS -" + new BigDecimal(orderPrivateCar.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -2309,12 +2930,18 @@ pay_type_english.text(orderPrivateCar.getPayType() == 1 ? "Mobile money" :(orderPrivateCar.getPayType() == 2?"Bank card":(orderPrivateCar.getPayType() == 3?"I-GO Wallet":"Cash"))); Element pay_money_english = document.getElementById("pay_money_english"); pay_money_english.text("GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); + Element dispute_english = document.getElementById("dispute_english"); + if(null != orderPrivateCar.getIsDispute() && orderPrivateCar.getIsDispute() == 1){ + dispute_english.text("(Note: Disputed order, after tripartite negotiation, the final pricing of the platform is GHS " + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN) + ")"); + }else{ + dispute_english.remove(); + } Element pdf_english = document.getElementById("pdf_english"); - pdf_english.attr("href", "http://182.160.16.251:80/user/base/order/uploadReceiptPdf?orderId=" + id + "&orderType=1"); + pdf_english.attr("href", "https://igo.i-go.group/user/base/order/uploadReceiptPdf?orderId=" + id + "&orderType=1"); 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=" + id + "&orderType=1"); + lost_item_english.attr("href", "https://igo.i-go.group/mailbox/user/lossGoods.html?language=" + language + "&orderId=" + id + "&orderType=1"); Element track_english = document.getElementById("track_english"); - track_english.attr("href", "http://182.160.16.251:81/mailbox/user/location.html?orderId=" + id); + track_english.attr("href", "https://igo.i-go.group/mailbox/user/location.html?orderId=" + id); Element pay_time_english = document.getElementById("pay_time_english"); pay_time_english.text(DateUtil.conversionFormat(language, sdf1.format(orderPrivateCar.getEndServiceTime()))); Elements driver_english = document.getElementsByClass("driver_english"); @@ -2343,11 +2970,46 @@ if(3 == language){ document.getElementById("chinese").remove(); document.getElementById("english").remove(); - document.getElementsByTag("title").get(0).text("Reçu"); + document.getElementsByTag("title").get(0).text("Reçu de course"); Element title_french = document.getElementById("title_french"); title_french.text("Le " + DateUtil.conversionFormat(language, sdf.format(orderPrivateCar.getTravelTime())) + ", vous avez dépensé GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue() + " sur le voyage"); - Element xcf_french = document.getElementById("xcf_french"); - xcf_french.text("GHS " + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element qbj_french = document.getElementById("qbj_french"); + qbj_french.text("GHS " + new BigDecimal(orderPrivateCar.getStartMoney()).setScale(2, RoundingMode.HALF_EVEN)); + Element scf_french = document.getElementById("scf_french"); + if(null != orderPrivateCar.getDurationMoney() && orderPrivateCar.getDurationMoney() > 0){ + scf_french.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getMileageMoney() && orderPrivateCar.getMileageMoney() > 0){ + lcf_french.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getWaitMoney() && orderPrivateCar.getWaitMoney() > 0){ + ddf_french.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getRoadTollMoney() && orderPrivateCar.getRoadTollMoney() > 0){ + glf_french.text("GHS " + new BigDecimal(orderPrivateCar.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 != orderPrivateCar.getParkMoney() && orderPrivateCar.getParkMoney() > 0){ + tcf_french.text("GHS " + new BigDecimal(orderPrivateCar.getParkMoney()).setScale(2, RoundingMode.HALF_EVEN)); + }else{ + Element tcf_french_div = document.getElementById("tcf_french_div"); + tcf_french_div.remove(); + } if(null != orderPrivateCar.getCouponMoney() && orderPrivateCar.getCouponMoney() > 0){ Element yhq_french = document.getElementById("yhq_french"); yhq_french.text("GHS -" + new BigDecimal(orderPrivateCar.getCouponMoney()).setScale(2, RoundingMode.HALF_EVEN)); @@ -2375,12 +3037,18 @@ pay_type_french.text(orderPrivateCar.getPayType() == 1 ? "Argent mobile" : (orderPrivateCar.getPayType() == 2?"Carte bancaire":(orderPrivateCar.getPayType() == 3?"Portefeuille I-GO":"En espèces"))); Element pay_money_french = document.getElementById("pay_money_french"); pay_money_french.text("GHS " + new BigDecimal(orderPrivateCar.getPayMoney()).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue()); + Element dispute_french = document.getElementById("dispute_french"); + if(null != orderPrivateCar.getIsDispute() && orderPrivateCar.getIsDispute() == 1){ + dispute_french.text("(Remarque: Il s’agit d’une commande contestée, et après des négociations entre trois parties, la plateforme l’a finalement tarifée à GHS " + new BigDecimal(orderPrivateCar.getOrderMoney()).setScale(2, RoundingMode.HALF_EVEN) + ")"); + }else{ + dispute_french.remove(); + } Element pdf_french = document.getElementById("pdf_french"); - pdf_french.attr("href", "http://182.160.16.251:80/user/base/order/uploadReceiptPdf?orderId=" + id + "&orderType=1"); + pdf_french.attr("href", "https://igo.i-go.group/user/base/order/uploadReceiptPdf?orderId=" + id + "&orderType=1"); 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=" + id + "&orderType=1"); + lost_item_french.attr("href", "https://igo.i-go.group/mailbox/user/lossGoods.html?language=" + language + "&orderId=" + id + "&orderType=1"); Element track_french = document.getElementById("track_french"); - track_french.attr("href", "http://182.160.16.251:81/mailbox/user/location.html?orderId=" + id); + track_french.attr("href", "https://igo.i-go.group/mailbox/user/location.html?orderId=" + id); Element pay_time_french = document.getElementById("pay_time_french"); pay_time_french.text(DateUtil.conversionFormat(language, sdf1.format(orderPrivateCar.getEndServiceTime()))); Elements driver_french = document.getElementsByClass("driver_french"); @@ -2407,14 +3075,14 @@ server_tel_french.attr("href", "tel:" + (null != phone ? phone.getPhone() : "")); } - EmailUtil.send(userInfo.getEmail(), language == 1 ? "I-GO电子收据" : language == 2 ? "Receipt" : "Reçu", document.html()); + EmailUtil.send(userInfo.getEmail(), language == 1 ? "打车收据" : language == 2 ? "Ride receipt" : "Reçu de course", document.html()); //开始生成pdf收据和html收据 - File file = new File("/usr/local/nginx/html/files/html/"); + File file = new File("/home/igotechgh/nginx/html/files/html/"); if(!file.exists()){ file.mkdirs(); } - file = new File("/usr/local/nginx/html/files/html/ride_receipt_" + id + ".html"); + file = new File("/home/igotechgh/nginx/html/files/html/ride_receipt_" + id + ".html"); if(!file.exists()){ file.createNewFile(); } @@ -2423,27 +3091,27 @@ fileWriter.flush(); fileWriter.close(); - File file1 = new File("/usr/local/nginx/html/files/pdf/"); + File file1 = new File("/home/igotechgh/nginx/html/files/pdf/"); if(!file1.exists()){ file1.mkdirs(); } - file1 = new File("/usr/local/nginx/html/files/pdf/ride_receipt_" + id + ".pdf"); + file1 = new File("/home/igotechgh/nginx/html/files/pdf/ride_receipt_" + id + ".pdf"); if(!file1.exists()){ file1.createNewFile(); } try { FileOutputStream fileOutputStream = new FileOutputStream(file1); - HtmlToPdfUtils.convertToPdf("/usr/local/nginx/html/files/html/ride_receipt_" + id + ".html", "I-GO", fileOutputStream); + HtmlToPdfUtils.convertToPdf("/home/igotechgh/nginx/html/files/html/ride_receipt_" + id + ".html", "I-GO", fileOutputStream); }catch (Exception e){ e.printStackTrace(); System.out.println("html转pdf异常"); } - String link ="http://182.160.16.251:81/files/html/ride_receipt_" + id + ".html"; + String link ="https://igo.i-go.group/files/html/ride_receipt_" + id + ".html"; TEmail tEmail = new TEmail(); tEmail.setLink(link); - tEmail.setName(language == 1 ? "I-GO电子收据" : language == 2 ? "Receipt" : "Reçu"); + tEmail.setName(language == 1 ? "打车收据" : language == 2 ? "Ride receipt" : "Reçu de course"); tEmail.setUserId(userInfo.getId()); tEmail.setType(1); tEmail.setOrderId(id); @@ -2470,8 +3138,8 @@ new Thread(new Runnable() { @Override public void run() { - pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0); - pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0); + pushUtil.pushOrderState(1, orderPrivateCar.getUserId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, ""); + pushUtil.pushOrderState(2, orderPrivateCar.getDriverId(), orderPrivateCar.getId(), 1, orderPrivateCar.getState(), 0, ""); } }).start(); @@ -2507,10 +3175,35 @@ map.put("state", map.get("oldState")); } if(state == 8 || state == 9){ - map.put("receipt", "http://182.160.16.251:81/files/html/ride_receipt_" + orderId + ".html"); + map.put("receipt", "https://igo.i-go.group/files/html/ride_receipt_" + orderId + ".html"); }else{ map.put("receipt", ""); } + + OrderPrivateCar orderPrivateCar = orderPrivateCarMapper.selectById(orderId); + Integer driverTimeOutTime = 0; + Integer driverTimeOut = 0; + CancleOrder cancleOrder = cancleOrderService.selectOne(new EntityWrapper<CancleOrder>().eq("companyId", orderPrivateCar.getCompanyId())); + JSONObject jsonObject = JSON.parseObject(cancleOrder.getContent()); + int driverTimeout1 = jsonObject.getIntValue("driverTimeout"); + if(orderPrivateCar.getOrderType() == 1 && null != orderPrivateCar.getEstimateArriveTime()){ + long time = orderPrivateCar.getEstimateArriveTime().getTime() + driverTimeout1 * 60000L; + if(System.currentTimeMillis() > time){ + driverTimeOutTime = Double.valueOf((System.currentTimeMillis() - time) / 60000).intValue(); + driverTimeOutTime = driverTimeOutTime == 0 ? 1 : driverTimeOutTime; + driverTimeOut = 1; + } + }else{ + long time = orderPrivateCar.getTravelTime().getTime() + driverTimeout1 * 60000L; + if(System.currentTimeMillis() >= time){ + driverTimeOutTime = Double.valueOf((System.currentTimeMillis() - time) / 60000).intValue(); + driverTimeOutTime = driverTimeOutTime == 0 ? 1 : driverTimeOutTime; + driverTimeOut = 1; + } + } + + map.put("driverTimeOutTime", driverTimeOutTime); + map.put("driverTimeOut", driverTimeOut); } return maps; } @@ -2521,7 +3214,7 @@ endTime = dateUtil.getStartOrEndDate(endTime, "end"); List<Map<String, Object>> list = orderPrivateCarMapper.queryInvoiceOrder(type, startTime, endTime, startMoney, endMoney, uid); for (Map<String, Object> map : list) { - map.put("orderName", language == 1 ? "打车订单" : language == 2 ? "Ride" : "Course"); + map.put("orderName", language == 1 ? "打车" : language == 2 ? "Ride" : "Course"); if(null != map.get("time")){ String time = map.get("time").toString(); map.put("time", DateUtil.conversionFormat(language, time)); @@ -2533,30 +3226,35 @@ @Override public Map<String, Object> queryOrderInfo(Integer language, Integer orderId) throws Exception { Map<String, Object> map = orderPrivateCarMapper.queryOrderInfo(orderId); + OrderPrivateCar orderPrivateCar = orderPrivateCarMapper.selectById(orderId); if(null != map.get("travelTime")){ String travelTime = map.get("travelTime").toString(); map.put("travelTime", DateUtil.conversionFormat1(language, travelTime)); } Integer state = Integer.valueOf(String.valueOf(map.get("state"))); if(null != map.get("reassignNotice") && Integer.valueOf(String.valueOf(map.get("reassignNotice"))) == 2){//改派完成,重新获取了新的司机数据,开始修改数据防止继续调用 - OrderPrivateCar orderPrivateCar = this.selectById(orderId); orderPrivateCar.setReassignNotice(0); this.updateById(orderPrivateCar); } if(state == 11){ map.put("state", map.get("oldState")); } + if(state == 12){ + OrderCancel query = orderCancelService.query(orderId, 1, 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){ - OrderPrivateCar orderPrivateCar = orderPrivateCarMapper.selectById(orderId); UserActivityDiscount1 query2 = userActivityDiscount1Mapper.query(Integer.valueOf(String.valueOf(map.get("companyId")))); if(null != query2){ Integer orderNum=this.selectCount(new EntityWrapper<OrderPrivateCar>().eq("userId",orderPrivateCar.getUserId()).eq("activityId",query2.getId()).last(" and to_days(getoffTime) = to_days(now())")); if(query2.getDistance()*1000>orderPrivateCar.getMileage() && query2.getOrderNum()>orderNum){ Double special = query2.getSpecial(); + map.put("discount", special); orderPrivateCar.setDiscount(special); Double orderMoney = orderPrivateCar.getOrderMoney(); double v = new BigDecimal(orderMoney).multiply(new BigDecimal(special / 10)).setScale(2, BigDecimal.ROUND_HALF_EVEN).doubleValue(); @@ -2572,7 +3270,7 @@ map.put("device", ToolUtil.isNotEmpty(driverId) ? 2 : 1); map.put("orderType", 1); if(state == 8 || state == 9){ - map.put("receipt", "http://182.160.16.251:81/files/html/ride_receipt_" + orderId + ".html"); + map.put("receipt", "https://igo.i-go.group/files/html/ride_receipt_" + orderId + ".html"); }else{ map.put("receipt", ""); } @@ -2580,9 +3278,31 @@ if(null != map.get("driverId")){ companyId = Integer.valueOf(String.valueOf(map.get("companyId"))); } + + Integer driverTimeOutTime = 0; + Integer driverTimeOut = 0; CancleOrder cancleOrder = cancleOrderService.selectOne(new EntityWrapper<CancleOrder>().eq("companyId", companyId)); JSONObject jsonObject = JSON.parseObject(cancleOrder.getContent()); - map.put("timeOutCancel", jsonObject.getIntValue("driverTimeout")); + int driverTimeout1 = jsonObject.getIntValue("driverTimeout"); + if(orderPrivateCar.getOrderType() == 1 && null != orderPrivateCar.getEstimateArriveTime()){ + long time = orderPrivateCar.getEstimateArriveTime().getTime() + driverTimeout1 * 60000L; + if(System.currentTimeMillis() > time){ + driverTimeOutTime = Double.valueOf((System.currentTimeMillis() - time) / 60000).intValue(); + driverTimeOutTime = driverTimeOutTime == 0 ? 1 : driverTimeOutTime; + driverTimeOut = 1; + } + }else{ + long time = orderPrivateCar.getTravelTime().getTime() + driverTimeout1 * 60000L; + if(System.currentTimeMillis() >= time){ + driverTimeOutTime = Double.valueOf((System.currentTimeMillis() - time) / 60000).intValue(); + driverTimeOutTime = driverTimeOutTime == 0 ? 1 : driverTimeOutTime; + driverTimeOut = 1; + } + } + + map.put("driverTimeOutTime", driverTimeOutTime); + map.put("driverTimeOut", driverTimeOut); + map.put("isDispute", orderPrivateCar.getIsDispute()); return map; } @@ -2622,7 +3342,7 @@ //读取文件(字符流) BufferedReader in = new BufferedReader(new InputStreamReader(new FileInputStream(file),"UTF-8")); //循环取出数据 - String str = null; + String str; StringBuffer sb = new StringBuffer(); while ((str = in.readLine()) != null) { sb.append(str); @@ -2637,10 +3357,11 @@ String lnt = "0"; String lat = "0"; + String tripId = redisUtil.getValue("trip" + uid); if(ToolUtil.isNotEmpty(value)){ lnt = value.split(",")[0]; lat = value.split(",")[1]; - DistancematrixVo distancematrix = GoogleMapUtil.getDistancematrix(orderPrivateCar.getStartLat(), orderPrivateCar.getStartLon(), Double.valueOf(lat), Double.valueOf(lnt)); + DistancematrixVo distancematrix = GoogleMapUtil.getDistancematrix(orderPrivateCar.getStartLat(), orderPrivateCar.getStartLon(), Double.valueOf(lat), Double.valueOf(lnt), tripId); if(null == distancematrix){ System.err.println("查询距离出错了"); @@ -2668,7 +3389,7 @@ orderServerWarpper.setLaveTime("0"); } if(orderPrivateCar.getState() == 5 || orderPrivateCar.getState() == 6){//服务中 - DistancematrixVo distancematrix = GoogleMapUtil.getDistancematrix(Double.valueOf(lat), Double.valueOf(lnt), orderPrivateCar.getEndLat(), orderPrivateCar.getEndLon()); + DistancematrixVo distancematrix = GoogleMapUtil.getDistancematrix(Double.valueOf(lat), Double.valueOf(lnt), orderPrivateCar.getEndLat(), orderPrivateCar.getEndLon(), tripId); if(null == distancematrix){ System.err.println("查询距离出错了"); }else if(distancematrix.getDistance() == 0){ @@ -2711,7 +3432,7 @@ public List<Map<String, Object>> queryRedEnvelope(Integer language, Integer uid) throws Exception { List<Map<String, Object>> list = orderPrivateCarMapper.queryRedEnvelope(uid); for (Map<String, Object> map : list) { - map.put("name", language == 1 ? "打车订单" : language == 2 ? "Ride" : "Course"); + map.put("name", language == 1 ? "打车" : language == 2 ? "Ride" : "Course"); if(null != map.get("time")){ String time = map.get("time").toString(); map.put("time", DateUtil.conversionFormat(language, time)); @@ -2766,7 +3487,22 @@ orderPrivateCar.setDestinationLat(endLat); orderPrivateCar.setDestinationLon(endLon); this.updateById(orderPrivateCar); - pushUtil.pushModifyAddress(2, orderPrivateCar.getDriverId(), orderId, 1, 1); + + Driver driver = driverService.selectById(orderPrivateCar.getDriverId()); + Integer language1 = driver.getLanguage(); + String audioUrl = ""; + switch (language1){ + case 1: + audioUrl = "https://igo.i-go.group/files/audio/system/ChangeAddress-CN.mp3"; + break; + case 2: + audioUrl = "https://igo.i-go.group/files/audio/system/ChangeAddress-EN.mp3"; + break; + case 3: + audioUrl = "https://igo.i-go.group/files/audio/system/ChangeAddress-FR.mp3"; + break; + } + pushUtil.pushModifyAddress(2, orderPrivateCar.getDriverId(), orderId, 1, 1, audioUrl); }else{ orderPrivateCar.setEndAddress(endAddress); orderPrivateCar.setEndLat(Double.valueOf(endLat)); -- Gitblit v1.7.1