Function CreateEntity

api/controller/entity.go:421–470

CreateEntity godoc @Summary 创建实体 @Description 手动创建一个新的实体 @Tags 实体管理 @Accept json @Produce json @Security BearerAuth @Param request body CreateEntityRequest true "实体信息" @Success 200 {object} model.CommonResponse{data=model.Entity} @Failure 409 {object} model.CommonResponse @Router /api/entities [post

(c *gin.Context)

// @Failure 409 {object} model.CommonResponse
// @Router /api/entities [post]
func CreateEntity(c *gin.Context) {
	eid := config.GetEID(c)
	if eid <= 0 {
		c.JSON(http.StatusBadRequest, model.ParamError.ToNewErrorResponse(model.InvalidEnterpriseID))
		return
	}

	var req CreateEntityRequest
	if err := c.ShouldBindJSON(&req); err != nil {
		c.JSON(http.StatusBadRequest, model.ParamError.ToResponse(err))
		return
	}

	req.Type = strings.TrimSpace(req.Type)
	req.Name = strings.TrimSpace(req.Name)
	req.Status = strings.TrimSpace(req.Status)
	if req.Type == "" || req.Name == "" {
		c.JSON(http.StatusBadRequest, model.ParamError.ToResponse(errors.New("type 或 name 不能为空")))
		return
	}

	status := req.Status
	if status == "" {
		status = "active"
	}

	entity := &model.Entity{
		Eid:    eid,
		Type:   req.Type,
		Name:   req.Name,
		Status: status,
	}

	if err := model.DB.Create(entity).Error; err != nil {
		if strings.Contains(strings.ToLower(err.Error()), "duplicate") || strings.Contains(strings.ToLower(err.Error()), "unique") {
			c.JSON(http.StatusConflict, model.RecordAlreadyExists.ToNewErrorResponse("实体已存在"))
			return
		}
		c.JSON(http.StatusInternalServerError, model.DBError.ToResponse(err))
		return
	}

	c.JSON(http.StatusOK, model.Success.ToResponse(entity))

	// 异步更新向量库
	go func(e model.Entity, enterpriseID int64) {
		svc := rag.NewEntityVectorService(model.DB)
		_ = svc.IndexEntity(enterpriseID, &e)
	}(*entity, eid)
}

// UpdateEntity godoc
// @Summary 更新实体