玩湃
blame | 历史 | 补丁 | 提交 | 提交对比 | show whitespace
44323
2023-10-07 e6ee956618b3c1a6371a6c22dfbb70868dbd3f17 
 cloud-server-management/src/main/java/com/dsh/guns/modular/system/controller/code/DataStatisticsController.java


@@ -1,26 +1,42 @@


package com.dsh.guns.modular.system.controller.code;




import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.dsh.course.feignClient.account.AppUserClient;


import com.dsh.course.feignClient.account.CityClient;


import com.dsh.course.feignClient.account.CityManagerClient;


import com.dsh.course.feignClient.account.FinanceClient;


import com.dsh.course.feignClient.account.*;


import com.dsh.course.feignClient.account.model.CityManager;


import com.dsh.course.feignClient.course.CancelledClassesClient;


import com.dsh.course.feignClient.account.model.TAppUser;


import com.dsh.course.feignClient.account.model.VipPayment;


import com.dsh.course.feignClient.activity.PointMercharsClient;


import com.dsh.course.feignClient.competition.CompetitionClient;


import com.dsh.course.feignClient.competition.model.Competition;


import com.dsh.course.feignClient.competition.model.CompetitionQuery;


import com.dsh.course.feignClient.competition.model.PaymentCompetition;


import com.dsh.course.feignClient.course.*;


import com.dsh.course.feignClient.course.model.TCoursePackage;


import com.dsh.course.feignClient.course.model.TCoursePackagePayment;


import com.dsh.course.feignClient.other.SiteClient;


import com.dsh.course.feignClient.other.StoreClient;


import com.dsh.course.model.MoneyBack;


import com.dsh.guns.config.UserExt;


import com.dsh.guns.core.base.controller.BaseController;


import com.dsh.guns.modular.system.model.*;


import com.dsh.guns.modular.system.service.ICityService;


import groovyjarjarpicocli.CommandLine;


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


import org.springframework.stereotype.Controller;


import org.springframework.ui.Model;


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


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




import javax.annotation.Resource;


import java.math.BigDecimal;


import java.util.ArrayList;


import java.util.HashSet;


import java.util.List;


import java.math.RoundingMode;


import java.text.SimpleDateFormat;


import java.time.*;


import java.time.format.DateTimeFormatter;


import java.time.temporal.ChronoUnit;


import java.time.temporal.TemporalAdjusters;


import java.util.*;


import java.util.stream.Collectors;




/**


 * 数据统计控制器


@@ -34,6 +50,28 @@


    private ICityService cityService;


    @Autowired


    private CityManagerClient cityManagerClient;


    @Autowired


    private AppUserClient appUserClient;


    @Autowired


    private VipPaymentClient vipPaymentClient;


    @Autowired


    private FinanceClient financeClient;


    @Autowired


    private CoursePackagePaymentClient coursePackagePaymentClient;


    @Autowired


    private CompetitionClient competitionClient;


    @Autowired


    private StoreClient storeClient;


    @Autowired


    private SiteClient siteClient;


    @Autowired


    private PointMercharsClient pointMercharsClient;


    @Autowired


    private RefundCoursePackageClient refundCoursePackageClient;


    @Resource


    private CourseStuddentClient courseStuddentClient;


    @Autowired


    private CoursePackageClient coursePackageClient;


    /**


     * 跳转到平台统计数据页面


     */


@@ -41,6 +79,395 @@


    public String index(Model model) {


        return PREFIX + "platformIncome.html";


    }




    /**


     * 营收数据-平台


     *


     */


    @RequestMapping(value = "/getIncomeData")


    @ResponseBody


    public Object getIncomeData(Integer type) {


        // 充值记录查询query


        RechargeRecordsQuery rechargeRecordsQuery = new RechargeRecordsQuery();


        // 报名课程查询query


        RegisterOrderQuery query = new RegisterOrderQuery();


        // 赛事活动查询query


        CompetitionQuery competitionQuery = new CompetitionQuery();


        // 会员支付查询query


        IncomeQuery incomeQuery = new IncomeQuery();


        // 场地预约记录查询query


        SiteBookingQuery siteBookingQuery = new SiteBookingQuery();


        Integer roleType = UserExt.getUser().getObjectType();


        IncomeVO incomeVO = new IncomeVO();


        List<IncomeVO> incomeVOS = new ArrayList<>();


                // 会员支付记录


                List<VipPayment> vipPayments = vipPaymentClient.registrationList(incomeQuery);


                for (VipPayment vipPayment : vipPayments) {


                    IncomeVO temp = new IncomeVO();


                    if (vipPayment.getPayStatus()==1){


                        temp.setInsertTime(vipPayment.getInsertTime());


                        incomeVOS.add(temp);


                    }


                    if (vipPayment.getAmount() != null) {


                        temp.setAmount(new BigDecimal(vipPayment.getAmount().toString()));


                    }


                }


                // 充值记录


                List<RechargeRecordsVO> rechargeRecordsVOS = financeClient.rechargeList(rechargeRecordsQuery);


                for (RechargeRecordsVO rechargeRecordsVO : rechargeRecordsVOS) {


                    IncomeVO temp = new IncomeVO();


                    temp.setInsertTime(rechargeRecordsVO.getInsertTime());


                    if (rechargeRecordsVO.getAmount() != null) {


                        temp.setAmount(rechargeRecordsVO.getAmount());


                    }


                    if (rechargeRecordsVO.getPayStatus() ==1){


                        incomeVOS.add(temp);


                    }




                }


                // 报名课程记录


                List<RegisterOrderVO> registerOrderVOS = coursePackagePaymentClient.listAllRegister(query);


                for (RegisterOrderVO registerOrderVO : registerOrderVOS) {


                    if (registerOrderVO.getMoney() == null) {


                        continue;


                    }


                    IncomeVO temp = new IncomeVO();


                    temp.setInsertTime(registerOrderVO.getInsertTime());


                    if (registerOrderVO.getMoney() != null) {


                        temp.setAmount(registerOrderVO.getMoney());


                    }


                    if (registerOrderVO.getPayStatus()==2){


                        incomeVOS.add(temp);


                    }


                }


                    // 报名活动


                    List<PaymentCompetition> competitions = competitionClient.listAllPayment(competitionQuery);


                    for (PaymentCompetition competition : competitions) {


                        if (competition.getPayStatus() != 2) {


                            continue;


                        }


                        if (competition.getPayType()==3 || competition.getPayType()==4){


                            continue;


                        }


                        IncomeVO temp = new IncomeVO();


                        temp.setInsertTime(competition.getInsertTime());


                        if (competition.getAmount() != null) {


                            temp.setAmount(new BigDecimal(competition.getAmount().toString()));


                        }


                        incomeVOS.add(temp);


                    }


                // 预约场地


                List<SiteBooking> siteBookings = siteClient.listAll(siteBookingQuery);


                for (SiteBooking siteBooking : siteBookings) {


                    IncomeVO temp = new IncomeVO();


                    if(siteBooking.getStatus()!=3){


                        continue;


                    }


                    temp.setInsertTime(siteBooking.getPayTime());


                    if (siteBooking.getPayMoney() != null) {


                        temp.setAmount(new BigDecimal(siteBooking.getPayMoney().toString()));


                    }


                    incomeVOS.add(temp);


                }


        // 积分商品


        List<PointMerchandiseIncomeVo> amount = pointMercharsClient.getAmount();


        for (PointMerchandiseIncomeVo pointMerchandiseIncomeVo : amount) {


            IncomeVO temp = new IncomeVO();


            temp.setInsertTime(pointMerchandiseIncomeVo.getInsertTime());


            if (pointMerchandiseIncomeVo.getCash()!=null){


                temp.setAmount(pointMerchandiseIncomeVo.getCash());


                incomeVOS.add(temp);


            }


        }




        // 最终返回的数据


        Map<String, List<Object>> monthlyData = new HashMap<>();


        // 创建一个 Map 用于存储每年的累计 amount


        Map<Integer, BigDecimal> yearToTotalAmountMap = new HashMap<>();


        // 初始化一个 BigDecimal 用于累加


        BigDecimal totalAmount1 = BigDecimal.ZERO;


        // 用于返回图表上的总营收 年度营收 月度 周度 日度


        List<Object> objects = new ArrayList<>();


        // 遍历 incomeVOS


        for (IncomeVO incomeVO1 : incomeVOS) {


            // 总营收


            BigDecimal total = incomeVO1.getAmount();


            // 累加到总金额


            totalAmount1 = totalAmount1.add(total);




            Date insertTime = incomeVO1.getInsertTime(); // 假设有一个方法用于获取 insertTime


            BigDecimal amount1 = incomeVO1.getAmount(); // 假设有一个方法用于获取 amount


            Calendar calendar = Calendar.getInstance();


            calendar.setTime(insertTime);


            int year = calendar.get(Calendar.YEAR); // 获取年份


            // 更新年份对应的累计 amount


            if (yearToTotalAmountMap.containsKey(year)) {


                BigDecimal totalAmount = yearToTotalAmountMap.get(year);


                yearToTotalAmountMap.put(year, totalAmount.add(amount1));


            } else {


                yearToTotalAmountMap.put(year, amount1);


            }


        }


        objects.add(totalAmount1);


        // 创建一个新的列表，按年份升序排列


        List<Integer> sortedYears = new ArrayList<>(yearToTotalAmountMap.keySet());


        Collections.sort(sortedYears);


        // 创建一个新的 IncomeVO 列表，包含按年份累计的 amount


        List<Object> resultIncomeVOS = new ArrayList<>();


        // 循环遍历2023年到2028年的年份


        for (int year = 2023; year <= 2028; year++) {


            BigDecimal totalAmount = yearToTotalAmountMap.getOrDefault(year, BigDecimal.ZERO);


            // 创建一个新的 IncomeVO 对象，并设置年份和累计金额


            IncomeVO resultIncomeVO = new IncomeVO();


            resultIncomeVO.setAmount(totalAmount);


            resultIncomeVOS.add(resultIncomeVO);


        }


        monthlyData.put("yearIncome",resultIncomeVOS);




        // 创建一个 Map 用于存储今年每个月的累计 amount


        Map<Integer, BigDecimal> monthToTotalAmountMap = new HashMap<>();


        Calendar calendar = Calendar.getInstance();


        int currentYear = calendar.get(Calendar.YEAR);


        List<BigDecimal> monthlyAmountList = new ArrayList<>(Collections.nCopies(12, BigDecimal.ZERO));




        for (IncomeVO incomeVO1 : incomeVOS) {


            Calendar calendar1 = Calendar.getInstance();


            calendar1.setTime(incomeVO1.getInsertTime());


            int year = calendar1.get(Calendar.YEAR);


            int month = calendar1.get(Calendar.MONTH) + 1; // 月份从0开始，所以需要加1


            if (year == currentYear) {


                BigDecimal totalAmount = monthlyAmountList.get(month - 1);


                totalAmount = totalAmount.add(incomeVO1.getAmount());


                monthlyAmountList.set(month - 1, totalAmount);


            }


        }


        monthlyData.put("monthIncome", Collections.singletonList(monthlyAmountList));




        // 获取当前月份


        LocalDate currentDate = LocalDate.now();


        int currentMonth = currentDate.getMonthValue();


        // 初始化一个长度为当前月份的天数的列表，并将每一天的金额初始化为零


        int daysInCurrentMonth = currentDate.lengthOfMonth();


        List<BigDecimal> weekAmount = new ArrayList<>(daysInCurrentMonth);


        for (int i = 0; i < daysInCurrentMonth; i++) {


            weekAmount.add(BigDecimal.ZERO);


        }


        for (IncomeVO incomeVO1 : incomeVOS) {


            SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");


            String string = dateFormat.format(incomeVO1.getInsertTime());


            LocalDate insertDate = LocalDate.parse(string, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));


            if (insertDate.getMonthValue() == currentMonth) {


                int dayOfMonth = insertDate.getDayOfMonth();


                BigDecimal currentAmount = weekAmount.get(dayOfMonth - 1); // 列表索引从0开始


                weekAmount.set(dayOfMonth - 1, currentAmount.add(incomeVO1.getAmount()));


            }


        }


        monthlyData.put("weekIncome", Collections.singletonList(weekAmount));




        LocalDateTime currentDateTime = LocalDateTime.now();


        List<BigDecimal> amountByDay = new ArrayList<>(Collections.nCopies(7, BigDecimal.ZERO));


        for (IncomeVO incomeVO3 : incomeVOS) {


            Date insertTime = incomeVO3.getInsertTime();


            // 将 Date 转换为 LocalDateTime


            LocalDateTime insertDateTime = LocalDateTime.ofInstant(insertTime.toInstant(), ZoneId.systemDefault());


            // 计算日期与当前日期的差距


            long daysDifference = ChronoUnit.DAYS.between(insertDateTime.toLocalDate(), currentDateTime.toLocalDate());


            // 如果日期在七天内，累加金额


            if (daysDifference >= 0 && daysDifference < 7) {


                int index = (int) (6 - daysDifference); // 计算对应的索引位置


                BigDecimal amount3 = incomeVO3.getAmount();


                BigDecimal updatedAmount = amountByDay.get(index).add(amount3);


                amountByDay.set(index, updatedAmount);




            }


        }




        monthlyData.put("dayIncome", Collections.singletonList(amountByDay));


        // 创建一个 Map 用于存储今年本周的累计 amount


        Map<Integer, BigDecimal> dayToTotalAmountMap = new HashMap<>();


        BigDecimal yearAmount = BigDecimal.ZERO; // 初始化累加变量为0


        BigDecimal monthAmount = BigDecimal.ZERO; // 初始化累加变量为0


        BigDecimal todayAmount = BigDecimal.ZERO; // 初始化累加变量为0


        // 获取当前日期和时间


        LocalDateTime now = LocalDateTime.now();


        // 今年的起始日期和结束日期


        LocalDateTime startOfYear = now.with(TemporalAdjusters.firstDayOfYear()).with(LocalTime.MIN);


        LocalDateTime endOfYear = now.with(TemporalAdjusters.lastDayOfYear()).with(LocalTime.MAX);


        // 本月的起始日期和结束日期


        LocalDateTime startOfMonth = now.with(TemporalAdjusters.firstDayOfMonth()).with(LocalTime.MIN);


        LocalDateTime endOfMonth = now.with(TemporalAdjusters.lastDayOfMonth()).with(LocalTime.MAX);


        // 本周的起始日期和结束日期


        LocalDateTime startOfWeek = now.with(TemporalAdjusters.previousOrSame(DayOfWeek.MONDAY)).with(LocalTime.MIN);


        LocalDateTime endOfWeek = now.with(TemporalAdjusters.nextOrSame(DayOfWeek.SUNDAY)).with(LocalTime.MAX);


        // 今天的起始日期和结束日期


        LocalDateTime startOfDay = now.with(LocalTime.MIN);


        LocalDateTime endOfDay = now.with(LocalTime.MAX);


        // 创建日期格式化器


        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");


        // 筛选符合条件的IncomeVO对象


        List<IncomeVO> thisYearIncome = incomeVOS.stream()


                .filter(income -> {


                    Date insertTime = income.getInsertTime();


                    try {


                        LocalDateTime insertDateTime = LocalDateTime.ofInstant(insertTime.toInstant(), ZoneId.systemDefault());


                        return insertDateTime.isAfter(startOfYear) && insertDateTime.isBefore(endOfYear);


                    } catch (Exception e) {


                        e.printStackTrace();


                        return false;


                    }


                })


                .collect(Collectors.toList());


        // 使用 map 方法将 IncomeVO 转换为 BigDecimal，提取出 amount 字段


        List<BigDecimal> amounts = thisYearIncome.stream()


                .map(IncomeVO::getAmount)


                .collect(Collectors.toList());


        //本年总收入


        BigDecimal totalAmount = amounts.stream()


                .reduce(BigDecimal.ZERO, BigDecimal::add);


        // 用于展示总营收 本年度营收 本月营收 本周营收 本日营收


        objects.add(totalAmount);


        List<IncomeVO> thisMonthIncome = incomeVOS.stream()


                .filter(income -> {


                    Date insertTime = income.getInsertTime();


                    try {


                        LocalDateTime insertDateTime = LocalDateTime.ofInstant(insertTime.toInstant(), ZoneId.systemDefault());


                        return insertDateTime.isAfter(startOfMonth) && insertDateTime.isBefore(endOfMonth);


                    } catch (Exception e) {


                        e.printStackTrace();


                        return false;


                    }


                })


                .collect(Collectors.toList());


        List<BigDecimal> amountMonth = thisMonthIncome.stream()


                .map(IncomeVO::getAmount)


                .collect(Collectors.toList());


        // 使用 本月总收入


        BigDecimal totalMonth = amountMonth.stream()


                .reduce(BigDecimal.ZERO, BigDecimal::add);




        objects.add(totalMonth);


        List<IncomeVO> thisWeekIncome = incomeVOS.stream()


                .filter(income -> {


                    Date insertTime = income.getInsertTime();


                    try {


                        LocalDateTime insertDateTime = LocalDateTime.ofInstant(insertTime.toInstant(), ZoneId.systemDefault());


                        return insertDateTime.isAfter(startOfWeek) && insertDateTime.isBefore(endOfWeek);


                    } catch (Exception e) {


                        e.printStackTrace();


                        return false;


                    }


                })


                .collect(Collectors.toList());


        List<BigDecimal> amountWeek = thisWeekIncome.stream()


                .map(IncomeVO::getAmount)


                .collect(Collectors.toList());


        // 使用 本月总收入


        BigDecimal totalWeek = amountWeek.stream()


                .reduce(BigDecimal.ZERO, BigDecimal::add);


        objects.add(totalWeek);


        List<IncomeVO> todayIncome = incomeVOS.stream()


                .filter(income -> {


                    Date insertTime = income.getInsertTime();


                    try {


                        LocalDateTime insertDateTime = LocalDateTime.ofInstant(insertTime.toInstant(), ZoneId.systemDefault());


                        return insertDateTime.isAfter(startOfDay) && insertDateTime.isBefore(endOfDay);


                    } catch (Exception e) {


                        e.printStackTrace();


                        return false;


                    }


                })


                .collect(Collectors.toList());


        List<BigDecimal> amountToday = todayIncome.stream()


                .map(IncomeVO::getAmount)


                .collect(Collectors.toList());


        // 使用 本月总收入


        BigDecimal totalToday = amountToday.stream()


                .reduce(BigDecimal.ZERO, BigDecimal::add);


        objects.add(totalToday);


        // 最后put


        monthlyData.put("yearMount",objects);




        return monthlyData;


    }




    /**


     * 运营统计-平台-用户数据


     *


     */


    @RequestMapping(value = "/getUserData")


    @ResponseBody


    public Object getUserData() {






        return null;


    }


    /**


     * 退费-平台


     *


     */


    @RequestMapping(value = "/getRefundData")


    @ResponseBody


    public Object getRefundData(Integer type) {


        // 赛事活动查询query


        CompetitionQuery competitionQuery = new CompetitionQuery();


        List<IncomeVO> incomeVOS = new ArrayList<>();


        // 获取学员课包退费


        List<MoneyBack> refund = refundCoursePackageClient.getRefund();




        for (MoneyBack moneyBack : refund) {


            List<TCoursePackagePayment> coursePackagePayments =  courseStuddentClient.queryByIds(moneyBack.getIds());


            BigDecimal totalAmount = BigDecimal.ZERO;


            for (TCoursePackagePayment payment : coursePackagePayments){


                //课包名称


                TCoursePackage tCoursePackage = coursePackageClient.queryById(payment.getCoursePackageId());


                payment.setName(tCoursePackage.getName());


                payment.setId(Long.valueOf(tCoursePackage.getId()));


                BigDecimal cashPayment = payment.getCashPayment();


                if (cashPayment==null){


                    cashPayment = BigDecimal.ZERO;


                }


                Integer totalClassHours = payment.getTotalClassHours();


                BigDecimal result =  new BigDecimal(0);


                if (totalClassHours!=0) {


                    result = cashPayment.divide(BigDecimal.valueOf(totalClassHours), 2, RoundingMode.HALF_UP);


                }


                //单价


                payment.setOnePrice(result);


                int has = payment.getTotalClassHours() - payment.getLaveClassHours();


                //剩余课时


                payment.setHasHours(has);


                BigDecimal onePrice = payment.getOnePrice();


                Integer laveClassHours = payment.getLaveClassHours();


                BigDecimal result1 = onePrice.multiply(BigDecimal.valueOf(laveClassHours));


                //总价


                payment.setRestPrice(result1);


                System.out.println("======="+result1);


                totalAmount = totalAmount.add(result1);


                IncomeVO temp = new IncomeVO();


                temp.setInsertTime(payment.getInsertTime());


                temp.setAmount(result1);


                incomeVOS.add(temp);


            }


        }


        // 获取赛事退费记录


        List<PaymentCompetition> competitions = competitionClient.listAllPayment(competitionQuery);


        for (PaymentCompetition competition : competitions) {


            if (competition.getPayStatus() != 3) {


                continue;


            }


            if (competition.getPayType()==3 || competition.getPayType()==4){


                continue;


            }


            IncomeVO temp = new IncomeVO();


            temp.setInsertTime(competition.getInsertTime());


            if (competition.getAmount() != null) {


                temp.setAmount(new BigDecimal(competition.getAmount().toString()));


            }


            incomeVOS.add(temp);


        }




        return null;


    }


    /**


     * 跳转到运营商统计数据页面


     */