明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | show whitespace
puzhibing
2025-02-11 0275498af38bc1c8fbc5bfea54f3cce3550fd6ab 
 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;


@@ -235,6 +236,9 @@


        data.setRecords(res1);


        return R.ok(data);


    }








    public static List<PayOrderDto> testing5(long total, long current, long size, List<PayOrderDto> str){


    List<PayOrderDto> result = new ArrayList<>();


    //获取初始化分页结构


@@ -256,6 +260,9 @@


    }


    return result;


}








    @ResponseBody


    @PostMapping(value = "/pay/order/refund")


    @ApiOperation(value = "退款", tags = {"管理后台-支付订单-订单信息"})


@@ -326,6 +333,10 @@


        return R.ok();




    }










    @ResponseBody


    @GetMapping(value = "/pay/order/refund/detail")


    @ApiOperation(value = "退款信息", tags = {"管理后台-支付订单-订单信息"})


@@ -475,6 +486,10 @@


        }


        return result;


    }










    @ResponseBody


    @PostMapping(value = "/pay/order/refund/list1")


    @ApiOperation(value = "列表1", tags = {"管理后台-支付订单-退款订单"})


@@ -585,6 +600,8 @@


                .between(TChargingOrder::getStartTime, req.getStartTime(), req.getEndTime())).size();


        return R.ok(size);


    }






    //用户订单数量


    @PostMapping(value = "/useOrderCount")


    public R<Long> useOrderCount(@RequestParam("userId") Long userId) {


@@ -593,11 +610,15 @@


        return R.ok(count);


    }








    //订单详情


    @PostMapping(value = "/detail")


    public R<TChargingOrder> detail(@RequestParam("orderId") Long orderId) {


        return R.ok(chargingOrderService.getById(orderId));


    }








    @PostMapping(value = "/getList")


    public R<List<TChargingOrder>> getList(@RequestParam("siteId") Integer siteId) {


@@ -605,6 +626,8 @@


        List<TChargingOrder> list = chargingOrderService.lambdaQuery().eq(TChargingOrder::getSiteId, siteId).list();


        return R.ok(list);


    }








    @PostMapping(value = "/getBySiteIdAndTime")


    public R<List<ChargingOrderGroup>> getBySiteIdAndTime(@RequestBody ChargingPercentProvinceDto chargingPercentProvinceDto) {


@@ -806,17 +829,11 @@


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


    }


    


    


//    @PostMapping("/endChargeBillingCharge1")


//    public void endChargeBillingCharge1(@RequestBody TransactionRecordMessageVO vo){


//        log.info("-------------------停止充电返回账单后计算费用及修改业务状态-------------------：" + vo);


//        chargingOrderService.endChargeBillingCharge1(vo);


//    }


    


    


    


@@ -1761,11 +1778,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的总和


@@ -1931,10 +1946,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);


@@ -2019,6 +2035,7 @@


    








    /**


     * 硬件充电结束后的处理逻辑


     * @param code


@@ -2028,6 +2045,8 @@


        log.info(code + "：-------------------充电桩自动结束充电-------------------");


        chargingOrderService.endCharge(code, 2);


    }








    /**


     * 硬件异常结束充电后的处理逻辑


@@ -2050,6 +2069,8 @@


        TChargingOrder chargingOrder = chargingOrderService.getChargingOrderByLicensePlate(query);


        return R.ok(chargingOrder);


    }






    /**


     * 修改充电订单


     * @param chargingOrder