新野县12345_后端

T_Email_EmailList.cs 13KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372
  1. using CallCenterApi.DB;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Data;
  5. using System.Data.SqlClient;
  6. using System.Linq;
  7. using System.Text;
  8. using System.Threading.Tasks;
  9. using CallCenterApi.Model;
  10. namespace CallCenterApi.DAL
  11. {
  12. public partial class T_Email_EmailList
  13. {
  14. public T_Email_EmailList()
  15. { }
  16. #region BasicMethod
  17. /// <summary>
  18. /// 得到最大ID
  19. /// </summary>
  20. public int GetMaxId()
  21. {
  22. return DbHelperSQL.GetMaxID("E_Id", "T_Email_EmailList");
  23. }
  24. /// <summary>
  25. /// 是否存在该记录
  26. /// </summary>
  27. public bool Exists(int E_Id)
  28. {
  29. StringBuilder strSql = new StringBuilder();
  30. strSql.Append("select count(1) from T_Email_EmailList");
  31. strSql.Append(" where E_Id=@E_Id");
  32. SqlParameter[] parameters = {
  33. new SqlParameter("@E_Id", SqlDbType.Int,4)
  34. };
  35. parameters[0].Value = E_Id;
  36. return DbHelperSQL.Exists(strSql.ToString(), parameters);
  37. }
  38. /// <summary>
  39. /// 增加一条数据
  40. /// </summary>
  41. public int Add(Model.T_Email_EmailList model)
  42. {
  43. StringBuilder strSql = new StringBuilder();
  44. strSql.Append("insert into T_Email_EmailList(");
  45. strSql.Append("E_Email,E_Name,E_State,E_AddTime,F_UserId,F_UserName)");
  46. strSql.Append(" values (");
  47. strSql.Append("@E_Email,@E_Name,@E_State,@E_AddTime,@F_UserId,@F_UserName)");
  48. strSql.Append(";select @@IDENTITY");
  49. SqlParameter[] parameters = {
  50. new SqlParameter("@E_Email", SqlDbType.VarChar,100),
  51. new SqlParameter("@E_Name", SqlDbType.NVarChar,500),
  52. new SqlParameter("@E_State", SqlDbType.Int,4),
  53. new SqlParameter("@E_AddTime", SqlDbType.DateTime),
  54. new SqlParameter("@F_UserId", SqlDbType.Int,4),
  55. new SqlParameter("@F_UserName", SqlDbType.VarChar,50)};
  56. parameters[0].Value = model.E_Email;
  57. parameters[1].Value = model.E_Name;
  58. parameters[2].Value = model.E_State;
  59. parameters[3].Value = model.E_AddTime;
  60. parameters[4].Value = model.F_UserId;
  61. parameters[5].Value = model.F_UserName;
  62. object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
  63. if (obj == null)
  64. {
  65. return 0;
  66. }
  67. else
  68. {
  69. return Convert.ToInt32(obj);
  70. }
  71. }
  72. /// <summary>
  73. /// 更新一条数据
  74. /// </summary>
  75. public bool Update(Model.T_Email_EmailList model)
  76. {
  77. StringBuilder strSql = new StringBuilder();
  78. strSql.Append("update T_Email_EmailList set ");
  79. strSql.Append("E_Email=@E_Email,");
  80. strSql.Append("E_Name=@E_Name,");
  81. strSql.Append("E_State=@E_State,");
  82. strSql.Append("E_AddTime=@E_AddTime,");
  83. strSql.Append("F_UserId=@F_UserId,");
  84. strSql.Append("F_UserName=@F_UserName");
  85. strSql.Append(" where E_Id=@E_Id");
  86. SqlParameter[] parameters = {
  87. new SqlParameter("@E_Email", SqlDbType.VarChar,100),
  88. new SqlParameter("@E_Name", SqlDbType.NVarChar,500),
  89. new SqlParameter("@E_State", SqlDbType.Int,4),
  90. new SqlParameter("@E_AddTime", SqlDbType.DateTime),
  91. new SqlParameter("@F_UserId", SqlDbType.Int,4),
  92. new SqlParameter("@F_UserName", SqlDbType.VarChar,50),
  93. new SqlParameter("@E_Id", SqlDbType.Int,4)};
  94. parameters[0].Value = model.E_Email;
  95. parameters[1].Value = model.E_Name;
  96. parameters[2].Value = model.E_State;
  97. parameters[3].Value = model.E_AddTime;
  98. parameters[4].Value = model.F_UserId;
  99. parameters[5].Value = model.F_UserName;
  100. parameters[6].Value = model.E_Id;
  101. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  102. if (rows > 0)
  103. {
  104. return true;
  105. }
  106. else
  107. {
  108. return false;
  109. }
  110. }
  111. /// <summary>
  112. /// 删除一条数据
  113. /// </summary>
  114. public bool Delete(int E_Id)
  115. {
  116. StringBuilder strSql = new StringBuilder();
  117. strSql.Append("delete from T_Email_EmailList ");
  118. strSql.Append(" where E_Id=@E_Id");
  119. SqlParameter[] parameters = {
  120. new SqlParameter("@E_Id", SqlDbType.Int,4)
  121. };
  122. parameters[0].Value = E_Id;
  123. int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
  124. if (rows > 0)
  125. {
  126. return true;
  127. }
  128. else
  129. {
  130. return false;
  131. }
  132. }
  133. /// <summary>
  134. /// 批量删除数据
  135. /// </summary>
  136. public bool DeleteList(string E_Idlist)
  137. {
  138. StringBuilder strSql = new StringBuilder();
  139. strSql.Append("delete from T_Email_EmailList ");
  140. strSql.Append(" where E_Id in (" + E_Idlist + ") ");
  141. int rows = DbHelperSQL.ExecuteSql(strSql.ToString());
  142. if (rows > 0)
  143. {
  144. return true;
  145. }
  146. else
  147. {
  148. return false;
  149. }
  150. }
  151. /// <summary>
  152. /// 得到一个对象实体
  153. /// </summary>
  154. public Model.T_Email_EmailList GetModel(int E_Id)
  155. {
  156. StringBuilder strSql = new StringBuilder();
  157. strSql.Append("select top 1 E_Id,E_Email,E_Name,E_State,E_AddTime,F_UserId,F_UserName from T_Email_EmailList ");
  158. strSql.Append(" where E_Id=@E_Id");
  159. SqlParameter[] parameters = {
  160. new SqlParameter("@E_Id", SqlDbType.Int,4)
  161. };
  162. parameters[0].Value = E_Id;
  163. Model.T_Email_EmailList model = new Model.T_Email_EmailList();
  164. DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  165. if (ds.Tables[0].Rows.Count > 0)
  166. {
  167. return DataRowToModel(ds.Tables[0].Rows[0]);
  168. }
  169. else
  170. {
  171. return null;
  172. }
  173. }
  174. /// <summary>
  175. /// 得到一个对象实体 By Email
  176. /// </summary>
  177. /// <param name="e_Email"></param>
  178. /// <returns></returns>
  179. public Model.T_Email_EmailList GetModelByEmail(string E_Email)
  180. {
  181. StringBuilder strSql = new StringBuilder();
  182. strSql.Append("select top 1 E_Id,E_Email,E_Name,E_State,E_AddTime,F_UserId,F_UserName from T_Email_EmailList ");
  183. strSql.Append(" where E_Email=@E_Email");
  184. SqlParameter[] parameters = {
  185. new SqlParameter("@E_Email", SqlDbType.VarChar,100)
  186. };
  187. parameters[0].Value = E_Email;
  188. Model.T_Email_EmailList model = new Model.T_Email_EmailList();
  189. DataSet ds = DbHelperSQL.Query(strSql.ToString(), parameters);
  190. if (ds.Tables[0].Rows.Count > 0)
  191. {
  192. return DataRowToModel(ds.Tables[0].Rows[0]);
  193. }
  194. else
  195. {
  196. return null;
  197. }
  198. }
  199. /// <summary>
  200. /// 得到一个对象实体
  201. /// </summary>
  202. public Model.T_Email_EmailList DataRowToModel(DataRow row)
  203. {
  204. Model.T_Email_EmailList model = new Model.T_Email_EmailList();
  205. if (row != null)
  206. {
  207. if (row["E_Id"] != null && row["E_Id"].ToString() != "")
  208. {
  209. model.E_Id = int.Parse(row["E_Id"].ToString());
  210. }
  211. if (row["E_Email"] != null)
  212. {
  213. model.E_Email = row["E_Email"].ToString();
  214. }
  215. if (row["E_Name"] != null)
  216. {
  217. model.E_Name = row["E_Name"].ToString();
  218. }
  219. if (row["E_State"] != null && row["E_State"].ToString() != "")
  220. {
  221. model.E_State = int.Parse(row["E_State"].ToString());
  222. }
  223. if (row["E_AddTime"] != null && row["E_AddTime"].ToString() != "")
  224. {
  225. model.E_AddTime = DateTime.Parse(row["E_AddTime"].ToString());
  226. }
  227. if (row["F_UserId"] != null && row["F_UserId"].ToString() != "")
  228. {
  229. model.F_UserId = int.Parse(row["F_UserId"].ToString());
  230. }
  231. if (row["F_UserName"] != null)
  232. {
  233. model.F_UserName = row["F_UserName"].ToString();
  234. }
  235. }
  236. return model;
  237. }
  238. /// <summary>
  239. /// 获得数据列表
  240. /// </summary>
  241. public DataSet GetList(string strWhere)
  242. {
  243. StringBuilder strSql = new StringBuilder();
  244. strSql.Append("select E_Id,E_Email,E_Name,E_State,E_AddTime,F_UserId,F_UserName ");
  245. strSql.Append(" FROM T_Email_EmailList ");
  246. if (strWhere.Trim() != "")
  247. {
  248. strSql.Append(" where " + strWhere);
  249. }
  250. return DbHelperSQL.Query(strSql.ToString());
  251. }
  252. /// <summary>
  253. /// 获得前几行数据
  254. /// </summary>
  255. public DataSet GetList(int Top, string strWhere, string filedOrder)
  256. {
  257. StringBuilder strSql = new StringBuilder();
  258. strSql.Append("select ");
  259. if (Top > 0)
  260. {
  261. strSql.Append(" top " + Top.ToString());
  262. }
  263. strSql.Append(" E_Id,E_Email,E_Name,E_State,E_AddTime,F_UserId,F_UserName ");
  264. strSql.Append(" FROM T_Email_EmailList ");
  265. if (strWhere.Trim() != "")
  266. {
  267. strSql.Append(" where " + strWhere);
  268. }
  269. strSql.Append(" order by " + filedOrder);
  270. return DbHelperSQL.Query(strSql.ToString());
  271. }
  272. /// <summary>
  273. /// 获取记录总数
  274. /// </summary>
  275. public int GetRecordCount(string strWhere)
  276. {
  277. StringBuilder strSql = new StringBuilder();
  278. strSql.Append("select count(1) FROM T_Email_EmailList ");
  279. if (strWhere.Trim() != "")
  280. {
  281. strSql.Append(" where " + strWhere);
  282. }
  283. object obj = DbHelperSQL.GetSingle(strSql.ToString());
  284. if (obj == null)
  285. {
  286. return 0;
  287. }
  288. else
  289. {
  290. return Convert.ToInt32(obj);
  291. }
  292. }
  293. /// <summary>
  294. /// 分页获取数据列表
  295. /// </summary>
  296. public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
  297. {
  298. StringBuilder strSql = new StringBuilder();
  299. strSql.Append("SELECT * FROM ( ");
  300. strSql.Append(" SELECT ROW_NUMBER() OVER (");
  301. if (!string.IsNullOrEmpty(orderby.Trim()))
  302. {
  303. strSql.Append("order by T." + orderby);
  304. }
  305. else
  306. {
  307. strSql.Append("order by T.E_Id desc");
  308. }
  309. strSql.Append(")AS Row, T.* from T_Email_EmailList T ");
  310. if (!string.IsNullOrEmpty(strWhere.Trim()))
  311. {
  312. strSql.Append(" WHERE " + strWhere);
  313. }
  314. strSql.Append(" ) TT");
  315. strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
  316. return DbHelperSQL.Query(strSql.ToString());
  317. }
  318. /*
  319. /// <summary>
  320. /// 分页获取数据列表
  321. /// </summary>
  322. public DataSet GetList(int PageSize,int PageIndex,string strWhere)
  323. {
  324. SqlParameter[] parameters = {
  325. new SqlParameter("@tblName", SqlDbType.VarChar, 255),
  326. new SqlParameter("@fldName", SqlDbType.VarChar, 255),
  327. new SqlParameter("@PageSize", SqlDbType.Int),
  328. new SqlParameter("@PageIndex", SqlDbType.Int),
  329. new SqlParameter("@IsReCount", SqlDbType.Bit),
  330. new SqlParameter("@OrderType", SqlDbType.Bit),
  331. new SqlParameter("@strWhere", SqlDbType.VarChar,1000),
  332. };
  333. parameters[0].Value = "T_Email_EmailList";
  334. parameters[1].Value = "E_Id";
  335. parameters[2].Value = PageSize;
  336. parameters[3].Value = PageIndex;
  337. parameters[4].Value = 0;
  338. parameters[5].Value = 0;
  339. parameters[6].Value = strWhere;
  340. return DbHelperSQL.RunProcedure("UP_GetRecordByPage",parameters,"ds");
  341. }*/
  342. #endregion BasicMethod
  343. #region ExtensionMethod
  344. #endregion ExtensionMethod
  345. }
  346. }