| | |
|---|
| | | import org.springframework.transaction.annotation.Transactional;
|
|---|
| | |
|
|---|
| | | import com.aliyun.openservices.ons.api.Message;
|
|---|
| | | import com.aliyun.openservices.ons.api.Producer;
|
|---|
| | | import com.yeshi.fanli.dao.mybatis.user.vip.UserVIPPreInfoMapper;
|
|---|
| | | import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;
|
|---|
| | | import com.yeshi.fanli.dto.mq.user.body.UserLevelChangedMQMsg;
|
|---|
| | |
|---|
| | | import com.yeshi.fanli.service.manger.msg.RocketMQManager;
|
|---|
| | | import com.yeshi.fanli.util.Constant;
|
|---|
| | | import com.yeshi.fanli.util.StringUtil;
|
|---|
| | | import com.yeshi.fanli.util.TimeUtil;
|
|---|
| | | import org.yeshi.utils.TimeUtil;
|
|---|
| | | import com.yeshi.fanli.util.annotation.RequestSerializableByKeyService;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|---|
