eafonyang
dd92845bc2
- 增加设备持久化、阻抗数据持久化、分享码持久化定时任务 - 通过环境变量 ENABLE_PERSIST_TASK 和 ENABLE_IMPEDANCE_PERSIST_TASK 控制任务启用 - 分享码配置新增最大数量和TTL时间支持多种时间单位（m/h/d） - 实现任务批量处理、锁机制及失败重试保障数据一致性 - 定时任务启动集成至服务主流程，增强系统可配置性和运维便利性 feat(ota): 新增根据设备型号和版本号查询版本名称接口 - 实现 GET /audio/getVerName 接口返回唯一 OTA 版本名称 verName - 添加请求参数校验及错误处理逻辑 - 在仓库层新增按型号和版本号查询版本名称的方法 - 完善接口文档及Swagger定义，支持前端调用查询版本名称功能
85 lines
3.0 KiB
Go
85 lines
3.0 KiB
Go
package router
|
|
|
|
import (
|
|
"database/sql"
|
|
"time"
|
|
|
|
"github.com/gin-gonic/gin"
|
|
"github.com/luxsin/app-api/internal/cache"
|
|
"github.com/luxsin/app-api/internal/config"
|
|
"github.com/luxsin/app-api/internal/handler"
|
|
"github.com/luxsin/app-api/internal/middleware"
|
|
"github.com/luxsin/app-api/internal/repository"
|
|
"github.com/luxsin/app-api/internal/search"
|
|
"github.com/luxsin/app-api/internal/storage"
|
|
"github.com/redis/go-redis/v9"
|
|
"go.uber.org/zap"
|
|
|
|
swaggerFiles "github.com/swaggo/files"
|
|
ginSwagger "github.com/swaggo/gin-swagger"
|
|
)
|
|
|
|
func New(log *zap.Logger, db *sql.DB, searchClient *search.Client, rdb *redis.Client, eqCfg config.EqualizeConfig, s3 *storage.S3Storage, shareCodeMaxPerMac int, shareCodeTTL time.Duration, env string) *gin.Engine {
|
|
r := gin.New()
|
|
r.Use(gin.Recovery())
|
|
r.Use(middleware.RequestID())
|
|
r.Use(middleware.Logger(log))
|
|
r.Use(middleware.CORS())
|
|
|
|
// Cache
|
|
brandCache := cache.NewBrandCache(rdb)
|
|
modelCache := cache.NewModelCache(rdb)
|
|
curveCache := cache.NewCurveCache(rdb)
|
|
|
|
// Repository
|
|
brandRepo := repository.NewBrandRepository(db, brandCache)
|
|
modelRepo := repository.NewModelRepository(db, modelCache)
|
|
otaRepo := repository.NewOTARepository(db)
|
|
curveRepo := repository.NewCurveRepository(db)
|
|
|
|
shareCodeCache := cache.NewShareCodeCache(rdb, shareCodeTTL)
|
|
|
|
// Handler
|
|
health := handler.NewHealthHandler()
|
|
brand := handler.NewBrandHandler(brandRepo, log)
|
|
model := handler.NewModelHandler(modelRepo, log)
|
|
modelList := handler.NewModelListHandler(searchClient, log)
|
|
device := handler.NewDeviceHandler(rdb, log)
|
|
impedance := handler.NewImpedanceHandler(rdb, log)
|
|
ota := handler.NewOTAHandler(otaRepo, log)
|
|
curve := handler.NewCurveHandler(curveRepo, curveCache, eqCfg, s3, log)
|
|
modelCSV := handler.NewModelCSVHandler(s3, log)
|
|
shareCode := handler.NewShareCodeHandler(shareCodeCache, log, shareCodeMaxPerMac)
|
|
|
|
v1 := r.Group("/api/v1")
|
|
{
|
|
v1.GET("/health", health.Check)
|
|
}
|
|
|
|
// Swagger — 仅非生产环境启用
|
|
if env != "production" {
|
|
r.GET("/docs/*any", ginSwagger.WrapHandler(swaggerFiles.Handler))
|
|
}
|
|
|
|
audio := r.Group("/audio")
|
|
{
|
|
audio.GET("/getBrand", middleware.CacheControl(middleware.CacheControlList), brand.GetBrand)
|
|
audio.GET("/getModel", middleware.CacheControl(middleware.CacheControlList), model.GetModel)
|
|
audio.GET("/modelList", middleware.CacheControl(middleware.CacheControlModelList), modelList.ModelList)
|
|
audio.GET("/reportDevInfo", device.ReportDevInfo)
|
|
audio.GET("/reportImpedance", impedance.ReportImpedance)
|
|
audio.GET("/ota", ota.GetOTA)
|
|
audio.GET("/getVerName", ota.GetVerName)
|
|
audio.GET("/getCurve", middleware.CacheControl(middleware.CacheControlCurve), curve.GetCurve)
|
|
audio.GET("/modelCurve", middleware.CacheControl(middleware.CacheControlCurve), curve.ModelCurve)
|
|
audio.GET("/getModelCSV", modelCSV.GetModelCSV)
|
|
audio.POST("/shareCreate", shareCode.ExportShareCode)
|
|
audio.GET("/shareList", shareCode.ListShareCodesByMac)
|
|
audio.GET("/shareQuery", shareCode.QueryShareCode)
|
|
audio.GET("/shareAccept", shareCode.ImportShareCode)
|
|
audio.GET("/shareDelete", shareCode.DeleteShareCode)
|
|
}
|
|
|
|
return r
|
|
}
|