yujian
2019-12-19 bb07147aaa96d1ef4c99e358dbbe7dad160dc62a
fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInfoExtraServiceImpl.java
@@ -19,8 +19,15 @@
import org.yeshi.utils.entity.FileUploadResult;
import org.yeshi.utils.tencentcloud.COSManager;
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;
import com.yeshi.fanli.dto.mq.user.body.InviteCodeActiveMQMsg;
import com.yeshi.fanli.dto.mq.user.body.UserInfoUpdateMQMsg;
import com.yeshi.fanli.dto.mq.user.body.UserInfoUpdateMQMsg.UserInfoUpdateTypeEnum;
import com.yeshi.fanli.dto.wx.WXAccountInfoDTO;
import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
@@ -43,6 +50,8 @@
import com.yeshi.fanli.util.InviteCodeFilterUtil;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.account.UserUtil;
import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
import com.yeshi.fanli.util.rocketmq.MQTopicName;
import com.yeshi.fanli.util.wx.WXLoginUtil;
import com.yeshi.fanli.vo.user.UserInfoExtraVO;
@@ -78,6 +87,9 @@
   @Resource
   private UserInviteRecordService userInviteRecordService;
   @Resource(name = "producer")
   private Producer producer;
   @Override
   public UserInfoExtraVO getRankInfo(Long uid) throws UserInfoExtraException, Exception {
@@ -276,7 +288,6 @@
      userInfoExtraMapper.insertSelective(userInfoExtra);
   }
   @Override
   public UserInfoExtra saveUserInfoExtra(UserInfoExtra userInfoExtra) throws UserInfoExtraException {
@@ -360,6 +371,12 @@
         userInfoExtra.setCreateTime(new Date());
         userInfoExtraMapper.insertSelective(userInfoExtra);
      }
      // 发送激活成功消息
      Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.inviteCodeActive,
            new Gson().toJson(new InviteCodeActiveMQMsg(uid, new Date())));
      producer.send(message);
      return mycode;
   }
@@ -472,6 +489,10 @@
         userInfoExtra.setCreateTime(new Date());
         userInfoExtraMapper.insertSelective(userInfoExtra);
      }
      // 发送激活成功消息
      Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.inviteCodeActive,
            new Gson().toJson(new InviteCodeActiveMQMsg(uid, new Date())));
      producer.send(message);
   }
   @Override
@@ -571,7 +592,8 @@
      }
      // 生成邀请码
      String inviteCode = createInviteCode(uid);;
      String inviteCode = createInviteCode(uid);
      ;
      if (StringUtil.isNullOrEmpty(inviteCode)) 
         throw new UserInfoExtraException(1, "激活码生成失败");
      
@@ -666,6 +688,7 @@
   /**
    * 生产邀请码
    *
    * @param uid
    * @return
    */
@@ -679,7 +702,6 @@
      }
      return inviteCode;
   }
   
   @Override
   public long countByRankId(Long rankId) {
@@ -782,7 +804,7 @@
      userInfoExtraMapper.updateAutoExtract(days);
   }
   @Transactional
   @Transactional(rollbackFor=Exception.class)
   @Override
   public void updateInviteCodeVip(String inviteCodeVip, Long uid) throws UserInfoExtraException {
      if (inviteCodeVip == null || inviteCodeVip.length() < 4 || inviteCodeVip.length() > 12)
@@ -817,5 +839,9 @@
      update.setInviteCodeVip(inviteCodeVip);
      update.setUpdateTime(new Date());
      userInfoExtraMapper.updateByPrimaryKeySelective(update);
       //发送邀请码更改成功的消息
      Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.userInfoUpdate,
            new Gson().toJson(new UserInfoUpdateMQMsg(uid, UserInfoUpdateTypeEnum.inviteCode, inviteCodeVip, new Date())));
      producer.send(message);
   }
}