明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
无关风月
2025-04-28 e1399ade3e27ef74ed58d56dbbb2bf77604ff5af 
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/controller/TChargingOrderController.java


@@ -12,6 +12,7 @@


import com.ruoyi.account.api.feignClient.AppUserCarClient;


import com.ruoyi.account.api.feignClient.AppUserClient;


import com.ruoyi.account.api.model.TAppUserCar;


import com.ruoyi.chargingPile.api.domain.SiteMenu;


import com.ruoyi.chargingPile.api.dto.GetSiteListDTO;


import com.ruoyi.chargingPile.api.feignClient.*;


import com.ruoyi.chargingPile.api.model.Site;


@@ -35,6 +36,7 @@


import com.ruoyi.integration.api.feignClient.UploadRealTimeMonitoringDataClient;


import com.ruoyi.integration.api.model.ChargingOrderAndUploadRealTimeMonitoringDataDto;


import com.ruoyi.integration.api.model.UploadRealTimeMonitoringPageData;


import com.ruoyi.order.api.dto.ChargingStatisticeDTO;


import com.ruoyi.order.api.model.*;


import com.ruoyi.order.api.query.ChargingOrderQuery;


import com.ruoyi.common.core.dto.MongoChargingOrderQuery;


@@ -53,19 +55,21 @@


import com.ruoyi.order.service.*;


import com.ruoyi.order.util.PreviousSixMonths;


import com.ruoyi.order.vo.EndOfChargePageInfo;


import com.ruoyi.order.vo.WatchChargingOrderVo;


import com.ruoyi.other.api.feignClient.RoleSiteClient;


import com.ruoyi.other.api.feignClient.UserSiteClient;


import com.ruoyi.payment.api.feignClient.AliPaymentClient;


import com.ruoyi.payment.api.feignClient.WxPaymentClient;


import com.ruoyi.payment.api.vo.AliQueryOrder;


import com.ruoyi.system.api.domain.SysUser;


import com.ruoyi.system.api.feignClient.SysUserClient;


import io.swagger.annotations.Api;


import io.swagger.annotations.ApiImplicitParam;


import io.swagger.annotations.ApiImplicitParams;


import com.ruoyi.system.api.feignClient.SysUserRoleClient;


import com.ruoyi.system.api.model.SysUserRoleVo;


import io.swagger.annotations.*;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


import io.swagger.annotations.ApiOperation;


import org.springframework.web.bind.annotation.*;




import javax.annotation.Resource;


@@ -147,9 +151,32 @@


    @Resource


    private SysUserClient sysUserClient;


    


    @Resource


    private UserSiteClient userSiteClient;


    


    


    


    @Resource


    private RoleSiteClient roleSiteClient;


    @Resource


    private SysUserRoleClient sysUserRoleClient;








    /**


     * 远程调用 监管平台查询前一天用能统计


     * @return


     */


    @ResponseBody


    @PostMapping(value = "/getChargingStatistics")


    public R<List<TChargingOrder>> getChargingStatistics(@RequestBody ChargingStatisticeDTO dto) {


        List<Long> collect = chargingOrderAccountingStrategyService.lambdaQuery().between(TChargingOrderAccountingStrategy::getCreateTime, dto.getStartTime(), dto.getEndTime())


                .list().stream().map(TChargingOrderAccountingStrategy::getChargingOrderId).collect(Collectors.toList());


        if (!collect.isEmpty()){


            List<TChargingOrder> list = chargingOrderService.lambdaQuery()


                    .in(TChargingOrder::getId,collect).list();


            return R.ok(list);


        }


        return R.ok(new ArrayList<TChargingOrder>());


    }




    /**


     * 远程调用 增加管理后台赠送会员记录


@@ -400,15 +427,38 @@


    @GetMapping(value = "/pay/order/charging/details")


    @ApiOperation(value = "充电明细", tags = {"管理后台-支付订单-订单信息"})


    public R<List<TChargingOrderAccountingStrategy>> chargingDetail(Long orderId) {


        List<TChargingOrderAccountingStrategy> list = chargingOrderAccountingStrategyService.lambdaQuery().eq(TChargingOrderAccountingStrategy::getChargingOrderId, orderId).orderByDesc(TChargingOrderAccountingStrategy::getStartTime).list();


        TChargingOrder chargingOrder = chargingOrderService.getById(orderId);


        List<TChargingOrderAccountingStrategy> list = chargingOrderAccountingStrategyService.lambdaQuery().eq(TChargingOrderAccountingStrategy::getChargingOrderId, orderId)


                .orderByDesc(TChargingOrderAccountingStrategy::getStartTime).list();


        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");


        for (TChargingOrderAccountingStrategy tChargingOrderAccountingStrategy : list) {


            String format = tChargingOrderAccountingStrategy.getCreateTime().format(formatter);


            LocalDateTime createTime = chargingOrder.getStartTime();


            String format = createTime.format(formatter);


            String startTime = tChargingOrderAccountingStrategy.getStartTime();


            if("00:00".equals(startTime)){


                createTime = createTime.plusDays(1);


                format = createTime.format(formatter);


            }


            tChargingOrderAccountingStrategy.setStartTime(format+" "+tChargingOrderAccountingStrategy.getStartTime());


            tChargingOrderAccountingStrategy.setEndTime(format+" "+tChargingOrderAccountingStrategy.getEndTime());


        }






        //从新排序


        list.sort(new Comparator<TChargingOrderAccountingStrategy>() {


            @Override


            public int compare(TChargingOrderAccountingStrategy o1, TChargingOrderAccountingStrategy o2) {


                String startTime = o1.getStartTime();


                String startTime1 = o2.getStartTime();


                LocalDateTime localDateTime = LocalDateTime.parse(startTime, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm"));


                LocalDateTime localDateTime1 = LocalDateTime.parse(startTime1, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm"));


                if(localDateTime.isBefore(localDateTime1)){


                    return -1;


                }


                if(localDateTime.isAfter(localDateTime1)){


                    return 1;


                }


                return 0;


            }


        });


        return R.ok(list);


    }


    


@@ -522,12 +572,6 @@


    }






    public static void main(String[] args) {


        ;


        System.err.println(Integer.parseInt("01"));


        System.err.println(Integer.valueOf("01"));


        ;


    }


    @RequiresPermissions(value = {"/chargingPileOrder/monitoring_record"}, logical = Logical.OR)


    @ResponseBody


    @GetMapping(value = "/chargingOrderInfo")


@@ -554,27 +598,15 @@


        List<TChargingOrderAccountingStrategy> list = chargingOrderAccountingStrategyService.lambdaQuery().eq(TChargingOrderAccountingStrategy::getChargingOrderId, strategyId).orderByDesc(TChargingOrderAccountingStrategy::getStartTime).list();


        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");


        for (TChargingOrderAccountingStrategy tChargingOrderAccountingStrategy : list) {


            String format = "";


            String format1 = "";


//            String temp1=list.get(0).getStartTime().split(":")[0];


            System.err.println("订单详情时间第一条"+list.get(0).getStartTime());


            System.err.println("订单详情时间开始"+tChargingOrderAccountingStrategy.getStartTime());


            System.err.println("订单详情时间结束"+tChargingOrderAccountingStrategy.getEndTime());


            String temp1=list.get(0).getStartTime().split(" ")[1].split(":")[0];


            String[] split = tChargingOrderAccountingStrategy.getStartTime().split(" ")[1].split(":");


            if (Integer.parseInt(split[0])>=Integer.parseInt(temp1)){


                format = byId.getCreateTime().format(formatter);


            }else {


                format = byId.getEndTime().format(formatter);


            }


            String[] split1 = tChargingOrderAccountingStrategy.getEndTime().split(" ")[1].split(":");


            if (Integer.parseInt(split1[0])<Integer.parseInt(temp1)){


                format1 = byId.getCreateTime().format(formatter);


            }else {


                format1 = byId.getEndTime().format(formatter);


            LocalDateTime createTime = byId.getStartTime();


            String format = createTime.format(formatter);


            String startTime = tChargingOrderAccountingStrategy.getStartTime();


            if("00:00".equals(startTime)){


                createTime = createTime.plusDays(1);


                format = createTime.format(formatter);


            }


            tChargingOrderAccountingStrategy.setStartTime(format+" "+tChargingOrderAccountingStrategy.getStartTime());


            tChargingOrderAccountingStrategy.setEndTime(format1+" "+tChargingOrderAccountingStrategy.getEndTime());


            tChargingOrderAccountingStrategy.setEndTime(format+" "+tChargingOrderAccountingStrategy.getEndTime());


            if (byId.getVipDiscountAmount()!=null && byId.getServiceCharge().compareTo(BigDecimal.ZERO) != 0){


                BigDecimal multiply = byId.getVipDiscountAmount().divide(byId.getServiceCharge(), 2)


                        .multiply(tChargingOrderAccountingStrategy.getPeriodOriginalServicePrice());


@@ -586,6 +618,23 @@


                tChargingOrderAccountingStrategy.setCouponDiscount(multiply);


            }


        }


        //从新排序


        list.sort(new Comparator<TChargingOrderAccountingStrategy>() {


            @Override


            public int compare(TChargingOrderAccountingStrategy o1, TChargingOrderAccountingStrategy o2) {


                String startTime = o1.getStartTime();


                String startTime1 = o2.getStartTime();


                LocalDateTime localDateTime = LocalDateTime.parse(startTime, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm"));


                LocalDateTime localDateTime1 = LocalDateTime.parse(startTime1, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm"));


                if(localDateTime.isBefore(localDateTime1)){


                    return -1;


                }


                if(localDateTime.isAfter(localDateTime1)){


                    return 1;


                }


                return 0;


            }


        });


        chargingOrderInfoVO.setList(list);


        return AjaxResult.success(chargingOrderInfoVO);


    }


@@ -813,6 +862,19 @@


    


    


    /**


     *


     * @param code


     */


    @ResponseBody


    @PostMapping(value = "/refund1")


    public R refund1(@RequestParam(value = "code") String code, @RequestParam(value = "money") BigDecimal money){


        chargingOrderService.refund1(code, money);


        return R.ok();


    }


    


    


    


    /**


     * 远程启动失败后退款回调


     */


    @ResponseBody


@@ -1031,13 +1093,16 @@


    }


    


    


    


    


    


    


    @RequiresPermissions(value = {"/platformRevenueAnalysis"}, logical = Logical.OR)


    @ResponseBody


    @GetMapping(value = "/six/total")


    @ApiOperation(value = "底部数据分类", tags = {"后台-数据分析-平台收入分析"})


    public R<Map<String,Object>> total() {


        //count近6个月的数据


        LocalDate sixBefore = PreviousSixMonths.get();


        Long userId = tokenService.getLoginUser().getUserid();


        //获取当前登录的siteIds


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


@@ -1049,31 +1114,42 @@


        if (siteIds.isEmpty()){


            siteIds.add(-1);


        }


        Map<String,Object>  map = chargingOrderService.countAll(sixBefore,siteIds);


        BigDecimal data = parkingLotClient.getRecordAmount(sixBefore).getData();


        Map<String,Object>  map = chargingOrderService.countAll(siteIds);


        BigDecimal data = parkingLotClient.getRecordAmount().getData();


        if (map ==null){


            map = new HashMap<String,Object>();


        }


        map.put("parkingAmount",data);


        BigDecimal data1 =   shoppingOrderService.getSumAmount(sixBefore);


        BigDecimal data1 =   shoppingOrderService.getSumAmount();


        map.put("shopAmount",data1);


        BigDecimal data2 =   vipOrderService.getSumAmout(sixBefore);


        BigDecimal data2 =   vipOrderService.getSumAmout();


        map.put("vipAmount",data2);


        List<TChargingOrder> list = chargingOrderService.lambdaQuery().between(TChargingOrder::getCreateTime, sixBefore, LocalDate.now()).list();


        BigDecimal serviceCharge = new BigDecimal("0");


        BigDecimal commissionAmount = new BigDecimal("0");




        for (TChargingOrder chargingOrder : list) {


            if (chargingOrder.getOrderSource().equals(2)){


                serviceCharge = serviceCharge.add(chargingOrder.getServiceCharge()!=null?chargingOrder.getServiceCharge().multiply(new BigDecimal("0.2")).setScale(2,BigDecimal.ROUND_DOWN):new BigDecimal("0"));


                commissionAmount = commissionAmount.add(chargingOrder.getServiceCharge()!=null?chargingOrder.getServiceCharge().multiply(new BigDecimal("0.2")).setScale(2,BigDecimal.ROUND_DOWN):new BigDecimal("0"));


        List<TChargingOrder> list = chargingOrderService.lambdaQuery().eq(TChargingOrder::getStatus, 5).eq(TChargingOrder::getDelFlag, 0)


                .eq(TChargingOrder::getRechargePaymentStatus, 2).list();


        BigDecimal sharingAmount = BigDecimal.ZERO;


        BigDecimal commissionAmount = BigDecimal.ZERO;


        //计算list中electrovalence的总和


        BigDecimal totalElectrovalence = BigDecimal.ZERO;


        //计算list中serviceCharge的总和


        BigDecimal totalServiceCharge = BigDecimal.ZERO;


        List<TChargingOrderAccountingStrategy> accountingStrategyList = chargingOrderAccountingStrategyService.list();


        for (TChargingOrder order : list) {


            List<TChargingOrderAccountingStrategy> collect = accountingStrategyList.stream().filter(s -> s.getChargingOrderId().equals(order.getId())).collect(Collectors.toList());


            BigDecimal periodElectricPrice = collect.stream().map(TChargingOrderAccountingStrategy::getPeriodElectricPrice).reduce(BigDecimal.ZERO, BigDecimal::add);


            BigDecimal periodServicePrice = collect.stream().map(TChargingOrderAccountingStrategy::getPeriodServicePrice).reduce(BigDecimal.ZERO, BigDecimal::add);


            totalElectrovalence = totalElectrovalence.add(periodElectricPrice);


            if(2 != order.getOrderSource()){


                totalServiceCharge = totalServiceCharge.add(periodServicePrice);


                commissionAmount = commissionAmount.add((periodElectricPrice.add(periodServicePrice)).multiply(new BigDecimal("0.006")));


            }else{


                serviceCharge = serviceCharge.add(chargingOrder.getServiceCharge());


                totalServiceCharge = totalServiceCharge.add(periodServicePrice.multiply(new BigDecimal("0.8")));


                sharingAmount = sharingAmount.add(periodServicePrice.multiply(new BigDecimal("0.2")));


            }




        }


        map.put("service_charge",serviceCharge);


        map.put("commission_amount",commissionAmount);


        map.put("service_charge",totalServiceCharge.setScale(2, BigDecimal.ROUND_HALF_EVEN));


        map.put("electrovalence",totalElectrovalence.setScale(2, BigDecimal.ROUND_HALF_EVEN));


        map.put("commission_amount",commissionAmount.setScale(2, BigDecimal.ROUND_HALF_EVEN));


        map.put("sharing_amount",sharingAmount.setScale(2, BigDecimal.ROUND_HALF_EVEN));


        return R.ok(map);


    }




@@ -1082,93 +1158,81 @@


    @ResponseBody


    @PostMapping(value = "/watch/chargingOrder")


    @ApiOperation(value = "监控订单", tags = {"管理后台-订单管理"})


    public R watchChargingOrder(@RequestBody MongoChargingOrderQuery mongoChargingOrderQuery) {


        Long userid = tokenService.getLoginUser().getUserid();


    public R watchChargingOrder(@RequestBody MongoChargingOrderQuery query) {


        Set<Integer> ids = null;


        //校验合作商权限


        SysUser sysUser = sysUserClient.getSysUser(tokenService.getLoginUser().getUserid()).getData();


        Integer roleType = sysUser.getRoleType();


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


        if (mongoChargingOrderQuery.getSiteId()==null){


            List<GetSiteListDTO> data = siteClient.getSiteListByUserId(userid).getData();


            for (GetSiteListDTO datum : data) {


                siteIds.add(datum.getId());


            }


        }else {


            siteIds.add(mongoChargingOrderQuery.getSiteId());


        }


        if (siteIds.isEmpty()){


            siteIds.add(-1);


        Integer objectId = sysUser.getObjectId();


        R<Integer> admin = sysUserClient.isAdmin(tokenService.getLoginUser().getUserid());


        //合作商


        if(roleType == 2){


            ids = partnerClient.authSite(objectId, SiteMenu.SITE_LIST.getValue()).getData();


        }else{


            if (roleType == 2){


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


                for (Integer siteId : siteIds) {


                    // 校验有没有这个站点的权限


                    List<Boolean> t1= partnerClient.watchChargingOrder(sysUser.getObjectId(),siteId).getData();


                    Boolean b = t1.get(1);


                    if (b){


                        integers.add(siteId);


                    }


            //非管理员需要根据角色和用户配置查询允许的站点数据


            //改用roleId=1来判断


            if(admin.getData()!=1){


                List<Integer> data = userSiteClient.getSiteIds(sysUser.getUserId()).getData();


                List<SysUserRoleVo> data2 = sysUserRoleClient.getRoleByUserId(sysUser.getUserId()).getData();


                if(data2.size() > 0){


                    List<Integer> data1 = roleSiteClient.getSiteIds(data2.get(0).getRoleId()).getData();


                    data.addAll(data1);


                }


                siteIds = integers;


                ids = new HashSet<>(data);


            }


        }


        if (siteIds.isEmpty()){


            siteIds.add(-1);


    


        LambdaQueryWrapper<TChargingOrder> queryWrapper = new LambdaQueryWrapper<TChargingOrder>().like(StringUtils.isNotEmpty(query.getCode()), TChargingOrder::getCode, query.getCode())


                .eq(null != query.getOrderType(), TChargingOrder::getOrderType, query.getOrderType())


                .eq(null != query.getSiteId(), TChargingOrder::getSiteId, query.getSiteId())


                .eq(null != query.getPileId(), TChargingOrder::getChargingPileId, query.getPileId())


                .eq(null != query.getGunId(), TChargingOrder::getChargingGunId, query.getGunId())


                .eq(null != query.getStatus(), TChargingOrder::getStatus, query.getStatus())


                .eq(TChargingOrder::getDelFlag, 0).eq(TChargingOrder::getRechargePaymentStatus, 2)


                .in(null != ids && ids.size() > 0, TChargingOrder::getSiteId, ids);


        if(StringUtils.isNotEmpty(query.getCreateTime())){


            String[] split = query.getCreateTime().split(" - ");


            queryWrapper.between(TChargingOrder::getStartTime, split[0], split[1]);


        }


        mongoChargingOrderQuery.setSiteIds(siteIds);


        mongoChargingOrderQuery.setPageSize(10);


        R<UploadRealTimeMonitoringPageData> all = uploadRealTimeMonitoringDataClient.getAll(mongoChargingOrderQuery);


        UploadRealTimeMonitoringPageData data1 = all.getData();




        List<ChargingOrderAndUploadRealTimeMonitoringDataDto> dtos = new ArrayList<>();


        Map<String,ChargingOrderVO> map  = new HashMap<>();




        for (UploadRealTimeMonitoringData uploadRealTimeMonitoringData : data1.getRecords()) {


            if (roleType==2){


                List<Boolean> data = partnerClient.watchChargingOrder(sysUser.getObjectId(), uploadRealTimeMonitoringData.getSiteId()).getData();


                uploadRealTimeMonitoringData.setAuthInfo(data.get(0));


                uploadRealTimeMonitoringData.setAuthDelete(data.get(1));


        if(StringUtils.isNotEmpty(query.getLastTime())){


            String[] split = query.getLastTime().split(" - ");


            queryWrapper.between(TChargingOrder::getEndTime, split[0], split[1]);


        }


        PageInfo<TChargingOrder> pageInfo = new PageInfo<>(query.getPageCurr(), query.getPageSize());


        PageInfo<TChargingOrder> orderPageInfo = chargingOrderService.page(pageInfo, queryWrapper.orderByDesc(TChargingOrder::getCreateTime));


        List<Site> siteList = siteClient.getSiteAll().getData();


        


        List<WatchChargingOrderVo> list = new ArrayList<>();


        for (TChargingOrder record : orderPageInfo.getRecords()) {


            WatchChargingOrderVo vo = new WatchChargingOrderVo();


            BeanUtils.copyProperties(record, vo);


            vo.setIdStr(record.getId().toString());


            Site site = siteList.stream().filter(s->s.getId().equals(record.getSiteId())).findFirst().get();


            vo.setSiteName(site.getName());


            TChargingPile chargingPile = chargingPileClient.getChargingPileById(record.getChargingPileId()).getData();


            vo.setTerminalName(chargingPile.getName());


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


            vo.setTerminalCode(chargingGun.getName());


            


            if(null != record.getStartTime() && null != record.getEndTime()){


                long time = record.getEndTime().toEpochSecond(ZoneOffset.UTC) - record.getStartTime().toEpochSecond(ZoneOffset.UTC);


                vo.setChargingTime(time + "");


            }


            ChargingOrderAndUploadRealTimeMonitoringDataDto dataDto = new ChargingOrderAndUploadRealTimeMonitoringDataDto();


            ChargingOrderQuery dto = new ChargingOrderQuery();


            dto.setCode(uploadRealTimeMonitoringData.getTransaction_serial_number());




            if (map.get(uploadRealTimeMonitoringData.getTransaction_serial_number())==null) {


                TCharingOrderVO vo = chargingOrderService.chargingOrder(dto);


                map.put(uploadRealTimeMonitoringData.getTransaction_serial_number(),vo.getList().getRecords().get(0));


                if (!vo.getList().getRecords().isEmpty()) {


                    ChargingOrderVO chargingOrderVO = vo.getList().getRecords().get(0);


                    if (chargingOrderVO != null) {


                        BeanUtils.copyProperties(chargingOrderVO, dataDto);


                    }




                    BeanUtils.copyProperties(uploadRealTimeMonitoringData, dataDto);


                    if (chargingOrderVO != null && chargingOrderVO.getOrderSource()==2){


                        dataDto.setPeriod_service_price(uploadRealTimeMonitoringData.getPeriod_service_price().multiply(new BigDecimal("0.2").setScale(2,BigDecimal.ROUND_DOWN)));


                    }


                    dataDto.setStartTime(uploadRealTimeMonitoringData.getStartTime());


                    dataDto.setEndTime(uploadRealTimeMonitoringData.getEndTime() == null ? null : uploadRealTimeMonitoringData.getEndTime());


                    dataDto.setStatus(uploadRealTimeMonitoringData.getStatus());


                    dtos.add(dataDto);


                }


            }else {


                ChargingOrderVO vo = map.get(uploadRealTimeMonitoringData.getTransaction_serial_number());


                BeanUtils.copyProperties(vo, dataDto);


                BeanUtils.copyProperties(uploadRealTimeMonitoringData, dataDto);


                dataDto.setStartTime(uploadRealTimeMonitoringData.getStartTime());


                dataDto.setEndTime(uploadRealTimeMonitoringData.getEndTime() == null ? null : uploadRealTimeMonitoringData.getEndTime());


                dataDto.setStatus(uploadRealTimeMonitoringData.getStatus());


                dtos.add(dataDto);


            }


            long count = chargingOrderAccountingStrategyService.count(new LambdaQueryWrapper<TChargingOrderAccountingStrategy>().eq(TChargingOrderAccountingStrategy::getChargingOrderId, record.getId()));


            vo.setTimeFrame(count);


    


            vo.setAuthInfo(roleType == 1 ? true : partnerClient.authMenu(objectId, record.getSiteId(), SiteMenu.CHARGING_PILE_ORDER_MONITORING_RECORD_INFO.getValue()));


            vo.setAuthDelete(roleType == 1 ? true : partnerClient.authMenu(objectId, record.getSiteId(), SiteMenu.CHARGING_PILE_ORDER_MONITORING_RECORD_DEL.getValue()));


            list.add(vo);


        }


        for (int i = 0; i < dtos.size(); i++) {


            dtos.get(i).setIndex(i);


        }




        PageChargingOrderAndUploadRealTimeMonitoringDataDto page = new PageChargingOrderAndUploadRealTimeMonitoringDataDto();


        page.setTotal(data1.getCount());


        page.setRecords(dtos);




        return R.ok(page);


        PageInfo<WatchChargingOrderVo> pageInfos = new PageInfo<>(query.getPageCurr(), query.getPageSize());


        pageInfos.setRecords(list);


        pageInfos.setCurrent(pageInfo.getCurrent());


        pageInfos.setPages(pageInfo.getPages());


        pageInfos.setSize(pageInfo.getSize());


        pageInfos.setStartIndex(pageInfo.getStartIndex());


        pageInfos.setTotal(pageInfo.getTotal());


        return R.ok(pageInfos);


    }


    


    


@@ -1222,54 +1286,36 @@


        if (siteIds.isEmpty())siteIds.add(-1);


        TCharingOrderMapVO tCharingOrderMapVO = new TCharingOrderMapVO();






        LocalDate start = null;


        LocalDate end = null;


        if (statisticsQueryDto.getDayType()==1){


            start = LocalDate.now();


            end = LocalDate.now().plusDays(1);




        }else if (statisticsQueryDto.getDayType()==2){


            LocalDate today = LocalDate.now();




            // 获取本周一的日期


            LocalDate mondayThisWeek = today.with(TemporalAdjusters.previousOrSame(DayOfWeek.MONDAY));


            start = statisticsQueryDto.getStartTime();


            end = statisticsQueryDto.getEndTime();


            System.out.println("本周一是: " + mondayThisWeek);


        }


        else if (statisticsQueryDto.getDayType()==3){


        } else if (statisticsQueryDto.getDayType()==3){


            // 获取当前日期


            LocalDate today = LocalDate.now();


            start = statisticsQueryDto.getStartTime();


            end = statisticsQueryDto.getEndTime().plusDays(1);


            // 获取本月1号的日期


//            start = yearMonth.atDay(1);


//


//            System.out.println("本月1号是: " + start);


            end = statisticsQueryDto.getEndTime();


        }else if (statisticsQueryDto.getDayType()==4){




            // 获取今年1月1日的日期


            start = statisticsQueryDto.getStartTime();


            end = statisticsQueryDto.getEndTime();


        }else if (statisticsQueryDto.getDayType()==5){




            // 获取今年1月1日的日期


            start = statisticsQueryDto.getStartTime();


            end = statisticsQueryDto.getEndTime();


            if (start.equals(end)){


                end =  end.plusDays(1);


            }


        }




        List<TChargingOrder> list = chargingOrderService.lambdaQuery().ge(TChargingOrder::getCreateTime, start).le(TChargingOrder::getCreateTime, end).in(TChargingOrder::getSiteId, siteIds).list();


        List<Long> chargingOrderIds = list.stream().map(TChargingOrder::getId).collect(Collectors.toList());


        chargingOrderIds.add(-1L);


        //上方饼图


         List<Map<String,Object>> maps =   chargingOrderService.getSumByType(chargingOrderIds);


         List<Map<String,Object>> maps = chargingOrderService.getSumByType(start,end, siteIds);




        if (statisticsQueryDto.getDayType()==1){


            List<Map<String,Object>> maps1 = chargingOrderService.getDateData(chargingOrderIds);


            List<Map<String,Object>> maps1 = chargingOrderService.getDateData(start,end, siteIds);




            List<Map<String, Object>> charMap = new ArrayList<>();


            // 生成从 "00:00" 到 "23:00" 的时间数据


@@ -1293,10 +1339,7 @@




            tCharingOrderMapVO.setMaps1(charMap);


        }else if (statisticsQueryDto.getDayType()==2){








            List<Map<String,Object>> maps1 = chargingOrderService.getWeekData(chargingOrderIds);


            List<Map<String,Object>> maps1 = chargingOrderService.getWeekData(start,end, siteIds);




            LocalDate startDate = statisticsQueryDto.getStartTime();


            LocalDate endDate = statisticsQueryDto.getEndTime();


@@ -1326,7 +1369,7 @@


            }


            tCharingOrderMapVO.setMaps1(dateRangeStatistics);


        }else if (statisticsQueryDto.getDayType()==3){


            List<Map<String,Object>> maps1 = chargingOrderService.getMonthData(chargingOrderIds);


            List<Map<String,Object>> maps1 = chargingOrderService.getMonthData(start,end, siteIds);




            LocalDate startDate = statisticsQueryDto.getStartTime();


            LocalDate endDate = statisticsQueryDto.getEndTime();


@@ -1356,7 +1399,7 @@


            }


            tCharingOrderMapVO.setMaps1(dateRangeStatistics);


        }else  if (statisticsQueryDto.getDayType()==4){


            List<Map<String,Object>> maps1 = chargingOrderService.getYearData(chargingOrderIds);


            List<Map<String,Object>> maps1 = chargingOrderService.getYearData(start,end, siteIds);




            LocalDate startDate = statisticsQueryDto.getStartTime();


            LocalDate endDate = statisticsQueryDto.getEndTime();


@@ -1387,7 +1430,7 @@


            }


            tCharingOrderMapVO.setMaps1(dateRangeStatistics);


        }else if (statisticsQueryDto.getDayType()==5){


            List<Map<String,Object>> maps1 = chargingOrderService.getByDate(chargingOrderIds);


            List<Map<String,Object>> maps1 = chargingOrderService.getByDate(start,end, siteIds);




            LocalDate startDate = statisticsQueryDto.getStartTime();


            LocalDate endDate = statisticsQueryDto.getEndTime();


@@ -1423,15 +1466,20 @@




        tCharingOrderMapVO.setMaps(maps);


        BigDecimal allMoney = new BigDecimal(0);


        BigDecimal commissionAmount = BigDecimal.ZERO;


        for (Map<String, Object> map : maps) {


            BigDecimal periodElectricPrice = (BigDecimal) map.get("period_electric_price");


            allMoney = allMoney.add(periodElectricPrice);


            Long order_source = (Long)map.get("order_source");


            if(2 != order_source){


                allMoney = allMoney.add(periodElectricPrice);


            }


            BigDecimal total_amount = (BigDecimal) map.get("total_amount");


            allMoney = allMoney.add(total_amount);


            commissionAmount = commissionAmount.add((BigDecimal) map.get("commissionAmount"));


        }


        allMoney =  allMoney.multiply(new BigDecimal("0.006"));




        tCharingOrderMapVO.setAllMoney(allMoney);


        tCharingOrderMapVO.setCommissionAmount(commissionAmount);


        return R.ok(tCharingOrderMapVO);




    }


@@ -1847,18 +1895,36 @@


        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)


                .between(TChargingOrder::getCreateTime, min, max).eq(TChargingOrder::getStatus,5).eq(TChargingOrder::getDelFlag, 0)


                .eq(TChargingOrder::getRechargePaymentStatus, 2)


                .eq(statisticsQueryDto.getSiteId() != null, TChargingOrder::getSiteId, statisticsQueryDto.getSiteId()).list();


        //当日的订单总数


        int size = list.size();


        //计算list中paymentAmount的总和


        BigDecimal totalPaymentAmount = list.stream().map(TChargingOrder::getPaymentAmount).reduce(BigDecimal.ZERO, BigDecimal::add);


        BigDecimal totalPaymentAmount = BigDecimal.ZERO;


        //计算list中electrovalence的总和


        BigDecimal totalElectrovalence = list.stream().map(TChargingOrder::getElectrovalence).reduce(BigDecimal.ZERO, BigDecimal::add);


        BigDecimal totalElectrovalence = BigDecimal.ZERO;


        //计算list中serviceCharge的总和


        BigDecimal totalServiceCharge = list.stream().map(TChargingOrder::getServiceCharge).reduce(BigDecimal.ZERO, BigDecimal::add);


        BigDecimal totalServiceCharge = BigDecimal.ZERO;


        //计算list中charging_capacity的总和


        BigDecimal totalChargingCapacity = list.stream().map(TChargingOrder::getChargingCapacity).reduce(BigDecimal.ZERO, BigDecimal::add);


        BigDecimal totalChargingCapacity = BigDecimal.ZERO;


        List<TChargingOrderAccountingStrategy> accountingStrategyList = chargingOrderAccountingStrategyService.list();


        for (TChargingOrder order : list) {


            List<TChargingOrderAccountingStrategy> collect = accountingStrategyList.stream().filter(s -> s.getChargingOrderId().equals(order.getId())).collect(Collectors.toList());


            BigDecimal periodElectricPrice = collect.stream().map(TChargingOrderAccountingStrategy::getPeriodElectricPrice).reduce(BigDecimal.ZERO, BigDecimal::add);


            BigDecimal periodServicePrice = collect.stream().map(TChargingOrderAccountingStrategy::getPeriodServicePrice).reduce(BigDecimal.ZERO, BigDecimal::add);


            BigDecimal chargingCapacity = collect.stream().map(TChargingOrderAccountingStrategy::getChargingCapacity).reduce(BigDecimal.ZERO, BigDecimal::add);


            totalElectrovalence = totalElectrovalence.add(periodElectricPrice);


            totalChargingCapacity = totalChargingCapacity.add(chargingCapacity);


            if(2 != order.getOrderSource()){


                totalServiceCharge = totalServiceCharge.add(periodServicePrice);


                totalPaymentAmount = totalPaymentAmount.add(periodElectricPrice).add(periodServicePrice);


            }else{


                totalServiceCharge = totalServiceCharge.add(periodServicePrice.multiply(new BigDecimal("0.8")));


                totalPaymentAmount = totalPaymentAmount.add(periodElectricPrice).add(periodServicePrice.multiply(new BigDecimal("0.8")));


            }


        }


        


        TCharingWorkVO tCharingWorkVO = new TCharingWorkVO();


        tCharingWorkVO.setCount(size);


        tCharingWorkVO.setTotalPaymentAmount(totalPaymentAmount);