messagemanage.cs

一个 用Ajax实现聊天室的简单例子 不全的地方指点

using System;
using System.Collections.Generic;
using System.Text;
using System.Data.SqlClient;
using ChatModel;

namespace ChatDAL
{
    public class MessageManage
    {
        DBHelper db = new DBHelper();  

        /// <summary>
        /// 取出公开信息
        /// </summary>
        /// <returns></returns>
        public List<Message> getPublicMessage()
        {
            List<Message> list = new List<Message>();
            string sql = "select fromTo,sendTo,content,timer from messages where isPublic=1";
            int ID = 0;
            UserManage um = new UserManage();
            SqlDataReader rs = db.getRead(sql);
            while (rs.Read())
            {
                Message m = new Message();
                ID = Convert.ToInt32(rs[0]);
                m.fromTo = um.getNameByID(ID);
                ID = Convert.ToInt32(rs[1]);
                m.sendTo = um.getNameByID(ID);
                m.content = rs[2].ToString();
                m.timer = Convert.ToDateTime(rs[3]);
                list.Add(m);
            }
            rs.Close();
            db.closeCon();
            return list; 
        }

        /// <summary>
        /// 取出自己的私聊信息
        /// </summary>
        /// <param name="userID"></param>
        /// <returns></returns>
        public List<Message> getPrivateMessage(int userID)
        {
            List<Message> list = new List<Message>();
            string sql = "select fromTo,sendTo,content,timer from messages where isPublic=0 and fromTo="
                + userID + " or isPublic=0 and sendTo=" + userID + "";
            int ID = 0;
            UserManage um = new UserManage();
            SqlDataReader rs = db.getRead(sql);
            while (rs.Read())
            {
                Message m = new Message();
                ID = Convert.ToInt32(rs[0]);
                m.fromTo = um.getNameByID(ID);
                ID = Convert.ToInt32(rs[1]);
                m.sendTo = um.getNameByID(ID);
                m.content = rs[2].ToString();
                m.timer = Convert.ToDateTime(rs[3]);
                list.Add(m);
            }
            rs.Close();
            db.closeCon();
            return list;
        }

        /// <summary>
        /// 发送信息
        /// </summary>
        /// <param name="m"></param>
        public void addMessage(Message m)
        {
            string sql = "insert into messages values(" + m.fromTo.ID + "," + m.sendTo.ID
                + ",'" + m.content + "','" + m.timer + "'," + m.isPublic + ")";
            db.getRow(sql);
        }

    }
}