scheduleservice.cs

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

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

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 ScheduleService
	{
        /// <summary>
        /// 
        /// </summary>
        /// <param name="schedule"></param>
        /// <returns></returns>
        public static Schedule AddSchedule(Schedule schedule)
		{
            string sql =
				"INSERT Schedule (Title, Address, MeetingId, BeginTime, EndTime, SchContent, CreateUser, CreateTime, IfPrivate)" +
				"VALUES (@Title, @Address, @MeetingId, @BeginTime, @EndTime, @SchContent, @CreateUser, @CreateTime, @IfPrivate)";
				
			sql += " ; SELECT @@IDENTITY";

            try
            {
				SqlParameter[] para = new SqlParameter[]
				{
					new SqlParameter("@CreateUser", schedule.CreateUser.UserId), //FK
					new SqlParameter("@MeetingId", schedule.Meeting.MeetingId), //FK
					new SqlParameter("@Title", schedule.Title),
					new SqlParameter("@Address", schedule.Address),
					new SqlParameter("@BeginTime", schedule.BeginTime),
					new SqlParameter("@EndTime", schedule.EndTime),
					new SqlParameter("@SchContent", schedule.SchContent),
					new SqlParameter("@CreateTime", schedule.CreateTime),
					new SqlParameter("@IfPrivate", schedule.IfPrivate)
				};
				
                int newId = DBHelper.GetScalar(sql, para);
				return GetScheduleByScheduleId(newId);
            }
            catch (Exception e)
            {
				Console.WriteLine(e.Message);
                throw e;
            }
		}
		/// <summary>
		/// 
		/// </summary>
		/// <param name="schedule"></param>
        public static void DeleteSchedule(Schedule schedule)
		{
			DeleteScheduleByScheduleId( schedule.ScheduleId );
		}
        /// <summary>
        /// 
        /// </summary>
        /// <param name="scheduleId"></param>
        public static void DeleteScheduleByScheduleId(int scheduleId)
		{
            string sql = "DELETE Schedule WHERE ScheduleId = @ScheduleId";

            try
            {
				SqlParameter[] para = new SqlParameter[]
				{
					new SqlParameter("@ScheduleId", scheduleId)
				};
			
                DBHelper.ExecuteCommand(sql, para);
            }
            catch (Exception e)
            {
				Console.WriteLine(e.Message);
				throw e;
            }
		}
		/// <summary>
		/// 
		/// </summary>
		/// <param name="schedule"></param>
        public static void ModifySchedule(Schedule schedule)
        {
            string sql =
                "UPDATE Schedule " +
                "SET " +
	                "CreateUser = @CreateUser, " + //FK
	                "MeetingId = @MeetingId, " + //FK
	                "Title = @Title, " +
	                "Address = @Address, " +
	                "BeginTime = @BeginTime, " +
	                "EndTime = @EndTime, " +
	                "SchContent = @SchContent, " +
	                "CreateTime = @CreateTime, " +
	                "IfPrivate = @IfPrivate " +
                "WHERE ScheduleId = @ScheduleId";


            try
            {
				SqlParameter[] para = new SqlParameter[]
				{
					new SqlParameter("@ScheduleId", schedule.ScheduleId),
					new SqlParameter("@CreateUser", schedule.CreateUser.UserId), //FK
					new SqlParameter("@MeetingId", schedule.Meeting.MeetingId), //FK
					new SqlParameter("@Title", schedule.Title),
					new SqlParameter("@Address", schedule.Address),
					new SqlParameter("@BeginTime", schedule.BeginTime),
					new SqlParameter("@EndTime", schedule.EndTime),
					new SqlParameter("@SchContent", schedule.SchContent),
					new SqlParameter("@CreateTime", schedule.CreateTime),
					new SqlParameter("@IfPrivate", schedule.IfPrivate)
				};

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

        }		
        /// <summary>
        /// 
        /// </summary>
        /// <returns></returns>
        public static IList<Schedule> GetAllSchedules()
        {
            string sqlAll = "SELECT * FROM Schedule";
			return GetSchedulesBySql( sqlAll );
        }
		/// <summary>
		/// 
		/// </summary>
		/// <param name="scheduleId"></param>
		/// <returns></returns>
        public static Schedule GetScheduleByScheduleId(int scheduleId)
        {
            string sql = "SELECT * FROM Schedule WHERE ScheduleId = @ScheduleId";

			string createUser;
			int meetingId;

            try
            {
                SqlDataReader reader = DBHelper.GetReader(sql, new SqlParameter("@ScheduleId", scheduleId));
                if (reader.Read())
                {
                    Schedule schedule = new Schedule();

					schedule.ScheduleId = (int)reader["ScheduleId"];
					schedule.Title = (string)reader["Title"];
					schedule.Address = (string)reader["Address"];
					schedule.BeginTime = (DateTime)reader["BeginTime"];
					schedule.EndTime = (DateTime)reader["EndTime"];
					schedule.SchContent = (string)reader["SchContent"];
					schedule.CreateTime = (DateTime)reader["CreateTime"];
					schedule.IfPrivate = (int)reader["IfPrivate"];
                    createUser = (string)reader["CreateUser"]; //FK
					meetingId = (int)reader["MeetingId"]; //FK

                    reader.Close();

					schedule.CreateUser = UserInfoService.GetUserInfoByUserId(createUser);
					schedule.Meeting = MeetingInfoService.GetMeetingInfoByMeetingId(meetingId);
					
                    return schedule;
                }
                else
                {
                    reader.Close();
                    return null;
                }
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }
        }
		

        ///根据创建的时间来查询个人日志信息
        public static Schedule GetScheduleByScheduleId(String createtime)
        {
            string sql = "SELECT * FROM Schedule WHERE CreateTime = @createtime";

            string createUser;
            int meetingId;

            try
            {
                SqlDataReader reader = DBHelper.GetReader(sql, new SqlParameter("@createtime", createtime));
                if (reader.Read())
                {
                    Schedule schedule = new Schedule();

                    schedule.ScheduleId = (int)reader["ScheduleId"];
                    schedule.Title = (string)reader["Title"];
                    schedule.Address = (string)reader["Address"];
                    schedule.BeginTime = (DateTime)reader["BeginTime"];
                    schedule.EndTime = (DateTime)reader["EndTime"];
                    schedule.SchContent = (string)reader["SchContent"];
                    schedule.CreateTime = (DateTime)reader["CreateTime"];
                    schedule.IfPrivate = (int)reader["IfPrivate"];
                    createUser = (string)reader["CreateUser"]; //FK
                    meetingId = (int)reader["MeetingId"]; //FK

                    reader.Close();

                    schedule.CreateUser = UserInfoService.GetUserInfoByUserId(createUser);
                    schedule.Meeting = MeetingInfoService.GetMeetingInfoByMeetingId(meetingId);

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

			try
			{
				DataTable table = DBHelper.GetDataSet( safeSql );
				
				foreach (DataRow row in table.Rows)
				{
					Schedule schedule = new Schedule();
					
					schedule.ScheduleId = (int)row["ScheduleId"];
					schedule.Title = (string)row["Title"];
					schedule.Address = (string)row["Address"];
					schedule.BeginTime = (DateTime)row["BeginTime"];
					schedule.EndTime = (DateTime)row["EndTime"];
					schedule.SchContent = (string)row["SchContent"];
					schedule.CreateTime = (DateTime)row["CreateTime"];
					schedule.IfPrivate = (int)row["IfPrivate"];
					schedule.CreateUser = UserInfoService.GetUserInfoByUserId((string)row["CreateUser"]); //FK
					schedule.Meeting = MeetingInfoService.GetMeetingInfoByMeetingId((int)row["MeetingId"]); //FK
	
					list.Add(schedule);
				}
	
				return list;
			}
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }

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

			try
			{
				DataTable table = DBHelper.GetDataSet( sql, values );
				
				foreach (DataRow row in table.Rows)
				{
					Schedule schedule = new Schedule();
					
					schedule.ScheduleId = (int)row["ScheduleId"];
					schedule.Title = (string)row["Title"];
					schedule.Address = (string)row["Address"];
					schedule.BeginTime = (DateTime)row["BeginTime"];
					schedule.EndTime = (DateTime)row["EndTime"];
					schedule.SchContent = (string)row["SchContent"];
					schedule.CreateTime = (DateTime)row["CreateTime"];
					schedule.IfPrivate = (int)row["IfPrivate"];
					schedule.CreateUser = UserInfoService.GetUserInfoByUserId((string)row["CreateUser"]); //FK
					schedule.Meeting = MeetingInfoService.GetMeetingInfoByMeetingId((int)row["MeetingId"]); //FK
	
					list.Add(schedule);
				}
	
				return list;
			}
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }
			
        }
		
	}
}