memberdaoimpl.java

针对网络跑步爱好者作为用户而开发的

package com.briup.run.dao.impl;

import java.util.List;
import org.hibernate.Query;
import org.hibernate.Session;
import com.briup.run.common.util.HibernateSessionFactory;
import com.briup.run.dao.IMemberDao;
import com.briup.run.dao.bean.GradeRecord;
import com.briup.run.dao.bean.MemberInfo;
import com.briup.run.dao.bean.PointAction;
import com.briup.run.dao.bean.PointRecord;
import com.briup.run.dao.bean.Province;

public class MemberDaoImpl implements IMemberDao {

	@SuppressWarnings("unchecked")
	public GradeRecord findGradeRecordByPoint(long point) throws Exception {
		Session session = HibernateSessionFactory.getSession();
		Query query = session.createQuery("from GradeRecord where minPoint<? and maxPoint>?");
		
		query.setLong(0, point);
		query.setLong(1, point);
		List list = query.list();
		if (list.size() > 0) {
			return (GradeRecord) list.get(0);
		} else {
			return null;
		}
	}

	@SuppressWarnings("unchecked")
	public MemberInfo findMemberByNickName(String nickname) throws Exception {
		Session session = HibernateSessionFactory.getSession();
		Query query = session.createQuery("from MemberInfo where nickName=?");
		query.setString(0, nickname);
		List list = query.list();
		if (list.size() > 0) {
			return (MemberInfo) list.get(0);
		} else {
			return null;
		}
	}

	@SuppressWarnings("unchecked")
	public List findMembersByNum(int num) throws Exception {
		Session session = HibernateSessionFactory.getSession();
		Query query = session
				.createQuery("from MemberInfo order by point desc");
		query.setFirstResult(0);
		query.setMaxResults(num);
		return query.list();
	}

	public Integer findNumMemberInfo() throws Exception {
		Session session = HibernateSessionFactory.getSession();
		Query query = session.createQuery("from MemberInfo");
		Integer num = new Integer(query.list().size());
		return num;
	}

	public Integer findOnlineMemberInfo() throws Exception {
		Session session = HibernateSessionFactory.getSession();
		Query query = session.createQuery("from MemberInfo where isOnline=?");
		query.setLong(0, 1);
		Integer num = new Integer(query.list().size());
		return num;
	}

	@SuppressWarnings("unchecked")
	public PointAction findPointActionByName(String actionname)
			throws Exception {
		Session session = HibernateSessionFactory.getSession();
		Query query = session
				.createQuery("from PointAction where actionName=?");
		query.setString(0, actionname);
		List list = query.list();
		if (list.size() > 0) {
			return (PointAction) list.get(0);
		} else {
			return null;
		}
	}

	@SuppressWarnings("unchecked")
	public List getMembersByConditions(Long minAge, Long maxAge, String gender,
			String provinceCity,int start,int end) throws Exception {
		String str = "from MemberInfo where 1=1";
		Session session = HibernateSessionFactory.getSession();
		if (gender != null)
			str = str + " and gender=" + gender;
		if (provinceCity != null)
			str = str + " and provincecity=" + provinceCity;
		if (minAge != null && maxAge != null)
			str = str + " and age between " + minAge + " and " + maxAge;
		Query query = session.createQuery(str);
		query.setFirstResult(start);
		query.setMaxResults(end);
		List list = query.list();
		return list;
	}

	@SuppressWarnings("unchecked")
	public MemberInfo getRandomMember(int num) throws Exception {
		Session session = HibernateSessionFactory.getSession();
		Query query = session.createQuery("from MemberInfo");
		query.setFirstResult(num);
		query.setMaxResults(1);
		List list = query.list();
		return (MemberInfo) list.get(0);
	}

	public void saveOrUpdateMemberInfo(MemberInfo info) throws Exception {
		Session session = HibernateSessionFactory.getSession();
		session.saveOrUpdate(info);
	}

	public void savePointRecord(PointRecord record) throws Exception {
		Session session = HibernateSessionFactory.getSession();
		session.save(record);
	}

	public void updateOnlineStatus() throws Exception {
		Session session = HibernateSessionFactory.getSession();
		session.createQuery("update MemberInfo set isonline=0").executeUpdate();
	}

	@SuppressWarnings("unchecked")
	public List findProvince() throws Exception {
		Session session=HibernateSessionFactory.getSession();
		Query query=session.createQuery("from Province");
		List list=query.list();
		return list;
	}

	public Province findProvinceByCode(String code) throws Exception {
		Session session=HibernateSessionFactory.getSession();
		Query query=session.createQuery("from Province where code=?");
		query.setString(0, code);
		return (Province)query.uniqueResult();
	}

	public Integer getTotalNumByConditions(Long minAge, Long maxAge, String gender, String provinceCity) throws Exception {
		String str = "from MemberInfo where 1=1";
		Session session = HibernateSessionFactory.getSession();
		if (gender != null)
			str = str + " and gender=" + gender;
		if (provinceCity != null)
			str = str + " and provincecity=" + provinceCity;
		if (minAge != null && maxAge != null)
			str = str + " and age between " + minAge + " and " + maxAge;
		Query query = session.createQuery(str);
		List list = query.list();
		return list.size();
	}
}