No Description

T_SMS_InternalMessages.cs 16KB

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