新增情人节活动

accompany-mq/accompany-mq-sdk/src/main/java/com/accompany/mq/constant/MqConstant.java

@@ -42,4 +42,12 @@ public interface MqConstant {
 
     String CHARGE_CONSUME_GROUP = "charge_consume_group";
 
+    String ACT_USER_TASK_TOPIC = "act_user_task_topic";
+
+    String ACT_USER_TASK_CONSUME_GROUP = "act_user_task_consume_group";
+
+    String ACT_TASK_REWARD_TOPIC = "act_task_reward_topic";
+
+    String ACT_TASK_REWARD_CONSUME_GROUP = "act_task_reward_consume_group";
+
 }

accompany-mq/accompany-mq-sdk/src/main/java/com/accompany/mq/model/ActTaskRewardMqMessage.java

@@ -0,0 +1,17 @@
+package com.accompany.mq.model;
+
+import lombok.Data;
+
+/**
+ * @author: liaozetao
+ * @date: 2024/2/5 11:57
+ * @description:
+ */
+@Data
+public class ActTaskRewardMqMessage extends BaseMqMessage {
+
+    /**
+     * 用户任务ID
+     */
+    private Long userTaskId;
+}

accompany-mq/accompany-mq-sdk/src/main/java/com/accompany/mq/model/ActUserTaskMqMessage.java

@@ -0,0 +1,42 @@
+package com.accompany.mq.model;
+
+import lombok.Data;
+
+/**
+ * @author: liaozetao
+ * @date: 2024/1/31 11:43
+ * @description:
+ */
+@Data
+public class ActUserTaskMqMessage extends BaseMqMessage {
+
+    /**
+     * 房间UID
+     */
+    private Long roomUid;
+
+    /**
+     * 送礼用户UID
+     */
+    private Long sendUid;
+
+    /**
+     * 收礼用户UID
+     */
+    private Long receiveUid;
+
+    /**
+     * 礼物ID
+     */
+    private Integer giftId;
+
+    /**
+     * 礼物值
+     */
+    private Long giftValue;
+
+    /**
+     * 消息时间
+     */
+    private Long messTime;
+}

accompany-mq/accompany-mq-service/src/main/java/com/accompany/mq/listener/AbstractMessageListener.java

@@ -3,6 +3,7 @@ package com.accompany.mq.listener;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.json.JSONUtil;
 import com.accompany.common.redis.RedisKey;
+import com.accompany.core.service.common.JedisLockService;
 import com.accompany.core.service.common.JedisService;
 import com.accompany.mq.model.BaseMqMessage;
 import com.google.gson.internal.$Gson$Types;
@@ -26,6 +27,9 @@ public abstract class AbstractMessageListener<T extends BaseMqMessage> implement
     @Autowired
     protected JedisService jedisService;
 
+    @Autowired
+    protected JedisLockService jedisLockService;
+
     @Override
     public void onMessage(String message) {
         try {