明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
无关风月
2025-02-07 a16c9bebf9ab97e04afa67db1665549af86948fb 
 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