明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
无关风月
2025-02-13 76cbf6741c91bf91469e406dc052e688e4fd6103 
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java


@@ -66,6 +66,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;




@@ -2920,6 +2921,8 @@


      return pageInfo;


   }




   @Autowired


   private TChargingOrderService chargingOrderService;


   @Override


   public SettlementTotalVO settlementTotal(String time) {


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


@@ -2934,6 +2937,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"));


@@ -2981,9 +2992,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());


@@ -3028,26 +3039,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();


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


@@ -3059,7 +3061,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())){


@@ -3175,11 +3177,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<>();


@@ -3222,7 +3229,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());


         }


@@ -3269,26 +3276,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();


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