using System; using System.Data; using System.Text; using System.Data.SqlClient; using RMYY_CallCenter_Api.DB; namespace RMYY_CallCenter_Api.DAL { /// /// 数据访问类:T_SMS_RecvSMS /// public partial class T_SMS_RecvSMS { public T_SMS_RecvSMS() { } #region BasicMethod /// /// 得到最大ID /// public int GetMaxId() { return DbHelperSQL.GetMaxID("SMSID", "T_SMS_RecvSMS"); } /// /// 是否存在该记录 /// public bool Exists(int SMSID) { StringBuilder strSql = new StringBuilder(); strSql.Append("select count(1) from T_SMS_RecvSMS"); strSql.Append(" where SMSID=@SMSID"); SqlParameter[] parameters = { new SqlParameter("@SMSID", SqlDbType.Int,4) }; parameters[0].Value = SMSID; return DbHelperSQL.Exists(strSql.ToString(), parameters); } /// /// 增加一条数据 /// public int Add(RMYY_CallCenter_Api.Model.T_SMS_RecvSMS model) { StringBuilder strSql = new StringBuilder(); strSql.Append("insert into T_SMS_RecvSMS("); strSql.Append("CallerNum,Content,RecvTime,RecvModemIMEI,F_UserID,F_CustomerID,F_Name,State)"); strSql.Append(" values ("); strSql.Append("@CallerNum,@Content,@RecvTime,@RecvModemIMEI,@F_UserID,@F_CustomerID,@F_Name,@State)"); strSql.Append(";select @@IDENTITY"); SqlParameter[] parameters = { new SqlParameter("@CallerNum", SqlDbType.VarChar,20), new SqlParameter("@Content", SqlDbType.NVarChar,-1), new SqlParameter("@RecvTime", SqlDbType.DateTime), new SqlParameter("@RecvModemIMEI", SqlDbType.VarChar,20), new SqlParameter("@F_UserID", SqlDbType.Int,4), new SqlParameter("@F_CustomerID", SqlDbType.Int,4), new SqlParameter("@F_Name", SqlDbType.NVarChar,50), new SqlParameter("@State", SqlDbType.SmallInt,2)}; parameters[0].Value = model.CallerNum; parameters[1].Value = model.Content; parameters[2].Value = model.RecvTime; parameters[3].Value = model.RecvModemIMEI; parameters[4].Value = model.F_UserID; parameters[5].Value = model.F_CustomerID; parameters[6].Value = model.F_Name; parameters[7].Value = model.State; object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters); if (obj == null) { return 0; } else { return Convert.ToInt32(obj); } } /// /// 更新一条数据 /// public bool Update(RMYY_CallCenter_Api.Model.T_SMS_RecvSMS model) { StringBuilder strSql = new StringBuilder(); strSql.Append("update T_SMS_RecvSMS set "); strSql.Append("CallerNum=@CallerNum,"); strSql.Append("Content=@Content,"); strSql.Append("RecvTime=@RecvTime,"); strSql.Append("RecvModemIMEI=@RecvModemIMEI,"); strSql.Append("F_UserID=@F_UserID,"); strSql.Append("F_CustomerID=@F_CustomerID,"); strSql.Append("F_Name=@F_Name,"); strSql.Append("State=@State"); strSql.Append(" where SMSID=@SMSID"); SqlParameter[] parameters = { new SqlParameter("@CallerNum", SqlDbType.VarChar,20), new SqlParameter("@Content", SqlDbType.NVarChar,-1), new SqlParameter("@RecvTime", SqlDbType.DateTime), new SqlParameter("@RecvModemIMEI", SqlDbType.VarChar,20), new SqlParameter("@F_UserID", SqlDbType.Int,4), new SqlParameter("@F_CustomerID", SqlDbType.Int,4), new SqlParameter("@F_Name", SqlDbType.NVarChar,50), new SqlParameter("@State", SqlDbType.SmallInt,2), new SqlParameter("@SMSID", SqlDbType.Int,4)}; parameters[0].Value = model.CallerNum; parameters[1].Value = model.Content; parameters[2].Value = model.RecvTime; parameters[3].Value = model.RecvModemIMEI; parameters[4].Value = model.F_UserID; parameters[5].Value = model.F_CustomerID; parameters[6].Value = model.F_Name; parameters[7].Value = model.State; parameters[8].Value = model.SMSID; int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters); if (rows > 0) { return true; } else { return false; } } /// /// 删除一条数据 /// public bool Delete(int SMSID) { StringBuilder strSql = new StringBuilder(); strSql.Append("delete from T_SMS_RecvSMS "); strSql.Append(" where SMSID=@SMSID"); SqlParameter[] parameters = { new SqlParameter("@SMSID", SqlDbType.Int,4) }; parameters[0].Value = SMSID; int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters); if (rows > 0) { return true; } else { return false; } } /// /// 批量删除数据 /// public bool DeleteList(string SMSIDlist) { StringBuilder strSql = new StringBuilder(); strSql.Append("delete from T_SMS_RecvSMS "); strSql.Append(" where SMSID in (" + SMSIDlist + ") "); int rows = DbHelperSQL.ExecuteSql(strSql.ToString()); if (rows > 0) { return true; } else { return false; } } /// /// 得到一个对象实体 /// public RMYY_CallCenter_Api.Model.T_SMS_RecvSMS GetModel(int SMSID) { StringBuilder strSql = new StringBuilder(); strSql.Append("select top 1 SMSID,CallerNum,Content,RecvTime,RecvModemIMEI,F_UserID,F_CustomerID,F_Name,State from T_SMS_RecvSMS "); strSql.Append(" where SMSID=@SMSID"); SqlParameter[] parameters = { new SqlParameter("@SMSID", SqlDbType.Int,4) }; parameters[0].Value = SMSID; RMYY_CallCenter_Api.Model.T_SMS_RecvSMS model = new RMYY_CallCenter_Api.Model.T_SMS_RecvSMS(); DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters); if (ds.Tables[0].Rows.Count > 0) { return DataRowToModel(ds.Tables[0].Rows[0]); } else { return null; } } /// /// 得到一个对象实体 /// public RMYY_CallCenter_Api.Model.T_SMS_RecvSMS DataRowToModel(DataRow row) { RMYY_CallCenter_Api.Model.T_SMS_RecvSMS model = new RMYY_CallCenter_Api.Model.T_SMS_RecvSMS(); if (row != null) { if (row["SMSID"] != null && row["SMSID"].ToString() != "") { model.SMSID = int.Parse(row["SMSID"].ToString()); } if (row["CallerNum"] != null) { model.CallerNum = row["CallerNum"].ToString(); } if (row["Content"] != null) { model.Content = row["Content"].ToString(); } if (row["RecvTime"] != null && row["RecvTime"].ToString() != "") { model.RecvTime = DateTime.Parse(row["RecvTime"].ToString()); } if (row["RecvModemIMEI"] != null) { model.RecvModemIMEI = row["RecvModemIMEI"].ToString(); } if (row["F_UserID"] != null && row["F_UserID"].ToString() != "") { model.F_UserID = int.Parse(row["F_UserID"].ToString()); } if (row["F_CustomerID"] != null && row["F_CustomerID"].ToString() != "") { model.F_CustomerID = int.Parse(row["F_CustomerID"].ToString()); } if (row["F_Name"] != null) { model.F_Name = row["F_Name"].ToString(); } if (row["State"] != null && row["State"].ToString() != "") { model.State = int.Parse(row["State"].ToString()); } } return model; } /// /// 获得数据列表 /// public DataSet GetList(string strWhere) { StringBuilder strSql = new StringBuilder(); strSql.Append("select SMSID,CallerNum,Content,RecvTime,RecvModemIMEI,F_UserID,F_CustomerID,F_Name,State "); strSql.Append(" FROM T_SMS_RecvSMS "); if (strWhere.Trim() != "") { strSql.Append(" where " + strWhere); } return DbHelperSQL.Query(strSql.ToString()); } /// /// 获得前几行数据 /// public DataSet GetList(int Top, string strWhere, string filedOrder) { StringBuilder strSql = new StringBuilder(); strSql.Append("select "); if (Top > 0) { strSql.Append(" top " + Top.ToString()); } strSql.Append(" SMSID,CallerNum,Content,RecvTime,RecvModemIMEI,F_UserID,F_CustomerID,F_Name,State "); strSql.Append(" FROM T_SMS_RecvSMS "); if (strWhere.Trim() != "") { strSql.Append(" where " + strWhere); } strSql.Append(" order by " + filedOrder); return DbHelperSQL.Query(strSql.ToString()); } /// /// 获取记录总数 /// public int GetRecordCount(string strWhere) { StringBuilder strSql = new StringBuilder(); strSql.Append("select count(1) FROM T_SMS_RecvSMS "); if (strWhere.Trim() != "") { strSql.Append(" where " + strWhere); } object obj = DbHelperSQL.GetSingle(strSql.ToString()); if (obj == null) { return 0; } else { return Convert.ToInt32(obj); } } /// /// 分页获取数据列表 /// 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_RecvSMS 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 DbHelperSQL.Query(strSql.ToString()); } /* /// /// 分页获取数据列表 /// public DataSet GetList(int PageSize,int PageIndex,string strWhere) { SqlParameter[] parameters = { new SqlParameter("@tblName", SqlDbType.VarChar, 255), new SqlParameter("@fldName", SqlDbType.VarChar, 255), new SqlParameter("@PageSize", SqlDbType.Int), new SqlParameter("@PageIndex", SqlDbType.Int), new SqlParameter("@IsReCount", SqlDbType.Bit), new SqlParameter("@OrderType", SqlDbType.Bit), new SqlParameter("@strWhere", SqlDbType.VarChar,1000), }; parameters[0].Value = "T_SMS_RecvSMS"; parameters[1].Value = "SMSID"; parameters[2].Value = PageSize; parameters[3].Value = PageIndex; parameters[4].Value = 0; parameters[5].Value = 0; parameters[6].Value = strWhere; return DbHelperSQL.RunProcedure("UP_GetRecordByPage",parameters,"ds"); }*/ #endregion BasicMethod #region ExtensionMethod #endregion ExtensionMethod } }