PMHistoryController.cs 5.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183
  1. using Cksoft.Data;
  2. using Cksoft.Data.Repository;
  3. using Cksoft.Unity;
  4. using Cksoft.Unity.Log4NetConfig;
  5. using DllEapDal;
  6. using DllEapEntity.Dtos;
  7. using DllEapEntity.PM;
  8. using Microsoft.AspNetCore.Authorization;
  9. using Microsoft.AspNetCore.Mvc;
  10. using System;
  11. using System.Collections.Generic;
  12. using System.Text;
  13. namespace DllEapBll.Controllers
  14. {
  15. /// <summary>
  16. /// 保养记录
  17. /// </summary>
  18. [Authorize]
  19. [ApiController]
  20. [Route("eap/api/[controller]/[action]")]
  21. public class PMHistoryController : ControllerBase
  22. {
  23. /// <summary>
  24. /// 保养记录列表
  25. /// </summary>
  26. /// <param name="filter"></param>
  27. /// <param name="sort"></param>
  28. /// <param name="pageIndex"></param>
  29. /// <param name="pageSize"></param>
  30. /// <param name="sortField"></param>
  31. /// <param name="sortOrder"></param>
  32. /// <returns></returns>
  33. [HttpGet]
  34. public LayuiModel<PMHistory> Get(string filter, string sort, int pageIndex = 1, int pageSize = 10, string sortField = "a.ID", string sortOrder = "ascend")
  35. {
  36. if (!string.IsNullOrEmpty(sort))
  37. {
  38. var arr = sort.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
  39. if (arr != null && arr.Length > 0)
  40. {
  41. sortField = arr[0];
  42. sortOrder = arr[1];
  43. }
  44. }
  45. if (sortOrder == "descend")
  46. {
  47. sortOrder = "desc";
  48. }
  49. else
  50. {
  51. sortOrder = "asc";
  52. }
  53. int start, end;
  54. start = (pageIndex - 1) * pageSize + 1;
  55. end = start + pageSize;
  56. using (IDatabase db = DbFactory.Base("eapslave"))
  57. {
  58. db.BeginTrans();
  59. var dal = new PMHistoryDal(db);
  60. var total = dal.GetCount(filter);
  61. string errorinfo = string.Empty;
  62. var roles = dal.Get(start, pageSize, sortOrder, sortField, filter, errorinfo);
  63. return new LayuiModel<PMHistory>
  64. {
  65. code = 1,
  66. count = total,
  67. data = roles,
  68. msg = ""
  69. };
  70. }
  71. }
  72. /// <summary>
  73. /// 保养记录详情
  74. /// </summary>
  75. /// <param name="id"></param>
  76. /// <returns></returns>
  77. [HttpGet]
  78. public PMHistory GetSingle(int id)
  79. {
  80. using (IDatabase db = DbFactory.Base("eapslave"))
  81. {
  82. var dal = new PMHistoryDal(db);
  83. return dal.Get(id);
  84. }
  85. }
  86. /// <summary>
  87. /// 新增/修改保养记录
  88. /// </summary>
  89. /// <param name="programMst"></param>
  90. /// <returns></returns>
  91. [HttpPost]
  92. public EapResponse Add([FromBody] PMHistory programMst)
  93. {
  94. string usercode = Request.Headers["usercode"];
  95. using (IDatabase db = DbFactory.Base("eap"))
  96. {
  97. db.BeginTrans();
  98. var dal = new PMHistoryDal(db);
  99. string errorinfo = string.Empty;
  100. var response = new EapResponse() { Code = 1, Msg = string.Empty };
  101. int id = -1;
  102. if (programMst.ID == 0)
  103. {
  104. id = dal.Add(programMst, usercode, ref errorinfo);
  105. }
  106. else
  107. {
  108. id = dal.Update(programMst, usercode, ref errorinfo);
  109. }
  110. if (id < 0)
  111. {
  112. db.Rollback();
  113. response.Code = -1;
  114. response.Msg = errorinfo;
  115. }
  116. else
  117. {
  118. db.Commit();
  119. LogHelper<PMHistory>.LogFatal("新增PMHistory-->" + Json.ToJson(programMst), "用户操作", usercode);
  120. }
  121. response.Id = id;
  122. return response;
  123. }
  124. }
  125. /// <summary>
  126. /// 删除记录
  127. /// </summary>
  128. /// <param name="id"></param>
  129. /// <returns></returns>
  130. [HttpPost]
  131. public EapResponse Delete([FromBody] int id)
  132. {
  133. IDatabase db = null;
  134. string errormsg = string.Empty;
  135. try
  136. {
  137. db = DbFactory.Base("eap");
  138. var dal = new PMHistoryDal(db);
  139. db.BeginTrans();
  140. var model = dal.Get(id);
  141. var res = dal.Delete(id, ref errormsg);
  142. if (res < 0)
  143. {
  144. db.Rollback();
  145. return new EapResponse()
  146. {
  147. Code = -1,
  148. Msg = errormsg
  149. };
  150. }
  151. db.Commit();
  152. LogHelper<PMHistory>.LogFatal("删除PMHistory-->:" + Json.ToJson(model), "用户操作", Request.Headers["usercode"]);
  153. return new EapResponse()
  154. {
  155. Code = 1,
  156. Msg = ""
  157. };
  158. }
  159. catch (Exception e)
  160. {
  161. errormsg = e.Message;
  162. return new EapResponse
  163. {
  164. Code = -1,
  165. Msg = errormsg
  166. };
  167. }
  168. finally
  169. {
  170. if (db != null)
  171. db.Close();
  172. }
  173. }
  174. }
  175. }