readcommonmessageservice.cs

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

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

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 ReadCommonMessageService
    {
        /// <summary>
        ///add message
        /// </summary>
        /// <param name="Message">ReadCommonMessage</param>
        /// <returns>ReadCommonMessage</returns>
        public static ReadCommonMessage AddReadCommonMessage(ReadCommonMessage Message)
        {
            string sql = "insert into ReadCommonMessage (MessageId,UserId) values(@MessageId,@UserId)";
            try
            {
                sql += " ; select @@identity";
                SqlParameter[] para = new SqlParameter[] { 
                new SqlParameter("@MessageId",Message.Message.MessageId),
                new SqlParameter("@UserId",Message.User.UserId)
            };
                int newID = DBHelper.GetScalar(sql, para);
                return GetReadCommonMessageByID(newID);
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
                throw ex;
            }
        }
        /// <summary>
        /// delete message
        /// </summary>
        /// <param name="readCommonMessage">ReadCommonMessage</param>
        /// <returns></returns>
        public static Boolean DeleteReadCommonMessage(ReadCommonMessage readCommonMessage)
        {
            return DeleteReadCommonMessageByID(readCommonMessage.ReadId);
        }
        /// <summary>
        /// modify message
        /// </summary>
        /// <param name="readCommonMessage">ReadCommonMessage</param>
        /// <returns>Boolean</returns>
        public static Boolean ModifyReadCommonMessage(ReadCommonMessage readCommonMessage)
        {
            string sql = "update ReadCommonMessage set MessageId=@MessageId,UserId=@UserId where ReadId=@ReadId";
            try
            {
                SqlParameter[] para = new SqlParameter[] { 
                new SqlParameter("@MessageId",readCommonMessage.Message.MessageId),
                new SqlParameter("@UserId",readCommonMessage.User.UserId),
                new SqlParameter("@ReadId",readCommonMessage.ReadId)
            };
                int count = DBHelper.ExecuteCommand(sql, para);
                return count > 0 ? true : false;
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
                throw ex;
            }
        }
        /// <summary>
        /// get all common message
        /// </summary>
        /// <returns>IList<ReadCommonMessage></returns>
        public static IList<ReadCommonMessage> GetAllReadCommonMessage()
        {
            return GetReadCommonMessageBySql("select * from ReadCommonMessage");
        }
        /// <summary>
        /// delete common message according to ID
        /// </summary>
        /// <param name="ReadCommonMessageId"></param>
        /// <returns></returns>
        public static Boolean DeleteReadCommonMessageByID(int ReadCommonMessageId)
        {
            string sql = "delete ReadCommonMessage where ReadId="+ReadCommonMessageId;
            try
            {
                int count = DBHelper.ExecuteCommand(sql);
                return count > 0 ? true : false;
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
                throw ex;
            }
        }
        /// <summary>
        /// get common message according to ID
        /// </summary>
        /// <param name="ReadCommonMessageID">ReadCommonMessageID</param>
        /// <returns>ReadCommonMessage</returns>
        public static ReadCommonMessage GetReadCommonMessageByID(int ReadCommonMessageID)
        {
            string sql = "select * from ReadCommonMessage where ReadId =" + ReadCommonMessageID;
            try
            {
                //path=%SystemRoot%\system32;%SystemRoot%;%SystemRoot%\System32\Wbem; 
                SqlDataReader read = DBHelper.GetReader(sql);
                if (read.Read())
                {
                    ReadCommonMessage mes = new ReadCommonMessage();
                    mes.ReadId = read.GetInt32(0);
                    mes.Message = MessageService.GetMessageByMessageId(read.GetInt32(1));
                    mes.User = UserInfoService.GetUserInfoByUserId(read.GetString(2));

                    read.Close();
                    return mes;
                }
                else
                {
                    read.Close();
                    return null;
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
                throw ex;
            }
        }
        public static ReadCommonMessage TouserID(string userID)
        {
            string sql = "select * from ReadCommonMessage where UserId = @userID";

            int messageId;
            string userId;
            try
            {
                SqlDataReader reader = DBHelper.GetReader(sql, new SqlParameter("@userID", userID));
                if (reader.Read())
                {
                    ReadCommonMessage rcmes = new ReadCommonMessage();
                    rcmes.ReadId = (int)reader["ReadId"];
                    messageId = (int)reader["MessageId"];
                    userId = (string)reader["UserId"];

                    reader.Close();
                    rcmes.Message = MessageService.GetMessageByMessageId(messageId);
                    rcmes.User = UserInfoService.GetUserInfoByUserId(userId);
                    return rcmes;
                }
                else
                {
                    reader.Close();
                    return null;
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
                throw ex;
            }
        }

        /// <summary>
        /// Get common message according to safe T-SQL
        /// </summary>
        /// <param name="safeSql">safeSql</param>
        /// <returns>IList<ReadCommonMessage></returns>
        private static IList<ReadCommonMessage> GetReadCommonMessageBySql(string safeSql)
        {
            List<ReadCommonMessage> list = new List<ReadCommonMessage>();
            try
            {
                DataTable table = DBHelper.GetDataSet(safeSql);
                foreach (DataRow row in table.Rows)
                {
                    ReadCommonMessage mes = new ReadCommonMessage();
                    mes.ReadId = (int)row["ReadId"];
                    mes.Message = MessageService.GetMessageByMessageId((int)row["MessageId"]);
                    mes.User = UserInfoService.GetUserInfoByUserId((string)row["UserId"]);
                    list.Add(mes);
                }
                return list;
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
                throw ex;
            }
        }
        /// <summary>
        /// Get common message according to safe T-SQL and parameter
        /// </summary>
        /// <param name="safeSql"></param>
        /// <param name="values"></param>
        /// <returns></returns>
        private static IList<ReadCommonMessage> GetReadCommonMessageBySql(string safeSql,params SqlParameter[] values)
        {
            List<ReadCommonMessage> list = new List<ReadCommonMessage>();
            try
            {
                DataTable table = DBHelper.GetDataSet(safeSql, values);
                foreach (DataRow row in table.Rows)
                {
                    ReadCommonMessage mes = new ReadCommonMessage();
                    mes.ReadId = (int)row["ReadId"];
                    mes.Message = MessageService.GetMessageByMessageId((int)row["MessageId"]);
                    mes.User = UserInfoService.GetUserInfoByUserId((string)row["UserId"]);
                    list.Add(mes);
                }
                return list;
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
                throw ex;
            }
        }
    }
}