删除ThreeSaleDao

admin

2019-03-15 dab56e93753325d37e2505467589718652758112

删除ThreeSaleDao

 fanli/src/main/java/com/yeshi/fanli/dao/user/ThreeSaleDao.java

File was deleted

 fanli/src/main/java/com/yeshi/fanli/entity/bus/recommend/MaskKey.java

@@ -6,23 +6,30 @@
import javax.persistence.GenerationType;

import javax.persistence.Id;

import javax.persistence.Table;



/**

 * 铭感词库

 * 
 * @author Administrator

 *

 */

@Entity

@Table(name="yeshi_ec_mask_key")

@Table(name = "yeshi_ec_mask_key")

public class MaskKey {

    @Id

    @GeneratedValue(strategy=GenerationType.AUTO)

    @Column(name="`id`")

    @GeneratedValue(strategy = GenerationType.AUTO)

    @Column(name = "`id`")

    private long id;

    private String content;



    public MaskKey() {

		


    }

	


    public MaskKey(String content) {

        super();

        this.content = content;

    }





    public MaskKey(long id) {

        super();

@@ -32,15 +39,17 @@
    public long getId() {

        return id;

    }



    public void setId(long id) {

        this.id = id;

    }



    public String getContent() {

        return content;

    }



    public void setContent(String content) {

        this.content = content;

    }

	
	


}


 fanli/src/main/java/com/yeshi/fanli/job/ThreeSaleJob.java

@@ -20,14 +20,8 @@


    @Scheduled(cron = "0 0 */1 * * ? ")

    public void twentyFour() {

//        if (Constant.IS_TASK)

//            threeSaleSerivce.validateTwentyFour();

    }



    @Scheduled(cron = "0 0 0 * * ? ")

    public void aYear() {

        if (Constant.IS_TASK)

            threeSaleSerivce.validate365();

        // if (Constant.IS_TASK)

        // threeSaleSerivce.validateTwentyFour();

    }



    @Scheduled(cron = "0 0 0 ? * MON ")


 fanli/src/main/java/com/yeshi/fanli/service/impl/hongbao/ThreeSaleSerivceImpl.java

@@ -1,6 +1,5 @@
package com.yeshi.fanli.service.impl.hongbao;



import java.io.Serializable;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Calendar;

@@ -9,18 +8,11 @@


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 org.yeshi.utils.NumberUtil;



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

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

@@ -41,9 +33,6 @@
public class ThreeSaleSerivceImpl implements ThreeSaleSerivce {



    @Resource

    private ThreeSaleDao dao;



    @Resource

    private HongBaoManageService hongBaoManageService;



    @Resource

@@ -62,35 +51,7 @@
    private MsgInviteDetailService msgInviteDetailService;



    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;

            }

        });

        return threeSaleMapper.selectBoss(uid);

    }



    @Transactional

@@ -254,134 +215,14 @@
        }

    }



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

            }

        });

        return threeSaleMapper.countFirstTeam(uid, null);

    }



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

            }

        });

        return threeSaleMapper.countSecondTeam(uid, null);

    }



    @Override


 fanli/src/main/java/com/yeshi/fanli/service/inter/hongbao/ThreeSaleSerivce.java

@@ -19,33 +19,19 @@
     */

    UserInfo getBoss(long uid);



    int findInviteCount(long id);



    void bind(UserInfo invitee, UserInfo inviter) throws ThreeSaleException;



    /**

     * 邀请关系生效

     * @param worker

     */

    void effective(UserInfo worker);



    void validateTwentyFour();



    void validate365();



    // 获取下级用户

    List<UserInfo> getFirstUsers(Long uid, int page);



    // 获取一级用户数量

    long getFirstUsersCount(Long uid);



    // 获取下2级用户

    List<UserInfo> getSecondUsers(Long uid, int page);



    // 获取二级用户数量

    long getSecondUsersCount(Long uid);



    // 获取最近有效的分销列表

    List<ThreeSale> getLastestThreeSaleList(int i, String key);



    // 邀请关系

    int getLastestThreeSaleCount(String key);



    /**

     * 查询一度队员集合