地铁二期项目正式开始

T_Msg_NoticeUsers.cs 12KB

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