三元财务API

T_Sys_Users.cs 11KB

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