Stock.cs 12 KB

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