| | |
|---|
| | |
|
|---|
| | | import com.aliyun.openservices.ons.api.Message;
|
|---|
| | | import com.aliyun.openservices.ons.api.Producer;
|
|---|
| | | import com.google.gson.Gson;
|
|---|
| | | import com.yeshi.fanli.dao.mybatis.user.UserInfoExtraMapper;
|
|---|
| | | import com.yeshi.fanli.dao.mybatis.user.UserRankRecordMapper;
|
|---|
| | | import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;
|
|---|
| | |
|---|
| | |
|
|---|
| | | userActivedRecordService.add(new UserActivedRecord(uid));
|
|---|
| | |
|
|---|
| | | // if (!Constant.IS_TEST) { // 发送激活成功消息
|
|---|
| | | if (!Constant.IS_TEST) { // 发送激活成功消息
|
|---|
| | | Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.inviteCodeActive,
|
|---|
| | | new InviteCodeActiveMQMsg(uid, new Date()));
|
|---|
| | | producer.send(message);
|
|---|
| | | // }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | return inviteCode;
|
|---|
| | | }
|
|---|
| | |
|---|
| | | return inviter;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Override
|
|---|
| | | public void updateAutoExtract(Integer days) {
|
|---|
| | | userInfoExtraMapper.updateAutoExtract(days);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | @Transactional(rollbackFor = Exception.class)
|
|---|
| | | @Override
|
|---|
