安徽12333项目api

T_SMS_InternalMessages.cs 15KB

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