task.cs

网络版的办公自动化系统 功能强大

using System;
using System.Data;
using System.Data.SqlClient;
using System.Collections;
namespace UDS.Components
{
	/// <summary>
	/// Task 
	/// </summary>
	public class Task
	{
		

		#region 添加任务
		/// <summary>
		/// 任务添加
		/// </summary>
		/// <param name="TaskClass">Task类</param>
		public string AddTask(TaskClass tc) 
		{		
			
			// create data object and params
			Database data = new Database();	
			string TaskID = "";
			SqlParameter[] prams = {
									   data.MakeInParam("@ArrangedBy",  SqlDbType.VarChar, 20, tc.ArrangedBy),
									   data.MakeInParam("@Subject",  SqlDbType.VarChar, 50, tc.Subject),
									   data.MakeInParam("@Detail",  SqlDbType.VarChar, 300, tc.Detail),
									   data.MakeInParam("@ProjectID",  SqlDbType.SmallInt,20, tc.ProjectID),
									   data.MakeInParam("@StartTime",  SqlDbType.DateTime, 20, DateTime.Parse(tc.StartTime.ToString())),
									   data.MakeInParam("@EndTime",  SqlDbType.DateTime, 20, DateTime.Parse(tc.EndTime.ToString())),
									   data.MakeInParam("@Attribute",  SqlDbType.Int, 1, tc.Attribute),
									   data.MakeInParam("@Type",  SqlDbType.Int, 1, tc.Type),
									   data.MakeInParam("@Status",  SqlDbType.Bit , 1, tc.Status),
									   data.MakeInParam("@Tag",  SqlDbType.Int, 1, tc.Tag),
									   data.MakeInParam("@IsAwake",  SqlDbType.Bit, 1, tc.IsAwake),
									   data.MakeInParam("@AwakeTime",  SqlDbType.DateTime, 20, DateTime.Parse(tc.AwakeTime)),
									   data.MakeInParam("@ContractList",  SqlDbType.NVarChar, 6000, tc.ContractList),
									   data.MakeInParam("@CooperatorList",  SqlDbType.NVarChar, 6000, tc.CooperatorList),
									   data.MakeOutParam("@InsertedTaskID", SqlDbType.Int,20) 
								   };

			try 
			{
				data.RunProc("SP_AddTask", prams);
				TaskID = prams[14].Value.ToString();
				if (TaskID == string.Empty )
					return null;
				else 
					return TaskID;
			}
			catch (Exception ex) 
			{
				Error.Log(ex.ToString());
				throw new Exception("任务添加出错!",ex);
			}
			
		}
		#endregion

		#region 添加任务评论
		/// <summary>
		/// 添加任务评论
		/// </summary>
		public bool AddTaskComment(string Username,string Comment,int TaskID) 
		{		
			
			// create data object and params
			Database data = new Database();	
			SqlParameter[] prams = {
									   data.MakeInParam("@Username",  SqlDbType.VarChar, 200, Username),
									   data.MakeInParam("@Comment",  SqlDbType.VarChar,4000, Comment),
									   data.MakeInParam("@TaskID",  SqlDbType.Int, 6, TaskID)
								   };

			try 
			{
				data.RunProc("sp_Task_AddComment", prams);
				return true;
			}
			catch (Exception ex) 
			{
				Error.Log(ex.ToString());
				throw new Exception("任务添加出错!",ex);
			}
		}
		#endregion

		#region 删除任务评论
		/// <summary>
		/// 删除任务评论
		/// </summary>
		public bool DeleteTaskComment(int ID) 
		{		
			
			// create data object and params
			Database data = new Database();	
			SqlParameter[] prams = {
									   data.MakeInParam("@ID",  SqlDbType.Int, 8, ID)
									  
								   };

			try 
			{
				data.RunProc("sp_Task_DeleteComment", prams);
				return true;
			}
			catch (Exception ex) 
			{
				Error.Log(ex.ToString());
				throw new Exception("删除任务评论出错!",ex);
			}
			
		}
		#endregion

		#region 添加任务订阅
		/// <summary>
		/// 添加任务订阅
		/// </summary>
		public bool AddTaskSubscription(string Username,string ExUsername,int TaskID,string Date) 
		{		
			
			// create data object and params
			Database data = new Database();	
			SqlParameter[] prams = {
									   data.MakeInParam("@Username",  SqlDbType.VarChar, 200, Username),
									   data.MakeInParam("@ExUsername",  SqlDbType.VarChar,200, ExUsername),
									   data.MakeInParam("@TaskID",  SqlDbType.Int, 6, TaskID),
									   data.MakeInParam("@Date",  SqlDbType.NVarChar, 30, Date)	
								   };

			try 
			{
				data.RunProc("sp_Task_AddSubscription", prams);
				return true;
			}
			catch (Exception ex) 
			{
				Error.Log(ex.ToString());
				throw new Exception("添加任务订阅出错!",ex);
			}
			
		}
		#endregion

		#region 删除任务订阅
		/// <summary>
		/// 删除任务订阅
		/// </summary>
		public bool DeleteTaskSubscription(string Username,string TaskID)
		{
			
			// 定义数据库操作类及DataReader
			Database data = new Database();
			// 执行存储过程，并返回SqlDataReader对象
			SqlParameter[] prams = {
									   data.MakeInParam("@Username",  SqlDbType.VarChar,200, Username),
									   data.MakeInParam("@TaskID",  SqlDbType.VarChar, 200, TaskID)
									 
								   };

			try 
			{
				data.RunProc("sp_Task_DeleteSubscription",prams);
				return true;				
			
			}
			catch(Exception ex)
			{
				Error.Log(ex.ToString());
                throw new Exception("删除某任务订阅出错!",ex);
			}
			finally
			{
				data.Dispose();
			}			
		}
		#endregion

		#region 添加任务至日程表
		/// <summary>
		/// 添加任务至日程表
		/// </summary>
		public bool AddTaskToSchedule(int TaskID,int PeriodID,string Username,string Date,bool IsConfirm) 
		{		
			
			Database data = new Database();	
			SqlParameter[] prams = {
									   data.MakeInParam("@TaskID",  SqlDbType.Int, 8, TaskID),
									   data.MakeInParam("@PeriodID",  SqlDbType.Int, 8, PeriodID),
									   data.MakeInParam("@Username",  SqlDbType.VarChar, 20, Username),
									   data.MakeInParam("@Date",  SqlDbType.VarChar,30, Date),
									   data.MakeInParam("@IsConfirm",  SqlDbType.Bit , 1, IsConfirm)
							 	   };

			try 
			{
				data.RunProc("SP_AddTaskToSchedule", prams);
				return true;
			}
			catch (Exception ex) 
			{
				Error.Log(ex.ToString());
				throw new Exception("任务添加至日程表出错!",ex);
			}
			
		}
		#endregion

		#region 读取工作时间段信息 SqlDataReader
		/// <summary>
		/// 返回项目相关信息
		/// </summary>
		public SqlDataReader GetPeriodInfo()
		{
			
			// 定义数据库操作类及DataReader
			Database data = new Database();
			SqlDataReader dataReader = null;
			// 执行存储过程，并返回SqlDataReader对象
			try 
			{
				data.RunProc("sp_GetPeriodInfo",out dataReader);
				return dataReader;

			}
			catch(Exception ex)
			{
				Error.Log(ex.ToString());
				throw new Exception("工作时间段信息读取出错!",ex);
			}
			finally
			{
				data	   = null;
		
			}
			
		}
		#endregion

		#region 检测日程是否冲突
		/// <summary>
		///  检测日程是否冲突
		/// </summary>
		public bool CheckExist(int PeriodID,string Username,string Date) 
		{		
			
			Database data = new Database();	
			bool IsExist = false;
			SqlParameter[] prams = {
									   data.MakeInParam("@PeriodID",  SqlDbType.Int, 8, PeriodID),
									   data.MakeInParam("@Username",  SqlDbType.VarChar, 20, Username),
									   data.MakeInParam("@Date",  SqlDbType.DateTime,30, DateTime.Parse(Date)),
									   data.MakeOutParam("@IsExist", SqlDbType.Bit ,1)
									};
			try 
			{
				data.RunProc("sp_ScheduleCheckExist", prams);
				IsExist = prams[3].Value.ToString()=="True"?true:false;
				return IsExist;
			}
			catch (Exception ex) 
			{
				Error.Log(ex.ToString());
				throw new Exception("检测冲突出错!",ex);
			}
			
		}
		#endregion

		#region 获得某用户某日的任务
		/// <summary>
		/// 获得某用户某日的任务
		/// </summary>
		public SqlDataReader GetDayTaskInSchedule(string Date,string Username)
		{
			
			// 定义数据库操作类及DataReader
			Database data = new Database();
			SqlDataReader dataReader = null;
			// 执行存储过程，并返回SqlDataReader对象
			SqlParameter[] prams = {
									   data.MakeInParam("@Username",  SqlDbType.VarChar, 20, Username),
									   data.MakeInParam("@Date",  SqlDbType.VarChar,30, Date)
								    };

			try 
			{
				data.RunProc("sp_GetDayTaskInSchedule",prams,out dataReader);
				return dataReader;

			}
			catch(Exception ex)
			{
				Error.Log(ex.ToString());
				throw new Exception("获得某用户某日的任务出错!",ex);
			}
			finally
			{
				data	   = null;
				dataReader = null;
			}
			
		}
		#endregion

		#region 获得某任务的状态
		/// <summary>
		/// 获得某任务的状态
		/// </summary>
		public SqlDataReader GetTaskStatus(int TaskID)
		{
			
			// 定义数据库操作类及DataReader
			Database data = new Database();
			SqlDataReader dataReader = null;
			// 执行存储过程，并返回SqlDataReader对象
			SqlParameter[] prams = {
									   data.MakeInParam("@TaskID",  SqlDbType.Int, 20, TaskID)
									   
								   };

			try 
			{
				data.RunProc("sp_GetTaskStatus",prams,out dataReader);
				return dataReader;

			}
			catch(Exception ex)
			{
				Error.Log(ex.ToString());
				throw new Exception("获得某任务的状态出错!",ex);
			}
			finally
			{
				data	   = null;
				dataReader = null;
			}
			
		}
		#endregion

		#region 获得某用户某任务的状态
		/// <summary>
		/// 获得某任务的状态
		/// </summary>
		public int GetTaskStatusBySomeone(int TaskID,string Username)
		{
			
			// 定义数据库操作类及DataReader
			Database data = new Database();
			SqlDataReader dataReader = null;
			// 执行存储过程，并返回SqlDataReader对象
			SqlParameter[] prams = {
									   data.MakeInParam("@TaskID",  SqlDbType.Int, 20, TaskID),
									   data.MakeInParam("@Username",  SqlDbType.NVarChar, 40, Username)	
									   
								   };

			try 
			{
				data.RunProc("sp_GetTaskStatusBySomeone",prams,out dataReader);
				if(dataReader.Read())
				{
					return Int32.Parse(dataReader[0].ToString());
				}
				else
				{
					return -1;
				}

			}
			catch(Exception ex)
			{
				Error.Log(ex.ToString());
				throw new Exception("获得某任务的状态出错!",ex);
			}
			finally
			{
				data	   = null;
				dataReader = null;
			}
			
		}
		#endregion

		#region 获得任务的评论列表
		/// <summary>
		/// 获得任务的评论列表
		/// </summary>
		public SqlDataReader GetTaskComment(int TaskID)
		{
			
			// 定义数据库操作类及DataReader
			Database data = new Database();
			SqlDataReader dataReader = null;
			// 执行存储过程，并返回SqlDataReader对象
			SqlParameter[] prams = {
									   data.MakeInParam("@TaskID",  SqlDbType.Int, 20, TaskID)
								   };

			try 
			{
				data.RunProc("sp_GetTaskComment",prams,out dataReader);
				return dataReader;

			}
			catch(Exception ex)
			{
				Error.Log(ex.ToString());
				throw new Exception("获得任务的评论列表出错!",ex);
			}
			finally
			{
				data	   = null;
				dataReader = null;
			}
			
		}
		#endregion

		#region 处理任务
		/// <summary>
		/// 接受日程
		/// </summary>
		public SqlDataReader DealTask(string IDS,int opt,string username,string date)
		{
			
			// 定义数据库操作类及DataReader
			Database data = new Database();
			SqlDataReader dataReader = null;
			// 执行存储过程，并返回SqlDataReader对象
			SqlParameter[] prams = {
									   data.MakeInParam("@IDS",  SqlDbType.VarChar, 2000, IDS),
									   data.MakeInParam("@opt",  SqlDbType.Int, 1, opt),
									   data.MakeInParam("@username",  SqlDbType.VarChar, 30, username)
								//	   data.MakeInParam("@date",  SqlDbType.VarChar, 40, date)
									};

			try 
			{
				data.RunProc("sp_DealTask",prams,out dataReader);
				return dataReader;

			}
			catch(Exception ex)
			{
				Error.Log(ex.ToString());
				throw new Exception("处理日程出错!",ex);
			}
			finally
			{
				data	   = null;
				dataReader = null;
			}