task_terminate.go 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455
  1. package handler
  2. import (
  3. "youngee_b_api/consts"
  4. "youngee_b_api/model/http_model"
  5. "youngee_b_api/service"
  6. "youngee_b_api/util"
  7. "github.com/gin-gonic/gin"
  8. "github.com/sirupsen/logrus"
  9. )
  10. func WrapTaskTerminateHandler(ctx *gin.Context) {
  11. handler := newTaskTerminateHandler(ctx)
  12. baseRun(handler)
  13. }
  14. func newTaskTerminateHandler(ctx *gin.Context) *TaskTerminateHandler {
  15. return &TaskTerminateHandler{
  16. req: http_model.NewTaskTerminateRequest(),
  17. resp: http_model.NewTaskTerminateResponse(),
  18. ctx: ctx,
  19. }
  20. }
  21. type TaskTerminateHandler struct {
  22. req *http_model.TaskTerminateRequest
  23. resp *http_model.CommonResponse
  24. ctx *gin.Context
  25. }
  26. func (h *TaskTerminateHandler) getRequest() interface{} {
  27. return h.req
  28. }
  29. func (h *TaskTerminateHandler) getContext() *gin.Context {
  30. return h.ctx
  31. }
  32. func (h *TaskTerminateHandler) getResponse() interface{} {
  33. return h.resp
  34. }
  35. func (h *TaskTerminateHandler) run() {
  36. data := http_model.TaskTerminateRequest{}
  37. data = *h.req
  38. res, err := service.Terminate.TaskTerminate(h.ctx, data)
  39. if err != nil {
  40. logrus.Errorf("[TaskTerminateHandler] call TaskTerminate err:%+v\n", err)
  41. util.HandlerPackErrorResp(h.resp, consts.ErrorInternal, "")
  42. return
  43. }
  44. h.resp.Message = ""
  45. h.resp.Data = res
  46. }
  47. func (h *TaskTerminateHandler) checkParam() error {
  48. return nil
  49. }