LeoSat2TaskProcessingController.cs 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677
  1. using DevExpress.Utils.Extensions;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Configuration;
  5. using System.IO;
  6. using System.Linq;
  7. using System.Web.Http;
  8. using XdCxRhDW.Dto;
  9. using XdCxRhDW.WebApi;
  10. using X2LeoTaskServer54.Service;
  11. namespace X2LeoTaskServer54.Controllers
  12. {
  13. /// <summary>
  14. ///低轨双星任务处理接口
  15. /// </summary>
  16. public class LeoSat2TaskProcessingController : BaseController
  17. {
  18. /*******************
  19. * !!!不要在Controller中放业务逻辑的全局变量(每次调用Http接口Controller都可能是一个新的对象)
  20. * Controller主要就是调用Service层的东西。Service层执行业务逻辑和调用Repository层操作数据库
  21. * ********************/
  22. private readonly TaskService _service;
  23. public LeoSat2TaskProcessingController(TaskService service)
  24. {
  25. _service = service;
  26. }
  27. /// <summary>
  28. /// 执行任务
  29. /// </summary>
  30. /// <param name="dto">任务信息</param>
  31. /// <returns></returns>
  32. [HttpPost]
  33. public AjaxResult Run(LeoSat2TaskHandleDto dto)
  34. {
  35. try
  36. {
  37. LogHelper.Info($"接收到任务编号:{dto.ID}");
  38. _service.StartAsync(dto);
  39. return Success();
  40. }
  41. catch (Exception ex)
  42. {
  43. Serilog.Log.Error(ex, "任务处理出错!");
  44. return Error("任务处理出错");
  45. }
  46. }
  47. /// <summary>
  48. /// 任务停止
  49. /// </summary>
  50. /// <param name="dto"></param>
  51. /// <returns></returns>
  52. [HttpPost]
  53. public AjaxResult Stop(TaskStopHandleDto dto)
  54. {
  55. try
  56. {
  57. LogHelper.Warning($"用户停止了任务,ID={dto.ID}");
  58. _service.Stop();
  59. return Success();
  60. }
  61. catch (Exception ex)
  62. {
  63. Serilog.Log.Error(ex, $"【任务{dto.ID}】停止执行异常!");
  64. return Error($"【任务{dto.ID}】停止执行异常!");
  65. }
  66. }
  67. }
  68. }