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

T_SMS_InternalMessages.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_SMS_InternalMessages
  12. {
  13. public T_SMS_InternalMessages()
  14. { }
  15. #region BasicMethod
  16. /// <summary>
  17. /// 得到最大ID
  18. /// </summary>
  19. public int GetMaxId()
  20. {
  21. return DbHelperSQL.GetMaxID("SMS_Id", "T_SMS_InternalMessages");
  22. }
  23. /// <summary>
  24. /// 是否存在该记录
  25. /// </summary>
  26. public bool Exists(int SMS_Id)
  27. {
  28. StringBuilder strSql = new StringBuilder();
  29. strSql.Append("select count(1) from T_SMS_InternalMessages");
  30. strSql.Append(" where SMS_Id=@SMS_Id");
  31. SqlParameter[] parameters = {
  32. new SqlParameter("@SMS_Id", SqlDbType.Int,4)
  33. };
  34. parameters[0].Value = SMS_Id;
  35. return DbHelperSQL.Exists(strSql.ToString(), parameters);
  36. }
  37. /// <summary>
  38. /// 增加一条数据
  39. /// </summary>
  40. public int Add(Model.T_SMS_InternalMessages model)
  41. {
  42. StringBuilder strSql = new StringBuilder();
  43. strSql.Append("insert into T_SMS_InternalMessages(");
  44. strSql.Append("SMS_Title,SMS_Content,SMS_ReceiveUserCode,SMS_SendUserCode,SMS_IsRead,SMS_SendTime,SMS_ReadTime,SMS_DeleteTime,SMS_IsDelete,SMS_Order,SMS_IsTop,SMS_Type)");
  45. strSql.Append(" values (");
  46. strSql.Append("@SMS_Title,@SMS_Content,@SMS_ReceiveUserCode,@SMS_SendUserCode,@SMS_IsRead,@SMS_SendTime,@SMS_ReadTime,@SMS_DeleteTime,@SMS_IsDelete,@SMS_Order,@SMS_IsTop,@SMS_Type)");
  47. strSql.Append(";select @@IDENTITY");
  48. SqlParameter[] parameters = {
  49. new SqlParameter("@SMS_Title", SqlDbType.VarChar,100),
  50. new SqlParameter("@SMS_Content", SqlDbType.NVarChar,500),
  51. new SqlParameter("@SMS_ReceiveUserCode", SqlDbType.VarChar,50),
  52. new SqlParameter("@SMS_SendUserCode", SqlDbType.VarChar,50),
  53. new SqlParameter("@SMS_IsRead", SqlDbType.Int,4),
  54. new SqlParameter("@SMS_SendTime", SqlDbType.DateTime),
  55. new SqlParameter("@SMS_ReadTime", SqlDbType.DateTime),
  56. new SqlParameter("@SMS_DeleteTime", SqlDbType.DateTime),
  57. new SqlParameter("@SMS_IsDelete", SqlDbType.Int,4),
  58. new SqlParameter("@SMS_Order", SqlDbType.Int,4),
  59. new SqlParameter("@SMS_IsTop", SqlDbType.Int,4),
  60. new SqlParameter("@SMS_Type", SqlDbType.Int,4)};
  61. parameters[0].Value = model.SMS_Title;
  62. parameters[1].Value = model.SMS_Content;
  63. parameters[2].Value = model.SMS_ReceiveUserCode;
  64. parameters[3].Value = model.SMS_SendUserCode;
  65. parameters[4].Value = model.SMS_IsRead;
  66. parameters[5].Value = model.SMS_SendTime;
  67. parameters[6].Value = model.SMS_ReadTime;
  68. parameters[7].Value = model.SMS_DeleteTime;
  69. parameters[8].Value = model.SMS_IsDelete;
  70. parameters[9].Value = model.SMS_Order;
  71. parameters[10].Value = model.SMS_IsTop;
  72. parameters[11].Value = model.SMS_Type;
  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_SMS_InternalMessages model)
  87. {
  88. StringBuilder strSql = new StringBuilder();
  89. strSql.Append("update T_SMS_InternalMessages set ");
  90. strSql.Append("SMS_Title=@SMS_Title,");
  91. strSql.Append("SMS_Content=@SMS_Content,");
  92. strSql.Append("SMS_ReceiveUserCode=@SMS_ReceiveUserCode,");
  93. strSql.Append("SMS_SendUserCode=@SMS_SendUserCode,");
  94. strSql.Append("SMS_IsRead=@SMS_IsRead,");
  95. strSql.Append("SMS_SendTime=@SMS_SendTime,");
  96. strSql.Append("SMS_ReadTime=@SMS_ReadTime,");
  97. strSql.Append("SMS_DeleteTime=@SMS_DeleteTime,");
  98. strSql.Append("SMS_IsDelete=@SMS_IsDelete,");
  99. strSql.Append("SMS_Order=@SMS_Order,");
  100. strSql.Append("SMS_IsTop=@SMS_IsTop,");
  101. strSql.Append("SMS_Type=@SMS_Type");
  102. strSql.Append(" where SMS_Id=@SMS_Id");
  103. SqlParameter[] parameters = {
  104. new SqlParameter("@SMS_Title", SqlDbType.VarChar,100),
  105. new SqlParameter("@SMS_Content", SqlDbType.NVarChar,500),
  106. new SqlParameter("@SMS_ReceiveUserCode", SqlDbType.VarChar,50),
  107. new SqlParameter("@SMS_SendUserCode", SqlDbType.VarChar,50),
  108. new SqlParameter("@SMS_IsRead", SqlDbType.Int,4),
  109. new SqlParameter("@SMS_SendTime", SqlDbType.DateTime),
  110. new SqlParameter("@SMS_ReadTime", SqlDbType.DateTime),
  111. new SqlParameter("@SMS_DeleteTime", SqlDbType.DateTime),
  112. new SqlParameter("@SMS_IsDelete", SqlDbType.Int,4),
  113. new SqlParameter("@SMS_Order", SqlDbType.Int,4),
  114. new SqlParameter("@SMS_IsTop", SqlDbType.Int,4),
  115. new SqlParameter("@SMS_Type", SqlDbType.Int,4),
  116. new SqlParameter("@SMS_Id", SqlDbType.Int,4)};
  117. parameters[0].Value = model.SMS_Title;
  118. parameters[1].Value = model.SMS_Content;
  119. parameters[2].Value = model.SMS_ReceiveUserCode;
  120. parameters[3].Value = model.SMS_SendUserCode;
  121. parameters[4].Value = model.SMS_IsRead;
  122. parameters[5].Value = model.SMS_SendTime;
  123. parameters[6].Value = model.SMS_ReadTime;
  124. parameters[7].Value = model.SMS_DeleteTime;
  125. parameters[8].Value = model.SMS_IsDelete;
  126. parameters[9].Value = model.SMS_Order;
  127. parameters[10].Value = model.SMS_IsTop;
  128. parameters[11].Value = model.SMS_Type;
  129. parameters[12].Value = model.SMS_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 SMS_Id)
  144. {
  145. StringBuilder strSql = new StringBuilder();
  146. strSql.Append("delete from T_SMS_InternalMessages ");
  147. strSql.Append(" where SMS_Id=@SMS_Id");
  148. SqlParameter[] parameters = {
  149. new SqlParameter("@SMS_Id", SqlDbType.Int,4)
  150. };
  151. parameters[0].Value = SMS_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 SMS_Idlist)
  166. {
  167. StringBuilder strSql = new StringBuilder();
  168. strSql.Append("delete from T_SMS_InternalMessages ");
  169. strSql.Append(" where SMS_Id in (" + SMS_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_SMS_InternalMessages GetModel(int SMS_Id)
  184. {
  185. StringBuilder strSql = new StringBuilder();
  186. strSql.Append("select top 1 * from T_SMS_InternalMessages ");
  187. strSql.Append(" where SMS_Id=@SMS_Id");
  188. SqlParameter[] parameters = {
  189. new SqlParameter("@SMS_Id", SqlDbType.Int,4)
  190. };
  191. parameters[0].Value = SMS_Id;
  192. Model.T_SMS_InternalMessages model = new Model.T_SMS_InternalMessages();
  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_SMS_InternalMessages DataRowToModel(DataRow row)
  207. {
  208. Model.T_SMS_InternalMessages model = new Model.T_SMS_InternalMessages();
  209. if (row != null)
  210. {
  211. if (row["SMS_Id"] != null && row["SMS_Id"].ToString() != "")
  212. {
  213. model.SMS_Id = int.Parse(row["SMS_Id"].ToString());
  214. }
  215. if (row["SMS_Title"] != null)
  216. {
  217. model.SMS_Title = row["SMS_Title"].ToString();
  218. }
  219. if (row["SMS_Content"] != null)
  220. {
  221. model.SMS_Content = row["SMS_Content"].ToString();
  222. }
  223. if (row["SMS_ReceiveUserCode"] != null)
  224. {
  225. model.SMS_ReceiveUserCode = row["SMS_ReceiveUserCode"].ToString();
  226. }
  227. if (row["SMS_SendUserCode"] != null)
  228. {
  229. model.SMS_SendUserCode = row["SMS_SendUserCode"].ToString();
  230. }
  231. if (row["SMS_IsRead"] != null && row["SMS_IsRead"].ToString() != "")
  232. {
  233. model.SMS_IsRead = int.Parse(row["SMS_IsRead"].ToString());
  234. }
  235. if (row["SMS_SendTime"] != null && row["SMS_SendTime"].ToString() != "")
  236. {
  237. model.SMS_SendTime = DateTime.Parse(row["SMS_SendTime"].ToString());
  238. }
  239. if (row["SMS_ReadTime"] != null && row["SMS_ReadTime"].ToString() != "")
  240. {
  241. model.SMS_ReadTime = DateTime.Parse(row["SMS_ReadTime"].ToString());
  242. }
  243. if (row["SMS_DeleteTime"] != null && row["SMS_DeleteTime"].ToString() != "")
  244. {
  245. model.SMS_DeleteTime = DateTime.Parse(row["SMS_DeleteTime"].ToString());
  246. }
  247. if (row["SMS_IsDelete"] != null && row["SMS_IsDelete"].ToString() != "")
  248. {
  249. model.SMS_IsDelete = int.Parse(row["SMS_IsDelete"].ToString());
  250. }
  251. if (row["SMS_Order"] != null && row["SMS_Order"].ToString() != "")
  252. {
  253. model.SMS_Order = int.Parse(row["SMS_Order"].ToString());
  254. }
  255. if (row["SMS_IsTop"] != null && row["SMS_IsTop"].ToString() != "")
  256. {
  257. model.SMS_IsTop = int.Parse(row["SMS_IsTop"].ToString());
  258. }
  259. if (row["SMS_Type"] != null && row["SMS_Type"].ToString() != "")
  260. {
  261. model.SMS_Type = int.Parse(row["SMS_Type"].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 * ");
  273. strSql.Append(" FROM T_SMS_InternalMessages ");
  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(" * ");
  292. strSql.Append(" FROM T_SMS_InternalMessages ");
  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_SMS_InternalMessages ");
  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.SMS_Id desc");
  336. }
  337. strSql.Append(")AS Row, T.* from T_SMS_InternalMessages 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_SMS_InternalMessages";
  362. parameters[1].Value = "SMS_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. }