明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
puzhibing
2024-10-17 201ec7bf9f2b7dec65db6ed02ef6f67cb1dd5851 
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java


@@ -70,10 +70,7 @@


import java.math.MathContext;


import java.math.RoundingMode;


import java.text.SimpleDateFormat;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.ZoneId;


import java.time.ZoneOffset;


import java.time.*;


import java.time.format.DateTimeFormatter;


import java.time.format.TextStyle;


import java.time.temporal.WeekFields;


@@ -992,7 +989,12 @@


            GetPlatformStopChargingReply query = new GetPlatformStopChargingReply();


            query.setCharging_gun_code(chargingGun.getCode());


            query.setCharging_pile_code(chargingPile.getCode());


            query.setEnd_time(chargingOrder.getEndTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));


				


            //将时间转换成UTC时间后查询数据（mongodb存储时间以UTC格式存储）


            ZoneId zoneId = ZoneId.systemDefault();


            ZonedDateTime zonedDateTime = ZonedDateTime.of(chargingOrder.getEndTime(), zoneId);


            ZonedDateTime endTime = zonedDateTime.withZoneSameInstant(ZoneId.of("UTC"));


            query.setEnd_time(endTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));


            PlatformStopChargingReply reply = platformStopChargingReplyClient.getPlatformStopChargingReply(query).getData();


            log.error(code1 + "：-------------------查询远程停止充电应答-------------------");


            if(null == reply){


@@ -1407,6 +1409,7 @@


      PageInfo<ChargingOrderListVO> pageInfo = new PageInfo<>(dto.getPageCurr(),dto.getPageSize());


      List<ChargingOrderListVO> list = this.baseMapper.chargingList(pageInfo,dto,startTime1,startTime2,endTime1,endTime2);


      for (ChargingOrderListVO chargingOrderListVO : list) {


         chargingOrderListVO.setPaymentAmount(chargingOrderListVO.getResidualAmount()==null?chargingOrderListVO.getPaymentAmount():chargingOrderListVO.getPaymentAmount().subtract(chargingOrderListVO.getResidualAmount()));


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


         List<Integer> integers = new ArrayList<>();


         integers.add(chargingOrderListVO.getSiteId());


@@ -1450,7 +1453,7 @@


                     if (data4!=null && !data4.isEmpty()) chargingOrderListVO.setLicensePlate(data4.get(0).getLicensePlate());


                  }


               }


               if (data3 != null) chargingOrderListVO.setPhone(data3.getPhone());


               chargingOrderListVO.setPhone(data3.getPhone());




            }


         }


@@ -1705,7 +1708,7 @@


            chargingOrder.setChargingPower(divide);


            chargingOrder.setCurrent(query.getOutput_current());


            chargingOrder.setVoltage(query.getOutput_voltage());


            chargingOrder.setPower(query.getOutput_current().multiply(query.getOutput_voltage()));


            chargingOrder.setPower(divide);


            chargingOrder.setNeedElec(query.getOutput_current());


            


            TChargingGun chargingGun = chargingGunClient.getChargingGunById(chargingOrder.getChargingGunId()).getData();


@@ -1772,25 +1775,42 @@


      


      //获取订单的计费策略


      List<AccountingStrategyDetailOrder> accountingStrategyDetailOrderList = accountingStrategyDetailOrderClient.getAllAccountingStrategyDetailOrder(chargingOrder.getId()).getData();


      AccountingStrategyDetailOrder accountingStrategyDetailOrder = accountingStrategyDetailOrderList.get(accountingStrategyDetailOrderList.size() - 1);


      if(accountingStrategyDetailOrder.getEndTime().equals("00:00")){


         accountingStrategyDetailOrder.setEndTime("24:00");


      }


      chargingOrderAccountingStrategyService.remove(new LambdaQueryWrapper<TChargingOrderAccountingStrategy>().eq(TChargingOrderAccountingStrategy::getChargingOrderId, chargingOrder.getId()));


      for (int i = 0; i < 12; i++) {


         Class<? extends TransactionRecordMessageVO> clazz = vo.getClass();


         try {


            String time = (String) clazz.getMethod("getTime" + (i + 1)).invoke(vo);


            if(StringUtils.hasLength(time)){


               //充电度数


               Object invoke = clazz.getMethod("getSharp_peak_charge" + (i + 1)).invoke(vo);


            Object invoke1 = clazz.getMethod("getTime" + (i + 1)).invoke(vo);


            if(null != invoke1){


               String[] split = invoke1.toString().split("-");


               AccountingStrategyDetailOrder strategyDetail = accountingStrategyDetailOrderList.stream().filter(s -> s.getStartTime().equals(split[0]) && s.getEndTime().equals(split[1])).findFirst().get();


               //阶段（1=尖阶段，2=峰阶段，3=平阶段，4=谷阶段）


               Object invoke = null;


               switch (strategyDetail.getType()){


                  case 1:


                     //充电度数


                     invoke = clazz.getMethod("getSharp_peak_charge" + (i + 1)).invoke(vo);


                     break;


                  case 2:


                     //充电度数


                     invoke = clazz.getMethod("getPeak_charge" + (i + 1)).invoke(vo);


                     break;


                  case 3:


                     //充电度数


                     invoke = clazz.getMethod("getFlat_peak_charge" + (i + 1)).invoke(vo);


                     break;


                  case 4:


                     //充电度数


                     invoke = clazz.getMethod("getLow_peak_charge" + (i + 1)).invoke(vo);


                     break;


               }


               if(null == invoke || invoke.toString().equals("0")){


                  continue;


               }


               BigDecimal Sharp_peak_charge = new BigDecimal(invoke.toString());


               //充电金额


               Object invoke1 = clazz.getMethod("getSharp_peak_amount" + (i + 1)).invoke(vo);


               BigDecimal sharp_peak_amount = new BigDecimal(invoke1.toString());


					


               String[] split = time.split("-");


               AccountingStrategyDetailOrder strategyDetail = accountingStrategyDetailOrderList.stream().filter(s -> s.getStartTime().equals(split[0]) && s.getEndTime().equals(split[1])).findFirst().get();


					


               TChargingOrderAccountingStrategy chargingOrderAccountingStrategy = new TChargingOrderAccountingStrategy();


               chargingOrderAccountingStrategy.setChargingOrderId(chargingOrder.getId());


               chargingOrderAccountingStrategy.setAccountingStrategyDetailId(strategyDetail.getId());


@@ -1881,10 +1901,10 @@


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


      order.setVipDiscountAmount(discountAmount);


      order.setServiceCharge(periodServicePrice_total);


      order.setElectrovalence(periodElectricPrice_total);


      order.setOrderAmount(orderAmount.setScale(2, RoundingMode.DOWN));


      order.setVipDiscountAmount(discountAmount.setScale(2, RoundingMode.DOWN));


      order.setServiceCharge(periodServicePrice_total.setScale(2, RoundingMode.DOWN));


      order.setElectrovalence(periodElectricPrice_total.setScale(2, RoundingMode.DOWN));


      order.setChargingCapacity(vo.getTotal_electricity());


      


      //计算优惠券


@@ -1922,8 +1942,8 @@


            }


         }


      }


      order.setPaymentAmount(payAmount);


      order.setRefundAmount(refundAmount);


      order.setPaymentAmount(payAmount.setScale(2, RoundingMode.DOWN));


      order.setRefundAmount(refundAmount.setScale(2, RoundingMode.DOWN));


      order.setRefundStatus(1);


      this.updateById(order);


      chargingOrder = this.getById(order.getId());