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

成为主播增加主播设备指纹校验：后台，邀请，成为代理

Browse Source
This commit is contained in:
tianfeng 2025-11-11 10:21:11 +08:00
parent a7eb054c03
commit bf9dcb1848
2 changed files with 14 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/team/AgentInviteHostExe.java
View File

@ -13,6 +13,7 @@ import com.red.circle.other.app.dto.clientobject.team.BdInviteMessageCO;
import com.red.circle.other.app.dto.cmd.team.*; import com.red.circle.other.app.dto.cmd.team.*;
import com.red.circle.other.app.util.OfficialNoticeUtils; import com.red.circle.other.app.util.OfficialNoticeUtils;
import com.red.circle.other.domain.gateway.user.UserProfileGateway; import com.red.circle.other.domain.gateway.user.UserProfileGateway;
import com.red.circle.other.domain.gateway.user.ability.RegisterDeviceGateway;
import com.red.circle.other.infra.database.cache.service.other.EnumConfigCacheService; import com.red.circle.other.infra.database.cache.service.other.EnumConfigCacheService;
import com.red.circle.other.infra.database.mongo.entity.team.bd.BdInviteAgentMessage; import com.red.circle.other.infra.database.mongo.entity.team.bd.BdInviteAgentMessage;
import com.red.circle.other.infra.database.mongo.entity.team.bd.MessageInviteGroup; import com.red.circle.other.infra.database.mongo.entity.team.bd.MessageInviteGroup;
@ -51,7 +52,7 @@ public class AgentInviteHostExe {
private final TeamMemberService teamMemberService; private final TeamMemberService teamMemberService;
private final TeamProfileService teamProfileService; private final TeamProfileService teamProfileService;
private final OfficialNoticeClient officialNoticeClient; private final OfficialNoticeClient officialNoticeClient;
private final EnumConfigCacheService enumConfigCacheService; private final RegisterDeviceGateway registerDeviceGateway;
private final UserProfileAppConvertor userProfileAppConvertor; private final UserProfileAppConvertor userProfileAppConvertor;
private final BdInviteAgentMessageService bdInviteAgentMessageService; private final BdInviteAgentMessageService bdInviteAgentMessageService;
@ -165,6 +166,11 @@ public class AgentInviteHostExe {
cmd.getStatus(), MessageInviteGroup.AGENT_INVITE_HOST.name())); cmd.getStatus(), MessageInviteGroup.AGENT_INVITE_HOST.name()));
if (Objects.equals(cmd.getStatus(), 1)) { if (Objects.equals(cmd.getStatus(), 1)) {
// 主播设备指纹校验
Boolean hasAnchorWithSameDevice = registerDeviceGateway.checkDeviceFingerprintHasAnchor(
message.getInviteUserId());
ResponseAssert.isFalse(TeamErrorCode.DEVICE_FINGERPRINT_USED_BY_ANCHOR, hasAnchorWithSameDevice);
teamMemberService.addMember(new TeamMember() teamMemberService.addMember(new TeamMember()
.setSortId(IdWorkerUtils.getId()) .setSortId(IdWorkerUtils.getId())
.setSysOrigin(cmd.requireReqSysOrigin()) .setSysOrigin(cmd.requireReqSysOrigin())

7
rc-service/rc-service-other/other-inner-endpoint/src/main/java/com/red/circle/other/app/inner/service/team/impl/TeamProfileClientServiceImpl.java
View File

@ -15,6 +15,7 @@ import com.red.circle.mq.business.model.event.team.TeamSalaryCountEvent;
import com.red.circle.mq.rocket.business.streams.TeamSalaryCountSink; import com.red.circle.mq.rocket.business.streams.TeamSalaryCountSink;
import com.red.circle.other.app.inner.service.team.TeamProfileClientService; import com.red.circle.other.app.inner.service.team.TeamProfileClientService;
import com.red.circle.other.domain.gateway.user.UserProfileGateway; import com.red.circle.other.domain.gateway.user.UserProfileGateway;
import com.red.circle.other.domain.gateway.user.ability.RegisterDeviceGateway;
import com.red.circle.other.domain.model.user.UserProfile; import com.red.circle.other.domain.model.user.UserProfile;
import com.red.circle.other.infra.convertor.team.TeamInfraConvertor; import com.red.circle.other.infra.convertor.team.TeamInfraConvertor;
import com.red.circle.other.infra.database.mongo.dto.team.TeamBillSettleResult; import com.red.circle.other.infra.database.mongo.dto.team.TeamBillSettleResult;
@ -117,6 +118,7 @@ public class TeamProfileClientServiceImpl implements TeamProfileClientService {
private final TeamApplicationProcessApprovalService teamApplicationProcessApprovalService; private final TeamApplicationProcessApprovalService teamApplicationProcessApprovalService;
private final BillDiamondBalanceService billDiamondBalanceService; private final BillDiamondBalanceService billDiamondBalanceService;
private final BillDiamondBalanceDetailsService billDiamondBalanceDetailsService; private final BillDiamondBalanceDetailsService billDiamondBalanceDetailsService;
private final RegisterDeviceGateway registerDeviceGateway;
@Override @Override
public List<TeamProfileDTO> listByIds(Set<Long> ids) { public List<TeamProfileDTO> listByIds(Set<Long> ids) {
@ -213,6 +215,11 @@ public class TeamProfileClientServiceImpl implements TeamProfileClientService {
businessDevelopmentBaseInfoService.checkBD(cmd.getBdUserId())); businessDevelopmentBaseInfoService.checkBD(cmd.getBdUserId()));
} }
// 主播设备指纹校验
Boolean hasAnchorWithSameDevice = registerDeviceGateway.checkDeviceFingerprintHasAnchor(
userProfile.getId());
ResponseAssert.isFalse(TeamErrorCode.DEVICE_FINGERPRINT_USED_BY_ANCHOR, hasAnchorWithSameDevice);
String key = "CreateTeam:" + userProfile.getId(); String key = "CreateTeam:" + userProfile.getId();
ResponseAssert.isTrue(CommonErrorCode.OPERATION_CONFLICT, redisService.lock(key, 60)); ResponseAssert.isTrue(CommonErrorCode.OPERATION_CONFLICT, redisService.lock(key, 60));