cngpfee.cs

网通网关Cngp

using System;
using System.Data;
using System.Data.OleDb;
using System.Collections;
using System.Timers;
using WriteLog;
namespace Cngp
{
	/// <summary>
	/// 从数据库中取出
	/// </summary>
	public class CngpFee
	{
		private OleDbConnection Conn;	
	
		public CngpFee()
		{
			Conn=new OleDbConnection("Provider=OraOLEDB.Oracle.1;Password=sjc600;Persist Security Info=True;User ID=cnc" +
				";Data Source=ora2003;Extended Properties=\"\";Pooling=true");
			//fee Struct
			
		}

		/// <summary>
		/// 从数据库中获取计费信息，只取1条
		/// </summary>
		/// <param name="mobileid">用户手机号码</param>
		/// <param name="content">发送内容</param>
		/// <param name="feetype">计费类型</param>
		/// <param name="feecode">计费代码</param>
		/// <param name="serviceid">栏目代码</param>
		/// <param name="sourceid">下发代码</param>
		public void GetFee(
			ref string mobileid,
			ref string content,
			ref string feetype,
			ref string feecode,
			ref string serviceid,
			ref string sourceid
			)
		{
			try
			{
				OleDbCommand Cmd=Conn.CreateCommand();
				Cmd.CommandType=CommandType.StoredProcedure;
				Cmd.CommandText="procedure_GetFee";
				if(Conn.State==ConnectionState.Closed)
				{
					Conn.Open();
				}
				//parameter
				OleDbParameter paraMobileid=new OleDbParameter("@mobileid",OleDbType.VarChar,15);
				OleDbParameter paraContent=new OleDbParameter("@content",OleDbType.VarChar,45);
				OleDbParameter paraFeetype=new OleDbParameter("@feetype",OleDbType.VarChar,2);
				OleDbParameter paraFeecode=new OleDbParameter("@feecode",OleDbType.VarChar,6);
				OleDbParameter paraServiceid=new OleDbParameter("@serviceid",OleDbType.VarChar,10);
				OleDbParameter paraSourceid=new OleDbParameter("@sourceid",OleDbType.VarChar,5);
				paraMobileid.Direction=ParameterDirection.Output;
				paraContent.Direction=ParameterDirection.Output;
				paraFeetype.Direction=ParameterDirection.Output;
				paraFeecode.Direction=ParameterDirection.Output;
				paraServiceid.Direction=ParameterDirection.Output;
				paraSourceid.Direction=ParameterDirection.Output;
				//add to command
				Cmd.Parameters.Add(paraMobileid);
				Cmd.Parameters.Add(paraContent);
				Cmd.Parameters.Add(paraFeetype);
				Cmd.Parameters.Add(paraFeecode);
				Cmd.Parameters.Add(paraServiceid);
				Cmd.Parameters.Add(paraSourceid);
				//execute
				Cmd.ExecuteNonQuery();
				//get value
				mobileid=Cmd.Parameters["@mobileid"].Value.ToString().Replace("\0","");
				content=Cmd.Parameters["@content"].Value.ToString().Replace("\0","");
				feetype=Cmd.Parameters["@feetype"].Value.ToString();
				feecode=Cmd.Parameters["@feecode"].Value.ToString();
				serviceid=Cmd.Parameters["@serviceid"].Value.ToString().Replace("\0","");
				sourceid=Cmd.Parameters["@sourceid"].Value.ToString().Replace("\0","");
			}
			catch(Exception ex)
			{
				Logs.writeLog(ex.Message.ToString(),false);
			}
			finally
			{
				if(Conn.State==ConnectionState.Open)
				{
					Conn.Close();
				}
			}
		}
		
		/// <summary>
		///  判断有没有没有发送的信息
		/// </summary>
		/// <returns></returns>
		public bool IfNoData()
		{
			if(Conn.State==ConnectionState.Closed)
			{
				Conn.Open();
			}
			OleDbCommand cmd=Conn.CreateCommand();
			cmd.CommandText="select count(*) from realtime_sendmessage where processflag=0";
			int Count=Convert.ToInt16(cmd.ExecuteScalar().ToString());
			if(Count==0)
			{
				return true;
			}
			else
			{
				return false;
			}
		}

	}
}