From 4f728d1f5d5c1a74595e512179c597b362e05b87 Mon Sep 17 00:00:00 2001 From: tianfeng <769204422@qq.com> Date: Tue, 28 Oct 2025 16:14:57 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9Ebd=E7=9B=B8=E5=85=B3=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../app/team/TeamBdRestController.java | 57 ++++- .../query/TeamBdMemberBillDetailQryExe.java | 229 ++++++++++++++++++ .../bd/query/TeamBdMemberBillListQryExe.java | 208 ++++++++++++++++ .../bd/query/TeamBdMonthlyIncomeQryExe.java | 190 +++++++++++++++ .../app/service/TeamBdBillServiceImpl.java | 48 ++++ .../TeamBdMemberBillAnchorDetailCO.java | 52 ++++ .../dto/clientobject/TeamBdMemberBillCO.java | 88 +++++++ .../TeamBdMemberBillDetailCO.java | 76 ++++++ .../clientobject/TeamBdMonthlyIncomeCO.java | 28 +++ .../app/dto/cmd/TeamBdMemberBillCmd.java | 41 ++++ .../dto/cmd/TeamBdMemberBillDetailCmd.java | 22 ++ .../app/dto/cmd/TeamBdMonthlyIncomeCmd.java | 17 ++ .../other/app/service/TeamBdBillService.java | 44 ++++ .../team/BusinessDevelopmentTeamService.java | 5 + .../BusinessDevelopmentTeamServiceImpl.java | 7 + 15 files changed, 1110 insertions(+), 2 deletions(-) create mode 100644 rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/bd/query/TeamBdMemberBillDetailQryExe.java create mode 100644 rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/bd/query/TeamBdMemberBillListQryExe.java create mode 100644 rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/bd/query/TeamBdMonthlyIncomeQryExe.java create mode 100644 rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/TeamBdBillServiceImpl.java create mode 100644 rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/TeamBdMemberBillAnchorDetailCO.java create mode 100644 rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/TeamBdMemberBillCO.java create mode 100644 rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/TeamBdMemberBillDetailCO.java create mode 100644 rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/TeamBdMonthlyIncomeCO.java create mode 100644 rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/TeamBdMemberBillCmd.java create mode 100644 rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/TeamBdMemberBillDetailCmd.java create mode 100644 rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/TeamBdMonthlyIncomeCmd.java create mode 100644 rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/service/TeamBdBillService.java diff --git a/rc-service/rc-service-other/other-adapter/src/main/java/com/red/circle/other/adapter/app/team/TeamBdRestController.java b/rc-service/rc-service-other/other-adapter/src/main/java/com/red/circle/other/adapter/app/team/TeamBdRestController.java index a974aaca..4578c4da 100644 --- a/rc-service/rc-service-other/other-adapter/src/main/java/com/red/circle/other/adapter/app/team/TeamBdRestController.java +++ b/rc-service/rc-service-other/other-adapter/src/main/java/com/red/circle/other/adapter/app/team/TeamBdRestController.java @@ -10,12 +10,17 @@ import com.red.circle.other.app.dto.cmd.team.DbInviteAgentCmd; import com.red.circle.other.app.dto.cmd.team.DbInviteMessageProcessCmd; import com.red.circle.other.app.dto.cmd.team.DbLeaderInviteBdCmd; import com.red.circle.other.app.service.team.TeamBdService; +import com.red.circle.other.app.service.TeamBdBillService; +import com.red.circle.other.app.dto.cmd.TeamBdMemberBillCmd; +import com.red.circle.other.app.dto.cmd.TeamBdMemberBillDetailCmd; +import com.red.circle.other.app.dto.cmd.TeamBdMonthlyIncomeCmd; +import com.red.circle.other.app.dto.clientobject.TeamBdMemberBillCO; +import com.red.circle.other.app.dto.clientobject.TeamBdMemberBillDetailCO; +import com.red.circle.other.app.dto.clientobject.TeamBdMonthlyIncomeCO; import com.red.circle.other.infra.database.mongo.entity.team.bd.MessageInviteGroup; import java.util.List; import com.red.circle.other.inner.model.cmd.team.bd.BdTeamPageQryCmd; -import com.red.circle.other.inner.model.dto.agency.bd.BdTeamInfoDTO; -import com.red.circle.other.inner.model.dto.agency.bd.BdTeamMemberDTO; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.http.MediaType; @@ -40,6 +45,7 @@ import org.springframework.web.bind.annotation.*; public class TeamBdRestController extends BaseController { private final TeamBdService teamBdService; + private final TeamBdBillService teamBdBillService; /** * 获得bd角色. @@ -232,4 +238,51 @@ public class TeamBdRestController extends BaseController { return teamBdService.bdPage(qryCmd); } + // ==================== BD Center 账单相关接口 ==================== + + /** + * 查询BD成员账单列表. + * + * @param cmd 查询命令 + * @return 成员账单列表 + * @eo.name 查询BD成员账单列表 + * @eo.url /member-bill/list + * @eo.method get + * @eo.request-type formdata + */ + @GetMapping("/member-bill/list") + public List queryMemberBillList(@Validated TeamBdMemberBillCmd cmd) { + return teamBdBillService.queryMemberBillList(cmd); + } + + /** + * 查询BD成员账单明细列表. + * + * @param cmd 查询命令 + * @return 成员账单明细列表 + * @eo.name 查询BD成员账单明细列表 + * @eo.url /member-bill/detail-list + * @eo.method get + * @eo.request-type formdata + */ + @GetMapping("/member-bill/detail-list") + public List queryMemberBillDetailList(@Validated TeamBdMemberBillDetailCmd cmd) { + return teamBdBillService.queryMemberBillDetailList(cmd); + } + + /** + * 查询BD团队月度收入汇总. + * + * @param cmd 查询命令 + * @return 月度收入汇总 + * @eo.name 查询BD团队月度收入 + * @eo.url /monthly-income + * @eo.method get + * @eo.request-type formdata + */ + @GetMapping("/monthly-income") + public TeamBdMonthlyIncomeCO queryMonthlyIncome(@Validated TeamBdMonthlyIncomeCmd cmd) { + return teamBdBillService.queryMonthlyIncome(cmd); + } + } diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/bd/query/TeamBdMemberBillDetailQryExe.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/bd/query/TeamBdMemberBillDetailQryExe.java new file mode 100644 index 00000000..49dba262 --- /dev/null +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/bd/query/TeamBdMemberBillDetailQryExe.java @@ -0,0 +1,229 @@ +package com.red.circle.other.app.command.bd.query; + +import com.red.circle.other.app.convertor.user.UserProfileAppConvertor; +import com.red.circle.other.app.dto.clientobject.TeamBdMemberBillAnchorDetailCO; +import com.red.circle.other.app.dto.clientobject.TeamBdMemberBillDetailCO; +import com.red.circle.other.app.dto.cmd.TeamBdMemberBillDetailCmd; +import com.red.circle.other.domain.gateway.user.UserProfileGateway; +import com.red.circle.other.infra.database.mongo.dto.team.TeamBillSettleResult; +import com.red.circle.other.infra.database.mongo.entity.team.team.TeamBillCycle; +import com.red.circle.other.infra.database.mongo.entity.team.team.TeamMemberTarget; +import com.red.circle.other.infra.database.mongo.entity.team.team.TeamProfile; +import com.red.circle.other.infra.database.mongo.service.team.team.TeamBillCycleService; +import com.red.circle.other.infra.database.mongo.service.team.team.TeamMemberTargetService; +import com.red.circle.other.infra.database.mongo.service.team.team.TeamProfileService; +import com.red.circle.other.infra.database.rds.entity.team.BusinessDevelopmentTeam; +import com.red.circle.other.infra.database.rds.service.team.BusinessDevelopmentTeamService; +import com.red.circle.other.inner.model.dto.agency.agency.TeamCounter; +import com.red.circle.other.inner.model.dto.user.UserProfileDTO; +import com.red.circle.other.inner.enums.team.TeamMemberTargetSettlementResult; +import com.red.circle.tool.core.collection.CollectionUtils; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import java.math.BigDecimal; +import java.time.LocalDate; +import java.time.format.DateTimeFormatter; +import java.util.*; +import java.util.stream.Collectors; + +/** + * 查询 BD 成员账单明细执行器. + * + * @author tf + * @since 2025-10-28 + */ +@Slf4j +@Component +@RequiredArgsConstructor +public class TeamBdMemberBillDetailQryExe { + + private final BusinessDevelopmentTeamService businessDevelopmentTeamService; + private final TeamBillCycleService teamBillCycleService; + private final TeamProfileService teamProfileService; + private final TeamMemberTargetService teamMemberTargetService; + private final UserProfileGateway userProfileGateway; + private final UserProfileAppConvertor userProfileAppConvertor; + + /** + * 执行查询. + * + * @param cmd 查询命令 + * @return 账单明细列表 + */ + public List execute(TeamBdMemberBillDetailCmd cmd) { + Long teamId = cmd.getTeamId(); + + // 2. 查询团队的最新账单列表（使用 listLatestBill 获取最近的账单记录） + List billCycleList = teamBillCycleService.listLatestBill(teamId, 10); + + if (CollectionUtils.isEmpty(billCycleList)) { + return Collections.emptyList(); + } + + // 3. 获取团队Profile信息 + TeamProfile teamProfile = teamProfileService.getById(teamId); + Integer teamMemberCount = Optional.ofNullable(teamProfile) + .map(TeamProfile::getCounter) + .map(TeamCounter::getMemberQuantity) + .map(Long::intValue) + .orElse(0); + + // 4. 遍历每个账单周期，组装明细数据 + return billCycleList.stream() + .map(billCycle -> buildBillDetailCO(billCycle, teamMemberCount)) + .collect(Collectors.toList()); + } + + /** + * 构建账单明细CO. + */ + private TeamBdMemberBillDetailCO buildBillDetailCO(TeamBillCycle billCycle, Integer teamMemberCount) { + TeamBdMemberBillDetailCO co = new TeamBdMemberBillDetailCO(); + + // 1. 账单周期日期 + String[] dates = parseBillBelongToDateRange(billCycle.getBillBelong()); + co.setStartDate(dates[0]); + co.setEndDate(dates[1]); + + // 2. 团队人数 + co.setTeamMemberCount(teamMemberCount); + + // 3. 账单状态 + co.setStatus(billCycle.getStatus()); + + // 4. 团队薪资和充值 + TeamBillSettleResult settleResult = billCycle.getSettleResult(); + if (settleResult != null) { + co.setTeamSalaryAmount(settleResult.getTotalSalary()); + co.setTeamRechargeAmount(BigDecimal.ZERO); + + // BD收益计算 + BigDecimal salaryRatio = new BigDecimal("0.03"); // 3% + BigDecimal rechargeRatio = new BigDecimal("0.05"); // 5% + + co.setBdRatioSalary(salaryRatio.multiply(new BigDecimal("100"))); + co.setBdRatioRecharge(rechargeRatio.multiply(new BigDecimal("100"))); + + BigDecimal bdSalaryIncome = Optional.ofNullable(settleResult.getTotalSalary()) + .orElse(BigDecimal.ZERO) + .multiply(salaryRatio); + BigDecimal bdRechargeIncome = Optional.ofNullable(BigDecimal.ZERO) + .orElse(BigDecimal.ZERO) + .multiply(rechargeRatio); + + co.setBdIncomeSalary(bdSalaryIncome); + co.setBdIncomeRecharge(bdRechargeIncome); + } else { + co.setTeamSalaryAmount(BigDecimal.ZERO); + co.setTeamRechargeAmount(BigDecimal.ZERO); + co.setBdIncomeSalary(BigDecimal.ZERO); + co.setBdIncomeRecharge(BigDecimal.ZERO); + co.setBdRatioSalary(BigDecimal.ZERO); + co.setBdRatioRecharge(BigDecimal.ZERO); + } + + // 5. 查询主播明细列表 + List anchorDetails = buildAnchorDetails( + billCycle.getTeamId(), billCycle.getBillBelong()); + co.setAnchorDetails(anchorDetails); + + return co; + } + + /** + * 构建主播明细列表. + */ + private List buildAnchorDetails(Long teamId, Integer billBelong) { + // 1. 查询该账单周期下的所有成员Target + List memberTargets = teamMemberTargetService.listByBillBelong(teamId, billBelong); + + if (CollectionUtils.isEmpty(memberTargets)) { + return Collections.emptyList(); + } + + // 2. 获取所有成员的用户信息 + Set userIdSet = memberTargets.stream() + .map(TeamMemberTarget::getUserId) + .collect(Collectors.toSet()); + + Map userProfileMap = userProfileAppConvertor.toMapUserProfileDTO( + userProfileGateway.mapByUserIds(userIdSet)); + + // 3. 组装主播明细 + return memberTargets.stream() + .map(target -> buildAnchorDetailCO(target, userProfileMap)) + .collect(Collectors.toList()); + } + + /** + * 构建主播明细CO. + */ + private TeamBdMemberBillAnchorDetailCO buildAnchorDetailCO( + TeamMemberTarget target, + Map userProfileMap) { + + TeamBdMemberBillAnchorDetailCO co = new TeamBdMemberBillAnchorDetailCO(); + + // 用户信息 + UserProfileDTO userProfile = userProfileMap.get(target.getUserId()); + if (userProfile != null) { + co.setUserId(target.getUserId()); + co.setUserName(userProfile.getUserNickname()); + co.setAvatar(userProfile.getUserAvatar()); + } + + // 从 settlementResult 中获取薪资数据 + TeamMemberTargetSettlementResult settlementResult = target.getSettlementResult(); + if (settlementResult != null) { + // 薪资（totalSalary） + co.setSalary(settlementResult.getTotalSalary()); + // 充值（acceptGiftValue） + co.setRecharge(new BigDecimal(Optional.ofNullable(settlementResult.getAcceptGiftValue()).orElse(0L))); + } else { + co.setSalary(BigDecimal.ZERO); + co.setRecharge(BigDecimal.ZERO); + } + + // 开播次数 TODO: 从直播记录中统计 + co.setHostCount(0); + + return co; + } + + /** + * 解析 billBelong 为日期范围. + * + * @param billBelong 账单归属（格式：20251001 或 20251016） + * @return 日期范围数组 [startDate, endDate]，格式：yyyy.MM.dd + */ + private String[] parseBillBelongToDateRange(Integer billBelong) { + if (billBelong == null) { + return new String[]{"", ""}; + } + + String billBelongStr = String.valueOf(billBelong); + int year = Integer.parseInt(billBelongStr.substring(0, 4)); + int month = Integer.parseInt(billBelongStr.substring(4, 6)); + int day = Integer.parseInt(billBelongStr.substring(6, 8)); + + LocalDate startDate = LocalDate.of(year, month, day); + LocalDate endDate; + + if (day == 1) { + // 1-15号的账单周期 + endDate = LocalDate.of(year, month, 15); + } else { + // 16-月末的账单周期 + endDate = startDate.withDayOfMonth(startDate.lengthOfMonth()); + } + + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy.MM.dd"); + return new String[]{ + startDate.format(formatter), + endDate.format(formatter) + }; + } + +} diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/bd/query/TeamBdMemberBillListQryExe.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/bd/query/TeamBdMemberBillListQryExe.java new file mode 100644 index 00000000..6ce95bfd --- /dev/null +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/bd/query/TeamBdMemberBillListQryExe.java @@ -0,0 +1,208 @@ +package com.red.circle.other.app.command.bd.query; + +import com.red.circle.other.app.convertor.user.UserProfileAppConvertor; +import com.red.circle.other.app.dto.clientobject.TeamBdMemberBillCO; +import com.red.circle.other.app.dto.cmd.TeamBdMemberBillCmd; +import com.red.circle.other.domain.gateway.user.UserProfileGateway; +import com.red.circle.other.infra.database.mongo.dto.team.TeamBillSettleResult; +import com.red.circle.other.infra.database.mongo.entity.team.team.TeamBillCycle; +import com.red.circle.other.infra.database.mongo.entity.team.team.TeamProfile; +import com.red.circle.other.infra.database.mongo.service.team.TeamBillCycleUtils; +import com.red.circle.other.infra.database.mongo.service.team.team.TeamBillCycleService; +import com.red.circle.other.infra.database.mongo.service.team.team.TeamProfileService; +import com.red.circle.other.infra.database.rds.entity.team.BusinessDevelopmentTeam; +import com.red.circle.other.infra.database.rds.service.team.BusinessDevelopmentBaseInfoService; +import com.red.circle.other.infra.database.rds.service.team.BusinessDevelopmentTeamService; +import com.red.circle.other.inner.endpoint.team.bd.BdTeamLeaderClient; +import com.red.circle.other.inner.enums.team.TeamBillCycleStatus; +import com.red.circle.other.inner.model.dto.agency.agency.TeamCounter; +import com.red.circle.other.inner.model.dto.user.UserProfileDTO; +import com.red.circle.tool.core.collection.CollectionUtils; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import java.math.BigDecimal; +import java.time.LocalDate; +import java.time.format.DateTimeFormatter; +import java.util.*; +import java.util.stream.Collectors; + +/** + * 查询 BD 成员账单列表执行器. + * + * @author tf + * @since 2025-10-28 + */ +@Slf4j +@Component +@RequiredArgsConstructor +public class TeamBdMemberBillListQryExe { + + private final BusinessDevelopmentTeamService businessDevelopmentTeamService; + private final TeamBillCycleService teamBillCycleService; + private final TeamProfileService teamProfileService; + private final UserProfileGateway userProfileGateway; + private final UserProfileAppConvertor userProfileAppConvertor; + private final BdTeamLeaderClient bdTeamLeaderClient; + + /** + * 执行查询. + * + * @param cmd 查询命令 + * @return 账单列表 + */ + public List execute(TeamBdMemberBillCmd cmd) { + List bdTeamList = new ArrayList<>(); + + Boolean bdLeader = bdTeamLeaderClient.check(cmd.getReqUserId()).getBody(); + if (Boolean.TRUE.equals(bdLeader)) { + bdTeamList.addAll(businessDevelopmentTeamService.listByUserId(cmd.getReqUserId())); + } else { + bdTeamList.add(businessDevelopmentTeamService.getByAgentId(cmd.getReqUserId())); + } + + // 1. 查询BD关联的所有代理 + if (CollectionUtils.isEmpty(bdTeamList)) { + return Collections.emptyList(); + } + + // 2. 获取团队ID集合 + Set teamIdSet = bdTeamList.stream() + .map(BusinessDevelopmentTeam::getTeamId) + .collect(Collectors.toSet()); + + // 3. 获取当前账单周期 billBelong + Integer currentBillBelong = TeamBillCycleUtils.getCalcBillBelong(); + + // 4. 查询当前周期的账单 + Map billCycleMap = teamBillCycleService.mapByTeamIds( + teamIdSet, currentBillBelong, TeamBillCycleStatus.SETTLED); + + // 5. 获取团队Profile信息（包含团队人数） + Map teamProfileMap = teamProfileService.mapProfileByIds(teamIdSet); + + // 6. 获取代理用户信息 + Set agentIdSet = bdTeamList.stream() + .map(BusinessDevelopmentTeam::getAgentId) + .collect(Collectors.toSet()); + Map userProfileMap = userProfileAppConvertor.toMapUserProfileDTO( + userProfileGateway.mapByUserIds(agentIdSet)); + + // 7. 组装返回结果 + return bdTeamList.stream() + .map(bdTeam -> buildMemberBillCO(bdTeam, billCycleMap, teamProfileMap, userProfileMap, currentBillBelong)) + .collect(Collectors.toList()); + } + + /** + * 构建成员账单CO. + */ + private TeamBdMemberBillCO buildMemberBillCO( + BusinessDevelopmentTeam bdTeam, + Map billCycleMap, + Map teamProfileMap, + Map userProfileMap, + Integer billBelong) { + + TeamBdMemberBillCO co = new TeamBdMemberBillCO(); + + // 代理用户信息 + UserProfileDTO userProfile = userProfileMap.get(bdTeam.getAgentId()); + if (userProfile != null) { + co.setAgentId(bdTeam.getAgentId()); + co.setAgentName(userProfile.getUserNickname()); + co.setAgentAvatar(userProfile.getUserAvatar()); + } + + // 团队信息 + co.setTeamId(bdTeam.getTeamId()); + + TeamProfile teamProfile = teamProfileMap.get(bdTeam.getTeamId()); + if (teamProfile != null) { + Long memberCount = Optional.ofNullable(teamProfile.getCounter()) + .map(TeamCounter::getMemberQuantity) + .orElse(0L); + co.setTeamMemberCount(memberCount.intValue()); + } else { + co.setTeamMemberCount(0); + } + + // 账单周期日期（从 billBelong 解析） + String[] dates = parseBillBelongToDateRange(billBelong); + co.setStartDate(dates[0]); + co.setEndDate(dates[1]); + + // 账单周期信息 + TeamBillCycle billCycle = billCycleMap.get(bdTeam.getTeamId()); + if (billCycle != null && billCycle.getSettleResult() != null) { + TeamBillSettleResult settleResult = billCycle.getSettleResult(); + + // 团队薪资和充值 + co.setTeamSalaryAmount(settleResult.getTotalSalary()); + co.setTeamRechargeAmount(BigDecimal.ZERO); + + // BD收益计算（这里使用默认比例，实际应该从配置读取） + BigDecimal salaryRatio = new BigDecimal("0.03"); // 3% + BigDecimal rechargeRatio = new BigDecimal("0.05"); // 5% + + co.setBdRatioSalary(salaryRatio.multiply(new BigDecimal("100"))); // 转换为百分比 + co.setBdRatioRecharge(rechargeRatio.multiply(new BigDecimal("100"))); + + BigDecimal bdSalaryIncome = Optional.ofNullable(settleResult.getTotalSalary()) + .orElse(BigDecimal.ZERO) + .multiply(salaryRatio); + BigDecimal bdRechargeIncome = Optional.ofNullable(BigDecimal.ZERO) + .orElse(BigDecimal.ZERO) + .multiply(rechargeRatio); + + co.setBdIncomeSalary(bdSalaryIncome); + co.setBdIncomeRecharge(bdRechargeIncome); + } else { + // 如果没有账单周期，设置默认值 + co.setTeamSalaryAmount(BigDecimal.ZERO); + co.setTeamRechargeAmount(BigDecimal.ZERO); + co.setBdIncomeSalary(BigDecimal.ZERO); + co.setBdIncomeRecharge(BigDecimal.ZERO); + co.setBdRatioSalary(BigDecimal.ZERO); + co.setBdRatioRecharge(BigDecimal.ZERO); + } + + return co; + } + + /** + * 解析 billBelong 为日期范围. + * + * @param billBelong 账单归属（格式：20251001 或 20251016） + * @return 日期范围数组 [startDate, endDate]，格式：yyyy.MM.dd + */ + private String[] parseBillBelongToDateRange(Integer billBelong) { + if (billBelong == null) { + return new String[]{"", ""}; + } + + String billBelongStr = String.valueOf(billBelong); + int year = Integer.parseInt(billBelongStr.substring(0, 4)); + int month = Integer.parseInt(billBelongStr.substring(4, 6)); + int day = Integer.parseInt(billBelongStr.substring(6, 8)); + + LocalDate startDate = LocalDate.of(year, month, day); + LocalDate endDate; + + if (day == 1) { + // 1-15号的账单周期 + endDate = LocalDate.of(year, month, 15); + } else { + // 16-月末的账单周期 + endDate = startDate.withDayOfMonth(startDate.lengthOfMonth()); + } + + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy.MM.dd"); + return new String[]{ + startDate.format(formatter), + endDate.format(formatter) + }; + } + +} diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/bd/query/TeamBdMonthlyIncomeQryExe.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/bd/query/TeamBdMonthlyIncomeQryExe.java new file mode 100644 index 00000000..6820ca45 --- /dev/null +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/bd/query/TeamBdMonthlyIncomeQryExe.java @@ -0,0 +1,190 @@ +package com.red.circle.other.app.command.bd.query; + +import com.red.circle.other.app.dto.clientobject.TeamBdMonthlyIncomeCO; +import com.red.circle.other.app.dto.cmd.TeamBdMonthlyIncomeCmd; +import com.red.circle.other.infra.database.mongo.dto.team.TeamBillSettleResult; +import com.red.circle.other.infra.database.mongo.entity.team.team.TeamBillCycle; +import com.red.circle.other.infra.database.mongo.service.team.TeamBillCycleUtils; +import com.red.circle.other.infra.database.mongo.service.team.team.TeamBillCycleService; +import com.red.circle.other.infra.database.rds.entity.team.BusinessDevelopmentTeam; +import com.red.circle.other.infra.database.rds.service.team.BusinessDevelopmentTeamService; +import com.red.circle.other.inner.endpoint.team.bd.BdTeamLeaderClient; +import com.red.circle.other.inner.enums.team.TeamBillCycleStatus; +import com.red.circle.tool.core.collection.CollectionUtils; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import java.math.BigDecimal; +import java.time.LocalDate; +import java.time.format.DateTimeFormatter; +import java.util.*; +import java.util.stream.Collectors; + +/** + * 查询 BD 团队月度收入执行器. + * + * @author tf + * @since 2025-10-28 + */ +@Slf4j +@Component +@RequiredArgsConstructor +public class TeamBdMonthlyIncomeQryExe { + + private final BusinessDevelopmentTeamService businessDevelopmentTeamService; + private final TeamBillCycleService teamBillCycleService; + private final BdTeamLeaderClient bdTeamLeaderClient; + + /** + * 执行查询. + * + * @param cmd 查询命令 + * @return 月度收入汇总 + */ + public TeamBdMonthlyIncomeCO execute(TeamBdMonthlyIncomeCmd cmd) { + TeamBdMonthlyIncomeCO co = new TeamBdMonthlyIncomeCO(); + + // 1. 查询BD关联的所有代理 + List bdTeamList = new ArrayList<>(); + Boolean bdLeader = bdTeamLeaderClient.check(cmd.getReqUserId()).getBody(); + if (Boolean.TRUE.equals(bdLeader)) { + bdTeamList.addAll(businessDevelopmentTeamService.listByUserId(cmd.getReqUserId())); + } else { + bdTeamList.add(businessDevelopmentTeamService.getByAgentId(cmd.getReqUserId())); + } + + if (CollectionUtils.isEmpty(bdTeamList)) { + co.setTotalIncome(BigDecimal.ZERO); + co.setPreviousPeriodIncome(BigDecimal.ZERO); + return co; + } + + // 2. 获取所有团队ID + Set teamIdSet = bdTeamList.stream() + .map(BusinessDevelopmentTeam::getTeamId) + .collect(Collectors.toSet()); + + // 3. 获取当前账单周期 billBelong + Integer currentBillBelong = TeamBillCycleUtils.getCalcBillBelong(); + + // 4. 获取上一个账单周期 billBelong + Integer previousBillBelong = calculatePreviousBillBelong(currentBillBelong); + + // 5. 查询当前周期的账单（当月总收入） + Map currentBillCycleMap = teamBillCycleService.mapByTeamIds( + teamIdSet, currentBillBelong, TeamBillCycleStatus.SETTLED); + + // 6. 查询上一个周期的账单（上期收入） + Map previousBillCycleMap = teamBillCycleService.mapByTeamIds( + teamIdSet, previousBillBelong, TeamBillCycleStatus.SETTLED); + + // 8. 计算当月总收入 + BigDecimal totalIncome = calculateTotalIncome(currentBillCycleMap); + + // 9. 计算上期收入 + BigDecimal previousPeriodIncome = calculateTotalIncome(previousBillCycleMap); + + co.setTotalIncome(totalIncome); + co.setPreviousPeriodIncome(previousPeriodIncome); + return co; + } + + /** + * 计算总收入（薪资收入 + 充值收入）. + */ + private BigDecimal calculateTotalIncome(Map billCycleMap) { + if (CollectionUtils.isEmpty(billCycleMap)) { + return BigDecimal.ZERO; + } + + BigDecimal salaryRatio = new BigDecimal("0.03"); // 3% + BigDecimal rechargeRatio = new BigDecimal("0.05"); // 5% + + BigDecimal totalIncome = BigDecimal.ZERO; + + for (TeamBillCycle billCycle : billCycleMap.values()) { + TeamBillSettleResult settleResult = billCycle.getSettleResult(); + if (settleResult != null) { + // BD薪资收益 + BigDecimal salaryIncome = Optional.ofNullable(settleResult.getTotalSalary()) + .orElse(BigDecimal.ZERO) + .multiply(salaryRatio); + + // BD充值收益 + BigDecimal rechargeIncome = Optional.ofNullable(BigDecimal.ZERO) + .orElse(BigDecimal.ZERO) + .multiply(rechargeRatio); + + totalIncome = totalIncome.add(salaryIncome).add(rechargeIncome); + } + } + + return totalIncome; + } + + /** + * 计算可提现收入（所有已完成账单的收入总和）. + */ + private BigDecimal calculateAvailableIncome(List completedBills) { + if (CollectionUtils.isEmpty(completedBills)) { + return BigDecimal.ZERO; + } + + BigDecimal salaryRatio = new BigDecimal("0.03"); // 3% + BigDecimal rechargeRatio = new BigDecimal("0.05"); // 5% + + BigDecimal availableIncome = BigDecimal.ZERO; + + for (TeamBillCycle billCycle : completedBills) { + TeamBillSettleResult settleResult = billCycle.getSettleResult(); + if (settleResult != null) { + // BD薪资收益 + BigDecimal salaryIncome = Optional.ofNullable(settleResult.getTotalSalary()) + .orElse(BigDecimal.ZERO) + .multiply(salaryRatio); + + // BD充值收益 + BigDecimal rechargeIncome = Optional.ofNullable(BigDecimal.ZERO) + .orElse(BigDecimal.ZERO) + .multiply(rechargeRatio); + + availableIncome = availableIncome.add(salaryIncome).add(rechargeIncome); + } + } + + return availableIncome; + } + + /** + * 计算上一个账单周期. + * + * @param currentBillBelong 当前账单周期（格式：20251001 或 20251016） + * @return 上一个账单周期 + */ + private Integer calculatePreviousBillBelong(Integer currentBillBelong) { + if (currentBillBelong == null) { + return null; + } + + String billBelongStr = String.valueOf(currentBillBelong); + int year = Integer.parseInt(billBelongStr.substring(0, 4)); + int month = Integer.parseInt(billBelongStr.substring(4, 6)); + int day = Integer.parseInt(billBelongStr.substring(6, 8)); + + LocalDate currentDate = LocalDate.of(year, month, day); + LocalDate previousDate; + + if (day == 1) { + // 当前是1号，上一个周期是上个月的16号 + previousDate = currentDate.minusMonths(1).withDayOfMonth(16); + } else { + // 当前是16号，上一个周期是本月的1号 + previousDate = currentDate.withDayOfMonth(1); + } + + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMdd"); + return Integer.parseInt(previousDate.format(formatter)); + } + +} diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/TeamBdBillServiceImpl.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/TeamBdBillServiceImpl.java new file mode 100644 index 00000000..f87bf811 --- /dev/null +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/TeamBdBillServiceImpl.java @@ -0,0 +1,48 @@ +package com.red.circle.other.app.service; + +import com.red.circle.other.app.command.bd.query.TeamBdMemberBillDetailQryExe; +import com.red.circle.other.app.command.bd.query.TeamBdMemberBillListQryExe; +import com.red.circle.other.app.command.bd.query.TeamBdMonthlyIncomeQryExe; +import com.red.circle.other.app.dto.clientobject.TeamBdMemberBillCO; +import com.red.circle.other.app.dto.clientobject.TeamBdMemberBillDetailCO; +import com.red.circle.other.app.dto.clientobject.TeamBdMonthlyIncomeCO; +import com.red.circle.other.app.dto.cmd.TeamBdMemberBillCmd; +import com.red.circle.other.app.dto.cmd.TeamBdMemberBillDetailCmd; +import com.red.circle.other.app.dto.cmd.TeamBdMonthlyIncomeCmd; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import java.util.List; + +/** + * BD 账单服务实现. + * + * @author tf + * @since 2025-10-28 + */ +@Slf4j +@Service +@RequiredArgsConstructor +public class TeamBdBillServiceImpl implements TeamBdBillService { + + private final TeamBdMemberBillListQryExe teamBdMemberBillListQryExe; + private final TeamBdMemberBillDetailQryExe teamBdMemberBillDetailQryExe; + private final TeamBdMonthlyIncomeQryExe teamBdMonthlyIncomeQryExe; + + @Override + public List queryMemberBillList(TeamBdMemberBillCmd cmd) { + return teamBdMemberBillListQryExe.execute(cmd); + } + + @Override + public List queryMemberBillDetailList(TeamBdMemberBillDetailCmd cmd) { + return teamBdMemberBillDetailQryExe.execute(cmd); + } + + @Override + public TeamBdMonthlyIncomeCO queryMonthlyIncome(TeamBdMonthlyIncomeCmd cmd) { + return teamBdMonthlyIncomeQryExe.execute(cmd); + } + +} diff --git a/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/TeamBdMemberBillAnchorDetailCO.java b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/TeamBdMemberBillAnchorDetailCO.java new file mode 100644 index 00000000..53ba2f29 --- /dev/null +++ b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/TeamBdMemberBillAnchorDetailCO.java @@ -0,0 +1,52 @@ +package com.red.circle.other.app.dto.clientobject; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.ser.std.ToStringSerializer; +import lombok.Data; + +import java.io.Serializable; +import java.math.BigDecimal; + +/** + * BD 成员账单明细 - 主播明细对象. + * + * @author tf + * @since 2025-10-28 + */ +@Data +public class TeamBdMemberBillAnchorDetailCO implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * 主播用户ID. + */ + @JsonSerialize(using = ToStringSerializer.class) + private Long userId; + + /** + * 主播用户名. + */ + private String userName; + + /** + * 主播头像. + */ + private String avatar; + + /** + * 主播薪资（单位：元）. + */ + private BigDecimal salary; + + /** + * 主播充值（单位：元）. + */ + private BigDecimal recharge; + + /** + * 主播开播次数. + */ + private Integer hostCount; + +} diff --git a/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/TeamBdMemberBillCO.java b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/TeamBdMemberBillCO.java new file mode 100644 index 00000000..7bc0254c --- /dev/null +++ b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/TeamBdMemberBillCO.java @@ -0,0 +1,88 @@ +package com.red.circle.other.app.dto.clientobject; + +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.ser.std.ToStringSerializer; +import lombok.Data; + +import java.io.Serializable; +import java.math.BigDecimal; + +/** + * BD 成员账单客户端对象. + * + * @author tf + * @since 2025-10-28 + */ +@Data +public class TeamBdMemberBillCO implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * 代理用户ID. + */ + @JsonSerialize(using = ToStringSerializer.class) + private Long agentId; + + /** + * 代理用户名. + */ + private String agentName; + + /** + * 代理头像. + */ + private String agentAvatar; + + /** + * 团队ID. + */ + @JsonSerialize(using = ToStringSerializer.class) + private Long teamId; + + /** + * 团队人数. + */ + private Integer teamMemberCount; + + /** + * 账单周期开始日期. + */ + private String startDate; + + /** + * 账单周期结束日期. + */ + private String endDate; + + /** + * 团队薪资总额（单位：元）. + */ + private BigDecimal teamSalaryAmount; + + /** + * 团队充值总额（单位：元）. + */ + private BigDecimal teamRechargeAmount; + + /** + * BD收益-薪资部分（单位：元）. + */ + private BigDecimal bdIncomeSalary; + + /** + * BD收益-充值部分（单位：元）. + */ + private BigDecimal bdIncomeRecharge; + + /** + * BD收益比例-薪资（%）. + */ + private BigDecimal bdRatioSalary; + + /** + * BD收益比例-充值（%）. + */ + private BigDecimal bdRatioRecharge; + +} diff --git a/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/TeamBdMemberBillDetailCO.java b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/TeamBdMemberBillDetailCO.java new file mode 100644 index 00000000..cc9e938e --- /dev/null +++ b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/TeamBdMemberBillDetailCO.java @@ -0,0 +1,76 @@ +package com.red.circle.other.app.dto.clientobject; + +import com.red.circle.other.inner.enums.team.TeamBillCycleStatus; +import lombok.Data; + +import java.io.Serializable; +import java.math.BigDecimal; +import java.util.List; + +/** + * BD 成员账单明细客户端对象. + * + * @author tf + * @since 2025-10-28 + */ +@Data +public class TeamBdMemberBillDetailCO implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * 账单周期开始日期. + */ + private String startDate; + + /** + * 账单周期结束日期. + */ + private String endDate; + + /** + * 团队人数. + */ + private Integer teamMemberCount; + + /** + * 团队薪资总额（单位：元）. + */ + private BigDecimal teamSalaryAmount; + + /** + * 团队充值总额（单位：元）. + */ + private BigDecimal teamRechargeAmount; + + /** + * BD收益-薪资部分（单位：元）. + */ + private BigDecimal bdIncomeSalary; + + /** + * BD收益-充值部分（单位：元）. + */ + private BigDecimal bdIncomeRecharge; + + /** + * BD收益比例-薪资（%）. + */ + private BigDecimal bdRatioSalary; + + /** + * BD收益比例-充值（%）. + */ + private BigDecimal bdRatioRecharge; + + /** + * 账单状态. + */ + private TeamBillCycleStatus status; + + /** + * 主播明细列表. + */ + private List anchorDetails; + +} diff --git a/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/TeamBdMonthlyIncomeCO.java b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/TeamBdMonthlyIncomeCO.java new file mode 100644 index 00000000..d0d8cfe7 --- /dev/null +++ b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/TeamBdMonthlyIncomeCO.java @@ -0,0 +1,28 @@ +package com.red.circle.other.app.dto.clientobject; + +import lombok.Data; + +import java.io.Serializable; +import java.math.BigDecimal; + +/** + * BD 团队月度收入客户端对象. + * + * @author tf + * @since 2025-10-28 + */ +@Data +public class TeamBdMonthlyIncomeCO implements Serializable { + + private static final long serialVersionUID = 1L; + + /** + * 当月总收入（单位：元）. + */ + private BigDecimal totalIncome; + + /** + * 上期收入（单位：元）. + */ + private BigDecimal previousPeriodIncome; +} diff --git a/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/TeamBdMemberBillCmd.java b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/TeamBdMemberBillCmd.java new file mode 100644 index 00000000..cdf23c94 --- /dev/null +++ b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/TeamBdMemberBillCmd.java @@ -0,0 +1,41 @@ +package com.red.circle.other.app.dto.cmd; + +import com.red.circle.common.business.dto.PageQueryCmd; +import com.red.circle.common.business.dto.cmd.AppExtCommand; +import jakarta.validation.constraints.NotNull; +import lombok.Data; +import lombok.EqualsAndHashCode; + +import java.time.LocalDate; + +/** + * BD 成员账单查询命令. + * + * @author tf + * @since 2025-10-28 + */ +@EqualsAndHashCode(callSuper = true) +@Data +public class TeamBdMemberBillCmd extends AppExtCommand { + + /** + * 查询开始日期. + */ + private LocalDate startDate; + + /** + * 查询结束日期. + */ + private LocalDate endDate; + + /** + * 页码. + */ + private Integer pageNum; + + /** + * 每页大小. + */ + private Integer pageSize; + +} diff --git a/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/TeamBdMemberBillDetailCmd.java b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/TeamBdMemberBillDetailCmd.java new file mode 100644 index 00000000..a2ae3704 --- /dev/null +++ b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/TeamBdMemberBillDetailCmd.java @@ -0,0 +1,22 @@ +package com.red.circle.other.app.dto.cmd; + +import com.red.circle.common.business.dto.cmd.AppExtCommand; +import jakarta.validation.constraints.NotNull; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + * BD 成员账单明细查询命令. + * + * @author tf + * @since 2025-10-28 + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class TeamBdMemberBillDetailCmd extends AppExtCommand { + + @NotNull(message = "teamId不能为空") + private Long teamId; + + +} diff --git a/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/TeamBdMonthlyIncomeCmd.java b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/TeamBdMonthlyIncomeCmd.java new file mode 100644 index 00000000..ef12e3a2 --- /dev/null +++ b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/TeamBdMonthlyIncomeCmd.java @@ -0,0 +1,17 @@ +package com.red.circle.other.app.dto.cmd; + +import com.red.circle.common.business.dto.cmd.AppExtCommand; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + * BD 团队月度收入查询命令. + * + * @author tf + * @since 2025-10-28 + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class TeamBdMonthlyIncomeCmd extends AppExtCommand { + +} diff --git a/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/service/TeamBdBillService.java b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/service/TeamBdBillService.java new file mode 100644 index 00000000..67d15d31 --- /dev/null +++ b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/service/TeamBdBillService.java @@ -0,0 +1,44 @@ +package com.red.circle.other.app.service; + +import com.red.circle.other.app.dto.clientobject.TeamBdMemberBillCO; +import com.red.circle.other.app.dto.clientobject.TeamBdMemberBillDetailCO; +import com.red.circle.other.app.dto.clientobject.TeamBdMonthlyIncomeCO; +import com.red.circle.other.app.dto.cmd.TeamBdMemberBillCmd; +import com.red.circle.other.app.dto.cmd.TeamBdMemberBillDetailCmd; +import com.red.circle.other.app.dto.cmd.TeamBdMonthlyIncomeCmd; + +import java.util.List; + +/** + * BD 账单服务接口. + * + * @author tf + * @since 2025-10-28 + */ +public interface TeamBdBillService { + + /** + * 查询 BD 成员账单列表. + * + * @param cmd 查询命令 + * @return 账单列表 + */ + List queryMemberBillList(TeamBdMemberBillCmd cmd); + + /** + * 查询 BD 成员账单明细列表. + * + * @param cmd 查询命令 + * @return 账单明细列表 + */ + List queryMemberBillDetailList(TeamBdMemberBillDetailCmd cmd); + + /** + * 查询 BD 团队月度收入汇总. + * + * @param cmd 查询命令 + * @return 月度收入 + */ + TeamBdMonthlyIncomeCO queryMonthlyIncome(TeamBdMonthlyIncomeCmd cmd); + +} diff --git a/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/team/BusinessDevelopmentTeamService.java b/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/team/BusinessDevelopmentTeamService.java index f5651eaf..111a2c62 100644 --- a/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/team/BusinessDevelopmentTeamService.java +++ b/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/team/BusinessDevelopmentTeamService.java @@ -84,6 +84,11 @@ public interface BusinessDevelopmentTeamService extends */ List listByUserId(Long userId); + /** + * 获得bd的成员. + */ + BusinessDevelopmentTeam getByAgentId(Long agentId); + /** * 根据bd用户id解散这个bd团队. */ diff --git a/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/team/impl/BusinessDevelopmentTeamServiceImpl.java b/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/team/impl/BusinessDevelopmentTeamServiceImpl.java index 125a4262..4bc5e503 100644 --- a/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/team/impl/BusinessDevelopmentTeamServiceImpl.java +++ b/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/rds/service/team/impl/BusinessDevelopmentTeamServiceImpl.java @@ -174,6 +174,13 @@ public class BusinessDevelopmentTeamServiceImpl extends .list(); } + @Override + public BusinessDevelopmentTeam getByAgentId(Long agentId) { + return query().eq(BusinessDevelopmentTeam::getAgentId, agentId) + .last("LIMIT 1") + .getOne(); + } + @Override public void deleteAllByUserId(Long userId) { delete()