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

绑定cp清除缓存

Browse Source
This commit is contained in:
tianfeng 2025-12-11 16:07:06 +08:00
parent a581d569f1
commit 41b8f700d2
1 changed files with 5 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/user/ProcessCpApplyCmd.java
View File

@ -9,6 +9,8 @@ import com.red.circle.framework.core.response.CommonErrorCode;
import com.red.circle.mq.business.model.event.user.CpApplyEvent;
import com.red.circle.mq.rocket.business.producer.UserMqMessageService;
import com.red.circle.other.app.dto.cmd.user.relation.cp.ProcessApplyCmd;
import com.red.circle.other.domain.gateway.user.UserProfileGateway;
import com.red.circle.other.infra.database.cache.service.user.UserRunProfileCacheService;
import com.red.circle.other.infra.database.rds.entity.user.user.CpApply;
import com.red.circle.other.infra.database.rds.entity.user.user.CpRelationship;
import com.red.circle.other.infra.database.rds.entity.user.user.CpValue;
@ -22,6 +24,7 @@ import com.red.circle.wallet.inner.endpoint.wallet.WalletGoldClient;
import com.red.circle.wallet.inner.model.cmd.GoldReceiptCmd;
import com.red.circle.wallet.inner.model.enums.GoldOrigin;
import java.math.BigDecimal;
import java.util.Arrays;
import java.util.Objects;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@ -43,6 +46,7 @@ public class ProcessCpApplyCmd {
private final WalletGoldClient walletGoldClient;
private final UserMqMessageService userMqMessageService;
private final CpRelationshipService cpRelationshipService;
private final UserProfileGateway userProfileGateway;
public void execute(ProcessApplyCmd cmd) {
process(cmd);
@ -89,18 +93,7 @@ public class ProcessCpApplyCmd {
cmd.requireReqSysOrigin());
}
// giftBackpackClient.incrGiftAndLimit(new GiftBackpackLimitCmd()
// .setUserId(cpApply.getSendApplyUserId())
// .setGiftId(cpGift.getId())
// .setQuantity(1)
// .setGiftTab(cpGift.getGiftTab())
// .setLimitContent(cpApply.getAcceptApplyUserId().toString())
// );
// imMessageClient
// .sendMessageText(cpApply.getAcceptApplyUserId().toString(),
// cpApply.getSendApplyUserId().toString(),
// cmd.getApplyText());
userProfileGateway.removeCacheAll(Arrays.asList(cpApply.getSendApplyUserId(), cpApply.getAcceptApplyUserId()));
}
private void refuseStatusWait(ProcessApplyCmd cmd, CpApply cpApply) {