双12活动添加,邀请码发布修改，爬单新规则添加

admin

2019-12-06 cd637932a970e7935b17d41568fe89c92775bccc

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInfoExtraServiceImpl.java

@@ -1,5 +1,6 @@
package com.yeshi.fanli.service.impl.user;



import java.io.InputStream;

import java.text.ParseException;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

@@ -12,21 +13,25 @@
import javax.annotation.Resource;



import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.yeshi.utils.DateUtil;

import org.yeshi.utils.HttpUtil;

import org.yeshi.utils.entity.FileUploadResult;

import org.yeshi.utils.tencentcloud.COSManager;



import com.yeshi.fanli.dao.mybatis.user.UserInfoExtraMapper;

import com.yeshi.fanli.dao.mybatis.user.UserRankRecordMapper;

import com.yeshi.fanli.dto.wx.WXAccountInfoDTO;

import com.yeshi.fanli.entity.bus.user.ThreeSale;

import com.yeshi.fanli.entity.bus.user.UserInfo;

import com.yeshi.fanli.entity.bus.user.UserInfoExtra;

import com.yeshi.fanli.entity.bus.user.UserRank;

import com.yeshi.fanli.entity.bus.user.UserRankRecord;

import com.yeshi.fanli.entity.bus.user.WeiXinUser;

import com.yeshi.fanli.exception.ThreeSaleException;

import com.yeshi.fanli.exception.user.ThreeSaleException;

import com.yeshi.fanli.exception.user.UserInfoExtraException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;

import com.yeshi.fanli.service.inter.order.CommonOrderCountService;

import com.yeshi.fanli.service.inter.user.ForbiddenUserIdentifyCodeService;

import com.yeshi.fanli.service.inter.user.UserAccountService;

@@ -34,19 +39,19 @@
import com.yeshi.fanli.service.inter.user.UserInfoService;

import com.yeshi.fanli.service.inter.user.UserInviteRecordService;

import com.yeshi.fanli.service.inter.user.UserRankService;

import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.account.UserUtil;

import com.yeshi.fanli.util.wx.WXLoginUtil;

import com.yeshi.fanli.vo.user.UserInfoExtraVO;





@Service

public class UserInfoExtraServiceImpl implements UserInfoExtraService {



   @Resource

   private UserInfoExtraMapper userInfoExtraMapper;

	


   @Resource

   private UserRankRecordMapper userRankRecordMapper;



@@ -58,22 +63,21 @@


   @Resource

   private ConfigService configService;

	


   @Resource

   private ThreeSaleSerivce threeSaleSerivce;

	


   @Resource

   private UserInfoService userInfoService;

	


   @Resource

   private UserAccountService userAccountService;

	


   @Resource

   private ForbiddenUserIdentifyCodeService forbiddenUserIdentifyCodeService;

	


   @Resource

   private UserInviteRecordService userInviteRecordService;

	


   @Override

   public UserInfoExtraVO getRankInfo(Long uid) throws UserInfoExtraException, Exception {

@@ -83,7 +87,7 @@
         throw new UserInfoExtraException(1, "用户附加信息不存在");

      }



      // 等级对照表 
      // 等级对照表

      String contrast = configService.get("user_rank_contrast");

      extraVO.setRankContrast(contrast);

      // 特别提醒

@@ -91,11 +95,11 @@
      extraVO.setRankTip(rankTip);



      Integer rankOrderNum = extraVO.getRankOrderNum();

		


      UserRank userRank = extraVO.getUserRank();

      // 青铜等级不返回恭喜语句 注：青铜等级id 必须为1

      if (userRank != null && userRank.getId() != null && userRank.getId() > 1) {

			


         String rankMsg = null;

         Integer rankSource = extraVO.getRankSource();

         switch (rankSource) {

@@ -150,13 +154,13 @@
   }



   @Override

   public void updateUserRankByUid(Long uid) throws UserInfoExtraException{

   public void updateUserRankByUid(Long uid) throws UserInfoExtraException {

      if (uid == null || uid == 0) {

         return;

      }

		


      boolean isupdateRank = true;

		


      UserInfoExtra userInfoExtra = userInfoExtraMapper.getInfoExtraByUid(uid);

      if (userInfoExtra != null && userInfoExtra.getId() != null) {

         // 判断当月是否已更新

@@ -166,46 +170,46 @@
            if (sdf.format(rankUpdateTime).equals(sdf.format(new Date()))) {

               isupdateRank = false;

            }

         } 
         }

      } else {

         userInfoExtra = new UserInfoExtra();

         userInfoExtra.setUserInfo(new UserInfo(uid));

      }

		


      // 更新等级

      if (isupdateRank) {

         updateRank(userInfoExtra);

      }

   }

	


   @Override

   public void createUserInfoExtra (Long uid) throws UserInfoExtraException{

   public void createUserInfoExtra(Long uid) throws UserInfoExtraException {

      UserInfoExtra userInfoExtra = userInfoExtraMapper.getInfoExtraByUid(uid);

      if (userInfoExtra != null) {

         return;

      } 
		
      }



      userInfoExtra = new UserInfoExtra();

      userInfoExtra.setUserInfo(new UserInfo(uid));

      userInfoExtra.setFirstLoginTime(new Date());

      userInfoExtra.setCreateTime(new Date());

      userInfoExtra.setUpdateTime(new Date());

      userInfoExtra.setActiveTime(new Date());

      userInfoExtraMapper.insertSelective(userInfoExtra);

   }

	
	


   @Override

   public UserInfoExtra updateRank(UserInfoExtra userInfoExtra) throws UserInfoExtraException {

      UserInfo userInfo = userInfoExtra.getUserInfo();

      if (userInfo == null ) {

      if (userInfo == null) {

         throw new UserInfoExtraException(1, "用户不存在");

      }

		


      Long uid = userInfo.getId();

      if (uid == null ) {

      if (uid == null) {

         throw new UserInfoExtraException(1, "用户ID不存在");

      }		
				
      }



      List<UserRank> listRank = userRankService.getAllRank();

      if (listRank == null || listRank.size() == 0) {

         throw new UserInfoExtraException(1, "系统等级不存在");

@@ -258,7 +262,6 @@
            userInfoExtra.setRankSource(Constant.TYPE_REBATE);

         }



			
         if (rank != null) {

            userInfoExtra.setUserRank(rank);

         } else {

@@ -270,21 +273,21 @@
            break;

         }

      }

		


      // 等级更新时间 当月1号

      Calendar calendar1=Calendar.getInstance();

        calendar1.set(Calendar.DAY_OF_MONTH, 1);

      Calendar calendar1 = Calendar.getInstance();

      calendar1.set(Calendar.DAY_OF_MONTH, 1);

      userInfoExtra.setRankUpdateTime(calendar1.getTime());

		


      // 保存信息并返回

      saveUserInfoExtra(userInfoExtra);

		


      UserRankRecord userRankRecord = new UserRankRecord();

      userRankRecord.setUid(uid);

      userRankRecord.setRankId(rank.getId());

      userRankRecord.setCreateTime(new Date());

      userRankRecordMapper.insertSelective(userRankRecord);

		


      return userInfoExtra;

   }



@@ -320,19 +323,19 @@
      }

      return userInfoExtra;

   }

	


   @Override

   public String activateInviteCode(Long uid, String inviteCode, String platform, String version) throws UserInfoExtraException{

   public String activateInviteCode(Long uid, String inviteCode) throws UserInfoExtraException {

      if (uid == null || inviteCode == null) {

         throw new UserInfoExtraException(1, "用户id、邀请码不能为空");

      }

		


      // 被邀请人信息

      UserInfo invitee = userInfoService.selectByPKey(uid);

      if (invitee == null) {

         throw new UserInfoExtraException(1, "用户不存在");

      }

		


      UserInfoExtra extra = userInfoExtraMapper.getInfoExtraByUid(uid);

      if (extra != null) {

         String inviteCodeHas = extra.getInviteCode();

@@ -340,16 +343,16 @@
            throw new UserInfoExtraException(1, "已存在邀请码,请刷新页面");

         }

      }

		


      // 邀请人信息

      UserInfo inviter = userInfoService.getInfoByPhoneOrInviteCode(inviteCode, inviteCode);

      if (inviter == null) {

         throw new UserInfoExtraException(1, "上级邀请码不存在");

      }

		


      // 绑定关系

      try {

         threeSaleSerivce.bindRelationshipByInviteCode(invitee, inviter, platform, version);

         threeSaleSerivce.bindRelationshipByInviteCode(invitee, inviter);

      } catch (ThreeSaleException e) {

         try {

            LogHelper.errorDetailInfo(e);

@@ -358,43 +361,40 @@
         }

         throw new UserInfoExtraException(1, "激活失败");

      }

		
		


      // 邀请码有效、生成邀请码

      String code = UserUtil.getInviteCode(uid); 
      String code = UserUtil.getInviteCode(uid);

      if (code == null || code.trim().length() == 0) {

         throw new UserInfoExtraException(1, "激活码生成失败");

      }

		


      UserInfoExtra userInfoExtra = new UserInfoExtra();

      userInfoExtra.setUserInfo(invitee);

      userInfoExtra.setInviteCode(code);

		


      // 保存额外信息

      saveUserInfoExtra(userInfoExtra);

		
		


      Long id = userInfoExtra.getId();

      if (id == null) {

         throw new UserInfoExtraException(1, "激活码生成失败");

      }

		


      return code;

   }

	
	


   @Override

   public void activationInviteWX(Long uid, String code, String platform, String version) throws UserInfoExtraException{

   public void activationInviteWX(WXAccountInfoDTO wxAccount, Long uid, String code) throws UserInfoExtraException {

      if (uid == null || code == null) {

         throw new UserInfoExtraException(1, "激活信息不完整");

      }

		


      // 用户信息

      UserInfo invitee = userInfoService.selectByPKey(uid);

      if (invitee == null) {

         throw new UserInfoExtraException(1, "用户不存在");

      }

		


      // 用户额外信息

      UserInfoExtra extra = userInfoExtraMapper.getInfoExtraByUid(uid);

      if (extra != null) {

@@ -403,9 +403,9 @@
            throw new UserInfoExtraException(1, "已经激活, 无需再次激活");

         }

      }

		


      // 获取微信信息

      WeiXinUser weiXinUser = WXLoginUtil.getWeiXinUser(code);

      WeiXinUser weiXinUser = WXLoginUtil.getWeiXinUser(code, wxAccount.getAppId(), wxAccount.getAppSecret());

      if (weiXinUser == null) {

         throw new UserInfoExtraException(1, "微信授权失败");

      }

@@ -413,7 +413,7 @@
      if (wxUnionId == null || wxUnionId.trim().length() == 0) {

         throw new UserInfoExtraException(1, "微信授权失败");

      }

		


      // 验证数据

      String wxUnionIdExist = invitee.getWxUnionId();

      if (StringUtil.isNullOrEmpty(wxUnionIdExist)) {

@@ -421,35 +421,59 @@
         if (newUser != null) {

            throw new UserInfoExtraException(1, "此微信已被其他帐号绑定");

         }

			


         // 自动绑定微信

         UserInfo updateUserInfo = new UserInfo(uid);

         updateUserInfo.setWxOpenId(weiXinUser.getOpenid());

         updateUserInfo.setWxUnionId(weiXinUser.getUnionid());

         if (!StringUtil.isNullOrEmpty(weiXinUser.getNickname())) {

            updateUserInfo.setWxName(weiXinUser.getNickname());

            updateUserInfo.setNickName(weiXinUser.getNickname());

         updateUserInfo.setWxName(weiXinUser.getNickname());

         updateUserInfo.setWxPic(weiXinUser.getHeadimgurl());



         // 将默认昵称替换成微信昵称

         String defaultNickName = Constant.systemCommonConfig.getDefaultNickName();

         if (!StringUtil.isNullOrEmpty(defaultNickName) && !StringUtil.isNullOrEmpty(weiXinUser.getNickname())) {

            defaultNickName = defaultNickName + uid;

            if ((defaultNickName.equals(invitee.getNickName()) || "返利券".equals(invitee.getNickName())

                  || invitee.getNickName().startsWith(Constant.systemCommonConfig.getDefaultNickName()))) {

               updateUserInfo.setNickName(weiXinUser.getNickname());

            }

         }

         if (!StringUtil.isNullOrEmpty(weiXinUser.getHeadimgurl())) {

            updateUserInfo.setWxPic(weiXinUser.getHeadimgurl());

            updateUserInfo.setPortrait(weiXinUser.getHeadimgurl());



         // 将默认头像替换成微信头像

         String defaultPortrait = Constant.systemCommonConfig.getDefaultPortrait();

         if (!StringUtil.isNullOrEmpty(weiXinUser.getHeadimgurl()) && !StringUtil.isNullOrEmpty(defaultPortrait)

               && defaultPortrait.equals(invitee.getPortrait())) {

            String headimgurl = weiXinUser.getHeadimgurl();

            InputStream asInputStream = HttpUtil.getAsInputStream(headimgurl);

            if (asInputStream == null) {

               LogHelper.test("微信头像下载失败: " + weiXinUser.getUnionid() + " " + headimgurl);

            } else {

               FileUploadResult result = COSManager.getInstance().uploadFile(asInputStream, String.format(

                     "/portrait/wx/%s_%s.jpg", weiXinUser.getUnionid(), System.currentTimeMillis() + ""));

               if (result != null && !StringUtil.isNullOrEmpty(result.getUrl())) {

                  headimgurl = result.getUrl();

               } else {

                  LogHelper.test("微信头像上传失败: " + weiXinUser.getUnionid() + " " + headimgurl);

               }

            }

            updateUserInfo.setPortrait(headimgurl);

         }



         userInfoService.updateByPrimaryKeySelective(updateUserInfo);

			
      } else if (!wxUnionId.equals(wxUnionIdExist)){



      } else if (!wxUnionId.equals(wxUnionIdExist)) {

         throw new UserInfoExtraException(1, "绑定微信与激活微信不一致");

      }

		
		


      // 邀请人ID -1.5.3新版

      Long inviterId = userInviteRecordService.getNewestInviterId(wxUnionId);

		


      // 兼容1.5.3 之前版本

      ThreeSale threeSale = threeSaleSerivce.getByWorkerId(uid);

      if (inviterId == null && threeSale != null) {

         Long bossId = threeSale.getBoss().getId();

         UserInfoExtra inviterExtra = userInfoExtraMapper.getInfoExtraByUid(bossId);

         if (inviterExtra != null && inviterExtra.getInviteCode() == null ) {

         if (inviterExtra != null && inviterExtra.getInviteCode() == null) {

            // 更新邀请码

            UserInfoExtra inviterInfoExtra = new UserInfoExtra();

            inviterInfoExtra.setId(inviterExtra.getId());

@@ -457,15 +481,15 @@
            userInfoExtraMapper.updateByPrimaryKeySelective(inviterInfoExtra);

         }

      }

		


      // 没有被邀请过

      if (inviterId == null && threeSale == null) {

         throw new UserInfoExtraException(1, "没有对应的邀请关系");

      }

		


      // 绑定关系

      try {

         threeSaleSerivce.bindRelationshipByWX(invitee, inviterId, threeSale, platform, version);

         threeSaleSerivce.bindRelationshipByWX(invitee, inviterId, threeSale);

      } catch (ThreeSaleException e) {

         try {

            LogHelper.errorDetailInfo(e);

@@ -474,10 +498,9 @@
         }

         throw new UserInfoExtraException(1, "关系绑定时失败");

      }

		
		


      // 邀请码有效、生成邀请码

      String inviteCode = UserUtil.getInviteCode(uid); 
      String inviteCode = UserUtil.getInviteCode(uid);

      if (inviteCode == null || inviteCode.trim().length() == 0) {

         throw new UserInfoExtraException(1, "激活码生成失败");

      }

@@ -494,41 +517,192 @@
         userInfoExtraMapper.insertSelective(userInfoExtra);

      }

   }

	
	


   @Override

   public void activeInviteWX(Long uid, WeiXinUser weiXinUser) throws UserInfoExtraException {

      if (uid == null || weiXinUser == null) {

         throw new UserInfoExtraException(1, "激活信息不完整");

      }



      // 用户信息

      UserInfo invitee = userInfoService.selectByPKey(uid);

      if (invitee == null) {

         throw new UserInfoExtraException(1, "用户不存在");

      }



      // 用户额外信息

      UserInfoExtra extra = userInfoExtraMapper.getInfoExtraByUid(uid);

      if (extra != null) {

         String inviteCodeHas = extra.getInviteCode();

         if (inviteCodeHas != null && inviteCodeHas.trim().length() > 0) {

            throw new UserInfoExtraException(1, "已经激活, 无需再次激活");

         }

      }



      String wxUnionId = weiXinUser.getUnionid();

      if (wxUnionId == null || wxUnionId.trim().length() == 0) {

         throw new UserInfoExtraException(1, "微信授权失败");

      }



      // 验证数据

      String wxUnionIdExist = invitee.getWxUnionId();

      if (StringUtil.isNullOrEmpty(wxUnionIdExist)) {

         UserInfo newUser = userInfoService.getEffectiveUserInfoByWXUnionId(weiXinUser.getUnionid());

         if (newUser != null) {

            throw new UserInfoExtraException(1, "此微信已被其他帐号绑定");

         }



         // 自动绑定微信

         UserInfo updateUserInfo = new UserInfo(uid);

         updateUserInfo.setWxOpenId(weiXinUser.getOpenid());

         updateUserInfo.setWxUnionId(weiXinUser.getUnionid());

         updateUserInfo.setWxName(weiXinUser.getNickname());

         updateUserInfo.setWxPic(weiXinUser.getHeadimgurl());



         // 将默认昵称替换成微信昵称

         String defaultNickName = Constant.systemCommonConfig.getDefaultNickName();

         if (!StringUtil.isNullOrEmpty(defaultNickName) && !StringUtil.isNullOrEmpty(weiXinUser.getNickname())) {

            defaultNickName = defaultNickName + uid;

            if ((defaultNickName.equals(invitee.getNickName()) || "返利券".equals(invitee.getNickName())

                  || invitee.getNickName().startsWith(Constant.systemCommonConfig.getDefaultNickName()))) {

               updateUserInfo.setNickName(weiXinUser.getNickname());

            }

         }



         // 将默认头像替换成微信头像

         String defaultPortrait = Constant.systemCommonConfig.getDefaultPortrait();

         if (!StringUtil.isNullOrEmpty(weiXinUser.getHeadimgurl()) && !StringUtil.isNullOrEmpty(defaultPortrait)

               && defaultPortrait.equals(invitee.getPortrait())) {

            String headimgurl = weiXinUser.getHeadimgurl();

            InputStream asInputStream = HttpUtil.getAsInputStream(headimgurl);

            if (asInputStream == null) {

               LogHelper.test("微信头像下载失败: " + weiXinUser.getUnionid() + " " + headimgurl);

            } else {

               FileUploadResult result = COSManager.getInstance().uploadFile(asInputStream, String.format(

                     "/portrait/wx/%s_%s.jpg", weiXinUser.getUnionid(), System.currentTimeMillis() + ""));

               if (result != null && !StringUtil.isNullOrEmpty(result.getUrl())) {

                  headimgurl = result.getUrl();

               } else {

                  LogHelper.test("微信头像上传失败: " + weiXinUser.getUnionid() + " " + headimgurl);

               }

            }

            updateUserInfo.setPortrait(headimgurl);

         }



         userInfoService.updateByPrimaryKeySelective(updateUserInfo);



      } else if (!wxUnionId.equals(wxUnionIdExist)) {

         throw new UserInfoExtraException(1, "绑定微信与激活微信不一致");

      }



      // 邀请人ID -1.5.3新版

      Long inviterId = userInviteRecordService.getNewestInviterId(wxUnionId);



      // 兼容1.5.3 之前版本

      ThreeSale threeSale = threeSaleSerivce.getByWorkerId(uid);

      if (inviterId == null && threeSale != null) {

         Long bossId = threeSale.getBoss().getId();

         UserInfoExtra inviterExtra = userInfoExtraMapper.getInfoExtraByUid(bossId);

         if (inviterExtra != null && inviterExtra.getInviteCode() == null) {

            // 更新邀请码

            UserInfoExtra inviterInfoExtra = new UserInfoExtra();

            inviterInfoExtra.setId(inviterExtra.getId());

            inviterInfoExtra.setInviteCode(UserUtil.getInviteCode(bossId));

            userInfoExtraMapper.updateByPrimaryKeySelective(inviterInfoExtra);

         }

      }



      // 没有被邀请过

      if (inviterId == null && threeSale == null) {

         throw new UserInfoExtraException(1, "没有对应的邀请关系");

      }



      // 绑定关系

      try {

         threeSaleSerivce.bindRelationshipByWX(invitee, inviterId, threeSale);

      } catch (ThreeSaleException e) {

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

            e1.printStackTrace();

         }

         throw new UserInfoExtraException(1, "关系绑定时失败");

      }



      // 邀请码有效、生成邀请码

      String inviteCode = UserUtil.getInviteCode(uid);

      if (inviteCode == null || inviteCode.trim().length() == 0) {

         throw new UserInfoExtraException(1, "激活码生成失败");

      }

      // 保存邀请码

      UserInfoExtra userInfoExtra = new UserInfoExtra();

      userInfoExtra.setUserInfo(invitee);

      userInfoExtra.setInviteCode(inviteCode);

      userInfoExtra.setUpdateTime(new Date());

      if (extra != null) {

         userInfoExtra.setId(extra.getId());

         userInfoExtraMapper.updateByPrimaryKeySelective(userInfoExtra);

      } else {

         userInfoExtra.setCreateTime(new Date());

         userInfoExtraMapper.insertSelective(userInfoExtra);

      }

   }



   @Override

   public void updateActiveTime(Long uid, Date date) {

      UserInfoExtra userInfoExtra = new UserInfoExtra();

      userInfoExtra.setUserInfo(new UserInfo(uid));

      userInfoExtra.setActiveTime(date);

      userInfoExtraMapper.updateInfoExtraByUid(userInfoExtra);

   }



   @Override

   public UserInfoExtra getUserInfoExtra(Long uid) {

      return userInfoExtraMapper.getInfoExtraByUid(uid);

   }

	


   @Override

   public UserInfoExtra getUserALLInfo(Long uid) {

      return userInfoExtraMapper.gerUserRank(uid);

   }



   @Override

   public UserInfoExtra getByUidForUpdate(Long uid) {

      return userInfoExtraMapper.getByUidForUpdate(uid);

   }



   @Override

   public void updateGoldCoin(Long id, Integer goldCoin) {

      userInfoExtraMapper.updateGoldCoin(id, goldCoin);

   }



   @Override

   public UserInfoExtraVO getInfoExtraVOByUid(Long uid) {

      return userInfoExtraMapper.getInfoExtraVOByUid(uid);

   }

	
	


   @Override

   public String getUserInviteCode(Long uid) throws UserInfoExtraException {

		


      UserInfoExtra userInfoExtra = userInfoExtraMapper.getInfoExtraByUid(uid);

      if (userInfoExtra == null) {

         userInfoExtra = new UserInfoExtra();

      }

		


      // 邀请码

      String inviteCode = userInfoExtra.getInviteCode();

		


      if (inviteCode == null || inviteCode.trim().length() == 0) {

         // 判断用户

         int relationshipNum = threeSaleSerivce.getSuccessRelationshipNum(uid);

			


         if (relationshipNum > 0) {

            // 邀请码有效、生成邀请码

            inviteCode = UserUtil.getInviteCode(uid); 
            inviteCode = UserUtil.getInviteCode(uid);

            if (inviteCode == null || inviteCode.trim().length() == 0) {

               throw new UserInfoExtraException(1, "激活码生成失败");

            }

				


            // 保存邀请码

            userInfoExtra.setUserInfo(new UserInfo(uid));

            userInfoExtra.setInviteCode(inviteCode);

@@ -536,22 +710,22 @@
            saveUserInfoExtra(userInfoExtra);

         }

      }

		


      return inviteCode;

   }

	


   @Override

   public long countByRankId(Long rankId) {

      return userInfoExtraMapper.countByRankId(rankId);

   }

	


   @Override

   public boolean isNewUser(Long uid) {

      boolean isNew = false;

      if (uid == null) {

         return isNew;

      }

		


      UserInfoExtra extra = userInfoExtraMapper.getInfoExtraByUid(uid);

      if (extra != null && extra.getFirstLoginTime() != null) {

         try {

@@ -565,20 +739,119 @@
      }

      return isNew;

   }

	
	


   @Override

   public UserRank gerUserRank(Long uid) {

      if(uid == null) {

      if (uid == null) {

         return null;

      }

		


      UserInfoExtra userInfoExtra = userInfoExtraMapper.gerUserRank(uid);

      if (userInfoExtra == null) {

         return null;

      }

      return userInfoExtra.getUserRank();

   }

	
	


   @Override

   public UserInfo getUserByInviteCode(String inviteCode) throws UserInfoExtraException {

      if (StringUtil.isNullOrEmpty(inviteCode)) {

         throw new UserInfoExtraException(1, "邀请码不能为空");

      }

      // 邀请人信息

      UserInfo inviter = userInfoService.getInfoByPhoneOrInviteCode(inviteCode, inviteCode);

      if (inviter == null) {

         throw new UserInfoExtraException(1, "上级邀请码不存在");

      }

      return inviter;

   }



   @Override

   public UserInfo getInviterInfo(Long uid, String wxUnionId) throws UserInfoExtraException {

      if (wxUnionId == null) {

         throw new UserInfoExtraException(1, "unionId信息不完整");

      }



      // 用户信息

      UserInfo invitee = userInfoService.selectByPKey(uid);

      if (invitee == null) {

         throw new UserInfoExtraException(1, "用户不存在");

      }



      // 用户额外信息

      UserInfoExtra extra = userInfoExtraMapper.getInfoExtraByUid(uid);

      if (extra != null) {

         String inviteCodeHas = extra.getInviteCode();

         if (inviteCodeHas != null && inviteCodeHas.trim().length() > 0) {

            throw new UserInfoExtraException(1, "已经激活, 无需再次激活");

         }

      }



      // 验证数据

      String wxUnionIdExist = invitee.getWxUnionId();

      if (StringUtil.isNullOrEmpty(wxUnionIdExist)) {

         UserInfo newUser = userInfoService.getEffectiveUserInfoByWXUnionId(wxUnionId);

         if (newUser != null) {

            throw new UserInfoExtraException(1, "此微信已被其他帐号绑定");

         }

      } else if (!wxUnionId.equals(wxUnionIdExist)) {

         throw new UserInfoExtraException(1, "绑定微信与激活微信不一致");

      }



      // 邀请人ID

      Long inviterId = userInviteRecordService.getNewestInviterId(wxUnionId);

      if (inviterId == null) {

         throw new UserInfoExtraException(1, "没有对应的邀请关系");

      }



      UserInfo inviter = userInfoService.selectByPKey(inviterId);

      if (inviter == null) {

         throw new UserInfoExtraException(1, "对应的邀请关系不存在");

      }

      return inviter;

   }



   @Override

   public void updateAutoExtract(Integer days) {

      userInfoExtraMapper.updateAutoExtract(days);

   }



   @Transactional

   @Override

   public void updateInviteCode(String inviteCode, Long uid) throws UserInfoExtraException {

      if (inviteCode.length() >= 6 && inviteCode.length() <= 12) {

         UserInfoExtra extra = getUserInfoExtra(uid);

         if (extra == null) {

            throw new UserInfoExtraException(2, "用户信息不存在");

         }



         if (StringUtil.isNullOrEmpty(extra.getInviteCode())) {

            throw new UserInfoExtraException(3, "邀请码尚未激活");

         }



         if (extra.getInviteCodeState() == null

               || extra.getInviteCodeState() != UserInfoExtra.INVITE_CODE_SATTE_VALID_NO_UPDATE) {

            throw new UserInfoExtraException(4, "只能修改一次");

         }



         if (inviteCode.equalsIgnoreCase(extra.getInviteCode())) {

            throw new UserInfoExtraException(5, "不能为原邀请码");

         }

         UserInfoExtra update = new UserInfoExtra();

         update.setId(extra.getId());



         extra = userInfoExtraMapper.selectByInviteCode(inviteCode);

         if (extra != null) {

            throw new UserInfoExtraException(6, "邀请码已存在");

         }



         update.setInviteCode(inviteCode);

         update.setInviteCodeState(UserInfoExtra.INVITE_CODE_SATTE_VALID_UPDATED);

         update.setUpdateTime(new Date());

         userInfoExtraMapper.updateByPrimaryKeySelective(update);

      } else {

         throw new UserInfoExtraException(1, "邀请码必须为6到12位");

      }



   }

}