package com.yeshi.fanli.service.impl.hongbao;
|
|
import java.io.Serializable;
|
import java.util.List;
|
import java.util.Map;
|
|
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.Transactional;
|
|
import com.yeshi.fanli.dao.mybatis.ThreeSaleMapper;
|
import com.yeshi.fanli.dao.mybatis.UserInfoMapper;
|
import com.yeshi.fanli.dao.user.ThreeSaleDao;
|
import com.yeshi.fanli.entity.bus.user.ThreeSale;
|
import com.yeshi.fanli.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.service.inter.config.InviteGetMoneyService;
|
import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
|
import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;
|
import com.yeshi.fanli.service.inter.user.UserInfoService;
|
import com.yeshi.fanli.util.Constant;
|
import org.yeshi.utils.NumberUtil;
|
|
@Service
|
public class ThreeSaleSerivceImpl implements ThreeSaleSerivce {
|
|
@Resource
|
private ThreeSaleDao dao;
|
|
@Resource
|
private HongBaoManageService hongBaoManageService;
|
|
@Resource
|
private UserInfoService userInfoService;
|
|
@Resource
|
private InviteGetMoneyService inviteGetMoneyService;
|
|
@Resource
|
private UserInfoMapper userInfoMapper;
|
|
@Resource
|
private ThreeSaleMapper threeSaleMapper;
|
|
|
|
|
public UserInfo getBoss(final long uid) {
|
return (UserInfo) dao.excute(new HibernateCallback<UserInfo>() {
|
public UserInfo doInHibernate(Session session) throws HibernateException {
|
Query query = session.createQuery("select ts.boss FROM ThreeSale ts where ts.worker.id = ?");
|
query.setParameter(0, uid);
|
List<UserInfo> list = query.list();
|
if (list.size() > 0) {
|
return list.get(0);
|
}
|
return null;
|
}
|
});
|
}
|
|
public int findInviteCount(final long id) {
|
|
return (Integer) dao.excute(new HibernateCallback<Integer>() {
|
|
public Integer doInHibernate(Session session) throws HibernateException {
|
SQLQuery query = session.createSQLQuery(
|
"SELECT COUNT(*) from `yeshi_ec_threesale` t1 RIGHT JOIN (SELECT t2.`worker_id` AS worker_id FROM `yeshi_ec_threesale` t2 WHERE t2.`boss_id`=? ) t3 ON t1.`boss_id`=t3.worker_id WHERE t1.`boss_id`=t3.worker_id ");
|
query.setParameter(0, id);
|
SQLQuery query2 = session
|
.createSQLQuery("SELECT COUNT(*) from `yeshi_ec_threesale` t4 WHERE t4.`boss_id`=?");
|
query2.setParameter(0, id);
|
int int1 = Integer.parseInt(query.uniqueResult() + "");
|
int int2 = Integer.parseInt(query2.uniqueResult() + "");
|
return int1 + int2;
|
}
|
});
|
}
|
|
@Transactional
|
public void bind(UserInfo invitee, UserInfo inviter) {
|
ThreeSale threeSale = new ThreeSale();
|
threeSale.setBoss(inviter);
|
threeSale.setWorker(invitee);
|
threeSale.setState(false);
|
threeSale.setCreateTime(System.currentTimeMillis());
|
dao.save(threeSale);
|
}
|
|
@Transactional
|
public void effective(UserInfo invitee) {
|
List<ThreeSale> list = dao.list("from ThreeSale ts where ts.worker.id = ? ",
|
new Serializable[] { invitee.getId() });
|
if (list.size() > 0) {
|
ThreeSale threeSale = list.get(0);
|
UserInfo inviter = threeSale.getBoss();
|
threeSale.setState(true);
|
dao.update(threeSale);
|
if (inviter != null)
|
reComputeUserRank(inviter.getId());
|
// }
|
// });
|
}
|
}
|
|
@Transactional
|
public void validateTwentyFour() {
|
dao.excute(new HibernateCallback() {
|
@Override
|
public Object doInHibernate(Session session) throws HibernateException {
|
long currentTimeMillis = System.currentTimeMillis();
|
Query query = session
|
.createQuery("delete from ThreeSale ts where ts.state = ? and (?-ts.createTime) > 86400000");
|
query.setParameter(0, false);
|
query.setParameter(1, currentTimeMillis);
|
query.executeUpdate();
|
return null;
|
}
|
});
|
}
|
|
@Transactional
|
public void validate365() {
|
dao.excute(new HibernateCallback() {
|
@Override
|
public Object doInHibernate(Session session) throws HibernateException {
|
long currentTimeMillis = System.currentTimeMillis();
|
Query query = session.createQuery("delete from ThreeSale ts where (?-ts.createTime) > 31536000000");
|
query.setParameter(0, currentTimeMillis);
|
query.executeUpdate();
|
return null;
|
}
|
});
|
}
|
|
@SuppressWarnings("unchecked")
|
@Override
|
public List<UserInfo> getFirstUsers(Long uid, int page) {
|
return (List<UserInfo>) dao.excute(new HibernateCallback<List<UserInfo>>() {
|
|
@Override
|
public List<UserInfo> doInHibernate(Session session) throws HibernateException {
|
Query query = session
|
.createSQLQuery(
|
"SELECT u.* FROM `yeshi_ec_threesale` t LEFT JOIN `yeshi_ec_user` u ON u.`id`=t.`worker_id` WHERE t.`boss_id`=? ORDER BY t.`createtime` DESC")
|
.addEntity(UserInfo.class);
|
query.setParameter(0, uid);
|
query.setFirstResult((page - 1) * Constant.PAGE_SIZE).setMaxResults(Constant.PAGE_SIZE);
|
return query.list();
|
}
|
});
|
|
}
|
|
@SuppressWarnings("unchecked")
|
@Override
|
public List<UserInfo> getSecondUsers(Long uid, int page) {
|
return (List<UserInfo>) dao.excute(new HibernateCallback<List<UserInfo>>() {
|
|
@Override
|
public List<UserInfo> doInHibernate(Session session) throws HibernateException {
|
Query query = session
|
.createSQLQuery(
|
"SELECT u.* FROM `yeshi_ec_threesale` t LEFT JOIN yeshi_ec_threesale t1 ON t1.`boss_id`=t.`worker_id` LEFT JOIN `yeshi_ec_user` u ON u.`id`=t1.`worker_id` WHERE t.`boss_id`=? AND u.`id` IS NOT NULL GROUP BY u.`id` ORDER BY t.`createtime` DESC")
|
.addEntity(UserInfo.class);
|
query.setParameter(0, uid);
|
query.setFirstResult((page - 1) * Constant.PAGE_SIZE).setMaxResults(Constant.PAGE_SIZE);
|
return query.list();
|
}
|
});
|
}
|
|
@Override
|
public List<ThreeSale> getLastestThreeSaleList(int page, String key) {
|
if (NumberUtil.isNumeric(key)) {
|
Long uid = Long.parseLong(key);
|
int start = (page - 1) * Constant.PAGE_SIZE;
|
List<ThreeSale> list = dao.list(
|
"from ThreeSale ts where ts.boss.nickName like ? or ts.boss.id = ? or ts.worker.nickName like ? or ts.worker.id = ? order by ts.createTime desc",
|
start, Constant.PAGE_SIZE, new Serializable[] { "%" + key + "%", uid, "%" + key + "%", uid });
|
return list;
|
}
|
int start = (page - 1) * Constant.PAGE_SIZE;
|
List<ThreeSale> list = dao.list(
|
"from ThreeSale ts where ts.boss.nickName like ? or ts.worker.nickName like ? order by ts.createTime desc",
|
start, Constant.PAGE_SIZE, new Serializable[] { "%" + key + "%", "%" + key + "%" });
|
return list;
|
|
}
|
|
@Override
|
public int getLastestThreeSaleCount(String key) {
|
if (NumberUtil.isNumeric(key)) {
|
long lk = Long.parseLong(key);
|
return (int) dao.getCount(
|
"select count(*) from ThreeSale ts where ts.boss.id = ? or ts.worker.id = ? or ts.boss.nickName like ? or ts.worker.nickName like ?",
|
new Serializable[] { lk, lk, "%" + key + "%", "%" + key + "%" });
|
}
|
Long lcount = dao.getCount(
|
"select count(*) from ThreeSale ts where ts.boss.nickName like ? or ts.worker.nickName like ?",
|
new Serializable[] { "%" + key + "%", "%" + key + "%" });
|
return lcount.intValue();
|
|
}
|
|
@Override
|
public long getFirstUsersCount(Long uid) {
|
return (Long) dao.excute(new HibernateCallback<Long>() {
|
|
@Override
|
public Long doInHibernate(Session session) throws HibernateException {
|
Query query = session.createSQLQuery(
|
"SELECT count(u.id) FROM `yeshi_ec_threesale` t LEFT JOIN `yeshi_ec_user` u ON u.`id`=t.`worker_id` WHERE t.`boss_id`=?");
|
query.setParameter(0, uid);
|
Object count = query.uniqueResult();
|
return Long.parseLong(count + "");
|
}
|
});
|
}
|
|
@Override
|
public long getSecondUsersCount(Long uid) {
|
return (Long) dao.excute(new HibernateCallback<Long>() {
|
|
@Override
|
public Long doInHibernate(Session session) throws HibernateException {
|
Query query = session.createSQLQuery(
|
"SELECT count(1) FROM `yeshi_ec_threesale` t LEFT JOIN yeshi_ec_threesale t1 ON t1.`boss_id`=t.`worker_id` LEFT JOIN `yeshi_ec_user` u ON u.`id`=t1.`worker_id` WHERE t.`boss_id`=? AND u.`id` IS NOT NULL");
|
query.setParameter(0, uid);
|
Object count = query.uniqueResult();
|
return Long.parseLong(count + "");
|
}
|
});
|
}
|
|
@Override
|
public void reComputeUserRank(Long uid) {
|
int myFirstTeamCount = inviteGetMoneyService.myFirstTeamCount(uid + "");
|
int mySecondTeamCount = inviteGetMoneyService.mySecondTeamCount(uid + "");
|
int count = myFirstTeamCount + mySecondTeamCount;
|
UserInfo user = userInfoService.getUserById(uid);
|
if (user == null)
|
return;
|
|
Map<String, String> convertMap = hongBaoManageService.convertMap();
|
int tong = Integer.parseInt(convertMap.get("sale_tong"));
|
int yin = Integer.parseInt(convertMap.get("sale_yin"));
|
int jin = Integer.parseInt(convertMap.get("sale_jin"));
|
int rank = user.getRank();
|
if (count >= jin) {
|
rank = 3;
|
} else if (count >= yin) {
|
rank = 2;
|
} else if (count >= tong) {
|
rank = 1;
|
}
|
|
if (rank > user.getRank()) {
|
// 更新Rank
|
UserInfo userInfo = new UserInfo(uid);
|
userInfo.setRank(rank);
|
userInfoMapper.updateByPrimaryKeySelective(userInfo);
|
}
|
|
}
|
|
@Override
|
public List<ThreeSale> queryMyFirstTeamList(int start, int count, String key, Long bossId){
|
return threeSaleMapper.queryMyFirstTeamList(start, count, key, bossId);
|
}
|
|
@Override
|
public long queryCountMyFirstTeamList(String key, Long bossId){
|
return threeSaleMapper.queryCountMyFirstTeamList(key, bossId);
|
}
|
|
@Override
|
public List<ThreeSale> queryMySecondTeamList(int start, int count, String key, Long bossId){
|
return threeSaleMapper.queryMySecondTeamList(start, count, key, bossId);
|
}
|
|
@Override
|
public long queryCountMySecondTeamList(String key, Long bossId){
|
return threeSaleMapper.queryCountMySecondTeamList(key, bossId);
|
}
|
|
|
@Override
|
public int deleteByPrimaryKey(Long id){
|
return threeSaleMapper.deleteByPrimaryKey(id);
|
}
|
|
@Override
|
public List<Long> queryLongTimeFailed(int daysNum){
|
return threeSaleMapper.queryLongTimeFailed(daysNum);
|
}
|
|
|
@Override
|
public List<ThreeSale> queryLongTimeSuccess(int daysNum){
|
return threeSaleMapper.queryLongTimeSuccess(daysNum);
|
}
|
|
@Override
|
public int updateExpire(List<Long> list){
|
return threeSaleMapper.updateExpire(list);
|
}
|
|
|
}
|
