diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/task/TaskListener.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/task/TaskListener.java index 0f6f36d8..0b68b5a7 100644 --- a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/task/TaskListener.java +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/task/TaskListener.java @@ -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) {