messageservice.cs

办公系统办公系统办公系统办公系统办公系统办公系统办公系统办公系统办公系统办公系统办公系统办公系统办公系统办公系统办公系统

//============================================================
// Producnt name:		BoBoARTS.CodeMad
// Version: 			1.0
// Coded by:			Shen Bo ([e-mail])
// Auto generated at: 	2008-9-18 16:23:03
//============================================================

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using Office.Model;

namespace Office.DAL
{
	public static partial class MessageService
	{
        /// <summary>
        /// 
        /// </summary>
        /// <param name="message"></param>
        /// <returns></returns>
        public static Message AddMessage(Message message)
		{
            string sql =
				"INSERT Message (Title, Content, Type, BeginTime, EndTime, FromUserId, IfPublish, RecordTime)" +
				"VALUES (@Title, @Content, @Type, @BeginTime, @EndTime, @FromUserId, @IfPublish, @RecordTime)";
				
			sql += " ; SELECT @@IDENTITY";

            try
            {
				SqlParameter[] para = new SqlParameter[]
				{
					new SqlParameter("@FromUserId", message.FromUserId), //FK
					new SqlParameter("@Type",message.TypeId), //FK
					new SqlParameter("@Title", message.Title),
					new SqlParameter("@Content", message.Content),
					new SqlParameter("@BeginTime", message.BeginTime),
					new SqlParameter("@EndTime", message.EndTime),
					new SqlParameter("@IfPublish", message.IfPublish),
					new SqlParameter("@RecordTime", message.RecordTime)
				};
				
                int newId = DBHelper.GetScalar(sql, para);
				return GetMessageByMessageId(newId);
            }
            catch (Exception e)
            {
				Console.WriteLine(e.Message);
                throw e;
            }
		}
		/// <summary>
		/// 
		/// </summary>
		/// <param name="message"></param>
        public static void DeleteMessage(Message message)
		{
			DeleteMessageByMessageId( message.MessageId );
		}
        /// <summary>
        /// 
        /// </summary>
        /// <param name="messageId"></param>
        public static void DeleteMessageByMessageId(int messageId)
		{
            string sql = "DELETE Message WHERE MessageId = @MessageId";

            try
            {
				SqlParameter[] para = new SqlParameter[]
				{
					new SqlParameter("@MessageId", messageId)
				};
			
                DBHelper.ExecuteCommand(sql, para);
            }
            catch (Exception e)
            {
				Console.WriteLine(e.Message);
				throw e;
            }
		}
		/// <summary>
		/// 
		/// </summary>
		/// <param name="message"></param>
        public static void ModifyMessage(Message message)
        {
            string sql =
                "UPDATE Message " +
                "SET " +
	                "FromUserId = @FromUserId, " + //FK
	                "Type = @Type, " + //FK
	                "Title = @Title, " +
	                "Content = @Content, " +
	                "BeginTime = @BeginTime, " +
	                "EndTime = @EndTime, " +
	                "IfPublish = @IfPublish, " +
	                "RecordTime = @RecordTime " +
                "WHERE MessageId = @MessageId";


            try
            {
				SqlParameter[] para = new SqlParameter[]
				{
					new SqlParameter("@MessageId", message.MessageId),
					new SqlParameter("@FromUserId", message.FromUserId), 
					new SqlParameter("@Type", message.TypeId), 
					new SqlParameter("@Title", message.Title),
					new SqlParameter("@Content", message.Content),
					new SqlParameter("@BeginTime", message.BeginTime),
					new SqlParameter("@EndTime", message.EndTime),
					new SqlParameter("@IfPublish", message.IfPublish),
					new SqlParameter("@RecordTime", message.RecordTime)
				};

				DBHelper.ExecuteCommand(sql, para);
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
				throw e;
            }

        }		
        /// <summary>
        /// 
        /// </summary>
        /// <returns></returns>
        public static IList<Message> GetAllMessages()
        {
            string sqlAll = "SELECT * FROM Message";
            return GetMessagesBySql(sqlAll);
        }
		/// <summary>
		/// 
		/// </summary>
		/// <param name="messageId"></param>
		/// <returns></returns>
        public static Message GetMessageByMessageId(int messageId)
        {
            string sql = "SELECT * FROM Message WHERE MessageId = @MessageId";

            try
            {
                SqlDataReader reader = DBHelper.GetReader(sql, new SqlParameter("@MessageId", messageId));
                if (reader.Read())
                {
                    Message message = new Message();

					message.MessageId = (int)reader["MessageId"];
					message.Title = (string)reader["Title"];
					message.Content = (string)reader["Content"];
                    //if (message.Content.Length > 7)
                    //{
                    //    message.Content = message.Content.Substring(0, 7) + "...";
                    //}
                   message.TypeId= (int)reader["Type"];
					message.BeginTime = (DateTime)reader["BeginTime"];
					message.EndTime = (DateTime)reader["EndTime"];
                    message.FromUserId = (string)reader["FromUserId"];
                    message.IfPublish = (int)reader["IfPublish"];
                    message.RecordTime = (DateTime)reader["RecordTime"];
					



                    reader.Close();
					
                    return message;
                }
                else
                {
                    reader.Close();
                    return null;
                }
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }
        }
		
		
		
     /// <summary>
     /// 
     /// </summary>
     /// <param name="safeSql"></param>
     /// <returns></returns>
        public static IList<Message> GetMessagesBySql( string safeSql )
        {
            List<Message> list = new List<Message>();

            try
            {
                DataTable table = DBHelper.GetDataSet( safeSql );
				
                foreach (DataRow row in table.Rows)
                {
                    Message message = new Message();
					
                    message.MessageId = (int)row["MessageId"];
                    message.Title = (string)row["Title"];
                    message.Content = (string)row["Content"];
                    if (message.Content.Length > 7)
                    {
                        message.Content = message.Content.Substring(0, 7) + "...";
                    }
                    message.TypeId = (int)row["Type"];
                    message.BeginTime = (DateTime)row["BeginTime"];
                    message.EndTime = (DateTime)row["EndTime"];

                    message.FromUserId = (string)row["FromUserId"];
                  
                    message.IfPublish = (int)row["IfPublish"];
                    message.RecordTime = (DateTime)row["RecordTime"];
	
                    list.Add(message);
                }
	
                return list;
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }

        }
		/// <summary>
		/// 
		/// </summary>
		/// <param name="sql"></param>
		/// <param name="values"></param>
		/// <returns></returns>
        public  static IList<Message> GetMessagesBySql( string sql, params SqlParameter[] values )
        {
            List<Message> list = new List<Message>();

            try
            {
                DataTable table = DBHelper.GetDataSet( sql, values );
				
                foreach (DataRow row in table.Rows)
                {
                    Message message = new Message();
					
                    message.MessageId = (int)row["MessageId"];
                    message.Title = (string)row["Title"];
                    message.Content = (string)row["Content"];
                    if (message.Content.Length > 7)
                    {
                        message.Content = message.Content.Substring(0, 7) + "...";
                    }
                    message.TypeId =(int)row["Type"]; 
                    message.BeginTime = (DateTime)row["BeginTime"];
                    message.EndTime = (DateTime)row["EndTime"];
                    message.FromUserId = (string)row["FromUserId"];
                    message.IfPublish = (int)row["IfPublish"];
                    message.RecordTime = (DateTime)row["RecordTime"];
                    
                 
	
                    list.Add(message);
                }
	
                return list;
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }
			
        }


        public static IList<Message> GetMessagesByTime(DateTime begintime,DateTime endtime)
        {
            List<Message> list = new List<Message>();
            try
            {
                string sql = "select *from Message where BeginTime>=@beginTime and EndTime<=@endTime";
                SqlParameter[] values ={
                
                    new SqlParameter("@beginTime",begintime),
                  new SqlParameter("@endTime",endtime)
                };
                DataTable table = DBHelper.GetDataSet(sql, values);

                foreach (DataRow row in table.Rows)
                {
                    Message message = new Message();

                    message.MessageId = (int)row["MessageId"];
                    message.Title = (string)row["Title"];
                    message.Content = (string)row["Content"];
                    if (message.Content.Length > 7)
                    {
                        message.Content = message.Content.Substring(0,7) + "...";
                    }

                    message.TypeId = (int)row["Type"];
                    message.BeginTime = (DateTime)row["BeginTime"];
                    message.EndTime = (DateTime)row["EndTime"];
                    message.FromUserId=(string)row["FromUserId"];
                    message.IfPublish = (int)row["IfPublish"];
                    message.RecordTime = (DateTime)row["RecordTime"];
                  

                    list.Add(message);
                }

                return list ;
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }
        }


        public static IList<Message> GetMessages(string FromUserId)
        {
            string sqlAll = "SELECT * FROM Message WHERE FromUserId = '" + FromUserId + "'";
            return GetMessagesBySql(sqlAll);
        }
        public static Message GetMessageToUser(string userId)
        {
            string sql = "SELECT * FROM Message WHERE  FromUserId= @FromUserId";


            try
            {
                SqlDataReader reader = DBHelper.GetReader(sql, new SqlParameter("@FromUserId", userId));
                if (reader.Read())
                {
                    Message message = new Message();

                    message.MessageId = (int)reader["MessageId"];
                    message.Title = (string)reader["Title"];
                    message.Content = (string)reader["Content"];
                    message.BeginTime = (DateTime)reader["BeginTime"];
                    message.EndTime = (DateTime)reader["EndTime"];
                    message.IfPublish = (int)reader["IfPublish"];
                    message.RecordTime = (DateTime)reader["RecordTime"];
                    message.FromUserId = (string)reader["FromUserId"]; //FK
                    message.TypeId=(int)reader["Type"]; //FK

                    reader.Close();

                    //message.FromUser = UserInfoService.GetUserInfoByUserId(fromUserId);
                    //message.Type = MessageTypeService.GetMessageTypeByMessageTypeId(type);

                    return message;
                }
                else
                {
                    reader.Close();
                    return null;
                }
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }
        }

        /// <summary>
        /// 
        /// </summary>
        /// <returns></returns>
        public static Boolean DeleteMessageMessageIds(String messageIds)
        {
            string sql = "DELETE Message WHERE MessageId in (" + messageIds + ")";
            try
            {
                DBHelper.ExecuteCommand(sql);
                return true;
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }
            return false;
        }
		
	}
}