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

新增taskId 11 填写其他用户邀请码任务

Browse Source
This commit is contained in:
tianfeng 2025-10-29 17:54:36 +08:00
parent 420e9b1b39
commit 4c12994010
3 changed files with 27 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/activity/BindInviteCodeExe.java
View File

@ -2,6 +2,8 @@ package com.red.circle.other.app.command.activity;
import com.red.circle.component.redis.service.RedisService;
import com.red.circle.framework.dto.ResultResponse;
import com.red.circle.mq.business.model.event.task.TaskApprovalEvent;
import com.red.circle.mq.rocket.business.producer.TaskMqMessage;
import com.red.circle.other.app.command.user.InviteCodeService;
import com.red.circle.other.app.dto.cmd.SpinsTaskProgressUpdateCmd;
import com.red.circle.other.app.dto.cmd.activity.BindInviteCodeCmd;
@ -12,6 +14,7 @@ import com.red.circle.other.infra.database.rds.entity.user.user.UserInviteUser;
import com.red.circle.other.infra.database.rds.service.user.user.UserInviteUserService;
import com.red.circle.other.infra.enums.user.InviteTypeEnum;
import com.red.circle.other.inner.endpoint.user.device.RegisterDeviceClient;
import com.red.circle.tool.core.date.LocalDateTimeUtils;
import com.red.circle.tool.core.date.TimestampUtils;
import com.red.circle.tool.core.date.ZonedDateTimeAsiaRiyadhUtils;
import com.red.circle.tool.core.sequence.IdWorkerUtils;
@ -44,6 +47,7 @@ public class BindInviteCodeExe {
private final RedisService redisService;
private final SpinsUserTaskProgressService spinsUserTaskProgressService;
private final RegisterDeviceClient registerDeviceClient;
private final TaskMqMessage taskMqMessage;
/**
* 执行绑定邀请码
@ -183,6 +187,12 @@ public class BindInviteCodeExe {
.setProgressValue(inviteCount)
);
}
// 关注一个用户任务
taskMqMessage.sendTask(TaskApprovalEvent.builder()
.taskId(11)
.userId(cmd.requiredReqUserId())
.build());
}
/**

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

@ -120,6 +120,10 @@ public class TaskListener implements MessageListener {
// 处理任务-10 的逻辑 关注一个房间
handleTask10(eventBody);
break;
case 11:
// 处理任务-11 的逻辑 填写其他人的邀请码
handleTask11(eventBody);
break;
default:
// 处理未知任务 ID 的情况
handleUnknownTask(taskId);
@ -325,6 +329,13 @@ public class TaskListener implements MessageListener {
}
}
private void handleTask11(TaskApprovalEvent eventBody) {
log.warn("处理任务-11: {}", eventBody);
eventBody.setTargetValue(1);
eventBody.setCompleteValue(1);
updateTaskStatus(eventBody);
}
private void dealRechargeCommission(TaskApprovalEvent eventBody) {
if (StringUtils.isNotBlank(eventBody.getSysOrigin()) && eventBody.getCurrencyDiff() > 0L) {
try {

6
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/task/TaskServiceImpl.java
View File

@ -23,6 +23,7 @@ import com.red.circle.other.inner.model.dto.activity.props.ActivityRewardProps;
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.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
@ -32,6 +33,7 @@ import java.util.stream.Collectors;
/**
* 任务服务实现类
*/
@Slf4j
@Service
@RequiredArgsConstructor
public class TaskServiceImpl implements TaskService {
@ -227,6 +229,10 @@ public class TaskServiceImpl implements TaskService {
List<UserTaskProgress> userTaskProgresses = userTaskProgressDao.selectList(updateWrapper);
if (CollectionUtils.isEmpty(userTaskProgresses)) {
TaskConfig taskConfig = taskConfigDao.selectById(taskId);
if (taskConfig == null) {
log.warn("任务不存在：{} 无法创建UserTaskProgress", taskId);
return;
}
UserTaskProgress progress = new UserTaskProgress();
progress.setId(IdWorkerUtils.getId());