Merge remote-tracking branch 'origin/alpha' into alpha

common/page_info.go

@@ -41,7 +41,7 @@ func (p *PageInfo) SetItems(items any) {
 func GetPageQuery(c *gin.Context) *PageInfo {
 func GetPageQuery(c *gin.Context) *PageInfo {
 	pageInfo := &PageInfo{}
 	pageInfo := &PageInfo{}
 	// 手动获取并处理每个参数
 	// 手动获取并处理每个参数
-	if page, err := strconv.Atoi(c.Query("page")); err == nil {
+	if page, err := strconv.Atoi(c.Query("p")); err == nil {
 		pageInfo.Page = page
 		pageInfo.Page = page
 	}
 	}
 	if pageSize, err := strconv.Atoi(c.Query("page_size")); err == nil {
 	if pageSize, err := strconv.Atoi(c.Query("page_size")); err == nil {

dto/openai_request.go

@@ -62,6 +62,8 @@ type GeneralOpenAIRequest struct {
 	Reasoning json.RawMessage `json:"reasoning,omitempty"`
 	Reasoning json.RawMessage `json:"reasoning,omitempty"`
 	// Ali Qwen Params
 	// Ali Qwen Params
 	VlHighResolutionImages json.RawMessage `json:"vl_high_resolution_images,omitempty"`
 	VlHighResolutionImages json.RawMessage `json:"vl_high_resolution_images,omitempty"`
+	// 用匿名参数接收额外参数，例如ollama的think参数在此接收
+	Extra map[string]json.RawMessage `json:"-"`
 }
 }
 
 
 func (r *GeneralOpenAIRequest) ToMap() map[string]any {
 func (r *GeneralOpenAIRequest) ToMap() map[string]any {

relay/channel/ollama/dto.go

 package ollama
 package ollama
 
 
-import "one-api/dto"
+import (
+	"encoding/json"
+	"one-api/dto"
+)
 
 
 type OllamaRequest struct {
 type OllamaRequest struct {
 	Model            string                `json:"model,omitempty"`
 	Model            string                `json:"model,omitempty"`
@@ -19,6 +22,7 @@ type OllamaRequest struct {
 	Suffix           any                   `json:"suffix,omitempty"`
 	Suffix           any                   `json:"suffix,omitempty"`
 	StreamOptions    *dto.StreamOptions    `json:"stream_options,omitempty"`
 	StreamOptions    *dto.StreamOptions    `json:"stream_options,omitempty"`
 	Prompt           any                   `json:"prompt,omitempty"`
 	Prompt           any                   `json:"prompt,omitempty"`
+	Think            json.RawMessage       `json:"think,omitempty"`
 }
 }
 
 
 type Options struct {
 type Options struct {

relay/channel/ollama/relay-ollama.go

@@ -50,7 +50,7 @@ func requestOpenAI2Ollama(request dto.GeneralOpenAIRequest) (*OllamaRequest, err
 	} else {
 	} else {
 		Stop, _ = request.Stop.([]string)
 		Stop, _ = request.Stop.([]string)
 	}
 	}
-	return &OllamaRequest{
+	ollamaRequest := &OllamaRequest{
 		Model:            request.Model,
 		Model:            request.Model,
 		Messages:         messages,
 		Messages:         messages,
 		Stream:           request.Stream,
 		Stream:           request.Stream,
@@ -67,7 +67,11 @@ func requestOpenAI2Ollama(request dto.GeneralOpenAIRequest) (*OllamaRequest, err
 		Prompt:           request.Prompt,
 		Prompt:           request.Prompt,
 		StreamOptions:    request.StreamOptions,
 		StreamOptions:    request.StreamOptions,
 		Suffix:           request.Suffix,
 		Suffix:           request.Suffix,
-	}, nil
+	}
+	if think, ok := request.Extra["think"]; ok {
+		ollamaRequest.Think = think
+	}
+	return ollamaRequest, nil
 }
 }
 
 
 func requestOpenAI2Embeddings(request dto.EmbeddingRequest) *OllamaEmbeddingRequest {
 func requestOpenAI2Embeddings(request dto.EmbeddingRequest) *OllamaEmbeddingRequest {

types/error.go

@@ -105,23 +105,25 @@ func (e *NewAPIError) SetMessage(message string) {
 func (e *NewAPIError) ToOpenAIError() OpenAIError {
 func (e *NewAPIError) ToOpenAIError() OpenAIError {
 	switch e.ErrorType {
 	switch e.ErrorType {
 	case ErrorTypeOpenAIError:
 	case ErrorTypeOpenAIError:
-		return e.RelayError.(OpenAIError)
+		if openAIError, ok := e.RelayError.(OpenAIError); ok {
+			return openAIError
+		}
 	case ErrorTypeClaudeError:
 	case ErrorTypeClaudeError:
-		claudeError := e.RelayError.(ClaudeError)
+		if claudeError, ok := e.RelayError.(ClaudeError); ok {
 			return OpenAIError{
 			return OpenAIError{
 				Message: e.Error(),
 				Message: e.Error(),
 				Type:    claudeError.Type,
 				Type:    claudeError.Type,
 				Param:   "",
 				Param:   "",
 				Code:    e.errorCode,
 				Code:    e.errorCode,
 			}
 			}
-	default:
+		}
+	}
 	return OpenAIError{
 	return OpenAIError{
 		Message: e.Error(),
 		Message: e.Error(),
 		Type:    string(e.ErrorType),
 		Type:    string(e.ErrorType),
 		Param:   "",
 		Param:   "",
 		Code:    e.errorCode,
 		Code:    e.errorCode,
 	}
 	}
-	}
 }
 }
 
 
 func (e *NewAPIError) ToClaudeError() ClaudeError {
 func (e *NewAPIError) ToClaudeError() ClaudeError {
@@ -163,7 +165,10 @@ func NewOpenAIError(err error, errorCode ErrorCode, statusCode int) *NewAPIError
 func NewErrorWithStatusCode(err error, errorCode ErrorCode, statusCode int) *NewAPIError {
 func NewErrorWithStatusCode(err error, errorCode ErrorCode, statusCode int) *NewAPIError {
 	return &NewAPIError{
 	return &NewAPIError{
 		Err: err,
 		Err: err,
-		RelayError: nil,
+		RelayError: OpenAIError{
+			Message: err.Error(),
+			Type:    string(errorCode),
+		},
 		ErrorType:  ErrorTypeNewAPIError,
 		ErrorType:  ErrorTypeNewAPIError,
 		StatusCode: statusCode,
 		StatusCode: statusCode,
 		errorCode:  errorCode,
 		errorCode:  errorCode,