IM12345_Api demo - 代码源于 商丘市12345项目

T_Email_SendEmail.cs 15KB

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