Customer.cs 9.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347
  1. /** 版本信息模板在安装目录下,可自行修改。
  2. * customer.cs
  3. *
  4. * 功 能: N/A
  5. * 类 名: customer
  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. /// 数据访问类:customer
  26. /// </summary>
  27. public partial class Customer
  28. {
  29. public Customer()
  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_customer");
  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.Customer model)
  49. {
  50. StringBuilder strSql=new StringBuilder();
  51. strSql.Append("insert into base_customer(");
  52. strSql.Append("id_,company_,name_,phone_,del_flag,create_by,create_time,update_by,update_time)");
  53. strSql.Append(" values (");
  54. strSql.Append("@id_,@company_,@name_,@phone_,@del_flag,@create_by,@create_time,@update_by,@update_time)");
  55. MySqlParameter[] parameters = {
  56. new MySqlParameter("@id_", MySqlDbType.VarChar,36),
  57. new MySqlParameter("@company_", MySqlDbType.VarChar,100),
  58. new MySqlParameter("@name_", MySqlDbType.VarChar,100),
  59. new MySqlParameter("@phone_", MySqlDbType.VarChar,100),
  60. new MySqlParameter("@del_flag", MySqlDbType.Bit),
  61. new MySqlParameter("@create_by", MySqlDbType.VarChar,36),
  62. new MySqlParameter("@create_time", MySqlDbType.Timestamp),
  63. new MySqlParameter("@update_by", MySqlDbType.VarChar,36),
  64. new MySqlParameter("@update_time", MySqlDbType.Timestamp)};
  65. parameters[0].Value = model.id_;
  66. parameters[1].Value = model.company_;
  67. parameters[2].Value = model.name_;
  68. parameters[3].Value = model.phone_;
  69. parameters[4].Value = model.del_flag;
  70. parameters[5].Value = model.create_by;
  71. parameters[6].Value = model.create_time;
  72. parameters[7].Value = model.update_by;
  73. parameters[8].Value = model.update_time;
  74. int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters);
  75. if (rows > 0)
  76. {
  77. return true;
  78. }
  79. else
  80. {
  81. return false;
  82. }
  83. }
  84. /// <summary>
  85. /// 更新一条数据
  86. /// </summary>
  87. public bool Update(Jpsoft.Model.Customer model)
  88. {
  89. StringBuilder strSql=new StringBuilder();
  90. strSql.Append("update base_customer set ");
  91. strSql.Append("company_=@company_,");
  92. strSql.Append("name_=@name_,");
  93. strSql.Append("phone_=@phone_,");
  94. strSql.Append("del_flag=@del_flag,");
  95. strSql.Append("create_by=@create_by,");
  96. strSql.Append("update_by=@update_by");
  97. strSql.Append(" where id_=@id_ ");
  98. MySqlParameter[] parameters = {
  99. new MySqlParameter("@company_", MySqlDbType.VarChar,100),
  100. new MySqlParameter("@name_", MySqlDbType.VarChar,100),
  101. new MySqlParameter("@phone_", MySqlDbType.VarChar,100),
  102. new MySqlParameter("@del_flag", MySqlDbType.Bit),
  103. new MySqlParameter("@create_by", MySqlDbType.VarChar,36),
  104. new MySqlParameter("@update_by", MySqlDbType.VarChar,36),
  105. new MySqlParameter("@id_", MySqlDbType.VarChar,36)};
  106. parameters[0].Value = model.company_;
  107. parameters[1].Value = model.name_;
  108. parameters[2].Value = model.phone_;
  109. parameters[3].Value = model.del_flag;
  110. parameters[4].Value = model.create_by;
  111. parameters[5].Value = model.update_by;
  112. parameters[6].Value = model.id_;
  113. int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters);
  114. if (rows > 0)
  115. {
  116. return true;
  117. }
  118. else
  119. {
  120. return false;
  121. }
  122. }
  123. /// <summary>
  124. /// 删除一条数据
  125. /// </summary>
  126. public bool Delete(string id_)
  127. {
  128. StringBuilder strSql=new StringBuilder();
  129. strSql.Append("delete from base_customer ");
  130. strSql.Append(" where id_=@id_ ");
  131. MySqlParameter[] parameters = {
  132. new MySqlParameter("@id_", MySqlDbType.VarChar,36) };
  133. parameters[0].Value = id_;
  134. int rows=DbHelperMySQL.ExecuteSql(strSql.ToString(),parameters);
  135. if (rows > 0)
  136. {
  137. return true;
  138. }
  139. else
  140. {
  141. return false;
  142. }
  143. }
  144. /// <summary>
  145. /// 批量删除数据
  146. /// </summary>
  147. public bool DeleteList(string id_list )
  148. {
  149. StringBuilder strSql=new StringBuilder();
  150. strSql.Append("delete from base_customer ");
  151. strSql.Append(" where id_ in ("+id_list + ") ");
  152. int rows=DbHelperMySQL.ExecuteSql(strSql.ToString());
  153. if (rows > 0)
  154. {
  155. return true;
  156. }
  157. else
  158. {
  159. return false;
  160. }
  161. }
  162. /// <summary>
  163. /// 得到一个对象实体
  164. /// </summary>
  165. public Jpsoft.Model.Customer GetModel(string id_)
  166. {
  167. StringBuilder strSql=new StringBuilder();
  168. strSql.Append("select id_,company_,name_,phone_,del_flag,create_by,create_time,update_by,update_time from base_customer ");
  169. strSql.Append(" where id_=@id_ ");
  170. MySqlParameter[] parameters = {
  171. new MySqlParameter("@id_", MySqlDbType.VarChar,36) };
  172. parameters[0].Value = id_;
  173. Jpsoft.Model.Customer model=new Jpsoft.Model.Customer();
  174. DataSet ds=DbHelperMySQL.Query(strSql.ToString(),parameters);
  175. if(ds.Tables[0].Rows.Count>0)
  176. {
  177. return DataRowToModel(ds.Tables[0].Rows[0]);
  178. }
  179. else
  180. {
  181. return null;
  182. }
  183. }
  184. /// <summary>
  185. /// 得到一个对象实体
  186. /// </summary>
  187. public Jpsoft.Model.Customer DataRowToModel(DataRow row)
  188. {
  189. Jpsoft.Model.Customer model=new Jpsoft.Model.Customer();
  190. if (row != null)
  191. {
  192. if(row["id_"]!=null)
  193. {
  194. model.id_=row["id_"].ToString();
  195. }
  196. if(row["company_"]!=null)
  197. {
  198. model.company_=row["company_"].ToString();
  199. }
  200. if(row["name_"]!=null)
  201. {
  202. model.name_=row["name_"].ToString();
  203. }
  204. if(row["phone_"]!=null)
  205. {
  206. model.phone_=row["phone_"].ToString();
  207. }
  208. if(row["del_flag"]!=null && row["del_flag"].ToString()!="")
  209. {
  210. if((row["del_flag"].ToString()=="1")||(row["del_flag"].ToString().ToLower()=="true"))
  211. {
  212. model.del_flag=true;
  213. }
  214. else
  215. {
  216. model.del_flag=false;
  217. }
  218. }
  219. if(row["create_by"]!=null)
  220. {
  221. model.create_by=row["create_by"].ToString();
  222. }
  223. if(row["create_time"]!=null && row["create_time"].ToString()!="")
  224. {
  225. model.create_time=DateTime.Parse(row["create_time"].ToString());
  226. }
  227. if(row["update_by"]!=null)
  228. {
  229. model.update_by=row["update_by"].ToString();
  230. }
  231. if(row["update_time"]!=null && row["update_time"].ToString()!="")
  232. {
  233. model.update_time=DateTime.Parse(row["update_time"].ToString());
  234. }
  235. }
  236. return model;
  237. }
  238. /// <summary>
  239. /// 获得数据列表
  240. /// </summary>
  241. public DataSet GetList(string strWhere)
  242. {
  243. StringBuilder strSql=new StringBuilder();
  244. strSql.Append("select id_,company_,name_,phone_,del_flag,create_by,create_time,update_by,update_time ");
  245. strSql.Append(" FROM base_customer ");
  246. if(strWhere.Trim()!="")
  247. {
  248. strSql.Append(" where "+strWhere);
  249. }
  250. return DbHelperMySQL.Query(strSql.ToString());
  251. }
  252. /// <summary>
  253. /// 获取记录总数
  254. /// </summary>
  255. public int GetRecordCount(string strWhere)
  256. {
  257. StringBuilder strSql=new StringBuilder();
  258. strSql.Append("select count(1) FROM base_customer ");
  259. if(strWhere.Trim()!="")
  260. {
  261. strSql.Append(" where "+strWhere);
  262. }
  263. object obj = DbHelperMySQL.GetSingle(strSql.ToString());
  264. if (obj == null)
  265. {
  266. return 0;
  267. }
  268. else
  269. {
  270. return Convert.ToInt32(obj);
  271. }
  272. }
  273. /// <summary>
  274. /// 分页获取数据列表
  275. /// </summary>
  276. public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)
  277. {
  278. StringBuilder strSql=new StringBuilder();
  279. strSql.Append("SELECT * FROM ( ");
  280. strSql.Append(" SELECT ROW_NUMBER() OVER (");
  281. if (!string.IsNullOrEmpty(orderby.Trim()))
  282. {
  283. strSql.Append("order by T." + orderby );
  284. }
  285. else
  286. {
  287. strSql.Append("order by T.id_ desc");
  288. }
  289. strSql.Append(")AS Row, T.* from base_customer T ");
  290. if (!string.IsNullOrEmpty(strWhere.Trim()))
  291. {
  292. strSql.Append(" WHERE " + strWhere);
  293. }
  294. strSql.Append(" ) TT");
  295. strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);
  296. return DbHelperMySQL.Query(strSql.ToString());
  297. }
  298. /*
  299. /// <summary>
  300. /// 分页获取数据列表
  301. /// </summary>
  302. public DataSet GetList(int PageSize,int PageIndex,string strWhere)
  303. {
  304. MySqlParameter[] parameters = {
  305. new MySqlParameter("@tblName", MySqlDbType.VarChar, 255),
  306. new MySqlParameter("@fldName", MySqlDbType.VarChar, 255),
  307. new MySqlParameter("@PageSize", MySqlDbType.Int32),
  308. new MySqlParameter("@PageIndex", MySqlDbType.Int32),
  309. new MySqlParameter("@IsReCount", MySqlDbType.Bit),
  310. new MySqlParameter("@OrderType", MySqlDbType.Bit),
  311. new MySqlParameter("@strWhere", MySqlDbType.VarChar,1000),
  312. };
  313. parameters[0].Value = "base_customer";
  314. parameters[1].Value = "id_";
  315. parameters[2].Value = PageSize;
  316. parameters[3].Value = PageIndex;
  317. parameters[4].Value = 0;
  318. parameters[5].Value = 0;
  319. parameters[6].Value = strWhere;
  320. return DbHelperMySQL.RunProcedure("UP_GetRecordByPage",parameters,"ds");
  321. }*/
  322. #endregion BasicMethod
  323. #region ExtensionMethod
  324. #endregion ExtensionMethod
  325. }
  326. }