messageservice.cs

简单聊天系统,自己做的,有数据库.多多支持,做的不好,请大家原谅.

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using NewChartModels;
namespace NewChartDAL
{
   public  class MessageService
    {
       public static IList<MessageInfo> GetAllMessage(int state)
       {
           List<MessageInfo> message = new List<MessageInfo>();
           string sql = "select * from Message where MessageState=@messageState";
           MessageInfo info = null;

           using (SqlDataReader reader = DBHelper.GetReader(sql, new SqlParameter("@messageState", state)))
           {
               while (reader.Read())
               {
                   info = new MessageInfo();
                   info.Id = Convert.ToInt32(reader["Id"]);

                   UsersInfo ui1 = new UsersInfo();
                   ui1.Id = (int)reader["FromUserId"];
                   info.FormUser = ui1;

                   UsersInfo ui2 = new UsersInfo();
                   ui2.Id = (int)reader["ToUserId"];
                   info.ToUser = ui2;

                   info.Message = reader["Message"].ToString();

                   info.RecotrdTime = Convert.ToDateTime(reader["RecordTime"]);

                   MessageStateInfo ms = new MessageStateInfo();
                   ms.Id = (int)reader["MessageState"];
                   info.MessageState = ms;

                   message.Add(info);
               }
           }
           return message;
       }


       public static void AddMessage(int formUserid, int toUserId, string message, DateTime recordTime, int messageState)
       {
           string sql = "insert into Message values(@formUserid,@toUserId,@message,@recordTime,@messageState)";
           MessageInfo info = new MessageInfo();
           SqlParameter[] p = new SqlParameter[]
           {
               new SqlParameter("@formUserid",formUserid),
               new SqlParameter("@toUserId",toUserId),
               new SqlParameter("@message",message),
               new SqlParameter("@recordTime",recordTime),
               new SqlParameter("@messageState",messageState)
             
           };
           DBHelper.ExecuteCommand(sql,p);
       }
    }
}