zayac/zayac-admin
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

重构了部分代码

Browse Source 
完善保存的功能
This commit is contained in:
zayac 2024-06-04 19:25:11 +08:00
parent f0b54f045a
commit 693f4e5f0f
39 changed files with 3278 additions and 485 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
zayac-admin-agent/src/main/java/com/zayac/admin/agent/mapper/DailyStatsMapper.java Normal file
View File

@ -0,0 +1,12 @@
package com.zayac.admin.agent.mapper;
import top.continew.starter.data.mybatis.plus.base.BaseMapper;
import com.zayac.admin.agent.model.entity.StatsDO;
/**
* 代理每日数据 Mapper
*
* @author zayac
* @since 2024/06/04 17:10
*/
public interface DailyStatsMapper extends BaseMapper<StatsDO> {}

12
zayac-admin-agent/src/main/java/com/zayac/admin/agent/mapper/FinanceMapper.java Normal file
View File

@ -0,0 +1,12 @@
package com.zayac.admin.agent.mapper;
import top.continew.starter.data.mybatis.plus.base.BaseMapper;
import com.zayac.admin.agent.model.entity.FinanceDO;
/**
* 代理线财务报 Mapper
*
* @author zayac
* @since 2024/06/04 17:14
*/
public interface FinanceMapper extends BaseMapper<FinanceDO> {}

12
zayac-admin-agent/src/main/java/com/zayac/admin/agent/mapper/FinanceSumMapper.java Normal file
View File

@ -0,0 +1,12 @@
package com.zayac.admin.agent.mapper;
import top.continew.starter.data.mybatis.plus.base.BaseMapper;
import com.zayac.admin.agent.model.entity.FinanceSumDO;
/**
* 财务报汇总 Mapper
*
* @author zayac
* @since 2024/06/04 17:10
*/
public interface FinanceSumMapper extends BaseMapper<FinanceSumDO> {}

301
zayac-admin-agent/src/main/java/com/zayac/admin/agent/model/entity/FinanceDO.java Normal file
View File

@ -0,0 +1,301 @@
package com.zayac.admin.agent.model.entity;
import java.io.Serial;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.math.BigDecimal;
import lombok.Data;
import com.baomidou.mybatisplus.annotation.TableName;
import top.continew.starter.extension.crud.model.entity.BaseDO;
/**
* 代理线财务报实体
*
* @author zayac
* @since 2024/06/04 17:14
*/
@Data
@TableName("agent_finance")
public class FinanceDO extends BaseDO {
@Serial
private static final long serialVersionUID = 1L;
/**
* 会员ID
*/
private Long memberId;
/**
* 代理名称
*/
private String agentName;
/**
* 邀请码
*/
private String inviteCode;
/**
* 顶级代理名称
*/
private String topName;
/**
* 分类ID
*/
private Integer category;
/**
* 分类名称
*/
private String categoryName;
/**
* 佣金日期
*/
private LocalDate commissionDate;
/**
* 活跃状态
*/
private Integer active;
/**
* 下属用户数量
*/
private Integer subordinateUserCount;
/**
* 存款金额
*/
private BigDecimal deposit;
/**
* 取款金额
*/
private BigDecimal draw;
/**
* 利润
*/
private BigDecimal profit;
/**
* 第三方支出
*/
private BigDecimal thirdPartySpend;
/**
* 促销金额
*/
private BigDecimal promo;
/**
* 回扣金额
*/
private BigDecimal rebate;
/**
* 净利润
*/
private BigDecimal netProfit;
/**
* 风险调整金额
*/
private BigDecimal riskAdjust;
/**
* 调整后利润
*/
private String czProfit;
/**
* 费率
*/
private String rate;
/**
* 上一次余额
*/
private BigDecimal lastBalance;
/**
* 修正值
*/
private BigDecimal correction;
/**
* 佣金
*/
private BigDecimal commission;
/**
* 余额
*/
private BigDecimal balance;
/**
* 备注
*/
private String remark;
/**
* 代理备注
*/
private String agentRemark;
/**
* 管理员名称
*/
private String adminName;
/**
* 佣金状态
*/
private Integer commissionStatus;
/**
* 平台详情
*/
private String plateDetail;
/**
* 发布日期
*/
private LocalDateTime releaseAt;
/**
* 团队名称
*/
private String teamName;
/**
* 发送备注
*/
private String sendRemark;
/**
* 代理状态
*/
private Integer agentStatus;
/**
* 二级线路
*/
private Integer secondaryLine;
/**
* 是否为队长
*/
private Boolean isCaptain;
/**
* 名称
*/
private String name;
/**
* 存款次数
*/
private Integer countDeposit;
/**
* 取款次数
*/
private Integer countDraw;
/**
* 投注次数
*/
private Integer countBets;
/**
* VIP特殊佣金
*/
private String vipSpecialCommission;
/**
* 新的活跃状态
*/
private Integer newActive;
/**
* 修正后的净利润
*/
private String repairNetProfit;
/**
* 显示的佣金率
*/
private Integer showCommissionRate;
/**
* 有效的新用户
*/
private Integer effectiveNew;
/**
* 修正值
*/
private String repCorrection;
/**
* 手续费
*/
private BigDecimal handlingFee;
/**
* 合作利润
*/
private Integer partnershipProfit;
/**
* 投注金额
*/
private BigDecimal bets;
/**
* 彩票投注金额
*/
private BigDecimal lotteryBet;
/**
* 成本金额
*/
private BigDecimal costMoney;
/**
* 成本率
*/
private BigDecimal costRate;
/**
* 回扣率
*/
private BigDecimal rebateRate;
/**
* 彩票佣金
*/
private BigDecimal lotteryCommission;
/**
* 负利润率
*/
private BigDecimal negativeProfitRate;
/**
* 负利润佣金
*/
private BigDecimal negativeProfitCommission;
/**
* 彩票利润
*/
private BigDecimal lotteryProfit;
}

164
zayac-admin-agent/src/main/java/com/zayac/admin/agent/model/entity/FinanceSumDO.java Normal file
View File

@ -0,0 +1,164 @@
package com.zayac.admin.agent.model.entity;
import java.io.Serial;
import java.math.BigDecimal;
import lombok.Data;
import com.baomidou.mybatisplus.annotation.TableName;
import top.continew.starter.extension.crud.model.entity.BaseDO;
/**
* 财务报汇总实体
*
* @author zayac
* @since 2024/06/04 17:10
*/
@Data
@TableName("agent_finance_sum")
public class FinanceSumDO extends BaseDO {
@Serial
private static final long serialVersionUID = 1L;
/**
* 下属用户数量总和
*/
private Integer subordinateUserCountSum;
/**
* 活跃总和
*/
private Integer activeSum;
/**
* 净利润总和
*/
private BigDecimal netProfitSum;
/**
* 上一次余额总和
*/
private BigDecimal lastBalanceSum;
/**
* 调整后利润总和
*/
private BigDecimal czProfitSum;
/**
* 费率
*/
private BigDecimal rate;
/**
* 修正总和
*/
private BigDecimal correctionSum;
/**
* 重复修正总和
*/
private BigDecimal repCorrectionSum;
/**
* 佣金总和
*/
private BigDecimal commissionSum;
/**
* VIP特殊佣金总和
*/
private BigDecimal vipSpecialCommissionSum;
/**
* 修正后的净利润
*/
private BigDecimal repairNetProfit;
/**
* 佣金状态
*/
private Integer commissionStatus;
/**
* 代理名称
*/
private String agentName;
/**
* 有效新用户总和
*/
private Integer effectiveNewSum;
/**
* 手续费
*/
private BigDecimal handlingFee;
/**
* 合作利润
*/
private Integer partnershipProfit;
/**
* 彩票投注总和
*/
private Integer lotteryBetSum;
/**
* 回扣率总和
*/
private BigDecimal rebateRateSum;
/**
* 彩票佣金总和
*/
private BigDecimal lotteryCommissionSum;
/**
* 负利润佣金总和
*/
private BigDecimal negativeProfitCommissionSum;
/**
* 负利润率总和
*/
private BigDecimal negativeProfitRateSum;
/**
* 成本率总和
*/
private BigDecimal costRateSum;
/**
* 成本金额总和
*/
private BigDecimal costMoneySum;
/**
* 利润总和
*/
private BigDecimal profitSum;
/**
* 第三方支出总和
*/
private BigDecimal thirdPartySpendSum;
/**
* 促销总和
*/
private BigDecimal promoSum;
/**
* 回扣总和
*/
private BigDecimal rebateSum;
/**
* 风险调整总和
*/
private BigDecimal riskAdjustSum;
}

161
zayac-admin-agent/src/main/java/com/zayac/admin/agent/model/entity/StatsDO.java Normal file
View File

@ -0,0 +1,161 @@
package com.zayac.admin.agent.model.entity;
import java.io.Serial;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.math.BigDecimal;
import lombok.Data;
import com.baomidou.mybatisplus.annotation.TableName;
import top.continew.starter.extension.crud.model.entity.BaseDO;
/**
* 代理每日数据实体
*
* @author zayac
* @since 2024/06/04 17:10
*/
@Data
@TableName("agent_stats")
public class StatsDO extends BaseDO {
@Serial
private static final long serialVersionUID = 1L;
/**
* 日期
*/
private LocalDate staticsDate;
/**
* 代理id
*/
private Long agentId;
/**
* 代理类型
*/
private Integer agentType;
/**
* 代理推荐码
*/
private String agentCode;
/**
* 代理名称
*/
private String agentName;
/**
* 注册人数
*/
private Integer isNew;
/**
* 首存人数
*/
private BigDecimal firstDeposit;
/**
* 投注额
*/
private BigDecimal deposit;
/**
* 投注红利
*/
private BigDecimal depositPromo;
/**
* 取款
*/
private BigDecimal draw;
/**
* 返水
*/
private BigDecimal promo;
/**
* 返水比例
*/
private BigDecimal promoDividend;
/**
*
*/
private BigDecimal rebate;
/**
* 账号调整
*/
private BigDecimal adjust;
/**
* 风险等级
*/
private BigDecimal riskAdjust;
/**
* 有效投注额
*/
private BigDecimal bets;
/**
* 输赢
*/
private BigDecimal profit;
/**
* 总投注额
*/
private BigDecimal allBets;
/**
* 首存人数
*/
private Integer firstCount;
/**
* 存款人数
*/
private Integer countDeposit;
/**
* 取款人数
*/
private Integer countDraw;
/**
* 投注人数
*/
private Integer countBets;
/**
* 创建日期
*/
private LocalDateTime createdAt;
/**
* 更新日期
*/
private LocalDateTime updatedAt;
/**
*
*/
private BigDecimal oldDeposit;
/**
*
*/
private Integer oldDepositCount;
/**
*
*/
private BigDecimal newDeposit;
}

41
zayac-admin-agent/src/main/java/com/zayac/admin/agent/model/query/FinanceQuery.java Normal file
View File

@ -0,0 +1,41 @@
package com.zayac.admin.agent.model.query;
import java.io.Serial;
import java.io.Serializable;
import java.time.LocalDateTime;
import java.math.BigDecimal;
import lombok.Data;
import io.swagger.v3.oas.annotations.media.Schema;
import top.continew.starter.data.core.annotation.Query;
import top.continew.starter.data.core.enums.QueryType;
/**
* 代理线财务报查询条件
*
* @author zayac
* @since 2024/06/04 17:14
*/
@Data
@Schema(description = "代理线财务报查询条件")
public class FinanceQuery implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
/**
* 创建人
*/
@Schema(description = "创建人")
@Query(type = QueryType.EQ)
private Long createUser;
/**
* 创建时间
*/
@Schema(description = "创建时间")
@Query(type = QueryType.EQ)
private LocalDateTime createTime;
}

27
zayac-admin-agent/src/main/java/com/zayac/admin/agent/model/query/FinanceSumQuery.java Normal file
View File

@ -0,0 +1,27 @@
package com.zayac.admin.agent.model.query;
import java.io.Serial;
import java.io.Serializable;
import java.time.LocalDateTime;
import java.math.BigDecimal;
import lombok.Data;
import io.swagger.v3.oas.annotations.media.Schema;
import top.continew.starter.data.core.annotation.Query;
import top.continew.starter.data.core.enums.QueryType;
/**
* 财务报汇总查询条件
*
* @author zayac
* @since 2024/06/04 17:10
*/
@Data
@Schema(description = "财务报汇总查询条件")
public class FinanceSumQuery implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
}

48
zayac-admin-agent/src/main/java/com/zayac/admin/agent/model/query/StatsQuery.java Normal file
View File

@ -0,0 +1,48 @@
package com.zayac.admin.agent.model.query;
import java.io.Serial;
import java.io.Serializable;
import java.time.LocalDate;
import java.time.LocalDateTime;
import lombok.Data;
import io.swagger.v3.oas.annotations.media.Schema;
import top.continew.starter.data.core.annotation.Query;
import top.continew.starter.data.core.enums.QueryType;
/**
* 代理每日数据查询条件
*
* @author zayac
* @since 2024/06/04 17:10
*/
@Data
@Schema(description = "代理每日数据查询条件")
public class StatsQuery implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
/**
* 日期
*/
@Schema(description = "日期")
@Query(type = QueryType.EQ)
private LocalDate staticsDate;
/**
* 代理id
*/
@Schema(description = "代理id")
@Query(type = QueryType.EQ)
private Long agentId;
/**
* 创建时间
*/
@Schema(description = "创建时间")
@Query(type = QueryType.EQ)
private LocalDateTime createTime;
}

305
zayac-admin-agent/src/main/java/com/zayac/admin/agent/model/req/FinanceReq.java Normal file
View File

@ -0,0 +1,305 @@
package com.zayac.admin.agent.model.req;
import java.io.Serial;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.math.BigDecimal;
import jakarta.validation.constraints.*;
import lombok.Data;
import io.swagger.v3.oas.annotations.media.Schema;
import org.hibernate.validator.constraints.Length;
import top.continew.starter.extension.crud.model.req.BaseReq;
/**
* 创建或修改代理线财务报信息
*
* @author zayac
* @since 2024/06/04 17:14
*/
@Data
@Schema(description = "创建或修改代理线财务报信息")
public class FinanceReq extends BaseReq {
@Serial
private static final long serialVersionUID = 1L;
/**
* 会员ID
*/
private Long memberId;
/**
* 代理名称
*/
private String agentName;
/**
* 邀请码
*/
private String inviteCode;
/**
* 顶级代理名称
*/
private String topName;
/**
* 分类ID
*/
private Integer category;
/**
* 分类名称
*/
private String categoryName;
/**
* 佣金日期
*/
private LocalDate commissionDate;
/**
* 活跃状态
*/
private Integer active;
/**
* 下属用户数量
*/
private Integer subordinateUserCount;
/**
* 存款金额
*/
private BigDecimal deposit;
/**
* 取款金额
*/
private BigDecimal draw;
/**
* 利润
*/
private BigDecimal profit;
/**
* 第三方支出
*/
private BigDecimal thirdPartySpend;
/**
* 促销金额
*/
private BigDecimal promo;
/**
* 回扣金额
*/
private BigDecimal rebate;
/**
* 净利润
*/
private BigDecimal netProfit;
/**
* 风险调整金额
*/
private BigDecimal riskAdjust;
/**
* 调整后利润
*/
private String czProfit;
/**
* 费率
*/
private String rate;
/**
* 上一次余额
*/
private BigDecimal lastBalance;
/**
* 修正值
*/
private BigDecimal correction;
/**
* 佣金
*/
private BigDecimal commission;
/**
* 余额
*/
private BigDecimal balance;
/**
* 备注
*/
private String remark;
/**
* 代理备注
*/
private String agentRemark;
/**
* 管理员名称
*/
private String adminName;
/**
* 佣金状态
*/
private Integer commissionStatus;
/**
* 平台详情
*/
private String plateDetail;
/**
* 发布日期
*/
private LocalDateTime releaseAt;
/**
* 团队名称
*/
private String teamName;
/**
* 发送备注
*/
private String sendRemark;
/**
* 代理状态
*/
private Integer agentStatus;
/**
* 二级线路
*/
private Integer secondaryLine;
/**
* 是否为队长
*/
private Boolean isCaptain;
/**
* 名称
*/
private String name;
/**
* 存款次数
*/
private Integer countDeposit;
/**
* 取款次数
*/
private Integer countDraw;
/**
* 投注次数
*/
private Integer countBets;
/**
* VIP特殊佣金
*/
private String vipSpecialCommission;
/**
* 新的活跃状态
*/
private Integer newActive;
/**
* 修正后的净利润
*/
private String repairNetProfit;
/**
* 显示的佣金率
*/
private Integer showCommissionRate;
/**
* 有效的新用户
*/
private Integer effectiveNew;
/**
* 修正值
*/
private String repCorrection;
/**
* 手续费
*/
private BigDecimal handlingFee;
/**
* 合作利润
*/
private Integer partnershipProfit;
/**
* 投注金额
*/
private BigDecimal bets;
/**
* 彩票投注金额
*/
private BigDecimal lotteryBet;
/**
* 成本金额
*/
private BigDecimal costMoney;
/**
* 成本率
*/
private BigDecimal costRate;
/**
* 回扣率
*/
private BigDecimal rebateRate;
/**
* 彩票佣金
*/
private BigDecimal lotteryCommission;
/**
* 负利润率
*/
private BigDecimal negativeProfitRate;
/**
* 负利润佣金
*/
private BigDecimal negativeProfitCommission;
/**
* 彩票利润
*/
private BigDecimal lotteryProfit;
}

168
zayac-admin-agent/src/main/java/com/zayac/admin/agent/model/req/FinanceSumReq.java Normal file
View File

@ -0,0 +1,168 @@
package com.zayac.admin.agent.model.req;
import java.io.Serial;
import java.time.LocalDateTime;
import java.math.BigDecimal;
import lombok.Data;
import io.swagger.v3.oas.annotations.media.Schema;
import org.hibernate.validator.constraints.Length;
import top.continew.starter.extension.crud.model.req.BaseReq;
/**
* 创建或修改财务报汇总信息
*
* @author zayac
* @since 2024/06/04 17:10
*/
@Data
@Schema(description = "创建或修改财务报汇总信息")
public class FinanceSumReq extends BaseReq {
@Serial
private static final long serialVersionUID = 1L;
/**
* 下属用户数量总和
*/
private Integer subordinateUserCountSum;
/**
* 活跃总和
*/
private Integer activeSum;
/**
* 净利润总和
*/
private BigDecimal netProfitSum;
/**
* 上一次余额总和
*/
private BigDecimal lastBalanceSum;
/**
* 调整后利润总和
*/
private BigDecimal czProfitSum;
/**
* 费率
*/
private BigDecimal rate;
/**
* 修正总和
*/
private BigDecimal correctionSum;
/**
* 重复修正总和
*/
private BigDecimal repCorrectionSum;
/**
* 佣金总和
*/
private BigDecimal commissionSum;
/**
* VIP特殊佣金总和
*/
private BigDecimal vipSpecialCommissionSum;
/**
* 修正后的净利润
*/
private BigDecimal repairNetProfit;
/**
* 佣金状态
*/
private Integer commissionStatus;
/**
* 代理名称
*/
private String agentName;
/**
* 有效新用户总和
*/
private Integer effectiveNewSum;
/**
* 手续费
*/
private BigDecimal handlingFee;
/**
* 合作利润
*/
private Integer partnershipProfit;
/**
* 彩票投注总和
*/
private Integer lotteryBetSum;
/**
* 回扣率总和
*/
private BigDecimal rebateRateSum;
/**
* 彩票佣金总和
*/
private BigDecimal lotteryCommissionSum;
/**
* 负利润佣金总和
*/
private BigDecimal negativeProfitCommissionSum;
/**
* 负利润率总和
*/
private BigDecimal negativeProfitRateSum;
/**
* 成本率总和
*/
private BigDecimal costRateSum;
/**
* 成本金额总和
*/
private BigDecimal costMoneySum;
/**
* 利润总和
*/
private BigDecimal profitSum;
/**
* 第三方支出总和
*/
private BigDecimal thirdPartySpendSum;
/**
* 促销总和
*/
private BigDecimal promoSum;
/**
* 回扣总和
*/
private BigDecimal rebateSum;
/**
* 风险调整总和
*/
private BigDecimal riskAdjustSum;
}

163
zayac-admin-agent/src/main/java/com/zayac/admin/agent/model/req/StatsReq.java Normal file
View File

@ -0,0 +1,163 @@
package com.zayac.admin.agent.model.req;
import java.io.Serial;
import java.math.BigDecimal;
import java.time.LocalDate;
import java.time.LocalDateTime;
import jakarta.validation.constraints.*;
import lombok.Data;
import io.swagger.v3.oas.annotations.media.Schema;
import top.continew.starter.extension.crud.model.req.BaseReq;
/**
* 创建或修改代理每日数据信息
*
* @author zayac
* @since 2024/06/04 17:10
*/
@Data
@Schema(description = "创建或修改代理每日数据信息")
public class StatsReq extends BaseReq {
@Serial
private static final long serialVersionUID = 1L;
/**
* 日期
*/
private LocalDate staticsDate;
/**
* 代理id
*/
private Long agentId;
/**
* 代理类型
*/
private Integer agentType;
/**
* 代理推荐码
*/
private String agentCode;
/**
* 代理名称
*/
private String agentName;
/**
* 注册人数
*/
private Integer isNew;
/**
* 首存人数
*/
private BigDecimal firstDeposit;
/**
* 投注额
*/
private BigDecimal deposit;
/**
* 投注红利
*/
private BigDecimal depositPromo;
/**
* 取款
*/
private BigDecimal draw;
/**
* 返水
*/
private BigDecimal promo;
/**
* 返水比例
*/
private BigDecimal promoDividend;
/**
*
*/
private BigDecimal rebate;
/**
* 账号调整
*/
private BigDecimal adjust;
/**
* 风险等级
*/
private BigDecimal riskAdjust;
/**
* 有效投注额
*/
private BigDecimal bets;
/**
* 输赢
*/
private BigDecimal profit;
/**
* 总投注额
*/
private BigDecimal allBets;
/**
* 首存人数
*/
private Integer firstCount;
/**
* 存款人数
*/
private Integer countDeposit;
/**
* 取款人数
*/
private Integer countDraw;
/**
* 投注人数
*/
private Integer countBets;
/**
* 创建日期
*/
private LocalDateTime createdAt;
/**
* 更新日期
*/
private LocalDateTime updatedAt;
/**
*
*/
private BigDecimal oldDeposit;
/**
*
*/
private Integer oldDepositCount;
/**
*
*/
private BigDecimal newDeposit;
}

415
zayac-admin-agent/src/main/java/com/zayac/admin/agent/model/resp/FinanceDetailResp.java Normal file
View File

@ -0,0 +1,415 @@
package com.zayac.admin.agent.model.resp;
import java.io.Serial;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.math.BigDecimal;
import lombok.Data;
import io.swagger.v3.oas.annotations.media.Schema;
import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
import com.alibaba.excel.annotation.ExcelProperty;
import top.continew.starter.extension.crud.model.resp.BaseDetailResp;
/**
* 代理线财务报详情信息
*
* @author zayac
* @since 2024/06/04 17:14
*/
@Data
@ExcelIgnoreUnannotated
@Schema(description = "代理线财务报详情信息")
public class FinanceDetailResp extends BaseDetailResp {
@Serial
private static final long serialVersionUID = 1L;
/**
* 会员ID
*/
@Schema(description = "会员ID")
@ExcelProperty(value = "会员ID")
private Long memberId;
/**
* 代理名称
*/
@Schema(description = "代理名称")
@ExcelProperty(value = "代理名称")
private String agentName;
/**
* 邀请码
*/
@Schema(description = "邀请码")
@ExcelProperty(value = "邀请码")
private String inviteCode;
/**
* 顶级代理名称
*/
@Schema(description = "顶级代理名称")
@ExcelProperty(value = "顶级代理名称")
private String topName;
/**
* 分类ID
*/
@Schema(description = "分类ID")
@ExcelProperty(value = "分类ID")
private Integer category;
/**
* 分类名称
*/
@Schema(description = "分类名称")
@ExcelProperty(value = "分类名称")
private String categoryName;
/**
* 佣金日期
*/
@Schema(description = "佣金日期")
@ExcelProperty(value = "佣金日期")
private LocalDate commissionDate;
/**
* 活跃状态
*/
@Schema(description = "活跃状态")
@ExcelProperty(value = "活跃状态")
private Integer active;
/**
* 下属用户数量
*/
@Schema(description = "下属用户数量")
@ExcelProperty(value = "下属用户数量")
private Integer subordinateUserCount;
/**
* 存款金额
*/
@Schema(description = "存款金额")
@ExcelProperty(value = "存款金额")
private BigDecimal deposit;
/**
* 取款金额
*/
@Schema(description = "取款金额")
@ExcelProperty(value = "取款金额")
private BigDecimal draw;
/**
* 利润
*/
@Schema(description = "利润")
@ExcelProperty(value = "利润")
private BigDecimal profit;
/**
* 第三方支出
*/
@Schema(description = "第三方支出")
@ExcelProperty(value = "第三方支出")
private BigDecimal thirdPartySpend;
/**
* 促销金额
*/
@Schema(description = "促销金额")
@ExcelProperty(value = "促销金额")
private BigDecimal promo;
/**
* 回扣金额
*/
@Schema(description = "回扣金额")
@ExcelProperty(value = "回扣金额")
private BigDecimal rebate;
/**
* 净利润
*/
@Schema(description = "净利润")
@ExcelProperty(value = "净利润")
private BigDecimal netProfit;
/**
* 风险调整金额
*/
@Schema(description = "风险调整金额")
@ExcelProperty(value = "风险调整金额")
private BigDecimal riskAdjust;
/**
* 调整后利润
*/
@Schema(description = "调整后利润")
@ExcelProperty(value = "调整后利润")
private String czProfit;
/**
* 费率
*/
@Schema(description = "费率")
@ExcelProperty(value = "费率")
private String rate;
/**
* 上一次余额
*/
@Schema(description = "上一次余额")
@ExcelProperty(value = "上一次余额")
private BigDecimal lastBalance;
/**
* 修正值
*/
@Schema(description = "修正值")
@ExcelProperty(value = "修正值")
private BigDecimal correction;
/**
* 佣金
*/
@Schema(description = "佣金")
@ExcelProperty(value = "佣金")
private BigDecimal commission;
/**
* 余额
*/
@Schema(description = "余额")
@ExcelProperty(value = "余额")
private BigDecimal balance;
/**
* 备注
*/
@Schema(description = "备注")
@ExcelProperty(value = "备注")
private String remark;
/**
* 代理备注
*/
@Schema(description = "代理备注")
@ExcelProperty(value = "代理备注")
private String agentRemark;
/**
* 管理员名称
*/
@Schema(description = "管理员名称")
@ExcelProperty(value = "管理员名称")
private String adminName;
/**
* 佣金状态
*/
@Schema(description = "佣金状态")
@ExcelProperty(value = "佣金状态")
private Integer commissionStatus;
/**
* 平台详情
*/
@Schema(description = "平台详情")
@ExcelProperty(value = "平台详情")
private String plateDetail;
/**
* 发布日期
*/
@Schema(description = "发布日期")
@ExcelProperty(value = "发布日期")
private LocalDateTime releaseAt;
/**
* 团队名称
*/
@Schema(description = "团队名称")
@ExcelProperty(value = "团队名称")
private String teamName;
/**
* 发送备注
*/
@Schema(description = "发送备注")
@ExcelProperty(value = "发送备注")
private String sendRemark;
/**
* 代理状态
*/
@Schema(description = "代理状态")
@ExcelProperty(value = "代理状态")
private Integer agentStatus;
/**
* 二级线路
*/
@Schema(description = "二级线路")
@ExcelProperty(value = "二级线路")
private Integer secondaryLine;
/**
* 是否为队长
*/
@Schema(description = "是否为队长")
@ExcelProperty(value = "是否为队长")
private Boolean isCaptain;
/**
* 名称
*/
@Schema(description = "名称")
@ExcelProperty(value = "名称")
private String name;
/**
* 存款次数
*/
@Schema(description = "存款次数")
@ExcelProperty(value = "存款次数")
private Integer countDeposit;
/**
* 取款次数
*/
@Schema(description = "取款次数")
@ExcelProperty(value = "取款次数")
private Integer countDraw;
/**
* 投注次数
*/
@Schema(description = "投注次数")
@ExcelProperty(value = "投注次数")
private Integer countBets;
/**
* VIP特殊佣金
*/
@Schema(description = "VIP特殊佣金")
@ExcelProperty(value = "VIP特殊佣金")
private String vipSpecialCommission;
/**
* 新的活跃状态
*/
@Schema(description = "新的活跃状态")
@ExcelProperty(value = "新的活跃状态")
private Integer newActive;
/**
* 修正后的净利润
*/
@Schema(description = "修正后的净利润")
@ExcelProperty(value = "修正后的净利润")
private String repairNetProfit;
/**
* 显示的佣金率
*/
@Schema(description = "显示的佣金率")
@ExcelProperty(value = "显示的佣金率")
private Integer showCommissionRate;
/**
* 有效的新用户
*/
@Schema(description = "有效的新用户")
@ExcelProperty(value = "有效的新用户")
private Integer effectiveNew;
/**
* 修正值
*/
@Schema(description = "修正值")
@ExcelProperty(value = "修正值")
private String repCorrection;
/**
* 手续费
*/
@Schema(description = "手续费")
@ExcelProperty(value = "手续费")
private BigDecimal handlingFee;
/**
* 合作利润
*/
@Schema(description = "合作利润")
@ExcelProperty(value = "合作利润")
private Integer partnershipProfit;
/**
* 投注金额
*/
@Schema(description = "投注金额")
@ExcelProperty(value = "投注金额")
private BigDecimal bets;
/**
* 彩票投注金额
*/
@Schema(description = "彩票投注金额")
@ExcelProperty(value = "彩票投注金额")
private BigDecimal lotteryBet;
/**
* 成本金额
*/
@Schema(description = "成本金额")
@ExcelProperty(value = "成本金额")
private BigDecimal costMoney;
/**
* 成本率
*/
@Schema(description = "成本率")
@ExcelProperty(value = "成本率")
private BigDecimal costRate;
/**
* 回扣率
*/
@Schema(description = "回扣率")
@ExcelProperty(value = "回扣率")
private BigDecimal rebateRate;
/**
* 彩票佣金
*/
@Schema(description = "彩票佣金")
@ExcelProperty(value = "彩票佣金")
private BigDecimal lotteryCommission;
/**
* 负利润率
*/
@Schema(description = "负利润率")
@ExcelProperty(value = "负利润率")
private BigDecimal negativeProfitRate;
/**
* 负利润佣金
*/
@Schema(description = "负利润佣金")
@ExcelProperty(value = "负利润佣金")
private BigDecimal negativeProfitCommission;
/**
* 彩票利润
*/
@Schema(description = "彩票利润")
@ExcelProperty(value = "彩票利润")
private BigDecimal lotteryProfit;
}

368
zayac-admin-agent/src/main/java/com/zayac/admin/agent/model/resp/FinanceResp.java Normal file
View File

@ -0,0 +1,368 @@
package com.zayac.admin.agent.model.resp;
import java.io.Serial;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.math.BigDecimal;
import lombok.Data;
import io.swagger.v3.oas.annotations.media.Schema;
import top.continew.starter.extension.crud.model.resp.BaseResp;
/**
* 代理线财务报信息
*
* @author zayac
* @since 2024/06/04 17:14
*/
@Data
@Schema(description = "代理线财务报信息")
public class FinanceResp extends BaseResp {
@Serial
private static final long serialVersionUID = 1L;
/**
* 会员ID
*/
@Schema(description = "会员ID")
private Long memberId;
/**
* 代理名称
*/
@Schema(description = "代理名称")
private String agentName;
/**
* 邀请码
*/
@Schema(description = "邀请码")
private String inviteCode;
/**
* 顶级代理名称
*/
@Schema(description = "顶级代理名称")
private String topName;
/**
* 分类ID
*/
@Schema(description = "分类ID")
private Integer category;
/**
* 分类名称
*/
@Schema(description = "分类名称")
private String categoryName;
/**
* 佣金日期
*/
@Schema(description = "佣金日期")
private LocalDate commissionDate;
/**
* 活跃状态
*/
@Schema(description = "活跃状态")
private Integer active;
/**
* 下属用户数量
*/
@Schema(description = "下属用户数量")
private Integer subordinateUserCount;
/**
* 存款金额
*/
@Schema(description = "存款金额")
private BigDecimal deposit;
/**
* 取款金额
*/
@Schema(description = "取款金额")
private BigDecimal draw;
/**
* 利润
*/
@Schema(description = "利润")
private BigDecimal profit;
/**
* 第三方支出
*/
@Schema(description = "第三方支出")
private BigDecimal thirdPartySpend;
/**
* 促销金额
*/
@Schema(description = "促销金额")
private BigDecimal promo;
/**
* 回扣金额
*/
@Schema(description = "回扣金额")
private BigDecimal rebate;
/**
* 净利润
*/
@Schema(description = "净利润")
private BigDecimal netProfit;
/**
* 风险调整金额
*/
@Schema(description = "风险调整金额")
private BigDecimal riskAdjust;
/**
* 调整后利润
*/
@Schema(description = "调整后利润")
private String czProfit;
/**
* 费率
*/
@Schema(description = "费率")
private String rate;
/**
* 上一次余额
*/
@Schema(description = "上一次余额")
private BigDecimal lastBalance;
/**
* 修正值
*/
@Schema(description = "修正值")
private BigDecimal correction;
/**
* 佣金
*/
@Schema(description = "佣金")
private BigDecimal commission;
/**
* 余额
*/
@Schema(description = "余额")
private BigDecimal balance;
/**
* 备注
*/
@Schema(description = "备注")
private String remark;
/**
* 代理备注
*/
@Schema(description = "代理备注")
private String agentRemark;
/**
* 管理员名称
*/
@Schema(description = "管理员名称")
private String adminName;
/**
* 佣金状态
*/
@Schema(description = "佣金状态")
private Integer commissionStatus;
/**
* 平台详情
*/
@Schema(description = "平台详情")
private String plateDetail;
/**
* 发布日期
*/
@Schema(description = "发布日期")
private LocalDateTime releaseAt;
/**
* 团队名称
*/
@Schema(description = "团队名称")
private String teamName;
/**
* 发送备注
*/
@Schema(description = "发送备注")
private String sendRemark;
/**
* 代理状态
*/
@Schema(description = "代理状态")
private Integer agentStatus;
/**
* 二级线路
*/
@Schema(description = "二级线路")
private Integer secondaryLine;
/**
* 是否为队长
*/
@Schema(description = "是否为队长")
private Boolean isCaptain;
/**
* 名称
*/
@Schema(description = "名称")
private String name;
/**
* 存款次数
*/
@Schema(description = "存款次数")
private Integer countDeposit;
/**
* 取款次数
*/
@Schema(description = "取款次数")
private Integer countDraw;
/**
* 投注次数
*/
@Schema(description = "投注次数")
private Integer countBets;
/**
* VIP特殊佣金
*/
@Schema(description = "VIP特殊佣金")
private String vipSpecialCommission;
/**
* 新的活跃状态
*/
@Schema(description = "新的活跃状态")
private Integer newActive;
/**
* 修正后的净利润
*/
@Schema(description = "修正后的净利润")
private String repairNetProfit;
/**
* 显示的佣金率
*/
@Schema(description = "显示的佣金率")
private Integer showCommissionRate;
/**
* 有效的新用户
*/
@Schema(description = "有效的新用户")
private Integer effectiveNew;
/**
* 修正值
*/
@Schema(description = "修正值")
private String repCorrection;
/**
* 手续费
*/
@Schema(description = "手续费")
private BigDecimal handlingFee;
/**
* 合作利润
*/
@Schema(description = "合作利润")
private Integer partnershipProfit;
/**
* 投注金额
*/
@Schema(description = "投注金额")
private BigDecimal bets;
/**
* 彩票投注金额
*/
@Schema(description = "彩票投注金额")
private BigDecimal lotteryBet;
/**
* 成本金额
*/
@Schema(description = "成本金额")
private BigDecimal costMoney;
/**
* 成本率
*/
@Schema(description = "成本率")
private BigDecimal costRate;
/**
* 回扣率
*/
@Schema(description = "回扣率")
private BigDecimal rebateRate;
/**
* 彩票佣金
*/
@Schema(description = "彩票佣金")
private BigDecimal lotteryCommission;
/**
* 负利润率
*/
@Schema(description = "负利润率")
private BigDecimal negativeProfitRate;
/**
* 负利润佣金
*/
@Schema(description = "负利润佣金")
private BigDecimal negativeProfitCommission;
/**
* 彩票利润
*/
@Schema(description = "彩票利润")
private BigDecimal lotteryProfit;
/**
* 修改人
*/
@Schema(description = "修改人")
private Long updateUser;
/**
* 修改时间
*/
@Schema(description = "修改时间")
private LocalDateTime updateTime;
}

224
zayac-admin-agent/src/main/java/com/zayac/admin/agent/model/resp/FinanceSumDetailResp.java Normal file
View File

@ -0,0 +1,224 @@
package com.zayac.admin.agent.model.resp;
import java.io.Serial;
import java.math.BigDecimal;
import lombok.Data;
import io.swagger.v3.oas.annotations.media.Schema;
import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
import com.alibaba.excel.annotation.ExcelProperty;
import top.continew.starter.extension.crud.model.resp.BaseDetailResp;
/**
* 财务报汇总详情信息
*
* @author zayac
* @since 2024/06/04 17:10
*/
@Data
@ExcelIgnoreUnannotated
@Schema(description = "财务报汇总详情信息")
public class FinanceSumDetailResp extends BaseDetailResp {
@Serial
private static final long serialVersionUID = 1L;
/**
* 下属用户数量总和
*/
@Schema(description = "下属用户数量总和")
@ExcelProperty(value = "下属用户数量总和")
private Integer subordinateUserCountSum;
/**
* 活跃总和
*/
@Schema(description = "活跃总和")
@ExcelProperty(value = "活跃总和")
private Integer activeSum;
/**
* 净利润总和
*/
@Schema(description = "净利润总和")
@ExcelProperty(value = "净利润总和")
private BigDecimal netProfitSum;
/**
* 上一次余额总和
*/
@Schema(description = "上一次余额总和")
@ExcelProperty(value = "上一次余额总和")
private BigDecimal lastBalanceSum;
/**
* 调整后利润总和
*/
@Schema(description = "调整后利润总和")
@ExcelProperty(value = "调整后利润总和")
private BigDecimal czProfitSum;
/**
* 费率
*/
@Schema(description = "费率")
@ExcelProperty(value = "费率")
private BigDecimal rate;
/**
* 修正总和
*/
@Schema(description = "修正总和")
@ExcelProperty(value = "修正总和")
private BigDecimal correctionSum;
/**
* 重复修正总和
*/
@Schema(description = "重复修正总和")
@ExcelProperty(value = "重复修正总和")
private BigDecimal repCorrectionSum;
/**
* 佣金总和
*/
@Schema(description = "佣金总和")
@ExcelProperty(value = "佣金总和")
private BigDecimal commissionSum;
/**
* VIP特殊佣金总和
*/
@Schema(description = "VIP特殊佣金总和")
@ExcelProperty(value = "VIP特殊佣金总和")
private BigDecimal vipSpecialCommissionSum;
/**
* 修正后的净利润
*/
@Schema(description = "修正后的净利润")
@ExcelProperty(value = "修正后的净利润")
private BigDecimal repairNetProfit;
/**
* 佣金状态
*/
@Schema(description = "佣金状态")
@ExcelProperty(value = "佣金状态")
private Integer commissionStatus;
/**
* 代理名称
*/
@Schema(description = "代理名称")
@ExcelProperty(value = "代理名称")
private String agentName;
/**
* 有效新用户总和
*/
@Schema(description = "有效新用户总和")
@ExcelProperty(value = "有效新用户总和")
private Integer effectiveNewSum;
/**
* 手续费
*/
@Schema(description = "手续费")
@ExcelProperty(value = "手续费")
private BigDecimal handlingFee;
/**
* 合作利润
*/
@Schema(description = "合作利润")
@ExcelProperty(value = "合作利润")
private Integer partnershipProfit;
/**
* 彩票投注总和
*/
@Schema(description = "彩票投注总和")
@ExcelProperty(value = "彩票投注总和")
private Integer lotteryBetSum;
/**
* 回扣率总和
*/
@Schema(description = "回扣率总和")
@ExcelProperty(value = "回扣率总和")
private BigDecimal rebateRateSum;
/**
* 彩票佣金总和
*/
@Schema(description = "彩票佣金总和")
@ExcelProperty(value = "彩票佣金总和")
private BigDecimal lotteryCommissionSum;
/**
* 负利润佣金总和
*/
@Schema(description = "负利润佣金总和")
@ExcelProperty(value = "负利润佣金总和")
private BigDecimal negativeProfitCommissionSum;
/**
* 负利润率总和
*/
@Schema(description = "负利润率总和")
@ExcelProperty(value = "负利润率总和")
private BigDecimal negativeProfitRateSum;
/**
* 成本率总和
*/
@Schema(description = "成本率总和")
@ExcelProperty(value = "成本率总和")
private BigDecimal costRateSum;
/**
* 成本金额总和
*/
@Schema(description = "成本金额总和")
@ExcelProperty(value = "成本金额总和")
private BigDecimal costMoneySum;
/**
* 利润总和
*/
@Schema(description = "利润总和")
@ExcelProperty(value = "利润总和")
private BigDecimal profitSum;
/**
* 第三方支出总和
*/
@Schema(description = "第三方支出总和")
@ExcelProperty(value = "第三方支出总和")
private BigDecimal thirdPartySpendSum;
/**
* 促销总和
*/
@Schema(description = "促销总和")
@ExcelProperty(value = "促销总和")
private BigDecimal promoSum;
/**
* 回扣总和
*/
@Schema(description = "回扣总和")
@ExcelProperty(value = "回扣总和")
private BigDecimal rebateSum;
/**
* 风险调整总和
*/
@Schema(description = "风险调整总和")
@ExcelProperty(value = "风险调整总和")
private BigDecimal riskAdjustSum;
}

205
zayac-admin-agent/src/main/java/com/zayac/admin/agent/model/resp/FinanceSumResp.java Normal file
View File

@ -0,0 +1,205 @@
package com.zayac.admin.agent.model.resp;
import java.io.Serial;
import java.time.LocalDateTime;
import java.math.BigDecimal;
import lombok.Data;
import io.swagger.v3.oas.annotations.media.Schema;
import top.continew.starter.extension.crud.model.resp.BaseResp;
/**
* 财务报汇总信息
*
* @author zayac
* @since 2024/06/04 17:10
*/
@Data
@Schema(description = "财务报汇总信息")
public class FinanceSumResp extends BaseResp {
@Serial
private static final long serialVersionUID = 1L;
/**
* 下属用户数量总和
*/
@Schema(description = "下属用户数量总和")
private Integer subordinateUserCountSum;
/**
* 活跃总和
*/
@Schema(description = "活跃总和")
private Integer activeSum;
/**
* 净利润总和
*/
@Schema(description = "净利润总和")
private BigDecimal netProfitSum;
/**
* 上一次余额总和
*/
@Schema(description = "上一次余额总和")
private BigDecimal lastBalanceSum;
/**
* 调整后利润总和
*/
@Schema(description = "调整后利润总和")
private BigDecimal czProfitSum;
/**
* 费率
*/
@Schema(description = "费率")
private BigDecimal rate;
/**
* 修正总和
*/
@Schema(description = "修正总和")
private BigDecimal correctionSum;
/**
* 重复修正总和
*/
@Schema(description = "重复修正总和")
private BigDecimal repCorrectionSum;
/**
* 佣金总和
*/
@Schema(description = "佣金总和")
private BigDecimal commissionSum;
/**
* VIP特殊佣金总和
*/
@Schema(description = "VIP特殊佣金总和")
private BigDecimal vipSpecialCommissionSum;
/**
* 修正后的净利润
*/
@Schema(description = "修正后的净利润")
private BigDecimal repairNetProfit;
/**
* 佣金状态
*/
@Schema(description = "佣金状态")
private Integer commissionStatus;
/**
* 代理名称
*/
@Schema(description = "代理名称")
private String agentName;
/**
* 有效新用户总和
*/
@Schema(description = "有效新用户总和")
private Integer effectiveNewSum;
/**
* 手续费
*/
@Schema(description = "手续费")
private BigDecimal handlingFee;
/**
* 合作利润
*/
@Schema(description = "合作利润")
private Integer partnershipProfit;
/**
* 彩票投注总和
*/
@Schema(description = "彩票投注总和")
private Integer lotteryBetSum;
/**
* 回扣率总和
*/
@Schema(description = "回扣率总和")
private BigDecimal rebateRateSum;
/**
* 彩票佣金总和
*/
@Schema(description = "彩票佣金总和")
private BigDecimal lotteryCommissionSum;
/**
* 负利润佣金总和
*/
@Schema(description = "负利润佣金总和")
private BigDecimal negativeProfitCommissionSum;
/**
* 负利润率总和
*/
@Schema(description = "负利润率总和")
private BigDecimal negativeProfitRateSum;
/**
* 成本率总和
*/
@Schema(description = "成本率总和")
private BigDecimal costRateSum;
/**
* 成本金额总和
*/
@Schema(description = "成本金额总和")
private BigDecimal costMoneySum;
/**
* 利润总和
*/
@Schema(description = "利润总和")
private BigDecimal profitSum;
/**
* 第三方支出总和
*/
@Schema(description = "第三方支出总和")
private BigDecimal thirdPartySpendSum;
/**
* 促销总和
*/
@Schema(description = "促销总和")
private BigDecimal promoSum;
/**
* 回扣总和
*/
@Schema(description = "回扣总和")
private BigDecimal rebateSum;
/**
* 风险调整总和
*/
@Schema(description = "风险调整总和")
private BigDecimal riskAdjustSum;
/**
* 修改人
*/
@Schema(description = "修改人")
private Long updateUser;
/**
* 修改时间
*/
@Schema(description = "修改时间")
private LocalDateTime updateTime;
}

219
zayac-admin-agent/src/main/java/com/zayac/admin/agent/model/resp/StatsDetailResp.java Normal file
View File

@ -0,0 +1,219 @@
package com.zayac.admin.agent.model.resp;
import java.io.Serial;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.math.BigDecimal;
import lombok.Data;
import io.swagger.v3.oas.annotations.media.Schema;
import com.alibaba.excel.annotation.ExcelIgnoreUnannotated;
import com.alibaba.excel.annotation.ExcelProperty;
import top.continew.starter.extension.crud.model.resp.BaseDetailResp;
/**
* 代理每日数据详情信息
*
* @author zayac
* @since 2024/06/04 17:10
*/
@Data
@ExcelIgnoreUnannotated
@Schema(description = "代理每日数据详情信息")
public class StatsDetailResp extends BaseDetailResp {
@Serial
private static final long serialVersionUID = 1L;
/**
* 日期
*/
@Schema(description = "日期")
@ExcelProperty(value = "日期")
private LocalDate staticsDate;
/**
* 代理id
*/
@Schema(description = "代理id")
@ExcelProperty(value = "代理id")
private Long agentId;
/**
* 代理类型
*/
@Schema(description = "代理类型")
@ExcelProperty(value = "代理类型")
private Integer agentType;
/**
* 代理推荐码
*/
@Schema(description = "代理推荐码")
@ExcelProperty(value = "代理推荐码")
private String agentCode;
/**
* 代理名称
*/
@Schema(description = "代理名称")
@ExcelProperty(value = "代理名称")
private String agentName;
/**
* 注册人数
*/
@Schema(description = "注册人数")
@ExcelProperty(value = "注册人数")
private Integer isNew;
/**
* 首存人数
*/
@Schema(description = "首存人数")
@ExcelProperty(value = "首存人数")
private BigDecimal firstDeposit;
/**
* 投注额
*/
@Schema(description = "投注额")
@ExcelProperty(value = "投注额")
private BigDecimal deposit;
/**
* 投注红利
*/
@Schema(description = "投注红利")
@ExcelProperty(value = "投注红利")
private BigDecimal depositPromo;
/**
* 取款
*/
@Schema(description = "取款")
@ExcelProperty(value = "取款")
private BigDecimal draw;
/**
* 返水
*/
@Schema(description = "返水")
@ExcelProperty(value = "返水")
private BigDecimal promo;
/**
* 返水比例
*/
@Schema(description = "返水比例")
@ExcelProperty(value = "返水比例")
private BigDecimal promoDividend;
/**
*
*/
@Schema(description = "")
@ExcelProperty(value = "")
private BigDecimal rebate;
/**
* 账号调整
*/
@Schema(description = "账号调整")
@ExcelProperty(value = "账号调整")
private BigDecimal adjust;
/**
* 风险等级
*/
@Schema(description = "风险等级")
@ExcelProperty(value = "风险等级")
private BigDecimal riskAdjust;
/**
* 有效投注额
*/
@Schema(description = "有效投注额")
@ExcelProperty(value = "有效投注额")
private BigDecimal bets;
/**
* 输赢
*/
@Schema(description = "输赢")
@ExcelProperty(value = "输赢")
private BigDecimal profit;
/**
* 总投注额
*/
@Schema(description = "总投注额")
@ExcelProperty(value = "总投注额")
private BigDecimal allBets;
/**
* 首存人数
*/
@Schema(description = "首存人数")
@ExcelProperty(value = "首存人数")
private Integer firstCount;
/**
* 存款人数
*/
@Schema(description = "存款人数")
@ExcelProperty(value = "存款人数")
private Integer countDeposit;
/**
* 取款人数
*/
@Schema(description = "取款人数")
@ExcelProperty(value = "取款人数")
private Integer countDraw;
/**
* 投注人数
*/
@Schema(description = "投注人数")
@ExcelProperty(value = "投注人数")
private Integer countBets;
/**
* 创建日期
*/
@Schema(description = "创建日期")
@ExcelProperty(value = "创建日期")
private LocalDateTime createdAt;
/**
* 更新日期
*/
@Schema(description = "更新日期")
@ExcelProperty(value = "更新日期")
private LocalDateTime updatedAt;
/**
*
*/
@Schema(description = "")
@ExcelProperty(value = "")
private BigDecimal oldDeposit;
/**
*
*/
@Schema(description = "")
@ExcelProperty(value = "")
private Integer oldDepositCount;
/**
*
*/
@Schema(description = "")
@ExcelProperty(value = "")
private BigDecimal newDeposit;
}

189
zayac-admin-agent/src/main/java/com/zayac/admin/agent/model/resp/StatsResp.java Normal file
View File

@ -0,0 +1,189 @@
package com.zayac.admin.agent.model.resp;
import java.io.Serial;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.math.BigDecimal;
import lombok.Data;
import io.swagger.v3.oas.annotations.media.Schema;
import top.continew.starter.extension.crud.model.resp.BaseResp;
/**
* 代理每日数据信息
*
* @author zayac
* @since 2024/06/04 17:10
*/
@Data
@Schema(description = "代理每日数据信息")
public class StatsResp extends BaseResp {
@Serial
private static final long serialVersionUID = 1L;
/**
* 日期
*/
@Schema(description = "日期")
private LocalDate staticsDate;
/**
* 代理id
*/
@Schema(description = "代理id")
private Long agentId;
/**
* 代理类型
*/
@Schema(description = "代理类型")
private Integer agentType;
/**
* 代理推荐码
*/
@Schema(description = "代理推荐码")
private String agentCode;
/**
* 代理名称
*/
@Schema(description = "代理名称")
private String agentName;
/**
* 注册人数
*/
@Schema(description = "注册人数")
private Integer isNew;
/**
* 首存人数
*/
@Schema(description = "首存人数")
private BigDecimal firstDeposit;
/**
* 投注额
*/
@Schema(description = "投注额")
private BigDecimal deposit;
/**
* 投注红利
*/
@Schema(description = "投注红利")
private BigDecimal depositPromo;
/**
* 取款
*/
@Schema(description = "取款")
private BigDecimal draw;
/**
* 返水
*/
@Schema(description = "返水")
private BigDecimal promo;
/**
* 返水比例
*/
@Schema(description = "返水比例")
private BigDecimal promoDividend;
/**
*
*/
@Schema(description = "")
private BigDecimal rebate;
/**
* 账号调整
*/
@Schema(description = "账号调整")
private BigDecimal adjust;
/**
* 风险等级
*/
@Schema(description = "风险等级")
private BigDecimal riskAdjust;
/**
* 有效投注额
*/
@Schema(description = "有效投注额")
private BigDecimal bets;
/**
* 输赢
*/
@Schema(description = "输赢")
private BigDecimal profit;
/**
* 总投注额
*/
@Schema(description = "总投注额")
private BigDecimal allBets;
/**
* 首存人数
*/
@Schema(description = "首存人数")
private Integer firstCount;
/**
* 存款人数
*/
@Schema(description = "存款人数")
private Integer countDeposit;
/**
* 取款人数
*/
@Schema(description = "取款人数")
private Integer countDraw;
/**
* 投注人数
*/
@Schema(description = "投注人数")
private Integer countBets;
/**
* 创建日期
*/
@Schema(description = "创建日期")
private LocalDateTime createdAt;
/**
* 更新日期
*/
@Schema(description = "更新日期")
private LocalDateTime updatedAt;
/**
*
*/
@Schema(description = "")
private BigDecimal oldDeposit;
/**
*
*/
@Schema(description = "")
private Integer oldDepositCount;
/**
*
*/
@Schema(description = "")
private BigDecimal newDeposit;
}

20
zayac-admin-agent/src/main/java/com/zayac/admin/agent/service/FinanceService.java Normal file
View File

@ -0,0 +1,20 @@
package com.zayac.admin.agent.service;
import com.zayac.admin.agent.model.entity.FinanceDO;
import top.continew.starter.extension.crud.service.BaseService;
import com.zayac.admin.agent.model.query.FinanceQuery;
import com.zayac.admin.agent.model.req.FinanceReq;
import com.zayac.admin.agent.model.resp.FinanceDetailResp;
import com.zayac.admin.agent.model.resp.FinanceResp;
import java.util.List;
/**
* 代理线财务报业务接口
*
* @author zayac
* @since 2024/06/04 17:14
*/
public interface FinanceService extends BaseService<FinanceResp, FinanceDetailResp, FinanceQuery, FinanceReq> {
void addAll(List<FinanceDO> financeReqList);
}

15
zayac-admin-agent/src/main/java/com/zayac/admin/agent/service/FinanceSumService.java Normal file
View File

@ -0,0 +1,15 @@
package com.zayac.admin.agent.service;
import top.continew.starter.extension.crud.service.BaseService;
import com.zayac.admin.agent.model.query.FinanceSumQuery;
import com.zayac.admin.agent.model.req.FinanceSumReq;
import com.zayac.admin.agent.model.resp.FinanceSumDetailResp;
import com.zayac.admin.agent.model.resp.FinanceSumResp;
/**
* 财务报汇总业务接口
*
* @author zayac
* @since 2024/06/04 17:10
*/
public interface FinanceSumService extends BaseService<FinanceSumResp, FinanceSumDetailResp, FinanceSumQuery, FinanceSumReq> {}

20
zayac-admin-agent/src/main/java/com/zayac/admin/agent/service/StatsService.java Normal file
View File

@ -0,0 +1,20 @@
package com.zayac.admin.agent.service;
import com.zayac.admin.agent.model.entity.StatsDO;
import top.continew.starter.extension.crud.service.BaseService;
import com.zayac.admin.agent.model.query.StatsQuery;
import com.zayac.admin.agent.model.req.StatsReq;
import com.zayac.admin.agent.model.resp.StatsDetailResp;
import com.zayac.admin.agent.model.resp.StatsResp;
import java.util.List;
/**
* 代理每日数据业务接口
*
* @author zayac
* @since 2024/06/04 17:10
*/
public interface StatsService extends BaseService<StatsResp, StatsDetailResp, StatsQuery, StatsReq> {
void addAll(List<StatsDO> list);
}

31
zayac-admin-agent/src/main/java/com/zayac/admin/agent/service/impl/DailyStatsServiceImpl.java Normal file
View File

@ -0,0 +1,31 @@
package com.zayac.admin.agent.service.impl;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import top.continew.starter.extension.crud.service.impl.BaseServiceImpl;
import com.zayac.admin.agent.mapper.DailyStatsMapper;
import com.zayac.admin.agent.model.entity.StatsDO;
import com.zayac.admin.agent.model.query.StatsQuery;
import com.zayac.admin.agent.model.req.StatsReq;
import com.zayac.admin.agent.model.resp.StatsDetailResp;
import com.zayac.admin.agent.model.resp.StatsResp;
import com.zayac.admin.agent.service.StatsService;
import java.util.List;
/**
* 代理每日数据业务实现
*
* @author zayac
* @since 2024/06/04 17:10
*/
@Service
@RequiredArgsConstructor
public class DailyStatsServiceImpl extends BaseServiceImpl<DailyStatsMapper, StatsDO, StatsResp, StatsDetailResp, StatsQuery, StatsReq> implements StatsService {
@Override
public void addAll(List<StatsDO> list) {
baseMapper.insertBatch(list);
}
}

32
zayac-admin-agent/src/main/java/com/zayac/admin/agent/service/impl/FinanceServiceImpl.java Normal file
View File

@ -0,0 +1,32 @@
package com.zayac.admin.agent.service.impl;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import top.continew.starter.extension.crud.service.impl.BaseServiceImpl;
import com.zayac.admin.agent.mapper.FinanceMapper;
import com.zayac.admin.agent.model.entity.FinanceDO;
import com.zayac.admin.agent.model.query.FinanceQuery;
import com.zayac.admin.agent.model.req.FinanceReq;
import com.zayac.admin.agent.model.resp.FinanceDetailResp;
import com.zayac.admin.agent.model.resp.FinanceResp;
import com.zayac.admin.agent.service.FinanceService;
import java.util.List;
/**
* 代理线财务报业务实现
*
* @author zayac
* @since 2024/06/04 17:14
*/
@Service
@RequiredArgsConstructor
public class FinanceServiceImpl extends BaseServiceImpl<FinanceMapper, FinanceDO, FinanceResp, FinanceDetailResp, FinanceQuery, FinanceReq> implements FinanceService {
public void addAll(List<FinanceDO> financeReqList){
baseMapper.insertBatch(financeReqList);
}
}

24
zayac-admin-agent/src/main/java/com/zayac/admin/agent/service/impl/FinanceSumServiceImpl.java Normal file
View File

@ -0,0 +1,24 @@
package com.zayac.admin.agent.service.impl;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import top.continew.starter.extension.crud.service.impl.BaseServiceImpl;
import com.zayac.admin.agent.mapper.FinanceSumMapper;
import com.zayac.admin.agent.model.entity.FinanceSumDO;
import com.zayac.admin.agent.model.query.FinanceSumQuery;
import com.zayac.admin.agent.model.req.FinanceSumReq;
import com.zayac.admin.agent.model.resp.FinanceSumDetailResp;
import com.zayac.admin.agent.model.resp.FinanceSumResp;
import com.zayac.admin.agent.service.FinanceSumService;
/**
* 财务报汇总业务实现
*
* @author zayac
* @since 2024/06/04 17:10
*/
@Service
@RequiredArgsConstructor
public class FinanceSumServiceImpl extends BaseServiceImpl<FinanceSumMapper, FinanceSumDO, FinanceSumResp, FinanceSumDetailResp, FinanceSumQuery, FinanceSumReq> implements FinanceSumService {}

2
zayac-admin-agent/src/main/java/com/zayac/admin/req/team/TeamFinanceReq.java
View File

@ -15,7 +15,7 @@ import java.time.LocalDate;
public class TeamFinanceReq {
private String agentName;
@JsonFormat(pattern = "yyyy-MM-dd")
@JsonFormat(pattern = "yyyy-MM")
private LocalDate commissionDate;
private boolean isRest;
private int pageNum;

2
zayac-admin-agent/src/main/java/com/zayac/admin/resp/Statics.java
View File

@ -49,7 +49,7 @@ public class Statics implements Serializable {
*/
String agentName;
/**
* 新增人数
* 注册人数
*/
Integer isNew;
/**

1
zayac-admin-agent/src/main/java/com/zayac/admin/resp/team/TeamAccount.java
View File

@ -32,6 +32,7 @@ import java.io.Serializable;
public class TeamAccount implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
private long id;
private long teamId;
private String agentName;

38
zayac-admin-agent/src/main/java/com/zayac/admin/resp/team/TeamFinance.java → zayac-admin-agent/src/main/java/com/zayac/admin/resp/team/TeamAccountFinance.java
View File

@ -2,28 +2,24 @@ package com.zayac.admin.resp.team;
import com.zayac.admin.resp.Venue;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.math.BigDecimal;
import java.util.List;
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class TeamFinance {
private long memberId; // 会员ID
@AllArgsConstructor
public class TeamAccountFinance {
private Long memberId; // 会员ID
private String agentName; // 代理名称
private String inviteCode; // 邀请码
private String topName; // 顶级代理名称
private int category; // 分类ID
private Integer category; // 分类ID
private String categoryName; // 分类名称
private String commissionDate; // 佣金日期
private int active; // 活跃状态
private int subordinateUserCount; // 下属用户数量
private Integer active; // 活跃状态
private Integer subordinateUserCount; // 下属用户数量
private BigDecimal deposit; // 存款金额
private BigDecimal draw; // 取款金额
private BigDecimal profit; // 利润
@ -41,27 +37,27 @@ public class TeamFinance {
private String remark; // 备注
private String agentRemark; // 代理备注
private String adminName; // 管理员名称
private int commissionStatus; // 佣金状态
private Integer commissionStatus; // 佣金状态
private String plateDetail; // 平台详情
private String releaseAt; // 发布日期
private String teamName; // 团队名称
private String sendRemark; // 发送备注
private int agentStatus; // 代理状态
private int secondaryLine; // 二级线路
private Integer agentStatus; // 代理状态
private Integer secondaryLine; // 二级线路
private List<Venue> venueList; // 场馆列表
private int isCaptain; // 是否为队长
private Integer isCaptain; // 是否为队长
private String name; // 名称
private int countDeposit; // 存款次数
private int countDraw; // 取款次数
private int countBets; // 投注次数
private Integer countDeposit; // 存款次数
private Integer countDraw; // 取款次数
private Integer countBets; // 投注次数
private String vipSpecialCommission; // VIP特殊佣金
private int newActive; // 新的活跃状态
private Integer newActive; // 新的活跃状态
private String repairNetProfit; // 修正后的净利润
private int showCommissionRate; // 显示的佣金率
private int effectiveNew; // 有效的新用户
private Integer showCommissionRate; // 显示的佣金率
private Integer effectiveNew; // 有效的新用户
private String repCorrection; // 修正值
private BigDecimal handlingFee; // 手续费
private int partnershipProfit; // 合作利润
private Integer partnershipProfit; // 合作利润
private BigDecimal bets; // 投注金额
private BigDecimal lotteryBet; // 彩票投注金额
private BigDecimal costMoney; // 成本金额

2
zayac-admin-agent/src/main/java/com/zayac/admin/resp/team/TeamFinancePagination.java
View File

@ -9,5 +9,5 @@ import lombok.NoArgsConstructor;
@AllArgsConstructor
@NoArgsConstructor
public class TeamFinancePagination<T> extends Pagination<T> {
private TeamTotalSum totalSumVo;
private TeamFinanceSum totalSumVo;
}

14
zayac-admin-agent/src/main/java/com/zayac/admin/resp/team/TeamTotalSum.java → zayac-admin-agent/src/main/java/com/zayac/admin/resp/team/TeamFinanceSum.java
View File

@ -9,9 +9,9 @@ import java.math.BigDecimal;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class TeamTotalSum {
private int subordinateUserCountSum; // 下属用户数量总和
private int activeSum; // 活跃总和
public class TeamFinanceSum {
private Integer subordinateUserCountSum; // 下属用户数量总和
private Integer activeSum; // 活跃总和
private BigDecimal netProfitSum; // 净利润总和
private BigDecimal lastBalanceSum; // 上一次余额总和
private BigDecimal czProfitSum; // 调整后利润总和
@ -21,12 +21,12 @@ public class TeamTotalSum {
private BigDecimal commissionSum; // 佣金总和
private BigDecimal vipSpecialCommissionSum; // VIP特殊佣金总和
private BigDecimal repairNetProfit; // 修正后的净利润
private int commissionStatus; // 佣金状态
private Integer commissionStatus; // 佣金状态
private String agentName; // 代理名称
private int effectiveNewSum; // 有效新用户总和
private Integer effectiveNewSum; // 有效新用户总和
private BigDecimal handlingFee; // 手续费
private int partnershipProfit; // 合作利润
private int lotteryBetSum; // 彩票投注总和
private Integer partnershipProfit; // 合作利润
private Integer lotteryBetSum; // 彩票投注总和
private BigDecimal rebateRateSum; // 回扣率总和
private BigDecimal lotteryCommissionSum; // 彩票佣金总和
private BigDecimal negativeProfitCommissionSum; // 负利润佣金总和

107
zayac-admin-agent/src/main/java/com/zayac/admin/schedule/DailyReport.java
View File

@ -18,6 +18,13 @@ package com.zayac.admin.schedule;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.util.StrUtil;
import com.zayac.admin.agent.model.entity.FinanceDO;
import com.zayac.admin.agent.model.entity.StatsDO;
import com.zayac.admin.agent.model.req.FinanceReq;
import com.zayac.admin.agent.model.req.FinanceSumReq;
import com.zayac.admin.agent.service.FinanceService;
import com.zayac.admin.agent.service.FinanceSumService;
import com.zayac.admin.agent.service.StatsService;
import com.zayac.admin.common.enums.DisEnableStatusEnum;
import com.zayac.admin.req.AgentDataVisualListReq;
import com.zayac.admin.req.team.TeamFinanceReq;
@ -26,15 +33,14 @@ import com.zayac.admin.resp.AgentDataVisualList;
import com.zayac.admin.resp.Statics;
import com.zayac.admin.resp.team.Team;
import com.zayac.admin.resp.team.TeamAccount;
import com.zayac.admin.resp.team.TeamFinance;
import com.zayac.admin.resp.team.TeamAccountFinance;
import com.zayac.admin.resp.team.TeamFinancePagination;
import com.zayac.admin.service.AgentDataVisualListService;
import com.zayac.admin.service.FinanceService;
import com.zayac.admin.service.CompletableFutureFinanceService;
import com.zayac.admin.service.TeamService;
import com.zayac.admin.service.TelegramMessageService;
import com.zayac.admin.system.model.entity.RoleDO;
import com.zayac.admin.system.model.entity.UserDO;
import com.zayac.admin.system.model.req.AgentStatsReq;
import com.zayac.admin.system.model.resp.AccountResp;
import com.zayac.admin.system.service.*;
import com.zayac.admin.utils.TableFormatter;
@ -47,6 +53,7 @@ import java.text.NumberFormat;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.time.YearMonth;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CompletableFuture;
@ -61,8 +68,10 @@ public class DailyReport {
private final AccountService accountService;
private final TelegramMessageService telegramMessageService;
private final AgentDataVisualListService agentDataVisualListService;
private final AgentStatsService agentStatsService;
private final StatsService statsService;
private final CompletableFutureFinanceService completableFutureFinanceService;
private final FinanceService financeService;
private final FinanceSumService financeSumService;
private static final String MINISTER_ROLE_CODE = "minister";
@ -70,24 +79,18 @@ public class DailyReport {
public void teamAccountDailyReport() {
LocalDateTime nowDateTime = LocalDateTime.now();
LocalDate nowDate = LocalDate.now();
sendDailyReport(nowDate, nowDate.atStartOfDay(), nowDateTime, false);
sendDailyReport(nowDate, nowDate.atStartOfDay(), nowDateTime);
}
@Scheduled(cron = "0 53 13 * * ?")
@Scheduled(cron = "0 15 0 * * ?")
public void dailySummarize() {
LocalDate yesterday = LocalDate.now().minusDays(1);
sendDailyReport(yesterday, yesterday.atStartOfDay(), LocalDateTime.of(yesterday, LocalTime.MAX), true);
//TODO 查询昨日注册存款失败用户
}
@Scheduled(cron = "0 59 23 * * ?")
public void dailyFinance() {
LocalDate nowDate = LocalDate.now();
sendDailyReport(yesterday, yesterday.atStartOfDay(), LocalDateTime.of(yesterday, LocalTime.MAX));
saveData(yesterday, yesterday.atStartOfDay(), LocalDateTime.of(yesterday, LocalTime.MAX));
}
private void sendDailyReport(LocalDate reportDate, LocalDateTime startDateTime, LocalDateTime endDateTime, boolean saveStatics) {
private void sendDailyReport(LocalDate reportDate, LocalDateTime startDateTime, LocalDateTime endDateTime) {
RoleDO minister = roleService.getByCode(MINISTER_ROLE_CODE);
List<Long> userIds = userRoleService.listUserIdByRoleId(minister.getId());
@ -102,10 +105,12 @@ public class DailyReport {
.sendMessage("6013830443:AAHUOS4v6Ln19ziZkH-L28-HZQLJrGcvhto", 6054562838L, table);
}
AgentDataVisualListReq agentDataVisualListReq = AgentDataVisualListReq.builder().build();
AgentDataVisualListReq agentDataVisualListReq = AgentDataVisualListReq.builder()
.monthDate(reportDate)
.build();
//获取部长对应下级所有用户
deptUsers.forEach(deptUser -> {
String message = getDeptUserMessage(deptUser, agentDataVisualListReq, reportDate, saveStatics);
deptUsers.parallelStream().forEach(deptUser -> {
String message = getDeptUserMessage(deptUser, agentDataVisualListReq, reportDate);
if (StrUtil.isNotBlank(message) && deptUser.getNeedNotify() == DisEnableStatusEnum.ENABLE) {
String botToken = StrUtil.isEmpty(deptUser.getBotToken()) ? ministerUser.getBotToken() : deptUser.getBotToken();
telegramMessageService.sendMessage(botToken, deptUser.getReportIds(), message);
@ -118,8 +123,7 @@ public class DailyReport {
//获取需要发送给用户的信息
private String getDeptUserMessage(UserDO deptUser,
AgentDataVisualListReq agentDataVisualListReq,
LocalDate reportDate,
boolean saveStatics) {
LocalDate reportDate) {
StringBuilder message = new StringBuilder();
// 主线注册新增不用报数,过滤
List<AccountResp> currUserAccounts = accountService.getAccountsByUserId(deptUser.getId(), DisEnableStatusEnum.ENABLE)
@ -147,46 +151,77 @@ public class DailyReport {
.append("日活: ")
.append(statics.getCountBets())
.append("\n\n");
if (saveStatics) {
AgentStatsReq agentStatsReq = new AgentStatsReq();
BeanUtil.copyProperties(statics, agentStatsReq);
agentStatsService.add(agentStatsReq);
}
});
return message.toString();
}
private void getDailyFinance(LocalDate date) {
LocalDate currMonth = LocalDate.now();
// 获取上个月的值
LocalDate lastMonth = currMonth.minusMonths(1);
if (date.equals(currMonth) || date.equals(lastMonth)) {
private void saveData(LocalDate reportDate, LocalDateTime startDateTime, LocalDateTime endDateTime) {
// 获取传入年月
YearMonth inputYearMonth = YearMonth.from(reportDate);
// 获取当前年月和上个月的年月
YearMonth currentYearMonth = YearMonth.now();
YearMonth previousYearMonth = currentYearMonth.minusMonths(1);
if (inputYearMonth.equals(currentYearMonth) || inputYearMonth.equals(previousYearMonth)) {
RoleDO minister = roleService.getByCode(MINISTER_ROLE_CODE);
List<Long> userIds = userRoleService.listUserIdByRoleId(minister.getId());
userIds.forEach(userId -> {
UserDO ministerUser = userService.getById(userId);
//List<UserDO> deptUsers = userService.getByDeptId(DisEnableStatusEnum.ENABLE, ministerUser.getDeptId());
List<UserDO> deptUsers = userService.getByDeptId(DisEnableStatusEnum.ENABLE, ministerUser.getDeptId());
TeamFinanceReq teamFinanceReq = TeamFinanceReq.builder()
.pageNum(1)
.pageSize(999)
.commissionDate(date)
.commissionDate(reportDate)
.build();
List<AccountResp> ministerUserAccounts = accountService.getAccountsByUserId(ministerUser.getId(), DisEnableStatusEnum.ENABLE)
.stream()
.filter(AccountResp::getIsTeam)
.toList();
ministerUserAccounts.forEach(accountResp -> {
TeamFinancePagination<TeamFinance> financePagination = financeService.getTeamFinance(accountResp, teamFinanceReq).join();
//TODO 序列化到数据库
ministerUserAccounts.parallelStream().forEach(accountResp -> {
TeamFinancePagination<List<TeamAccountFinance>> financePagination = completableFutureFinanceService.getTeamFinance(accountResp, teamFinanceReq).join();
List<FinanceDO> financeReqList = financePagination.getList().stream().map(finance -> {
FinanceDO financeDO = new FinanceDO();
BeanUtil.copyProperties(finance, financeDO);
return financeDO;
}).toList();
financeService.addAll(financeReqList);
FinanceSumReq financeSumReq = new FinanceSumReq();
BeanUtil.copyProperties(financePagination.getTotalSumVo(),financeSumReq);
financeSumService.add(financeSumReq);
});
AgentDataVisualListReq agentDataVisualListReq = AgentDataVisualListReq.builder()
.monthDate(reportDate)
.build();
deptUsers.parallelStream().forEach(deptUser -> {
List<AccountResp> currUserAccounts = accountService.getAccountsByUserId(deptUser.getId(), DisEnableStatusEnum.ENABLE)
.stream()
.filter(accountResp -> !accountResp.getIsTeam())
.toList();
List<StatsDO> list = currUserAccounts.parallelStream().map(currAccount -> {
CompletableFuture<AgentDataVisualList> future = agentDataVisualListService
.getAgentDataVisualList(currAccount, agentDataVisualListReq);
AgentDataVisualList agentData = future.join();
Statics statics = agentData.getCurData()
.stream()
.filter(data -> data.getStaticsDate().equals(reportDate))
.findFirst()
.orElseThrow();
StatsDO statsDO = new StatsDO();
BeanUtil.copyProperties(statics, statsDO);
return statsDO;
}
).toList();
statsService.addAll(list);
});
});
} else {
throw new BusinessException("只允许查询当月以及上个月的数据");
}
}

6
zayac-admin-agent/src/main/java/com/zayac/admin/service/FinanceService.java → zayac-admin-agent/src/main/java/com/zayac/admin/service/CompletableFutureFinanceService.java
View File

@ -2,7 +2,7 @@ package com.zayac.admin.service;
import com.zayac.admin.constant.ApiPathConstants;
import com.zayac.admin.req.team.TeamFinanceReq;
import com.zayac.admin.resp.team.TeamFinance;
import com.zayac.admin.resp.team.TeamAccountFinance;
import com.zayac.admin.resp.team.TeamFinancePagination;
import com.zayac.admin.system.model.resp.AccountResp;
import lombok.RequiredArgsConstructor;
@ -14,10 +14,10 @@ import java.util.concurrent.CompletableFuture;
@Service
@RequiredArgsConstructor
public class FinanceService {
public class CompletableFutureFinanceService {
private final CompletableFutureWebClientService completableFutureWebClientService;
public CompletableFuture<TeamFinancePagination<TeamFinance>> getTeamFinance(AccountResp account, TeamFinanceReq teamFinanceReq) {
public CompletableFuture<TeamFinancePagination<List<TeamAccountFinance>>> getTeamFinance(AccountResp account, TeamFinanceReq teamFinanceReq) {
//设置一个超大的分页参数 确保一次查询到所有的代理线
if (teamFinanceReq.getPageSize() == 0) {
teamFinanceReq.setPageSize(100);

23
zayac-admin-system/src/main/java/com/zayac/admin/system/mapper/AgentStatsMapper.java
View File

@ -1,23 +0,0 @@
/*
* Copyright (c) 2022-present Charles7c Authors. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.zayac.admin.system.mapper;
import com.zayac.admin.system.model.entity.AgentStatsDO;
import top.continew.starter.data.mybatis.plus.base.BaseMapper;
public interface AgentStatsMapper extends BaseMapper<AgentStatsDO> {
}

26
zayac-admin-system/src/main/java/com/zayac/admin/system/model/entity/AgentFinanceDO.java
View File

@ -1,26 +0,0 @@
/*
* Copyright (c) 2022-present Charles7c Authors. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.zayac.admin.system.model.entity;
import top.continew.starter.extension.crud.model.entity.BaseDO;
import java.io.Serial;
public class AgentFinanceDO extends BaseDO {
@Serial
private static final long serialVersionUID = 1L;
}

140
zayac-admin-system/src/main/java/com/zayac/admin/system/model/entity/AgentStatsDO.java
View File

@ -1,140 +0,0 @@
/*
* Copyright (c) 2022-present Charles7c Authors. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.zayac.admin.system.model.entity;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.*;
import top.continew.starter.extension.crud.model.entity.BaseDO;
import java.io.Serial;
import java.time.LocalDate;
import java.time.LocalDateTime;
/**
* 代理线每日数据
*/
@Data
@TableName("agent_daily_stats")
public class AgentStatsDO extends BaseDO {
@Serial
private static final long serialVersionUID = 1L;
/**
* 日期
*/
LocalDate staticsDate;
/**
* 代理id
*/
Long agentId;
/**
* 代理类型
*/
Integer agentType;
/**
* 代理推荐码
*/
String agentCode;
/**
* 代理名称
*/
String agentName;
/**
* 新增人数
*/
Integer isNew;
/**
* 首存人数
*/
Double firstDeposit;
/**
* 投注额
*/
Double deposit;
/**
* 投注红利
*/
Double depositPromo;
/**
* 取款
*/
Double draw;
/**
* 返水
*/
Double promo;
/**
* 返水比例
*/
Double promoDividend;
Double rebate;
/**
* 账号调整
*/
Double adjust;
/**
* 风险等级
*/
Double riskAdjust;
/**
* 有效投注额
*/
Double bets;
/**
* 输赢
*/
Double profit;
/**
* 总投注额
*/
Double allBets;
/**
* 首存人数
*/
Integer firstCount;
/**
* 存款人数
*/
Integer countDeposit;
/**
* 取款人数
*/
Integer countDraw;
/**
* 投注人数
*/
Integer countBets;
/**
* 创建日期
*/
LocalDateTime createdAt;
/**
* 更新日期
*/
LocalDateTime updatedAt;
/**
* 老用户存款人数
*/
Double oldDeposit;
/**
* 老用户存款金额
*/
Integer oldDepositCount;
/**
* 新用户存款金额
*/
Double newDeposit;
}

27
zayac-admin-system/src/main/java/com/zayac/admin/system/model/query/AgentStatsQuery.java
View File

@ -1,27 +0,0 @@
/*
* Copyright (c) 2022-present Charles7c Authors. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.zayac.admin.system.model.query;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import java.io.Serializable;
@Data
@Schema(description = "代理线每日报表查询条件")
public class AgentStatsQuery implements Serializable {
}

133
zayac-admin-system/src/main/java/com/zayac/admin/system/model/req/AgentStatsReq.java
View File

@ -1,133 +0,0 @@
/*
* Copyright (c) 2022-present Charles7c Authors. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.zayac.admin.system.model.req;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import top.continew.starter.extension.crud.model.req.BaseReq;
import java.time.LocalDate;
import java.time.LocalDateTime;
@Data
public class AgentStatsReq extends BaseReq {
/**
* 日期
*/
LocalDate staticsDate;
/**
* 代理id
*/
Long agentId;
/**
* 代理类型
*/
Integer agentType;
/**
* 代理推荐码
*/
String agentCode;
/**
* 代理名称
*/
String agentName;
/**
* 新增人数
*/
Integer isNew;
/**
* 首存人数
*/
Double firstDeposit;
/**
* 投注额
*/
Double deposit;
/**
* 投注红利
*/
Double depositPromo;
/**
* 取款
*/
Double draw;
/**
* 返水
*/
Double promo;
/**
* 返水比例
*/
Double promoDividend;
Double rebate;
/**
* 账号调整
*/
Double adjust;
/**
* 风险等级
*/
Double riskAdjust;
/**
* 有效投注额
*/
Double bets;
/**
* 输赢
*/
Double profit;
/**
* 总投注额
*/
Double allBets;
/**
* 首存人数
*/
Integer firstCount;
/**
* 存款人数
*/
Integer countDeposit;
/**
* 取款人数
*/
Integer countDraw;
/**
* 投注人数
*/
Integer countBets;
/**
* 创建日期
*/
LocalDateTime createdAt;
/**
* 更新日期
*/
LocalDateTime updatedAt;
/**
* 老用户存款人数
*/
Double oldDeposit;
/**
* 老用户存款金额
*/
Integer oldDepositCount;
/**
* 新用户存款金额
*/
Double newDeposit;
}

34
zayac-admin-system/src/main/java/com/zayac/admin/system/service/AgentStatsService.java
View File

@ -1,34 +0,0 @@
/*
* Copyright (c) 2022-present Charles7c Authors. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.zayac.admin.system.service;
import com.zayac.admin.system.model.query.AgentStatsQuery;
import com.zayac.admin.system.model.req.AgentStatsReq;
import com.zayac.admin.system.model.resp.AgentStatsDetailResp;
import com.zayac.admin.system.model.resp.AgentStatsResp;
import org.springframework.stereotype.Service;
import top.continew.starter.extension.crud.service.BaseService;
/**
* 账号业务接口
*
* @author zayac
* @since 2024/05/10 20:44
*/
@Service
public interface AgentStatsService extends BaseService<AgentStatsResp, AgentStatsDetailResp, AgentStatsQuery, AgentStatsReq> {
}

32
zayac-admin-system/src/main/java/com/zayac/admin/system/service/impl/AgentStatsServiceImpl.java
View File

@ -1,32 +0,0 @@
/*
* Copyright (c) 2022-present Charles7c Authors. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.zayac.admin.system.service.impl;
import com.zayac.admin.system.mapper.AgentStatsMapper;
import com.zayac.admin.system.model.entity.AgentStatsDO;
import com.zayac.admin.system.model.query.AgentStatsQuery;
import com.zayac.admin.system.model.req.AgentStatsReq;
import com.zayac.admin.system.model.resp.*;
import com.zayac.admin.system.service.AgentStatsService;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import top.continew.starter.extension.crud.service.impl.BaseServiceImpl;
@Service
@RequiredArgsConstructor
public class AgentStatsServiceImpl extends BaseServiceImpl<AgentStatsMapper, AgentStatsDO, AgentStatsResp, AgentStatsDetailResp, AgentStatsQuery, AgentStatsReq> implements AgentStatsService {
}