From a16c9bebf9ab97e04afa67db1665549af86948fb Mon Sep 17 00:00:00 2001 From: 无关风月 <443237572@qq.com> Date: 星期五, 07 二月 2025 17:02:30 +0800 Subject: [PATCH] Merge branch 'master' of http://120.76.84.145:10101/gitblit/r/java/mx_charging_pile --- ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java | 69 +++++++--------------------------- 1 files changed, 15 insertions(+), 54 deletions(-) diff --git a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java index 0db7e43..1ece9fc 100644 --- a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java +++ b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java @@ -1,4 +1,5 @@ package com.ruoyi.order.controller; +import com.alibaba.fastjson2.JSON; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import java.math.BigDecimal; @@ -800,9 +801,9 @@ * @param vo */ @PostMapping("/endChargeBillingCharge") - public void endChargeBillingCharge(@RequestBody TransactionRecordMessageVO vo){ + public R endChargeBillingCharge(@RequestBody TransactionRecordMessageVO vo){ log.info("-------------------停止充电返回账单后计算费用及修改业务状态-------------------:" + vo); - chargingOrderService.endChargeBillingCharge(vo); + return chargingOrderService.endChargeBillingCharge(vo); } @@ -1749,11 +1750,9 @@ LocalDateTime min = selectDate.with(LocalTime.MIN); LocalDateTime max = selectDate.with(LocalTime.MAX); - - - - - List<TChargingOrder> list = chargingOrderService.lambdaQuery().in(!siteIds.isEmpty(), TChargingOrder::getSiteId, siteIds).ge( TChargingOrder::getCreateTime,min).le(BasePojo::getCreateTime,max).eq(TChargingOrder::getStatus,5).eq(statisticsQueryDto.getSiteId() != null, TChargingOrder::getSiteId, statisticsQueryDto.getSiteId()).list(); + List<TChargingOrder> list = chargingOrderService.lambdaQuery().in(!siteIds.isEmpty(), TChargingOrder::getSiteId, siteIds) + .ge( TChargingOrder::getCreateTime,min).le(BasePojo::getCreateTime,max).eq(TChargingOrder::getStatus,5) + .eq(statisticsQueryDto.getSiteId() != null, TChargingOrder::getSiteId, statisticsQueryDto.getSiteId()).list(); //当日的订单总数 int size = list.size(); //计算list中paymentAmount的总和 @@ -1792,7 +1791,7 @@ siteIds.add(statisticsQueryDto.getSiteId()); } if (statisticsQueryDto.getDayType()==1) { - List<Map<String,Object>> charMap1 = chargingOrderService.getHourType(siteIds,statisticsQueryDto); + List<Map<String,Object>> charMap1 = chargingOrderService.getHourType(siteIds,statisticsQueryDto); List<Map<String, Object>> charMap = new ArrayList<>(); // 生成从 "00:00" 到 "23:00" 的时间数据 for (int hour = 0; hour < 24; hour++) { @@ -1919,10 +1918,11 @@ } List<Map<String,Object>> capMap = chargingOrderService.getchargingCapacity(siteIds,statisticsQueryDto); List<TChargingPile> chargingPiles = chargingPileClient.getChargingPileBySiteIds(siteIds).getData(); - BigDecimal totalRatedPower = chargingPiles.stream().map(TChargingPile::getRatedPower).reduce(BigDecimal.ZERO, BigDecimal::add).multiply(new BigDecimal(chargingPiles.size())).multiply(new BigDecimal(24)); + BigDecimal totalRatedPower = chargingPiles.stream().map(TChargingPile::getRatedPower).reduce(BigDecimal.ZERO, BigDecimal::add); - //每日利用率=当日充电度数/(总桩数量*桩总功率*24小时) - BigDecimal multiply1 = new BigDecimal(chargingPiles.size()).multiply(totalRatedPower).multiply(new BigDecimal(24)); + //每日利用率=当日充电度数/(桩总功率*24小时) + BigDecimal multiply1 = totalRatedPower.multiply(new BigDecimal(24)); + System.err.println(JSON.toJSONString(capMap) + "---" + chargingPiles.size() + "---" + totalRatedPower + "---" + multiply1); capMap.forEach(map -> { BigDecimal chargingCapacity = (BigDecimal) map.get("chargingCapacity"); BigDecimal result = chargingCapacity.divide(multiply1, 4, RoundingMode.HALF_UP); @@ -2007,49 +2007,6 @@ - private static List<TChargingOrder> getSampleData() { - // 这里可以替换为实际查询逻辑 - List<TChargingOrder> list = new ArrayList<>(); - // 示例数据 - for (int i = 0; i < 24; i++) { - TChargingOrder order = new TChargingOrder(); - order.setStartTime(LocalDateTime.now().minusHours(23 - i)); - order.setOrderAmount(BigDecimal.valueOf(i + 1)); - list.add(order); - } - return list; - } - - private static List<Map<String, BigDecimal>> processData(List<TChargingOrder> list) { - Map<LocalDateTime, BigDecimal> hourlySum = new HashMap<>(); - - // 按每个小时分组并求和 - for (TChargingOrder order : list) { - LocalDateTime hour = order.getStartTime().truncatedTo(ChronoUnit.HOURS); - BigDecimal amount = order.getOrderAmount(); - hourlySum.merge(hour, amount, BigDecimal::add); - } - - // 创建结果列表 - List<Map<String, BigDecimal>> resultList = new ArrayList<>(); - for (int i = 1; i <= 23; i++) { - LocalDateTime keyHour = LocalDateTime.now().withHour(i); - BigDecimal sum = BigDecimal.ZERO; - - // 计算键之后的一小时的数据之和 - for (int j = i + 1; j <= 23; j++) { - LocalDateTime nextHour = LocalDateTime.now().withHour(j); - sum = sum.add(hourlySum.getOrDefault(nextHour, BigDecimal.ZERO)); - } - - Map<String, BigDecimal> entry = new HashMap<>(); - entry.put(String.valueOf(i), sum); - resultList.add(entry); - } - - return resultList; - } - /** * 硬件充电结束后的处理逻辑 @@ -2061,6 +2018,8 @@ chargingOrderService.endCharge(code, 2); } + + /** * 硬件异常结束充电后的处理逻辑 * @param code @@ -2082,6 +2041,8 @@ TChargingOrder chargingOrder = chargingOrderService.getChargingOrderByLicensePlate(query); return R.ok(chargingOrder); } + + /** * 修改充电订单 * @param chargingOrder -- Gitblit v1.7.1