operdatabase.cs

联通短信平台

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

namespace database
{
	/// <summary>
	/// OperDatabase 的摘要说明。
	/// </summary>
	

	public class SmsDetails
	{
		public int Sms_ID;
		public string Sms_ServiceID;
		public int Sms_SeqID;
		public string Sms_MsgID;
		public int Sms_Fee_UserType;
		public string Sms_SPID;
		public string Sms_FeeType;
		public string Sms_FeeCode;
		public string Sms_SPCode;
		public string Sms_Dest_Terminal_ID;
		public int Sms_Msg_Length;
		public string Sms_Msg_Content;
	}
	public class ErrorDetails
	{
		public int ID;
		public string Information;
	
	}
	public class OperDatabase 
	{
		
		string connstr;  // = "data source=(local);initial catalog=sms;persist security info=False;user id=sa;password=123";
		SqlConnection conn;
		//sendMessage send;
		public OperDatabase()
		{
			//connstr ="data source=A-0283QBDDU7CK6;initial catalog=HSH21;persist security info=False;user id=liuyuxiang;password=5829266";
		//connstr = "Integrated Security=SSPI;Persist Security Info=False;Initial Catalog=CMPP;Data Source=HUASHEN";
		connstr ="Persist Security Info=False;Initial Catalog=SMS;UID=sa;Data Source=CXT-dev;Packet Size=4096;Workstation ID=CXT-dev;";
		//	send = new sendMessage();
			//connstr = "workstation id=HSH1;packet size=4096;user id=sa;data source=HSH1;persist security info=True;initial catalog=sms;password=123456";
		}
		

		public bool InsertMO(int nSeqId,string usMsgId,string sPCode,string sServiceId,string sSrcTel,int uRegister, int usMsgLen, string usMsgContent)
		{
			
			try
			{
				conn = new SqlConnection(connstr);
				SqlCommand comm = new SqlCommand("Insert_MO_BACK",conn);
				comm.CommandType = CommandType.StoredProcedure;
				comm.Parameters.Add("@Sms_SeqID",SqlDbType.Int,4);
				comm.Parameters.Add("@Sms_MsgID",SqlDbType.NVarChar,70);
				comm.Parameters.Add("@Sms_SPCode",SqlDbType.NVarChar,21);
				comm.Parameters.Add("@Sms_ServiceID",SqlDbType.NVarChar,20);
				comm.Parameters.Add("@Sms_SrcTel",SqlDbType.NVarChar,32);
				comm.Parameters.Add("@Sms_Register",SqlDbType.Int,4);
				comm.Parameters.Add("@Sms_MsgLen",SqlDbType.Int,4);
				comm.Parameters.Add("@Sms_Content",SqlDbType.NVarChar,70);
				
				comm.Parameters["@Sms_SeqID"].Value = nSeqId;
				comm.Parameters["@Sms_MsgID"].Value = usMsgId;
				comm.Parameters["@Sms_SPCode"].Value = sPCode;
				comm.Parameters["@Sms_ServiceID"].Value = sServiceId;
				comm.Parameters["@Sms_SrcTel"].Value = sSrcTel;
				comm.Parameters["@Sms_Register"].Value = uRegister;
				comm.Parameters["@Sms_MsgLen"].Value = usMsgLen;
				comm.Parameters["@Sms_Content"].Value = usMsgContent;
				
				conn.Open();
				comm.ExecuteNonQuery();
				conn.Close();

				conn = new SqlConnection(connstr);
				SqlCommand comm1 = new SqlCommand("Insert_MO",conn);
				comm1.CommandType = CommandType.StoredProcedure;
				comm1.Parameters.Add("@Sms_SeqID",SqlDbType.Int,4);
				comm1.Parameters.Add("@Sms_MsgID",SqlDbType.NVarChar,70);
				comm1.Parameters.Add("@Sms_SPCode",SqlDbType.NVarChar,21);
				comm1.Parameters.Add("@Sms_ServiceID",SqlDbType.NVarChar,20);
				comm1.Parameters.Add("@Sms_SrcTel",SqlDbType.NVarChar,32);
				comm1.Parameters.Add("@Sms_Register",SqlDbType.Int,4);
				comm1.Parameters.Add("@Sms_MsgLen",SqlDbType.Int,4);
				comm1.Parameters.Add("@Sms_Content",SqlDbType.NVarChar,70);
				
				comm1.Parameters["@Sms_SeqID"].Value = nSeqId;
				comm1.Parameters["@Sms_MsgID"].Value = usMsgId;
				comm1.Parameters["@Sms_SPCode"].Value = sPCode;
				comm1.Parameters["@Sms_ServiceID"].Value = sServiceId;
				comm1.Parameters["@Sms_SrcTel"].Value = sSrcTel;
				comm1.Parameters["@Sms_Register"].Value = uRegister;
				comm1.Parameters["@Sms_MsgLen"].Value = usMsgLen;
				comm1.Parameters["@Sms_Content"].Value = usMsgContent;
				
				conn.Open();
				comm1.ExecuteNonQuery();
				conn.Close();

			
				return true;
			}
			catch(Exception e)
			{
				return false;
		//send.Deliever("插入数据库失败!"+e.Message);
			}	
			
		}
		public bool InsertError(string message)
		{
			
			try
			{
				conn = new SqlConnection(connstr);
				SqlCommand comm = new SqlCommand("Insert_Error",conn);
				comm.CommandType = CommandType.StoredProcedure;
				comm.Parameters.Add("@Information",SqlDbType.NVarChar,70);
			
				comm.Parameters["@Information"].Value = message;
			
				conn.Open();
				comm.ExecuteNonQuery();
				conn.Close();
			
				return true;
			}
			catch(Exception e)
			{
				return false;
				//	send.Deliever("插入数据库失败!"+e.Message);
			}	
			
		}
		public SmsDetails  GetMT()
		{
	          
				conn = new SqlConnection("Persist Security Info=False;Initial Catalog=SMS;UID=sa;Data Source=CXT-dev;Packet Size=4096;Workstation ID=CXT-dev;");
				DataSet dataSet = new DataSet();
				conn.Open();
				SqlDataAdapter sqlDA = new SqlDataAdapter();
				SqlCommand comm = new SqlCommand("Get_MT",conn);
				comm.CommandType =CommandType.StoredProcedure;
				sqlDA.SelectCommand =comm;
				sqlDA.Fill( dataSet, "SMS" );
				conn.Close();
				
				SmsDetails details = new SmsDetails();
				// if the record was found, set the properties of the class instance
			
				if (dataSet.Tables[0].Rows.Count > 0)
				{
					try
					{
						DataRow rowNews = dataSet.Tables[0].Rows[0];
						details.Sms_ID = (int)rowNews["Sms_ID"];
						details.Sms_MsgID =rowNews["Sms_MsgID"].ToString();
						details.Sms_ServiceID = rowNews["Sms_ServiceID"].ToString();
						details.Sms_SPCode = rowNews["Sms_SPCode"].ToString();
						details.Sms_Fee_UserType = (int)rowNews["Sms_Fee_UserType"];
						details.Sms_SPID = rowNews["Sms_SPID"].ToString();
						details.Sms_FeeType = rowNews["Sms_FeeType"].ToString();
						details.Sms_FeeCode = rowNews["Sms_FeeCode"].ToString();
						details.Sms_Dest_Terminal_ID = rowNews["Sms_Dest_Terminal_Id"].ToString();
						details.Sms_Msg_Length = (int)rowNews["Sms_Msg_Length"];
						details.Sms_SeqID = (int)rowNews["Sms_SeqID"];
						details.Sms_Msg_Content = rowNews["Sms_Msg_Content"].ToString();
					}
					catch(Exception ex)
					{
					//	send.Deliever("获得数据库数据转换数据失败!"+ex.Message);
       
					}
				}
				else
					details.Sms_ID =-1;

					return details;
			
		
				
		}
		public ErrorDetails sendError()
		{
			
			conn = new SqlConnection(connstr);
			DataSet dataSet = new DataSet();
			conn.Open();
			SqlDataAdapter sqlDA1 = new SqlDataAdapter();
			SqlCommand comm = new SqlCommand("Get_Error",conn);
			comm.CommandType =CommandType.StoredProcedure;
			sqlDA1.SelectCommand =comm;
			sqlDA1.Fill(dataSet, "Error" );
			conn.Close();
				
			ErrorDetails details = new ErrorDetails();
			// if the record was found, set the properties of the class instance
			
			if (dataSet.Tables[0].Rows.Count > 0)
			{
				try
				{
					DataRow rowNews = dataSet.Tables[0].Rows[0];
					details.ID = (int)rowNews["ID"];
					details.Information =rowNews["Information"].ToString();	
				}
				catch(Exception ex)
				{
					//	send.Deliever("获得数据库数据转换数据失败!"+ex.Message);
       
				}
			}
			else
				details.ID =-1;

			return details;
		}
/*
		public SmsDetails  GetMT()
		{
			try
			{
				conn = new SqlConnection(connstr);
				DataSet dataSet = new DataSet();
				conn.Open();
				SqlDataAdapter sqlDA = new SqlDataAdapter();
				SqlCommand comm = new SqlCommand("Get_MT",conn);
				comm.CommandType =CommandType.StoredProcedure;
				sqlDA.SelectCommand =comm;
				sqlDA.Fill( dataSet, "SMS" );
				conn.Close();
				
					SmsDetails details = new SmsDetails();
					// if the record was found, set the properties of the class instance
			
					if (dataSet.Tables[0].Rows.Count > 0)
					{
						DataRow rowNews = dataSet.Tables[0].Rows[0];
						details.Sms_ID = (int)rowNews["Sms_ID"];
						details.Sms_ServiceID = rowNews["Sms_ServiceID"].ToString();
						details.Sms_SPCode = rowNews["Sms_SPCode"].ToString();
						details.Sms_Fee_UserType = (int)rowNews["Sms_Fee_UserType"];
						details.Sms_SPID = rowNews["Sms_SPID"].ToString();
						details.Sms_FeeType = rowNews["Sms_FeeType"].ToString();
						details.Sms_FeeCode = rowNews["Sms_FeeCode"].ToString();
						details.Sms_Dest_Terminal_ID = rowNews["Sms_Dest_Terminal_Id"].ToString();
						details.Sms_Msg_Length = (int)rowNews["Sms_Msg_Length"];
						details.Sms_Msg_Content = rowNews["Sms_Msg_Content"].ToString();
					}

					return details;
				
			}
			catch(DataException e)
			{
				return null;
			}		
		}
		*/
		

	}
}