明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Pu Zhibing
2025-02-14 95da1e36eaad95a0701c7b6f44534054d217557f 
 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;




@@ -1322,8 +1323,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 +1378,7 @@




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


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


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


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


         }


@@ -1576,7 +1577,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()+"");


@@ -2838,7 +2839,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 +2984,8 @@


      return pageInfo;


   }




   @Autowired


   private TChargingOrderService chargingOrderService;


   @Override


   public SettlementTotalVO settlementTotal(String time) {


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


@@ -2997,6 +3000,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 +3055,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 +3102,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 +3124,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 +3240,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 +3292,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 +3339,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();


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