mrbaseinf.cs

专业的办公oa代码下载 c#语言编写 三层结构

using System;
using System.Data;
using System.Data.SqlClient;


using qminoa.Common.Data;

namespace qminoa.DA
{
	public class MrBaseInf :IDisposable
	{
		private string conStr ;
		private SqlConnection con ;
		private SqlDataAdapter commandAdp ;

		private string paramChg(string str)
		{
			str = "@"+str;
			return str;
		}

		public DataSet GetEmpConData_By_ConID(int conID)
		{
			SqlCommand command = new SqlCommand();
			command.CommandText = "GetEmpConInfByConID";
			command.CommandType = CommandType.StoredProcedure;
			command.Connection = con;

			SqlParameter param = new SqlParameter(paramChg(EmpConData.CONID_FIELD),SqlDbType.Int);
			param.Value = conID;
			command.Parameters.Add(param);

			commandAdp.SelectCommand = command;
			DataSet data = new DataSet();
			try
			{
				commandAdp.Fill(data);
			}
			catch(Exception ex)
			{
				throw new ApplicationException(ex.ToString());
			}
			return data;
		}

		public bool UpdateMrContact(EmpConData empData)
		{
			SqlCommand command = new SqlCommand();
			command.CommandText = "UpdateMrContact";
			command.CommandType = CommandType.StoredProcedure;
			command.Connection = con;

			command.Parameters.Add(paramChg(EmpConData.CONID_FIELD),SqlDbType.Int);
			command.Parameters.Add(paramChg(EmpConData.CATETORY_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpConData.FDATE_FIELD),SqlDbType.DateTime);
			command.Parameters.Add(paramChg(EmpConData.TDATE_FIELD),SqlDbType.DateTime);
			command.Parameters.Add(paramChg(EmpConData.POSILEVL_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpConData.SALALEVL_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpConData.ANNSALA_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpConData.STATUS_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpConData.CONNOTE_FIELD),SqlDbType.Text);
			command.Parameters[paramChg(EmpConData.CONID_FIELD)].SourceColumn = EmpConData.CONID_FIELD;
			command.Parameters[paramChg(EmpConData.CATETORY_FIELD)].SourceColumn = EmpConData.CATETORY_FIELD;
			command.Parameters[paramChg(EmpConData.FDATE_FIELD)].SourceColumn = EmpConData.FDATE_FIELD;
			command.Parameters[paramChg(EmpConData.TDATE_FIELD)].SourceColumn = EmpConData.TDATE_FIELD;
			command.Parameters[paramChg(EmpConData.POSILEVL_FIELD)].SourceColumn = EmpConData.POSILEVL_FIELD;
			command.Parameters[paramChg(EmpConData.SALALEVL_FIELD)].SourceColumn = EmpConData.SALALEVL_FIELD;
			command.Parameters[paramChg(EmpConData.ANNSALA_FIELD)].SourceColumn = EmpConData.ANNSALA_FIELD;
			command.Parameters[paramChg(EmpConData.STATUS_FIELD)].SourceColumn = EmpConData.STATUS_FIELD;
			command.Parameters[paramChg(EmpConData.CONNOTE_FIELD)].SourceColumn = EmpConData.CONNOTE_FIELD;
			
			commandAdp.UpdateCommand = command;
			commandAdp.Update(empData,EmpConData.EMPCONTACT_TABLE_NAME);

			if(empData.HasErrors)
			{
				empData.Tables[EmpBaseData.EMP_TABLE_NAME].GetErrors()[0].ClearErrors();
				return false;
			}
			else
			{
				empData.AcceptChanges();
				return true;
			}
		}

		public bool InsertMrContact(EmpConData empData)
		{
			SqlCommand command = new SqlCommand();
			command.CommandText = "InsertMrContact";
			command.CommandType = CommandType.StoredProcedure;
			command.Connection = con;

			command.Parameters.Add(paramChg(EmpBaseData.EMPID_FIELD),SqlDbType.Int);
			command.Parameters.Add(paramChg(EmpConData.CATETORY_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpConData.FDATE_FIELD),SqlDbType.DateTime);
			command.Parameters.Add(paramChg(EmpConData.TDATE_FIELD),SqlDbType.DateTime);
			command.Parameters.Add(paramChg(EmpConData.POSILEVL_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpConData.SALALEVL_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpConData.ANNSALA_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpConData.STATUS_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpConData.CONNOTE_FIELD),SqlDbType.Text);
			command.Parameters[paramChg(EmpBaseData.EMPID_FIELD)].SourceColumn = EmpBaseData.EMPID_FIELD;
			command.Parameters[paramChg(EmpConData.CATETORY_FIELD)].SourceColumn = EmpConData.CATETORY_FIELD;
			command.Parameters[paramChg(EmpConData.FDATE_FIELD)].SourceColumn = EmpConData.FDATE_FIELD;
			command.Parameters[paramChg(EmpConData.TDATE_FIELD)].SourceColumn = EmpConData.TDATE_FIELD;
			command.Parameters[paramChg(EmpConData.POSILEVL_FIELD)].SourceColumn = EmpConData.POSILEVL_FIELD;
			command.Parameters[paramChg(EmpConData.SALALEVL_FIELD)].SourceColumn = EmpConData.SALALEVL_FIELD;
			command.Parameters[paramChg(EmpConData.ANNSALA_FIELD)].SourceColumn = EmpConData.ANNSALA_FIELD;
			command.Parameters[paramChg(EmpConData.STATUS_FIELD)].SourceColumn = EmpConData.STATUS_FIELD;
			command.Parameters[paramChg(EmpConData.CONNOTE_FIELD)].SourceColumn = EmpConData.CONNOTE_FIELD;
			
			commandAdp.InsertCommand = command;

			commandAdp.Update(empData,EmpConData.EMPCONTACT_TABLE_NAME);

			if(empData.HasErrors)
			{
				empData.Tables[EmpBaseData.EMP_TABLE_NAME].GetErrors()[0].ClearErrors();
				return false;
			}
			else
			{
				empData.AcceptChanges();
				return true;
			}
		}

		public bool DeleteMrContact(int conID)
		{
			SqlCommand command = new SqlCommand();
			command.CommandText = "DeleteMrContact";
			command.CommandType = CommandType.StoredProcedure;
			command.Connection = con;

			SqlParameter param = new SqlParameter(paramChg(EmpConData.CONID_FIELD),SqlDbType.Int);
			param.Value = conID;
			command.Parameters.Add(param);

			con.Open();
			int result = command.ExecuteNonQuery();
			con.Close();
			if(result>0)
			{
				return true;
			}
			else
			{
				return false;
			}

		}

		public DataSet GetEmpConData(int empID)
		{
			SqlCommand command = new SqlCommand();
			command.CommandText = "GetEmpConInf";
			command.CommandType = CommandType.StoredProcedure;
			command.Connection = con;

			SqlParameter param = new SqlParameter(paramChg(EmpBaseData.EMPID_FIELD),SqlDbType.Int);
			param.Value = empID;
			command.Parameters.Add(param);

			commandAdp.SelectCommand = command;
			DataSet data = new DataSet();
			try
			{
				commandAdp.Fill(data);
			}
			catch(Exception ex)
			{
				throw new ApplicationException(ex.ToString());
			}
			return data;

		}

		public bool InsertMrArchive(EmpArcData empData)
		{
			SqlCommand command = new SqlCommand();
			command.CommandText = "InsertMrArchive";
			command.CommandType = CommandType.StoredProcedure;
			command.Connection = con;

			command.Parameters.Add(paramChg(EmpBaseData.EMPID_FIELD),SqlDbType.Int);
			command.Parameters.Add(paramChg(EmpArcData.CATETORY_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpArcData.FDATE_FIELD),SqlDbType.DateTime);
			command.Parameters.Add(paramChg(EmpArcData.TDATE_FIELD),SqlDbType.DateTime);
			command.Parameters.Add(paramChg(EmpArcData.BRANAME_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpArcData.DEPNAME_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpArcData.POSITION_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpArcData.REASON_FIELD),SqlDbType.Text);
			command.Parameters.Add(paramChg(EmpArcData.ARCNOTE_FIELD),SqlDbType.Text);

			command.Parameters[paramChg(EmpBaseData.EMPID_FIELD)].SourceColumn = EmpBaseData.EMPID_FIELD;
			command.Parameters[paramChg(EmpArcData.CATETORY_FIELD)].SourceColumn = EmpArcData.CATETORY_FIELD;
			command.Parameters[paramChg(EmpArcData.FDATE_FIELD)].SourceColumn = EmpArcData.FDATE_FIELD;
			command.Parameters[paramChg(EmpArcData.TDATE_FIELD)].SourceColumn = EmpArcData.TDATE_FIELD;
			command.Parameters[paramChg(EmpArcData.BRANAME_FIELD)].SourceColumn = EmpArcData.BRANAME_FIELD;
			command.Parameters[paramChg(EmpArcData.DEPNAME_FIELD)].SourceColumn = EmpArcData.DEPNAME_FIELD;
			command.Parameters[paramChg(EmpArcData.POSITION_FIELD)].SourceColumn = EmpArcData.POSITION_FIELD;
			command.Parameters[paramChg(EmpArcData.REASON_FIELD)].SourceColumn = EmpArcData.REASON_FIELD;
			command.Parameters[paramChg(EmpArcData.ARCNOTE_FIELD)].SourceColumn = EmpArcData.ARCNOTE_FIELD;

			commandAdp.InsertCommand = command;

			commandAdp.Update(empData,EmpArcData.EMPARCHIVE_TABLE_NAME);

			if(empData.HasErrors)
			{
				empData.Tables[EmpBaseData.EMP_TABLE_NAME].GetErrors()[0].ClearErrors();
				return false;
			}
			else
			{
				empData.AcceptChanges();
				return true;
			}
		}

		public bool UpdateMrArchive(EmpArcData empData)
		{
			SqlCommand command = new SqlCommand();
			command.CommandText = "UpdateMrArchive";
			command.CommandType = CommandType.StoredProcedure;
			command.Connection = con;

			command.Parameters.Add(paramChg(EmpArcData.ARCID_FIELD),SqlDbType.Int);
			command.Parameters.Add(paramChg(EmpArcData.CATETORY_FIELD),SqlDbType.VarChar)  ;
				command.Parameters.Add(paramChg(EmpArcData.FDATE_FIELD),SqlDbType.DateTime);
			command.Parameters.Add(paramChg(EmpArcData.TDATE_FIELD),SqlDbType.DateTime);
			command.Parameters.Add(paramChg(EmpArcData.BRANAME_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpArcData.DEPNAME_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpArcData.POSITION_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpArcData.REASON_FIELD),SqlDbType.Text);
			command.Parameters.Add(paramChg(EmpArcData.ARCNOTE_FIELD),SqlDbType.Text);
			//
			//
			//
			command.Parameters[paramChg(EmpArcData.ARCID_FIELD)].SourceColumn = EmpArcData.ARCID_FIELD;
			command.Parameters[paramChg(EmpArcData.CATETORY_FIELD)].SourceColumn = EmpArcData.CATETORY_FIELD;
			command.Parameters[paramChg(EmpArcData.FDATE_FIELD)].SourceColumn = EmpArcData.FDATE_FIELD;
			command.Parameters[paramChg(EmpArcData.TDATE_FIELD)].SourceColumn = EmpArcData.TDATE_FIELD;
			command.Parameters[paramChg(EmpArcData.BRANAME_FIELD)].SourceColumn = EmpArcData.BRANAME_FIELD;
			command.Parameters[paramChg(EmpArcData.DEPNAME_FIELD)].SourceColumn = EmpArcData.DEPNAME_FIELD;
			command.Parameters[paramChg(EmpArcData.POSITION_FIELD)].SourceColumn = EmpArcData.POSITION_FIELD;
			command.Parameters[paramChg(EmpArcData.REASON_FIELD)].SourceColumn = EmpArcData.REASON_FIELD;
			command.Parameters[paramChg(EmpArcData.ARCNOTE_FIELD)].SourceColumn = EmpArcData.ARCNOTE_FIELD;

			commandAdp.UpdateCommand = command;

			commandAdp.Update(empData,EmpArcData.EMPARCHIVE_TABLE_NAME);

			if(empData.HasErrors)
			{
				empData.Tables[EmpBaseData.EMP_TABLE_NAME].GetErrors()[0].ClearErrors();
				return false;
			}
			else
			{
				empData.AcceptChanges();
				return true;
			}
		}

		public DataSet GetEmpArcData_By_ArcID(int arcID)
		{
			SqlCommand command = new SqlCommand();
			command.CommandText = "GetEmpArcInfByArcID";
			command.CommandType = CommandType.StoredProcedure;
			command.Connection = con;

			SqlParameter param = new SqlParameter(paramChg(EmpArcData.ARCID_FIELD),SqlDbType.Int);
			param.Value = arcID;
			command.Parameters.Add(param);

			commandAdp.SelectCommand = command;
			DataSet data = new DataSet();
			try
			{
				commandAdp.Fill(data);
			}
			catch(Exception ex)
			{
				throw new ApplicationException(ex.ToString());
			}
			return data;
		}

		public bool DeleteMrArchive(int arcID)
		{
			SqlCommand command = new SqlCommand();
			command.CommandText = "DeleteMrArchive";
			command.CommandType = CommandType.StoredProcedure;
			command.Connection = con;

			SqlParameter param = new SqlParameter(paramChg(EmpArcData.ARCID_FIELD),SqlDbType.Int);
			param.Value = arcID;
			command.Parameters.Add(param);

			con.Open();
			int result = command.ExecuteNonQuery();
			con.Close();
			if(result>0)
			{
				return true;
			}
			else
			{
				return false;
			}
		}

		public bool UpdateMrVita(EmpVisaData empData)
		{
			SqlCommand command = new SqlCommand();
			command.CommandText = "UpdateMrVita";
			command.CommandType = CommandType.StoredProcedure;
			command.Connection = con;

			command.Parameters.Add(paramChg(EmpVisaData.VISAID_FIELD),SqlDbType.Int);
			command.Parameters.Add(paramChg(EmpVisaData.FDATE_FIELD),SqlDbType.DateTime);
			command.Parameters.Add(paramChg(EmpVisaData.TDATE_FIELD),SqlDbType.DateTime);
			command.Parameters.Add(paramChg(EmpVisaData.COMMPANY_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpVisaData.DEPNAME_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpVisaData.POSITION_FIELD),SqlDbType.VarChar);
			command.Parameters.Add(paramChg(EmpVisaData.VISANOTE_FIELD),SqlDbType.Text);
			//
			//
			//
			command.Parameters[paramChg(EmpVisaData.VISAID_FIELD)].SourceColumn = EmpVisaData.VISAID_FIELD;
			command.Parameters[paramChg(EmpVisaData.FDATE_FIELD)].SourceColumn = EmpVisaData.FDATE_FIELD;
			command.Parameters[paramChg(EmpVisaData.TDATE_FIELD)].SourceColumn = EmpVisaData.TDATE_FIELD;
			command.Parameters[paramChg(EmpVisaData.COMMPANY_FIELD)].SourceColumn = EmpVisaData.COMMPANY_FIELD;
			command.Parameters[paramChg(EmpVisaData.DEPNAME_FIELD)].SourceColumn = EmpVisaData.DEPNAME_FIELD;
			command.Parameters[paramChg(EmpVisaData.POSITION_FIELD)].SourceColumn = EmpVisaData.POSITION_FIELD;
			command.Parameters[paramChg(EmpVisaData.VISANOTE_FIELD)].SourceColumn = EmpVisaData.VISANOTE_FIELD;

			commandAdp.UpdateCommand = command;

			commandAdp.Update(empData,EmpVisaData.EMPVISA_TABLE_NAME);

			if(empData.HasErrors)
			{
				empData.Tables[EmpBaseData.EMP_TABLE_NAME].GetErrors()[0].ClearErrors();
				return false;
			}
			else
			{
				empData.AcceptChanges();
				return true;
			}


		}

		public bool InsertMrVita(EmpVisaData empData)
		{