rechargeRecords.go 1.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869
  1. package handler
  2. import (
  3. "errors"
  4. "fmt"
  5. "github.com/gin-gonic/gin"
  6. "github.com/sirupsen/logrus"
  7. "youngee_m_api/consts"
  8. "youngee_m_api/db"
  9. "youngee_m_api/model/http_model"
  10. "youngee_m_api/pack"
  11. "youngee_m_api/util"
  12. )
  13. func WrapRechargeRecordsHandler(ctx *gin.Context) {
  14. handler := newRechargeRecordsHandler(ctx)
  15. BaseRun(handler)
  16. }
  17. type RechargeRecordsHandler struct {
  18. ctx *gin.Context
  19. req *http_model.GetRechargeRecordsRequest
  20. resp *http_model.CommonResponse
  21. }
  22. func (r RechargeRecordsHandler) getContext() *gin.Context {
  23. return r.ctx
  24. }
  25. func (r RechargeRecordsHandler) getResponse() interface{} {
  26. return r.resp
  27. }
  28. func (r RechargeRecordsHandler) getRequest() interface{} {
  29. return r.req
  30. }
  31. func (r RechargeRecordsHandler) run() {
  32. condition := pack.HttpRechargeRecordsRequestToCondition(r.req)
  33. data, err := db.GetRechargeRecords(r.ctx, r.req, condition)
  34. if err != nil {
  35. // 数据库查询失败,返回5001
  36. logrus.Errorf("[RechargeRecordsHandler] call GetRechargeRecords err:%+v\n", err)
  37. util.HandlerPackErrorResp(r.resp, consts.ErrorInternal, "")
  38. logrus.Info("GetRechargeRecords fail,req:%+v", r.req)
  39. return
  40. }
  41. r.resp.Data = data
  42. }
  43. func (r RechargeRecordsHandler) checkParam() error {
  44. var errs []error
  45. if r.req.PageNum < 0 || r.req.PageSize <= 0 {
  46. errs = append(errs, errors.New("page param error"))
  47. }
  48. r.req.PageNum--
  49. if len(errs) != 0 {
  50. return fmt.Errorf("check param errs:%+v", errs)
  51. }
  52. return nil
  53. }
  54. func newRechargeRecordsHandler(ctx *gin.Context) *RechargeRecordsHandler {
  55. return &RechargeRecordsHandler{
  56. ctx: ctx,
  57. req: http_model.NewGetRechargeRecordsRequest(),
  58. resp: http_model.NewGetRechargeRecordsResponse(),
  59. }
  60. }