From 67d06a785d5fc4524639ace27651c01ff05a4b58 Mon Sep 17 00:00:00 2001 From: liujie <1793218484@qq.com> Date: 星期四, 29 五月 2025 22:31:33 +0800 Subject: [PATCH] 修改bug --- ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingBillServiceImpl.java | 371 +++++++++++++++++++++++++++++----------------------- 1 files changed, 209 insertions(+), 162 deletions(-) diff --git a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingBillServiceImpl.java b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingBillServiceImpl.java index 84ec02b..529c1fb 100644 --- a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingBillServiceImpl.java +++ b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingBillServiceImpl.java @@ -20,18 +20,16 @@ import com.ruoyi.common.security.utils.SecurityUtils; import com.ruoyi.integration.api.feignClient.UploadRealTimeMonitoringDataClient; import com.ruoyi.integration.api.model.UploadRealTimeMonitoringData; -import com.ruoyi.order.api.model.TChargingOrder; -import com.ruoyi.order.api.model.TChargingOrderRefund; +import com.ruoyi.order.api.model.*; import com.ruoyi.order.api.vo.ChargingBillListVO; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.common.core.web.page.PageInfo; -import com.ruoyi.order.api.model.TChargingBill; import com.ruoyi.order.api.vo.ChargingBillVO; -import com.ruoyi.order.api.model.ChargingListQuery; import com.ruoyi.order.mapper.TChargingBillMapper; import com.ruoyi.order.mapper.TChargingOrderMapper; import com.ruoyi.order.service.TChargingBillService; +import com.ruoyi.order.service.TChargingOrderAccountingStrategyService; import com.ruoyi.order.service.TChargingOrderRefundService; import com.ruoyi.system.api.domain.SysUser; import com.ruoyi.system.api.feignClient.SysUserClient; @@ -88,7 +86,6 @@ @Override public ChargingBillVO chargingBillList1(ChargingListQuery dto) { - ChargingBillVO chargingBillVO = new ChargingBillVO(); List<TChargingOrder> tChargingOrders1 = new ArrayList<>(); String startTime1 = null; @@ -105,7 +102,7 @@ List<TAppUser> userList = appUserClient.getAllUser().getData(); List<TAppUserCar> carList = appUserCarClient.getAllCar().getData(); List<TChargingOrder> total = chargingOrderList.selectList(new LambdaQueryWrapper<>(TChargingOrder.class) - .eq(TChargingOrder::getRechargePaymentStatus, 2)); + .isNotNull(TChargingOrder::getPayTime)); List<TChargingOrderRefund> totalRefund = chargingOrderRefundService.lambdaQuery().eq(TChargingOrderRefund::getRefundStatus, 2).list(); Long userId = tokenService.getLoginUser().getUserid(); // 查询当前登陆人按钮权限 @@ -160,6 +157,7 @@ BigDecimal sharingAmountTotal = new BigDecimal("0"); BigDecimal chargingCapacityTotal = new BigDecimal("0"); BigDecimal discountTotal = new BigDecimal("0"); + List<TChargingOrderAccountingStrategy> list3 = chargingOrderAccountingStrategyService.list(); for (ChargingBillListVO chargingBillListVO : list) { @@ -179,7 +177,10 @@ break; case 2: temp = "各个站点账单"; - temp1 = siteClient.getSiteByIds(Arrays.asList(chargingBillListVO.getSiteId())).getData().get(0).getName(); + Site site = siteList.stream().filter(e -> e.getId().equals(chargingBillListVO.getSiteId())).findFirst().orElse(null); + if (site!=null){ + temp1 =site.getName(); + } break; } chargingBillVO.setCategory(temp); @@ -204,10 +205,15 @@ // 获取该月份的最后一天 LocalDateTime lastDayOfMonth = localDate.with(TemporalAdjusters.lastDayOfMonth()); LocalDateTime firstDayOfMonth = localDate.with(TemporalAdjusters.firstDayOfMonth()); - List<TChargingOrder> tChargingOrders = total.stream().filter(e -> chargingBillListVO.getType() == 2 ? - e.getSiteId().equals(chargingBillListVO.getSiteId()) : true && - e.getPayTime().isBefore(lastDayOfMonth.withHour(23).withMinute(59).withSecond(59)) - && e.getPayTime().isAfter(firstDayOfMonth.withHour(0).withMinute(0).withSecond(0))).collect(Collectors.toList()); + List<TChargingOrder> tChargingOrders = new ArrayList<>(); + if (chargingBillListVO.getType() == 2){ + tChargingOrders = total.stream().filter(e -> e.getSiteId().equals(chargingBillListVO.getSiteId()) && e.getPayTime().isBefore(lastDayOfMonth.withHour(23).withMinute(59).withSecond(59)) + && e.getPayTime().isAfter(firstDayOfMonth.withHour(0).withMinute(0).withSecond(0))).collect(Collectors.toList()); + }else{ + tChargingOrders = total.stream().filter(e -> e.getPayTime().isBefore(lastDayOfMonth.withHour(23).withMinute(59).withSecond(59)) + && e.getPayTime().isAfter(firstDayOfMonth.withHour(0).withMinute(0).withSecond(0))).collect(Collectors.toList()); + } + int chargingSecond = 0; @@ -223,6 +229,7 @@ chargingBillVO.setCategory(""); chargingBillVO.setExportList(tChargingOrders); for (TChargingOrder tChargingOrder : tChargingOrders) { + Site site1 = siteList.stream().filter(site -> site.getId().equals(tChargingOrder.getSiteId())).findFirst().orElse(null); if (site1!=null){ chargingBillVO.setSiteName(site1.getName()); @@ -246,26 +253,29 @@ tChargingOrder.setOrderClassification1("线上订单"); tChargingOrder.setRechargePaymentType1("预付"); tChargingOrder.setChargingType("充电桩接口充电服务"); - switch (tChargingOrder.getStatus()){ - case 1: - tChargingOrder.setStatus1("等待中"); - break; - case 2: - tChargingOrder.setStatus1("启动中"); - break; - case 3: - tChargingOrder.setStatus1("充电中"); - break; - case 4: - tChargingOrder.setStatus1("停止中"); - break; - case 5: - tChargingOrder.setStatus1("已结束"); - break; - case 0: - tChargingOrder.setStatus1("未知"); - break; + if (tChargingOrder.getStatus()!=null){ + switch (tChargingOrder.getStatus()){ + case 1: + tChargingOrder.setStatus1("等待中"); + break; + case 2: + tChargingOrder.setStatus1("启动中"); + break; + case 3: + tChargingOrder.setStatus1("充电中"); + break; + case 4: + tChargingOrder.setStatus1("停止中"); + break; + case 5: + tChargingOrder.setStatus1("已结束"); + break; + case 0: + tChargingOrder.setStatus1("未知"); + break; + } } + if (tChargingOrder.getEndMode()!=null){ switch (tChargingOrder.getEndMode()){ case 1: @@ -282,13 +292,11 @@ break; } } - BigDecimal add = tChargingOrder.getElectrovalence().add(tChargingOrder.getServiceCharge()); - tChargingOrder.setTotalAmount(add.toString()); tChargingOrder.setDiscount(tChargingOrder.getCouponDiscountAmount()!=null?tChargingOrder.getCouponDiscountAmount().toString():"0"); - UploadRealTimeMonitoringData data5 = uploadRealTimeMonitoringDataClient.chargingOrderInfo(tChargingOrder.getCode()).getData(); - if (data5!=null){ - tChargingOrder.setEndSoc(data5.getSoc().toString()); - } +// UploadRealTimeMonitoringData data5 = uploadRealTimeMonitoringDataClient.chargingOrderInfo(tChargingOrder.getCode()).getData(); +// if (data5!=null){ +// tChargingOrder.setEndSoc(data5.getSoc().toString()); +// } if (tChargingOrder.getStartTime()!=null && tChargingOrder.getEndTime()!=null){ LocalDateTime startTime = tChargingOrder.getStartTime(); LocalDateTime endTime = tChargingOrder.getEndTime(); @@ -326,18 +334,29 @@ }else{ tChargingOrder.setLicensePlate(tChargingOrder.getPlateNum()); } + List<TChargingOrderAccountingStrategy> list4 = list3.stream().filter(e -> e.getChargingOrderId().equals(tChargingOrder.getId())).collect(Collectors.toList()); + BigDecimal electronic_reduce = list4.stream().map(TChargingOrderAccountingStrategy::getPeriodElectricPrice).reduce(BigDecimal.ZERO, BigDecimal::add); + BigDecimal service_reduce = list4.stream().map(TChargingOrderAccountingStrategy::getPeriodServicePrice).reduce(BigDecimal.ZERO, BigDecimal::add); + BigDecimal charging_capacity = list4.stream().map(TChargingOrderAccountingStrategy::getChargingCapacity).reduce(BigDecimal.ZERO, BigDecimal::add); + tChargingOrder.setTotalAmount(electronic_reduce.add(service_reduce)+""); // 累加实收金额 支付结算金额 - if (tChargingOrder.getRechargeAmount()!=null){ - paymentAmount = paymentAmount.add(tChargingOrder.getPaymentAmount()); - } + if (tChargingOrder.getOrderSource()!=2){ + paymentAmount = paymentAmount.add(electronic_reduce.add(service_reduce)); + // 累加累计服务费 + serviceCharge = serviceCharge.add(service_reduce); + }else{ + paymentAmount = paymentAmount.add(electronic_reduce.add(service_reduce.multiply(new BigDecimal("0.8")))); + // 累加累计服务费 + serviceCharge = serviceCharge.add(service_reduce.multiply(new BigDecimal("0.8"))); + } + // 总金额 if (tChargingOrder.getRechargeAmount()!=null){ orderAmount = orderAmount.add(tChargingOrder.getRechargeAmount()); } // 累加累计电费 - if (tChargingOrder.getElectrovalence()!=null){ - electrovalence = electrovalence.add(tChargingOrder.getElectrovalence()); - } + electrovalence = electrovalence.add(electronic_reduce); + if (tChargingOrder.getRechargeAmount()!=null){ rechargeAmount = rechargeAmount.add(tChargingOrder.getRechargeAmount()); } @@ -345,24 +364,17 @@ for (TChargingOrderRefund tChargingOrderRefund : list2) { refundAmount = refundAmount.add(tChargingOrderRefund.getRefundTotalAmount()); } - // 累加累计服务费 - if (tChargingOrder.getServiceCharge()!=null){ - serviceCharge = serviceCharge.add(tChargingOrder.getServiceCharge()); - } // 累加平台手续费 if (tChargingOrder.getOrderAmount()!=null){ commissionAmount = commissionAmount.add(tChargingOrder.getRechargeAmount().multiply(BigDecimal.valueOf(0.006)) .setScale(2,BigDecimal.ROUND_DOWN)); } // 累加平台分佣 - if (tChargingOrder.getSharingAmount()!=null){ - sharingAmount = sharingAmount.add(tChargingOrder.getSharingAmount()); + if (tChargingOrder.getOrderSource()==2){ + sharingAmount = sharingAmount.add(service_reduce.multiply(BigDecimal.valueOf(0.2)).setScale(2,BigDecimal.ROUND_DOWN)); } // 累加充电度数 - if (tChargingOrder.getChargingCapacity()!=null){ - chargingCapacity = chargingCapacity.add(tChargingOrder.getChargingCapacity()); - } - + chargingCapacity = chargingCapacity.add(charging_capacity); } // 将chargingSecond 这是以秒为单位存放的总秒数 将其转化为xx小时xx分钟xx秒 int hours = chargingSecond / 3600; @@ -375,7 +387,7 @@ chargingBillVO.setPaymentAmount(BigDecimal.ZERO); } - chargingBillListVO.setPaymentAmount(paymentAmount.subtract(sharingAmount)); + chargingBillListVO.setPaymentAmount(paymentAmount); chargingBillListVO.setOrderAmount(refundAmount); chargingBillListVO.setRefundAmount(refundAmount == null?BigDecimal.ZERO:refundAmount); chargingBillListVO.setElectrovalence(electrovalence == null?BigDecimal.ZERO:electrovalence); @@ -383,7 +395,7 @@ chargingBillListVO.setCommissionAmount(commissionAmount == null?BigDecimal.ZERO:commissionAmount.setScale(2,BigDecimal.ROUND_DOWN)); chargingBillListVO.setSharingAmount(sharingAmount == null?BigDecimal.ZERO:sharingAmount); chargingBillListVO.setChargingCapacity(chargingCapacity == null?BigDecimal.ZERO:chargingCapacity); - chargingBillListVO.setBillMoney(orderAmount + chargingBillListVO.setBillMoney(paymentAmount .subtract(commissionAmount.setScale(2,BigDecimal.ROUND_DOWN)).subtract(sharingAmount).setScale(2, BigDecimal.ROUND_DOWN)); switch (chargingBillListVO.getType()){ case 1: @@ -404,11 +416,15 @@ BigDecimal bigDecimal = new BigDecimal("0"); int i = 0; for (ChargingBillListVO chargingBillListVO : list1) { - if (chargingBillListVO.getSiteId()!=0&&!siteIds.contains(chargingBillListVO.getSiteId())){ - continue; - } - if (chargingBillListVO.getType()==1){ - continue; + if (dto.getType() == 1){ + + }else{ + if (chargingBillListVO.getSiteId()!=0&&!siteIds.contains(chargingBillListVO.getSiteId())){ + continue; + } + if (chargingBillListVO.getType()==1){ + continue; + } } i++; LocalDateTime billTime = chargingBillListVO.getBillTime(); @@ -427,23 +443,35 @@ // 获取该月份的最后一天 LocalDateTime lastDayOfMonth = localDate.with(TemporalAdjusters.lastDayOfMonth()); LocalDateTime firstDayOfMonth = localDate.with(TemporalAdjusters.firstDayOfMonth()); - List<TChargingOrder> tChargingOrders = total.stream().filter(e -> chargingBillListVO.getType() == 2 ? - e.getSiteId().equals(chargingBillListVO.getSiteId()) : true && - e.getPayTime().isBefore(lastDayOfMonth.withHour(23).withMinute(59).withSecond(59)) - && e.getPayTime().isAfter(firstDayOfMonth.withHour(0).withMinute(0).withSecond(0))).collect(Collectors.toList()); + List<TChargingOrder> tChargingOrders = new ArrayList<>(); + if (chargingBillListVO.getType() == 2){ + tChargingOrders = total.stream().filter(e -> e.getSiteId().equals(chargingBillListVO.getSiteId()) && e.getPayTime().isBefore(lastDayOfMonth.withHour(23).withMinute(59).withSecond(59)) + && e.getPayTime().isAfter(firstDayOfMonth.withHour(0).withMinute(0).withSecond(0))).collect(Collectors.toList()); + }else{ + tChargingOrders = total.stream().filter(e -> e.getPayTime().isBefore(lastDayOfMonth.withHour(23).withMinute(59).withSecond(59)) + && e.getPayTime().isAfter(firstDayOfMonth.withHour(0).withMinute(0).withSecond(0))).collect(Collectors.toList()); + } for (TChargingOrder tChargingOrder : tChargingOrders) { - if (tChargingOrder.getOrderAmount()!=null){ - paymentAmountTotal = paymentAmountTotal.add(tChargingOrder.getPaymentAmount()); + List<TChargingOrderAccountingStrategy> list4 = list3.stream().filter(e -> e.getChargingOrderId().equals(tChargingOrder.getId())).collect(Collectors.toList()); + BigDecimal electronic_reduce = list4.stream().map(TChargingOrderAccountingStrategy::getPeriodElectricPrice).reduce(BigDecimal.ZERO, BigDecimal::add); + BigDecimal service_reduce = list4.stream().map(TChargingOrderAccountingStrategy::getPeriodServicePrice).reduce(BigDecimal.ZERO, BigDecimal::add); + BigDecimal charging_capacity = list4.stream().map(TChargingOrderAccountingStrategy::getChargingCapacity).reduce(BigDecimal.ZERO, BigDecimal::add); + tChargingOrder.setTotalAmount(electronic_reduce.add(service_reduce)+""); + if (tChargingOrder.getOrderSource()!=2){ + paymentAmountTotal = paymentAmountTotal.add(electronic_reduce.add(service_reduce)); + // 累加累计服务费 + serviceChargeTotal = serviceChargeTotal.add(service_reduce); + }else{ + paymentAmountTotal = paymentAmountTotal.add(electronic_reduce.add(service_reduce.multiply(new BigDecimal("0.8")))); + // 累加累计服务费 + serviceChargeTotal = serviceChargeTotal.add(service_reduce.multiply(new BigDecimal("0.8"))); } - // 累加订单金额 if (tChargingOrder.getRechargeAmount()!=null){ orderAmountTotal = orderAmountTotal.add(tChargingOrder.getRechargeAmount()); } // 累加累计电费 - if (tChargingOrder.getElectrovalence()!=null){ - electrovalenceTotal = electrovalenceTotal.add(tChargingOrder.getElectrovalence()); - } + electrovalenceTotal = electrovalenceTotal.add(electronic_reduce); List<TChargingOrderRefund> list2 = totalRefund.stream().filter(e -> e.getChargingOrderId().equals(tChargingOrder.getId())).collect(Collectors.toList()); for (TChargingOrderRefund tChargingOrderRefund : list2) { refundAmountTotal =refundAmountTotal.add(tChargingOrderRefund.getRefundAmount()); @@ -453,24 +481,19 @@ tChargingOrder.setRefundTime1(DateUtils.localDateTimeToString(tChargingOrderRefund.getRefundTime())); bigDecimal = bigDecimal.add(tChargingOrderRefund.getRefundAmount()); } - // 累加累计服务费 - if (tChargingOrder.getServiceCharge()!=null){ - serviceChargeTotal = serviceChargeTotal.add(tChargingOrder.getServiceCharge()); - } + // 累加平台手续费 if (tChargingOrder.getOrderAmount()!=null){ commissionAmountTotal = commissionAmountTotal.add(tChargingOrder.getRechargeAmount().multiply(new BigDecimal("0.006")) .setScale(2,BigDecimal.ROUND_DOWN)); } // 累加平台分佣 - if (tChargingOrder.getSharingAmount()!=null){ - sharingAmountTotal = sharingAmountTotal.add(tChargingOrder.getSharingAmount()); + if (tChargingOrder.getOrderSource()==2 ){ + sharingAmountTotal = sharingAmountTotal.add(service_reduce.multiply(BigDecimal.valueOf(0.2)).setScale(2,BigDecimal.ROUND_DOWN)); } // 累加充电度数 - if (tChargingOrder.getElectricity()!=null){ + chargingCapacityTotal = chargingCapacityTotal.add(charging_capacity); - chargingCapacityTotal = chargingCapacityTotal.add(tChargingOrder.getElectricity()); - } // 累加优惠金额 if (tChargingOrder.getCouponDiscountAmount()!=null){ discountTotal = discountTotal.add(tChargingOrder.getCouponDiscountAmount()); @@ -501,7 +524,8 @@ chargingBillVO.setList(pageInfo); return chargingBillVO; } - + @Resource + private TChargingOrderAccountingStrategyService chargingOrderAccountingStrategyService; @Override public ChargingBillVO chargingBillList(ChargingListQuery dto) { @@ -521,13 +545,15 @@ startTime2 = split[1]; } List<TChargingOrder> total = chargingOrderList.selectList(new LambdaQueryWrapper<>(TChargingOrder.class) - .eq(TChargingOrder::getRechargePaymentStatus, 2)); + .isNotNull(TChargingOrder::getPayTime)); PageInfo<ChargingBillListVO> pageInfo = new PageInfo<>(dto.getPageCurr(),dto.getPageSize()); List<Site> data6 = siteClient.getSiteAll().getData(); List<TChargingGun> gunList = chargingGunClient.getAllGun().getData(); List<TChargingPile> pileList = chargingGunClient.getAllPile().getData(); List<TAppUser> userList = appUserClient.getAllUser().getData(); List<TAppUserCar> carList = appUserCarClient.getAllCar().getData(); + List<TChargingOrderAccountingStrategy> list3 = chargingOrderAccountingStrategyService.list(); + Long userId = tokenService.getLoginUser().getUserid(); // 查询当前登陆人按钮权限 SysUser sysUser = sysUserClient.getSysUser(tokenService.getLoginUser().getUserid()).getData(); @@ -614,7 +640,10 @@ break; case 2: temp = "各个站点账单"; - temp1 = data6.stream().filter(e->e.getId().equals(chargingBillListVO.getSiteId())).findFirst().orElse(new Site()).getName(); + Site site = data6.stream().filter(e -> e.getId().equals(chargingBillListVO.getSiteId())).findFirst().orElse(null); + if(site!=null){ + temp1 = site.getName(); + } break; } chargingBillVO.setCategory(temp); @@ -639,10 +668,14 @@ // 获取该月份的最后一天 LocalDateTime lastDayOfMonth = localDate.with(TemporalAdjusters.lastDayOfMonth()); LocalDateTime firstDayOfMonth = localDate.with(TemporalAdjusters.firstDayOfMonth()); - List<TChargingOrder> tChargingOrders = total.stream().filter(e -> chargingBillListVO.getType() == 2 ? - e.getSiteId().equals(chargingBillListVO.getSiteId()) : true && - e.getPayTime().isBefore(lastDayOfMonth.withHour(23).withMinute(59).withSecond(59)) - && e.getPayTime().isAfter(firstDayOfMonth.withHour(0).withMinute(0).withSecond(0))).collect(Collectors.toList()); + List<TChargingOrder> tChargingOrders = new ArrayList<>(); + if (chargingBillListVO.getType() == 2){ + tChargingOrders = total.stream().filter(e -> e.getSiteId().equals(chargingBillListVO.getSiteId()) && e.getPayTime().isBefore(lastDayOfMonth.withHour(23).withMinute(59).withSecond(59)) + && e.getPayTime().isAfter(firstDayOfMonth.withHour(0).withMinute(0).withSecond(0))).collect(Collectors.toList()); + }else{ + tChargingOrders = total.stream().filter(e -> e.getPayTime().isBefore(lastDayOfMonth.withHour(23).withMinute(59).withSecond(59)) + && e.getPayTime().isAfter(firstDayOfMonth.withHour(0).withMinute(0).withSecond(0))).collect(Collectors.toList()); + } int chargingSecond = 0; BigDecimal paymentAmount = new BigDecimal("0"); BigDecimal orderAmount = new BigDecimal("0"); @@ -679,26 +712,29 @@ tChargingOrder.setOrderClassification1("线上订单"); tChargingOrder.setRechargePaymentType1("预付"); tChargingOrder.setChargingType("充电桩接口充电服务"); - switch (tChargingOrder.getStatus()){ - case 1: - tChargingOrder.setStatus1("等待中"); - break; - case 2: - tChargingOrder.setStatus1("启动中"); - break; - case 3: - tChargingOrder.setStatus1("充电中"); - break; - case 4: - tChargingOrder.setStatus1("停止中"); - break; - case 5: - tChargingOrder.setStatus1("已结束"); - break; - case 0: - tChargingOrder.setStatus1("未知"); - break; + if (tChargingOrder.getStatus()!=null){ + switch (tChargingOrder.getStatus()){ + case 1: + tChargingOrder.setStatus1("等待中"); + break; + case 2: + tChargingOrder.setStatus1("启动中"); + break; + case 3: + tChargingOrder.setStatus1("充电中"); + break; + case 4: + tChargingOrder.setStatus1("停止中"); + break; + case 5: + tChargingOrder.setStatus1("已结束"); + break; + case 0: + tChargingOrder.setStatus1("未知"); + break; + } } + if (tChargingOrder.getEndMode()!=null){ switch (tChargingOrder.getEndMode()){ case 1: @@ -715,8 +751,7 @@ break; } } - BigDecimal add = tChargingOrder.getElectrovalence().add(tChargingOrder.getServiceCharge()); - tChargingOrder.setTotalAmount(add.toString()); + tChargingOrder.setDiscount(tChargingOrder.getCouponDiscountAmount()!=null?tChargingOrder.getCouponDiscountAmount().toString():"0"); if (tChargingOrder.getStartTime()!=null && tChargingOrder.getEndTime()!=null){ LocalDateTime startTime = tChargingOrder.getStartTime(); @@ -758,43 +793,46 @@ tChargingOrder.setUserName(data3.getName()); tChargingOrder.setPhone(data3.getPhone()); } - if ( tChargingOrder.getPaymentAmount()!=null&&(!tChargingOrder.getOrderSource().equals(2))){ + List<TChargingOrderAccountingStrategy> list4 = list3.stream().filter(e -> e.getChargingOrderId().equals(tChargingOrder.getId())).collect(Collectors.toList()); + BigDecimal electronic_reduce = list4.stream().map(TChargingOrderAccountingStrategy::getPeriodElectricPrice).reduce(BigDecimal.ZERO, BigDecimal::add); + BigDecimal service_reduce = list4.stream().map(TChargingOrderAccountingStrategy::getPeriodServicePrice).reduce(BigDecimal.ZERO, BigDecimal::add); + BigDecimal charging_capacity = list4.stream().map(TChargingOrderAccountingStrategy::getChargingCapacity).reduce(BigDecimal.ZERO, BigDecimal::add); + + if ( !tChargingOrder.getOrderSource().equals(2)){ // 实收 - paymentAmount = paymentAmount.add(tChargingOrder.getPaymentAmount()); + paymentAmount = paymentAmount.add(electronic_reduce).add(service_reduce); + BigDecimal add = electronic_reduce.add(service_reduce); + tChargingOrder.setTotalAmount(add.toString()); } // 总金额 if (tChargingOrder.getRechargeAmount()!=null){ orderAmount = orderAmount.add(tChargingOrder.getRechargeAmount()); } // 累加累计电费 - if (tChargingOrder.getElectrovalence()!=null){ - electrovalence = electrovalence.add(tChargingOrder.getElectrovalence()); - } + electrovalence = electrovalence.add(electronic_reduce); if (tChargingOrder.getRefundAmount()!=null && tChargingOrder.getRefundStatus() !=null && tChargingOrder.getRefundStatus() == 2){ refundAmount = refundAmount.add(tChargingOrder.getRefundAmount()); } // 累加累计服务费 - if (tChargingOrder.getServiceCharge()!=null){ - if (tChargingOrder.getOrderSource().equals(2)) { - serviceCharge = serviceCharge.add(tChargingOrder.getServiceCharge().multiply(new BigDecimal("0.2")).setScale(2, BigDecimal.ROUND_DOWN)); - // 累加平台分佣 - sharingAmount = sharingAmount.add(tChargingOrder.getServiceCharge().multiply(new BigDecimal("0.2")).setScale(2,BigDecimal.ROUND_DOWN)); - // 累加实收 - paymentAmount = paymentAmount.add(tChargingOrder.getServiceCharge().multiply(new BigDecimal("0.2")).setScale(2,BigDecimal.ROUND_DOWN)); - }else { - serviceCharge = serviceCharge.add(tChargingOrder.getServiceCharge()); - } - } - // 累加平台手续费 - if (tChargingOrder.getOrderAmount()!=null){ - commissionAmount = commissionAmount.add(tChargingOrder.getRechargeAmount().multiply(BigDecimal.valueOf(0.006)) - .setScale(2,BigDecimal.ROUND_DOWN)); - } - // 累加充电度数 - if (tChargingOrder.getChargingCapacity()!=null){ - chargingCapacity = chargingCapacity.add(tChargingOrder.getChargingCapacity()); + if (tChargingOrder.getOrderSource().equals(2)) { + serviceCharge = serviceCharge.add(service_reduce.multiply(new BigDecimal("0.8")).setScale(2, BigDecimal.ROUND_DOWN)); + // 累加平台分佣 + sharingAmount = sharingAmount.add(service_reduce.multiply(new BigDecimal("0.2")).setScale(2,BigDecimal.ROUND_DOWN)); + // 累加实收 + paymentAmount = paymentAmount.add(electronic_reduce).add(service_reduce.multiply(new BigDecimal("0.8")).setScale(2,BigDecimal.ROUND_DOWN)); + BigDecimal add = electronic_reduce.add(service_reduce.multiply(new BigDecimal("0.8"))); + tChargingOrder.setTotalAmount(add.toString()); + }else { + serviceCharge = serviceCharge.add(service_reduce); + } + + // 累加平台手续费 + if (tChargingOrder.getRechargeAmount()!=null){ + commissionAmount = commissionAmount.add(tChargingOrder.getRechargeAmount().multiply(BigDecimal.valueOf(0.006)).setScale(2,BigDecimal.ROUND_DOWN)); } + // 累加充电度数 + chargingCapacity = chargingCapacity.add(charging_capacity); } // 将chargingSecond 这是以秒为单位存放的总秒数 将其转化为xx小时xx分钟xx秒 int hours = chargingSecond / 3600; @@ -828,8 +866,17 @@ chargingBillListVO.setChargingSecond(chargingSecond); } for (ChargingBillListVO chargingBillListVO : list1) { - if (chargingBillListVO.getSiteId()!=0&&!siteIds.contains(chargingBillListVO.getSiteId())){ - continue; + if (dto.getType() == 1){ + if (chargingBillListVO.getSiteId()!=0){ + continue; + } + }else{ + if (chargingBillListVO.getSiteId()!=0&&!siteIds.contains(chargingBillListVO.getSiteId())){ + continue; + } + if (chargingBillListVO.getType()==1){ + continue; + } } if (roleType == 2){ if (chargingBillListVO.getSiteId()==0){ @@ -845,7 +892,6 @@ chargingBillListVO.setUid(chargingBillListVO.getId().toString()); // 根据账单的出账时间 查询上个月的充电订单 LocalDateTime localDate = chargingBillListVO.getBillTime().minusMonths(1); -// LocalDateTime localDate = chargingBillListVO.getBillTime().minusDays(1); // 账单周期 chargingBillListVO.setBillWeek(localDate.format(java.time.format.DateTimeFormatter.ofPattern("yyyy-MM"))); // 获取 LocalDate 对象 @@ -853,10 +899,15 @@ // 获取该月份的最后一天 LocalDateTime lastDayOfMonth = localDate.with(TemporalAdjusters.lastDayOfMonth()); LocalDateTime firstDayOfMonth = localDate.with(TemporalAdjusters.firstDayOfMonth()); - List<TChargingOrder> tChargingOrders = total.stream().filter(e -> chargingBillListVO.getType() == 2 ? - e.getSiteId().equals(chargingBillListVO.getSiteId()) : true && - e.getPayTime().isBefore(lastDayOfMonth.withHour(23).withMinute(59).withSecond(59)) - && e.getPayTime().isAfter(firstDayOfMonth.withHour(0).withMinute(0).withSecond(0))).collect(Collectors.toList()); + + List<TChargingOrder> tChargingOrders = new ArrayList<>(); + if (chargingBillListVO.getType() == 2){ + tChargingOrders = total.stream().filter(e -> e.getSiteId().equals(chargingBillListVO.getSiteId()) && e.getPayTime().isBefore(lastDayOfMonth.withHour(23).withMinute(59).withSecond(59)) + && e.getPayTime().isAfter(firstDayOfMonth.withHour(0).withMinute(0).withSecond(0))).collect(Collectors.toList()); + }else{ + tChargingOrders = total.stream().filter(e -> e.getPayTime().isBefore(lastDayOfMonth.withHour(23).withMinute(59).withSecond(59)) + && e.getPayTime().isAfter(firstDayOfMonth.withHour(0).withMinute(0).withSecond(0))).collect(Collectors.toList()); + } orderCount+=tChargingOrders.size(); BigDecimal paymentAmount = new BigDecimal("0"); BigDecimal orderAmount = new BigDecimal("0"); @@ -867,12 +918,15 @@ BigDecimal chargingCapacity = new BigDecimal("0"); chargingBillListVO.setOrderCount(tChargingOrders.size()); for (TChargingOrder tChargingOrder : tChargingOrders) { + List<TChargingOrderAccountingStrategy> list4 = list3.stream().filter(e -> e.getChargingOrderId().equals(tChargingOrder.getId())).collect(Collectors.toList()); + BigDecimal electronic_reduce = list4.stream().map(TChargingOrderAccountingStrategy::getPeriodElectricPrice).reduce(BigDecimal.ZERO, BigDecimal::add); + BigDecimal service_reduce = list4.stream().map(TChargingOrderAccountingStrategy::getPeriodServicePrice).reduce(BigDecimal.ZERO, BigDecimal::add); + BigDecimal charging_capacity = list4.stream().map(TChargingOrderAccountingStrategy::getChargingCapacity).reduce(BigDecimal.ZERO, BigDecimal::add); // 累加实收金额 - if ( tChargingOrder.getPaymentAmount()!=null&&(!tChargingOrder.getOrderSource().equals(2))){ - paymentAmount = paymentAmount.add(tChargingOrder.getPaymentAmount()); - paymentAmountTotal = paymentAmountTotal.add(tChargingOrder.getPaymentAmount()); + if (!tChargingOrder.getOrderSource().equals(2)){ + paymentAmount = paymentAmount.add(electronic_reduce.add(service_reduce)); + paymentAmountTotal = paymentAmountTotal.add(electronic_reduce.add(service_reduce)); } - // 累加订单金额 if (tChargingOrder.getRechargeAmount()!=null){ orderAmount = orderAmount.add(tChargingOrder.getRechargeAmount()); @@ -880,42 +934,35 @@ } // 累加累计电费 if (tChargingOrder.getElectrovalence()!=null){ - electrovalence = electrovalence.add(tChargingOrder.getElectrovalence()); - electrovalenceTotal = electrovalenceTotal.add(tChargingOrder.getElectrovalence()); + electrovalence = electrovalence.add(electronic_reduce); + electrovalenceTotal = electrovalenceTotal.add(electronic_reduce); } if (tChargingOrder.getRefundAmount()!=null && tChargingOrder.getRefundStatus() !=null && tChargingOrder.getRefundStatus() == 2){ refundAmountTotal = refundAmountTotal.add(tChargingOrder.getRefundAmount()); } // 累加累计服务费 - if (tChargingOrder.getServiceCharge()!=null){ if (tChargingOrder.getOrderSource().equals(2)) { - serviceCharge = serviceCharge.add(tChargingOrder.getServiceCharge().multiply(new BigDecimal("0.2")).setScale(2, BigDecimal.ROUND_DOWN)); - serviceChargeTotal = serviceChargeTotal.add(tChargingOrder.getServiceCharge().multiply(new BigDecimal("0.2")).setScale(2, BigDecimal.ROUND_DOWN)); + serviceCharge = serviceCharge.add(service_reduce.multiply(new BigDecimal("0.8")).setScale(2, BigDecimal.ROUND_DOWN)); + serviceChargeTotal = serviceChargeTotal.add(service_reduce.multiply(new BigDecimal("0.8")).setScale(2, BigDecimal.ROUND_DOWN)); // 累加平台分佣 - sharingAmount = sharingAmount.add(tChargingOrder.getServiceCharge().multiply(new BigDecimal("0.2")).setScale(2, BigDecimal.ROUND_DOWN)); - sharingAmountTotal = sharingAmountTotal.add(tChargingOrder.getServiceCharge().multiply(new BigDecimal("0.2")).setScale(2, BigDecimal.ROUND_DOWN)); + sharingAmount = sharingAmount.add(service_reduce.multiply(new BigDecimal("0.2")).setScale(2, BigDecimal.ROUND_DOWN)); + sharingAmountTotal = sharingAmountTotal.add(service_reduce.multiply(new BigDecimal("0.2")).setScale(2, BigDecimal.ROUND_DOWN)); // 累加实收 - paymentAmount = paymentAmount.add(tChargingOrder.getServiceCharge().multiply(new BigDecimal("0.2")).setScale(2,BigDecimal.ROUND_DOWN)); - paymentAmountTotal = paymentAmountTotal.add(tChargingOrder.getServiceCharge().multiply(new BigDecimal("0.2")).setScale(2,BigDecimal.ROUND_DOWN)); + paymentAmount = paymentAmount.add(electronic_reduce.add(service_reduce.multiply(new BigDecimal("0.8")).setScale(2,BigDecimal.ROUND_DOWN))); + paymentAmountTotal = paymentAmountTotal.add(electronic_reduce.add(service_reduce.multiply(new BigDecimal("0.8")).setScale(2,BigDecimal.ROUND_DOWN))); }else{ - serviceCharge = serviceCharge.add(tChargingOrder.getServiceCharge()); - serviceChargeTotal = serviceChargeTotal.add(tChargingOrder.getServiceCharge()); + serviceCharge = serviceCharge.add(service_reduce); + serviceChargeTotal = serviceChargeTotal.add(service_reduce); } - - } - - // 累加平台手续费 + // 累加平台手续费 if (tChargingOrder.getOrderAmount()!=null){ commissionAmount = commissionAmount.add(tChargingOrder.getRechargeAmount().multiply(new BigDecimal("0.006")).setScale(2,BigDecimal.ROUND_DOWN)); - commissionAmountTotal = commissionAmountTotal.add(tChargingOrder.getRechargeAmount().multiply(new BigDecimal("0.006")) - .setScale(2,BigDecimal.ROUND_DOWN)); + commissionAmountTotal = commissionAmountTotal.add(tChargingOrder.getRechargeAmount().multiply(new BigDecimal("0.006")).setScale(2,BigDecimal.ROUND_DOWN)); } // 累加充电度数 - if (tChargingOrder.getElectricity()!=null){ - chargingCapacity = chargingCapacity.add(tChargingOrder.getElectricity()); - chargingCapacityTotal = chargingCapacityTotal.add(tChargingOrder.getElectricity()); - } + chargingCapacity = chargingCapacity.add(charging_capacity); + chargingCapacityTotal = chargingCapacityTotal.add(charging_capacity); // 累加优惠金额 if (tChargingOrder.getCouponDiscountAmount()!=null){ discountTotal = discountTotal.add(tChargingOrder.getCouponDiscountAmount()); -- Gitblit v1.7.1