GAAS GFrame项目web后台
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

117 lines
3.2 KiB

  1. package task
  2. import (
  3. omModel "LAPP_GAAS_GFrame_BACKEND/models/om"
  4. services "LAPP_GAAS_GFrame_BACKEND/services/om"
  5. )
  6. var parseOrderFromFileStatus int
  7. var parseOrderFromDBStatus int
  8. var createParseTaskFrmDBByDayStatus int
  9. var createParseTaskFrmDBByTimeStatus int
  10. /******************************************************************************
  11. *
  12. * @Struct Name : ParseWorkOrderFromFile
  13. *-----------------------------------------------------------------------------
  14. *
  15. * @Description : 启动定时任务
  16. *
  17. * @Author : zhangxin
  18. *
  19. * @Date : 2021-05-12
  20. *
  21. ******************************************************************************/
  22. func ParseWorkOrderFromFile() {
  23. if parseOrderFromFileStatus == 0 {
  24. parseOrderFromFileStatus = 1
  25. defer func() {
  26. parseOrderFromFileStatus = 0
  27. }()
  28. } else {
  29. return
  30. }
  31. plantNr := 100
  32. omService := services.NewParseMesWorkOrderService()
  33. omService.OMParseDemandFromFile(plantNr)
  34. }
  35. /******************************************************************************
  36. *
  37. * @Struct Name : ParseWorkOrderFromDB
  38. *-----------------------------------------------------------------------------
  39. *
  40. * @Description : 启动定时任务
  41. *
  42. * @Author : zhangxin
  43. *
  44. * @Date : 2021-05-12
  45. *
  46. ******************************************************************************/
  47. func ParseWorkOrderFromDB() {
  48. if parseOrderFromFileStatus == 1 {
  49. return
  50. }
  51. if parseOrderFromDBStatus == 0 {
  52. parseOrderFromDBStatus = 1
  53. defer func() {
  54. parseOrderFromDBStatus = 0
  55. }()
  56. } else {
  57. return
  58. }
  59. plantNr := 100
  60. omService := services.NewParseMesWorkOrderService()
  61. omService.OMParseDemandFromDB(plantNr)
  62. }
  63. /******************************************************************************
  64. *
  65. * @Struct Name : CreateParseFromDBByDayTask
  66. *-----------------------------------------------------------------------------
  67. *
  68. * @Description : 启动定时任务
  69. *
  70. * @Author : zhangxin
  71. *
  72. * @Date : 2021-05-12
  73. *
  74. ******************************************************************************/
  75. func CreateParseFromDBByDayTask() {
  76. if createParseTaskFrmDBByDayStatus == 0 {
  77. createParseTaskFrmDBByDayStatus = 1
  78. defer func() {
  79. createParseTaskFrmDBByDayStatus = 0
  80. }()
  81. } else {
  82. return
  83. }
  84. plantNr := 100
  85. omService := services.NewDemandHeadFromDBService()
  86. omService.CreateParseTask(plantNr, omModel.ParseTaskTypeByDay)
  87. }
  88. /******************************************************************************
  89. *
  90. * @Struct Name : CreateParseFromDBByTimeTask
  91. *-----------------------------------------------------------------------------
  92. *
  93. * @Description : 启动定时任务
  94. *
  95. * @Author : zhangxin
  96. *
  97. * @Date : 2021-05-12
  98. *
  99. ******************************************************************************/
  100. func CreateParseFromDBByTimeTask() {
  101. if createParseTaskFrmDBByTimeStatus == 0 {
  102. createParseTaskFrmDBByTimeStatus = 1
  103. defer func() {
  104. createParseTaskFrmDBByTimeStatus = 0
  105. }()
  106. } else {
  107. return
  108. }
  109. plantNr := 100
  110. omService := services.NewDemandHeadFromDBService()
  111. omService.CreateParseTask(plantNr, omModel.ParseTaskTypeByTime)
  112. }