package com.yeshi.fanli.service.impl.user;
|
|
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.orm.hibernate4.HibernateCallback;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Propagation;
|
import org.springframework.transaction.annotation.Transactional;
|
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.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.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.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;
|
|
@Service
|
public class UserInfoServiceImpl implements UserInfoService {
|
|
@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;
|
|
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;
|
}
|
|
}
|
