moliparty/peko-java
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

用户活动创建，定时，过期，后天审核==

Browse Source
This commit is contained in:
hokli
2025-05-12 18:46:06 +08:00
parent 976a73fd6e
commit 34313b2697
32 changed files with 729 additions and 260 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -47,4 +47,5 @@ public interface MqConstant {
String LUCKY_25_TOPIC = "lucky_25_topic";
String LUCKY_25_CONSUME_GROUP = "lucky_25_consume_group";
}

23
accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/UserEventBeginEndConsumer.java
View File

@@ -1,23 +0,0 @@
package com.accompany.mq.consumer;
import cn.hutool.core.date.DateUtil;
import com.accompany.business.message.UserEventBeginEndMessage;
import com.accompany.mq.constant.MqConstant;
import com.accompany.mq.listener.AbstractMessageListener;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Component;
import java.util.Date;
@Slf4j
@Component
@ConditionalOnProperty(name = "spring.application.name", havingValue = "admin")
@RocketMQMessageListener(topic = MqConstant.USER_ENEVT_DELAY_TOPIC, consumerGroup = MqConstant.USER_ENEVT_DELAY_CONSUME_GROUP)
public class UserEventBeginEndConsumer extends AbstractMessageListener<UserEventBeginEndMessage> {
@Override
protected void onMessage(UserEventBeginEndMessage eventBeginEndMessage) throws Exception {
log.info("onMessage gameMsgMessage: {}, begin:{},now:{}", eventBeginEndMessage.toString(), eventBeginEndMessage.getMsgDate(), DateUtil.formatDateTime(new Date()));
}
}