LYZHGD_3.0/还原代码/DAL/T_SMS_SendSM...

using DBUtility;
using JAnCallCenter.Model;
using System;
using System.Configuration;
using System.Data;
using Oracle.ManagedDataAccess.Client;
using System.Text;

namespace JAnCallCenter.DAL
{
	public class T_SMS_SendSMSTask
	{
		public bool Exists(decimal SMSID)
		{
			StringBuilder strSql = new StringBuilder();
			strSql.Append("select count(1) from T_SMS_SendSMSTask");
			strSql.Append(" where SMSID=:SMSID ");
			OracleParameter[] parameters = new OracleParameter[]
			{
				new OracleParameter(":SMSID", OracleDbType.Int32, 7)
			};
			parameters[0].Value = SMSID;
			return DbHelperOra.Exists(strSql.ToString(), parameters);
		}

		public bool Add(Model.T_SMS_SendSMSTask model)
		{
			StringBuilder strSql = new StringBuilder();
			strSql.Append("insert into T_SMS_SendSMSTask(");
			strSql.Append("SMSID,TELNUM,CONTENT,COMMITTIME,STATE,SENDTIME,LASTSENTTIME,MAXSENDCOUNT,CURSENTCOUNT,INFO,SENDMODEMIMEI,F_USERID,F_CUSTOMERID,F_NAME,SENDTYPE,SMSSOURCE)");
			strSql.Append(" values (");
			strSql.Append("s_sms_sendsmstask.nextval,:TELNUM,:CONTENT,:COMMITTIME,:STATE,:SENDTIME,:LASTSENTTIME,:MAXSENDCOUNT,:CURSENTCOUNT,:INFO,:SENDMODEMIMEI,:F_USERID,:F_CUSTOMERID,:F_NAME,:SENDTYPE,:SMSSOURCE)");
			OracleParameter[] parameters = new OracleParameter[]
			{
				new OracleParameter(":TELNUM", OracleDbType.Varchar2, 20),
				new OracleParameter(":CONTENT", OracleDbType.NVarchar2),
				new OracleParameter(":COMMITTIME", OracleDbType.Date),
				new OracleParameter(":STATE", OracleDbType.Int32, 4),
				new OracleParameter(":SENDTIME", OracleDbType.Date),
				new OracleParameter(":LASTSENTTIME", OracleDbType.Date),
				new OracleParameter(":MAXSENDCOUNT", OracleDbType.Int32, 4),
				new OracleParameter(":CURSENTCOUNT", OracleDbType.Int32, 4),
				new OracleParameter(":INFO", OracleDbType.NVarchar2),
				new OracleParameter(":SENDMODEMIMEI", OracleDbType.Varchar2, 20),
				new OracleParameter(":F_USERID", OracleDbType.Int32, 4),
				new OracleParameter(":F_CUSTOMERID", OracleDbType.Int32, 4),
				new OracleParameter(":F_NAME", OracleDbType.NVarchar2),
				new OracleParameter(":SENDTYPE", OracleDbType.Int32, 4),
				new OracleParameter(":SMSSOURCE", OracleDbType.Int32, 4)
			};
			if (model.TELNUM.StartsWith("0") || model.TELNUM.StartsWith("+860"))
			{
				model.TELNUM = model.TELNUM.Substring(model.TELNUM.IndexOf("0") + 1, 11);
			}
			parameters[0].Value = model.TELNUM;
			parameters[1].Value = model.CONTENT;
			parameters[2].Value = model.COMMITTIME;
			parameters[3].Value = model.STATE;
			parameters[4].Value = model.SENDTIME;
			parameters[5].Value = model.LASTSENTTIME;
			parameters[6].Value = model.MAXSENDCOUNT;
			parameters[7].Value = model.CURSENTCOUNT;
			parameters[8].Value = model.INFO;
			parameters[9].Value = model.SENDMODEMIMEI;
			parameters[10].Value = model.F_USERID;
			parameters[11].Value = model.F_CUSTOMERID;
			parameters[12].Value = model.F_NAME;
			string chinaUnicom = ConfigurationSettings.AppSettings["chinaUnicom"].ToString();
			string chinaMobile = ConfigurationSettings.AppSettings["chinaMobile1"].ToString();
			if (chinaUnicom.IndexOf(model.TELNUM.Substring(0, 3)) > -1)
			{
				parameters[13].Value = 1;
			}
			else if (chinaMobile.IndexOf(model.TELNUM.Substring(0, 3)) > -1)
			{
				parameters[13].Value = 2;
			}
			else
			{
				parameters[13].Value = 3;
			}
			parameters[14].Value = 1;
			int rows = DbHelperOra.ExecuteSql(strSql.ToString(), parameters);
			return rows > 0;
		}

		public bool Update(Model.T_SMS_SendSMSTask model)
		{
			StringBuilder strSql = new StringBuilder();
			strSql.Append("update T_SMS_SendSMSTask set ");
			strSql.Append("TELNUM=:TELNUM,");
			strSql.Append("CONTENT=:CONTENT,");
			strSql.Append("COMMITTIME=:COMMITTIME,");
			strSql.Append("STATE=:STATE,");
			strSql.Append("SENDTIME=:SENDTIME,");
			strSql.Append("LASTSENTTIME=:LASTSENTTIME,");
			strSql.Append("MAXSENDCOUNT=:MAXSENDCOUNT,");
			strSql.Append("CURSENTCOUNT=:CURSENTCOUNT,");
			strSql.Append("INFO=:INFO,");
			strSql.Append("SENDMODEMIMEI=:SENDMODEMIMEI,");
			strSql.Append("F_USERID=:F_USERID,");
			strSql.Append("F_CUSTOMERID=:F_CUSTOMERID,");
			strSql.Append("F_NAME=:F_NAME,");
			strSql.Append("SENDTYPE=:SENDTYPE,");
			strSql.Append("SMSSOURCE=:SMSSOURCE");
			strSql.Append(" where SMSID=:SMSID ");
			OracleParameter[] parameters = new OracleParameter[]
			{
				new OracleParameter(":TELNUM", OracleDbType.Varchar2, 20),
				new OracleParameter(":CONTENT", OracleDbType.NVarchar2),
				new OracleParameter(":COMMITTIME", OracleDbType.Date),
				new OracleParameter(":STATE", OracleDbType.Int32, 4),
				new OracleParameter(":SENDTIME", OracleDbType.Date),
				new OracleParameter(":LASTSENTTIME", OracleDbType.Date),
				new OracleParameter(":MAXSENDCOUNT", OracleDbType.Int32, 4),
				new OracleParameter(":CURSENTCOUNT", OracleDbType.Int32, 4),
				new OracleParameter(":INFO", OracleDbType.NVarchar2),
				new OracleParameter(":SENDMODEMIMEI", OracleDbType.Varchar2, 20),
				new OracleParameter(":F_USERID", OracleDbType.Int32, 4),
				new OracleParameter(":F_CUSTOMERID", OracleDbType.Int32, 4),
				new OracleParameter(":F_NAME", OracleDbType.NVarchar2),
				new OracleParameter(":SENDTYPE", OracleDbType.Int32, 4),
				new OracleParameter(":SMSSOURCE", OracleDbType.Int32, 4),
				new OracleParameter(":SMSID", OracleDbType.Int32, 7)
			};
			parameters[0].Value = model.TELNUM;
			parameters[1].Value = model.CONTENT;
			parameters[2].Value = model.COMMITTIME;
			parameters[3].Value = model.STATE;
			parameters[4].Value = model.SENDTIME;
			parameters[5].Value = model.LASTSENTTIME;
			parameters[6].Value = model.MAXSENDCOUNT;
			parameters[7].Value = model.CURSENTCOUNT;
			parameters[8].Value = model.INFO;
			parameters[9].Value = model.SENDMODEMIMEI;
			parameters[10].Value = model.F_USERID;
			parameters[11].Value = model.F_CUSTOMERID;
			parameters[12].Value = model.F_NAME;
			parameters[13].Value = model.SENDTYPE;
			parameters[14].Value = model.SMSSOURCE;
			parameters[15].Value = model.SMSID;
			int rows = DbHelperOra.ExecuteSql(strSql.ToString(), parameters);
			return rows > 0;
		}

		public bool Delete(decimal SMSID)
		{
			StringBuilder strSql = new StringBuilder();
			strSql.Append("delete from T_SMS_SendSMSTask ");
			strSql.Append(" where SMSID=:SMSID ");
			OracleParameter[] parameters = new OracleParameter[]
			{
				new OracleParameter(":SMSID", OracleDbType.Int32, 7)
			};
			parameters[0].Value = SMSID;
			int rows = DbHelperOra.ExecuteSql(strSql.ToString(), parameters);
			return rows > 0;
		}

		public bool DeleteList(string SMSIDlist)
		{
			StringBuilder strSql = new StringBuilder();
			strSql.Append("delete from T_SMS_SendSMSTask ");
			strSql.Append(" where SMSID in (" + SMSIDlist + ")  ");
			int rows = DbHelperOra.ExecuteSql(strSql.ToString());
			return rows > 0;
		}

		public Model.T_SMS_SendSMSTask GetModel(decimal SMSID)
		{
			StringBuilder strSql = new StringBuilder();
			strSql.Append("select SMSID,TELNUM,CONTENT,COMMITTIME,STATE,SENDTIME,LASTSENTTIME,MAXSENDCOUNT,CURSENTCOUNT,INFO,SENDMODEMIMEI,F_USERID,F_CUSTOMERID,F_NAME,SENDTYPE,SMSSOURCE from T_SMS_SendSMSTask ");
			strSql.Append(" where SMSID=:SMSID ");
			OracleParameter[] parameters = new OracleParameter[]
			{
				new OracleParameter(":SMSID", OracleDbType.Int32, 7)
			};
			parameters[0].Value = SMSID;
            Model.T_SMS_SendSMSTask model = new Model.T_SMS_SendSMSTask();
			DataSet ds = DbHelperOra.Query(strSql.ToString(), parameters);
            Model.T_SMS_SendSMSTask result;
			if (ds.Tables[0].Rows.Count > 0)
			{
				if (ds.Tables[0].Rows[0]["SMSID"] != null && ds.Tables[0].Rows[0]["SMSID"].ToString() != "")
				{
					model.SMSID = decimal.Parse(ds.Tables[0].Rows[0]["SMSID"].ToString());
				}
				if (ds.Tables[0].Rows[0]["TELNUM"] != null && ds.Tables[0].Rows[0]["TELNUM"].ToString() != "")
				{
					model.TELNUM = ds.Tables[0].Rows[0]["TELNUM"].ToString();
				}
				if (ds.Tables[0].Rows[0]["CONTENT"] != null && ds.Tables[0].Rows[0]["CONTENT"].ToString() != "")
				{
					model.CONTENT = ds.Tables[0].Rows[0]["CONTENT"].ToString();
				}
				if (ds.Tables[0].Rows[0]["COMMITTIME"] != null && ds.Tables[0].Rows[0]["COMMITTIME"].ToString() != "")
				{
					model.COMMITTIME = DateTime.Parse(ds.Tables[0].Rows[0]["COMMITTIME"].ToString());
				}
				if (ds.Tables[0].Rows[0]["STATE"] != null && ds.Tables[0].Rows[0]["STATE"].ToString() != "")
				{
					model.STATE = decimal.Parse(ds.Tables[0].Rows[0]["STATE"].ToString());
				}
				if (ds.Tables[0].Rows[0]["SENDTIME"] != null && ds.Tables[0].Rows[0]["SENDTIME"].ToString() != "")
				{
					model.SENDTIME = new DateTime?(DateTime.Parse(ds.Tables[0].Rows[0]["SENDTIME"].ToString()));
				}
				if (ds.Tables[0].Rows[0]["LASTSENTTIME"] != null && ds.Tables[0].Rows[0]["LASTSENTTIME"].ToString() != "")
				{
					model.LASTSENTTIME = new DateTime?(DateTime.Parse(ds.Tables[0].Rows[0]["LASTSENTTIME"].ToString()));
				}
				if (ds.Tables[0].Rows[0]["MAXSENDCOUNT"] != null && ds.Tables[0].Rows[0]["MAXSENDCOUNT"].ToString() != "")
				{
					model.MAXSENDCOUNT = decimal.Parse(ds.Tables[0].Rows[0]["MAXSENDCOUNT"].ToString());
				}
				if (ds.Tables[0].Rows[0]["CURSENTCOUNT"] != null && ds.Tables[0].Rows[0]["CURSENTCOUNT"].ToString() != "")
				{
					model.CURSENTCOUNT = decimal.Parse(ds.Tables[0].Rows[0]["CURSENTCOUNT"].ToString());
				}
				if (ds.Tables[0].Rows[0]["INFO"] != null && ds.Tables[0].Rows[0]["INFO"].ToString() != "")
				{
					model.INFO = ds.Tables[0].Rows[0]["INFO"].ToString();
				}
				if (ds.Tables[0].Rows[0]["SENDMODEMIMEI"] != null && ds.Tables[0].Rows[0]["SENDMODEMIMEI"].ToString() != "")
				{
					model.SENDMODEMIMEI = ds.Tables[0].Rows[0]["SENDMODEMIMEI"].ToString();
				}
				if (ds.Tables[0].Rows[0]["F_USERID"] != null && ds.Tables[0].Rows[0]["F_USERID"].ToString() != "")
				{
					model.F_USERID = new decimal?(decimal.Parse(ds.Tables[0].Rows[0]["F_USERID"].ToString()));
				}
				if (ds.Tables[0].Rows[0]["F_CUSTOMERID"] != null && ds.Tables[0].Rows[0]["F_CUSTOMERID"].ToString() != "")
				{
					model.F_CUSTOMERID = new decimal?(decimal.Parse(ds.Tables[0].Rows[0]["F_CUSTOMERID"].ToString()));
				}
				if (ds.Tables[0].Rows[0]["F_NAME"] != null && ds.Tables[0].Rows[0]["F_NAME"].ToString() != "")
				{
					model.F_NAME = ds.Tables[0].Rows[0]["F_NAME"].ToString();
				}
				if (ds.Tables[0].Rows[0]["SENDTYPE"] != null && ds.Tables[0].Rows[0]["SENDTYPE"].ToString() != "")
				{
					model.SENDTYPE = decimal.Parse(ds.Tables[0].Rows[0]["SENDTYPE"].ToString());
				}
				if (ds.Tables[0].Rows[0]["SMSSOURCE"] != null && ds.Tables[0].Rows[0]["SMSSOURCE"].ToString() != "")
				{
					model.SMSSOURCE = new decimal?(decimal.Parse(ds.Tables[0].Rows[0]["SMSSOURCE"].ToString()));
				}
				result = model;
			}
			else
			{
				result = null;
			}
			return result;
		}

		public DataSet GetList(string strWhere)
		{
			StringBuilder strSql = new StringBuilder();
			strSql.Append("select SMSID,TELNUM,CONTENT,COMMITTIME,STATE,SENDTIME,LASTSENTTIME,MAXSENDCOUNT,CURSENTCOUNT,INFO,SENDMODEMIMEI,F_USERID,F_CUSTOMERID,F_NAME,SENDTYPE,SMSSOURCE ");
			strSql.Append(" FROM T_SMS_SendSMSTask ");
			if (strWhere.Trim() != "")
			{
				strSql.Append(" where " + strWhere);
			}
			return DbHelperOra.Query(strSql.ToString());
		}

		public int GetRecordCount(string strWhere)
		{
			StringBuilder strSql = new StringBuilder();
			strSql.Append("select count(1) FROM T_SMS_SendSMSTask ");
			if (strWhere.Trim() != "")
			{
				strSql.Append(" where " + strWhere);
			}
			object obj = DbHelperSQL.GetSingle(strSql.ToString());
			int result;
			if (obj == null)
			{
				result = 0;
			}
			else
			{
				result = Convert.ToInt32(obj);
			}
			return result;
		}

		public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
		{
			StringBuilder strSql = new StringBuilder();
			strSql.Append("SELECT * FROM ( ");
			strSql.Append(" SELECT ROW_NUMBER() OVER (");
			if (!string.IsNullOrEmpty(orderby.Trim()))
			{
				strSql.Append("order by T." + orderby);
			}
			else
			{
				strSql.Append("order by T.SMSID desc");
			}
			strSql.Append(")AS Row, T.*  from T_SMS_SendSMSTask T ");
			if (!string.IsNullOrEmpty(strWhere.Trim()))
			{
				strSql.Append(" WHERE " + strWhere);
			}
			strSql.Append(" ) TT");
			strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
			return DbHelperOra.Query(strSql.ToString());
		}
	}
}