明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Pu Zhibing
2025-03-04 9380492f1821e0306ea4fa481b49e14bb09f433a 
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java


@@ -67,6 +67,7 @@


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;


import org.springframework.util.StringUtils;




@@ -914,9 +915,15 @@


            amount.setTotal(rechargeAmount.multiply(new BigDecimal(100)).intValue());


            amount.setCurrency("CNY");


            model.setAmount(amount);


            R<String> orderR = wxPaymentClient.refundOrderR(model);


            R<Map<String, Object>> orderR = wxPaymentClient.refundOrderR(model);


            if(200 == orderR.getCode()){


               chargingOrderRefundService.save(chargingOrderRefund);


               //手续费


               Map<String, Object> amount1 = (Map<String, Object>) orderR.getData().get("amount");


               Object refund_fee1 = amount1.get("refund_fee");


               BigDecimal refund_fee = new BigDecimal(null == refund_fee1 ? "0" : refund_fee1.toString()).divide(new BigDecimal(100));


               chargingOrderRefund.setRefundFee(refund_fee);


               chargingOrderRefundService.updateById(chargingOrderRefund);


            }


         }


         if(2 == rechargePaymentType){


@@ -1322,8 +1329,8 @@


            }




         }


         chargingOrderVO.setCommissionAmount(chargingOrderVO.getOrderAmount()!=null?chargingOrderVO.getOrderAmount().multiply(new BigDecimal("0.006")):new BigDecimal("0"));


         chargingOrderVO.setPlatFormMoney(chargingOrderVO.getOrderAmount()!=null?chargingOrderVO.getOrderAmount().multiply(new BigDecimal("0.006")).setScale(2,BigDecimal.ROUND_DOWN):new BigDecimal("0"));


         chargingOrderVO.setCommissionAmount(chargingOrderVO.getRechargeAmount()!=null?chargingOrderVO.getRechargeAmount().multiply(new BigDecimal("0.006")):new BigDecimal("0"));


         chargingOrderVO.setPlatFormMoney(chargingOrderVO.getRechargeAmount()!=null?chargingOrderVO.getRechargeAmount().multiply(new BigDecimal("0.006")).setScale(2,BigDecimal.ROUND_DOWN):new BigDecimal("0"));


         chargingOrderVO.setUid(chargingOrderVO.getId()+"");


         TChargingGun data3 = allGun.stream().filter(e->e.getId().equals(chargingOrderVO.getChargingGunId())).findFirst().orElse(null);


         TChargingPile data2 = allPile.stream().filter(e->e.getId().equals(chargingOrderVO.getChargingPileId())).findFirst().orElse(null);


@@ -1377,7 +1384,9 @@




      for (ChargingOrderVO chargingOrderVO : list1) {


         paymentMoney= paymentMoney.add(chargingOrderVO.getPaymentAmount()!=null?chargingOrderVO.getPaymentAmount():new BigDecimal("0"));


         commissionMoney = commissionMoney.add(chargingOrderVO.getOrderAmount()!=null?chargingOrderVO.getOrderAmount().multiply(new BigDecimal("0.006")):new BigDecimal("0"));


         if (chargingOrderVO.getRechargeAmount()!=null){


            commissionMoney = commissionMoney.add(chargingOrderVO.getRechargeAmount().multiply(new BigDecimal("0.006")).setScale(2,BigDecimal.ROUND_DOWN));


         }


         if (chargingOrderVO.getChargingCapacity()!=null){


            total = total.add(chargingOrderVO.getElectricity()!=null?chargingOrderVO.getElectricity():new BigDecimal("0"));


         }


@@ -1398,7 +1407,8 @@


      }


      tCharingOrderVO.setTotal(total);


      tCharingOrderVO.setTime(time);


      tCharingOrderVO.setIncome(paymentMoney.subtract(commissionMoney));


//      tCharingOrderVO.setIncome(paymentMoney.subtract(commissionMoney));


      tCharingOrderVO.setIncome(paymentMoney);


      tCharingOrderVO.setElectronicMoney(electronicMoney);


      tCharingOrderVO.setServiceMoney(serviceMoney);


      pageInfo.setRecords(list);


@@ -1576,7 +1586,7 @@


         chargingOrderListVO.setChargingCapacity(chargingOrderListVO.getElectricity());


         BigDecimal bigDecimal = new BigDecimal("0.006");


         if (chargingOrderListVO.getOrderAmount()!=null){


            chargingOrderListVO.setCommissionAmount(chargingOrderListVO.getPaymentAmount().multiply(bigDecimal));


            chargingOrderListVO.setCommissionAmount(chargingOrderListVO.getRechargeAmount().multiply(bigDecimal));


         }


         chargingOrderListVO.setPaymentAmount(chargingOrderListVO.getPaymentAmount());


         chargingOrderListVO.setUid(chargingOrderListVO.getId()+"");


@@ -2009,10 +2019,10 @@


      if(null == chargingOrder){


         return R.ok();


      }


      Integer status = chargingOrder.getStatus();


      if(status == 5){


         return R.ok();


      }


//      Integer status = chargingOrder.getStatus();


//      if(status == 5){


//         return R.ok();


//      }


      


      //如果使用优惠券需要判断优惠券是否满足使用条件


      //根据实际的充电金额计算退款金额   退回费用=(原金额/总金额)*(总金额-实际充电金额)


@@ -2075,7 +2085,7 @@


               AccountingStrategyDetailOrderVo vo1 = new AccountingStrategyDetailOrderVo();


               BeanUtils.copyProperties(strategyDetail, vo1);


               vo1.setChargingCapacity(sharp_peak_charge);


               lists.add(vo1);


               lists.add(0, vo1);


            }


            


            //第二天的


@@ -2202,42 +2212,19 @@


         total = total.add(electrovalenc.add(originalServicePrice));


      }


      


      BigDecimal orderAmount = BigDecimal.valueOf(total.doubleValue());


      //折扣金额


      BigDecimal discountAmount = chargingOrder.getVipDiscountAmount();


      //原金额


      BigDecimal rechargeAmount = chargingOrder.getRechargeAmount();


      BigDecimal vipDiscountAmount = chargingOrder.getVipDiscountAmount();


      //总金额（充值金额+会员折扣金额）


      BigDecimal decimal = rechargeAmount.add(vipDiscountAmount);


      BigDecimal decimal = rechargeAmount.add(discountAmount);


      //退款金额（已经计算了折扣优惠部分）


      //如果充电总金额未使用完，则需要退回费用=(原金额/总金额)*(总金额-实际充电金额)


      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);


      //支付金额


      BigDecimal payAmount = rechargeAmount.subtract(refundAmount);


      //实际充值服务费-会员折扣


      periodServicePrice_total = periodServicePrice_total.subtract(discountAmount);




      TChargingOrder order = new TChargingOrder();


@@ -2259,10 +2246,12 @@


      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());


      if(discountAmount.compareTo(BigDecimal.ZERO) == 0){


         order.setVipDiscount(BigDecimal.valueOf(1));


      }


      


      //计算优惠券


      BigDecimal couponDiscount = BigDecimal.ZERO;


@@ -2316,7 +2305,9 @@


      }


      //优惠券优惠金额


      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);


@@ -2430,9 +2421,15 @@


               amount.setTotal(rechargeAmount.multiply(new BigDecimal(100)).intValue());


               amount.setCurrency("CNY");


               model.setAmount(amount);


               R<String> orderR = wxPaymentClient.refundOrderR(model);


               if(200 == orderR.getCode()){


               R<Map<String, Object>> result = wxPaymentClient.refundOrderR(model);


               if(200 == result.getCode()){


                  chargingOrderRefundService.save(chargingOrderRefund);


                  //手续费


                  Map<String, Object> amount1 = (Map<String, Object>) result.getData().get("amount");


                  Object refund_fee1 = amount1.get("refund_fee");


                  BigDecimal refund_fee = new BigDecimal(null == refund_fee1 ? "0" : refund_fee1.toString()).divide(new BigDecimal(100));


                  chargingOrderRefund.setRefundFee(refund_fee);


                  chargingOrderRefundService.updateById(chargingOrderRefund);


               }


            }


            if(2 == rechargePaymentType){


@@ -2588,12 +2585,18 @@


               amount.setTotal(tChargingOrder.getRechargeAmount().multiply(new BigDecimal(100)).intValue());


               amount.setCurrency("CNY");


               model.setAmount(amount);


               R<String> orderR = wxPaymentClient.refundOrderR(model);


               R<Map<String, Object>> orderR = wxPaymentClient.refundOrderR(model);


               if(200 == orderR.getCode()){


                  tChargingOrder.setRefundStatus(2);


                  tChargingOrder.setRefundAmount((tChargingOrder.getRefundAmount()==null? BigDecimal.valueOf(0) :tChargingOrder.getRefundAmount()).add(payOrderQueryDto.getRefundAmount()));


                  this.baseMapper.updateById(tChargingOrder);


                  chargingOrderRefundService.save(chargingOrderRefund);


                  //手续费


                  Map<String, Object> amount1 = (Map<String, Object>) orderR.getData().get("amount");


                  Object refund_fee1 = amount1.get("refund_fee");


                  BigDecimal refund_fee = new BigDecimal(null == refund_fee1 ? "0" : refund_fee1.toString()).divide(new BigDecimal(100));


                  chargingOrderRefund.setRefundFee(refund_fee);


                  chargingOrderRefundService.updateById(chargingOrderRefund);


               }


            }




@@ -2650,12 +2653,18 @@


               amount.setTotal(tChargingOrder.getPaymentAmount().multiply(new BigDecimal(100)).intValue());


               amount.setCurrency("CNY");


               model.setAmount(amount);


               R<String> orderR = wxPaymentClient.refundOrderR(model);


               R<Map<String, Object>> orderR = wxPaymentClient.refundOrderR(model);


               if(200 == orderR.getCode()){


                  tChargingOrder.setRefundStatus(2);


                  tChargingOrder.setRefundAmount((tChargingOrder.getRefundAmount()==null? BigDecimal.valueOf(0) :tChargingOrder.getRefundAmount()).add(payOrderQueryDto.getRefundAmount()));


                  shoppingOrderService.updateById(tChargingOrder);


                  shoppingOrderRefundService.save(chargingOrderRefund);


                  //手续费


                  Map<String, Object> amount1 = (Map<String, Object>) orderR.getData().get("amount");


                  Object refund_fee1 = amount1.get("refund_fee");


                  BigDecimal refund_fee = new BigDecimal(null == refund_fee1 ? "0" : refund_fee1.toString()).divide(new BigDecimal(100));


                  chargingOrderRefund.setRefundFee(refund_fee);


                  shoppingOrderRefundService.updateById(chargingOrderRefund);


               }


            }




@@ -2709,12 +2718,18 @@


            amount.setTotal(tChargingOrder.getPaymentAmount().multiply(new BigDecimal(100)).intValue());


            amount.setCurrency("CNY");


            model.setAmount(amount);


            R<String> orderR = wxPaymentClient.refundOrderR(model);


            R<Map<String, Object>> orderR = wxPaymentClient.refundOrderR(model);


            if(200 == orderR.getCode()){


               tChargingOrder.setRefundStatus(2);


               tChargingOrder.setRefundAmount((tChargingOrder.getRefundAmount()==null? BigDecimal.valueOf(0) :tChargingOrder.getRefundAmount()).add(payOrderQueryDto.getRefundAmount()));


               vipOrderService.updateById(tChargingOrder);


               vipOrderRefundService.save(chargingOrderRefund);


               //手续费


               Map<String, Object> amount1 = (Map<String, Object>) orderR.getData().get("amount");


               Object refund_fee1 = amount1.get("refund_fee");


               BigDecimal refund_fee = new BigDecimal(null == refund_fee1 ? "0" : refund_fee1.toString()).divide(new BigDecimal(100));


               chargingOrderRefund.setRefundFee(refund_fee);


               vipOrderRefundService.updateById(chargingOrderRefund);


            }


         }




@@ -2838,7 +2853,7 @@


         }


         if (tChargingOrder.getPaymentAmount()!=null){


            paymentAmount = paymentAmount.add(tChargingOrder.getPaymentAmount());


            orderCommission = orderCommission.add(tChargingOrder.getPaymentAmount().multiply(new BigDecimal("0.006"))


            orderCommission = orderCommission.add(tChargingOrder.getRechargeAmount().multiply(new BigDecimal("0.006"))


                  .setScale(2,BigDecimal.ROUND_DOWN));


         }




@@ -2983,6 +2998,8 @@


      return pageInfo;


   }




   @Autowired


   private TChargingOrderService chargingOrderService;


   @Override


   public SettlementTotalVO settlementTotal(String time) {


      Long userId = tokenService.getLoginUser().getUserid();


@@ -2997,6 +3014,14 @@


      if (siteIds.isEmpty()){


         siteIds.add(-1);


      }


      List<Site> siteList = 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<TChargingOrder> totalOrder = chargingOrderService.list(new LambdaQueryWrapper<>(TChargingOrder.class)


            .eq(TChargingOrder::getRechargePaymentStatus, 2));


      List<TChargingOrderRefund> totalRefund = chargingOrderRefundService.lambdaQuery().eq(TChargingOrderRefund::getRefundStatus, 2).list();


      SettlementTotalVO res = new SettlementTotalVO();


      List<TSettlementConfirm> list1 = tSettlementConfirmMapper.settlementTotal(time,siteIds);


      LocalDateTime parse = LocalDateTime.parse(time, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));


@@ -3044,9 +3069,9 @@


      for (TSettlementConfirm tSettlementConfirm : list1) {


         tSettlementConfirm.setXuhao(i);


         tSettlementConfirm.setMetering(tSettlementConfirm.getSupplyElectronic());


         List<Site> data1 = siteClient.getSiteByIds(Arrays.asList(tSettlementConfirm.getSiteId())).getData();


         if (!data1.isEmpty()){


            tSettlementConfirm.setSiteName(data1.get(0).getName());


         Site site = siteList.stream().filter(e -> e.getId().equals(tSettlementConfirm.getSiteId())).findFirst().orElse(null);


         if (site!=null){


            tSettlementConfirm.setSiteName(site.getName());


         }


         if (tSettlementConfirm.getMeteringElectronic()!=null){


            meteringElectronic = meteringElectronic.add(tSettlementConfirm.getMeteringElectronic());


@@ -3091,26 +3116,17 @@


               eq.between("end_time", tSettlementConfirm.getStartTime(), tSettlementConfirm.getEndTime());


               break;


         }


         List<TChargingOrder> tChargingOrders = this.baseMapper.selectList(eq);


         Map<String,TChargingOrder> map = new HashMap<>();


         StringBuilder stringBuilder = new StringBuilder();


         for (TChargingOrder tChargingOrder : tChargingOrders) {


            stringBuilder.append(tChargingOrder.getCode()).append(",");




         }


         List<TChargingOrder> tChargingOrders = totalOrder.stream().filter(e-> e.getPayTime()


               .isBefore(tSettlementConfirm.getEndTime())


               && e.getPayTime().isAfter(tSettlementConfirm.getStartTime())&&e.getSiteId().equals(tSettlementConfirm.getSiteId())).collect(Collectors.toList());


         // 充电总时长




         Long temp = 1L;


         if (StringUtils.hasLength(stringBuilder.toString())){


            String substring = stringBuilder.substring(0, stringBuilder.length() - 1);


            for (String s : substring.split(",")) {


               UploadRealTimeMonitoringData data6 = uploadRealTimeMonitoringDataClient.chargingOrderInfo(s).getData();


               if (data6!=null){


                  temp+=(data6.getCumulative_charging_time()*60);




               }




            }


         Long temp = 0L;


         for (TChargingOrder tChargingOrder : tChargingOrders) {


            LocalDateTime startTime = tChargingOrder.getStartTime();


            LocalDateTime endTime = tChargingOrder.getEndTime();


            // 计算时间差 单位秒


            long between = ChronoUnit.SECONDS.between(startTime, endTime);


            temp+=between;


         }


         List<TChargingPile> data = siteClient.getPileListBySiteId(tSettlementConfirm.getSiteId()).getData();


         // 计算充电桩的功率平均值


@@ -3122,7 +3138,7 @@




         tSettlementConfirm.setIncome(tSettlementConfirm.getElectrovalence().add(tSettlementConfirm.getServiceCharge()));


         //利用率=充电量/（桩数量*功率*时间）


         List<TChargingPile> data2 = chargingPileClient.getChargingPileBySiteId(tSettlementConfirm.getSiteId()).getData();


         List<TChargingPile> data2 = pileList.stream().filter(e -> e.getSiteId().equals(tSettlementConfirm.getSiteId())).collect(Collectors.toList());


         BigDecimal bigDecimal2 = new BigDecimal("0");




         if (data2!=null && (!data2.isEmpty())){


@@ -3238,11 +3254,16 @@


      if (siteIds.isEmpty()){


         siteIds.add(-1);


      }


      List<Site> siteList = 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<TChargingOrder> totalOrder = chargingOrderService.list(new LambdaQueryWrapper<>(TChargingOrder.class)


            .eq(TChargingOrder::getRechargePaymentStatus, 2));


      SettlementTotalVO res = new SettlementTotalVO();


      List<TSettlementConfirm> list1 = tSettlementConfirmMapper.settlementTotal(time,siteIds);


      LocalDateTime parse = LocalDateTime.parse(time, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));


      // 减少一个月


      LocalDateTime minus = parse.minusMonths(1);


      List<TSettlementConfirm> list2 = tSettlementConfirmMapper.settlementTotal(time,siteIds);


      // 合计


      List<TSettlementConfirm> total = new ArrayList<>();


@@ -3285,7 +3306,7 @@


      for (TSettlementConfirm tSettlementConfirm : list1) {


         tSettlementConfirm.setXuhao(i);


         tSettlementConfirm.setMetering(tSettlementConfirm.getSupplyElectronic());


         List<Site> data1 = siteClient.getSiteByIds(Arrays.asList(tSettlementConfirm.getSiteId())).getData();


         List<Site> data1 = siteList.stream().filter(e -> e.getId().equals(tSettlementConfirm.getSiteId())).collect(Collectors.toList());


         if (!data1.isEmpty()){


            tSettlementConfirm.setSiteName(data1.get(0).getName());


         }


@@ -3332,26 +3353,18 @@


               eq.between("end_time", tSettlementConfirm.getStartTime(), tSettlementConfirm.getEndTime());


               break;


         }


         List<TChargingOrder> tChargingOrders = this.baseMapper.selectList(eq);


         Map<String,TChargingOrder> map = new HashMap<>();


         StringBuilder stringBuilder = new StringBuilder();


         for (TChargingOrder tChargingOrder : tChargingOrders) {


            stringBuilder.append(tChargingOrder.getCode()).append(",");




         }


         List<TChargingOrder> tChargingOrders = totalOrder.stream().filter(e-> e.getPayTime()


               .isBefore(tSettlementConfirm.getEndTime())


               && e.getPayTime().isAfter(tSettlementConfirm.getStartTime())&&e.getSiteId().equals(tSettlementConfirm.getSiteId())).collect(Collectors.toList());


         // 充电总时长




         Long temp = 1L;


         if (StringUtils.hasLength(stringBuilder.toString())){


            String substring = stringBuilder.substring(0, stringBuilder.length() - 1);


            for (String s : substring.split(",")) {


               UploadRealTimeMonitoringData data6 = uploadRealTimeMonitoringDataClient.chargingOrderInfo(s).getData();


               if (data6!=null){


                  temp+=(data6.getCumulative_charging_time()*60);




               }




            }


         Long temp = 0L;


         for (TChargingOrder tChargingOrder : tChargingOrders) {


            LocalDateTime startTime = tChargingOrder.getStartTime();


            LocalDateTime endTime = tChargingOrder.getEndTime();


            // 计算时间差 单位秒


            long between = ChronoUnit.SECONDS.between(startTime, endTime);


            temp+=between;


         }


         List<TChargingPile> data = siteClient.getPileListBySiteId(tSettlementConfirm.getSiteId()).getData();


         // 计算充电桩的功率平均值