FxWcsTaskDisCore.cs 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116
  1. using SqlSugar;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Linq;
  5. using System.Text;
  6. using System.Threading.Tasks;
  7. using WMS.Core.APPBLL;
  8. using WMS.Info;
  9. using WMS.Util;
  10. namespace WMS.Core.ServiceCore
  11. {
  12. public class FxWcsTaskDisCore
  13. {
  14. /// <summary>
  15. /// 获取分页数据
  16. /// <summary>
  17. /// <returns></returns>
  18. public IEnumerable<dynamic> GetTaskPageList(Pagination pagination, string queryJson)
  19. {
  20. SqlSugarClient client = null;
  21. try
  22. {
  23. client = SysDbCore.GetDbCtx();
  24. int count = 0;
  25. var queryParam = queryJson.ToJObject();
  26. var db = client.Queryable<WCS_TASK_DIS>();
  27. //单据日期
  28. if (!queryParam["Btime"].IsEmpty() && !queryParam["Etime"].IsEmpty())
  29. {
  30. db.Where(ord => ord.TASK_ADDDATETIME >= queryParam["Btime"].ToDate() && ord.TASK_ADDDATETIME <= queryParam["Etime"].ToDate());
  31. }
  32. if (!queryParam["keyword"].IsEmpty())
  33. {
  34. string kw = queryParam["keyword"].ToString();
  35. db.Where(ord => ord.TASK_NO == Convert.ToInt32(kw));
  36. }
  37. if (pagination.sord.ToUpper() != "ASC")
  38. {
  39. pagination.sidx = pagination.sidx + " DESC";
  40. }
  41. if (pagination.sidx.Contains("F_editTime"))
  42. pagination.sidx = pagination.sidx + " DESC";
  43. var list = db.OrderBy(pagination.sidx).Select<dynamic>(@"
  44. [TASK_ID],
  45. [TASK_NO],
  46. [TASK_SYSTYPE],
  47. [TASK_POSIDFROM],
  48. [TASK_POSIDCUR],
  49. [TASK_POSIDNEXT],
  50. [TASK_POSIDTO],
  51. [TASK_POSIDMOVE],
  52. [TASK_WHID],
  53. [TASK_ADDUSERNO],
  54. [TASK_ADDDATETIME],
  55. [TASK_EDITUSERNO],
  56. [TASK_EDITDATETIME],
  57. [TASK_NOTES],
  58. [TASK_SRMNO],
  59. [TASK_BOXBARCODE],
  60. [TASK_BOXNUM],
  61. [ISBONDED],
  62. [TASK_ITEM6],
  63. [TASK_ITEM7],
  64. [TASK_ITEM8],
  65. [TASK_ITEM9],
  66. [TASK_ITEM10],
  67. [TASK_ORDERTYPE],
  68. [TASK_WKSTATUS],
  69. [TASK_PRIORITY],
  70. [TASK_COMTYPE],
  71. [DEVICE_TYPE]").ToPageList(pagination.page, pagination.rows, ref count);
  72. pagination.records = count;
  73. return list;
  74. }
  75. catch (Exception ex)
  76. {
  77. throw ex;
  78. }
  79. finally
  80. {
  81. client.Dispose();
  82. }
  83. }
  84. /// <summary>
  85. /// 获取单据数据
  86. /// <summary>
  87. /// <returns></returns>
  88. public IEnumerable<WCS_TASK_DIS_DTL> GeItem(string taskId)
  89. {
  90. try
  91. {
  92. var lst = SysDbCore.GetDbCtx().Queryable<WCS_TASK_DIS_DTL>().Where(it => it.PARENTID == taskId);
  93. var list = lst.Select<WCS_TASK_DIS_DTL>(@" ID,
  94. PARENTID,
  95. TASKNO,
  96. POSIDCUR,
  97. POSIDNEXT,
  98. DESCRIPTION,
  99. NOTES,
  100. TASK_WKSTATUS,
  101. EXECUTEDATE,
  102. DEVICE_TYPE,
  103. DEVICE_TASKNO,
  104. DEVICE_NO ").ToList();
  105. return list;
  106. }
  107. catch (Exception ex)
  108. {
  109. throw ex;
  110. }
  111. }
  112. }
  113. }