From 44311853fa68f04db11d341bd374a4ac9b5ea567 Mon Sep 17 00:00:00 2001
From: liujie <liujie>
Date: 星期六, 07 十月 2023 17:37:42 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
cloud-server-management/src/main/java/com/dsh/guns/modular/system/controller/code/DataStatisticsController.java | 443 ++++++++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 435 insertions(+), 8 deletions(-)
diff --git a/cloud-server-management/src/main/java/com/dsh/guns/modular/system/controller/code/DataStatisticsController.java b/cloud-server-management/src/main/java/com/dsh/guns/modular/system/controller/code/DataStatisticsController.java
index 20603a8..deeb3ec 100644
--- a/cloud-server-management/src/main/java/com/dsh/guns/modular/system/controller/code/DataStatisticsController.java
+++ b/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;
+ }
/**
* 跳转到运营商统计数据页面
*/
--
Gitblit v1.7.1