券推送插入

yujian

2019-04-22 b6c37e4bc38db88a360d0f2c6099183f9bb75bdc

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

@@ -4,102 +4,110 @@
import java.io.FileWriter;

import java.io.IOException;

import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;



import javax.annotation.Resource;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpSession;



import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.tencentcloud.COSManager;



import com.google.gson.Gson;

import com.qcloud.cos.model.COSObjectSummary;

import com.qcloud.cos.model.ObjectListing;

import com.yeshi.fanli.dao.mybatis.AccountDetailsMapper;

import com.yeshi.fanli.dao.mybatis.AccountMessageMapper;

import com.yeshi.fanli.dao.mybatis.BindingAccountMapper;

import com.yeshi.fanli.dao.mybatis.MoneyRecordMapper;

import com.yeshi.fanli.dao.mybatis.PidOrderMapper;

import com.yeshi.fanli.dao.mybatis.ThreeSaleMapper;

import com.yeshi.fanli.dao.mybatis.UserConnectHistoryMapper;

import com.yeshi.fanli.dao.mybatis.UserInfoMapper;

import com.yeshi.fanli.dao.mybatis.hongbao.HongBaoMapper;

import com.yeshi.fanli.dao.mybatis.order.OrderItemMapper;

import com.yeshi.fanli.dao.mybatis.order.OrderMapper;

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

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

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

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

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

import com.yeshi.fanli.entity.bus.user.ForbiddenUserIdentifyCode.ForbiddenUserIdentifyCodeTypeEnum;

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

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

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

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

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

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

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

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

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

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

import com.yeshi.fanli.entity.taobao.PidOrder;

import com.yeshi.fanli.exception.UserAccountException;

import com.yeshi.fanli.log.LogHelper;

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

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

import com.yeshi.fanli.service.inter.msg.UserAccountMsgNotificationService;

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

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

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

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

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

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

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

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.FileUtil;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.factory.AccountDetailsFactory;

import com.yeshi.fanli.util.factory.msg.MsgAccountDetailFactory;

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

import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.tencentcloud.COSManager;



import net.sf.json.JSONObject;



@Service

public class UserAccountServiceImpl implements UserAccountService {



   @Resource

   private RedisManager redisManager;



   @Resource

   private UserInfoMapper userInfoMapper;



   @Resource

   private BindingAccountMapper bindingAccountMapper;

   private BindingAccountService bindingAccountService;



   @Resource

   private UserConnectHistoryMapper userConnectHistoryMapper;



   @Resource

   private AccountDetailsMapper accountDetailsMapper;



   @Resource

   private HongBaoMapper hongBaoMapper;



   @Resource

   private OrderMapper orderMapper;



   @Resource

   private OrderItemMapper orderItemMapper;



   @Resource

   private ThreeSaleMapper threeSaleMapper;



   @Resource

   private PidOrderMapper pidOrderMapper;



   @Resource

   private HongBaoService hongBaoService;

   private ThreeSaleSerivce threeSaleSerivce;



   @Resource

   private AccountMessageMapper accountMessageMapper;

   @Resource

   private MoneyRecordMapper moneyRecordMapper;



   @Resource

   private SpreadUserImgService spreadUserImgService;



   @Resource

   private UserAccountMsgNotificationService userAccountMsgNotificationService;



   @Resource

   private UserExtraTaoBaoInfoService userExtraTaoBaoInfoService;



   @Resource

   private ForbiddenUserIdentifyCodeService forbiddenUserIdentifyCodeService;



   @Resource

   private UserInfoExtraService userInfoExtraService;



   @Resource

   private UserAccountBindingHistoryService userAccountBindingHistoryService;



   @Transactional

   @Override

   public LoginResult login(HttpSession session, Boolean first, String appId, String code, String phone,

   public LoginResult login(HttpServletRequest request, Boolean first, String appId, String code, String phone,

         UserInfo tbUserInfo, boolean wxinstall, int loginType) throws UserAccountException {



      JSONObject logInfo = new JSONObject();

      logInfo.put("appId", appId);

      logInfo.put("code", code);

      logInfo.put("phone", phone);

      if (tbUserInfo != null)

         logInfo.put("tbUserInfo", tbUserInfo.getId());

      logInfo.put("loginType", loginType);

      LogHelper.lgoinInfo(logInfo.toString());



      HttpSession session = request.getSession();

      if (first != null && first == true)

         session.removeAttribute("LAST_LOGIN_USER");

      // 会话中上次登录的用户

@@ -109,7 +117,20 @@
         WeiXinUser weiXinUser = null;

         switch (loginType) {

         case 1:// 淘宝

               // 判断淘宝是否被封禁

            if (!StringUtil.isNullOrEmpty(tbUserInfo.getTaoBaoUid())) {

               ForbiddenUserIdentifyCode identifyCode = forbiddenUserIdentifyCodeService.listByTypeAndIdentifyCode(

                     ForbiddenUserIdentifyCodeTypeEnum.taobaoUid, tbUserInfo.getTaoBaoUid());

               if (identifyCode != null && identifyCode.getEffective() != null && identifyCode.getEffective())

                  throw new UserAccountException(Constant.CODE_FORBIDDEN_USER,

                        Constant.FORBIDDEN_USER_REASON_DESC);

            }

            userInfo = getUserInfoByTaoBaoOpenId(appId, tbUserInfo.getOpenid());

            // 判断用户是否被删除

            if (userInfo != null && userInfo.getState() != null

                  && (userInfo.getState() == UserInfo.STATE_DELETE_OUT_OF_DATE

                        || userInfo.getState() == UserInfo.STATE_DELETE))

               userInfo = null;

            if (userInfo == null) {// 原先的账号不存在

               userInfo = new UserInfo();

               userInfo.setAppId(appId);

@@ -141,12 +162,23 @@
            if (weiXinUser == null)

               throw new UserAccountException(1001, "无法获取到微信个人信息");

            LogHelper.test("微信授权用户信息：" + new Gson().toJson(weiXinUser));

            // 判断微信unionid是否被封禁

            ForbiddenUserIdentifyCode identifyCode = forbiddenUserIdentifyCodeService.listByTypeAndIdentifyCode(

                  ForbiddenUserIdentifyCodeTypeEnum.wxUnionId, weiXinUser.getUnionid());

            if (identifyCode != null && identifyCode.getEffective() != null && identifyCode.getEffective())

               throw new UserAccountException(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC);



            userInfo = getUserInfoByWXUnionId(appId, weiXinUser.getUnionid());

            // 判断用户是否被删除

            if (userInfo != null && userInfo.getState() != null

                  && (userInfo.getState() == UserInfo.STATE_DELETE_OUT_OF_DATE

                        || userInfo.getState() == UserInfo.STATE_DELETE))

               userInfo = null;

            // 直接用的微信登录

            if (lastUser == null) {

               if (userInfo != null) {

                  // 使分销关系生效

                  threeSaleMapper.effectThreeSale(userInfo.getId());

                  threeSaleSerivce.effective(userInfo);

                  // 更新头像与昵称

                  UserInfo updateUserInfo = new UserInfo(userInfo.getId());

                  updateUserInfo.setNickName(weiXinUser.getNickname());

@@ -154,6 +186,11 @@
                     updateUserInfo.setPortrait(weiXinUser.getHeadimgurl());

                  updateUserInfo.setWxPic(weiXinUser.getHeadimgurl());

                  updateUserInfo.setWxName(weiXinUser.getNickname());

                  // 设置登录时间与登录类型

                  updateUserInfo.setLastLoginTime(System.currentTimeMillis());

                  updateUserInfo.setLoginType(loginType);

                  updateUserInfo.setLastLoginIp(request.getRemoteHost());



                  userInfoMapper.updateByPrimaryKeySelective(updateUserInfo);

                  // 删除邀请图片

                  spreadUserImgService.deleteImgUrl(userInfo.getId());

@@ -167,6 +204,9 @@
               userInfo.setWxOpenId(weiXinUser.getOpenid());

               userInfo.setWxUnionId(weiXinUser.getUnionid());

               userInfo.setWxPic(weiXinUser.getHeadimgurl());

               userInfo.setLastLoginTime(System.currentTimeMillis());

               userInfo.setLoginType(loginType);

               userInfo.setLastLoginIp(request.getRemoteHost());

               addUser(userInfo);



               return new LoginResult(LoginResult.TYPE_NORMAL, userInfo);

@@ -197,20 +237,24 @@
                     // 绑定关系

                     UserInfo updateUserInfo = new UserInfo(userInfo.getId());



                     if (!StringUtil.isNullOrEmpty(lastUser.getPhone()))

                     if (!StringUtil.isNullOrEmpty(lastUser.getPhone())) {

                        updateUserInfo.setPhone(lastUser.getPhone());



                        userAccountMsgNotificationService.bindingSuccess(userInfo.getId(),

                              MsgAccountDetailFactory.TYPE_PHONE);

                     }

                     if (!StringUtil.isNullOrEmpty(lastUser.getOpenid())) {

                        updateUserInfo.setOpenid(lastUser.getOpenid());

                        updateUserInfo.setTbName(lastUser.getTbName());

                        updateUserInfo.setTbPic(lastUser.getTbPic());

                        userAccountMsgNotificationService.bindingSuccess(userInfo.getId(),

                              MsgAccountDetailFactory.TYPE_TB);

                     }

                     updateUserInfo.setLastLoginTime(System.currentTimeMillis());

                     userInfoMapper.updateByPrimaryKeySelective(updateUserInfo);

                     session.removeAttribute("LAST_LOGIN_USER");



                     // 使分销关系生效

                     threeSaleMapper.effectThreeSale(userInfo.getId());

                     threeSaleSerivce.effective(userInfo);



                     return new LoginResult(LoginResult.TYPE_NORMAL, userInfo);

                  } else {// 两个账号拥有不同的UID

@@ -224,7 +268,7 @@
                     result.setLessUser(lastUser);



                     // 使分销关系生效

                     threeSaleMapper.effectThreeSale(userInfo.getId());

                     threeSaleSerivce.effective(userInfo);

                     return result;

                  }



@@ -247,13 +291,27 @@
                     userInfo.setTbPic(lastUser.getTbPic());

                  }

                  userInfo.setLastLoginTime(System.currentTimeMillis());

                  userInfo.setLoginType(loginType);

                  userInfo.setLastLoginIp(request.getRemoteHost());

                  addUser(userInfo);

                  session.removeAttribute("LAST_LOGIN_USER");

                  return new LoginResult(LoginResult.TYPE_NORMAL, userInfo);

               }

            }

         case 3:// 手机号码

               // 判断手机号码是否被封禁

            ForbiddenUserIdentifyCode identifyCode1 = forbiddenUserIdentifyCodeService

                  .listByTypeAndIdentifyCode(ForbiddenUserIdentifyCodeTypeEnum.phone, phone);

            if (identifyCode1 != null && identifyCode1.getEffective() != null && identifyCode1.getEffective())

               throw new UserAccountException(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC);



            userInfo = getUserInfoByPhone(appId, phone);

            // 判断用户是否被删除

            if (userInfo != null && userInfo.getState() != null

                  && (userInfo.getState() == UserInfo.STATE_DELETE_OUT_OF_DATE

                        || userInfo.getState() == UserInfo.STATE_DELETE))

               userInfo = null;



            if (userInfo == null) {// 原先的账号不存在

               userInfo = new UserInfo();

               userInfo.setAppId(appId);

@@ -292,10 +350,25 @@
   @Override

   public LoginResult loginNoInstallWX(String appId, String code, String phone, UserInfo tbUserInfo, int loginType)

         throws UserAccountException {

      JSONObject logInfo = new JSONObject();

      logInfo.put("appId", appId);

      logInfo.put("code", code);

      logInfo.put("phone", phone);

      if (tbUserInfo != null)

         logInfo.put("tbUserInfo", tbUserInfo.getId());

      logInfo.put("loginType", loginType);

      LogHelper.lgoinInfo(logInfo.toString());



      UserInfo userInfo = null;

      WeiXinUser weiXinUser = null;

      switch (loginType) {

      case 1:// 淘宝

         if (!StringUtil.isNullOrEmpty(tbUserInfo.getTaoBaoUid())) {

            ForbiddenUserIdentifyCode identifyCode = forbiddenUserIdentifyCodeService.listByTypeAndIdentifyCode(

                  ForbiddenUserIdentifyCodeTypeEnum.taobaoUid, tbUserInfo.getTaoBaoUid());

            if (identifyCode != null && identifyCode.getEffective() != null && identifyCode.getEffective())

               throw new UserAccountException(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC);

         }

         userInfo = getUserInfoByTaoBaoOpenId(appId, tbUserInfo.getOpenid());

         break;

      case 2:// 微信

@@ -303,12 +376,29 @@
         weiXinUser = WXLoginUtil.getWeiXinUserWithSavePortrait(code);

         if (weiXinUser == null)

            throw new UserAccountException(1001, "无法获取到微信个人信息");



         // 判断是否被封禁

         ForbiddenUserIdentifyCode identifyCode = forbiddenUserIdentifyCodeService

               .listByTypeAndIdentifyCode(ForbiddenUserIdentifyCodeTypeEnum.phone, phone);

         if (identifyCode != null && identifyCode.getEffective() != null && identifyCode.getEffective())

            throw new UserAccountException(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC);



         userInfo = getUserInfoByWXUnionId(appId, weiXinUser.getUnionid());

         break;

      case 3:// 手机号码

            // 判断是否被封禁

         ForbiddenUserIdentifyCode identifyCode1 = forbiddenUserIdentifyCodeService

               .listByTypeAndIdentifyCode(ForbiddenUserIdentifyCodeTypeEnum.phone, phone);

         if (identifyCode1 != null && identifyCode1.getEffective() != null && identifyCode1.getEffective())

            throw new UserAccountException(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC);

         userInfo = getUserInfoByPhone(appId, phone);

         break;

      }



      // 判断用户是否被删除

      if (userInfo != null && userInfo.getState() != null && (userInfo.getState() == UserInfo.STATE_DELETE_OUT_OF_DATE

            || userInfo.getState() == UserInfo.STATE_DELETE))

         userInfo = null;



      if (userInfo != null) {

         UserInfo updateUserInfo = new UserInfo(userInfo.getId());

@@ -389,32 +479,21 @@
      if (!StringUtil.isNullOrEmpty(mainUser.getPhone()) && !StringUtil.isNullOrEmpty(lessUser.getPhone()))

         throw new UserAccountException(9, "两个账号都绑定了手机号码，请解绑其中一个");



      if (lessUser.getMyHongBao().compareTo(new BigDecimal("20")) >= 0

            && mainUser.getMyHongBao().compareTo(new BigDecimal("20")) > 0)

         throw new UserAccountException(10, String.format("账户ID:%s 的资金超过20元，为保证资金安全请联系客服打通", lessUser.getId() + ""));

      if (lessUser.getMyHongBao().compareTo(new BigDecimal("10")) >= 0

            && mainUser.getMyHongBao().compareTo(new BigDecimal("10")) > 0)

         throw new UserAccountException(10, String.format("账户ID:%s 的资金超过10元，为保证资金安全请联系客服打通", lessUser.getId() + ""));



      // 判定是否绑定了同一支付宝

      List<BindingAccount> mainUserAccountList = bindingAccountMapper.selectByUid(mainUser.getId());

      if (mainUserAccountList != null)

         for (int i = 0; i < mainUserAccountList.size(); i++) {

            if (mainUserAccountList.get(i).getType() == BindingAccount.TYPE_WXPAY) {

               mainUserAccountList.remove(i);

               i--;

            }

         }

      List<BindingAccount> lessUserAccountList = bindingAccountMapper.selectByUid(lessUser.getId());

      if (lessUserAccountList != null)

         for (int i = 0; i < lessUserAccountList.size(); i++) {

            if (lessUserAccountList.get(i).getType() == BindingAccount.TYPE_WXPAY) {

               lessUserAccountList.remove(i);

               i--;

            }

         }

      BindingAccount mainUserAccount = bindingAccountService.getBindingAccountByUidAndType(mainUser.getId(),

            BindingAccount.TYPE_ALIPAY);



      BindingAccount lessUserAccount = bindingAccountService.getBindingAccountByUidAndType(lessUser.getId(),

            BindingAccount.TYPE_ALIPAY);



      // 有不同的支付宝账号

      boolean hasDiffrentAlipayAccount = false;

      if (mainUserAccountList != null && mainUserAccountList.size() > 0 && lessUserAccountList != null

            && lessUserAccountList.size() > 0) {

         if (!mainUserAccountList.get(0).getAccount().equalsIgnoreCase(lessUserAccountList.get(0).getAccount()))

      if (mainUserAccount != null && lessUserAccount != null) {

         if (!mainUserAccount.getAccount().equalsIgnoreCase(lessUserAccount.getAccount()))

            hasDiffrentAlipayAccount = true;

      }



@@ -454,51 +533,10 @@
      userInfoMapper.connectUser(mainUser.getId(), lessUser.getId());



      // 查询是否有多余的新人红包

      List<HongBao> list = hongBaoMapper.selectByUidAndType(mainUser.getId(), HongBao.TYPE_XINREN);

      int subCount = 0;

      int addCount = 0;

      for (HongBao hb : list) {

         if (hb.getMoney().compareTo(new BigDecimal(0)) > 0)

            addCount++;

         if (hb.getMoney().compareTo(new BigDecimal(0)) < 0)

            subCount++;

      }



      // 有2个或者2个以上的新人红包

      if (addCount - subCount > 1) {

         // 扣除一个新人红包

         AccountDetails accountDetails = new AccountDetails();

         accountDetails.setCreateTime(TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd HH:mm:ss"));

         accountDetails.setExtract(null);

         accountDetails.setMoney("-" + list.get(1).getMoney().toString());

         accountDetails.setOrderItem(null);

         accountDetails.setTitle(" 账号合并扣除重复新人红包");

         accountDetails.setType(AccountDetailsFactory.TUIKUAN);

         accountDetails.setUserInfo(mainUser);

         accountDetailsMapper.insertSelective(accountDetails);



         AccountMessage accountMessage = new AccountMessage();

         accountMessage.setContent(" 账号合并扣除重复新人红包" + list.get(1).getMoney().toString() + "元");

         accountMessage.setCreateTime(System.currentTimeMillis());

         accountMessage.setIsOpen(false);

         accountMessage.setSystemMsgId(0);

         accountMessage.setTitle(" 账号合并扣除重复新人红包");

         accountMessage.setUserInfo(mainUser);

         accountMessageMapper.insertSelective(accountMessage);



         userInfoMapper.subHongBaoByUid(mainUser.getId(), list.get(1).getMoney());



         HongBao hongBao = new HongBao(mainUser, new BigDecimal(0).subtract(list.get(1).getMoney()), null,

               HongBao.TYPE_XINREN, HongBao.STATE_YILINGQU, System.currentTimeMillis(), System.currentTimeMillis(),

               System.currentTimeMillis(), null, "账号合并扣除");



         hongBaoMapper.insertSelective(hongBao);



         MoneyRecord moneyRecord = new MoneyRecord(mainUser, hongBao, list.get(1).getMoney(), "账号合并扣除重复新人红包", "账号合并",

               System.currentTimeMillis(), 2);

         moneyRecordMapper.insertSelective(moneyRecord);

      }



      userAccountMsgNotificationService.connectSuccess(mainUser.getId(), lessUser.getId());

   }



   /**

@@ -508,8 +546,26 @@
    * @param unionId

    * @return

    */

   public UserInfo getUserInfoByWXUnionId(String appId, String unionId) {

      return userInfoMapper.getUserInfoByAppIdAndWXUnionId(appId, unionId);

   @Override

   public UserInfo getUserInfoByWXUnionId(String appId, String unionId) throws UserAccountException {

      if (StringUtil.isNullOrEmpty(appId))

         throw new UserAccountException(1, "appId为空");

      if (StringUtil.isNullOrEmpty(unionId))

         throw new UserAccountException(2, "unionId为空");



      List<UserInfo> list = userInfoMapper.listByAppIdAndWXUnionId(appId, unionId);

      // 剔除被删除掉的用户

      for (int i = 0; i < list.size(); i++) {

         if (list.get(i).getState() == UserInfo.STATE_DELETE

               || list.get(i).getState() == UserInfo.STATE_DELETE_OUT_OF_DATE) {

            list.remove(i);

            i--;

         }

      }

      if (list.size() > 0)

         return list.get(list.size() - 1);

      else

         return null;

   }



   /**

@@ -519,9 +575,26 @@
    * @param openId

    * @return

    */

   public UserInfo getUserInfoByTaoBaoOpenId(String appId, String openId) {

   public UserInfo getUserInfoByTaoBaoOpenId(String appId, String openId) throws UserAccountException {

      if (StringUtil.isNullOrEmpty(appId))

         throw new UserAccountException(1, "appId为空");

      if (StringUtil.isNullOrEmpty(openId))

         throw new UserAccountException(2, "openId为空");

      List<UserInfo> list = userInfoMapper.listByAppIdAndTaoBaoOpenId(appId, openId);



      return userInfoMapper.getUserInfoByAppIdAndTaoBaoOpenId(appId, openId);

      // 剔除被删除掉的用户

      for (int i = 0; i < list.size(); i++) {

         if (list.get(i).getState() == UserInfo.STATE_DELETE

               || list.get(i).getState() == UserInfo.STATE_DELETE_OUT_OF_DATE) {

            list.remove(i);

            i--;

         }

      }

      if (list.size() > 0)

         return list.get(list.size() - 1);

      else

         return null;



   }



   /**

@@ -531,9 +604,26 @@
    * @param phone

    * @return

    */

   public UserInfo getUserInfoByPhone(String appId, String phone) {

   public UserInfo getUserInfoByPhone(String appId, String phone) throws UserAccountException {

      if (StringUtil.isNullOrEmpty(appId))

         throw new UserAccountException(1, "appId为空");

      if (StringUtil.isNullOrEmpty(phone))

         throw new UserAccountException(2, "phone为空");

      List<UserInfo> list = userInfoMapper.listByAppIdAndPhone(appId, phone);



      return userInfoMapper.getUserInfoByAppIdAndPhone(appId, phone);

      // 剔除被删除掉的用户

      for (int i = 0; i < list.size(); i++) {

         if (list.get(i).getState() == UserInfo.STATE_DELETE

               || list.get(i).getState() == UserInfo.STATE_DELETE_OUT_OF_DATE) {

            list.remove(i);

            i--;

         }

      }

      if (list.size() > 0)

         return list.get(list.size() - 1);

      else

         return null;



   }



   private void updateLatestLoginTime(Long uid) {

@@ -587,9 +677,6 @@
         updateUserInfo.setNickName(Constant.systemCommonConfig.getDefaultNickName() + user.getId());

         userInfoMapper.updateByPrimaryKeySelective(updateUserInfo);

      }



      // 添加新人红包

      hongBaoService.setNewUserHongBaoMyBatis(user, 1);

   }



   @Override

@@ -613,6 +700,7 @@
      UserInfo update = new UserInfo(user.getId());

      update.setPhone(phone);

      userInfoMapper.updateByPrimaryKeySelective(update);

      userAccountMsgNotificationService.bindingSuccess(uid, MsgAccountDetailFactory.TYPE_PHONE);

   }



   @Override

@@ -633,6 +721,7 @@
      UserInfo updateUserInfo = new UserInfo(uid);

      updateUserInfo.setPhone("");

      userInfoMapper.updateByPrimaryKeySelective(updateUserInfo);

      userAccountMsgNotificationService.unBindingSuccess(uid, MsgAccountDetailFactory.TYPE_PHONE);

   }



   @Override

@@ -642,8 +731,12 @@
      if (user == null)

         throw new UserAccountException(4, "用户不存在");



      if (!StringUtil.isNullOrEmpty(user.getOpenid()))

      if (!StringUtil.isNullOrEmpty(user.getOpenid()) && !user.getOpenid().equalsIgnoreCase(tbOpenId))

         throw new UserAccountException(5, "当前账号已经绑定了淘宝，请先解绑");



      // 绑定同一个淘宝号

      if (!StringUtil.isNullOrEmpty(user.getOpenid()) && user.getOpenid().equalsIgnoreCase(tbOpenId))

         return;



      UserInfo taoBaoUser = getUserInfoByTaoBaoOpenId(user.getAppId(), tbOpenId);

      if (taoBaoUser != null)

@@ -658,6 +751,8 @@
         update.setPortrait(tbPortrait);

      }

      userInfoMapper.updateByPrimaryKeySelective(update);



      userAccountMsgNotificationService.bindingSuccess(uid, MsgAccountDetailFactory.TYPE_TB);

   }



   @Override

@@ -682,6 +777,10 @@
      }



      userInfoMapper.updateByPrimaryKeySelective(update);



      userExtraTaoBaoInfoService.unBindUid(uid);



      userAccountMsgNotificationService.unBindingSuccess(uid, MsgAccountDetailFactory.TYPE_TB);

   }



   @Override

@@ -714,6 +813,8 @@
         updateUserInfo.setPortrait(Constant.systemCommonConfig.getDefaultPortrait());

      }

      userInfoMapper.updateByPrimaryKeySelective(updateUserInfo);



      userAccountMsgNotificationService.changeBindingSuccess(uid, MsgAccountDetailFactory.TYPE_WX);

   }



   @Override

@@ -725,19 +826,10 @@
      // 备份用户信息

      UserInfo user = userInfoMapper.selectByPrimaryKey(uid);



      // 备份资金明细

      List<AccountDetails> accountDetailsList = accountDetailsMapper.selectByUid(uid);

      // 备份红包信息

      List<HongBao> hongBaoList = hongBaoMapper.selectByUid(uid);

      // 备份订单，子订单信息

      List<Order> orderList = orderMapper.selectByUid(uid);

      List<OrderItem> orderItemList = orderItemMapper.selectByUid(uid);

      // TODO 备份资金明细



      // 备份邀请关系

      List<ThreeSale> threeSaleList = threeSaleMapper.selectByUid(uid);



      // 备份分享赚

      List<PidOrder> pidOrderList = pidOrderMapper.selectByUid(uid);

      List<ThreeSale> threeSaleList = new ArrayList<>();



      FileWriter fw = null;

      try {

@@ -747,23 +839,8 @@
         fw.write("#UserInfo" + "\r\n");

         fw.write(JsonUtil.getSimpleGsonWithDate().toJson(user) + "\r\n");



         fw.write("#AccountDetails" + "\r\n");

         fw.write(JsonUtil.getSimpleGsonWithDate().toJson(accountDetailsList) + "\r\n");



         fw.write("#HongBao" + "\r\n");

         fw.write(JsonUtil.getSimpleGsonWithDate().toJson(hongBaoList) + "\r\n");



         fw.write("#Order" + "\r\n");

         fw.write(JsonUtil.getSimpleGsonWithDate().toJson(orderList) + "\r\n");



         fw.write("#OrderItem" + "\r\n");

         fw.write(JsonUtil.getSimpleGsonWithDate().toJson(orderItemList) + "\r\n");



         fw.write("#ThreeSale" + "\r\n");

         fw.write(JsonUtil.getSimpleGsonWithDate().toJson(threeSaleList) + "\r\n");



         fw.write("#PidOrder" + "\r\n");

         fw.write(JsonUtil.getSimpleGsonWithDate().toJson(pidOrderList) + "\r\n");



         fw.close();



@@ -828,4 +905,253 @@
      return user.getPortrait();

   }



   @Transactional

   @Override

   public UserInfo loginPhone(HttpServletRequest request, int loginType, String vcode, String phone, String appId)

         throws UserAccountException {



      // 空额清理

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

         throw new UserAccountException(1, "请输入手机号码");

      }

      phone = phone.replaceAll(" ", "");



      // 苹果应用商店上线测试号码

      if ("17316780233".equalsIgnoreCase(phone) && "258168".equalsIgnoreCase(vcode)) {

         ;

      } else {



         if (StringUtil.isNullOrEmpty(vcode)) {

            throw new UserAccountException(1, "请输入验证码");

         }



         String oldVcode = redisManager.getSMSVCode(phone, SMSHistory.TYPE_LOGIN);

         LogHelper.test("----------------------登录验证码： " + oldVcode);

         if (StringUtil.isNullOrEmpty(oldVcode) || !oldVcode.equalsIgnoreCase(vcode)) {

            throw new UserAccountException(1, "验证码错误，重新输入");

         }

      }



      JSONObject logInfo = new JSONObject();

      logInfo.put("appId", appId);

      logInfo.put("phone", phone);

      logInfo.put("loginType", loginType);

      LogHelper.lgoinInfo(logInfo.toString());



      // 判断手机号码是否被封禁

      ForbiddenUserIdentifyCode identifyCode1 = forbiddenUserIdentifyCodeService

            .listByTypeAndIdentifyCode(ForbiddenUserIdentifyCodeTypeEnum.phone, phone);

      if (identifyCode1 != null && identifyCode1.getEffective() != null && identifyCode1.getEffective()) {

         throw new UserAccountException(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC);

      }



      // 清空限制

      redisManager.clearSMSFrequencyLimit(phone, SMSHistory.TYPE_LOGIN);

      // 清理次数

      redisManager.removeCommonString("sendMSNLoginCount" + phone);



      // 查询是否存在该电话历史用户

      UserInfo userInfo = userInfoMapper.getEffectiveUserInfoByPhone(phone);

      if (userInfo != null) {

         // 更新账户登录信息

         updateLonginInfo(userInfo, loginType, request);

      } else {

         userInfo = new UserInfo();

         userInfo.setAppId(appId);

         userInfo.setNickName(Constant.systemCommonConfig.getDefaultNickName());

         userInfo.setPortrait(Constant.systemCommonConfig.getDefaultPortrait());

         userInfo.setPhone(phone);

         userInfo.setLoginType(loginType);

         userInfo.setState(UserInfo.STATE_NORMAL);

         // 创建用户

         addUser(userInfo);



         try {

            // 第一次登录时创建用户额外信息

            userInfoExtraService.createUserInfoExtra(userInfo.getId());

         } catch (Exception e) {

            e.printStackTrace();

         }

      }



      return userInfo;

   }



   @Transactional

   @Override

   public UserInfo loginWinXin(HttpServletRequest request, int loginType, String code, String appId)

         throws UserAccountException {

      // 日志信息

      JSONObject logInfo = new JSONObject();

      logInfo.put("appId", appId);

      logInfo.put("code", code);

      logInfo.put("loginType", loginType);

      LogHelper.lgoinInfo(logInfo.toString());



      // 通过Code换取信息

      WeiXinUser weiXinUser = WXLoginUtil.getWeiXinUserWithSavePortrait(code);

      if (weiXinUser == null) {

         throw new UserAccountException(1, "微信帐号授权失败");

      }

      LogHelper.test("微信授权用户信息：" + new Gson().toJson(weiXinUser));



      // 判断微信unionid是否被封禁

      ForbiddenUserIdentifyCode identifyCode = forbiddenUserIdentifyCodeService

            .listByTypeAndIdentifyCode(ForbiddenUserIdentifyCodeTypeEnum.wxUnionId, weiXinUser.getUnionid());

      if (identifyCode != null && identifyCode.getEffective() != null && identifyCode.getEffective()) {

         throw new UserAccountException(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC);

      }



      UserInfo userInfo = userInfoMapper.getEffectiveUserInfoByWXUnionId(weiXinUser.getUnionid());

      // 直接用的微信登录

      if (userInfo != null) {

         LogHelper.test("微信unionID存在:"+weiXinUser.getUnionid());

         // 更新账户登录信息

         updateLonginInfo(userInfo, loginType, request);

         // 删除邀请分享图

         spreadUserImgService.deleteImgUrl(userInfo.getId());

      } else {

         LogHelper.test("微信unionID不存在:"+weiXinUser.getUnionid());

         // 创建新账户

         userInfo = new UserInfo();

         userInfo.setPortrait(weiXinUser.getHeadimgurl());

         userInfo.setAppId(appId);

         userInfo.setNickName(weiXinUser.getNickname());

         userInfo.setWxName(weiXinUser.getNickname());

         userInfo.setWxOpenId(weiXinUser.getOpenid());

         userInfo.setWxUnionId(weiXinUser.getUnionid());

         userInfo.setWxPic(weiXinUser.getHeadimgurl());

         userInfo.setLastLoginTime(System.currentTimeMillis());

         userInfo.setLoginType(loginType);

         userInfo.setLastLoginIp(request.getRemoteHost());

         userInfo.setState(UserInfo.STATE_NORMAL);

         addUser(userInfo);



         try {

            // 第一次登录时创建用户额外信息

            userInfoExtraService.createUserInfoExtra(userInfo.getId());

         } catch (Exception e) {

            e.printStackTrace();

         }

      }

      return userInfo;

   }



   /**

    * 更新账户登录信息

    * 
    * @param userInfo

    * @param loginType

    * @param request

    */

   public void updateLonginInfo(UserInfo userInfo, int loginType, HttpServletRequest request) {

      // 设置登录时间与登录类型

      UserInfo updateUserInfo = new UserInfo(userInfo.getId());

      updateUserInfo.setLastLoginTime(System.currentTimeMillis());

      updateUserInfo.setLoginType(loginType);

      updateUserInfo.setLastLoginIp(request.getRemoteHost());

      userInfoMapper.updateByPrimaryKeySelective(updateUserInfo);

   }



   @Override

   public void bindPhoneNew(Long uid, String phone) throws UserAccountException {

      UserInfo user = userInfoMapper.selectByPrimaryKey(uid);

      if (user == null) {

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

      }



      String hasPhone = user.getPhone();

      if (!StringUtil.isNullOrEmpty(hasPhone) && hasPhone.equals(phone)) {

         throw new UserAccountException(2, "您已经绑定了该电话号码");

      }



      UserInfo phoneUser = userInfoMapper.getEffectiveUserInfoByPhone(phone);

      if (phoneUser != null) {

         throw new UserAccountException(2, "号码已经被占用");

      }



      // 更新电话号码

      UserInfo update = new UserInfo(user.getId());

      update.setPhone(phone);

      userInfoMapper.updateByPrimaryKeySelective(update);

      // 加入绑定记录

      UserAccountBindingHistory history = new UserAccountBindingHistory();

      history.setContent(phone);

      history.setType(UserAccountBindingHistory.TYPE_PHONE);

      history.setUid(uid);



      // 之前已经绑定电话号码

      if (!StringUtil.isNullOrEmpty(user.getPhone()))

         history.setFirst(false);

      else

         history.setFirst(true);

      userAccountBindingHistoryService.addUserAccountBindingHistory(history);



      // 发送消息

      userAccountMsgNotificationService.bindingSuccess(uid, MsgAccountDetailFactory.TYPE_PHONE);

   }



   @Override

   public void bindWeiXin(Long uid, String code) throws UserAccountException {

      UserInfo user = userInfoMapper.selectByPrimaryKey(uid);

      if (user == null) {

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

      }



      WeiXinUser weiXinUser = WXLoginUtil.getWeiXinUserWithSavePortrait(code);

      if (weiXinUser == null) {

         throw new UserAccountException(2, "微信帐号授权失败");

      }

		
      String wxUnionId = weiXinUser.getUnionid();

      if (StringUtil.isNullOrEmpty(wxUnionId)) {

         throw new UserAccountException(2, "微信帐号授权失败");

      }

		
      String wxUnionIdExist = user.getWxUnionId();

      if (StringUtil.isNullOrEmpty(wxUnionIdExist)) {

         UserInfo newUser = userInfoMapper.getEffectiveUserInfoByWXUnionId(wxUnionId);

         if (newUser != null) {

            throw new UserAccountException(4, "该微信号已被其他帐号绑定");

         }

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

         throw new UserAccountException(3, "微信帐号一致无需更换");

      }



      if (StringUtil.isNullOrEmpty(user.getPhone())) {

         throw new UserAccountException(5, "该帐号没有绑定手机号码，需绑定手机号码才能完成微信更换");

      }



      UserInfo updateUserInfo = new UserInfo(uid);

      updateUserInfo.setWxName(weiXinUser.getNickname());

      updateUserInfo.setWxOpenId(weiXinUser.getOpenid());

      updateUserInfo.setWxPic(weiXinUser.getHeadimgurl());

      updateUserInfo.setWxUnionId(weiXinUser.getUnionid());

      updateUserInfo.setNickName(weiXinUser.getNickname());

      updateUserInfo.setPortrait(weiXinUser.getHeadimgurl());

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

         updateUserInfo.setNickName(Constant.systemCommonConfig.getDefaultNickName());

      }



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

         updateUserInfo.setPortrait(Constant.systemCommonConfig.getDefaultPortrait());

      }

      userInfoMapper.updateByPrimaryKeySelective(updateUserInfo);



      // 加入绑定记录

      UserAccountBindingHistory history = new UserAccountBindingHistory();

      history.setContent(weiXinUser.getUnionid());

      history.setType(UserAccountBindingHistory.TYPE_WX);

      history.setUid(uid);



      // 之前已经绑定电话号码

      if (!StringUtil.isNullOrEmpty(user.getWxUnionId()))

         history.setFirst(false);

      else

         history.setFirst(true);

      userAccountBindingHistoryService.addUserAccountBindingHistory(history);



      userAccountMsgNotificationService.bindingSuccess(uid, MsgAccountDetailFactory.TYPE_WX);

   }



}