淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

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

@@ -1,1062 +1,812 @@
package com.yeshi.fanli.service.impl.user;



import java.io.File;

import java.io.IOException;

import java.io.InputStream;

import java.io.Serializable;

import java.math.BigDecimal;

import java.math.BigInteger;

import java.util.ArrayList;

import java.util.Calendar;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.UUID;



import javax.annotation.Resource;



import org.hibernate.HibernateException;

import org.hibernate.Query;

import org.hibernate.SQLQuery;

import org.hibernate.Session;

import org.springframework.core.task.TaskExecutor;

import org.springframework.orm.hibernate4.HibernateCallback;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Propagation;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.web.multipart.MultipartFile;

import org.yeshi.utils.FileUtil;

import org.yeshi.utils.HttpUtil;

import org.yeshi.utils.NumberUtil;

import org.yeshi.utils.tencentcloud.COSManager;



import com.google.gson.Gson;

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

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

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

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.dao.user.UserInfoDao;

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

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

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

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

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

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

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

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

import com.yeshi.fanli.exception.ThreeSaleException;

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

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

import com.yeshi.fanli.log.LogHelper;

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

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

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

import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionAuthRecordService;

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

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

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

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

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.ThreadUtil;

import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.Utils;

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

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

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



import net.coobird.thumbnailator.Thumbnails;



@Service

public class UserInfoServiceImpl implements UserInfoService {



   @Resource(name = "taskExecutor")

   private TaskExecutor executor;



   @Resource

   private UserInfoDao userInfoDao;



   @Resource

   private UserInfoService userInfoService;



   @Resource

   private ConfigService configService;



   @Resource

   private ThreeSaleSerivce threeSaleSerivce;



   @Resource

   private UserInfoMapper userInfoMapper;



   @Resource

   private BindingAccountMapper bindingAccountMapper;



   @Resource

   private PayInfoMapper payInfoMapper;



   @Resource

   private UserShareGoodsHistoryMapper userShareGoodsHistoryMapper;



   @Resource

   private ScanHistoryMapper scanHistoryMapper;



   @Resource

   private ShareMapper shareMapper;



   @Resource

   private HongBaoV2CountService hongBaoV2CountService;



   @Resource

   private UserRankService userRankService;



   @Resource

   private UserActiveLogService userActiveLogService;



   @Resource

   private UserExtraTaoBaoInfoService userExtraTaoBaoInfoService;



   @Resource

   private TaoBaoUnionAuthRecordService taoBaoUnionAuthRecordService;



   @Resource

   private SpreadUserImgService spreadUserImgService;



   @Resource

   private ForbiddenUserIdentifyCodeService forbiddenUserIdentifyCodeService;



   @Resource

   private BindingAccountService bindingAccountService;



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

      List<UserInfo> list = null;

      if (loginType == 1) {

         list = userInfoDao.list("from UserInfo u where u.openid=? and u.appId = ? ",

               new Serializable[] { openid, appid });

      } else {

         list = userInfoDao.list("from UserInfo u where u.wxUnionId=? and u.appId = ? ",

               new Serializable[] { openid, appid });

      }



      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 getUserByLoginTypeAndOpenIdByMybatis(int loginType,

   // String openid, String appid) {

   // List<UserInfo> list = null;

   // if (loginType == 1) {

   // list = userInfoDao.list("from UserInfo u where u.openid=? and u.appId = ?

   // ",

   // new Serializable[] { openid, appid });

   // } else {

   // list = userInfoDao.list("from UserInfo u where u.wxUnionId=? and u.appId

   // = ? ",

   // new Serializable[] { openid, appid });

   // }

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

   // return list.get(0);

   // }

   // return null;

   // }



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

         }



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

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

            // final UserInfo temp = form;

            ThreadUtil.run(new Runnable() {

               public void run() {

                  UserInfo temp = userInfoDao.find(UserInfo.class, form.getId());

                  COSManager cosManager = COSManager.getInstance();

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

                  String uploadFile = cosManager.uploadFile(inputStream, UUID.randomUUID().toString()).getUrl();

                  temp.setPortrait(uploadFile);

                  userInfoDao.update(temp);

               }

            });

         }

      } catch (Exception e) {

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

            e1.printStackTrace();

         }

         return null;

      }

      return form;

   }



   public boolean createUser(UserInfo form, String appid) {

      Long id = (Long) userInfoDao.excute(new HibernateCallback<Long>() {

         public Long doInHibernate(Session session) throws HibernateException {

            SQLQuery query = session.createSQLQuery("SELECT IFNULL(MAX(id),100000) FROM yeshi_ec_user ");

            List list = query.list();

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

            if (dd == 0) {

               dd = 1;

            }

            long bid = Long.parseLong(list.get(0) + "");

            return bid + dd;

         }

      });

      form.setId(id);

      form.setAppId(appid);

      userInfoDao.save(form);

      return true;

   }



   public UserInfo getUserById(long uid) {

      UserInfo user = userInfoDao.find(UserInfo.class, 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) {

      userInfoDao.update(user);

   }



   public long getUserCount() {

      return userInfoDao.getCount("select count(*) from UserInfo");

   }



   public List<UserInfo> getUserList(int index, String key) {



      int start = index * Constant.PAGE_SIZE;



      if (NumberUtil.isNumeric(key)) {

         long l = Long.parseLong(key);

         return userInfoDao.list("from UserInfo u where u.id = ? or u.nickName like ? order by u.id desc", start,

               Constant.PAGE_SIZE, new Serializable[] { l, "%" + key + "%" });

      }



      return userInfoDao.list("from UserInfo u where u.nickName like ? order by u.id desc ", start,

            Constant.PAGE_SIZE, new Serializable[] { "%" + key + "%" });



   }



   public int getUserCount(String key) {

      if (NumberUtil.isNumeric(key)) {

         long lk = Long.parseLong(key);

         return (int) userInfoDao.getCount("select count(u.id) from UserInfo u where u.id = ? or u.nickName like ? ",

               new Serializable[] { lk, "%" + key + "%" });

      }

      Long lcount = userInfoDao.getCount("select count(u.id) from UserInfo u where u.nickName like ? ",

            new Serializable[] { "%" + key + "%" });

      return lcount.intValue();

   }



   @SuppressWarnings("unchecked")

   public Map<String, Integer> getnewUserByDate(final int days, Date date) {



      final Map<String, Integer> map = new HashMap<String, Integer>();

      long timestampms = date.getTime();

      final long timestamps = timestampms / 1000;

      List<String> list = TimeUtil.getEmupDate(days, timestampms);

      for (String dataStr : list) {

         map.put(dataStr, 0);

      }

      return (Map<String, Integer>) userInfoDao.excute(new HibernateCallback<Map<String, Integer>>() {



         public Map<String, Integer> doInHibernate(Session session) throws HibernateException {

            SQLQuery sqlQuery = session.createSQLQuery(

                  "SELECT DATE(FROM_UNIXTIME(createtime/1000)) c,COUNT(*) FROM yeshi_ec_user WHERE DATE_SUB(FROM_UNIXTIME(?), INTERVAL ? DAY) <= DATE(FROM_UNIXTIME(createtime/1000)) AND DATE(FROM_UNIXTIME(createtime/1000)) <= FROM_UNIXTIME(?) GROUP BY c");

            sqlQuery.setParameter(0, timestamps);

            sqlQuery.setParameter(1, days);

            sqlQuery.setParameter(2, timestamps);

            List<Object[]> list = sqlQuery.list();

            for (Object[] objArr : list) {

               map.put(TimeUtil.getSimpleDate((Date) objArr[0]), ((BigInteger) objArr[1]).intValue());

            }

            return map;

         }

      });

   }



   @SuppressWarnings("unchecked")

   public Map<String, Integer> getnewUserByMonth(final int months, final Date endDate) {

      List<String> monthList = Utils.getDateMonthList(months, endDate);

      final Map<String, Integer> map = new HashMap<String, Integer>();

      for (String monthStr : monthList) {

         map.put(monthStr, 0);

      }

      return (Map<String, Integer>) userInfoDao.excute(new HibernateCallback<Map<String, Integer>>() {



         public Map<String, Integer> doInHibernate(Session session) throws HibernateException {

            Calendar calendar = Calendar.getInstance();

            calendar.setTime(endDate);

            calendar.set(Calendar.MONTH, calendar.get(Calendar.MONTH) + 1);

            calendar.set(Calendar.DAY_OF_MONTH, 1);

            long curTime = (calendar.getTime().getTime()) / 1000;

            SQLQuery sqlQuery = session.createSQLQuery(

                  "SELECT DATE_FORMAT(FROM_UNIXTIME(createtime/1000),'%Y-%m') months,COUNT(*) FROM yeshi_ec_user WHERE DATE(FROM_UNIXTIME(createtime/1000)) >= DATE_SUB(FROM_UNIXTIME(?),INTERVAL ? MONTH) AND DATE(FROM_UNIXTIME(createtime/1000)) < FROM_UNIXTIME(?) GROUP BY months");

            sqlQuery.setParameter(0, curTime);

            sqlQuery.setParameter(1, months);

            sqlQuery.setParameter(2, curTime);

            List<Object[]> list = sqlQuery.list();

            for (Object[] objArr : list) {

               map.put((String) objArr[0], ((BigInteger) objArr[1]).intValue());

            }

            return map;

         }

      });

   }



   @SuppressWarnings("unchecked")

   public Map<String, Integer> getUserTotalByDate(final int days, Date date) {



      final Map<String, Integer> map = new HashMap<String, Integer>();

      long timestampms = date.getTime();

      final List<String> list = TimeUtil.getEmupDate(days, timestampms);

      for (String dataStr : list) {

         map.put(dataStr, 0);

      }

      return (Map<String, Integer>) userInfoDao.excute(new HibernateCallback<Map<String, Integer>>() {



         public Map<String, Integer> doInHibernate(Session session) throws HibernateException {

            StringBuffer sb = new StringBuffer();

            int ii = 0;

            for (String day : list) {

               if (ii == 0) {

                  sb.append("SELECT '" + day + "' AS t,IFNULL(SUM(a.s),0) FROM yeshi_ec_user_day a WHERE a.c<= '"

                        + day + "' ");

               } else {

                  sb.append("UNION ALL SELECT '" + day

                        + "' AS t,IFNULL(SUM(a.s),0) FROM yeshi_ec_user_day a WHERE a.c<= '" + day + "' ");

               }

               ii++;

            }



            SQLQuery sqlQuery = session.createSQLQuery(sb.toString());

            List<Object[]> list = sqlQuery.list();

            for (Object[] objArr : list) {

               map.put(String.valueOf(objArr[0]), ((BigDecimal) objArr[1]).intValue());

            }

            return map;

         }

      });

   }



   @SuppressWarnings("unchecked")

   public Map<String, Integer> getUserTotalByMonth(int months, Date date) {

      final List<String> monthList = Utils.getDateMonthList(months, date);

      final Map<String, Integer> map = new HashMap<String, Integer>();

      for (String monthStr : monthList) {

         map.put(monthStr, 0);

      }

      return (Map<String, Integer>) userInfoDao.excute(new HibernateCallback<Map<String, Integer>>() {



         public Map<String, Integer> doInHibernate(Session session) throws HibernateException {



            StringBuffer sb = new StringBuffer();

            int ii = 0;

            for (String month : monthList) {

               if (ii == 0) {

                  sb.append("SELECT '" + month

                        + "' AS t,IFNULL(SUM(a.s),0) FROM yeshi_ec_user_month a WHERE a.months<= '" + month

                        + "' ");

               } else {

                  sb.append("UNION ALL SELECT '" + month

                        + "' AS t,IFNULL(SUM(a.s),0) FROM yeshi_ec_user_month a WHERE a.months<= '" + month

                        + "' ");

               }

               ii++;

            }



            SQLQuery sqlQuery = session.createSQLQuery(sb.toString());

            List<Object[]> list = sqlQuery.list();

            for (Object[] objArr : list) {

               map.put((String) objArr[0], ((BigDecimal) objArr[1]).intValue());

            }

            return map;

         }

      });

   }



   public List<UserInfo> getUserListByUid(long uid) {

      List<UserInfo> list = userInfoDao.list("from UserInfo u where u.id = ? ", new Serializable[] { uid });

      return list;

   }



   public double getFreezeAssets(final double min) {

      return (Double) userInfoDao.excute(new HibernateCallback<Double>() {



         public Double doInHibernate(Session session) throws HibernateException {

            Query query = session.createSQLQuery(

                  "select IFNULL(sum(u.my_hongBao),0) from yeshi_ec_user u where u.my_hongBao < ? ");

            query.setParameter(0, min);

            Double result = Double.parseDouble(query.uniqueResult() + "");

            return result.doubleValue();

         }

      });

   }



   public double getCanAssets(final double min) {

      return (Double) userInfoDao.excute(new HibernateCallback<Double>() {



         public Double doInHibernate(Session session) throws HibernateException {

            Query query = session.createSQLQuery(

                  "select IFNULL(sum(u.my_hongBao),0) from yeshi_ec_user u where u.my_hongBao >= ? ");

            query.setParameter(0, min);

            Double result = Double.parseDouble(query.uniqueResult() + "");

            return result.doubleValue();

         }

      });

   }



   public long getRandomShamUser() {

      return (Long) userInfoDao.excute(new HibernateCallback<Long>() {



         public Long doInHibernate(Session session) throws HibernateException {

            SQLQuery sqlQuery = session

                  .createSQLQuery("SELECT id FROM yeshi_ec_user WHERE login_type=-1 ORDER BY RAND() LIMIT 1");

            List list = sqlQuery.list();

            if (list.size() > 0) {

               long id = Long.parseLong(list.get(0) + "");

               return id;

            }

            return (long) 0;

         }

      });

   }



   @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()),

                     Constant.WXHEADURL + 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);

      }



      try {

         threeSaleSerivce.bind(find, inviter);

         return true;

      } catch (ThreeSaleException e) {

         e.printStackTrace();

         return false;

      }

   }



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

         }

      }

      userInfoDao.update(user);

   }



   @Transactional

   public void addMoney(UserInfo userInfo, BigDecimal money) {



      userInfoDao.excute(new HibernateCallback() {

         @Override

         public Object doInHibernate(Session session) throws HibernateException {

            Query query = session.createQuery("update UserInfo u set u.myHongBao = u.myHongBao + ? where u.id = ?");

            query.setParameter(0, money);

            query.setParameter(1, userInfo.getId());

            query.executeUpdate();

            return null;

         }

      });



   }



   @SuppressWarnings("unchecked")

   @Override

   public List<UserInfo> findFriends(long id, int type) {

      List<UserInfo> list;

      if (type == 1) {

         list = userInfoDao.list("select ts.worker from ThreeSale ts where ts.boss.id = ?",

               new Serializable[] { id });

      } else {

         list = (List<UserInfo>) userInfoDao.excute(new HibernateCallback<List<UserInfo>>() {

            @Override

            public List<UserInfo> doInHibernate(Session session) throws HibernateException {

               SQLQuery query = session.createSQLQuery(

                     "select uu.* from yeshi_ec_user uu left join (SELECT trw.`worker_id` as id FROM  yeshi_ec_threesale trw RIGHT JOIN "

                           + "(SELECT tr.`worker_id` AS id FROM `yeshi_ec_threesale` tr LEFT JOIN `yeshi_ec_user` u  ON tr.`boss_id`=u.`id` WHERE tr.`boss_id`=?) nu ON nu.id = trw.`boss_id`"

                           + "WHERE nu.id = trw.`boss_id`) u on uu.id=u.id where uu.id=u.id");

               query.setParameter(0, id);

               query.addEntity(UserInfo.class);

               return query.list();

            }

         });

      }

      return list;

   }



   @Override

   public int findFriendsCount(long id, int type) {

      if (type == 1) {

         return (int) userInfoDao.getCount("select count(*) from ThreeSale ts where ts.boss.id = ? and ts.state=1",

               new Serializable[] { id });

      } else {

         return (int) userInfoDao.getCountSQL(" from  yeshi_ec_threesale trw RIGHT JOIN "

               + "(SELECT tr.`worker_id` AS id FROM `yeshi_ec_threesale` tr LEFT JOIN `yeshi_ec_user` u  ON tr.`boss_id`=u.`id` WHERE tr.`boss_id`=? and tr.state=1) nu ON nu.id = trw.`boss_id`"

               + "WHERE nu.id = trw.`boss_id` and trw.state=1", new Serializable[] { id });

      }

   }



   @Override

   public void updateLoginInfo(UserInfo user) {

      userInfoDao.excute(new HibernateCallback() {

         @Override

         public Object doInHibernate(Session session) throws HibernateException {

            SQLQuery query = session

                  .createSQLQuery("update yeshi_ec_user u set u.loginip=?,u.last_logintime=? where u.id = ?");

            query.setParameter(0, user.getLastLoginIp());

            query.setParameter(1, user.getLastLoginTime());

            query.setParameter(2, user.getId());

            return query.executeUpdate();

         }

      });

   }



   @Override

   public List<InviteUser> getFriendsList(final long id, int type, int page, int pageSize) {

      List<InviteUser> list = null;

      if (type == 1) {

         list = userInfoDao.getHibernateTemplate().execute(new HibernateCallback<List<InviteUser>>() {

            @Override

            public List<InviteUser> doInHibernate(Session session) throws HibernateException {

               List list = session

                     .createSQLQuery(

                           "SELECT u.id,u.`nick_name`,u.`portrait`,uu.state FROM (SELECT t.* FROM `yeshi_ec_threesale` t  "

                                 + "WHERE t.`boss_id`=? AND (t.expire = 0  OR  t.expire IS NULL) ORDER BY t.createTime DESC) uu LEFT JOIN yeshi_ec_user u ON u.`id`=uu.worker_id")

                     .setParameter(0, id).setFirstResult((page - 1) * pageSize).setMaxResults(pageSize).list();

               return covertToInviteUserList(list);

            }

         });

      } else {

         list = userInfoDao.getHibernateTemplate().execute(new HibernateCallback<List<InviteUser>>() {

            @Override

            public List<InviteUser> doInHibernate(Session session) throws HibernateException {

               List list = session

                     .createSQLQuery(

                           "SELECT u.id,u.`nick_name`,u.`portrait`,uu.state FROM (SELECT tt.* FROM `yeshi_ec_threesale` t  LEFT JOIN yeshi_ec_threesale tt ON tt.`boss_id`=t.`worker_id` "

                                 + " WHERE t.`boss_id`=? AND tt.`id` IS NOT NULL AND (tt.expire = 0  OR  tt.expire IS NULL) ORDER BY tt.createTime DESC) uu LEFT JOIN yeshi_ec_user u ON u.`id`=uu.worker_id")

                     .setParameter(0, id).setFirstResult((page - 1) * pageSize).setMaxResults(pageSize).list();

               return covertToInviteUserList(list);

            }

         });

      }

      return list;

   }



   private List<InviteUser> covertToInviteUserList(List list) {

      List<InviteUser> ilist = new ArrayList<>();

      if (list != null)

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

            Object[] objs = (Object[]) list.get(i);

            InviteUser inviteUser = new InviteUser();

            UserInfo user = new UserInfo();

            user.setId(Long.parseLong(objs[0] + ""));

            user.setNickName(objs[1] + "");

            user.setPortrait(objs[2] + "");

            inviteUser.setUserInfo(user);

            inviteUser.setValid(Boolean.parseBoolean(objs[3] + ""));

            ilist.add(inviteUser);

         }

      return ilist;

   }



   @Override

   public void cleanPassword(long id) {

      userInfoMapper.cleanPassword(id);

   }



   @Override

   public long getFriendsListCount(long id, int type) {

      if (type == 1)

         return userInfoDao.getCountSQL("SELECT COUNT(t.`id`) FROM `yeshi_ec_threesale` t  WHERE t.`boss_id`=  " + id

               + " AND (t.expire = 0  OR  t.expire IS NULL)");

      else

         return userInfoDao.getCountSQL(

               "SELECT COUNT(tt.id) FROM `yeshi_ec_threesale` t  LEFT JOIN yeshi_ec_threesale tt ON tt.`boss_id`=t.`worker_id`  WHERE t.`boss_id`="

                     + id + " AND tt.`id` IS NOT NULL AND (tt.expire = 0  OR  tt.expire IS NULL)");

   }



   @Override

   public BigDecimal getNewPeopleHB(Long id) {

      return userInfoMapper.getNewPeopleHB(id);

   }



   @Override

   public UserInfo getUserByIdWithMybatis(long uid) {

      UserInfo user = userInfoMapper.selectByPKey(uid);

      return UserUtil.filterForClientUser(user);

   }



   @Override

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

         String startTime, String endTime) {

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

   }



   @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) {



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

            startTime, endTime, orderField, orderMode);



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

      }



      // 最近登录时间

      Long lastLoginTime = userInfoVO.getLastLoginTime();

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

         userInfoVO.setLastLoginTime(null);

      }



      /*

       * 显示用户微信 淘宝 老版本存在 String wxUnionId = userInfoVO.getWxUnionId(); if

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

       * userInfoVO.setWxName(null); }

       * 
       * String taoBaoUid = userInfoVO.getTaoBaoUid(); if (taoBaoUid == null

       * || taoBaoUid.trim().length() == 0) { userInfoVO.setTbName(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());



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

            // 微信

            userInfoVO.setAccountWX(bindingAccount.getAccount());

            userInfoVO.setAccountNameWX(bindingAccount.getName());

            userInfoVO.setAccountBindIdWX(bindingAccount.getId());

         }

      }



      // 最近一次下单时间

      Date lastOrderTime = hongBaoV2CountService.getLastHongBaoTime(uid);

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

         userInfoVO.setLastOrderTime(lastOrderTime.getTime());

      }



      // 今日总订单

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

      userInfoVO.setTodayOrder(todayOrder);



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

      BigDecimal unaccountedMoney = hongBaoV2CountService.countWillGetMoneyByUid(uid);

      if (unaccountedMoney == null) {

         unaccountedMoney = new BigDecimal(0);

      }

      userInfoVO.setUnaccountedMoney(unaccountedMoney.toString());



      // 历史总收益

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

      if (totalMoneyHistory == null) {

         totalMoneyHistory = new BigDecimal(0);

      }

      userInfoVO.setTotalMoneyHistory(totalMoneyHistory.toString());



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

      double totalMoney = payInfoMapper.sumMoneyByUid(uid);

      userInfoVO.setTotalMoney(totalMoney);



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

      userInfoVO.setTotalExtract(totalMoney);



      // 统计分享个数

      long countUserShares = userShareGoodsHistoryMapper.countUserShares(uid);

      userInfoVO.setCountUserShares(countUserShares);



      // 统计浏览足迹

      long countScanHistory = scanHistoryMapper.countUserScanHistory(uid);

      userInfoVO.setCountScanHistory(countScanHistory);



      // 一度队员数量

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

      userInfoVO.setCountLevelOne(firstTeamCount);



      // 二度队员数量

      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 UserInfo selectByPKey(Long id) {

      return userInfoMapper.selectByPKey(id);

   }



   @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("");

      }



      userInfoMapper.updateByPrimaryKeySelective(user);

   }



   @Override

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

      return userInfoMapper.longTimeNoLogin(daysNum, list);

   }



   /**

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

    * 
    * @param phone

    * @param inviteCode

    * @return

    */

   @Override

   public UserInfo getInfoByPhoneOrInviteCode(String phone, String inviteCode) {

      return userInfoMapper.getInfoByPhoneOrInviteCode(phone, inviteCode);

   }



   @Override

   public UserInfo getEffectiveUserInfoByPhone(String phone) {

      return userInfoMapper.getEffectiveUserInfoByPhone(phone);

   }



   @Override

   public UserInfo getEffectiveUserInfoByWXUnionId(String unionId) {

      return userInfoMapper.getEffectiveUserInfoByWXUnionId(unionId);

   }



   @Override

   public UserInfo getUserInfo(Long uid) throws UserInfoException {

      if (uid == null) {

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

      }



      UserInfo userInfo = userInfoMapper.selectByPKey(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_NORMAL) {

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

      }



      // 淘宝昵称 组织

      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(taoBaoNickName)) {

               userInfo.setTbName(taoBaoNickName);

            } else {

               String taoBaoUserNick = taoBaoUnionAuthRecordService.getTaoBaoUserNick(uid);

               if (!StringUtil.isNullOrEmpty(taoBaoUserNick)) {

                  userInfo.setTbName(taoBaoUserNick);

               }

            }

         }

      }



      if (clearOpenid) {

         userInfo.setOpenid(null);

      }



      return userInfo;

   }



   @Override

   public BigDecimal getBalance(Long uid) {

      UserInfo user = userInfoMapper.selectByPKey(uid);

      if (user != null)

         return user.getMyHongBao();

      return null;

   }



   @Override

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



      UserInfo userInfo = userInfoMapper.selectByPKey(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 filePath = "/img/user/" + UUID.randomUUID().toString().replace("-", "") + ".jpg";

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



      // 删除本地图片

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

         new File(targetPath).delete();

      }



      // 原头像

      String portrait = userInfo.getPortrait();



      // 更新信息

      userInfo.setPortrait(fileLink);

      userInfoMapper.updateByPrimaryKeySelective(userInfo);



      // 删除原头像

      if (!StringUtil.isNullOrEmpty(portrait) && portrait.contains("/img/user/")) {

         COSManager.getInstance().deleteFile(portrait);

      }



      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.selectByPKey(uid);

      if (userInfo == null) {

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

      }



      userInfo.setNickName(nickName);

      userInfoMapper.updateByPrimaryKeySelective(userInfo);

   }



   @Override

   public void forbiddenUser(Long uid, String reason) {

      UserInfo currentInfo = userInfoService.selectByPKey(uid);

      if (currentInfo == null) {

         return;

      }

      if (currentInfo.getState() != UserInfo.STATE_NORMAL) {

         return;

      }



      currentInfo.setState(UserInfo.STATE_FORBIDDEN);

      currentInfo.setStateDesc(reason);

      userInfoService.updateByPrimaryKeySelective(currentInfo);



      // 加入封禁的账号列表

      ForbiddenUserIdentifyCode forbiddenUserIdentifyCode = new ForbiddenUserIdentifyCode();

      forbiddenUserIdentifyCode.setType(ForbiddenUserIdentifyCodeTypeEnum.wxUnionId);

      forbiddenUserIdentifyCode.setIdentifyCode(currentInfo.getWxUnionId());

      forbiddenUserIdentifyCode.setBeiZhu(currentInfo.getWxName());

      try {

         forbiddenUserIdentifyCodeService.forbiddenIdentifyCode(forbiddenUserIdentifyCode);

      } catch (ForbiddenUserIdentifyCodeException e) {

         e.printStackTrace();

      }



      // 电话号码

      forbiddenUserIdentifyCode = new ForbiddenUserIdentifyCode();

      forbiddenUserIdentifyCode.setType(ForbiddenUserIdentifyCodeTypeEnum.phone);

      forbiddenUserIdentifyCode.setIdentifyCode(currentInfo.getPhone());

      try {

         forbiddenUserIdentifyCodeService.forbiddenIdentifyCode(forbiddenUserIdentifyCode);

      } catch (ForbiddenUserIdentifyCodeException e) {

         e.printStackTrace();

      }



      // 淘宝

      UserExtraTaoBaoInfo taoBao = userExtraTaoBaoInfoService.getByUid(uid);

      if (taoBao != null && !StringUtil.isNullOrEmpty(taoBao.getTaoBaoUid())) {

         forbiddenUserIdentifyCode = new ForbiddenUserIdentifyCode();

         forbiddenUserIdentifyCode.setType(ForbiddenUserIdentifyCodeTypeEnum.taobaoUid);

         forbiddenUserIdentifyCode.setIdentifyCode(taoBao.getTaoBaoUid());

         try {

            forbiddenUserIdentifyCodeService.forbiddenIdentifyCode(forbiddenUserIdentifyCode);

         } catch (ForbiddenUserIdentifyCodeException e) {

            e.printStackTrace();

         }

      }



      // 查询支付宝绑定

      List<BindingAccount> list = bindingAccountService.getBindingAccountByUid(uid);

      if (list != null) {

         for (BindingAccount ba : list) {

            forbiddenUserIdentifyCode = new ForbiddenUserIdentifyCode();

            forbiddenUserIdentifyCode.setType(ForbiddenUserIdentifyCodeTypeEnum.alipayAccount);

            forbiddenUserIdentifyCode.setIdentifyCode(ba.getAccount());

            forbiddenUserIdentifyCode.setBeiZhu(ba.getName());

            try {

               forbiddenUserIdentifyCodeService.forbiddenIdentifyCode(forbiddenUserIdentifyCode);

            } catch (ForbiddenUserIdentifyCodeException e) {

               e.printStackTrace();

            }

         }

      }



   }

}

package com.yeshi.fanli.service.impl.user;

import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.math.BigDecimal;
import java.util.Date;
import java.util.List;
import java.util.UUID;

import javax.annotation.Resource;

import com.yeshi.fanli.entity.SystemEnum;
import com.yeshi.fanli.entity.config.SystemConfigKeyEnum;
import com.yeshi.fanli.service.inter.config.SystemConfigService;
import com.yeshi.fanli.util.*;
import org.springframework.context.annotation.Lazy;
import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;
import org.yeshi.utils.FileUtil;
import org.yeshi.utils.HttpUtil;
import org.yeshi.utils.tencentcloud.COSManager;

import com.google.gson.Gson;
import com.yeshi.fanli.dao.mybatis.BindingAccountMapper;
import com.yeshi.fanli.dao.mybatis.PayInfoMapper;
import com.yeshi.fanli.dao.mybatis.ScanHistoryMapper;
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.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.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.account.UserUtil;
import com.yeshi.fanli.util.user.UserLevelUtil;
import com.yeshi.fanli.vo.user.UserInfoVO;

import net.coobird.thumbnailator.Thumbnails;

@Service
public class UserInfoServiceImpl implements UserInfoService {

    @Resource(name = "taskExecutor")
    private TaskExecutor executor;

    @Resource
    private ThreeSaleSerivce threeSaleSerivce;

    @Resource
    private UserInfoMapper userInfoMapper;

    @Resource
    private BindingAccountMapper bindingAccountMapper;

    @Resource
    private PayInfoMapper payInfoMapper;

    @Resource
    private UserShareGoodsHistoryMapper userShareGoodsHistoryMapper;

    @Resource
    private ScanHistoryMapper scanHistoryMapper;

    @Resource
    private HongBaoV2CountService hongBaoV2CountService;

    @Lazy
    @Resource
    private CommonOrderCountService commonOrderCountService;

    @Resource
    private UserExtraTaoBaoInfoService userExtraTaoBaoInfoService;

    @Resource
    private TaoBaoUnionAuthRecordService taoBaoUnionAuthRecordService;

    @Resource
    private SpreadUserImgService spreadUserImgService;

    @Lazy
    @Resource
    private IntegralDetailService integralDetailService;

    @Lazy
    @Resource
    private UserInfoModifyRecordService userInfoModifyRecordService;

    @Resource
    private RedisManager redisManager;

    @Resource
    private SystemConfigService systemConfigService;


    public UserInfo getUserByLoginTypeAndOpenId(int loginType, String openid, SystemEnum sysetm) {
        List<UserInfo> list = null;
        UserInfoMapper.DaoQuery daoQuery = new UserInfoMapper.DaoQuery();
        daoQuery.system = sysetm;
        daoQuery.count = 1000;
        if (loginType == 1) {
            daoQuery.openId = openid;
        } else {
            daoQuery.wxUnionId = openid;
        }
        list = userInfoMapper.list(daoQuery);


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

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

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

    @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.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;
    }

    @Transactional
    public void update(UserInfo user) {
        userInfoMapper.updateByPrimaryKeySelective(user);
    }

    public long getUserCount() {
        return userInfoMapper.countAvaiableUser();
    }


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

    @Transactional
    public void addMoney(UserInfo userInfo, BigDecimal money) {
        userInfoMapper.addHongBaoByUid(userInfo.getId(), money);
    }

    @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 void cleanPassword(long id) {
        userInfoMapper.cleanPassword(id);
    }

    @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 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) {

        List<UserInfoVO> userList = userInfoMapper.queryInfo(start, count, userState, key, keyType, userRank, days,
                startTime, endTime, userType, level, activeCode, system);

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

            String userLevel = userInfoVO.getUserLevel();
            if (!StringUtil.isNullOrEmpty(userLevel)) {
                userInfoVO.setUserLevel(UserLevelUtil.getByEnumName(userLevel).getName());
            }
            // 累计提现
            userInfoVO.setTotalExtract(payInfoMapper.sumMoneyByUid(uid));

            // 累计订单数量
            userInfoVO.setTotalOrder(commonOrderCountService.countHistoryOrderNum(uid));

            // 累计兑换金币
            userInfoVO.setTotalGoldCoinUsed(Math.abs(integralDetailService.sumUseGoldCoin(uid)));

            // 邀请人
            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) {
        UserInfoMapper.DaoQuery daoQuery = new UserInfoMapper.DaoQuery();
        daoQuery.system = system;
        daoQuery.count = 1000;
        daoQuery.wxUnionId = unionId;

        return userInfoMapper.list(daoQuery);
    }

    @Override
    public List<UserInfo> listBySystemAndTaoBaoOpenId(SystemEnum system, String openId) {
        UserInfoMapper.DaoQuery daoQuery = new UserInfoMapper.DaoQuery();
        daoQuery.system = system;
        daoQuery.count = 1000;
        daoQuery.openId = openId;
        return userInfoMapper.list(daoQuery);
    }

    @Override
    public List<UserInfo> listBySystemAndPhone(SystemEnum system, String phone) {
        UserInfoMapper.DaoQuery daoQuery = new UserInfoMapper.DaoQuery();
        daoQuery.system = system;
        daoQuery.count = 1000;
        daoQuery.phone = phone;
        return userInfoMapper.list(daoQuery);
    }

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

        // 最近登录时间
        Long lastLoginTime = userInfoVO.getLastLoginTime();
        if (lastLoginTime != null && lastLoginTime == 0) {
            userInfoVO.setLastLoginTime(null);
        }

        // 显示用户微信 淘宝 老版本存在
        String wxUnionId = userInfoVO.getWxUnionId();
        if (wxUnionId == null || wxUnionId.trim().length() == 0) {
            userInfoVO.setWxName(null);
        }

        // 是否绑定支付宝（购买 + 分享权限）
        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 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());

            } else if (type != null && type == 2) {
                // 微信
                userInfoVO.setAccountWX(bindingAccount.getAccount());
                userInfoVO.setAccountNameWX(bindingAccount.getName());
                userInfoVO.setAccountBindIdWX(bindingAccount.getId());
            }
        }

        // 最近一次下单时间
        Date lastOrderTime = hongBaoV2CountService.getLastHongBaoTime(uid);
        if (lastOrderTime != null && lastOrderTime.getTime() != 0) {
            userInfoVO.setLastOrderTime(lastOrderTime.getTime());
        }

        // 今日总订单
        long todayOrder = hongBaoV2CountService.countValidNumberByUid(uid, 1);
        userInfoVO.setTodayOrder(todayOrder);

        // 未领取红包 待入账金额
        BigDecimal unaccountedMoney = hongBaoV2CountService.countWillGetMoneyByUid(uid);
        if (unaccountedMoney == null) {
            unaccountedMoney = new BigDecimal(0);
        }
        userInfoVO.setUnaccountedMoney(unaccountedMoney.toString());

        // 历史总收益
        BigDecimal totalMoneyHistory = hongBaoV2CountService.countMoneyByUidAndState(uid, 3);
        if (totalMoneyHistory == null) {
            totalMoneyHistory = new BigDecimal(0);
        }
        userInfoVO.setTotalMoneyHistory(totalMoneyHistory.toString());

        // 支付宝账号 累计转账总金额
        double totalMoney = payInfoMapper.sumMoneyByUid(uid);
        userInfoVO.setTotalMoney(totalMoney);

        // 累计提现 (暂未计入微信)
        userInfoVO.setTotalExtract(totalMoney);

        // 统计分享个数
        long countUserShares = userShareGoodsHistoryMapper.countUserShares(uid);
        userInfoVO.setCountUserShares(countUserShares);

        // 统计浏览足迹
        long countScanHistory = scanHistoryMapper.countUserScanHistory(uid);
        userInfoVO.setCountScanHistory(countScanHistory);

        // 一度队员数量
        //int firstTeamCount = shareMapper.myFirstTeamCount(uid + "");
        //userInfoVO.setCountLevelOne(firstTeamCount);

        // 二度队员数量
        //int secondTeamCount = shareMapper.mySecondTeamCount(uid + "");
        //userInfoVO.setCountLevelTwo(secondTeamCount);

        String userLevel = userInfoVO.getUserLevel();
        if (!StringUtil.isNullOrEmpty(userLevel)) {
            userInfoVO.setUserLevel(UserLevelUtil.getByEnumName(userLevel).getName());
        }

        String inviteCode = userInfoVO.getInviteCode();
        if (!StringUtil.isNullOrEmpty(inviteCode)) {
            userInfoVO.setInviteCode("已激活");
        } else {
            userInfoVO.setInviteCode("未激活");
        }
    }

    @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 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("");
        }

        userInfoMapper.updateByPrimaryKeySelective(user);
    }

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

    @Override
    public UserInfo getEffectiveUserInfoByPhone(String phone, SystemEnum system) {

        UserInfoMapper.DaoQuery daoQuery = new UserInfoMapper.DaoQuery();
        daoQuery.system = system;
        daoQuery.count = 1000;
        daoQuery.phone = phone;
        daoQuery.state = UserInfo.STATE_NORMAL;
        List<UserInfo> userInfoList = userInfoMapper.list(daoQuery);

        return userInfoList != null && userInfoList.size() > 0 ? userInfoList.get(0) : null;
    }

    @Override
    public UserInfo getEffectiveUserInfoByWXUnionId(String unionId, SystemEnum system) {
        UserInfoMapper.DaoQuery daoQuery = new UserInfoMapper.DaoQuery();
        daoQuery.system = system;
        daoQuery.count = 1000;
        daoQuery.wxUnionId = unionId;
        daoQuery.state = UserInfo.STATE_NORMAL;
        List<UserInfo> userInfoList = userInfoMapper.list(daoQuery);

        return userInfoList != null && userInfoList.size() > 0 ? userInfoList.get(0) : null;

    }

    @Override
    public UserInfo getEffectiveUserInfoByQQOpenId(String opneId, SystemEnum sysetm) {
        UserInfoMapper.DaoQuery daoQuery = new UserInfoMapper.DaoQuery();
        daoQuery.system = sysetm;
        daoQuery.count = 1000;
        daoQuery.qqOpenId = opneId;
        daoQuery.state = UserInfo.STATE_NORMAL;
        List<UserInfo> userInfoList = userInfoMapper.list(daoQuery);
        return userInfoList != null && userInfoList.size() > 0 ? userInfoList.get(0) : null;
    }

    @Override
    public UserInfo getEffectiveUserInfoByOpenId(String openId, SystemEnum sysetm) {
        UserInfoMapper.DaoQuery daoQuery = new UserInfoMapper.DaoQuery();
        daoQuery.system = sysetm;
        daoQuery.count = 1000;
        daoQuery.openId = openId;
        daoQuery.state = UserInfo.STATE_NORMAL;
        List<UserInfo> userInfoList = userInfoMapper.list(daoQuery);
        return userInfoList != null && userInfoList.size() > 0 ? userInfoList.get(0) : null;
    }

    @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, "用户不存在");
        }

        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, "帐户已被删除，请重新登录");
        }

        // 淘宝昵称 组织
        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(taoBaoNickName)) {
                    userInfo.setTbName(taoBaoNickName);
                } else {
                    String taoBaoUserNick = taoBaoUnionAuthRecordService.getTaoBaoUserNick(uid);
                    if (!StringUtil.isNullOrEmpty(taoBaoUserNick)) {
                        userInfo.setTbName(taoBaoUserNick);
                    }
                }
            }
        }

        if (clearOpenid) {
            userInfo.setOpenid(null);
        }

        return userInfo;
    }

    @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 {

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

        // 原头像
        String portrait = userInfo.getPortrait();

        // 更新信息
        userInfo.setPortrait(fileLink);
        userInfoMapper.updateByPrimaryKeySelective(userInfo);

        // 删除原头像
        if (!StringUtil.isNullOrEmpty(portrait)) {
            COSManager.getInstance().deleteFile(portrait);
        }

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

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

    @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 long countByType(int type) {
        return userInfoMapper.countByType(type);
    }

    @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 String getDefaultNickName(SystemEnum system, Long uid) {
        return systemConfigService.getValueCache(SystemConfigKeyEnum.defaultNickNamePrefix, system) + uid;
    }

    @Override
    public String getDefaultNickName(Long uid) {
        SystemEnum system = getUserSystem(uid);
        return getDefaultNickName(system, uid);
    }

    @Override
    public String getDefaultPortrait(SystemEnum system) {
        return systemConfigService.getValueCache(SystemConfigKeyEnum.defaultPortrait, system);
    }

    @Override
    public String getDefaultPortrait(Long uid) {
        SystemEnum system = getUserSystem(uid);
        return getDefaultPortrait(system);
    }


}