msgdaoim.java

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

package com.yhbbs.message.dao;

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

import com.ibatis.sqlmap.client.SqlMapClient;
import com.yhbbs.data.AppSqlMap;
import com.yhbbs.message.bean.MsgCountIm;
import com.yhbbs.message.biz.MessageBiz;
import com.yhbbs.message.itface.Message;
import com.yhbbs.message.itface.MsgCount;
import com.yhbbs.message.itface.MsgDao;
import com.yhbbs.message.itface.Templet;

/**
 * <p>Title:论坛消息数据存取模块Bean</p>
 * <li>	论坛短消息数据存取模块 <br>
 * <li>	论坛注册，帖子删除移动短消息数据存取模块 <br>
 * <br><b>WebSite: www.yyhweb.com</b>
 * <br><b>CopyRight: yhbbs[永恒论坛]</b>
 * @author stephen
 * @version YH-1.0
 */
public class MsgDaoIm implements MsgDao {
	
	private SqlMapClient sqlMapClient;
	
	/**
	 * constructor
	 */
	public MsgDaoIm() {		
		sqlMapClient = AppSqlMap.getInstance();
	}

	private static MsgDaoIm msgdao = new MsgDaoIm();
	
	/**
	 * @return get the instance of msgdaoim
	 */
	public static MsgDaoIm getInstance(){
		return msgdao;
	}
	
	private int getInt(Object ob){
		if(ob!=null){
			return Integer.parseInt(ob.toString());
		}else
			return 0;
	}
	
	public Templet getRegTemplet() throws SQLException {

		return (Templet) sqlMapClient.queryForObject("getRegTemplet",null);
	}

	public Templet getRegMessage() throws SQLException{

		return (Templet) sqlMapClient.queryForObject("getRegMessage",null);
	}

	public Templet getMoveMessage() throws SQLException {

		return (Templet) sqlMapClient.queryForObject("getMoveMessage",null);
	}

	public Templet getDeleteMessage() throws SQLException {

		return (Templet) sqlMapClient.queryForObject("getDeleteMessage",null);
	}

	public void addMessage(Message msg)throws SQLException{
		
		sqlMapClient.insert("addMessage", msg);
	}
	
	public void deleteMessage(int msgId,int i)throws SQLException{
		if(i==0)
			sqlMapClient.delete("delSendMsg", msgId);
		else if(i==1)
			sqlMapClient.delete("delRevMsg", msgId);
		else
			sqlMapClient.delete("deleteMessage", msgId);
	}
	public List getMsgs(HashMap map,int i) throws SQLException {
		if(i==0)
			return (List)sqlMapClient.queryForList("getSendMsgs",map);
		else 
			return (List)sqlMapClient.queryForList("getRevMsgs",map);
	}

	public int getMsgCounts(int userId,int i) throws SQLException {
		switch (i){
			case 0:return getInt(sqlMapClient.queryForObject("getSendCounts",userId));
			case 1:return getInt(sqlMapClient.queryForObject("getRevCounts",userId));
			case 2:return getInt(sqlMapClient.queryForObject("getNewCounts",userId));
			case 3:return getInt(sqlMapClient.queryForObject("getAllMsgCounts",userId));
			default:return 0;
		}
			
	}
	public MsgCount getMsgCount(int userId) throws SQLException {
		MsgCount curMsg = new MsgCountIm();
		curMsg.setSends(getMsgCounts(userId,0));
		curMsg.setReceives(getMsgCounts(userId,1));
		curMsg.setNewmsgs(getMsgCounts(userId,2));
		return curMsg;
	}
	
	public Message getMessage(int msgId) throws SQLException {
		return (Message) sqlMapClient.queryForObject("getMessage",msgId);
	}
	public void ReadMessage(int msgId) throws SQLException {
			
		sqlMapClient.update("readMessage", msgId);
	}
   
	// 后台管理使用
	
	public boolean updateTemplet(int i, Templet templet) throws SQLException {
		switch (i){
			case 0:return sqlMapClient.update("updateRegTemplet", templet)>0;
			case 1:return sqlMapClient.update("updateRegMessage", templet)>0;
			case 2:return sqlMapClient.update("updateMoveMessage", templet)>0;
			case 3:return sqlMapClient.update("updateDelMessage", templet)>0;
		    default:return false;
		}
	}
}