JobTasksController.cs 4.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177
  1. using IMCS.CCS.Entitys;
  2. using IMCS.CCS.Service;
  3. using IMCS.CCS.Services;
  4. using Microsoft.AspNetCore.Mvc;
  5. using System.Collections.Generic;
  6. using System.Linq;
  7. using System.Threading.Tasks;
  8. namespace IMCS.CCS.Controllers
  9. {
  10. [ApiController]
  11. [Route("api/[controller]")]
  12. /// <summary>
  13. /// 任务调度器
  14. /// </summary>
  15. public class JobTasksController : ControllerBase
  16. {
  17. private readonly ITaskJobService _taskJobService;
  18. public JobTasksController(ITaskJobService taskJobService)
  19. {
  20. _taskJobService = taskJobService;
  21. }
  22. /// <summary>
  23. ///
  24. /// </summary>
  25. /// <returns></returns>
  26. [HttpPost("test")]
  27. public async Task<string> Test()
  28. {
  29. return "not exist";
  30. }
  31. /// <summary>
  32. /// 上传程序回调任务
  33. /// </summary>
  34. /// <returns></returns>
  35. [HttpPost("CallbackJob1")]
  36. public async Task<string> CallbackJob1()
  37. {
  38. return await _taskJobService.CallbackJob1();
  39. //return "not exist";
  40. }
  41. /// <summary>
  42. /// 柔性产线,伺服回调任务
  43. /// </summary>
  44. /// <returns></returns>
  45. [HttpPost("CallbackJob2")]
  46. public async Task<string> CallbackJob2()
  47. {
  48. return await _taskJobService.CallbackJob2();
  49. }
  50. /// <summary>
  51. /// 打标机回调任务
  52. /// </summary>
  53. /// <returns></returns>
  54. [HttpPost("CallbackJob3")]
  55. public async Task<string> CallbackJob3()
  56. {
  57. return await _taskJobService.CallbackJob3();
  58. }
  59. /// <summary>
  60. /// 启动机床程序,智能单元及质量中心取放回调任务
  61. /// </summary>
  62. /// <returns></returns>
  63. [HttpPost("CallbackJob4")]
  64. public async Task<string> CallbackJob4()
  65. {
  66. return await _taskJobService.CallbackJob4();
  67. }
  68. /// <summary>
  69. /// 启动清洗机回调任务
  70. /// </summary>
  71. /// <returns></returns>
  72. [HttpPost("CallbackJob5")]
  73. public async Task<string> CallbackJob5()
  74. {
  75. return await _taskJobService.CallbackJob5();
  76. }
  77. /// <summary>
  78. /// 采集数据S7
  79. /// </summary>
  80. /// <returns></returns>
  81. [HttpPost("DataCollectS7Job")]
  82. public async Task<string> DataCollectS7Job()
  83. {
  84. return await _taskJobService.DataCollectS7Job();
  85. }
  86. /// <summary>
  87. /// 采集数据HEIDEHAIN
  88. /// </summary>
  89. /// <returns></returns>
  90. [HttpPost("DataCollectHeidehainJob")]
  91. public async Task<string> DataCollectHeidehainJob()
  92. {
  93. return await _taskJobService.DataCollectHeidehainJob();
  94. }
  95. /// <summary>
  96. /// 监控设备状态
  97. /// </summary>
  98. /// <returns></returns>
  99. /*[HttpPost("MonitorEquipmentStatusJob")]
  100. public async Task<string> MonitorEquipmentStatusJob()
  101. {
  102. return await _taskJobService.MonitorEquipmentStatusJob();
  103. }*/
  104. /// <summary>
  105. /// 监控设备状态
  106. /// </summary>
  107. /// <returns></returns>
  108. [HttpPost("DeviceStatusJob")]
  109. public async Task<string> DeviceStatusJob()
  110. {
  111. return await _taskJobService.DeviceStatusJob();
  112. }
  113. /// <summary>
  114. /// 删除redis
  115. /// </summary>
  116. /// <returns></returns>
  117. [HttpPost("RemoveRedis")]
  118. public void RemoveRedis()
  119. {
  120. //_taskJobService.removeRedis();
  121. }
  122. /// <summary>
  123. /// 心跳任务
  124. /// </summary>
  125. /// <returns></returns>
  126. [HttpPost("PlcHeartbeatJob")]
  127. public async Task<string> PlcHeartbeatJob()
  128. {
  129. return await _taskJobService.PlcHeartbeatJob();
  130. }
  131. /// <summary>
  132. /// 监控设备状态
  133. /// </summary>
  134. /// <returns></returns>
  135. [HttpPost("MonitorEquipmentStatusJob")]
  136. public async Task<string> MonitorEquipmentStatusJob2()
  137. {
  138. return await _taskJobService.MonitorEquipmentStatusJob2();
  139. }
  140. /// <summary>
  141. /// 采集数据S7报警数据
  142. /// </summary>
  143. /// <returns></returns>
  144. [HttpPost("DataCollectS7JobWarn")]
  145. public async Task<List<string>> DataCollectS7JobWarn()
  146. {
  147. return await _taskJobService.DataCollectS7JobWarn();
  148. }
  149. /// <summary>
  150. /// 定时清楚redis缓存
  151. /// </summary>
  152. /// <returns></returns>
  153. [HttpPost("remoteRedis")]
  154. public async Task<string> remoteRedis()
  155. {
  156. return await _taskJobService.remoteRedis();
  157. }
  158. }
  159. }