删除多余的用户服务方法

admin

2019-09-16 87e3fa8532276bb2bf85ae9bc8d9e664b9e187c4

删除多余的用户服务方法

 fanli/src/main/java/com/yeshi/fanli/controller/ClientJspController.java

@@ -149,42 +149,18 @@
        return "coupon";

    }



    //该方法以及废弃

    @Deprecated

    @RequestMapping("findThreeFriendsCount")

    public void findThreeFriendsCount(long id, String callback, PrintWriter out) {

        int count1 = userInfoService.findFriendsCount(id, 1);

        int count2 = userInfoService.findFriendsCount(id, 2);

        JSONObject data = new JSONObject();

        data.put("count1", count1);

        data.put("count2", count2);



        if (!StringUtil.isNullOrEmpty(callback)) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data)));

        } else {

            out.print(JsonUtil.loadTrueResult(data));

        }

		
    }



    //该方法以及废弃

    @Deprecated

    @RequestMapping("findThreeFriends")

    public void findThreeFriends(long id, int type, int page, String callback, PrintWriter out) {

        int pageSize = 30;

        List<InviteUser> list = userInfoService.getFriendsList(id, type, page, pageSize);

        JSONArray array = new JSONArray();

        for (InviteUser user : list) {

            JSONObject item = JSONObject.fromObject(new GsonBuilder().create().toJson(user.getUserInfo()));

            item.put("valid", user.isValid());

            array.add(item);

        }



        long count = userInfoService.getFriendsListCount(id, type);



        JSONObject data = new JSONObject();

        data.put("list", array);

        data.put("pages", count % pageSize == 0 ? count / pageSize : count / pageSize + 1);

        if (!StringUtil.isNullOrEmpty(callback)) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data)));

        } else {

            out.print(JsonUtil.loadTrueResult(data));

        }

		
    }



    @RequestMapping(value = "getConpon", method = RequestMethod.POST)


 fanli/src/main/java/com/yeshi/fanli/dao/mybatis/UserInfoMapper.java

@@ -197,4 +197,5 @@
    // 根据AppId与电话号码获取用户
    List<UserInfo> listByClosed(@Param("appId") String appId, @Param("phone") String phone);

    long countAvaiableUser();
}

 fanli/src/main/java/com/yeshi/fanli/mapping/UserInfoMapper.xml

@@ -686,5 +686,12 @@
        uf.`uie_invite_code` = #{inviteCode})

        LIMIT 1

    </select>

	
	
    <select id="countAvaiableUser" resultType="java.lang.Long">

        SELECT count(*) FROM

        yeshi_ec_user u

        where u.state=0

    </select>



</mapper>


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

@@ -3,33 +3,21 @@
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.context.annotation.Lazy;

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;

@@ -39,9 +27,7 @@
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.InviteUser;

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;

@@ -65,8 +51,6 @@
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;

@@ -78,9 +62,6 @@


    @Resource(name = "taskExecutor")

    private TaskExecutor executor;



    @Resource

    private UserInfoDao userInfoDao;



    @Resource

    private UserInfoService userInfoService;

@@ -132,20 +113,17 @@


    @Resource

    private BindingAccountService bindingAccountService;

	


    @Lazy

    @Resource

    private UserInfoModifyRecordService userInfoModifyRecordService;

	


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

            list = userInfoMapper.listByAppIdAndTaoBaoOpenId(appid, openid);

        } else {

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

                    new Serializable[] { openid, appid });

            list = userInfoMapper.listByAppIdAndWXUnionId(appid, openid);

        }



        if (list != null)

@@ -162,25 +140,6 @@
        }

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

@@ -205,15 +164,15 @@


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

                        UserInfo temp = userInfoMapper.selectByPrimaryKey(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);

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

                        updateTemp.setPortrait(uploadFile);

                        userInfoMapper.updateByPrimaryKeySelective(updateTemp);

                    }

                });

            }

@@ -229,26 +188,24 @@
    }



    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;

            }

        });



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

        userInfoDao.save(form);

        userInfoMapper.insertSelective(form);

        return true;

    }



    public UserInfo getUserById(long uid) {

        UserInfo user = userInfoDao.find(UserInfo.class, uid);

        UserInfo user = userInfoMapper.selectByPrimaryKey(uid);

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

            return null;

        if (user != null) {

@@ -260,211 +217,11 @@


    @Transactional

    public void update(UserInfo user) {

        userInfoDao.update(user);

        userInfoMapper.updateByPrimaryKeySelective(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;

            }

        });

        return userInfoMapper.countAvaiableUser();

    }



    @Transactional

@@ -527,138 +284,25 @@
                user.setPortrait(user.getTbPic());

            }

        }

        userInfoDao.update(user);

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

        }

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

    }



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

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

@@ -730,21 +374,21 @@
            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); 
         }

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

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

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

@@ -975,9 +619,9 @@
        if (!StringUtil.isNullOrEmpty(portrait) && portrait.contains("/img/user/")) {

            COSManager.getInstance().deleteFile(portrait);

        }

		


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

		


        executor.execute(new Runnable() {

            @Override

            public void run() {


 fanli/src/main/java/com/yeshi/fanli/service/inter/user/UserInfoService.java

@@ -56,39 +56,11 @@


    public long getUserCount();



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



    public int getUserCount(String key);



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



    public Map<String, Integer> getnewUserByMonth(int months, Date date);



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



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



    public List<UserInfo> getUserListByUid(long uid);



    public double getFreezeAssets(double min);



    public double getCanAssets(double min);



    public long getRandomShamUser();



    public boolean inviteWXUserInfo(String code, UserInfo inviter);



    public void unBindUserInfo(UserInfo find, int type);



    public void addMoney(UserInfo userInfo, BigDecimal money);



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



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



    public long getFriendsListCount(long id, int type);



    public int findFriendsCount(long id, int type);



    public boolean createUser(UserInfo form, String appid);