onDemandGroupController.go 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111
  1. package controller
  2. import (
  3. "github.com/gin-gonic/gin"
  4. "iot_manager_service/app/dao"
  5. "iot_manager_service/app/model"
  6. "iot_manager_service/app/service"
  7. "iot_manager_service/app/utils"
  8. "math"
  9. "net/http"
  10. "strconv"
  11. )
  12. // 灯随车走分组管理对象
  13. var OnDemandGroup = new(onDemandGroupCtl)
  14. type onDemandGroupCtl struct{}
  15. func (c *onDemandGroupCtl) Detail(ctx *gin.Context) {
  16. id, e := strconv.Atoi(ctx.Query("id"))
  17. if e != nil {
  18. ctx.JSON(http.StatusOK, utils.ParamsInvalidResponse(e.Error(), nil))
  19. return
  20. }
  21. device, err := service.OnDemandGroupService.Get(id)
  22. if err != nil {
  23. ctx.JSON(http.StatusOK, err)
  24. return
  25. }
  26. ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, device))
  27. }
  28. func (c *onDemandGroupCtl) List(ctx *gin.Context) {
  29. searchValue := ctx.Query("searchValue")
  30. current, _ := strconv.Atoi(ctx.Query("current"))
  31. size, _ := strconv.Atoi(ctx.Query("size"))
  32. if current == 0 {
  33. current = 1
  34. }
  35. if size <= 0 || size > 100 {
  36. size = 10
  37. }
  38. devices, err := service.OnDemandGroupService.List(searchValue, current, size)
  39. if err != nil {
  40. ctx.JSON(http.StatusOK, err)
  41. return
  42. }
  43. pages := math.Ceil(float64(len(devices)) / float64(size))
  44. rsp := model.RspOnDemandGroupList{
  45. Current: current,
  46. Size: size,
  47. Total: len(devices),
  48. Pages: int(pages),
  49. Records: devices,
  50. }
  51. ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, rsp))
  52. }
  53. func (c *onDemandGroupCtl) CreateOrUpdate(ctx *gin.Context) {
  54. var req *dao.OnDemandGroup
  55. if err := ctx.ShouldBindJSON(&req); err != nil {
  56. ctx.JSON(http.StatusOK, utils.ParamsInvalidResponse(err.Error(), nil))
  57. return
  58. }
  59. err := service.OnDemandGroupService.CreateOrUpdate(req)
  60. ctx.JSON(http.StatusOK, err)
  61. }
  62. func (c *onDemandGroupCtl) Remove(ctx *gin.Context) {
  63. var req *model.ReqOnDemandGroupRemove
  64. if err := ctx.ShouldBindJSON(&req); err != nil {
  65. ctx.JSON(http.StatusOK, utils.ParamsInvalidResponse(err.Error(), nil))
  66. return
  67. }
  68. err := service.OnDemandGroupService.Remove(req.IDs)
  69. if err != nil {
  70. ctx.JSON(http.StatusOK, err)
  71. return
  72. }
  73. ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, nil))
  74. }
  75. func (c *onDemandGroupCtl) GetList(ctx *gin.Context) {
  76. devices, err := service.OnDemandGroupService.GetList()
  77. if err != nil {
  78. ctx.JSON(http.StatusOK, err)
  79. return
  80. }
  81. ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, devices))
  82. }
  83. func (c *onDemandGroupCtl) GroupNumber(ctx *gin.Context) {
  84. id, e := strconv.Atoi(ctx.Query("id"))
  85. if e != nil {
  86. ctx.JSON(http.StatusOK, utils.ParamsInvalidResponse(e.Error(), nil))
  87. return
  88. }
  89. if id <= 0 {
  90. ctx.JSON(http.StatusOK, utils.ParamsInvalidResponse(model.ParamsInvalid, nil))
  91. return
  92. }
  93. device, err := service.OnDemandGroupService.GroupNumberList(id)
  94. if err != nil {
  95. ctx.JSON(http.StatusOK, err)
  96. return
  97. }
  98. ctx.JSON(http.StatusOK, utils.SuccessResponse(utils.Succeeded, device))
  99. }