9.11

luodangjia

2024-09-11 8a01a386da08eab56e112926b91359e24a2f7117

 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/TChargingOrderServiceImpl.java

@@ -62,6 +62,7 @@
import com.ruoyi.payment.api.model.WxPaymentRefundModel;
import com.ruoyi.payment.api.vo.*;
import com.ruoyi.system.api.feignClient.SysUserClient;
import com.sun.org.apache.bcel.internal.generic.NEW;
import io.seata.spring.annotation.GlobalTransactional;
import io.swagger.annotations.ApiModelProperty;
import org.slf4j.Logger;
@@ -643,7 +644,7 @@
            model.setOut_trade_no(chargingOrder.getCode());
            model.setOut_refund_no(chargingOrderRefund.getRefundCode());
            model.setReason("充电失败，取消充电订单");
            model.setNotify_url("http://127.0.0.1:9000/order/t-charging-order/chargingOrderStartupFailureWxRefund");
            model.setNotify_url("http://221.182.45.100:9000/order/t-charging-order/chargingOrderStartupFailureWxRefund");
            WxPaymentRefundModel.RefundAmount amount = new WxPaymentRefundModel.RefundAmount();
            amount.setRefund(rechargeAmount.multiply(new BigDecimal(100)).intValue());
            amount.setTotal(rechargeAmount.multiply(new BigDecimal(100)).intValue());
@@ -953,7 +954,7 @@
            model.setOut_trade_no(chargingOrder.getCode());
            model.setOut_refund_no(chargingOrderRefund.getRefundCode());
            model.setReason("充电完成退款");
            model.setNotify_url("http://127.0.0.1:9000/order/t-charging-order/chargingOrderStartupFailureWxRefund");
            model.setNotify_url("http://221.182.45.100:9000/order/t-charging-order/chargingOrderStartupFailureWxRefund");
            WxPaymentRefundModel.RefundAmount amount = new WxPaymentRefundModel.RefundAmount();
            amount.setRefund(refundAmount.multiply(new BigDecimal(100)).intValue());
            amount.setTotal(rechargeAmount.multiply(new BigDecimal(100)).intValue());
@@ -1124,32 +1125,32 @@
   }

   @Override
   public Map<String, BigDecimal> countAll(LocalDate sixBefore) {
   public Map<String, Object> countAll(LocalDate sixBefore) {
      return this.baseMapper.countAll(sixBefore);
   }

   @Override
   public List<Map<String, BigDecimal>> getSumByType(List<Long> chargingOrderIds) {
   public List<Map<String, Object>> getSumByType(List<Long> chargingOrderIds) {
      return this.baseMapper.getSumByType(chargingOrderIds);
   }

   @Override
   public List<Map<String, BigDecimal>> getDateData(List<Long> chargingOrderIds) {
   public List<Map<String, Object>> getDateData(List<Long> chargingOrderIds) {
      return this.baseMapper.getDateData(chargingOrderIds);
   }

   @Override
   public List<Map<String, BigDecimal>> getWeekData(List<Long> chargingOrderIds) {
   public List<Map<String, Object>> getWeekData(List<Long> chargingOrderIds) {
      return this.baseMapper.getWeekData(chargingOrderIds);
   }

   @Override
   public List<Map<String, BigDecimal>> getMonthData(List<Long> chargingOrderIds) {
   public List<Map<String, Object>> getMonthData(List<Long> chargingOrderIds) {
      return this.baseMapper.getMonthData(chargingOrderIds);
   }

   @Override
   public List<Map<String, BigDecimal>> getYearData(List<Long> chargingOrderIds) {
   public List<Map<String, Object>> getYearData(List<Long> chargingOrderIds) {
      return this.baseMapper.getYearData(chargingOrderIds);
   }
   @Resource
@@ -1244,6 +1245,7 @@
      }
      // 不分页
      List<ChargingOrderListVO> list1 = this.baseMapper.chargingList1(dto,startTime1,startTime2,endTime1,endTime2);
      chargingOrderTimeVO.setExportList(list1);
      chargingOrderTimeVO.setOrderCount(list1.size());
      // 计算充电总度数
      BigDecimal electronic = new BigDecimal("0");
@@ -1354,7 +1356,6 @@
         chargingOrderListInfoVO.setTerminalName(data2.getName()+data1.getName());
      }
      chargingOrderListInfoVO.setEndMode(chargingOrder.getEndMode());
      // todo 周一完善
      // 获取开始SOC 结束soc
      List<UploadRealTimeMonitoringData> data6 = uploadRealTimeMonitoringDataClient.getDataByOrderCode(chargingOrder.getCode()).getData();
      if (!data6.isEmpty()){
@@ -1555,6 +1556,75 @@
      endCharge(orderCode, 0);
   }

   @Override
   public List<Map<String, Object>> getByDate(List<Long> chargingOrderIds) {
      return this.baseMapper.getByDate(chargingOrderIds);
   }

   @Override
   public List<Map<String, Object>> queryPower(List<Integer> siteIds) {
      return this.baseMapper.queryPower(siteIds);
   }

   @Override
   public Map<String, Object> qureryPowerLevel(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {
      return this.baseMapper.queryPowerLevel(siteIds,statisticsQueryDto);
   }

   @Override
   public List<Map<String, Object>> queryOrderCountAndMoneyBySiteIdDate(List<Integer> siteIds) {
      return this.baseMapper.queryOrderCountAndMoneyBySiteIdDate(siteIds);
   }

   @Override
   public List<Map<String, Object>> usersDay() {
      return this.baseMapper.usersDay();
   }

   @Override
   public List<Map<String, Object>> usersByQuery(ChargingStatisticsQueryDto statisticsQueryDto) {
      return this.baseMapper.usersByQuery(statisticsQueryDto);
   }

   @Override
   public List<Map<String, Object>> getUserTagCount() {
      return this.baseMapper.getUserTagCount();
   }

   @Override
   public List<Map<String, Object>> getVipCount() {
      return this.baseMapper.getVipCount();
   }

   @Override
   public List<Map<String, Object>> unitConsumption(ChargingStatisticsQueryDto statisticsQueryDto) {
      return this.baseMapper.unitConsumption(statisticsQueryDto);
   }

   @Override
   public List<Map<String, Object>> carUserMethod() {
      return this.baseMapper.carUserMethod();
   }

   @Override
   public List<Map<String, Object>> carUserBrand() {
      return this.baseMapper.carUserBrand();
   }

   @Override
   public Map<String, Object> countLocalCar() {
      return this.baseMapper.countLocalCar();
   }

   @Override
   public Long getAver(List<Integer> siteIds) {
      return this.baseMapper.getAver(siteIds);
   }

   @Override
   public List<Map<String, Object>> getLevelEvaluate(List<Integer> siteIds) {
      return this.baseMapper.getLevelEvaluate(siteIds);
   }


   @Override
@@ -1583,7 +1653,7 @@
               model.setOut_refund_no(chargingOrderRefund.getRefundCode());
               model.setTransaction_id(tChargingOrder.getRechargeSerialNumber());
               model.setReason("取消订单");
               model.setNotify_url("http://127.0.0.1:9000/order/t-shopping-order/cancelShoppingOrderWxRefund");
               model.setNotify_url("http://221.182.45.100:9000/order/t-shopping-order/cancelShoppingOrderWxRefund");
               WxPaymentRefundModel.RefundAmount amount = new WxPaymentRefundModel.RefundAmount();
               amount.setRefund(payOrderQueryDto.getRefundAmount().multiply(new BigDecimal(100)).intValue());
               amount.setTotal(tChargingOrder.getPaymentAmount().multiply(new BigDecimal(100)).intValue());
@@ -1734,7 +1804,7 @@
      tSettlementConfirm.setMetering(dto.getData().getMetering());
      tSettlementConfirm.setClean(dto.getData().getClean());
      tSettlementConfirm.setMaintain(dto.getData().getMaintain());
      tSettlementConfirm.setCost(dto.getData().getCost());
      tSettlementConfirm.setCost(dto.getData().getVenue().add(dto.getData().getClean()).add(dto.getData().getMaintain()));
      tSettlementConfirm.setProfitMoney(new BigDecimal("0"));
      tSettlementConfirm.setNewMoney(new BigDecimal("0"));
      tSettlementConfirm.setNewSettlement(new BigDecimal("0"));
@@ -1751,6 +1821,8 @@
      tSettlementConfirm.setServiceMoney(dto.getData().getServiceMoney());
      tSettlementConfirm.setTotalService(dto.getData().getTotalService());
      tSettlementConfirm.setServiceRemark(dto.getData().getServiceRemark());
      tSettlementConfirm.setDistribution(dto.getData().getDistribution());
      tSettlementConfirm.setIncome(dto.getData().getElectrovalence().add(dto.getData().getServiceCharge()));
      if (dto.getState() == 2){
         tSettlementConfirmMapper.insert(tSettlementConfirm);
      }
@@ -1781,9 +1853,218 @@
      return null;
   }

   @Override
   public SettlementTotalVO settlementTotal(String time) {
      SettlementTotalVO res = new SettlementTotalVO();
      List<TSettlementConfirm> list1 = tSettlementConfirmMapper.settlementTotal(time);
      LocalDateTime parse = LocalDateTime.parse(time, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
      // 减少一个月
      LocalDateTime minus = parse.minusMonths(1);
      List<TSettlementConfirm> list2 = tSettlementConfirmMapper.settlementTotal(time);
      // 合计
      List<TSettlementConfirm> total = new ArrayList<>();

      TSettlementConfirm tSettlementConfirm1 = new TSettlementConfirm();
      BigDecimal meteringElectronic = new BigDecimal("0");
      BigDecimal chargingElectronic = new BigDecimal("0");
      BigDecimal lossElectronic = new BigDecimal("0");
      BigDecimal income = new BigDecimal("0");
      BigDecimal venue = new BigDecimal("0");
      BigDecimal metering = new BigDecimal("0");
      BigDecimal clean = new BigDecimal("0");
      BigDecimal maintain = new BigDecimal("0");
      BigDecimal cost = new BigDecimal("0");
      BigDecimal profitMoney = new BigDecimal("0");
      BigDecimal newMoney = new BigDecimal("0");
      BigDecimal newSettlement = new BigDecimal("0");
      BigDecimal supplyElectronic = new BigDecimal("0");
      BigDecimal proportionPartner = new BigDecimal("0");
      BigDecimal proportionMoney = new BigDecimal("0");
      BigDecimal totalElectronic = new BigDecimal("0");
      BigDecimal totalService = new BigDecimal("0");
      BigDecimal servicePartner = new BigDecimal("0");
      BigDecimal serviceMoney = new BigDecimal("0");
      BigDecimal sharingAmount = new BigDecimal("0");
      BigDecimal commissionAmount = new BigDecimal("0");
      BigDecimal electrovalence = new BigDecimal("0");
      BigDecimal serviceCharge = new BigDecimal("0");
      BigDecimal orderCommission = new BigDecimal("0");
      BigDecimal vipDiscount = new BigDecimal("0");
      BigDecimal couponDiscount = new BigDecimal("0");
//      tSettlementConfirm1.setIncomePercentage();
//      tSettlementConfirm1.setTotalPercentage();
      tSettlementConfirm1.setElectronicRefund(0);
// 上月成本合计
      BigDecimal beforeCost= new BigDecimal("0");
      // 上月利润合计
      BigDecimal beforeIncome= new BigDecimal("0");
      for (TSettlementConfirm tSettlementConfirm : list1) {
         List<Site> data1 = siteClient.getSiteByIds(Arrays.asList(tSettlementConfirm.getSiteId())).getData();
         if (!data1.isEmpty()){
            tSettlementConfirm.setSiteName(data1.get(0).getName());
         }
         meteringElectronic = meteringElectronic.add(tSettlementConfirm.getMeteringElectronic());
         chargingElectronic = chargingElectronic.add(tSettlementConfirm.getChargingElectronic());
         lossElectronic = lossElectronic.add(tSettlementConfirm.getLossElectronic());
         income = income.add(tSettlementConfirm.getIncome());
         venue = venue.add(tSettlementConfirm.getVenue());
         metering = metering.add(tSettlementConfirm.getMetering());
         clean = clean.add(tSettlementConfirm.getClean());
         maintain = maintain.add(tSettlementConfirm.getMaintain());
         cost = cost.add(tSettlementConfirm.getCost());
         profitMoney = profitMoney.add(tSettlementConfirm.getProfitMoney());
         newMoney = newMoney.add(tSettlementConfirm.getNewMoney());
         newSettlement = newSettlement.add(tSettlementConfirm.getNewSettlement());
         supplyElectronic = supplyElectronic.add(tSettlementConfirm.getSupplyElectronic());
         proportionPartner = proportionPartner.add(tSettlementConfirm.getProportionPartner());
         proportionMoney = proportionMoney.add(tSettlementConfirm.getProportionMoney());
         totalElectronic = totalElectronic.add(tSettlementConfirm.getTotalElectronic());
         totalService = totalService.add(tSettlementConfirm.getTotalService());
         servicePartner = servicePartner.add(tSettlementConfirm.getServicePartner());
         serviceMoney = serviceMoney.add(tSettlementConfirm.getServiceMoney());
         sharingAmount = sharingAmount.add(tSettlementConfirm.getSharingAmount());
         commissionAmount = commissionAmount.add(tSettlementConfirm.getCommissionAmount());
         electrovalence = electrovalence.add(tSettlementConfirm.getElectrovalence());
         serviceCharge = serviceCharge.add(tSettlementConfirm.getServiceCharge());
         orderCommission = orderCommission.add(tSettlementConfirm.getOrderCommission());
         vipDiscount = vipDiscount.add(tSettlementConfirm.getVipDiscount());
         couponDiscount = couponDiscount.add(tSettlementConfirm.getCouponDiscount());

         // 查询结算确认单开始时间和结束时间的单子
         QueryWrapper<TChargingOrder> eq = new QueryWrapper<TChargingOrder>()
               .eq("site_id", tSettlementConfirm.getSiteId())
               .eq("recharge_payment_status",2);
         switch (tSettlementConfirm.getType()){
            case 1:
               eq.between("start_time", tSettlementConfirm.getStartTime(), tSettlementConfirm.getEndTime());
               break;
            case 2:
               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(",");
         }
         Long temp = 0L;
         if (StringUtils.hasLength(stringBuilder.toString())){
            List<UploadRealTimeMonitoringData> data6 = uploadRealTimeMonitoringDataClient.getOrderInfoByCodes(stringBuilder.substring(0,stringBuilder.length()-1)).getData();
            temp+=data6.stream().mapToLong(UploadRealTimeMonitoringData::getCumulative_charging_time).sum();
         }
         List<TChargingPile> data = siteClient.getPileListBySiteId(tSettlementConfirm.getSiteId()).getData();
         // 计算充电桩的功率平均值
         BigDecimal bigDecimal = new BigDecimal("0");
         for (TChargingPile datum : data) {
            bigDecimal = bigDecimal.add(datum.getRatedPower());
         }
         BigDecimal bigDecimal1 = bigDecimal.divide(new BigDecimal(data.size())).setScale(2, RoundingMode.HALF_DOWN);

         tSettlementConfirm.setIncome(tSettlementConfirm.getElectrovalence().add(tSettlementConfirm.getServiceCharge()));
         // todo 计算利用率 该电站充电桩本月利用率：
         //利用率=充电量/（桩数量*功率*时间）

         for (TSettlementConfirm settlementConfirm : list2) {
            settlementConfirm.setIncome(settlementConfirm.getElectrovalence().add(settlementConfirm.getServiceCharge()));
            if (tSettlementConfirm.getSiteId().equals(settlementConfirm.getSiteId())){
               // 电站相同比较收入涨幅跌幅
               BigDecimal subtract = tSettlementConfirm.getIncome().subtract(settlementConfirm.getIncome()).divide(tSettlementConfirm.getIncome()).setScale(2, RoundingMode.HALF_DOWN).multiply(new BigDecimal("100"));
               tSettlementConfirm.setIncomePercentage(subtract+"%");
               // 比较总利润 收入合计-成本合计
               BigDecimal subtract1 = tSettlementConfirm.getIncome().subtract(tSettlementConfirm.getCost());
               BigDecimal subtract2 = settlementConfirm.getIncome().subtract(settlementConfirm.getCost());
               tSettlementConfirm.setTotalPercentage(subtract1.subtract(subtract2).divide(subtract2).setScale(2, RoundingMode.HALF_DOWN).multiply(new BigDecimal("100"))+"%");
            }
            beforeCost = beforeCost.add(settlementConfirm.getCost());
            beforeIncome = beforeIncome.add(settlementConfirm.getIncome());


         }
      }
      TSettlementConfirm tSettlementConfirm = new TSettlementConfirm();
      tSettlementConfirm.setMeteringElectronic(meteringElectronic);
      tSettlementConfirm.setChargingElectronic(chargingElectronic);
      tSettlementConfirm.setLossElectronic(lossElectronic);
      tSettlementConfirm.setIncome(income);
      tSettlementConfirm.setVenue(venue);
      tSettlementConfirm.setMetering(metering);
      tSettlementConfirm.setClean(clean);
      tSettlementConfirm.setMaintain(maintain);
      tSettlementConfirm.setCost(cost);
      tSettlementConfirm.setProfitMoney(profitMoney);
      tSettlementConfirm.setNewMoney(newMoney);
      tSettlementConfirm.setNewSettlement(newSettlement);
      tSettlementConfirm.setSupplyElectronic(supplyElectronic);
      tSettlementConfirm.setProportionPartner(proportionPartner);
      tSettlementConfirm.setProportionMoney(proportionMoney);
      tSettlementConfirm.setTotalElectronic(totalElectronic);
      tSettlementConfirm.setTotalService(totalService);
      tSettlementConfirm.setServicePartner(servicePartner);
      tSettlementConfirm.setServiceMoney(serviceMoney);
      tSettlementConfirm.setSharingAmount(sharingAmount);
      tSettlementConfirm.setCommissionAmount(commissionAmount);
      tSettlementConfirm.setElectrovalence(electrovalence);
      tSettlementConfirm.setServiceCharge(serviceCharge);
      tSettlementConfirm.setOrderCommission(orderCommission);
      tSettlementConfirm.setVipDiscount(vipDiscount);
      tSettlementConfirm.setCouponDiscount(couponDiscount);
      // 本月
      BigDecimal subtract = income.subtract(beforeIncome).divide(beforeIncome).setScale(2, RoundingMode.HALF_DOWN).multiply(new BigDecimal("100"));
      tSettlementConfirm.setIncomePercentage(subtract+"%");
      // 比较总利润 收入合计-成本合计
      BigDecimal subtract1 = income.subtract(cost);
      BigDecimal subtract2 = beforeIncome.subtract(beforeCost);
      tSettlementConfirm.setTotalPercentage(subtract1.subtract(subtract2).divide(subtract2).setScale(2, RoundingMode.HALF_DOWN).multiply(new BigDecimal("100"))+"%");
      tSettlementConfirm.setIncomePercentage(subtract+"%");
      tSettlementConfirm.setElectronicRefund(0);
      // 查询上次汇报数据 进行比对涨幅跌幅
      total.add(tSettlementConfirm);
      res.setList1(list1);
      res.setList2(total);
      return res;
   }

   @Override
   public List<Map<String, Object>> countBySource(List<Integer> siteIds) {
      return this.baseMapper.countBySource(siteIds);
   }

   @Override
   public List<Map<String, Object>> equipmentUserType1(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {
      return this.baseMapper.equipmentUserType1(siteIds,statisticsQueryDto);
   }

   @Override
   public List<Map<String, Object>> equipmentUserType2(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {
      return this.baseMapper.equipmentUserType2(siteIds,statisticsQueryDto);
   }

   @Override
   public List<Map<String, Object>> equipmentMapbroke1(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {
      return this.baseMapper.equipmentMapbroke1(siteIds,statisticsQueryDto);
   }

   @Override
   public List<Map<String, Object>> equipmentMapbroke2(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {
      return this.baseMapper.equipmentMapbroke2(siteIds,statisticsQueryDto);
   }

   @Override
   public List<Map<String, Object>> equipmentMapOut1(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {
      return this.baseMapper.equipmentMapOut1(siteIds,statisticsQueryDto);
   }

   @Override
   public List<Map<String, Object>> equipmentMapOut2(List<Integer> siteIds, ChargingStatisticsQueryDto statisticsQueryDto) {
      return this.baseMapper.equipmentMapOut2(siteIds,statisticsQueryDto);
   }

   public static void main(String[] args) {
      String format = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy年MM月dd日HH:mm:ss"));
      String format1 = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy年MM月dd日HH:mm:ss"));
      System.err.println(format+"至"+format1);
//      String format = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy年MM月dd日HH:mm:ss"));
//      String format1 = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy年MM月dd日HH:mm:ss"));
//      System.err.println(format+"至"+format1);
//      LocalDateTime parse = LocalDateTime.parse("2024-01-12 00:00:00", DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
//      System.err.println(parse.format(DateTimeFormatter.ofPattern("yyyy-dd")));
   }
}