userdaoim.java

一个不错的bbs论坛系统．对初学者很有帮助

package com.yhbbs.user.dao;

import java.sql.SQLException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.ibatis.sqlmap.client.SqlMapClient;
import com.yhbbs.bbs.bean.WealthDtoIm;
import com.yhbbs.data.AppSqlMap;
import com.yhbbs.user.itface.bean.ArtMoney;
import com.yhbbs.user.itface.bean.User;
import com.yhbbs.user.itface.bean.UserIndex;
import com.yhbbs.user.itface.bean.UserLgDto;
import com.yhbbs.user.itface.bean.UserSession;
import com.yhbbs.user.itface.dao.UserDao;
import com.yhbbs.utils.Constants;

/**
 * <p>Title:论坛用户数据存取模块Bean</p>
 * <li> 论坛用户数据存取模块 <br>
 * <br><b>WebSite: www.yyhweb.com</b>
 * <br><b>CopyRight: yyhweb[由由华网]</b>
 * @author stephen
 * @version YHBBS-2.0
 */
public class UserDaoIm implements UserDao {
	
	private SqlMapClient sqlMapClient;
	
	private static UserDao userdao = new UserDaoIm();
	
	/**
	 * Constructor Method
	 */
	public UserDaoIm(){
		sqlMapClient = AppSqlMap.getInstance();
	}
		
	/**
	 * @return 获得一个UserDaoIm
	 */
	public static UserDao getInstance(){
		return userdao;
	}
	
	private int getInt(Object ob){
		if(ob!=null)
			return Integer.parseInt(ob.toString());
		else
			return 0;
	}
	private String getString(Object ob){
		if(ob!=null)
			return ob.toString();
		else
			return "";
	}
	
	public User getUser(int userid) throws SQLException {
		
		return (User)sqlMapClient.queryForObject("getUserById",userid);	
	}
	
	public UserIndex getIndexUser(int userid) throws SQLException {
		
		return (UserIndex)sqlMapClient.queryForObject("getIndexUser",userid);	
	}

	public User getUser(String username) throws SQLException {
		
		return (User)sqlMapClient.queryForObject("getUserByName",username);
	}
	
	public int getUserId(String username) throws SQLException {
			
		return getInt(sqlMapClient.queryForObject("getUserId",username));
	}
	
	public String getUserName(int userId) throws SQLException {
		
		return getString(sqlMapClient.queryForObject("getUserName",userId));
	}
	
	public int getUserMail(String email) throws SQLException {
		
		return getInt(sqlMapClient.queryForObject("getUserByMail",email));
	}
	
	public String getUserMail(int userId) throws SQLException {
		
		return getString(sqlMapClient.queryForObject("getUserMail",userId));
	}
	
	public void addUser(User user) throws SQLException {
		
		sqlMapClient.insert("addUser",user);
	}
	
	public boolean editUser(User user,boolean flag) throws SQLException {
		if(flag){
			if(user.getPassword().length()>=Constants.pwdlength)
				return sqlMapClient.update("editUserp",user)>0;
			else
				return sqlMapClient.update("editUser",user)>0;
		}else{
			if(user.getPassword().length()>=Constants.pwdlength)
				return sqlMapClient.update("editUserByAdminp",user)>0;
			else
				return sqlMapClient.update("editUserByAdmin",user)>0;
		}
	}

	public int userLogin(HashMap userMap) throws SQLException {
		
		return getInt(sqlMapClient.queryForObject("userlogin",userMap));
	}
	
	public void upUserLogin(int userId) throws SQLException {
		
		sqlMapClient.update("upCookieUser",userId);
	}
	
	public void upUserLogin(UserLgDto user) throws SQLException {
		
		sqlMapClient.update("upUserLogin",user);
	}
	
	public UserSession getOnlineUser(int userId) throws SQLException{
		
		return (UserSession) sqlMapClient.queryForObject("getOnlineUser",userId);
	}
	
	public void upUserlogout(int userId) throws SQLException {
		
		sqlMapClient.update("upUserLogout",userId);
	}
	
	public void postArticle(WealthDtoIm userWth,boolean flag) throws SQLException {
		if(flag)
			sqlMapClient.update("postArticle",userWth);
		else
			sqlMapClient.update("replayArticle",userWth);
	}
	
	public void eliteArticle(WealthDtoIm userWth,boolean flag) throws SQLException {
		if(flag)
			sqlMapClient.update("eliteArticle",userWth);
		else
			sqlMapClient.update("eliteCel",userWth);
	}
	public void deleteArticle(WealthDtoIm userWth,boolean flag) throws SQLException {
		if(flag)
			sqlMapClient.update("deleteArticle",userWth);
		else
			sqlMapClient.update("deleteReplay",userWth);
	}
	
	public int getUsersCount() throws SQLException {
		
		return getInt(sqlMapClient.queryForObject("getUsersCount",null));
	}
	
	public int getMaxUserId() throws SQLException {
		
		return getInt(sqlMapClient.queryForObject("getMaxUserId",null));
	}
	
	public List getAllGroupUsers(int groupid) throws SQLException {
		
		return (List)sqlMapClient.queryForList("getAllGroupUsers",groupid);
	}
	public List getAllTypeUsers(int typeid) throws SQLException {
		
		return null;
	}
	
	public List getUserByRegTime(HashMap userpage) throws SQLException {

		return (List)sqlMapClient.queryForList("getUserByRegTime",userpage);
	}

	public List getUserByPost(HashMap userpage) throws SQLException {

		return (List)sqlMapClient.queryForList("getUserByPost",userpage);
	}

	public List get20RegUsers() throws SQLException {

		return (List)sqlMapClient.queryForList("get20RegUsers",null);
	}

	public List get20PostUsers() throws SQLException {

		return (List)sqlMapClient.queryForList("get20PostUsers",null);
	}

	public UserSession getNewUser() throws SQLException {

		return (UserSession)sqlMapClient.queryForObject("getNewUser",null);
	}

	public List getBirthDayUser() throws SQLException {
	
		return (List)sqlMapClient.queryForList("getBirthDayUser",null);
	}

	public boolean upUserWealth(ArtMoney artMoney) throws SQLException {
		
		return sqlMapClient.update("upUserWealth",artMoney)>0;
	}
	
	public User getPostGrade(int userId) throws SQLException {
		
		return (User) sqlMapClient.queryForObject("getPostGrade",userId);
	}
	
	public void userUpGrade(int userId) throws SQLException {
		
		sqlMapClient.update("userUpGrade",userId);
	}
	public void userDownGrade(int userId) throws SQLException {
		
		sqlMapClient.update("userDownGrade",userId);
	}
	
	/** 以下为管理后台用到 */
	
	public  List getUsers(HashMap selectMap) throws SQLException {
		
		return (List)sqlMapClient.queryForList("getUsers",selectMap);
	}
	
	public boolean deleteUser(int userId)throws SQLException {
		return sqlMapClient.delete("deleteUser", userId)>0;
	}

	public boolean updateUserType(String userName,int userType) throws SQLException {
		Map<String, Comparable> map = new HashMap<String, Comparable>();
		map.put("username", userName);
		map.put("usertype", userType);
		return sqlMapClient.update("updateUserType",map)>0;
	}
	
}