- 新增 domain 层:model、provider、route、stats 实体 - 新增 service 层:models、providers、routing、stats 业务逻辑 - 新增 repository 层:models、providers、stats 数据访问 - 新增 pkg 工具包:errors、logger、validator - 新增中间件:CORS、logging、recovery、request ID - 新增数据库迁移:初始 schema 和索引 - 新增单元测试和集成测试 - 新增规范文档:config-management、database-migration、error-handling、layered-architecture、middleware-system、request-validation、structured-logging、test-coverage - 移除 config 子包和 model_router(已迁移至分层架构)
150 lines
2.9 KiB
Go
150 lines
2.9 KiB
Go
package handler
|
|
|
|
import (
|
|
"net/http"
|
|
|
|
"github.com/gin-gonic/gin"
|
|
"gorm.io/gorm"
|
|
|
|
appErrors "nex/backend/pkg/errors"
|
|
|
|
"nex/backend/internal/domain"
|
|
"nex/backend/internal/service"
|
|
)
|
|
|
|
// ModelHandler 模型管理处理器
|
|
type ModelHandler struct {
|
|
modelService service.ModelService
|
|
}
|
|
|
|
// NewModelHandler 创建模型处理器
|
|
func NewModelHandler(modelService service.ModelService) *ModelHandler {
|
|
return &ModelHandler{modelService: modelService}
|
|
}
|
|
|
|
// CreateModel 创建模型
|
|
func (h *ModelHandler) CreateModel(c *gin.Context) {
|
|
var req struct {
|
|
ID string `json:"id" binding:"required"`
|
|
ProviderID string `json:"provider_id" binding:"required"`
|
|
ModelName string `json:"model_name" binding:"required"`
|
|
}
|
|
|
|
if err := c.ShouldBindJSON(&req); err != nil {
|
|
c.JSON(http.StatusBadRequest, gin.H{
|
|
"error": "缺少必需字段: id, provider_id, model_name",
|
|
})
|
|
return
|
|
}
|
|
|
|
model := &domain.Model{
|
|
ID: req.ID,
|
|
ProviderID: req.ProviderID,
|
|
ModelName: req.ModelName,
|
|
}
|
|
|
|
err := h.modelService.Create(model)
|
|
if err != nil {
|
|
if err == appErrors.ErrProviderNotFound {
|
|
c.JSON(http.StatusBadRequest, gin.H{
|
|
"error": "供应商不存在",
|
|
})
|
|
return
|
|
}
|
|
writeError(c, err)
|
|
return
|
|
}
|
|
|
|
c.JSON(http.StatusCreated, model)
|
|
}
|
|
|
|
// ListModels 列出模型
|
|
func (h *ModelHandler) ListModels(c *gin.Context) {
|
|
providerID := c.Query("provider_id")
|
|
|
|
models, err := h.modelService.List(providerID)
|
|
if err != nil {
|
|
writeError(c, err)
|
|
return
|
|
}
|
|
|
|
c.JSON(http.StatusOK, models)
|
|
}
|
|
|
|
// GetModel 获取模型
|
|
func (h *ModelHandler) GetModel(c *gin.Context) {
|
|
id := c.Param("id")
|
|
|
|
model, err := h.modelService.Get(id)
|
|
if err != nil {
|
|
if err == gorm.ErrRecordNotFound {
|
|
c.JSON(http.StatusNotFound, gin.H{
|
|
"error": "模型未找到",
|
|
})
|
|
return
|
|
}
|
|
writeError(c, err)
|
|
return
|
|
}
|
|
|
|
c.JSON(http.StatusOK, model)
|
|
}
|
|
|
|
// UpdateModel 更新模型
|
|
func (h *ModelHandler) UpdateModel(c *gin.Context) {
|
|
id := c.Param("id")
|
|
|
|
var req map[string]interface{}
|
|
if err := c.ShouldBindJSON(&req); err != nil {
|
|
c.JSON(http.StatusBadRequest, gin.H{
|
|
"error": "无效的请求格式",
|
|
})
|
|
return
|
|
}
|
|
|
|
err := h.modelService.Update(id, req)
|
|
if err != nil {
|
|
if err == gorm.ErrRecordNotFound {
|
|
c.JSON(http.StatusNotFound, gin.H{
|
|
"error": "模型未找到",
|
|
})
|
|
return
|
|
}
|
|
if err == appErrors.ErrProviderNotFound {
|
|
c.JSON(http.StatusBadRequest, gin.H{
|
|
"error": "供应商不存在",
|
|
})
|
|
return
|
|
}
|
|
writeError(c, err)
|
|
return
|
|
}
|
|
|
|
model, err := h.modelService.Get(id)
|
|
if err != nil {
|
|
writeError(c, err)
|
|
return
|
|
}
|
|
|
|
c.JSON(http.StatusOK, model)
|
|
}
|
|
|
|
// DeleteModel 删除模型
|
|
func (h *ModelHandler) DeleteModel(c *gin.Context) {
|
|
id := c.Param("id")
|
|
|
|
err := h.modelService.Delete(id)
|
|
if err != nil {
|
|
if err == gorm.ErrRecordNotFound {
|
|
c.JSON(http.StatusNotFound, gin.H{
|
|
"error": "模型未找到",
|
|
})
|
|
return
|
|
}
|
|
writeError(c, err)
|
|
return
|
|
}
|
|
|
|
c.Status(http.StatusNoContent)
|
|
}
|