Merge branch 'div' of ssh://193.112.35.168:29418/fanli-server into div

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);

   }

}