userdaoimpl.java

jsp学习交流网

package cfq.business.impl;

import java.util.Date;
import java.util.Iterator;
import java.util.List;

import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import cfq.business.dao.UserDao;
import cfq.comm.utils.DateFormatUtils;
import cfq.hibernate.vo.News;
import cfq.hibernate.vo.Newscomment;
import cfq.hibernate.vo.Resource;
import cfq.hibernate.vo.Users;
import cfq.struts.actionform.NewsCommtForm;
import cfq.struts.actionform.ScoreForm;
import cfq.struts.actionform.UploadForm;
import cfq.struts.actionform.UserRegsActionForm;

public class UserDaoImpl extends HibernateDaoSupport implements UserDao {

	//用户登录
	public String userLogin(String username, String password) {
		String result="fail";
		String hql="From Users u where u.username=? and u.password=?";
		List list=this.getSession().createQuery(hql).setString(0, username)
										  .setString(1, password)							
										  .list();
		if(list.size()>0){
			result="OK";
		}
		return result;
	}


	public String userDownLoad() {
		return null;
	}

	
	
	//用户注册
	public String addUser(UserRegsActionForm userinfo) {
		String result="OK";
		String username=userinfo.getUsername();
		List list=this.getSession().createQuery("from Users u where u.username=?").setString(0, username)
																		.list();
		if(list.size()>0){
			result="ExistUser";
			return result;
		}else{
			Users user=new Users();
			user.setUsername(userinfo.getUsername());
			user.setPassword(userinfo.getPassword());
			user.setAge(userinfo.getAge());
			user.setEmail(userinfo.getEmail());
			user.setSex(userinfo.getSex());
			user.setRegisterdate(DateFormatUtils.dateToStirng(new Date()));
			this.getHibernateTemplate().save(user);
			return result;
		}
	}

	 //用户发表评论
	public void addComment(NewsCommtForm ncf) {
		
		Newscomment nsc=new Newscomment();
		nsc.setCommtitle(ncf.getCommttitle());
		nsc.setCommcontent(ncf.getCommtcontent());
		nsc.setCommdate(DateFormatUtils.dateToStirng(new Date()));
		
		News ns=(News)this.getSession().load(News.class, ncf.getNewsid());
		nsc.setNews(ns);
		this.getSession().save(nsc);
	}

	//根据用户名查找，由于用户在注册进行了用户名唯一性检查，所以只返回一个对象
	public Users queryByusername(String username) {
		Users ur=null;
		List list=this.getSession().createQuery("from Users u where u.username=?").setString(0, username)
																		          .list();
		if(list.size()>0){
			Iterator iter=list.iterator();
			ur=(Users)iter.next();
		}
		return ur;
	}

	
    //保存用户上传文件的相关信息
	public String addUserUpLoad(UploadForm uf) {
		String result="OK";
		try{
			Users user=(Users)this.getSession().load(Users.class, uf.getUserid());
			Resource res=new Resource();
			res.setResname(uf.getFile().getFileName());
			res.setResclass(uf.getResclass());
			res.setResdescp(uf.getResdescription());
			res.setOthername(uf.getOthername());
			res.setUploaddate(DateFormatUtils.dateToStirng(new Date()));
			res.setUsers(user);
			this.getSession().save(res);
		}catch(Exception e){
			result="fail";
		}
		return result;
	}


	//用户下载资源的时候给该资源打个分数
	public void addScore(ScoreForm sf) {
		Resource rs=null;
		String hql="from Resource r where r.resname=?";
		List list=this.getSession().createQuery(hql).setString(0, sf.getResname())
													.list();
		Iterator iter=list.iterator();
		while(iter.hasNext()){
			rs=(Resource)iter.next();
			
		}
		rs.setResworth(sf.getScore());
	}

}