Staff.cs 9.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338
  1. /** 版本信息模板在安装目录下,可自行修改。
  2. * staff.cs
  3. *
  4. * 功 能: N/A
  5. * 类 名: staff
  6. *
  7. * Ver 变更日期 负责人 变更内容
  8. * ───────────────────────────────────
  9. * V0.01 2024-07-27 10:51:14 N/A 初版
  10. *
  11. * Copyright (c) 2012 Maticsoft Corporation. All rights reserved.
  12. *┌──────────────────────────────────┐
  13. *│ 此技术信息为本公司机密信息,未经本公司书面同意禁止向第三方披露. │
  14. *│ 版权所有:动软卓越(北京)科技有限公司              │
  15. *└──────────────────────────────────┘
  16. */
  17. using System;
  18. using System.Data;
  19. using System.Text;
  20. using MySql.Data.MySqlClient;
  21. using Maticsoft.DBUtility;//Please add references
  22. namespace Jpsoft.DAL
  23. {
  24. /// <summary>
  25. /// 数据访问类:staff
  26. /// </summary>
  27. public partial class Staff
  28. {
  29. public Staff()
  30. {}
  31. #region BasicMethod
  32. /// <summary>
  33. /// 是否存在该记录
  34. /// </summary>
  35. public bool Exists(string id_)
  36. {
  37. StringBuilder strSql=new StringBuilder();
  38. strSql.Append("select count(1) from base_staff");
  39. strSql.Append(" where id_=@id_ ");
  40. MySqlParameter[] parameters = {
  41. new MySqlParameter("@id_", MySqlDbType.VarChar,36) };
  42. parameters[0].Value = id_;
  43. return DbHelperMySQL.Exists(strSql.ToString(),parameters);
  44. }
  45. /// <summary>
  46. /// 增加一条数据
  47. /// </summary>
  48. public bool Add(Jpsoft.Model.Staff model)
  49. {
  50. StringBuilder strSql=new StringBuilder();
  51. strSql.Append("insert into base_staff(");
  52. strSql.Append("id_,serial_number,name_,del_flag,create_by,create_time,update_by,update_time)");
  53. strSql.Append(" values (");
  54. strSql.Append("@id_,@serial_number,@name_,@del_flag,@create_by,@create_time,@update_by,@update_time)");
  55. MySqlParameter[] parameters = {
  56. new MySqlParameter("@id_", MySqlDbType.VarChar,36),
  57. new MySqlParameter("@serial_number", MySqlDbType.VarChar,10),
  58. new MySqlParameter("@name_", MySqlDbType.VarChar,100),
  59. new MySqlParameter("@del_flag", MySqlDbType.Bit),
  60. new MySqlParameter("@create_by", MySqlDbType.VarChar,36),
  61. new MySqlParameter("@create_time", MySqlDbType.Timestamp),
  62. new MySqlParameter("@update_by", MySqlDbType.VarChar,36),
  63. new MySqlParameter("@update_time", MySqlDbType.Timestamp)};
  64. parameters[0].Value = model.id_;
  65. parameters[1].Value = model.serial_number;
  66. parameters[2].Value = model.name_;
  67. parameters[3].Value = model.del_flag;
  68. parameters[4].Value = model.create_by;
  69. parameters[5].Value = model.create_time;
  70. parameters[6].Value = model.update_by;
  71. parameters[7].Value = model.update_time;
  72. int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters);
  73. if (rows > 0)
  74. {
  75. return true;
  76. }
  77. else
  78. {
  79. return false;
  80. }
  81. }
  82. /// <summary>
  83. /// 更新一条数据
  84. /// </summary>
  85. public bool Update(Jpsoft.Model.Staff model)
  86. {
  87. StringBuilder strSql=new StringBuilder();
  88. strSql.Append("update base_staff set ");
  89. strSql.Append("serial_number=@serial_number,");
  90. strSql.Append("name_=@name_,");
  91. strSql.Append("del_flag=@del_flag,");
  92. strSql.Append("create_by=@create_by,");
  93. strSql.Append("update_by=@update_by");
  94. strSql.Append(" where id_=@id_ ");
  95. MySqlParameter[] parameters = {
  96. new MySqlParameter("@serial_number", MySqlDbType.VarChar,10),
  97. new MySqlParameter("@name_", MySqlDbType.VarChar,100),
  98. new MySqlParameter("@del_flag", MySqlDbType.Bit),
  99. new MySqlParameter("@create_by", MySqlDbType.VarChar,36),
  100. new MySqlParameter("@update_by", MySqlDbType.VarChar,36),
  101. new MySqlParameter("@id_", MySqlDbType.VarChar,36)};
  102. parameters[0].Value = model.serial_number;
  103. parameters[1].Value = model.name_;
  104. parameters[2].Value = model.del_flag;
  105. parameters[3].Value = model.create_by;
  106. parameters[4].Value = model.update_by;
  107. parameters[5].Value = model.id_;
  108. int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters);
  109. if (rows > 0)
  110. {
  111. return true;
  112. }
  113. else
  114. {
  115. return false;
  116. }
  117. }
  118. /// <summary>
  119. /// 删除一条数据
  120. /// </summary>
  121. public bool Delete(string id_)
  122. {
  123. StringBuilder strSql=new StringBuilder();
  124. strSql.Append("delete from base_staff ");
  125. strSql.Append(" where id_=@id_ ");
  126. MySqlParameter[] parameters = {
  127. new MySqlParameter("@id_", MySqlDbType.VarChar,36) };
  128. parameters[0].Value = id_;
  129. int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters);
  130. if (rows > 0)
  131. {
  132. return true;
  133. }
  134. else
  135. {
  136. return false;
  137. }
  138. }
  139. /// <summary>
  140. /// 批量删除数据
  141. /// </summary>
  142. public bool DeleteList(string id_list )
  143. {
  144. StringBuilder strSql=new StringBuilder();
  145. strSql.Append("delete from base_staff ");
  146. strSql.Append(" where id_ in ("+id_list + ") ");
  147. int rows=DbHelperMySQL.ExecuteSql(strSql.ToString());
  148. if (rows > 0)
  149. {
  150. return true;
  151. }
  152. else
  153. {
  154. return false;
  155. }
  156. }
  157. /// <summary>
  158. /// 得到一个对象实体
  159. /// </summary>
  160. public Jpsoft.Model.Staff GetModel(string id_)
  161. {
  162. StringBuilder strSql=new StringBuilder();
  163. strSql.Append("select id_,serial_number,name_,del_flag,create_by,create_time,update_by,update_time from base_staff ");
  164. strSql.Append(" where id_=@id_ ");
  165. MySqlParameter[] parameters = {
  166. new MySqlParameter("@id_", MySqlDbType.VarChar,36) };
  167. parameters[0].Value = id_;
  168. Jpsoft.Model.Staff model=new Jpsoft.Model.Staff();
  169. DataSet ds=DbHelperMySQL.Query(strSql.ToString(),parameters);
  170. if(ds.Tables[0].Rows.Count>0)
  171. {
  172. return DataRowToModel(ds.Tables[0].Rows[0]);
  173. }
  174. else
  175. {
  176. return null;
  177. }
  178. }
  179. /// <summary>
  180. /// 得到一个对象实体
  181. /// </summary>
  182. public Jpsoft.Model.Staff DataRowToModel(DataRow row)
  183. {
  184. Jpsoft.Model.Staff model=new Jpsoft.Model.Staff();
  185. if (row != null)
  186. {
  187. if(row["id_"]!=null)
  188. {
  189. model.id_=row["id_"].ToString();
  190. }
  191. if(row["serial_number"]!=null)
  192. {
  193. model.serial_number=row["serial_number"].ToString();
  194. }
  195. if(row["name_"]!=null)
  196. {
  197. model.name_=row["name_"].ToString();
  198. }
  199. if(row["del_flag"]!=null && row["del_flag"].ToString()!="")
  200. {
  201. if((row["del_flag"].ToString()=="1")||(row["del_flag"].ToString().ToLower()=="true"))
  202. {
  203. model.del_flag=true;
  204. }
  205. else
  206. {
  207. model.del_flag=false;
  208. }
  209. }
  210. if(row["create_by"]!=null)
  211. {
  212. model.create_by=row["create_by"].ToString();
  213. }
  214. if(row["create_time"]!=null && row["create_time"].ToString()!="")
  215. {
  216. model.create_time=DateTime.Parse(row["create_time"].ToString());
  217. }
  218. if(row["update_by"]!=null)
  219. {
  220. model.update_by=row["update_by"].ToString();
  221. }
  222. if(row["update_time"]!=null && row["update_time"].ToString()!="")
  223. {
  224. model.update_time=DateTime.Parse(row["update_time"].ToString());
  225. }
  226. }
  227. return model;
  228. }
  229. /// <summary>
  230. /// 获得数据列表
  231. /// </summary>
  232. public DataSet GetList(string strWhere)
  233. {
  234. StringBuilder strSql=new StringBuilder();
  235. strSql.Append("select id_,serial_number,name_,del_flag,create_by,create_time,update_by,update_time ");
  236. strSql.Append(" FROM base_staff ");
  237. if(strWhere.Trim()!="")
  238. {
  239. strSql.Append(" where "+strWhere);
  240. }
  241. return DbHelperMySQL.Query(strSql.ToString());
  242. }
  243. /// <summary>
  244. /// 获取记录总数
  245. /// </summary>
  246. public int GetRecordCount(string strWhere)
  247. {
  248. StringBuilder strSql=new StringBuilder();
  249. strSql.Append("select count(1) FROM base_staff ");
  250. if(strWhere.Trim()!="")
  251. {
  252. strSql.Append(" where "+strWhere);
  253. }
  254. object obj = DbHelperMySQL.GetSingle(strSql.ToString());
  255. if (obj == null)
  256. {
  257. return 0;
  258. }
  259. else
  260. {
  261. return Convert.ToInt32(obj);
  262. }
  263. }
  264. /// <summary>
  265. /// 分页获取数据列表
  266. /// </summary>
  267. public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
  268. {
  269. StringBuilder strSql=new StringBuilder();
  270. strSql.Append("SELECT * FROM ( ");
  271. strSql.Append(" SELECT ROW_NUMBER() OVER (");
  272. if (!string.IsNullOrEmpty(orderby.Trim()))
  273. {
  274. strSql.Append("order by T." + orderby );
  275. }
  276. else
  277. {
  278. strSql.Append("order by T.id_ desc");
  279. }
  280. strSql.Append(")AS Row, T.* from base_staff T ");
  281. if (!string.IsNullOrEmpty(strWhere.Trim()))
  282. {
  283. strSql.Append(" WHERE " + strWhere);
  284. }
  285. strSql.Append(" ) TT");
  286. strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
  287. return DbHelperMySQL.Query(strSql.ToString());
  288. }
  289. /*
  290. /// <summary>
  291. /// 分页获取数据列表
  292. /// </summary>
  293. public DataSet GetList(int PageSize,int PageIndex,string strWhere)
  294. {
  295. MySqlParameter[] parameters = {
  296. new MySqlParameter("@tblName", MySqlDbType.VarChar, 255),
  297. new MySqlParameter("@fldName", MySqlDbType.VarChar, 255),
  298. new MySqlParameter("@PageSize", MySqlDbType.Int32),
  299. new MySqlParameter("@PageIndex", MySqlDbType.Int32),
  300. new MySqlParameter("@IsReCount", MySqlDbType.Bit),
  301. new MySqlParameter("@OrderType", MySqlDbType.Bit),
  302. new MySqlParameter("@strWhere", MySqlDbType.VarChar,1000),
  303. };
  304. parameters[0].Value = "base_staff";
  305. parameters[1].Value = "id_";
  306. parameters[2].Value = PageSize;
  307. parameters[3].Value = PageIndex;
  308. parameters[4].Value = 0;
  309. parameters[5].Value = 0;
  310. parameters[6].Value = strWhere;
  311. return DbHelperMySQL.RunProcedure("UP_GetRecordByPage",parameters,"ds");
  312. }*/
  313. #endregion BasicMethod
  314. #region ExtensionMethod
  315. #endregion ExtensionMethod
  316. }
  317. }