| 123456789101112131415161718192021222324252627282930313233343536 |
- /*
- * MQTT 报文管理 API List(数据来自 iotcore-stat Elasticsearch,站点即 equipNo)
- * 看板:
- * /mqttDataManage/total/daily - GET 日总量
- * /mqttDataManage/total/monthly - GET 月总量
- * /mqttDataManage/total/dailyTrend - GET 月度每日总量(柱状图,整月补零)
- * /mqttDataManage/site/daily - GET 站点日总量(分页)
- * /mqttDataManage/site/cmdType - GET 站点当日命令类型总量(下钻,分页)
- * 查询:
- * /mqttDataManage/messages - GET 逐条报文查询
- *
- * 注:站点月总量列表(site/monthly)因查询非常慢、非常耗资源已下线。
- */
- package routes
- import (
- "fwh-toolbox-server/controllers"
- "github.com/gofiber/fiber/v2"
- )
- func MqttDataManageSetup(api fiber.Router) {
- // 报文总量
- api.Get("/mqttDataManage/total/daily", controllers.GetMqttDailyTotal)
- api.Get("/mqttDataManage/total/monthly", controllers.GetMqttMonthlyTotal)
- api.Get("/mqttDataManage/total/dailyTrend", controllers.GetMqttMonthlyDailyTrend)
- // 站点日总量(分页降序)
- api.Get("/mqttDataManage/site/daily", controllers.GetMqttSiteDailyTotals)
- // 下钻:站点当日命令类型总量
- api.Get("/mqttDataManage/site/cmdType", controllers.GetMqttSiteCmdTypeTotals)
- // 逐条报文查询
- api.Get("/mqttDataManage/messages", controllers.QueryMqttMessages)
- }
|