From 57d4f20af80b07b9f3693b30c40b9327b69d896b Mon Sep 17 00:00:00 2001
From: tianfeng <769204422@qq.com>
Date: Fri, 5 Dec 2025 11:15:25 +0800
Subject: [PATCH] =?UTF-8?q?=E7=BB=91=E5=AE=9A=E9=82=80=E8=AF=B7=E7=A0=81?=
 =?UTF-8?q?=E4=BB=BB=E5=8A=A1=20=E8=87=AA=E5=8A=A8=E9=A2=86=E5=8F=96?=
 =?UTF-8?q?=E5=A5=96=E5=8A=B1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../other/app/listener/task/TaskListener.java    | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

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) {