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-12-05 11:15:25 +08:00
parent 2068eb2e0c
commit 57d4f20af8
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/task/TaskListener.java
View File

@ -2,6 +2,8 @@ package com.red.circle.other.app.listener.task;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.google.common.base.Throwables;
import com.red.circle.common.business.core.enums.SysOriginPlatformEnum;
import com.red.circle.common.business.enums.SendPropsOrigin;
import com.red.circle.component.mq.MessageEventProcess;
import com.red.circle.component.mq.MessageEventProcessDescribe;
import com.red.circle.component.mq.config.RocketMqMessageListener;
@ -22,7 +24,10 @@ import com.red.circle.other.domain.gateway.user.ability.InviteUserGateway;
import com.red.circle.other.infra.database.rds.dao.task.UserTaskProgressDAO;
import com.red.circle.other.infra.database.rds.entity.task.UserTaskProgress;
import com.red.circle.other.infra.database.rds.service.user.user.RelationshipFriendService;
import com.red.circle.other.inner.endpoint.activity.PropsActivityClient;
import com.red.circle.other.inner.model.cmd.activity.SendActivityRewardCmd;
import com.red.circle.tool.core.date.TimestampUtils;
import com.red.circle.tool.core.sequence.IdWorkerUtils;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
@ -46,6 +51,7 @@ public class TaskListener implements MessageListener {
private final SpinsUserTaskProgressService spinsUserTaskProgressService;
private final AdminTaskService adminTaskService;
private final UserTaskProgressDAO userTaskProgressDAO;
private final PropsActivityClient propsActivityCnfClient;
@Override
public Action consume(ConsumerMessage message) {
@ -352,6 +358,16 @@ public class TaskListener implements MessageListener {
userTaskProgress.setIsRewardCollected(1);
userTaskProgress.setCompletedTime(TimestampUtils.now());
userTaskProgressDAO.updateById(userTaskProgress);
// 发送道具
propsActivityCnfClient.sendActivityReward(new SendActivityRewardCmd()
.setTrackId(IdWorkerUtils.getId())
.setSysOrigin(SysOriginPlatformEnum.LIKEI)
.setAcceptUserId(eventBody.getUserId())
.setSourceGroupId(userTaskProgress.getRewardId())
.setOrigin(SendPropsOrigin.DAILY_TASK_REWARD)
);
}
private void dealRechargeCommission(TaskApprovalEvent eventBody) {