ginUtils.go 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104
  1. /**
  2. * @Author: zou.yingbin
  3. * @Create : 2021/1/25 9:42
  4. * @Modify : 2021/1/25 9:42
  5. */
  6. package app
  7. import (
  8. "github.com/gin-gonic/gin"
  9. "mtp2_if/global/e"
  10. "mtp2_if/logger"
  11. "net/http"
  12. )
  13. // GetData 获取数据接口
  14. type IGetData interface {
  15. GetData() ([]interface{}, error)
  16. }
  17. // IGetDataEx 获取数据接口
  18. type IGetDataEx interface {
  19. GetDataEx() (interface{}, error)
  20. }
  21. // ICalc 数据处理接口
  22. type ICalc interface {
  23. Calc()
  24. }
  25. // GinUtils 封装绑定和数据获取处理
  26. type GinUtils struct {
  27. Gin
  28. err error
  29. }
  30. // DoBindReq 处理参数绑定
  31. func (r *GinUtils) DoBindReq(req interface{}) {
  32. if r.err = r.C.ShouldBind(req); r.err != nil {
  33. r.Gin.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil)
  34. }
  35. }
  36. // DoGetData 处理数据获取, 参数obj为models结构体
  37. // Deprecated
  38. func (r *GinUtils) DoGetData(obj interface{}) {
  39. // 如果在参数绑定阶段有错误, 则不执行数据获取
  40. if r.err != nil {
  41. return
  42. }
  43. if v, ok := obj.(IGetData); ok {
  44. if d, err := v.GetData(); err == nil {
  45. // 执行数据处理
  46. for i := range d {
  47. if val, ok := d[i].(ICalc); ok {
  48. val.Calc()
  49. } else {
  50. break
  51. }
  52. }
  53. r.Gin.Response(http.StatusOK, e.SUCCESS, d)
  54. } else {
  55. logger.GetLogger().Errorf("query fail, %v", err)
  56. r.Gin.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil)
  57. }
  58. }
  59. }
  60. // DoGetDataEx 处理数据获取, 参数obj为models结构体
  61. // Deprecated
  62. func (r *GinUtils) DoGetDataEx(modelObj interface{}) {
  63. // 如果在参数绑定阶段有错误, 则不执行数据获取
  64. if r.err != nil {
  65. return
  66. }
  67. if v, ok := modelObj.(IGetDataEx); ok {
  68. if d, err := v.GetDataEx(); err == nil {
  69. r.Gin.Response(http.StatusOK, e.SUCCESS, d)
  70. } else {
  71. logger.GetLogger().Errorf("query fail, %v", err)
  72. r.Gin.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil)
  73. }
  74. }
  75. }
  76. // DoGetDataI 获取数据
  77. func (r *GinUtils) DoGetDataI(iObj IGetDataEx) {
  78. // 如果在参数绑定阶段有错误, 则不执行数据获取
  79. if r.err != nil {
  80. return
  81. }
  82. if d, err := iObj.GetDataEx(); err == nil {
  83. r.Gin.Response(http.StatusOK, e.SUCCESS, d)
  84. } else {
  85. logger.GetLogger().Errorf("query fail, %v", err)
  86. r.Gin.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil)
  87. }
  88. }
  89. // NewGinUtils 生成处理GinUtils实例
  90. func NewGinUtils(c *gin.Context) *GinUtils {
  91. return &GinUtils{Gin: Gin{C: c}}
  92. }