using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using CallCenterApi.DB; using System.Data.SqlClient; using System.Data; namespace CallCenterApi.DAL { /// /// 数据访问类:SF_TaskDetail /// public partial class SF_TaskDetail { public SF_TaskDetail() { } #region BasicMethod /// /// 得到最大ID /// public int GetMaxId() { return DbHelperSQL.GetMaxID("ID", "SF_TaskDetail"); } /// /// 是否存在该记录 /// public bool Exists(int ID) { StringBuilder strSql = new StringBuilder(); strSql.Append("select count(1) from SF_TaskDetail"); strSql.Append(" where ID=@ID"); SqlParameter[] parameters = { new SqlParameter("@ID", SqlDbType.Int,4) }; parameters[0].Value = ID; return DbHelperSQL.Exists(strSql.ToString(), parameters); } /// /// 增加一条数据 /// public int Add(CallCenterApi.Model.SF_TaskDetail model) { StringBuilder strSql = new StringBuilder(); strSql.Append("insert into SF_TaskDetail("); strSql.Append("taskID,BINGRENZYID,sfstate)"); strSql.Append(" values ("); strSql.Append("@taskID,@BINGRENZYID,@sfstate)"); strSql.Append(";select @@IDENTITY"); SqlParameter[] parameters = { new SqlParameter("@taskID", SqlDbType.Int,4), new SqlParameter("@BINGRENZYID", SqlDbType.NVarChar,100), new SqlParameter("@sfstate", SqlDbType.NVarChar,50)}; parameters[0].Value = model.taskID; parameters[1].Value = model.BINGRENZYID; parameters[2].Value = model.sfstate; object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters); if (obj == null) { return 0; } else { return Convert.ToInt32(obj); } } /// /// 更新一条数据 /// public bool Update(CallCenterApi.Model.SF_TaskDetail model) { StringBuilder strSql = new StringBuilder(); strSql.Append("update SF_TaskDetail set "); strSql.Append("taskID=@taskID,"); strSql.Append("BINGRENZYID=@BINGRENZYID,"); strSql.Append("sfstate=@sfstate"); strSql.Append(" where ID=@ID"); SqlParameter[] parameters = { new SqlParameter("@taskID", SqlDbType.Int,4), new SqlParameter("@BINGRENZYID", SqlDbType.NVarChar,100), new SqlParameter("@sfstate", SqlDbType.NVarChar,50), new SqlParameter("@ID", SqlDbType.Int,4)}; parameters[0].Value = model.taskID; parameters[1].Value = model.BINGRENZYID; parameters[2].Value = model.sfstate; parameters[3].Value = model.ID; int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters); if (rows > 0) { return true; } else { return false; } } /// /// 删除一条数据 /// public bool Delete(int ID) { StringBuilder strSql = new StringBuilder(); strSql.Append("delete from SF_TaskDetail "); strSql.Append(" where ID=@ID"); SqlParameter[] parameters = { new SqlParameter("@ID", SqlDbType.Int,4) }; parameters[0].Value = ID; int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters); if (rows > 0) { return true; } else { return false; } } /// /// 批量删除数据 /// public bool DeleteList(string IDlist) { StringBuilder strSql = new StringBuilder(); strSql.Append("delete from SF_TaskDetail "); strSql.Append(" where ID in (" + IDlist + ") "); int rows = DbHelperSQL.ExecuteSql(strSql.ToString()); if (rows > 0) { return true; } else { return false; } } /// /// 得到一个对象实体 /// public CallCenterApi.Model.SF_TaskDetail GetModel(int ID) { StringBuilder strSql = new StringBuilder(); strSql.Append("select top 1 ID,taskID,BINGRENZYID,sfstate from SF_TaskDetail "); strSql.Append(" where ID=@ID"); SqlParameter[] parameters = { new SqlParameter("@ID", SqlDbType.Int,4) }; parameters[0].Value = ID; CallCenterApi.Model.SF_TaskDetail model = new CallCenterApi.Model.SF_TaskDetail(); 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 CallCenterApi.Model.SF_TaskDetail DataRowToModel(DataRow row) { CallCenterApi.Model.SF_TaskDetail model = new CallCenterApi.Model.SF_TaskDetail(); if (row != null) { if (row["ID"] != null && row["ID"].ToString() != "") { model.ID = int.Parse(row["ID"].ToString()); } if (row["taskID"] != null && row["taskID"].ToString() != "") { model.taskID = int.Parse(row["taskID"].ToString()); } if (row["BINGRENZYID"] != null) { model.BINGRENZYID = row["BINGRENZYID"].ToString(); } if (row["sfstate"] != null) { model.sfstate = row["sfstate"].ToString(); } } return model; } /// /// 获得数据列表 /// public DataSet GetList(string strWhere) { StringBuilder strSql = new StringBuilder(); strSql.Append("select ID,taskID,BINGRENZYID,sfstate "); strSql.Append(" FROM SF_TaskDetail "); 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(" ID,taskID,BINGRENZYID,sfstate "); strSql.Append(" FROM SF_TaskDetail "); 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 SF_TaskDetail "); 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.ID desc"); } strSql.Append(")AS Row, T.* from SF_TaskDetail 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 = "SF_TaskDetail"; parameters[1].Value = "ID"; 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 public DataTable GetALLList(string strWhere, string orderby, int startIndex, int endIndex, out int count) { StringBuilder strSqlCount = new StringBuilder(); strSqlCount.Append("SELECT count(1) FROM ( "); strSqlCount.Append(" SELECT ROW_NUMBER() OVER ("); strSqlCount.Append("order by T1.ID desc"); strSqlCount.Append(" )AS r, T1.* from SF_TaskDetail T1 "); strSqlCount.Append(" left join SF_BINGRENQK T2 on T2.BINGRENZYID=T1.BINGRENZYID"); if (!string.IsNullOrEmpty(strWhere.Trim())) { strSqlCount.Append(" WHERE " + strWhere); } strSqlCount.Append(" ) TT"); count = Convert.ToInt32(DbHelperSQL.GetSingle(strSqlCount.ToString())); StringBuilder strSql = new StringBuilder(); strSql.Append("SELECT * FROM ( "); strSql.Append(" SELECT ROW_NUMBER() OVER ("); if (!string.IsNullOrEmpty(orderby.Trim())) { strSql.Append("order by T1." + orderby); } else { strSql.Append("order by T1.ID "); } strSql.Append(" )AS r,T2.*,T1.taskID ,T1.sfstate, (SELECT TOP 1 T3.ssmc FROM sf_shoushuxx T3 WHERE T3.BINGRENZYID=T2.BINGRENZYID) ssmc from SF_TaskDetail T1 "); strSql.Append(" left join SF_BINGRENQK T2 on T2.BINGRENZYID=T1.BINGRENZYID"); if (!string.IsNullOrEmpty(strWhere.Trim())) { strSql.Append(" WHERE " + strWhere); } strSql.Append(" ) TT"); strSql.AppendFormat(" WHERE TT.r between {0} and {1}", startIndex, endIndex); DataSet ds = DbHelperSQL.Query(strSql.ToString()); if (ds != null && ds.Tables[0] != null) { if (ds.Tables[0].Rows.Count > 0) return ds.Tables[0]; } return null; } public DataTable GetALLListById(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 T1." + orderby); } else { strSql.Append("order by T1.ID "); } strSql.Append(" )AS r,T2.*,T1.taskID,T4.* from SF_TaskDetail T1 "); strSql.Append(" left join SF_BINGRENQK T2 on T2.BINGRENZYID=T1.BINGRENZYID"); strSql.Append(" left join SF_TaskResult T4 on T4.F_Id=T1.BINGRENZYID "); if (!string.IsNullOrEmpty(strWhere.Trim())) { strSql.Append(" WHERE " + strWhere); } strSql.Append(" ) TT"); strSql.AppendFormat(" WHERE TT.r between {0} and {1}", startIndex, endIndex); DataSet ds = DbHelperSQL.Query(strSql.ToString()); if (ds != null && ds.Tables[0] != null) { if (ds.Tables[0].Rows.Count > 0) return ds.Tables[0]; } return null; } /// /// 得到一个对象实体 /// public CallCenterApi.Model.SF_TaskDetail GetModelByTaskIdAndBingrenzyID(int taskID,int BINGRENZYID) { StringBuilder strSql = new StringBuilder(); strSql.Append("select top 1 ID,taskID,BINGRENZYID,sfstate from SF_TaskDetail "); strSql.Append(" where taskID=@taskID"); strSql.Append(" and BINGRENZYID=@BINGRENZYID"); SqlParameter[] parameters = { new SqlParameter("@taskID", SqlDbType.Int,4), new SqlParameter("@BINGRENZYID", SqlDbType.NVarChar,100), }; parameters[0].Value = taskID; parameters[1].Value = BINGRENZYID; CallCenterApi.Model.SF_TaskDetail model = new CallCenterApi.Model.SF_TaskDetail(); DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters); if (ds.Tables[0].Rows.Count > 0) { return DataRowToModel(ds.Tables[0].Rows[0]); } else { return null; } } #endregion ExtensionMethod } }