封丘民调

T_Sys_Users.cs 11KB

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