hy/aslan-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

BD团队more接口 新增缓存逻辑

Browse Source
This commit is contained in:
tianfeng 2025-11-27 20:14:27 +08:00
parent bb23ff48e3
commit 6c2ff98b5e
1 changed files with 26 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/bd/query/BdTeamMemberDetailQryExe.java
View File

@ -1,10 +1,13 @@
package com.red.circle.other.app.command.bd.query; package com.red.circle.other.app.command.bd.query;
import com.alibaba.fastjson.JSON;
import com.red.circle.component.redis.service.RedisService;
import com.red.circle.framework.core.asserts.ResponseAssert; import com.red.circle.framework.core.asserts.ResponseAssert;
import com.red.circle.other.app.convertor.user.UserProfileAppConvertor; import com.red.circle.other.app.convertor.user.UserProfileAppConvertor;
import com.red.circle.other.app.dto.clientobject.BdIncomeDetailCO; import com.red.circle.other.app.dto.clientobject.BdIncomeDetailCO;
import com.red.circle.other.app.dto.clientobject.BdIncomeDetailMemberCO; import com.red.circle.other.app.dto.clientobject.BdIncomeDetailMemberCO;
import com.red.circle.other.app.dto.clientobject.BdTeamMemberDetailCO; import com.red.circle.other.app.dto.clientobject.BdTeamMemberDetailCO;
import com.red.circle.other.app.dto.clientobject.BdTeamOverviewCO;
import com.red.circle.other.app.dto.cmd.BdTeamMemberDetailQueryCmd; import com.red.circle.other.app.dto.cmd.BdTeamMemberDetailQueryCmd;
import com.red.circle.other.domain.gateway.user.UserProfileGateway; import com.red.circle.other.domain.gateway.user.UserProfileGateway;
import com.red.circle.other.infra.database.mongo.dto.team.TeamBillMemberTarget; import com.red.circle.other.infra.database.mongo.dto.team.TeamBillMemberTarget;
@ -30,6 +33,7 @@ import java.math.BigDecimal;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.time.ZoneId; import java.time.ZoneId;
import java.util.*; import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors; import java.util.stream.Collectors;
/** /**
@ -49,6 +53,7 @@ public class BdTeamMemberDetailQryExe {
private final UserProfileGateway userProfileGateway; private final UserProfileGateway userProfileGateway;
private final UserProfileAppConvertor userProfileAppConvertor; private final UserProfileAppConvertor userProfileAppConvertor;
private final TeamProfileService teamProfileService; private final TeamProfileService teamProfileService;
private final RedisService redisService;
/** /**
* 执行查询 * 执行查询
@ -57,15 +62,29 @@ public class BdTeamMemberDetailQryExe {
String type = cmd.getType(); String type = cmd.getType();
Long targetId = cmd.getTargetId(); Long targetId = cmd.getTargetId();
if ("AGENCY".equals(type)) { // 缓存查询
// Agency视角：查询单个team的数据 String cacheKey = "bdteam:detail:" + type + ":" + targetId;
return queryAgencyDetail(targetId); BdTeamMemberDetailCO cached = redisService.getStringToObject(cacheKey, BdTeamMemberDetailCO.class);
} else if ("BD".equals(type)) { if (cached != null) {
// BD视角：查询该BD下所有team的汇总数据 return cached;
return queryBdDetail(targetId);
} }
return new BdTeamMemberDetailCO(); // 查询数据
BdTeamMemberDetailCO result;
if ("AGENCY".equals(type)) {
// Agency视角：查询单个team的数据
result = queryAgencyDetail(targetId);
} else if ("BD".equals(type)) {
// BD视角：查询该BD下所有team的汇总数据
result = queryBdDetail(targetId);
} else {
result = new BdTeamMemberDetailCO();
}
// 缓存结果（1分钟）
redisService.setString(cacheKey, JSON.toJSONString(result), 1, TimeUnit.MINUTES);
return result;
} }
/** /**