mqttDataManageRoutes.go 1.3 KB

123456789101112131415161718192021222324252627282930313233343536
  1. /*
  2. * MQTT 报文管理 API List(数据来自 iotcore-stat Elasticsearch,站点即 equipNo)
  3. * 看板:
  4. * /mqttDataManage/total/daily - GET 日总量
  5. * /mqttDataManage/total/monthly - GET 月总量
  6. * /mqttDataManage/total/dailyTrend - GET 月度每日总量(柱状图,整月补零)
  7. * /mqttDataManage/site/daily - GET 站点日总量(分页)
  8. * /mqttDataManage/site/cmdType - GET 站点当日命令类型总量(下钻,分页)
  9. * 查询:
  10. * /mqttDataManage/messages - GET 逐条报文查询
  11. *
  12. * 注:站点月总量列表(site/monthly)因查询非常慢、非常耗资源已下线。
  13. */
  14. package routes
  15. import (
  16. "fwh-toolbox-server/controllers"
  17. "github.com/gofiber/fiber/v2"
  18. )
  19. func MqttDataManageSetup(api fiber.Router) {
  20. // 报文总量
  21. api.Get("/mqttDataManage/total/daily", controllers.GetMqttDailyTotal)
  22. api.Get("/mqttDataManage/total/monthly", controllers.GetMqttMonthlyTotal)
  23. api.Get("/mqttDataManage/total/dailyTrend", controllers.GetMqttMonthlyDailyTrend)
  24. // 站点日总量(分页降序)
  25. api.Get("/mqttDataManage/site/daily", controllers.GetMqttSiteDailyTotals)
  26. // 下钻:站点当日命令类型总量
  27. api.Get("/mqttDataManage/site/cmdType", controllers.GetMqttSiteCmdTypeTotals)
  28. // 逐条报文查询
  29. api.Get("/mqttDataManage/messages", controllers.QueryMqttMessages)
  30. }