From 8a038cf6f0792cfe260a94e86d954b50f068e758 Mon Sep 17 00:00:00 2001 From: 无关风月 <443237572@qq.com> Date: 星期五, 07 二月 2025 16:55:41 +0800 Subject: [PATCH] bug修改 --- ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java | 594 +++++++--------------------------------------------------- 1 files changed, 76 insertions(+), 518 deletions(-) diff --git a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java index e5b683f..d54b825 100644 --- a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java +++ b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java @@ -80,6 +80,7 @@ import java.time.*; import java.time.format.DateTimeFormatter; import java.time.format.TextStyle; +import java.time.temporal.ChronoUnit; import java.time.temporal.WeekFields; import java.util.*; import java.util.concurrent.*; @@ -887,10 +888,13 @@ dto.setRefundReason("充电失败,取消充电订单"); RefundResp resp = aliPaymentClient.refund(dto).getData(); if(null != resp){ - AjaxResult success = chargingOrderStartupFailureWxRefund(resp.getOutTradeNo(), resp.getTradeNo(), "SUCCESS", null); - if(success.isSuccess()){ - chargingOrderRefundService.save(chargingOrderRefund); + chargingOrderRefundService.save(chargingOrderRefund); + try { + Thread.sleep(1000); + } catch (InterruptedException e) { + throw new RuntimeException(e); } + chargingOrderStartupFailureWxRefund(chargingOrderRefund.getRefundCode(), resp.getTradeNo(), "SUCCESS", null); } } @@ -1096,7 +1100,7 @@ if(1 == doubleIntegration){ num1 *= 2; } - + } GetInviteUser query = new GetInviteUser(); @@ -1260,16 +1264,6 @@ BigDecimal refundMoney = new BigDecimal("0"); BigDecimal paymentMoney = new BigDecimal("0"); List<String> collect2 = list.stream().map(TChargingOrder::getCode).collect(Collectors.toList()); - StringBuilder stringBuilder2 = new StringBuilder(); - List<UploadRealTimeMonitoringData> uploadRealTimeMonitoringData2 = new ArrayList<>(); - for (String s : collect2) { - stringBuilder2.append(s).append(","); - } - if (stringBuilder2.length()>0){ - StringBuilder ids = stringBuilder2.deleteCharAt(stringBuilder2.length() - 1); - uploadRealTimeMonitoringData2 = uploadRealTimeMonitoringDataClient.getOrderInfoByCodes(ids.toString()).getData(); - - } for (ChargingOrderVO chargingOrderVO : list) { if (roleType == 2){ for (Integer siteId : siteIds) { @@ -1296,11 +1290,13 @@ // 充电订单 明细记录 List<TChargingOrderAccountingStrategy> chargingOrderId = chargingOrderAccountingStrategyService.list(new QueryWrapper<TChargingOrderAccountingStrategy>() .eq("charging_order_id", chargingOrderVO.getId())); - UploadRealTimeMonitoringData data5 = uploadRealTimeMonitoringData2.stream().filter(e -> e.getTransaction_serial_number().equals(chargingOrderVO.getCode())) - .findFirst().orElse(null); - if (data5!=null && data5.getCumulative_charging_time()!=null){ - long l = data5.getCumulative_charging_time() * 60L; - chargingOrderVO.setChargingSecond(l); + if (chargingOrderVO.getStartTime()!=null && chargingOrderVO.getEndTime()!=null){ + LocalDateTime startTime = chargingOrderVO.getStartTime(); + LocalDateTime endTime = chargingOrderVO.getEndTime(); + // 计算时间差 单位秒 + long between = ChronoUnit.SECONDS.between(startTime, endTime); + chargingOrderVO.setChargingSecond(between); + } // 充电时段数 int size = chargingOrderId.size(); @@ -1321,17 +1317,13 @@ } } - List<String> collect = list1.stream().map(TChargingOrder::getCode).collect(Collectors.toList()); - StringBuilder stringBuilder = new StringBuilder(); - List<UploadRealTimeMonitoringData> uploadRealTimeMonitoringData = new ArrayList<>(); - for (String s : collect) { - stringBuilder.append(s).append(","); - } - if (stringBuilder.length()>0){ - StringBuilder ids = stringBuilder.deleteCharAt(stringBuilder.length() - 1); - uploadRealTimeMonitoringData = uploadRealTimeMonitoringDataClient.getOrderInfoByCodes(ids.toString()).getData(); - } + + List<Long> orderIds = list1.stream().map(TChargingOrder::getId).collect(Collectors.toList()); + if(orderIds.isEmpty())orderIds.add(-1L); + List<TChargingOrderRefund> chargingOrderRefunds = chargingOrderRefundService.lambdaQuery() + .in(TChargingOrderRefund::getChargingOrderId, orderIds) + .eq(TChargingOrderRefund::getRefundStatus,2).list(); for (ChargingOrderVO chargingOrderVO : list1) { paymentMoney= paymentMoney.add(chargingOrderVO.getPaymentAmount()!=null?chargingOrderVO.getPaymentAmount():new BigDecimal("0")); @@ -1339,19 +1331,17 @@ if (chargingOrderVO.getChargingCapacity()!=null){ total = total.add(chargingOrderVO.getElectricity()!=null?chargingOrderVO.getElectricity():new BigDecimal("0")); } - UploadRealTimeMonitoringData data5 = uploadRealTimeMonitoringData.stream().filter(e -> e.getTransaction_serial_number().equals(chargingOrderVO.getCode())) - .findFirst().orElse(null); - if (data5!=null && data5.getCumulative_charging_time()!=null){ - long l = data5.getCumulative_charging_time() * 60L; - chargingOrderVO.setChargingSecond(l); - time+=l; + if (chargingOrderVO.getStartTime()!=null && chargingOrderVO.getEndTime()!=null){ + LocalDateTime startTime = chargingOrderVO.getStartTime(); + LocalDateTime endTime = chargingOrderVO.getEndTime(); + // 计算时间差 单位秒 + long between = ChronoUnit.SECONDS.between(startTime, endTime); + time+=between; } - List<TChargingOrderRefund> list2 = chargingOrderRefundService.lambdaQuery().eq(TChargingOrderRefund::getRefundStatus, 2) - .eq(TChargingOrderRefund::getChargingOrderId, chargingOrderVO.getId()).list(); + List<TChargingOrderRefund> list2 = chargingOrderRefunds.stream().filter(e -> e.getChargingOrderId() != null && e.getChargingOrderId().equals(chargingOrderVO.getId())) + .collect(Collectors.toList()); for (TChargingOrderRefund tChargingOrderRefund : list2) { - if (tChargingOrderRefund.getRefundStatus()==2){ refundMoney = refundMoney.add(tChargingOrderRefund.getRefundTotalAmount()); - } } electronicMoney = electronicMoney.add(chargingOrderVO.getElectrovalence()!=null?chargingOrderVO.getElectrovalence():new BigDecimal("0")); serviceMoney = serviceMoney.add(chargingOrderVO.getServiceCharge()!=null?chargingOrderVO.getServiceCharge():new BigDecimal("0")); @@ -1447,6 +1437,9 @@ String startTime2 = null; String endTime1 = null; String endTime2 = null; + + List<TChargingGun> allGun = chargingGunClient.getAllGun().getData(); + List<TChargingPile> allPile = chargingGunClient.getAllPile().getData(); if (StringUtils.hasLength(dto.getStartTime())){ String[] split = dto.getStartTime().split(" - "); @@ -1544,19 +1537,18 @@ chargingOrderListVO.setSiteName(site.getName()); } if (chargingOrderListVO.getChargingGunId()!=null && chargingOrderListVO.getChargingPileId()!=null){ - TChargingGun data1 = chargingGunClient.getChargingGunById(chargingOrderListVO.getChargingGunId()).getData(); - TChargingPile data2 = chargingPileClient.getChargingPileById(chargingOrderListVO.getChargingPileId()).getData(); + TChargingGun data1 = allGun.stream().filter(e->e.getId().equals(chargingOrderListVO.getChargingGunId())).findFirst().orElse(null); + TChargingGun data2 = allGun.stream().filter(e->e.getId().equals(chargingOrderListVO.getChargingGunId())).findFirst().orElse(null); if (data2 != null && data1 != null) { chargingOrderListVO.setTerminalName(data2.getName() + "-" + data1.getName()); } } - // 获取充电时间 - UploadRealTimeMonitoringData data5 = uploadRealTimeMonitoringDataClient.chargingOrderInfo(chargingOrderListVO.getCode()).getData(); - if (data5!=null){ - if (data5.getTime_remaining()!=null){ - chargingOrderListVO.setChargingSecond(data5.getCumulative_charging_time()*60L); - - } + if (chargingOrderListVO.getStartTime()!=null && chargingOrderListVO.getEndTime()!=null){ + LocalDateTime startTime = chargingOrderListVO.getStartTime(); + LocalDateTime endTime = chargingOrderListVO.getEndTime(); + // 计算时间差 单位秒 + long between = ChronoUnit.SECONDS.between(startTime, endTime); + chargingOrderListVO.setChargingSecond(between); } // 获取开始SOC 结束soc if (chargingOrderListVO.getCode()!=null){ @@ -1640,6 +1632,28 @@ // 不分页 PageInfo<ChargingOrderListVO> pageInfo1 = new PageInfo<>(1,999999999); List<ChargingOrderListVO> list1 = this.baseMapper.chargingList(pageInfo1,dto,startTime1,startTime2,endTime1,endTime2); + for (ChargingOrderListVO chargingOrderListVO : list1) { + List<Integer> integers = new ArrayList<>(); + integers.add(chargingOrderListVO.getSiteId()); + Site site = sites.stream().filter(e -> e.getId().equals(chargingOrderListVO.getSiteId())).findFirst().orElse(null); + if (site!=null){ + chargingOrderListVO.setSiteName(site.getName()); + } + if (chargingOrderListVO.getStartTime()!=null && chargingOrderListVO.getEndTime()!=null){ + LocalDateTime startTime = chargingOrderListVO.getStartTime(); + LocalDateTime endTime = chargingOrderListVO.getEndTime(); + // 计算时间差 单位秒 + long between = ChronoUnit.SECONDS.between(startTime, endTime); + chargingOrderListVO.setChargingSecond(between); + } + if (chargingOrderListVO.getChargingGunId()!=null && chargingOrderListVO.getChargingPileId()!=null){ + TChargingGun data1 = allGun.stream().filter(e->e.getId().equals(chargingOrderListVO.getChargingGunId())).findFirst().orElse(null); + TChargingGun data2 = allGun.stream().filter(e->e.getId().equals(chargingOrderListVO.getChargingGunId())).findFirst().orElse(null); + if (data2 != null && data1 != null) { + chargingOrderListVO.setTerminalName(data2.getName() + "-" + data1.getName()); + } + } + } chargingOrderTimeVO.setExportList(list1); chargingOrderTimeVO.setOrderCount(list1.size()); // 计算充电总度数 @@ -1757,6 +1771,8 @@ public ChargingOrderListInfoVO chargingInfo(String uid) { TChargingOrder chargingOrder= this.getById(uid); ChargingOrderListInfoVO chargingOrderListInfoVO = new ChargingOrderListInfoVO(); + chargingOrderListInfoVO.setStartTime(chargingOrder.getStartTime()); + chargingOrderListInfoVO.setEndTime(chargingOrder.getEndTime()); chargingOrderListInfoVO.setStatus(chargingOrder.getStatus()); BigDecimal bigDecimal = new BigDecimal("0.006"); if (chargingOrder.getOrderAmount()!=null){ @@ -1833,13 +1849,12 @@ chargingOrderListInfoVO.setList(data6); } - // 获取充电时间 - UploadRealTimeMonitoringData data5 = uploadRealTimeMonitoringDataClient.chargingOrderInfo(chargingOrder.getCode()).getData(); - if (data5!=null){ - if (data5.getTime_remaining()!=null){ - chargingOrderListInfoVO.setChargingSecond(data5.getCumulative_charging_time()*60L+""); - - } + if (chargingOrderListInfoVO.getStartTime()!=null && chargingOrderListInfoVO.getEndTime()!=null){ + LocalDateTime startTime = chargingOrderListInfoVO.getStartTime(); + LocalDateTime endTime = chargingOrderListInfoVO.getEndTime(); + // 计算时间差 单位秒 + long between = ChronoUnit.SECONDS.between(startTime, endTime); + chargingOrderListInfoVO.setChargingSecond(between+""); } if (chargingOrder.getAppUserCarId()!=null){ @@ -2110,6 +2125,7 @@ BigDecimal vipDiscountAmount = BigDecimal.ZERO; //计算优惠金额 if(null != chargingOrder.getVipDiscount()){ + //0.58折 vipDiscountAmount = serviceCharge.multiply(new BigDecimal(1).subtract(chargingOrder.getVipDiscount())); serviceCharge = serviceCharge.multiply(chargingOrder.getVipDiscount()); } @@ -2124,9 +2140,7 @@ periodElectricPrice_total = periodElectricPrice_total.add(electrovalenc); periodServicePrice_total = periodServicePrice_total.add(originalServicePrice); total = total.add(electrovalenc.add(originalServicePrice)); - } - //原金额 BigDecimal rechargeAmount = chargingOrder.getRechargeAmount(); @@ -2165,7 +2179,7 @@ discountAmount = discountAmount.setScale(4, RoundingMode.HALF_EVEN); payAmount = payAmount.subtract(discountAmount); periodServicePrice_total = periodServicePrice_total.subtract(discountAmount); - + TChargingOrder order = new TChargingOrder(); order.setId(chargingOrder.getId()); order.setAppUserId(chargingOrder.getAppUserId()); @@ -2361,442 +2375,6 @@ } -// /** -// * 停止充电返回账单后计算费用 -// * @param vo -// */ -// @Override -// @GlobalTransactional(rollbackFor = Exception.class) -// public void endChargeBillingCharge1(TransactionRecordMessageVO vo) { -// TChargingOrder chargingOrder = this.getOne(new LambdaQueryWrapper<TChargingOrder>().eq(TChargingOrder::getCode, vo.getTransaction_serial_number())); -// Integer status = chargingOrder.getStatus(); -//// if(status == 5){ -//// return; -//// } -// -// //如果使用优惠券需要判断优惠券是否满足使用条件 -// //根据实际的充电金额计算退款金额 退回费用=(原金额/总金额)*(总金额-实际充电金额) -// //退款金额=优惠券金额+剩余充电金额 -// BigDecimal periodElectricPrice_total = BigDecimal.ZERO; -// BigDecimal periodServicePrice_total = BigDecimal.ZERO; -// BigDecimal total = BigDecimal.ZERO; -// -// //获取订单的计费策略 -// List<AccountingStrategyDetailOrder> accountingStrategyDetailOrderList = accountingStrategyDetailOrderClient.getAllAccountingStrategyDetailOrder(chargingOrder.getId()).getData(); -// accountingStrategyDetailOrderList.get(accountingStrategyDetailOrderList.size() - 1).setEndTime("23:59"); -// //开始处理计费明细数据和优惠数据 -//// chargingOrderAccountingStrategyService.remove(new LambdaQueryWrapper<TChargingOrderAccountingStrategy>().eq(TChargingOrderAccountingStrategy::getChargingOrderId, chargingOrder.getId())); -// SimpleDateFormat sdfs = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); -// List<AccountingStrategyDetailOrderVo> lists = new ArrayList<>(); -// try { -// //跨天 -// if(!vo.getStart_time().split(" ")[0].equals(vo.getEnd_time().split(" ")[0])){ -// //当天的 -// //开始通过计费策略遍历解析每个时段的费用明细 -// String start_time = vo.getStart_time(); -// String end_time = vo.getEnd_time(); -// long start = sdfs.parse(start_time).getTime(); -// long end = sdfs.parse(end_time).getTime(); -// Class<? extends TransactionRecordMessageVO> clazz = vo.getClass(); -// /** -// * "start_time": "2025-01-03 23:06:43.00", -// * "end_time": "2025-01-04 00:39:39.00", -// */ -// for (int i = accountingStrategyDetailOrderList.size(); i > 0; i--) { -// AccountingStrategyDetailOrder strategyDetail = accountingStrategyDetailOrderList.get(i - 1); -// long time = sdfs.parse(start_time.split(" ")[0] + " " + strategyDetail.getEndTime() + ":00").getTime(); -// if(time < start){ -// break; -// } -// //阶段(1=尖阶段,2=峰阶段,3=平阶段,4=谷阶段) -// Object invoke = null; -// switch (strategyDetail.getType()){ -// case 1: -// //充电度数 -// invoke = clazz.getMethod("getSpike_charge" + (i)).invoke(vo); -// break; -// case 2: -// //充电度数 -// invoke = clazz.getMethod("getPeak_charge" + (i)).invoke(vo); -// break; -// case 3: -// //充电度数 -// invoke = clazz.getMethod("getFlat_charge" + (i)).invoke(vo); -// break; -// case 4: -// //充电度数 -// invoke = clazz.getMethod("getValley_charge" + (i)).invoke(vo); -// break; -// } -// if(null == invoke || Double.valueOf(invoke.toString()) == 0){ -// continue; -// } -// BigDecimal sharp_peak_charge = new BigDecimal(invoke.toString()); -// AccountingStrategyDetailOrderVo vo1 = new AccountingStrategyDetailOrderVo(); -// BeanUtils.copyProperties(strategyDetail, vo1); -// vo1.setChargingCapacity(sharp_peak_charge); -// lists.add(vo1); -// } -// -// //第二天的 -// //开始通过计费策略遍历解析每个时段的费用明细 -// for (int i = 0; i < accountingStrategyDetailOrderList.size(); i++) { -// AccountingStrategyDetailOrder strategyDetail = accountingStrategyDetailOrderList.get(i); -// long time = sdfs.parse(end_time.split(" ")[0] + " " + strategyDetail.getStartTime() + ":00").getTime(); -// if(time > end){ -// break; -// } -// //阶段(1=尖阶段,2=峰阶段,3=平阶段,4=谷阶段) -// Object invoke = null; -// switch (strategyDetail.getType()){ -// case 1: -// //充电度数 -// invoke = clazz.getMethod("getSpike_charge" + (i + 1)).invoke(vo); -// break; -// case 2: -// //充电度数 -// invoke = clazz.getMethod("getPeak_charge" + (i + 1)).invoke(vo); -// break; -// case 3: -// //充电度数 -// invoke = clazz.getMethod("getFlat_charge" + (i + 1)).invoke(vo); -// break; -// case 4: -// //充电度数 -// invoke = clazz.getMethod("getValley_charge" + (i + 1)).invoke(vo); -// break; -// } -// if(null == invoke || Double.valueOf(invoke.toString()) == 0){ -// continue; -// } -// BigDecimal sharp_peak_charge = new BigDecimal(invoke.toString()); -// AccountingStrategyDetailOrderVo vo1 = new AccountingStrategyDetailOrderVo(); -// BeanUtils.copyProperties(strategyDetail, vo1); -// vo1.setChargingCapacity(sharp_peak_charge); -// lists.add(vo1); -// } -// }else{ -// for (int i = 0; i < accountingStrategyDetailOrderList.size(); i++) { -// Class<? extends TransactionRecordMessageVO> clazz = vo.getClass(); -// AccountingStrategyDetailOrder strategyDetail = accountingStrategyDetailOrderList.get(i); -// //阶段(1=尖阶段,2=峰阶段,3=平阶段,4=谷阶段) -// Object invoke = null; -// switch (strategyDetail.getType()){ -// case 1: -// //充电度数 -// invoke = clazz.getMethod("getSpike_charge" + (i + 1)).invoke(vo); -// break; -// case 2: -// //充电度数 -// invoke = clazz.getMethod("getPeak_charge" + (i + 1)).invoke(vo); -// break; -// case 3: -// //充电度数 -// invoke = clazz.getMethod("getFlat_charge" + (i + 1)).invoke(vo); -// break; -// case 4: -// //充电度数 -// invoke = clazz.getMethod("getValley_charge" + (i + 1)).invoke(vo); -// break; -// } -// if(null == invoke || Double.valueOf(invoke.toString()) == 0){ -// continue; -// } -// BigDecimal sharp_peak_charge = new BigDecimal(invoke.toString()); -// AccountingStrategyDetailOrderVo vo1 = new AccountingStrategyDetailOrderVo(); -// BeanUtils.copyProperties(strategyDetail, vo1); -// vo1.setChargingCapacity(sharp_peak_charge); -// lists.add(vo1); -// } -// } -// }catch (Exception e){ -// e.printStackTrace(); -// } -// -// //开始处理明细 -// for (int i = 0; i < lists.size(); i++) { -// AccountingStrategyDetailOrderVo strategyDetail = lists.get(i); -// BigDecimal sharp_peak_charge = strategyDetail.getChargingCapacity(); -// TChargingOrderAccountingStrategy chargingOrderAccountingStrategy = new TChargingOrderAccountingStrategy(); -// chargingOrderAccountingStrategy.setChargingOrderId(chargingOrder.getId()); -// chargingOrderAccountingStrategy.setAccountingStrategyDetailId(strategyDetail.getId()); -// chargingOrderAccountingStrategy.setType(strategyDetail.getType()); -// chargingOrderAccountingStrategy.setElectrovalence(strategyDetail.getElectrovalence()); -// chargingOrderAccountingStrategy.setServiceCharge(strategyDetail.getServiceCharge()); -// chargingOrderAccountingStrategy.setCostServiceCharge(strategyDetail.getCostServiceCharge()); -// if(i == 0){ -// String time = vo.getStart_time().split(" ")[1]; -// chargingOrderAccountingStrategy.setStartTime(time.substring(0, time.lastIndexOf(":"))); -// }else{ -// chargingOrderAccountingStrategy.setStartTime(strategyDetail.getStartTime()); -// } -// if(i == lists.size() - 1){ -// String time = vo.getEnd_time().split(" ")[1]; -// chargingOrderAccountingStrategy.setEndTime(time.substring(0, time.lastIndexOf(":"))); -// }else{ -// chargingOrderAccountingStrategy.setEndTime(strategyDetail.getEndTime()); -// } -// -// //已充电总度数 -// BigDecimal electrovalenc = strategyDetail.getElectrovalence().multiply(sharp_peak_charge); -// BigDecimal originalServicePrice = strategyDetail.getServiceCharge().multiply(sharp_peak_charge); -// BigDecimal serviceCharge = originalServicePrice; -// BigDecimal vipDiscountAmount = BigDecimal.ZERO; -// //计算优惠金额 -// if(null != chargingOrder.getVipDiscount()){ -// vipDiscountAmount = serviceCharge.multiply(new BigDecimal(1).subtract(chargingOrder.getVipDiscount())); -// serviceCharge = serviceCharge.multiply(chargingOrder.getVipDiscount()); -// } -// chargingOrderAccountingStrategy.setChargingCapacity(sharp_peak_charge); -// chargingOrderAccountingStrategy.setPeriodElectricPrice(electrovalenc.setScale(4, RoundingMode.HALF_EVEN)); -// chargingOrderAccountingStrategy.setPeriodServicePrice(serviceCharge.setScale(4, RoundingMode.HALF_EVEN)); -// chargingOrderAccountingStrategy.setPeriodOriginalServicePrice(originalServicePrice.setScale(4, RoundingMode.HALF_EVEN)); -// chargingOrderAccountingStrategy.setVipDiscountAmount(vipDiscountAmount.setScale(4, RoundingMode.HALF_EVEN)); -// chargingOrderAccountingStrategy.setCreateTime(LocalDateTime.now()); -//// chargingOrderAccountingStrategyService.save(chargingOrderAccountingStrategy); -// System.err.println("----------"+JSON.toJSONString(chargingOrderAccountingStrategy)); -// -// periodElectricPrice_total = periodElectricPrice_total.add(electrovalenc); -// periodServicePrice_total = periodServicePrice_total.add(originalServicePrice); -// total = total.add(electrovalenc.add(originalServicePrice)); -// -// } -// -// -// //原金额 -// BigDecimal rechargeAmount = chargingOrder.getRechargeAmount(); -// BigDecimal vipDiscountAmount = chargingOrder.getVipDiscountAmount(); -// //总金额(充值金额+会员折扣金额) -// BigDecimal decimal = rechargeAmount.add(vipDiscountAmount); -// //退款金额(已经计算了折扣优惠部分) -// //如果充电总金额未使用完,则需要退回费用=(原金额/总金额)*(总金额-实际充电金额) -// BigDecimal refundAmount = rechargeAmount.divide(decimal, new MathContext(4, RoundingMode.HALF_EVEN)).multiply(decimal.subtract(total)); -// BigDecimal orderAmount = BigDecimal.valueOf(total.doubleValue()); -// BigDecimal payAmount = BigDecimal.valueOf(total.doubleValue()); -// //折扣金额 -// BigDecimal discountAmount = BigDecimal.ZERO; -//// if(null != chargingOrder.getVipDiscount()){ -//// TAppUser appUser = appUserClient.getUserById(chargingOrder.getAppUserId()).getData(); -//// //判断会员是否还有充电优惠次数 -//// GetAppUserVipDetail getAppUserVipDetail = new GetAppUserVipDetail(); -//// getAppUserVipDetail.setAppUserId(chargingOrder.getAppUserId()); -//// getAppUserVipDetail.setVipId(appUser.getVipId()); -//// TAppUserVipDetail data = appUserVipDetailClient.getAppUserVipDetail(getAppUserVipDetail).getData(); -//// if(null != data && data.getChargeNum() > 0){ -//// data.setChargeNum(data.getChargeNum() - 1); -//// appUserVipDetailClient.updateAppUserVipDetail(data); -//// -//// //服务费折扣 -//// discountAmount = periodServicePrice_total.multiply((new BigDecimal(1).subtract(chargingOrder.getVipDiscount()))); -//// TVip vip = vipClient.getInfo1(appUser.getVipId()).getData(); -//// BigDecimal maximumDeduction = vip.getMaximumDeduction(); -//// //普通会员有最高优惠限制 -//// if(vip.getType() == 1 && discountAmount.compareTo(maximumDeduction) > 0){ -//// discountAmount = maximumDeduction; -//// } -//// } -//// } -// //会员折扣金额 -// discountAmount = discountAmount.setScale(4, RoundingMode.HALF_EVEN); -// payAmount = payAmount.subtract(discountAmount); -// periodServicePrice_total = periodServicePrice_total.subtract(discountAmount); -// -// TChargingOrder order = new TChargingOrder(); -// order.setId(chargingOrder.getId()); -// order.setAppUserId(chargingOrder.getAppUserId()); -// UploadRealTimeMonitoringData uploadRealTimeMonitoringData = uploadRealTimeMonitoringDataClient.chargingOrderInfo(chargingOrder.getCode()).getData(); -// if(null != uploadRealTimeMonitoringData && null == chargingOrder.getEndMode()){ -// Integer soc = uploadRealTimeMonitoringData.getSoc(); -// order.setEndMode(soc > 98 ? 2 : 3); -// }else{ -// order.setEndMode(1); -// } -// order.setResidualAmount(rechargeAmount.subtract(total).setScale(2, RoundingMode.HALF_EVEN)); -// order.setStartTime(LocalDateTime.parse(vo.getStart_time(), DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SS"))); -// order.setEndTime(LocalDateTime.parse(vo.getEnd_time(), DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SS"))); -// order.setStatus(5); -// order.setOrderAmount(orderAmount.setScale(2, RoundingMode.HALF_EVEN)); -// order.setVipDiscountAmount(discountAmount.setScale(2, RoundingMode.HALF_EVEN)); -// order.setElectrovalence(periodElectricPrice_total.setScale(2, RoundingMode.HALF_EVEN)); -// order.setChargingCapacity(vo.getTotal_electricity()); -// order.setElectricity(vo.getTotal_electricity()); -// -// //计算优惠券 -// BigDecimal couponDiscount = BigDecimal.ZERO; -//// if(null != chargingOrder.getAppCouponId()){ -//// //判断实际充电金额是否满足优惠券使用条件,如果不满足则不适用优惠券。 -//// TAppCoupon appCoupon = appCouponClient.getAppCouponById(chargingOrder.getAppCouponId()).getData(); -//// String couponJson = appCoupon.getCouponJson(); -//// TCoupon tCoupon = JSON.parseObject(couponJson, TCoupon.class); -//// Integer preferentialMode = tCoupon.getPreferentialMode(); -//// if(1 == preferentialMode){ -//// //满减 -//// if(payAmount.compareTo(tCoupon.getMeetTheConditions()) >= 0){ -//// BigDecimal couponDiscountAmount = tCoupon.getDiscountAmount(); -//// //如果优惠金额大于服务费金额,以服务费作为最大限制 -//// if(periodServicePrice_total.compareTo(couponDiscountAmount) < 0){ -//// couponDiscount = periodServicePrice_total; -//// periodServicePrice_total = BigDecimal.ZERO; -//// }else{ -//// couponDiscount = couponDiscountAmount; -//// } -//// appCoupon.setStatus(2); -////// appCouponClient.updateAppCoupon(appCoupon); -//// }else{ -//// order.setAppCouponId(null); -//// order.setCouponDiscountAmount(BigDecimal.ZERO); -////// appCouponClient.refund(chargingOrder.getAppCouponId().toString()); -//// } -//// } -//// if(2 == preferentialMode){ -//// //抵扣 -//// if(payAmount.compareTo(tCoupon.getMeetTheConditions()) >= 0){ -//// //折扣金额 -//// BigDecimal divide = payAmount.multiply(new BigDecimal(10).subtract(tCoupon.getDiscount())).divide(new BigDecimal(10)); -//// divide = divide.compareTo(tCoupon.getMaximumDiscountAmount()) > 0 ? tCoupon.getMaximumDiscountAmount() : divide; -//// //如果优惠金额大于服务费金额,以服务费作为最大限制 -//// if(periodServicePrice_total.compareTo(divide) < 0){ -//// couponDiscount = periodServicePrice_total; -//// periodServicePrice_total = BigDecimal.ZERO; -//// }else{ -//// couponDiscount = divide; -//// } -//// -//// appCoupon.setStatus(2); -//// appCouponClient.updateAppCoupon(appCoupon); -//// }else{ -//// order.setAppCouponId(null); -//// order.setCouponDiscountAmount(BigDecimal.ZERO); -//// appCouponClient.refund(chargingOrder.getAppCouponId().toString()); -//// } -//// } -//// } -// //优惠券优惠金额 -// couponDiscount = couponDiscount.setScale(4, RoundingMode.HALF_EVEN); -// refundAmount = refundAmount.add(couponDiscount); -// payAmount = payAmount.subtract(couponDiscount); -// if(periodServicePrice_total.compareTo(BigDecimal.ZERO) > 0){ -// periodServicePrice_total = periodServicePrice_total.subtract(couponDiscount); -// } -// order.setCouponDiscountAmount(couponDiscount.setScale(2, RoundingMode.HALF_EVEN)); -// order.setServiceCharge(periodServicePrice_total.setScale(2, RoundingMode.HALF_EVEN)); -// order.setPaymentAmount(payAmount.setScale(2, RoundingMode.HALF_EVEN)); -// order.setRefundAmount(refundAmount.setScale(2, RoundingMode.HALF_EVEN)); -// order.setRefundStatus(1); -//// this.updateById(order); -// System.err.println("----------"+JSON.toJSONString(order)); -//// chargingOrder = this.getById(order.getId()); -//// -//// //开始将优惠券优惠的金额添加到明细中 -//// BigDecimal couponDiscountAmount = order.getCouponDiscountAmount(); -//// if(null != couponDiscountAmount && couponDiscountAmount.compareTo(BigDecimal.ZERO) > 0){ -//// List<TChargingOrderAccountingStrategy> list = chargingOrderAccountingStrategyService.list(new LambdaQueryWrapper<TChargingOrderAccountingStrategy>().eq(TChargingOrderAccountingStrategy::getChargingOrderId, order.getId())); -//// BigDecimal reduce = list.stream().map(TChargingOrderAccountingStrategy::getPeriodServicePrice).reduce(BigDecimal.ZERO, BigDecimal::add); -//// for (TChargingOrderAccountingStrategy chargingOrderAccountingStrategy : list) { -//// BigDecimal periodServicePrice = chargingOrderAccountingStrategy.getPeriodServicePrice(); -//// BigDecimal multiply = couponDiscountAmount.multiply(periodServicePrice.divide(reduce, new MathContext(4, RoundingMode.HALF_EVEN))); -//// periodServicePrice = periodServicePrice.subtract(multiply); -//// chargingOrderAccountingStrategy.setPeriodServicePrice(periodServicePrice.setScale(2, RoundingMode.HALF_EVEN)); -//// chargingOrderAccountingStrategy.setCouponDiscountAmount(multiply.setScale(2, RoundingMode.HALF_EVEN)); -//// } -////// chargingOrderAccountingStrategyService.updateBatchById(list); -//// } -//// -//// // 将枪状态重置为空闲 -//// TChargingGun chargingGun = new TChargingGun(); -//// chargingGun.setId(chargingOrder.getChargingGunId()); -//// chargingGun.setStatus(2); -//// chargingGun.setChargingPower(BigDecimal.ZERO); -////// chargingGunClient.updateChargingGunById(chargingGun); -//// -//// //添加积分 -//// TIntegralRule integralRule = integralRuleClient.getSet().getData(); -//// if(null != integralRule){ -//// TAppUser appUser = appUserClient.getUserById(chargingOrder.getAppUserId()).getData(); -//// Integer num1 = JSON.parseObject(integralRule.getChargeCredit()).getInteger("num1"); -//// Integer integral = chargingOrder.getServiceCharge().intValue() * num1; -//// if(null != appUser.getVipId()){ -//// TVip vip = vipClient.getInfo1(appUser.getVipId()).getData(); -//// Integer doubleIntegration = vip.getDoubleIntegration(); -//// //双倍积分 -//// if(1 == doubleIntegration){ -//// integral *= 2; -//// } -//// } -//// -//// if(integral > 0){ -//// TAppUserIntegralChange appUserIntegralChange = new TAppUserIntegralChange(); -//// appUserIntegralChange.setAppUserId(appUser.getId()); -//// appUserIntegralChange.setChangeType(2); -//// appUserIntegralChange.setHistoricalIntegral(appUser.getPoints()); -//// appUser.setPoints(appUser.getPoints() + integral); -//// appUserIntegralChange.setCurrentIntegral(appUser.getPoints()); -//// appUserIntegralChange.setCreateTime(LocalDateTime.now()); -//// appUserIntegralChange.setOrderCode(chargingOrder.getCode()); -//// appUserIntegralChange.setExtension(chargingOrder.getId().toString()); -//// appUserClient.updateAppUser(appUser); -//// appUserIntegralChangeClient.addAppUserIntegralChange(appUserIntegralChange); -//// } -//// } -//// -//// //计算用户标签 -//// editUserTag(chargingOrder); -//// //用户推荐奖励 -//// referralReward(chargingOrder); -//// -//// //开始构建退款费用 -//// if(refundAmount.compareTo(BigDecimal.ZERO) > 0){ -//// Integer rechargePaymentType = chargingOrder.getRechargePaymentType(); -//// //构建退款明细 -//// TChargingOrderRefund chargingOrderRefund = new TChargingOrderRefund(); -//// chargingOrderRefund.setChargingOrderId(chargingOrder.getId()); -//// SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); -//// chargingOrderRefund.setRefundCode("CDF" + sdf.format(new Date()) + (Double.valueOf(Math.random() * 1000).intValue())); -//// chargingOrderRefund.setRefundAmount(refundAmount); -//// chargingOrderRefund.setRefundStatus(1); -//// chargingOrderRefund.setPayType(rechargePaymentType); -//// chargingOrderRefund.setRefundStatus(1); -//// chargingOrderRefund.setCode(chargingOrder.getCode()); -//// chargingOrderRefund.setRefundTitle("充电完成退款"); -//// chargingOrderRefund.setRefundContent("充电完成退款"); -//// chargingOrderRefund.setRefundReason("充电完成退款"); -//// chargingOrderRefund.setRefundRemark("实际充电消费金额:" + chargingOrder.getPaymentAmount()); -//// chargingOrderRefund.setRefundTotalAmount(refundAmount); -//// chargingOrderRefund.setPayAmount(rechargeAmount); -//// if(1 == rechargePaymentType){ -//// WxPaymentRefundModel model = new WxPaymentRefundModel(); -//// model.setOut_trade_no(chargingOrder.getCode()); -//// model.setOut_refund_no(chargingOrderRefund.getRefundCode()); -//// model.setReason("充电完成退款"); -//// model.setNotify_url("/payment/wx/refund/notify"); -//// WxPaymentRefundModel.RefundAmount amount = new WxPaymentRefundModel.RefundAmount(); -//// amount.setRefund(refundAmount.multiply(new BigDecimal(100)).intValue()); -//// amount.setTotal(rechargeAmount.multiply(new BigDecimal(100)).intValue()); -//// amount.setCurrency("CNY"); -//// model.setAmount(amount); -//// R<String> orderR = wxPaymentClient.refundOrderR(model); -//// if(200 == orderR.getCode()){ -//// chargingOrderRefundService.save(chargingOrderRefund); -//// } -//// } -//// if(2 == rechargePaymentType){ -//// RefundReq dto = new RefundReq(); -//// dto.setOutTradeNo(chargingOrder.getCode()); -//// dto.setOutRequestNo(chargingOrderRefund.getCode()); -//// dto.setRefundAmount(refundAmount.toString()); -//// dto.setRefundReason("充电完成退款"); -//// RefundResp resp = aliPaymentClient.refund(dto).getData(); -//// if(null != resp){ -//// AjaxResult success = chargingOrderStartupFailureWxRefund(resp.getOutTradeNo(), resp.getTradeNo(), "SUCCESS", null); -//// if(success.isSuccess()){ -//// chargingOrderRefundService.save(chargingOrderRefund); -//// } -//// } -//// } -//// -//// } -// } - @Override @@ -2887,6 +2465,10 @@ private TVipOrderService vipOrderService; @Resource private TVipOrderRefundService vipOrderRefundService; + + + + @Override public R payRefund(PayOrderRefundDto payOrderQueryDto) { if (payOrderQueryDto.getType()==1){ @@ -2944,7 +2526,6 @@ dto.setRefundReason("取消订单"); RefundResp resp = aliPaymentClient.refund(dto).getData(); if(null != resp){ - SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-DDTHH:mm:ss+TIMEZONE"); chargingOrderRefund.setRefundStatus(2); chargingOrderRefund.setRefundAmount((tChargingOrder.getRefundAmount()==null? BigDecimal.valueOf(0) :tChargingOrder.getRefundAmount()).add(payOrderQueryDto.getRefundAmount())); this.baseMapper.updateById(tChargingOrder); @@ -2952,11 +2533,6 @@ } } - - - - - } if (payOrderQueryDto.getType()==2){ TShoppingOrder tChargingOrder = shoppingOrderService.getById(payOrderQueryDto.getOrderId()); @@ -3012,16 +2588,10 @@ dto.setRefundReason("取消订单"); RefundResp resp = aliPaymentClient.refund(dto).getData(); if(null != resp){ - SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-DDTHH:mm:ss+TIMEZONE"); - tChargingOrder.setRefundStatus(2); tChargingOrder.setRefundAmount((tChargingOrder.getRefundAmount()==null? BigDecimal.valueOf(0) :tChargingOrder.getRefundAmount()).add(payOrderQueryDto.getRefundAmount())); - - shoppingOrderService.updateById(tChargingOrder); - shoppingOrderRefundService.save(chargingOrderRefund); - } } @@ -3032,8 +2602,6 @@ if (tChargingOrder.getPaymentAmount().compareTo(payOrderQueryDto.getRefundAmount())==-1){ return R.fail("退款金额需小于支付金额"); } - - TVipOrderRefund chargingOrderRefund = new TVipOrderRefund(); chargingOrderRefund.setVipOrderId(tChargingOrder.getId()); chargingOrderRefund.setRefundAmount(payOrderQueryDto.getRefundAmount()); @@ -3079,23 +2647,13 @@ dto.setRefundReason("取消订单"); RefundResp resp = aliPaymentClient.refund(dto).getData(); if(null != resp){ - SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-DDTHH:mm:ss+TIMEZONE"); - tChargingOrder.setRefundStatus(2); tChargingOrder.setRefundAmount((tChargingOrder.getRefundAmount()==null? BigDecimal.valueOf(0) :tChargingOrder.getRefundAmount()).add(payOrderQueryDto.getRefundAmount())); - - vipOrderService.updateById(tChargingOrder); - vipOrderRefundService.save(chargingOrderRefund); - } } - } - - - return R.ok(); } -- Gitblit v1.7.1