系统区分BUG修复

admin

2020-07-14 eec7e789a87863c25d92c10ad5dfc22ad80c448d

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

@@ -10,6 +10,8 @@


import javax.annotation.Resource;



import com.yeshi.fanli.entity.SystemEnum;

import com.yeshi.fanli.util.*;

import org.springframework.context.annotation.Lazy;

import org.springframework.core.task.TaskExecutor;

import org.springframework.stereotype.Service;

@@ -27,29 +29,23 @@
import com.yeshi.fanli.dao.mybatis.UserInfoMapper;

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

import com.yeshi.fanli.dao.mybatis.share.ShareMapper;

import com.yeshi.fanli.dto.user.UserInviteLevelEnum;

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

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

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

import com.yeshi.fanli.entity.bus.user.UserInfoModifyRecord.ModifyTypeEnum;

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

import com.yeshi.fanli.entity.system.BusinessSystem;

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

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

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.count.HongBaoV2CountService;

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

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

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

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

import com.yeshi.fanli.service.inter.user.integral.IntegralDetailService;

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

import com.yeshi.fanli.service.inter.user.tb.TaoBaoUnionAuthRecordService;

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

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.FilePathEnum;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.ThreadUtil;

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

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

import com.yeshi.fanli.util.user.UserLevelUtil;

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



import net.coobird.thumbnailator.Thumbnails;

@@ -57,604 +53,681 @@
@Service

public class UserInfoServiceImpl implements UserInfoService {



   @Resource(name = "taskExecutor")

   private TaskExecutor executor;

    @Resource(name = "taskExecutor")

    private TaskExecutor executor;



   @Resource

   private ThreeSaleSerivce threeSaleSerivce;

    @Resource

    private ThreeSaleSerivce threeSaleSerivce;



   @Resource

   private UserInfoMapper userInfoMapper;

    @Resource

    private UserInfoMapper userInfoMapper;



   @Resource

   private BindingAccountMapper bindingAccountMapper;

    @Resource

    private BindingAccountMapper bindingAccountMapper;



   @Resource

   private PayInfoMapper payInfoMapper;

    @Resource

    private PayInfoMapper payInfoMapper;



   @Resource

   private UserShareGoodsHistoryMapper userShareGoodsHistoryMapper;

    @Resource

    private UserShareGoodsHistoryMapper userShareGoodsHistoryMapper;



   @Resource

   private ScanHistoryMapper scanHistoryMapper;

    @Resource

    private ScanHistoryMapper scanHistoryMapper;



   @Resource

   private ShareMapper shareMapper;

    @Resource

    private HongBaoV2CountService hongBaoV2CountService;



   @Resource

   private HongBaoV2CountService hongBaoV2CountService;

    @Lazy

    @Resource

    private CommonOrderCountService commonOrderCountService;



    @Resource

    private UserExtraTaoBaoInfoService userExtraTaoBaoInfoService;



   @Resource

   private UserExtraTaoBaoInfoService userExtraTaoBaoInfoService;

    @Resource

    private TaoBaoUnionAuthRecordService taoBaoUnionAuthRecordService;



   @Resource

   private TaoBaoUnionAuthRecordService taoBaoUnionAuthRecordService;

    @Resource

    private SpreadUserImgService spreadUserImgService;



   @Resource

   private SpreadUserImgService spreadUserImgService;

    @Lazy

    @Resource

    private IntegralDetailService integralDetailService;



   @Lazy

   @Resource

   private UserInfoModifyRecordService userInfoModifyRecordService;

    @Lazy

    @Resource

    private UserInfoModifyRecordService userInfoModifyRecordService;



   public UserInfo getUserByLoginTypeAndOpenId(int loginType, String openid, String appid) {

      List<UserInfo> list = null;

      if (loginType == 1) {

         list = userInfoMapper.listByAppIdAndTaoBaoOpenId(appid, openid);

      } else {

         list = userInfoMapper.listByAppIdAndWXUnionId(appid, openid);

      }

    @Resource

    private RedisManager redisManager;



      if (list != null)

         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 != null && list.size() > 0) {

         return list.get(0);

      }

      return null;

   }

    public UserInfo getUserByLoginTypeAndOpenId(int loginType, String openid, SystemEnum sysetm) {

        List<UserInfo> list = null;

        if (loginType == 1) {

            list = userInfoMapper.listBySystemAndTaoBaoOpenId(sysetm, openid);

        } else {

            list = userInfoMapper.listBySystemAndWXUnionId(sysetm, openid);

        }



   @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRES_NEW)

   public UserInfo addUser(UserInfo form, String appid) {

      try {

         LogHelper.test("用户的注册信息:" + new Gson().toJson(form));

         form.setCreatetime(new Date().getTime());

         form.setRank(0);

         String openId = form.getLoginType() == Constant.TAOBAO ? form.getOpenid() : form.getWxUnionId();

         UserInfo find = getUserByLoginTypeAndOpenId(form.getLoginType(), openId, Constant.APPID);

         if (find != null) {

            return find;

         }

         boolean create = createUser(form, appid);

         if (!create) {

            return null;

         }

         int loginType = form.getLoginType();

         // 建的假用户。。

         if (loginType == -1) {

            return form;

         }

        if (list != null)

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

                }

            }



         LogHelper.userInfo("添加用户:" + form);

         if (form.getLoginType() == Constant.WEIXIN) {

            ThreadUtil.run(new Runnable() {

               public void run() {

                  UserInfo temp = userInfoMapper.selectByPrimaryKey(form.getId());

                  COSManager cosManager = COSManager.getInstance();

                  InputStream inputStream = HttpUtil.getAsInputStream(temp.getPortrait());

                  String uploadFile = cosManager.uploadFile(inputStream, FilePathEnum.userPortrait.getPath() + UUID.randomUUID().toString()).getUrl();

                  UserInfo updateTemp = new UserInfo(temp.getId());

                  updateTemp.setPortrait(uploadFile);

                  userInfoMapper.updateByPrimaryKeySelective(updateTemp);

               }

            });

         }

      } catch (Exception e) {

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

            e1.printStackTrace();

         }

         return null;

      }

      return form;

   }

        if (list != null && list.size() > 0) {

            return list.get(0);

        }

        return null;

    }



   public boolean createUser(UserInfo form, String appid) {

    @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRES_NEW)

    public UserInfo addUser(UserInfo form, SystemEnum sysetm) {

        try {

            LogHelper.test("用户的注册信息:" + new Gson().toJson(form));

            form.setCreatetime(new Date().getTime());

            form.setRank(0);

            String openId = form.getLoginType() == Constant.TAOBAO ? form.getOpenid() : form.getWxUnionId();

            UserInfo find = getUserByLoginTypeAndOpenId(form.getLoginType(), openId, sysetm);

            if (find != null) {

                return find;

            }

            boolean create = createUser(form, sysetm);

            if (!create) {

                return null;

            }

            int loginType = form.getLoginType();

            // 建的假用户。。

            if (loginType == -1) {

                return form;

            }



      long maxUid = userInfoMapper.getMaxUid();

            LogHelper.userInfo("添加用户:" + form);

            if (form.getLoginType() == Constant.WEIXIN) {

                ThreadUtil.run(new Runnable() {

                    public void run() {

                        UserInfo temp = userInfoMapper.selectByPrimaryKey(form.getId());

                        COSManager cosManager = COSManager.getInstance();

                        InputStream inputStream = HttpUtil.getAsInputStream(temp.getPortrait());

                        String uploadFile = cosManager.uploadFile(inputStream, FilePathEnum.userPortrait.getPath() + UUID.randomUUID().toString()).getUrl();

                        UserInfo updateTemp = new UserInfo(temp.getId());

                        updateTemp.setPortrait(uploadFile);

                        userInfoMapper.updateByPrimaryKeySelective(updateTemp);

                    }

                });

            }

        } catch (Exception e) {

            try {

                LogHelper.errorDetailInfo(e);

            } catch (Exception e1) {

                e1.printStackTrace();

            }

            return null;

        }

        return form;

    }



      long dd = (long) (Math.random() * 100);

      if (dd == 0) {

         dd = 1;

      }

      long bid = maxUid;

      long id = bid + dd;

    @Transactional

    public boolean createUser(UserInfo form, SystemEnum sysetm) {

        long maxUid = userInfoMapper.getMaxUid();

        long dd = (long) (Math.random() * 100);

        if (dd == 0) {

            dd = 1;

        }

        long bid = maxUid;

        long id = bid + dd;



      form.setId(id);

      form.setAppId(appid);

      userInfoMapper.insertSelective(form);

      return true;

   }

        form.setId(id);

        form.setSystem(sysetm);

        userInfoMapper.insertSelective(form);

        return true;

    }



   public UserInfo getUserById(long uid) {

      UserInfo user = userInfoMapper.selectByPrimaryKey(uid);

      if (user.getState() != null && user.getState() != UserInfo.STATE_NORMAL)

         return null;

      if (user != null) {

         user.setRankIcon(UserUtil.getRankIcon(user.getRank()));

         user.setRankNamePicture(UserUtil.getRankNamePicture(user.getRank()));

      }

      return user;

   }

    public UserInfo getUserById(long uid) {

        UserInfo user = userInfoMapper.selectByPrimaryKey(uid);

        if (user.getState() != null && user.getState() != UserInfo.STATE_NORMAL)

            return null;

        if (user != null) {

            user.setRankIcon(UserUtil.getRankIcon(user.getRank()));

            user.setRankNamePicture(UserUtil.getRankNamePicture(user.getRank()));

        }

        return user;

    }



   @Transactional

   public void update(UserInfo user) {

      userInfoMapper.updateByPrimaryKeySelective(user);

   }

    @Transactional

    public void update(UserInfo user) {

        userInfoMapper.updateByPrimaryKeySelective(user);

    }



   public long getUserCount() {

      return userInfoMapper.countAvaiableUser();

   }

    public long getUserCount() {

        return userInfoMapper.countAvaiableUser();

    }



   @Transactional

   public boolean inviteWXUserInfo(String code, UserInfo inviter) {

      WeiXinUser weiXinUser = WXLoginUtil.getWeiXinWYUser(code);

      if (weiXinUser == null) {

         return false;

      }

      String wxUnionId = weiXinUser.getUnionid();

      UserInfo find = getUserByLoginTypeAndOpenId(Constant.WEIXIN, wxUnionId, Constant.APPID);



      if (find == null) {

         find = new UserInfo();

         find.setAppId(Constant.APPID);

         find.setWxUnionId(weiXinUser.getUnionid());

         String wxHeadImg = COSManager.getInstance()

               .uploadFile(HttpUtil.getAsInputStream(weiXinUser.getHeadimgurl()),

                     FilePathEnum.userPortrait.getPath() + UUID.randomUUID().toString())

               .getUrl();

         find.setPortrait(wxHeadImg);

         find.setWxPic(wxHeadImg);

         find.setNickName(weiXinUser.getNickname());

         find.setWxName(weiXinUser.getNickname());

         find.setLoginType(Constant.WEIXIN);

         find.setRank(0);

         find.setWxOpenId(weiXinUser.getOpenid());

         BusinessSystem system = new BusinessSystem(Constant.FANLI);

         system.setPlatform(1);

         find.setSystem(system);

      }

    @Transactional

    public void unBindUserInfo(UserInfo user, int type) {

        if (type == Constant.TAOBAO) {

            user.setOpenid("");

            user.setTbName("");

            user.setTbPic("");

            if (!StringUtil.isNullOrEmpty(user.getWxOpenId())) {

                user.setLoginType(Constant.WEIXIN);

                user.setNickName(user.getWxName());

                user.setPortrait(user.getWxPic());

            }

        } else if (type == Constant.WEIXIN) {

            user.setWxName("");

            user.setWxOpenId("");

            user.setWxUnionId("");

            user.setWxPic("");

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

                user.setLoginType(Constant.TAOBAO);

                user.setNickName(user.getTbName());

                user.setPortrait(user.getTbPic());

            }

        }

        userInfoMapper.updateByPrimaryKeySelective(user);

    }



      try {

         threeSaleSerivce.bind(find, inviter);

         return true;

      } catch (ThreeSaleException e) {

         e.printStackTrace();

         return false;

      }

   }

    @Transactional

    public void addMoney(UserInfo userInfo, BigDecimal money) {

        userInfoMapper.addHongBaoByUid(userInfo.getId(), money);

    }



   @Transactional

   public void unBindUserInfo(UserInfo user, int type) {

      if (type == Constant.TAOBAO) {

         user.setOpenid("");

         user.setTbName("");

         user.setTbPic("");

         if (!StringUtil.isNullOrEmpty(user.getWxOpenId())) {

            user.setLoginType(Constant.WEIXIN);

            user.setNickName(user.getWxName());

            user.setPortrait(user.getWxPic());

         }

      } else if (type == Constant.WEIXIN) {

         user.setWxName("");

         user.setWxOpenId("");

         user.setWxUnionId("");

         user.setWxPic("");

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

            user.setLoginType(Constant.TAOBAO);

            user.setNickName(user.getTbName());

            user.setPortrait(user.getTbPic());

         }

      }

      userInfoMapper.updateByPrimaryKeySelective(user);

   }

    @Override

    public void updateLoginInfo(UserInfo user) {

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

        update.setLastLoginIp(user.getLastLoginIp());

        update.setLastLoginTime(user.getLastLoginTime());

        userInfoMapper.updateByPrimaryKeySelective(update);

    }



   @Transactional

   public void addMoney(UserInfo userInfo, BigDecimal money) {

      userInfoMapper.addHongBaoByUid(userInfo.getId(), money);

   }

    @Override

    public void cleanPassword(long id) {

        userInfoMapper.cleanPassword(id);

    }



   @Override

   public void updateLoginInfo(UserInfo user) {

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

      update.setLastLoginIp(user.getLastLoginIp());

      update.setLastLoginTime(user.getLastLoginTime());

      userInfoMapper.updateByPrimaryKeySelective(update);

   }

    @Override

    public BigDecimal getNewPeopleHB(Long id) {

        return userInfoMapper.getNewPeopleHB(id);

    }



   @Override

   public void cleanPassword(long id) {

      userInfoMapper.cleanPassword(id);

   }

    @Override

    public UserInfo getUserByIdWithMybatis(long uid) {

        UserInfo user = userInfoMapper.selectByPrimaryKey(uid);

        return UserUtil.filterForClientUser(user);

    }



   @Override

   public BigDecimal getNewPeopleHB(Long id) {

      return userInfoMapper.getNewPeopleHB(id);

   }



   @Override

   public UserInfo getUserByIdWithMybatis(long uid) {

      UserInfo user = userInfoMapper.selectByPrimaryKey(uid);

      return UserUtil.filterForClientUser(user);

   }

    @Override

    public long countInfo(Integer userState, String key, Integer keyType, String userRank, Integer days,

                          String startTime, String endTime, Integer userType, String level, Integer activeCode,SystemEnum system) {

        return userInfoMapper.countInfo(userState, key, keyType, userRank, days, startTime, endTime, userType, level, activeCode,system);

    }



   @Override

   public long queryCount(Integer userState, String key, Integer keyType, String userRank, Integer days,

         String startTime, String endTime,Integer userType) {

      return userInfoMapper.queryCount(userState, key, keyType, userRank, days, startTime, endTime,userType);

   }

    @Override

    public List<UserInfoVO> queryInfo(long start, int count, Integer userState, String key, Integer keyType,

                                      String userRank, Integer days, String startTime, String endTime, Integer userType, String level, Integer activeCode,SystemEnum system) {



   @Override

   public List<UserInfoVO> query(long start, int count, Integer userState, String key, Integer keyType,

         String userRank, Integer days, String startTime, String endTime, Integer orderField, Integer orderMode,Integer userType) {

        List<UserInfoVO> userList = userInfoMapper.queryInfo(start, count, userState, key, keyType, userRank, days,

                startTime, endTime, userType, level, activeCode,system);



      List<UserInfoVO> userList = userInfoMapper.query(start, count, userState, key, keyType, userRank, days,

            startTime, endTime, orderField, orderMode,userType);

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

            return null;

        }



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

         return null;

      }

        for (UserInfoVO userInfoVO : userList) {

            Long uid = userInfoVO.getId();

            String rankName = userInfoVO.getRankName();

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

                userInfoVO.setRankName("青铜");

                userInfoVO.setRankPicture("http://img.flqapp.com/resource/rank/rank_picture_new_1.png");

            }



      for (UserInfoVO userInfoVO : userList) {

         // 数据加工处理

         convertUserInfoVOData(userInfoVO);

      }

            String userLevel = userInfoVO.getUserLevel();

            if (!StringUtil.isNullOrEmpty(userLevel)) {

                userInfoVO.setUserLevel(UserLevelUtil.getByEnumName(userLevel).getName());

            }

            // 累计提现

            userInfoVO.setTotalExtract(payInfoMapper.sumMoneyByUid(uid));



      return userList;

   }

            // 累计订单数量

            userInfoVO.setTotalOrder(commonOrderCountService.countHistoryOrderNum(uid));



   public void convertUserInfoVOData(UserInfoVO userInfoVO) {

      String rankName = userInfoVO.getRankName();

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

         userInfoVO.setRankName("青铜");

         userInfoVO.setRankPicture("http://img.flqapp.com/resource/rank/rank_picture_new_1.png");

      }

            // 累计兑换金币

            userInfoVO.setTotalGoldCoinUsed(Math.abs(integralDetailService.sumUseGoldCoin(uid)));



      String f_alipayAccount = userInfoVO.getAlipayAccountInvalid();

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

         userInfoVO.setAlipayAccountState(1);

      }

            // 邀请人

            UserInfo boss = threeSaleSerivce.getBoss(uid);

            if (boss == null) {

                userInfoVO.setBossName("");

            } else {

                userInfoVO.setBossName("邀请人：" + boss.getNickName());

            }



            // 微信号

            String wxId = userInfoVO.getWxId();

            if (StringUtil.isNullOrEmpty(wxId)) {

                userInfoVO.setWxId("");

            } else {

                userInfoVO.setWxId("微信号:" + wxId);

            }

        }



        return userList;

    }



    @Override

    public List<UserInfo> listBySystemAndWXUnionId(SystemEnum system, String unionId) {

        return userInfoMapper.listBySystemAndWXUnionId(system, unionId);

    }



    @Override

    public List<UserInfo> listBySystemAndTaoBaoOpenId(SystemEnum system, String openId) {

        return userInfoMapper.listBySystemAndTaoBaoOpenId(system, openId);

    }



    @Override

    public List<UserInfo> listBySystemAndPhone(SystemEnum system, String phone) {

        return userInfoMapper.listBySystemAndPhone(system, phone);

    }



    @Override

    public SystemEnum getUserSystem(Long uid) {

        String value = redisManager.getCommonString(RedisKeyEnum.getRedisKey(RedisKeyEnum.userSystem, uid + ""));

        if (!StringUtil.isNullOrEmpty(value)) {

            return SystemEnum.valueOf(value);

        }

        UserInfo user = selectByPKey(uid);

        if (user != null) {

            //保存1天

            redisManager.cacheCommonString(RedisKeyEnum.getRedisKey(RedisKeyEnum.userSystem, uid + ""), user.getSystem().name(), 60 * 60 * 24);

            return user.getSystem();

        }

        return null;

    }





    @Override

    public long queryCount(Integer userState, String key, Integer keyType, String userRank, Integer days,

                           String startTime, String endTime, Integer userType, String level, Integer activeCode,SystemEnum system) {

        return userInfoMapper.queryCount(userState, key, keyType, userRank, days, startTime, endTime, userType, level, activeCode,system);

    }



    @Override

    public List<UserInfoVO> query(long start, int count, Integer userState, String key, Integer keyType,

                                  String userRank, Integer days, String startTime, String endTime, Integer orderField, Integer orderMode,

                                  Integer userType, String level, Integer activeCode,SystemEnum system) {



        List<UserInfoVO> userList = userInfoMapper.query(start, count, userState, key, keyType, userRank, days,

                startTime, endTime, orderField, orderMode, userType, level, activeCode,system);



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

            return null;

        }



        for (UserInfoVO userInfoVO : userList) {

            // 数据加工处理

            convertUserInfoVOData(userInfoVO);

        }



        return userList;

    }



    public void convertUserInfoVOData(UserInfoVO userInfoVO) {

        String rankName = userInfoVO.getRankName();

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

            userInfoVO.setRankName("青铜");

            userInfoVO.setRankPicture("http://img.flqapp.com/resource/rank/rank_picture_new_1.png");

        }



        String f_alipayAccount = userInfoVO.getAlipayAccountInvalid();

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

            userInfoVO.setAlipayAccountState(1);

        }



        String f_phone = userInfoVO.getPhoneInvalid();

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

            userInfoVO.setPhoneState(1);

        }



        String f_taobaoUid = userInfoVO.getTaobaoUidInvalid();

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

            userInfoVO.setTaobaoUidState(1);

        }



        String f_wxUnionId = userInfoVO.getWxUnionIdInvalid();

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

            userInfoVO.setWxUnionIdState(1);

        }



      String f_phone = userInfoVO.getPhoneInvalid();

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

         userInfoVO.setPhoneState(1);

      }

        // 最近登录时间

        Long lastLoginTime = userInfoVO.getLastLoginTime();

        if (lastLoginTime != null && lastLoginTime == 0) {

            userInfoVO.setLastLoginTime(null);

        }



      String f_taobaoUid = userInfoVO.getTaobaoUidInvalid();

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

         userInfoVO.setTaobaoUidState(1);

      }

        // 显示用户微信 淘宝 老版本存在

        String wxUnionId = userInfoVO.getWxUnionId();

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

            userInfoVO.setWxName(null);

        }



      String f_wxUnionId = userInfoVO.getWxUnionIdInvalid();

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

         userInfoVO.setWxUnionIdState(1);

      }

        // 是否绑定支付宝（购买 + 分享权限）

        String taoBaoUid = userInfoVO.getTaoBaoUid();

        String tbSpecialId = userInfoVO.getTbSpecialId();

        String tbRelationId = userInfoVO.getTbRelationId();

        if (StringUtil.isNullOrEmpty(taoBaoUid) || StringUtil.isNullOrEmpty(tbSpecialId)

                || StringUtil.isNullOrEmpty(tbRelationId)) {

            userInfoVO.setTbName(null);

            userInfoVO.setTaoBaoUid(null);

        }



      // 最近登录时间

      Long lastLoginTime = userInfoVO.getLastLoginTime();

      if (lastLoginTime != null && lastLoginTime == 0) {

         userInfoVO.setLastLoginTime(null);

      }

        Long uid = userInfoVO.getId();

        /* 绑定收款账号信息 */

        List<BindingAccount> account = bindingAccountMapper.selectByUid(uid);

        if (account != null && account.size() > 0) {

            BindingAccount bindingAccount = account.get(0);

            Integer type = bindingAccount.getType();

            if (type != null && type == 1) {

                // 支付宝

                userInfoVO.setAccountAlipay(bindingAccount.getAccount());

                userInfoVO.setAccountName(bindingAccount.getName());

                userInfoVO.setAccountBindId(bindingAccount.getId());



      // 显示用户微信 淘宝 老版本存在

      String wxUnionId = userInfoVO.getWxUnionId();

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

         userInfoVO.setWxName(null);

      }

            } else if (type != null && type == 2) {

                // 微信

                userInfoVO.setAccountWX(bindingAccount.getAccount());

                userInfoVO.setAccountNameWX(bindingAccount.getName());

                userInfoVO.setAccountBindIdWX(bindingAccount.getId());

            }

        }



      // 是否绑定支付宝（购买 + 分享权限）

      String taoBaoUid = userInfoVO.getTaoBaoUid();

      String tbSpecialId = userInfoVO.getTbSpecialId();

      String tbRelationId = userInfoVO.getTbRelationId();

      if (StringUtil.isNullOrEmpty(taoBaoUid) || StringUtil.isNullOrEmpty(tbSpecialId)

            || StringUtil.isNullOrEmpty(tbRelationId)) {

         userInfoVO.setTbName(null);

         userInfoVO.setTaoBaoUid(null);

      }

        // 最近一次下单时间

        Date lastOrderTime = hongBaoV2CountService.getLastHongBaoTime(uid);

        if (lastOrderTime != null && lastOrderTime.getTime() != 0) {

            userInfoVO.setLastOrderTime(lastOrderTime.getTime());

        }



      Long uid = userInfoVO.getId();

      /* 绑定收款账号信息 */

      List<BindingAccount> account = bindingAccountMapper.selectByUid(uid);

      if (account != null && account.size() > 0) {

         BindingAccount bindingAccount = account.get(0);

         Integer type = bindingAccount.getType();

         if (type != null && type == 1) {

            // 支付宝

            userInfoVO.setAccountAlipay(bindingAccount.getAccount());

            userInfoVO.setAccountName(bindingAccount.getName());

            userInfoVO.setAccountBindId(bindingAccount.getId());

        // 今日总订单

        long todayOrder = hongBaoV2CountService.countValidNumberByUid(uid, 1);

        userInfoVO.setTodayOrder(todayOrder);



         } else if (type != null && type == 2) {

            // 微信

            userInfoVO.setAccountWX(bindingAccount.getAccount());

            userInfoVO.setAccountNameWX(bindingAccount.getName());

            userInfoVO.setAccountBindIdWX(bindingAccount.getId());

         }

      }

        // 未领取红包 待入账金额

        BigDecimal unaccountedMoney = hongBaoV2CountService.countWillGetMoneyByUid(uid);

        if (unaccountedMoney == null) {

            unaccountedMoney = new BigDecimal(0);

        }

        userInfoVO.setUnaccountedMoney(unaccountedMoney.toString());



      // 最近一次下单时间

      Date lastOrderTime = hongBaoV2CountService.getLastHongBaoTime(uid);

      if (lastOrderTime != null && lastOrderTime.getTime() != 0) {

         userInfoVO.setLastOrderTime(lastOrderTime.getTime());

      }

        // 历史总收益

        BigDecimal totalMoneyHistory = hongBaoV2CountService.countMoneyByUidAndState(uid, 3);

        if (totalMoneyHistory == null) {

            totalMoneyHistory = new BigDecimal(0);

        }

        userInfoVO.setTotalMoneyHistory(totalMoneyHistory.toString());



      // 今日总订单

      long todayOrder = hongBaoV2CountService.countValidNumberByUid(uid, 1);

      userInfoVO.setTodayOrder(todayOrder);

        // 支付宝账号 累计转账总金额

        double totalMoney = payInfoMapper.sumMoneyByUid(uid);

        userInfoVO.setTotalMoney(totalMoney);



      // 未领取红包 待入账金额

      BigDecimal unaccountedMoney = hongBaoV2CountService.countWillGetMoneyByUid(uid);

      if (unaccountedMoney == null) {

         unaccountedMoney = new BigDecimal(0);

      }

      userInfoVO.setUnaccountedMoney(unaccountedMoney.toString());

        // 累计提现 (暂未计入微信)

        userInfoVO.setTotalExtract(totalMoney);



      // 历史总收益

      BigDecimal totalMoneyHistory = hongBaoV2CountService.countMoneyByUidAndState(uid, 3);

      if (totalMoneyHistory == null) {

         totalMoneyHistory = new BigDecimal(0);

      }

      userInfoVO.setTotalMoneyHistory(totalMoneyHistory.toString());

        // 统计分享个数

        long countUserShares = userShareGoodsHistoryMapper.countUserShares(uid);

        userInfoVO.setCountUserShares(countUserShares);



      // 支付宝账号 累计转账总金额

      double totalMoney = payInfoMapper.sumMoneyByUid(uid);

      userInfoVO.setTotalMoney(totalMoney);

        // 统计浏览足迹

        long countScanHistory = scanHistoryMapper.countUserScanHistory(uid);

        userInfoVO.setCountScanHistory(countScanHistory);



      // 累计提现 (暂未计入微信)

      userInfoVO.setTotalExtract(totalMoney);

        // 一度队员数量

        //int firstTeamCount = shareMapper.myFirstTeamCount(uid + "");

        //userInfoVO.setCountLevelOne(firstTeamCount);



      // 统计分享个数

      long countUserShares = userShareGoodsHistoryMapper.countUserShares(uid);

      userInfoVO.setCountUserShares(countUserShares);

        // 二度队员数量

        //int secondTeamCount = shareMapper.mySecondTeamCount(uid + "");

        //userInfoVO.setCountLevelTwo(secondTeamCount);



      // 统计浏览足迹

      long countScanHistory = scanHistoryMapper.countUserScanHistory(uid);

      userInfoVO.setCountScanHistory(countScanHistory);

        String userLevel = userInfoVO.getUserLevel();

        if (!StringUtil.isNullOrEmpty(userLevel)) {

            userInfoVO.setUserLevel(UserLevelUtil.getByEnumName(userLevel).getName());

        }



      // 一度队员数量

      int firstTeamCount = shareMapper.myFirstTeamCount(uid + "");

      userInfoVO.setCountLevelOne(firstTeamCount);

        String inviteCode = userInfoVO.getInviteCode();

        if (!StringUtil.isNullOrEmpty(inviteCode)) {

            userInfoVO.setInviteCode("已激活");

        } else {

            userInfoVO.setInviteCode("未激活");

        }

    }



      // 二度队员数量

      int secondTeamCount = shareMapper.mySecondTeamCount(uid + "");

      userInfoVO.setCountLevelTwo(secondTeamCount);

   }

    @Override

    public double querySumMoney(String key, Integer userType, Integer days, String startTime, String endTime) {

        return userInfoMapper.querySumMoney(key, userType, days, startTime, endTime);

    }



   @Override

   public double querySumMoney(String key, Integer userType, Integer days, String startTime, String endTime) {

      return userInfoMapper.querySumMoney(key, userType, days, startTime, endTime);

   }

    @Override

    public UserInfo selectByPKey(Long id) {

        return userInfoMapper.selectByPrimaryKey(id);

    }



   @Override

   public UserInfo selectByPKey(Long id) {

      return userInfoMapper.selectByPrimaryKey(id);

   }

    @Override

    public int updateByPrimaryKeySelective(UserInfo record) {

        return userInfoMapper.updateByPrimaryKeySelective(record);

    }



   @Override

   public int updateByPrimaryKeySelective(UserInfo record) {

      return userInfoMapper.updateByPrimaryKeySelective(record);

   }

    @Override

    @Transactional

    public void deleteBindInfo(UserInfo user, int type) {

        if (type == 1) {

            user.setOpenid("");

            user.setTbName("");

            user.setTbPic("");

            if (!StringUtil.isNullOrEmpty(user.getWxOpenId())) {

                user.setLoginType(Constant.WEIXIN);

                user.setNickName(user.getWxName());

                user.setPortrait(user.getWxPic());

            }

        } else if (type == 2) {

            user.setWxName("");

            user.setWxOpenId("");

            user.setWxUnionId("");

            user.setWxPic("");

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

                user.setLoginType(Constant.TAOBAO);

                user.setNickName(user.getTbName());

                user.setPortrait(user.getTbPic());

            }

        } else if (type == 3) {

            user.setPhone("");

        }



   @Override

   @Transactional

   public void deleteBindInfo(UserInfo user, int type) {

      if (type == 1) {

         user.setOpenid("");

         user.setTbName("");

         user.setTbPic("");

         if (!StringUtil.isNullOrEmpty(user.getWxOpenId())) {

            user.setLoginType(Constant.WEIXIN);

            user.setNickName(user.getWxName());

            user.setPortrait(user.getWxPic());

         }

      } else if (type == 2) {

         user.setWxName("");

         user.setWxOpenId("");

         user.setWxUnionId("");

         user.setWxPic("");

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

            user.setLoginType(Constant.TAOBAO);

            user.setNickName(user.getTbName());

            user.setPortrait(user.getTbPic());

         }

      } else if (type == 3) {

         user.setPhone("");

      }

        userInfoMapper.updateByPrimaryKeySelective(user);

    }



      userInfoMapper.updateByPrimaryKeySelective(user);

   }

    @Override

    public List<Long> longTimeNoLogin(int daysNum, List<Long> list) {

        return userInfoMapper.longTimeNoLogin(daysNum, list);

    }



   @Override

   public List<Long> longTimeNoLogin(int daysNum, List<Long> list) {

      return userInfoMapper.longTimeNoLogin(daysNum, list);

   }

    /**

     * 根据电话号码、邀请码获取邀请用户

     *

     * @param inviteCode

     * @return

     */

    @Override

    public UserInfo getUserInfoByInviteCode(String inviteCode) {

        return userInfoMapper.getUserInfoByInviteCode(inviteCode);

    }



   /**

    * 根据电话号码、邀请码获取邀请用户

    * 
    * @param phone

    * @param inviteCode

    * @return

    */

   @Override

   public UserInfo getUserInfoByInviteCode(String inviteCode) {

      return userInfoMapper.getUserInfoByInviteCode(inviteCode);

   }

    @Override

    public UserInfo getEffectiveUserInfoByPhone(String phone, SystemEnum system) {

        return userInfoMapper.getEffectiveUserInfoByPhone(phone, system);

    }



   @Override

   public UserInfo getEffectiveUserInfoByPhone(String phone) {

      return userInfoMapper.getEffectiveUserInfoByPhone(phone);

   }

    @Override

    public UserInfo getEffectiveUserInfoByWXUnionId(String unionId, SystemEnum system) {

        return userInfoMapper.getEffectiveUserInfoByWXUnionId(unionId, system);

    }



   @Override

   public UserInfo getEffectiveUserInfoByWXUnionId(String unionId) {

      return userInfoMapper.getEffectiveUserInfoByWXUnionId(unionId);

   }

    @Override

    public UserInfo getEffectiveUserInfoByOpenId(String openId, SystemEnum sysetm) {

        return userInfoMapper.getEffectiveUserInfoByOpenId(openId,sysetm);

    }



   @Override

   public UserInfo getUserInfo(Long uid) throws UserInfoException {

      if (uid == null) {

         throw new UserInfoException(1, "请求参数为空");

      }

    @Override

    public UserInfo getUserInfo(Long uid) throws UserInfoException {

        if (uid == null) {

            throw new UserInfoException(1, "请求参数为空");

        }



      UserInfo userInfo = userInfoMapper.selectByPrimaryKey(uid);

      if (userInfo == null) {

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

      }

        UserInfo userInfo = userInfoMapper.selectByPrimaryKey(uid);

        if (userInfo == null) {

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

        }



      if (userInfo.getState() == UserInfo.STATE_FORBIDDEN) {

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

      }

        if (userInfo.getState() == UserInfo.STATE_FORBIDDEN) {

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

        }



      if (userInfo.getState() == UserInfo.STATE_DELETE || userInfo.getState() == UserInfo.STATE_DELETE_OUT_OF_DATE) {

         throw new UserInfoException(Constant.CODE_FORBIDDEN_USER, "帐户已被删除，请重新登录");

      }

        if (userInfo.getState() == UserInfo.STATE_DELETE || userInfo.getState() == UserInfo.STATE_DELETE_OUT_OF_DATE) {

            throw new UserInfoException(Constant.CODE_FORBIDDEN_USER, "帐户已被删除，请重新登录");

        }



      // 淘宝昵称 组织

      boolean clearOpenid = true;

      UserExtraTaoBaoInfo extraTaoBaoInfo = userExtraTaoBaoInfoService.getByUid(uid);

      if (extraTaoBaoInfo != null) {

         String specialId = extraTaoBaoInfo.getSpecialId();

         String relationId = extraTaoBaoInfo.getRelationId();

         String taoBaoNickName = extraTaoBaoInfo.getTaoBaoNickName();

        // 淘宝昵称 组织

        boolean clearOpenid = true;

        UserExtraTaoBaoInfo extraTaoBaoInfo = userExtraTaoBaoInfoService.getByUid(uid);

        if (extraTaoBaoInfo != null) {

            String specialId = extraTaoBaoInfo.getSpecialId();

            String relationId = extraTaoBaoInfo.getRelationId();

            String taoBaoNickName = extraTaoBaoInfo.getTaoBaoNickName();



         if (!StringUtil.isNullOrEmpty(specialId) && !StringUtil.isNullOrEmpty(relationId)) {

            clearOpenid = false;

            userInfo.setOpenid(extraTaoBaoInfo.getTaoBaoUid());

            if (!StringUtil.isNullOrEmpty(specialId) && !StringUtil.isNullOrEmpty(relationId)) {

                clearOpenid = false;

                userInfo.setOpenid(extraTaoBaoInfo.getTaoBaoUid());



            if (!StringUtil.isNullOrEmpty(taoBaoNickName)) {

               userInfo.setTbName(taoBaoNickName);

            } else {

               String taoBaoUserNick = taoBaoUnionAuthRecordService.getTaoBaoUserNick(uid);

               if (!StringUtil.isNullOrEmpty(taoBaoUserNick)) {

                  userInfo.setTbName(taoBaoUserNick);

               }

            }

         }

      }

                if (!StringUtil.isNullOrEmpty(taoBaoNickName)) {

                    userInfo.setTbName(taoBaoNickName);

                } else {

                    String taoBaoUserNick = taoBaoUnionAuthRecordService.getTaoBaoUserNick(uid);

                    if (!StringUtil.isNullOrEmpty(taoBaoUserNick)) {

                        userInfo.setTbName(taoBaoUserNick);

                    }

                }

            }

        }



      if (clearOpenid) {

         userInfo.setOpenid(null);

      }

        if (clearOpenid) {

            userInfo.setOpenid(null);

        }



      return userInfo;

   }

        return userInfo;

    }



   @Override

   public BigDecimal getBalance(Long uid) {

      UserInfo user = userInfoMapper.selectByPrimaryKey(uid);

      if (user != null)

         return user.getMyHongBao();

      return null;

   }

    @Override

    public BigDecimal getBalance(Long uid) {

        UserInfo user = userInfoMapper.selectByPrimaryKey(uid);

        if (user != null)

            return user.getMyHongBao();

        return null;

    }



   @Override

   public void uploadPortrait(MultipartFile file, Long uid) throws UserInfoException, IOException {

    @Override

    public void uploadPortrait(MultipartFile file, Long uid) throws UserInfoException, IOException {



      UserInfo userInfo = userInfoMapper.selectByPrimaryKey(uid);

      if (userInfo == null) {

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

      }

        UserInfo userInfo = userInfoMapper.selectByPrimaryKey(uid);

        if (userInfo == null) {

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

        }



      // 谷歌压缩图片

      String targetPath = FileUtil.getCacheDir() + "/uploadPortrait_" + uid + "_" + System.currentTimeMillis()

            + ".jpg";

      Thumbnails.of(file.getInputStream()).size(200, 200).toFile(targetPath);

        // 谷歌压缩图片

        String targetPath = FileUtil.getCacheDir() + "/uploadPortrait_" + uid + "_" + System.currentTimeMillis()

                + ".jpg";

        Thumbnails.of(file.getInputStream()).size(200, 200).toFile(targetPath);



      // 执行上传

      String filePath =FilePathEnum.userPortrait.getPath() + UUID.randomUUID().toString().replace("-", "") + ".jpg";

      String fileLink = COSManager.getInstance().uploadFile(new File(targetPath), filePath).getUrl();

        // 执行上传

        String filePath = FilePathEnum.userPortrait.getPath() + UUID.randomUUID().toString().replace("-", "") + ".jpg";

        String fileLink = COSManager.getInstance().uploadFile(new File(targetPath), filePath).getUrl();



      // 删除本地图片

      if (new File(targetPath).exists()) {

         new File(targetPath).delete();

      }

        // 删除本地图片

        if (new File(targetPath).exists()) {

            new File(targetPath).delete();

        }



      // 原头像

      String portrait = userInfo.getPortrait();

        // 原头像

        String portrait = userInfo.getPortrait();



      // 更新信息

      userInfo.setPortrait(fileLink);

      userInfoMapper.updateByPrimaryKeySelective(userInfo);

        // 更新信息

        userInfo.setPortrait(fileLink);

        userInfoMapper.updateByPrimaryKeySelective(userInfo);



      // 删除原头像

      if (!StringUtil.isNullOrEmpty(portrait)) {

         COSManager.getInstance().deleteFile(portrait);

      }

        // 删除原头像

        if (!StringUtil.isNullOrEmpty(portrait)) {

            COSManager.getInstance().deleteFile(portrait);

        }



      userInfoModifyRecordService.addModifyRecord(uid, ModifyTypeEnum.portrait, fileLink);

        userInfoModifyRecordService.addModifyRecord(uid, ModifyTypeEnum.portrait, fileLink);



      executor.execute(new Runnable() {

         @Override

         public void run() {

            try {

               // 删除分享头像信息

               spreadUserImgService.deleteImgUrl(uid);

            } catch (Exception e) {

               try {

                  LogHelper.errorDetailInfo(e);

               } catch (Exception e1) {

                  e1.printStackTrace();

               }

            }

         }

      });

   }

        executor.execute(new Runnable() {

            @Override

            public void run() {

                try {

                    // 删除分享头像信息

                    spreadUserImgService.deleteImgUrl(uid);

                } catch (Exception e) {

                    try {

                        LogHelper.errorDetailInfo(e);

                    } catch (Exception e1) {

                        e1.printStackTrace();

                    }

                }

            }

        });

    }



   @Override

   public void saveUserInfo(String nickName, Long uid) throws UserInfoException {

      UserInfo userInfo = userInfoMapper.selectByPrimaryKey(uid);

      if (userInfo == null) {

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

      }

    @Override

    public void saveUserInfo(String nickName, Long uid) throws UserInfoException {

        UserInfo userInfo = userInfoMapper.selectByPrimaryKey(uid);

        if (userInfo == null) {

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

        }



      userInfo.setNickName(nickName);

      userInfoMapper.updateByPrimaryKeySelective(userInfo);

   }

        userInfo.setNickName(nickName);

        userInfoMapper.updateByPrimaryKeySelective(userInfo);

    }



   @Override

   public List<UserInfo> getAutoExtractUser(int start, int count, BigDecimal minSurplus, String beganDate,

         String endDate) {

      return userInfoMapper.getAutoExtractUser(start, count, minSurplus, beganDate, endDate);

   }

    @Override

    public List<UserInfo> getAutoExtractUser(int start, int count, BigDecimal minSurplus, String beganDate,

                                             String endDate) {

        return userInfoMapper.getAutoExtractUser(start, count, minSurplus, beganDate, endDate);

    }



   @Override

   public List<UserInfo> listByType(int type, int page, int count) {

      return userInfoMapper.listByType(type, (page - 1) * count, count);

   }

    @Override

    public List<UserInfo> listByType(int type, int page, int count) {

        return userInfoMapper.listByType(type, (page - 1) * count, count);

    }



   @Override

   public long countByType(int type) {

      return userInfoMapper.countByType(type);

   }

    @Override

    public long countByType(int type) {

        return userInfoMapper.countByType(type);

    }



   @Override

   public List<UserInfo> getAutoExtractUserTo1212(int start, int count) {

      return userInfoMapper.getAutoExtractUserTo1212(start, count);

   }

    @Override

    public List<UserInfo> getAutoExtractUserTo1212(int start, int count) {

        return userInfoMapper.getAutoExtractUserTo1212(start, count);

    }



   @Override

   public UserInfo selectAvailableByPrimaryKey(Long uid) {

      return userInfoMapper.selectAvailableByPrimaryKey(uid);

   }

    @Override

    public UserInfo selectAvailableByPrimaryKey(Long uid) {

        return userInfoMapper.selectAvailableByPrimaryKey(uid);

    }





}