50 {
+ return fmt.Errorf("API信息数量不能超过50个")
+ }
+
+ for i, apiInfo := range apiInfoList {
+ urlStr, ok := apiInfo["url"].(string)
+ if !ok || urlStr == "" {
+ return fmt.Errorf("第%d个API信息缺少URL字段", i+1)
+ }
+ route, ok := apiInfo["route"].(string)
+ if !ok || route == "" {
+ return fmt.Errorf("第%d个API信息缺少线路描述字段", i+1)
+ }
+ description, ok := apiInfo["description"].(string)
+ if !ok || description == "" {
+ return fmt.Errorf("第%d个API信息缺少说明字段", i+1)
+ }
+ color, ok := apiInfo["color"].(string)
+ if !ok || color == "" {
+ return fmt.Errorf("第%d个API信息缺少颜色字段", i+1)
+ }
+
+ if err := validateURL(urlStr, i+1, "API信息"); err != nil {
+ return err
+ }
+
+ if len(urlStr) > 500 {
+ return fmt.Errorf("第%d个API信息的URL长度不能超过500字符", i+1)
+ }
+ if len(route) > 100 {
+ return fmt.Errorf("第%d个API信息的线路描述长度不能超过100字符", i+1)
+ }
+ if len(description) > 200 {
+ return fmt.Errorf("第%d个API信息的说明长度不能超过200字符", i+1)
+ }
+
+ if !validColors[color] {
+ return fmt.Errorf("第%d个API信息的颜色值不合法", i+1)
+ }
+
+ if err := checkDangerousContent(description, i+1, "API信息"); err != nil {
+ return err
+ }
+ if err := checkDangerousContent(route, i+1, "API信息"); err != nil {
+ return err
+ }
+ }
+ return nil
+}
+
+func GetApiInfo() []map[string]interface{} {
+ return getJSONList(GetConsoleSetting().ApiInfo)
+}
+
+func validateAnnouncements(announcementsStr string) error {
+ list, err := parseJSONArray(announcementsStr, "系统公告")
+ if err != nil {
+ return err
+ }
+ if len(list) > 100 {
+ return fmt.Errorf("系统公告数量不能超过100个")
+ }
+ validTypes := map[string]bool{
+ "default": true, "ongoing": true, "success": true, "warning": true, "error": true,
+ }
+ for i, ann := range list {
+ content, ok := ann["content"].(string)
+ if !ok || content == "" {
+ return fmt.Errorf("第%d个公告缺少内容字段", i+1)
+ }
+ publishDateAny, exists := ann["publishDate"]
+ if !exists {
+ return fmt.Errorf("第%d个公告缺少发布日期字段", i+1)
+ }
+ publishDateStr, ok := publishDateAny.(string)
+ if !ok || publishDateStr == "" {
+ return fmt.Errorf("第%d个公告的发布日期不能为空", i+1)
+ }
+ if _, err := time.Parse(time.RFC3339, publishDateStr); err != nil {
+ return fmt.Errorf("第%d个公告的发布日期格式错误", i+1)
+ }
+ if t, exists := ann["type"]; exists {
+ if typeStr, ok := t.(string); ok {
+ if !validTypes[typeStr] {
+ return fmt.Errorf("第%d个公告的类型值不合法", i+1)
+ }
+ }
+ }
+ if len(content) > 500 {
+ return fmt.Errorf("第%d个公告的内容长度不能超过500字符", i+1)
+ }
+ if extra, exists := ann["extra"]; exists {
+ if extraStr, ok := extra.(string); ok && len(extraStr) > 200 {
+ return fmt.Errorf("第%d个公告的说明长度不能超过200字符", i+1)
+ }
+ }
+ }
+ return nil
+}
+
+func validateFAQ(faqStr string) error {
+ list, err := parseJSONArray(faqStr, "FAQ信息")
+ if err != nil {
+ return err
+ }
+ if len(list) > 100 {
+ return fmt.Errorf("FAQ数量不能超过100个")
+ }
+ for i, faq := range list {
+ question, ok := faq["question"].(string)
+ if !ok || question == "" {
+ return fmt.Errorf("第%d个FAQ缺少问题字段", i+1)
+ }
+ answer, ok := faq["answer"].(string)
+ if !ok || answer == "" {
+ return fmt.Errorf("第%d个FAQ缺少答案字段", i+1)
+ }
+ if len(question) > 200 {
+ return fmt.Errorf("第%d个FAQ的问题长度不能超过200字符", i+1)
+ }
+ if len(answer) > 1000 {
+ return fmt.Errorf("第%d个FAQ的答案长度不能超过1000字符", i+1)
+ }
+ }
+ return nil
+}
+
+func getPublishTime(item map[string]interface{}) time.Time {
+ if v, ok := item["publishDate"]; ok {
+ if s, ok2 := v.(string); ok2 {
+ if t, err := time.Parse(time.RFC3339, s); err == nil {
+ return t
+ }
+ }
+ }
+ return time.Time{}
+}
+
+func GetAnnouncements() []map[string]interface{} {
+ list := getJSONList(GetConsoleSetting().Announcements)
+ sort.SliceStable(list, func(i, j int) bool {
+ return getPublishTime(list[i]).After(getPublishTime(list[j]))
+ })
+ return list
+}
+
+func GetFAQ() []map[string]interface{} {
+ return getJSONList(GetConsoleSetting().FAQ)
+}
+
+func validateUptimeKumaGroups(groupsStr string) error {
+ groups, err := parseJSONArray(groupsStr, "Uptime Kuma分组配置")
+ if err != nil {
+ return err
+ }
+
+ if len(groups) > 20 {
+ return fmt.Errorf("Uptime Kuma分组数量不能超过20个")
+ }
+
+ nameSet := make(map[string]bool)
+
+ for i, group := range groups {
+ categoryName, ok := group["categoryName"].(string)
+ if !ok || categoryName == "" {
+ return fmt.Errorf("第%d个分组缺少分类名称字段", i+1)
+ }
+ if nameSet[categoryName] {
+ return fmt.Errorf("第%d个分组的分类名称与其他分组重复", i+1)
+ }
+ nameSet[categoryName] = true
+ urlStr, ok := group["url"].(string)
+ if !ok || urlStr == "" {
+ return fmt.Errorf("第%d个分组缺少URL字段", i+1)
+ }
+ slug, ok := group["slug"].(string)
+ if !ok || slug == "" {
+ return fmt.Errorf("第%d个分组缺少Slug字段", i+1)
+ }
+ description, ok := group["description"].(string)
+ if !ok {
+ description = ""
+ }
+
+ if err := validateURL(urlStr, i+1, "分组"); err != nil {
+ return err
+ }
+
+ if len(categoryName) > 50 {
+ return fmt.Errorf("第%d个分组的分类名称长度不能超过50字符", i+1)
+ }
+ if len(urlStr) > 500 {
+ return fmt.Errorf("第%d个分组的URL长度不能超过500字符", i+1)
+ }
+ if len(slug) > 100 {
+ return fmt.Errorf("第%d个分组的Slug长度不能超过100字符", i+1)
+ }
+ if len(description) > 200 {
+ return fmt.Errorf("第%d个分组的描述长度不能超过200字符", i+1)
+ }
+
+ if !slugRegex.MatchString(slug) {
+ return fmt.Errorf("第%d个分组的Slug只能包含字母、数字、下划线和连字符", i+1)
+ }
+
+ if err := checkDangerousContent(description, i+1, "分组"); err != nil {
+ return err
+ }
+ if err := checkDangerousContent(categoryName, i+1, "分组"); err != nil {
+ return err
+ }
+ }
+ return nil
+}
+
+func GetUptimeKumaGroups() []map[string]interface{} {
+ return getJSONList(GetConsoleSetting().UptimeKumaGroups)
+}
diff --git a/setting/midjourney.go b/setting/midjourney.go
new file mode 100644
index 0000000000000000000000000000000000000000..8b6e08336a4ab30420845496160d8240afa8b0c9
--- /dev/null
+++ b/setting/midjourney.go
@@ -0,0 +1,7 @@
+package setting
+
+var MjNotifyEnabled = false
+var MjAccountFilterEnabled = false
+var MjModeClearEnabled = false
+var MjForwardUrlEnabled = true
+var MjActionCheckSuccessEnabled = true
diff --git a/setting/model_setting/claude.go b/setting/model_setting/claude.go
new file mode 100644
index 0000000000000000000000000000000000000000..c8baff14f19ceffe2c93cb2f5432a5238a744b8d
--- /dev/null
+++ b/setting/model_setting/claude.go
@@ -0,0 +1,65 @@
+package model_setting
+
+import (
+ "net/http"
+ "one-api/setting/config"
+)
+
+//var claudeHeadersSettings = map[string][]string{}
+//
+//var ClaudeThinkingAdapterEnabled = true
+//var ClaudeThinkingAdapterMaxTokens = 8192
+//var ClaudeThinkingAdapterBudgetTokensPercentage = 0.8
+
+// ClaudeSettings 定义Claude模型的配置
+type ClaudeSettings struct {
+ HeadersSettings map[string]map[string][]string `json:"model_headers_settings"`
+ DefaultMaxTokens map[string]int `json:"default_max_tokens"`
+ ThinkingAdapterEnabled bool `json:"thinking_adapter_enabled"`
+ ThinkingAdapterBudgetTokensPercentage float64 `json:"thinking_adapter_budget_tokens_percentage"`
+}
+
+// 默认配置
+var defaultClaudeSettings = ClaudeSettings{
+ HeadersSettings: map[string]map[string][]string{},
+ ThinkingAdapterEnabled: true,
+ DefaultMaxTokens: map[string]int{
+ "default": 8192,
+ },
+ ThinkingAdapterBudgetTokensPercentage: 0.8,
+}
+
+// 全局实例
+var claudeSettings = defaultClaudeSettings
+
+func init() {
+ // 注册到全局配置管理器
+ config.GlobalConfig.Register("claude", &claudeSettings)
+}
+
+// GetClaudeSettings 获取Claude配置
+func GetClaudeSettings() *ClaudeSettings {
+ // check default max tokens must have default key
+ if _, ok := claudeSettings.DefaultMaxTokens["default"]; !ok {
+ claudeSettings.DefaultMaxTokens["default"] = 8192
+ }
+ return &claudeSettings
+}
+
+func (c *ClaudeSettings) WriteHeaders(originModel string, httpHeader *http.Header) {
+ if headers, ok := c.HeadersSettings[originModel]; ok {
+ for headerKey, headerValues := range headers {
+ httpHeader.Del(headerKey)
+ for _, headerValue := range headerValues {
+ httpHeader.Add(headerKey, headerValue)
+ }
+ }
+ }
+}
+
+func (c *ClaudeSettings) GetDefaultMaxTokens(model string) int {
+ if maxTokens, ok := c.DefaultMaxTokens[model]; ok {
+ return maxTokens
+ }
+ return c.DefaultMaxTokens["default"]
+}
diff --git a/setting/model_setting/gemini.go b/setting/model_setting/gemini.go
new file mode 100644
index 0000000000000000000000000000000000000000..d41def59bb4d6e1935f3f6718d5b0ff37f0032a1
--- /dev/null
+++ b/setting/model_setting/gemini.go
@@ -0,0 +1,70 @@
+package model_setting
+
+import (
+ "one-api/setting/config"
+)
+
+// GeminiSettings 定义Gemini模型的配置
+type GeminiSettings struct {
+ SafetySettings map[string]string `json:"safety_settings"`
+ VersionSettings map[string]string `json:"version_settings"`
+ SupportedImagineModels []string `json:"supported_imagine_models"`
+ ThinkingAdapterEnabled bool `json:"thinking_adapter_enabled"`
+ ThinkingAdapterBudgetTokensPercentage float64 `json:"thinking_adapter_budget_tokens_percentage"`
+}
+
+// 默认配置
+var defaultGeminiSettings = GeminiSettings{
+ SafetySettings: map[string]string{
+ "default": "OFF",
+ "HARM_CATEGORY_CIVIC_INTEGRITY": "BLOCK_NONE",
+ },
+ VersionSettings: map[string]string{
+ "default": "v1beta",
+ "gemini-1.0-pro": "v1",
+ },
+ SupportedImagineModels: []string{
+ "gemini-2.0-flash-exp-image-generation",
+ "gemini-2.0-flash-exp",
+ },
+ ThinkingAdapterEnabled: false,
+ ThinkingAdapterBudgetTokensPercentage: 0.6,
+}
+
+// 全局实例
+var geminiSettings = defaultGeminiSettings
+
+func init() {
+ // 注册到全局配置管理器
+ config.GlobalConfig.Register("gemini", &geminiSettings)
+}
+
+// GetGeminiSettings 获取Gemini配置
+func GetGeminiSettings() *GeminiSettings {
+ return &geminiSettings
+}
+
+// GetGeminiSafetySetting 获取安全设置
+func GetGeminiSafetySetting(key string) string {
+ if value, ok := geminiSettings.SafetySettings[key]; ok {
+ return value
+ }
+ return geminiSettings.SafetySettings["default"]
+}
+
+// GetGeminiVersionSetting 获取版本设置
+func GetGeminiVersionSetting(key string) string {
+ if value, ok := geminiSettings.VersionSettings[key]; ok {
+ return value
+ }
+ return geminiSettings.VersionSettings["default"]
+}
+
+func IsGeminiModelSupportImagine(model string) bool {
+ for _, v := range geminiSettings.SupportedImagineModels {
+ if v == model {
+ return true
+ }
+ }
+ return false
+}
diff --git a/setting/model_setting/global.go b/setting/model_setting/global.go
new file mode 100644
index 0000000000000000000000000000000000000000..9eccb2158fd3e9b7e6ff005edc1b42da06a99451
--- /dev/null
+++ b/setting/model_setting/global.go
@@ -0,0 +1,26 @@
+package model_setting
+
+import (
+ "one-api/setting/config"
+)
+
+type GlobalSettings struct {
+ PassThroughRequestEnabled bool `json:"pass_through_request_enabled"`
+}
+
+// 默认配置
+var defaultOpenaiSettings = GlobalSettings{
+ PassThroughRequestEnabled: false,
+}
+
+// 全局实例
+var globalSettings = defaultOpenaiSettings
+
+func init() {
+ // 注册到全局配置管理器
+ config.GlobalConfig.Register("global", &globalSettings)
+}
+
+func GetGlobalSettings() *GlobalSettings {
+ return &globalSettings
+}
diff --git a/setting/operation_setting/general_setting.go b/setting/operation_setting/general_setting.go
new file mode 100644
index 0000000000000000000000000000000000000000..c68b0314ab2c8b3386b1ca92263b802fba515e23
--- /dev/null
+++ b/setting/operation_setting/general_setting.go
@@ -0,0 +1,25 @@
+package operation_setting
+
+import "one-api/setting/config"
+
+type GeneralSetting struct {
+ DocsLink string `json:"docs_link"`
+ PingIntervalEnabled bool `json:"ping_interval_enabled"`
+ PingIntervalSeconds int `json:"ping_interval_seconds"`
+}
+
+// 默认配置
+var generalSetting = GeneralSetting{
+ DocsLink: "https://docs.newapi.pro",
+ PingIntervalEnabled: false,
+ PingIntervalSeconds: 60,
+}
+
+func init() {
+ // 注册到全局配置管理器
+ config.GlobalConfig.Register("general_setting", &generalSetting)
+}
+
+func GetGeneralSetting() *GeneralSetting {
+ return &generalSetting
+}
diff --git a/setting/operation_setting/monitor_setting.go b/setting/operation_setting/monitor_setting.go
new file mode 100644
index 0000000000000000000000000000000000000000..b24eec0160aaa4a809a709348517a6cbcd70354f
--- /dev/null
+++ b/setting/operation_setting/monitor_setting.go
@@ -0,0 +1,34 @@
+package operation_setting
+
+import (
+ "one-api/setting/config"
+ "os"
+ "strconv"
+)
+
+type MonitorSetting struct {
+ AutoTestChannelEnabled bool `json:"auto_test_channel_enabled"`
+ AutoTestChannelMinutes int `json:"auto_test_channel_minutes"`
+}
+
+// 默认配置
+var monitorSetting = MonitorSetting{
+ AutoTestChannelEnabled: false,
+ AutoTestChannelMinutes: 10,
+}
+
+func init() {
+ // 注册到全局配置管理器
+ config.GlobalConfig.Register("monitor_setting", &monitorSetting)
+}
+
+func GetMonitorSetting() *MonitorSetting {
+ if os.Getenv("CHANNEL_TEST_FREQUENCY") != "" {
+ frequency, err := strconv.Atoi(os.Getenv("CHANNEL_TEST_FREQUENCY"))
+ if err == nil && frequency > 0 {
+ monitorSetting.AutoTestChannelEnabled = true
+ monitorSetting.AutoTestChannelMinutes = frequency
+ }
+ }
+ return &monitorSetting
+}
diff --git a/setting/operation_setting/operation_setting.go b/setting/operation_setting/operation_setting.go
new file mode 100644
index 0000000000000000000000000000000000000000..0f7cefc2eafb9d84d6cc1c76a15e14011c3b31b0
--- /dev/null
+++ b/setting/operation_setting/operation_setting.go
@@ -0,0 +1,32 @@
+package operation_setting
+
+import "strings"
+
+var DemoSiteEnabled = false
+var SelfUseModeEnabled = false
+
+var AutomaticDisableKeywords = []string{
+ "Your credit balance is too low",
+ "This organization has been disabled.",
+ "You exceeded your current quota",
+ "Permission denied",
+ "The security token included in the request is invalid",
+ "Operation not allowed",
+ "Your account is not authorized",
+}
+
+func AutomaticDisableKeywordsToString() string {
+ return strings.Join(AutomaticDisableKeywords, "\n")
+}
+
+func AutomaticDisableKeywordsFromString(s string) {
+ AutomaticDisableKeywords = []string{}
+ ak := strings.Split(s, "\n")
+ for _, k := range ak {
+ k = strings.TrimSpace(k)
+ k = strings.ToLower(k)
+ if k != "" {
+ AutomaticDisableKeywords = append(AutomaticDisableKeywords, k)
+ }
+ }
+}
diff --git a/setting/operation_setting/payment_setting.go b/setting/operation_setting/payment_setting.go
new file mode 100644
index 0000000000000000000000000000000000000000..8d85fc3b275d1f38c7d1cccd55a892e19e231a53
--- /dev/null
+++ b/setting/operation_setting/payment_setting.go
@@ -0,0 +1,23 @@
+package operation_setting
+
+import "one-api/setting/config"
+
+type PaymentSetting struct {
+ AmountOptions []int `json:"amount_options"`
+ AmountDiscount map[int]float64 `json:"amount_discount"` // 充值金额对应的折扣，例如 100 元 0.9 表示 100 元充值享受 9 折优惠
+}
+
+// 默认配置
+var paymentSetting = PaymentSetting{
+ AmountOptions: []int{10, 20, 50, 100, 200, 500},
+ AmountDiscount: map[int]float64{},
+}
+
+func init() {
+ // 注册到全局配置管理器
+ config.GlobalConfig.Register("payment_setting", &paymentSetting)
+}
+
+func GetPaymentSetting() *PaymentSetting {
+ return &paymentSetting
+}
diff --git a/setting/operation_setting/payment_setting_old.go b/setting/operation_setting/payment_setting_old.go
new file mode 100644
index 0000000000000000000000000000000000000000..3b012361edfae43ec47674407eb03cb351b62527
--- /dev/null
+++ b/setting/operation_setting/payment_setting_old.go
@@ -0,0 +1,59 @@
+/**
+此文件为旧版支付设置文件，如需增加新的参数、变量等，请在 payment_setting.go 中添加
+This file is the old version of the payment settings file. If you need to add new parameters, variables, etc., please add them in payment_setting.go
+*/
+
+package operation_setting
+
+import (
+ "one-api/common"
+)
+
+var PayAddress = ""
+var CustomCallbackAddress = ""
+var EpayId = ""
+var EpayKey = ""
+var Price = 7.3
+var MinTopUp = 1
+var USDExchangeRate = 7.3
+
+var PayMethods = []map[string]string{
+ {
+ "name": "支付宝",
+ "color": "rgba(var(--semi-blue-5), 1)",
+ "type": "alipay",
+ },
+ {
+ "name": "微信",
+ "color": "rgba(var(--semi-green-5), 1)",
+ "type": "wxpay",
+ },
+ {
+ "name": "自定义1",
+ "color": "black",
+ "type": "custom1",
+ "min_topup": "50",
+ },
+}
+
+func UpdatePayMethodsByJsonString(jsonString string) error {
+ PayMethods = make([]map[string]string, 0)
+ return common.Unmarshal([]byte(jsonString), &PayMethods)
+}
+
+func PayMethods2JsonString() string {
+ jsonBytes, err := common.Marshal(PayMethods)
+ if err != nil {
+ return "[]"
+ }
+ return string(jsonBytes)
+}
+
+func ContainsPayMethod(method string) bool {
+ for _, payMethod := range PayMethods {
+ if payMethod["type"] == method {
+ return true
+ }
+ }
+ return false
+}
diff --git a/setting/operation_setting/tools.go b/setting/operation_setting/tools.go
new file mode 100644
index 0000000000000000000000000000000000000000..f3030ef53014bd3e6aaf9ab31d17b6dad16e3534
--- /dev/null
+++ b/setting/operation_setting/tools.go
@@ -0,0 +1,110 @@
+package operation_setting
+
+import "strings"
+
+const (
+ // Web search
+ WebSearchPriceHigh = 25.00
+ WebSearchPrice = 10.00
+ // File search
+ FileSearchPrice = 2.5
+)
+
+const (
+ GPTImage1Low1024x1024 = 0.011
+ GPTImage1Low1024x1536 = 0.016
+ GPTImage1Low1536x1024 = 0.016
+ GPTImage1Medium1024x1024 = 0.042
+ GPTImage1Medium1024x1536 = 0.063
+ GPTImage1Medium1536x1024 = 0.063
+ GPTImage1High1024x1024 = 0.167
+ GPTImage1High1024x1536 = 0.25
+ GPTImage1High1536x1024 = 0.25
+)
+
+const (
+ // Gemini Audio Input Price
+ Gemini25FlashPreviewInputAudioPrice = 1.00
+ Gemini25FlashProductionInputAudioPrice = 1.00 // for `gemini-2.5-flash`
+ Gemini25FlashLitePreviewInputAudioPrice = 0.50
+ Gemini25FlashNativeAudioInputAudioPrice = 3.00
+ Gemini20FlashInputAudioPrice = 0.70
+ GeminiRoboticsER15InputAudioPrice = 1.00
+)
+
+const (
+ // Claude Web search
+ ClaudeWebSearchPrice = 10.00
+)
+
+func GetClaudeWebSearchPricePerThousand() float64 {
+ return ClaudeWebSearchPrice
+}
+
+func GetWebSearchPricePerThousand(modelName string, contextSize string) float64 {
+ // 确定模型类型
+ // https://platform.openai.com/docs/pricing Web search 价格按模型类型收费
+ // 新版计费规则不再关联 search context size，故在const区域将各size的价格设为一致。
+ // gpt-5, gpt-5-mini, gpt-5-nano 和 o 系列模型价格为 10.00 美元/千次调用，产生额外 token 计入 input_tokens
+ // gpt-4o, gpt-4.1, gpt-4o-mini 和 gpt-4.1-mini 价格为 25.00 美元/千次调用，不产生额外 token
+ isNormalPriceModel :=
+ strings.HasPrefix(modelName, "o3") ||
+ strings.HasPrefix(modelName, "o4") ||
+ strings.HasPrefix(modelName, "gpt-5")
+ var priceWebSearchPerThousandCalls float64
+ if isNormalPriceModel {
+ priceWebSearchPerThousandCalls = WebSearchPrice
+ } else {
+ priceWebSearchPerThousandCalls = WebSearchPriceHigh
+ }
+ return priceWebSearchPerThousandCalls
+}
+
+func GetFileSearchPricePerThousand() float64 {
+ return FileSearchPrice
+}
+
+func GetGeminiInputAudioPricePerMillionTokens(modelName string) float64 {
+ if strings.HasPrefix(modelName, "gemini-2.5-flash-preview-native-audio") {
+ return Gemini25FlashNativeAudioInputAudioPrice
+ } else if strings.HasPrefix(modelName, "gemini-2.5-flash-preview-lite") {
+ return Gemini25FlashLitePreviewInputAudioPrice
+ } else if strings.HasPrefix(modelName, "gemini-2.5-flash-preview") {
+ return Gemini25FlashPreviewInputAudioPrice
+ } else if strings.HasPrefix(modelName, "gemini-2.5-flash") {
+ return Gemini25FlashProductionInputAudioPrice
+ } else if strings.HasPrefix(modelName, "gemini-2.0-flash") {
+ return Gemini20FlashInputAudioPrice
+ } else if strings.HasPrefix(modelName, "gemini-robotics-er-1.5") {
+ return GeminiRoboticsER15InputAudioPrice
+ }
+ return 0
+}
+
+func GetGPTImage1PriceOnceCall(quality string, size string) float64 {
+ prices := map[string]map[string]float64{
+ "low": {
+ "1024x1024": GPTImage1Low1024x1024,
+ "1024x1536": GPTImage1Low1024x1536,
+ "1536x1024": GPTImage1Low1536x1024,
+ },
+ "medium": {
+ "1024x1024": GPTImage1Medium1024x1024,
+ "1024x1536": GPTImage1Medium1024x1536,
+ "1536x1024": GPTImage1Medium1536x1024,
+ },
+ "high": {
+ "1024x1024": GPTImage1High1024x1024,
+ "1024x1536": GPTImage1High1024x1536,
+ "1536x1024": GPTImage1High1536x1024,
+ },
+ }
+
+ if qualityMap, exists := prices[quality]; exists {
+ if price, exists := qualityMap[size]; exists {
+ return price
+ }
+ }
+
+ return GPTImage1High1024x1024
+}
diff --git a/setting/payment_stripe.go b/setting/payment_stripe.go
new file mode 100644
index 0000000000000000000000000000000000000000..3a397227b0df30e52cd5225802907aba31799a9b
--- /dev/null
+++ b/setting/payment_stripe.go
@@ -0,0 +1,8 @@
+package setting
+
+var StripeApiSecret = ""
+var StripeWebhookSecret = ""
+var StripePriceId = ""
+var StripeUnitPrice = 8.0
+var StripeMinTopUp = 1
+var StripePromotionCodesEnabled = false
diff --git a/setting/rate_limit.go b/setting/rate_limit.go
new file mode 100644
index 0000000000000000000000000000000000000000..b99810a0e32b991470ba08a291dbee5a770329fa
--- /dev/null
+++ b/setting/rate_limit.go
@@ -0,0 +1,68 @@
+package setting
+
+import (
+ "encoding/json"
+ "fmt"
+ "math"
+ "one-api/common"
+ "sync"
+)
+
+var ModelRequestRateLimitEnabled = false
+var ModelRequestRateLimitDurationMinutes = 1
+var ModelRequestRateLimitCount = 0
+var ModelRequestRateLimitSuccessCount = 1000
+var ModelRequestRateLimitGroup = map[string][2]int{}
+var ModelRequestRateLimitMutex sync.RWMutex
+
+func ModelRequestRateLimitGroup2JSONString() string {
+ ModelRequestRateLimitMutex.RLock()
+ defer ModelRequestRateLimitMutex.RUnlock()
+
+ jsonBytes, err := json.Marshal(ModelRequestRateLimitGroup)
+ if err != nil {
+ common.SysLog("error marshalling model ratio: " + err.Error())
+ }
+ return string(jsonBytes)
+}
+
+func UpdateModelRequestRateLimitGroupByJSONString(jsonStr string) error {
+ ModelRequestRateLimitMutex.RLock()
+ defer ModelRequestRateLimitMutex.RUnlock()
+
+ ModelRequestRateLimitGroup = make(map[string][2]int)
+ return json.Unmarshal([]byte(jsonStr), &ModelRequestRateLimitGroup)
+}
+
+func GetGroupRateLimit(group string) (totalCount, successCount int, found bool) {
+ ModelRequestRateLimitMutex.RLock()
+ defer ModelRequestRateLimitMutex.RUnlock()
+
+ if ModelRequestRateLimitGroup == nil {
+ return 0, 0, false
+ }
+
+ limits, found := ModelRequestRateLimitGroup[group]
+ if !found {
+ return 0, 0, false
+ }
+ return limits[0], limits[1], true
+}
+
+func CheckModelRequestRateLimitGroup(jsonStr string) error {
+ checkModelRequestRateLimitGroup := make(map[string][2]int)
+ err := json.Unmarshal([]byte(jsonStr), &checkModelRequestRateLimitGroup)
+ if err != nil {
+ return err
+ }
+ for group, limits := range checkModelRequestRateLimitGroup {
+ if limits[0] < 0 || limits[1] < 1 {
+ return fmt.Errorf("group %s has negative rate limit values: [%d, %d]", group, limits[0], limits[1])
+ }
+ if limits[0] > math.MaxInt32 || limits[1] > math.MaxInt32 {
+ return fmt.Errorf("group %s [%d, %d] has max rate limits value 2147483647", group, limits[0], limits[1])
+ }
+ }
+
+ return nil
+}
diff --git a/setting/ratio_setting/cache_ratio.go b/setting/ratio_setting/cache_ratio.go
new file mode 100644
index 0000000000000000000000000000000000000000..b53d2c3d1b20ff9c9b0e6913d00ebfeb41337688
--- /dev/null
+++ b/setting/ratio_setting/cache_ratio.go
@@ -0,0 +1,140 @@
+package ratio_setting
+
+import (
+ "encoding/json"
+ "one-api/common"
+ "sync"
+)
+
+var defaultCacheRatio = map[string]float64{
+ "gpt-4": 0.5,
+ "o1": 0.5,
+ "o1-2024-12-17": 0.5,
+ "o1-preview-2024-09-12": 0.5,
+ "o1-preview": 0.5,
+ "o1-mini-2024-09-12": 0.5,
+ "o1-mini": 0.5,
+ "o3-mini": 0.5,
+ "o3-mini-2025-01-31": 0.5,
+ "gpt-4o-2024-11-20": 0.5,
+ "gpt-4o-2024-08-06": 0.5,
+ "gpt-4o": 0.5,
+ "gpt-4o-mini-2024-07-18": 0.5,
+ "gpt-4o-mini": 0.5,
+ "gpt-4o-realtime-preview": 0.5,
+ "gpt-4o-mini-realtime-preview": 0.5,
+ "gpt-4.5-preview": 0.5,
+ "gpt-4.5-preview-2025-02-27": 0.5,
+ "gpt-4.1": 0.25,
+ "gpt-4.1-mini": 0.25,
+ "gpt-4.1-nano": 0.25,
+ "gpt-5": 0.1,
+ "gpt-5-2025-08-07": 0.1,
+ "gpt-5-chat-latest": 0.1,
+ "gpt-5-mini": 0.1,
+ "gpt-5-mini-2025-08-07": 0.1,
+ "gpt-5-nano": 0.1,
+ "gpt-5-nano-2025-08-07": 0.1,
+ "deepseek-chat": 0.25,
+ "deepseek-reasoner": 0.25,
+ "deepseek-coder": 0.25,
+ "claude-3-sonnet-20240229": 0.1,
+ "claude-3-opus-20240229": 0.1,
+ "claude-3-haiku-20240307": 0.1,
+ "claude-3-5-haiku-20241022": 0.1,
+ "claude-3-5-sonnet-20240620": 0.1,
+ "claude-3-5-sonnet-20241022": 0.1,
+ "claude-3-7-sonnet-20250219": 0.1,
+ "claude-3-7-sonnet-20250219-thinking": 0.1,
+ "claude-sonnet-4-20250514": 0.1,
+ "claude-sonnet-4-20250514-thinking": 0.1,
+ "claude-opus-4-20250514": 0.1,
+ "claude-opus-4-20250514-thinking": 0.1,
+ "claude-opus-4-1-20250805": 0.1,
+ "claude-opus-4-1-20250805-thinking": 0.1,
+ "claude-sonnet-4-5-20250929": 0.1,
+ "claude-sonnet-4-5-20250929-thinking": 0.1,
+}
+
+var defaultCreateCacheRatio = map[string]float64{
+ "claude-3-sonnet-20240229": 1.25,
+ "claude-3-opus-20240229": 1.25,
+ "claude-3-haiku-20240307": 1.25,
+ "claude-3-5-haiku-20241022": 1.25,
+ "claude-3-5-sonnet-20240620": 1.25,
+ "claude-3-5-sonnet-20241022": 1.25,
+ "claude-3-7-sonnet-20250219": 1.25,
+ "claude-3-7-sonnet-20250219-thinking": 1.25,
+ "claude-sonnet-4-20250514": 1.25,
+ "claude-sonnet-4-20250514-thinking": 1.25,
+ "claude-opus-4-20250514": 1.25,
+ "claude-opus-4-20250514-thinking": 1.25,
+ "claude-opus-4-1-20250805": 1.25,
+ "claude-opus-4-1-20250805-thinking": 1.25,
+ "claude-sonnet-4-5-20250929": 1.25,
+ "claude-sonnet-4-5-20250929-thinking": 1.25,
+}
+
+//var defaultCreateCacheRatio = map[string]float64{}
+
+var cacheRatioMap map[string]float64
+var cacheRatioMapMutex sync.RWMutex
+
+// GetCacheRatioMap returns the cache ratio map
+func GetCacheRatioMap() map[string]float64 {
+ cacheRatioMapMutex.RLock()
+ defer cacheRatioMapMutex.RUnlock()
+ return cacheRatioMap
+}
+
+// CacheRatio2JSONString converts the cache ratio map to a JSON string
+func CacheRatio2JSONString() string {
+ cacheRatioMapMutex.RLock()
+ defer cacheRatioMapMutex.RUnlock()
+ jsonBytes, err := json.Marshal(cacheRatioMap)
+ if err != nil {
+ common.SysLog("error marshalling cache ratio: " + err.Error())
+ }
+ return string(jsonBytes)
+}
+
+// UpdateCacheRatioByJSONString updates the cache ratio map from a JSON string
+func UpdateCacheRatioByJSONString(jsonStr string) error {
+ cacheRatioMapMutex.Lock()
+ defer cacheRatioMapMutex.Unlock()
+ cacheRatioMap = make(map[string]float64)
+ err := json.Unmarshal([]byte(jsonStr), &cacheRatioMap)
+ if err == nil {
+ InvalidateExposedDataCache()
+ }
+ return err
+}
+
+// GetCacheRatio returns the cache ratio for a model
+func GetCacheRatio(name string) (float64, bool) {
+ cacheRatioMapMutex.RLock()
+ defer cacheRatioMapMutex.RUnlock()
+ ratio, ok := cacheRatioMap[name]
+ if !ok {
+ return 1, false // Default to 1 if not found
+ }
+ return ratio, true
+}
+
+func GetCreateCacheRatio(name string) (float64, bool) {
+ ratio, ok := defaultCreateCacheRatio[name]
+ if !ok {
+ return 1.25, false // Default to 1.25 if not found
+ }
+ return ratio, true
+}
+
+func GetCacheRatioCopy() map[string]float64 {
+ cacheRatioMapMutex.RLock()
+ defer cacheRatioMapMutex.RUnlock()
+ copyMap := make(map[string]float64, len(cacheRatioMap))
+ for k, v := range cacheRatioMap {
+ copyMap[k] = v
+ }
+ return copyMap
+}
diff --git a/setting/ratio_setting/expose_ratio.go b/setting/ratio_setting/expose_ratio.go
new file mode 100644
index 0000000000000000000000000000000000000000..1c1833b385339223603547fe56579fa8ea5bcbe2
--- /dev/null
+++ b/setting/ratio_setting/expose_ratio.go
@@ -0,0 +1,17 @@
+package ratio_setting
+
+import "sync/atomic"
+
+var exposeRatioEnabled atomic.Bool
+
+func init() {
+ exposeRatioEnabled.Store(false)
+}
+
+func SetExposeRatioEnabled(enabled bool) {
+ exposeRatioEnabled.Store(enabled)
+}
+
+func IsExposeRatioEnabled() bool {
+ return exposeRatioEnabled.Load()
+}
diff --git a/setting/ratio_setting/exposed_cache.go b/setting/ratio_setting/exposed_cache.go
new file mode 100644
index 0000000000000000000000000000000000000000..a6131bebabe10ce72578f4e0460c73e25062bfc2
--- /dev/null
+++ b/setting/ratio_setting/exposed_cache.go
@@ -0,0 +1,55 @@
+package ratio_setting
+
+import (
+ "sync"
+ "sync/atomic"
+ "time"
+
+ "github.com/gin-gonic/gin"
+)
+
+const exposedDataTTL = 30 * time.Second
+
+type exposedCache struct {
+ data gin.H
+ expiresAt time.Time
+}
+
+var (
+ exposedData atomic.Value
+ rebuildMu sync.Mutex
+)
+
+func InvalidateExposedDataCache() {
+ exposedData.Store((*exposedCache)(nil))
+}
+
+func cloneGinH(src gin.H) gin.H {
+ dst := make(gin.H, len(src))
+ for k, v := range src {
+ dst[k] = v
+ }
+ return dst
+}
+
+func GetExposedData() gin.H {
+ if c, ok := exposedData.Load().(*exposedCache); ok && c != nil && time.Now().Before(c.expiresAt) {
+ return cloneGinH(c.data)
+ }
+ rebuildMu.Lock()
+ defer rebuildMu.Unlock()
+ if c, ok := exposedData.Load().(*exposedCache); ok && c != nil && time.Now().Before(c.expiresAt) {
+ return cloneGinH(c.data)
+ }
+ newData := gin.H{
+ "model_ratio": GetModelRatioCopy(),
+ "completion_ratio": GetCompletionRatioCopy(),
+ "cache_ratio": GetCacheRatioCopy(),
+ "model_price": GetModelPriceCopy(),
+ }
+ exposedData.Store(&exposedCache{
+ data: newData,
+ expiresAt: time.Now().Add(exposedDataTTL),
+ })
+ return cloneGinH(newData)
+}
diff --git a/setting/ratio_setting/group_ratio.go b/setting/ratio_setting/group_ratio.go
new file mode 100644
index 0000000000000000000000000000000000000000..a3fcafd999e479dc80b635e7f4b965d84366ea44
--- /dev/null
+++ b/setting/ratio_setting/group_ratio.go
@@ -0,0 +1,122 @@
+package ratio_setting
+
+import (
+ "encoding/json"
+ "errors"
+ "one-api/common"
+ "sync"
+)
+
+var groupRatio = map[string]float64{
+ "default": 1,
+ "vip": 1,
+ "svip": 1,
+}
+var groupRatioMutex sync.RWMutex
+
+var (
+ GroupGroupRatio = map[string]map[string]float64{
+ "vip": {
+ "edit_this": 0.9,
+ },
+ }
+ groupGroupRatioMutex sync.RWMutex
+)
+
+func GetGroupRatioCopy() map[string]float64 {
+ groupRatioMutex.RLock()
+ defer groupRatioMutex.RUnlock()
+
+ groupRatioCopy := make(map[string]float64)
+ for k, v := range groupRatio {
+ groupRatioCopy[k] = v
+ }
+ return groupRatioCopy
+}
+
+func ContainsGroupRatio(name string) bool {
+ groupRatioMutex.RLock()
+ defer groupRatioMutex.RUnlock()
+
+ _, ok := groupRatio[name]
+ return ok
+}
+
+func GroupRatio2JSONString() string {
+ groupRatioMutex.RLock()
+ defer groupRatioMutex.RUnlock()
+
+ jsonBytes, err := json.Marshal(groupRatio)
+ if err != nil {
+ common.SysLog("error marshalling model ratio: " + err.Error())
+ }
+ return string(jsonBytes)
+}
+
+func UpdateGroupRatioByJSONString(jsonStr string) error {
+ groupRatioMutex.Lock()
+ defer groupRatioMutex.Unlock()
+
+ groupRatio = make(map[string]float64)
+ return json.Unmarshal([]byte(jsonStr), &groupRatio)
+}
+
+func GetGroupRatio(name string) float64 {
+ groupRatioMutex.RLock()
+ defer groupRatioMutex.RUnlock()
+
+ ratio, ok := groupRatio[name]
+ if !ok {
+ common.SysLog("group ratio not found: " + name)
+ return 1
+ }
+ return ratio
+}
+
+func GetGroupGroupRatio(userGroup, usingGroup string) (float64, bool) {
+ groupGroupRatioMutex.RLock()
+ defer groupGroupRatioMutex.RUnlock()
+
+ gp, ok := GroupGroupRatio[userGroup]
+ if !ok {
+ return -1, false
+ }
+ ratio, ok := gp[usingGroup]
+ if !ok {
+ return -1, false
+ }
+ return ratio, true
+}
+
+func GroupGroupRatio2JSONString() string {
+ groupGroupRatioMutex.RLock()
+ defer groupGroupRatioMutex.RUnlock()
+
+ jsonBytes, err := json.Marshal(GroupGroupRatio)
+ if err != nil {
+ common.SysLog("error marshalling group-group ratio: " + err.Error())
+ }
+ return string(jsonBytes)
+}
+
+func UpdateGroupGroupRatioByJSONString(jsonStr string) error {
+ groupGroupRatioMutex.Lock()
+ defer groupGroupRatioMutex.Unlock()
+
+ GroupGroupRatio = make(map[string]map[string]float64)
+ return json.Unmarshal([]byte(jsonStr), &GroupGroupRatio)
+}
+
+func CheckGroupRatio(jsonStr string) error {
+ checkGroupRatio := make(map[string]float64)
+ err := json.Unmarshal([]byte(jsonStr), &checkGroupRatio)
+ if err != nil {
+ return err
+ }
+ for name, ratio := range checkGroupRatio {
+ if ratio < 0 {
+ return errors.New("group ratio must be not less than 0: " + name)
+ }
+ }
+ return nil
+}
diff --git a/setting/ratio_setting/model_ratio.go b/setting/ratio_setting/model_ratio.go
new file mode 100644
index 0000000000000000000000000000000000000000..608594793a4f54e2991b37e85e6418035500d625
--- /dev/null
+++ b/setting/ratio_setting/model_ratio.go
@@ -0,0 +1,817 @@
+package ratio_setting
+
+import (
+ "encoding/json"
+ "one-api/common"
+ "one-api/setting/operation_setting"
+ "strings"
+ "sync"
+)
+
+// from songquanpeng/one-api
+const (
+ USD2RMB = 7.3 // 暂定 1 USD = 7.3 RMB
+ USD = 500 // $0.002 = 1 -> $1 = 500
+ RMB = USD / USD2RMB
+)
+
+// modelRatio
+// https://platform.openai.com/docs/models/model-endpoint-compatibility
+// https://cloud.baidu.com/doc/WENXINWORKSHOP/s/Blfmc9dlf
+// https://openai.com/pricing
+// TODO: when a new api is enabled, check the pricing here
+// 1 === $0.002 / 1K tokens
+// 1 === ￥0.014 / 1k tokens
+
+var defaultModelRatio = map[string]float64{
+ //"midjourney": 50,
+ "gpt-4-gizmo-*": 15,
+ "gpt-4o-gizmo-*": 2.5,
+ "gpt-4-all": 15,
+ "gpt-4o-all": 15,
+ "gpt-4": 15,
+ //"gpt-4-0314": 15, //deprecated
+ "gpt-4-0613": 15,
+ "gpt-4-32k": 30,
+ //"gpt-4-32k-0314": 30, //deprecated
+ "gpt-4-32k-0613": 30,
+ "gpt-4-1106-preview": 5, // $10 / 1M tokens
+ "gpt-4-0125-preview": 5, // $10 / 1M tokens
+ "gpt-4-turbo-preview": 5, // $10 / 1M tokens
+ "gpt-4-vision-preview": 5, // $10 / 1M tokens
+ "gpt-4-1106-vision-preview": 5, // $10 / 1M tokens
+ "chatgpt-4o-latest": 2.5, // $5 / 1M tokens
+ "gpt-4o": 1.25, // $2.5 / 1M tokens
+ "gpt-4o-audio-preview": 1.25, // $2.5 / 1M tokens
+ "gpt-4o-audio-preview-2024-10-01": 1.25, // $2.5 / 1M tokens
+ "gpt-4o-2024-05-13": 2.5, // $5 / 1M tokens
+ "gpt-4o-2024-08-06": 1.25, // $2.5 / 1M tokens
+ "gpt-4o-2024-11-20": 1.25, // $2.5 / 1M tokens
+ "gpt-4o-realtime-preview": 2.5,
+ "gpt-4o-realtime-preview-2024-10-01": 2.5,
+ "gpt-4o-realtime-preview-2024-12-17": 2.5,
+ "gpt-4o-mini-realtime-preview": 0.3,
+ "gpt-4o-mini-realtime-preview-2024-12-17": 0.3,
+ "gpt-4.1": 1.0, // $2 / 1M tokens
+ "gpt-4.1-2025-04-14": 1.0, // $2 / 1M tokens
+ "gpt-4.1-mini": 0.2, // $0.4 / 1M tokens
+ "gpt-4.1-mini-2025-04-14": 0.2, // $0.4 / 1M tokens
+ "gpt-4.1-nano": 0.05, // $0.1 / 1M tokens
+ "gpt-4.1-nano-2025-04-14": 0.05, // $0.1 / 1M tokens
+ "gpt-image-1": 2.5, // $5 / 1M tokens
+ "o1": 7.5, // $15 / 1M tokens
+ "o1-2024-12-17": 7.5, // $15 / 1M tokens
+ "o1-preview": 7.5, // $15 / 1M tokens
+ "o1-preview-2024-09-12": 7.5, // $15 / 1M tokens
+ "o1-mini": 0.55, // $1.1 / 1M tokens
+ "o1-mini-2024-09-12": 0.55, // $1.1 / 1M tokens
+ "o1-pro": 75.0, // $150 / 1M tokens
+ "o1-pro-2025-03-19": 75.0, // $150 / 1M tokens
+ "o3-mini": 0.55,
+ "o3-mini-2025-01-31": 0.55,
+ "o3-mini-high": 0.55,
+ "o3-mini-2025-01-31-high": 0.55,
+ "o3-mini-low": 0.55,
+ "o3-mini-2025-01-31-low": 0.55,
+ "o3-mini-medium": 0.55,
+ "o3-mini-2025-01-31-medium": 0.55,
+ "o3": 1.0, // $2 / 1M tokens
+ "o3-2025-04-16": 1.0, // $2 / 1M tokens
+ "o3-pro": 10.0, // $20 / 1M tokens
+ "o3-pro-2025-06-10": 10.0, // $20 / 1M tokens
+ "o3-deep-research": 5.0, // $10 / 1M tokens
+ "o3-deep-research-2025-06-26": 5.0, // $10 / 1M tokens
+ "o4-mini": 0.55, // $1.1 / 1M tokens
+ "o4-mini-2025-04-16": 0.55, // $1.1 / 1M tokens
+ "o4-mini-deep-research": 1.0, // $2 / 1M tokens
+ "o4-mini-deep-research-2025-06-26": 1.0, // $2 / 1M tokens
+ "gpt-4o-mini": 0.075,
+ "gpt-4o-mini-2024-07-18": 0.075,
+ "gpt-4-turbo": 5, // $0.01 / 1K tokens
+ "gpt-4-turbo-2024-04-09": 5, // $0.01 / 1K tokens
+ "gpt-4.5-preview": 37.5,
+ "gpt-4.5-preview-2025-02-27": 37.5,
+ "gpt-5": 0.625,
+ "gpt-5-2025-08-07": 0.625,
+ "gpt-5-chat-latest": 0.625,
+ "gpt-5-mini": 0.125,
+ "gpt-5-mini-2025-08-07": 0.125,
+ "gpt-5-nano": 0.025,
+ "gpt-5-nano-2025-08-07": 0.025,
+ //"gpt-3.5-turbo-0301": 0.75, //deprecated
+ "gpt-3.5-turbo": 0.25,
+ "gpt-3.5-turbo-0613": 0.75,
+ "gpt-3.5-turbo-16k": 1.5, // $0.003 / 1K tokens
+ "gpt-3.5-turbo-16k-0613": 1.5,
+ "gpt-3.5-turbo-instruct": 0.75, // $0.0015 / 1K tokens
+ "gpt-3.5-turbo-1106": 0.5, // $0.001 / 1K tokens
+ "gpt-3.5-turbo-0125": 0.25,
+ "babbage-002": 0.2, // $0.0004 / 1K tokens
+ "davinci-002": 1, // $0.002 / 1K tokens
+ "text-ada-001": 0.2,
+ "text-babbage-001": 0.25,
+ "text-curie-001": 1,
+ //"text-davinci-002": 10,
+ //"text-davinci-003": 10,
+ "text-davinci-edit-001": 10,
+ "code-davinci-edit-001": 10,
+ "whisper-1": 15, // $0.006 / minute -> $0.006 / 150 words -> $0.006 / 200 tokens -> $0.03 / 1k tokens
+ "tts-1": 7.5, // 1k characters -> $0.015
+ "tts-1-1106": 7.5, // 1k characters -> $0.015
+ "tts-1-hd": 15, // 1k characters -> $0.03
+ "tts-1-hd-1106": 15, // 1k characters -> $0.03
+ "davinci": 10,
+ "curie": 10,
+ "babbage": 10,
+ "ada": 10,
+ "text-embedding-3-small": 0.01,
+ "text-embedding-3-large": 0.065,
+ "text-embedding-ada-002": 0.05,
+ "text-search-ada-doc-001": 10,
+ "text-moderation-stable": 0.1,
+ "text-moderation-latest": 0.1,
+ "claude-instant-1": 0.4, // $0.8 / 1M tokens
+ "claude-2.0": 4, // $8 / 1M tokens
+ "claude-2.1": 4, // $8 / 1M tokens
+ "claude-3-haiku-20240307": 0.125, // $0.25 / 1M tokens
+ "claude-3-5-haiku-20241022": 0.5, // $1 / 1M tokens
+ "claude-3-sonnet-20240229": 1.5, // $3 / 1M tokens
+ "claude-3-5-sonnet-20240620": 1.5,
+ "claude-3-5-sonnet-20241022": 1.5,
+ "claude-3-7-sonnet-20250219": 1.5,
+ "claude-3-7-sonnet-20250219-thinking": 1.5,
+ "claude-sonnet-4-20250514": 1.5,
+ "claude-sonnet-4-5-20250929": 1.5,
+ "claude-3-opus-20240229": 7.5, // $15 / 1M tokens
+ "claude-opus-4-20250514": 7.5,
+ "claude-opus-4-1-20250805": 7.5,
+ "ERNIE-4.0-8K": 0.120 * RMB,
+ "ERNIE-3.5-8K": 0.012 * RMB,
+ "ERNIE-3.5-8K-0205": 0.024 * RMB,
+ "ERNIE-3.5-8K-1222": 0.012 * RMB,
+ "ERNIE-Bot-8K": 0.024 * RMB,
+ "ERNIE-3.5-4K-0205": 0.012 * RMB,
+ "ERNIE-Speed-8K": 0.004 * RMB,
+ "ERNIE-Speed-128K": 0.004 * RMB,
+ "ERNIE-Lite-8K-0922": 0.008 * RMB,
+ "ERNIE-Lite-8K-0308": 0.003 * RMB,
+ "ERNIE-Tiny-8K": 0.001 * RMB,
+ "BLOOMZ-7B": 0.004 * RMB,
+ "Embedding-V1": 0.002 * RMB,
+ "bge-large-zh": 0.002 * RMB,
+ "bge-large-en": 0.002 * RMB,
+ "tao-8k": 0.002 * RMB,
+ "PaLM-2": 1,
+ "gemini-1.5-pro-latest": 1.25, // $3.5 / 1M tokens
+ "gemini-1.5-flash-latest": 0.075,
+ "gemini-2.0-flash": 0.05,
+ "gemini-2.5-pro-exp-03-25": 0.625,
+ "gemini-2.5-pro-preview-03-25": 0.625,
+ "gemini-2.5-pro": 0.625,
+ "gemini-2.5-flash-preview-04-17": 0.075,
+ "gemini-2.5-flash-preview-04-17-thinking": 0.075,
+ "gemini-2.5-flash-preview-04-17-nothinking": 0.075,
+ "gemini-2.5-flash-preview-05-20": 0.075,
+ "gemini-2.5-flash-preview-05-20-thinking": 0.075,
+ "gemini-2.5-flash-preview-05-20-nothinking": 0.075,
+ "gemini-2.5-flash-thinking-*": 0.075, // 用于为后续所有2.5 flash thinking budget 模型设置默认倍率
+ "gemini-2.5-pro-thinking-*": 0.625, // 用于为后续所有2.5 pro thinking budget 模型设置默认倍率
+ "gemini-2.5-flash-lite-preview-thinking-*": 0.05,
+ "gemini-2.5-flash-lite-preview-06-17": 0.05,
+ "gemini-2.5-flash": 0.15,
+ "gemini-robotics-er-1.5-preview": 0.15,
+ "gemini-embedding-001": 0.075,
+ "text-embedding-004": 0.001,
+ "chatglm_turbo": 0.3572, // ￥0.005 / 1k tokens
+ "chatglm_pro": 0.7143, // ￥0.01 / 1k tokens
+ "chatglm_std": 0.3572, // ￥0.005 / 1k tokens
+ "chatglm_lite": 0.1429, // ￥0.002 / 1k tokens
+ "glm-4": 7.143, // ￥0.1 / 1k tokens
+ "glm-4v": 0.05 * RMB, // ￥0.05 / 1k tokens
+ "glm-4-alltools": 0.1 * RMB, // ￥0.1 / 1k tokens
+ "glm-3-turbo": 0.3572,
+ "glm-4-plus": 0.05 * RMB,
+ "glm-4-0520": 0.1 * RMB,
+ "glm-4-air": 0.001 * RMB,
+ "glm-4-airx": 0.01 * RMB,
+ "glm-4-long": 0.001 * RMB,
+ "glm-4-flash": 0,
+ "glm-4v-plus": 0.01 * RMB,
+ "qwen-turbo": 0.8572, // ￥0.012 / 1k tokens
+ "qwen-plus": 10, // ￥0.14 / 1k tokens
+ "text-embedding-v1": 0.05, // ￥0.0007 / 1k tokens
+ "SparkDesk-v1.1": 1.2858, // ￥0.018 / 1k tokens
+ "SparkDesk-v2.1": 1.2858, // ￥0.018 / 1k tokens
+ "SparkDesk-v3.1": 1.2858, // ￥0.018 / 1k tokens
+ "SparkDesk-v3.5": 1.2858, // ￥0.018 / 1k tokens
+ "SparkDesk-v4.0": 1.2858,
+ "360GPT_S2_V9": 0.8572, // ¥0.012 / 1k tokens
+ "360gpt-turbo": 0.0858, // ¥0.0012 / 1k tokens
+ "360gpt-turbo-responsibility-8k": 0.8572, // ¥0.012 / 1k tokens
+ "360gpt-pro": 0.8572, // ¥0.012 / 1k tokens
+ "360gpt2-pro": 0.8572, // ¥0.012 / 1k tokens
+ "embedding-bert-512-v1": 0.0715, // ¥0.001 / 1k tokens
+ "embedding_s1_v1": 0.0715, // ¥0.001 / 1k tokens
+ "semantic_similarity_s1_v1": 0.0715, // ¥0.001 / 1k tokens
+ "hunyuan": 7.143, // ¥0.1 / 1k tokens // https://cloud.tencent.com/document/product/1729/97731#e0e6be58-60c8-469f-bdeb-6c264ce3b4d0
+ // https://platform.lingyiwanwu.com/docs#-计费单元
+ // 已经按照 7.2 来换算美元价格
+ "yi-34b-chat-0205": 0.18,
+ "yi-34b-chat-200k": 0.864,
+ "yi-vl-plus": 0.432,
+ "yi-large": 20.0 / 1000 * RMB,
+ "yi-medium": 2.5 / 1000 * RMB,
+ "yi-vision": 6.0 / 1000 * RMB,
+ "yi-medium-200k": 12.0 / 1000 * RMB,
+ "yi-spark": 1.0 / 1000 * RMB,
+ "yi-large-rag": 25.0 / 1000 * RMB,
+ "yi-large-turbo": 12.0 / 1000 * RMB,
+ "yi-large-preview": 20.0 / 1000 * RMB,
+ "yi-large-rag-preview": 25.0 / 1000 * RMB,
+ "command": 0.5,
+ "command-nightly": 0.5,
+ "command-light": 0.5,
+ "command-light-nightly": 0.5,
+ "command-r": 0.25,
+ "command-r-plus": 1.5,
+ "command-r-08-2024": 0.075,
+ "command-r-plus-08-2024": 1.25,
+ "deepseek-chat": 0.27 / 2,
+ "deepseek-coder": 0.27 / 2,
+ "deepseek-reasoner": 0.55 / 2, // 0.55 / 1k tokens
+ // Perplexity online 模型对搜索额外收费，有需要应自行调整，此处不计入搜索费用
+ "llama-3-sonar-small-32k-chat": 0.2 / 1000 * USD,
+ "llama-3-sonar-small-32k-online": 0.2 / 1000 * USD,
+ "llama-3-sonar-large-32k-chat": 1 / 1000 * USD,
+ "llama-3-sonar-large-32k-online": 1 / 1000 * USD,
+ // grok
+ "grok-3-beta": 1.5,
+ "grok-3-mini-beta": 0.15,
+ "grok-2": 1,
+ "grok-2-vision": 1,
+ "grok-beta": 2.5,
+ "grok-vision-beta": 2.5,
+ "grok-3-fast-beta": 2.5,
+ "grok-3-mini-fast-beta": 0.3,
+ // submodel
+ "NousResearch/Hermes-4-405B-FP8": 0.8,
+ "Qwen/Qwen3-235B-A22B-Thinking-2507": 0.6,
+ "Qwen/Qwen3-Coder-480B-A35B-Instruct-FP8": 0.8,
+ "Qwen/Qwen3-235B-A22B-Instruct-2507": 0.3,
+ "zai-org/GLM-4.5-FP8": 0.8,
+ "openai/gpt-oss-120b": 0.5,
+ "deepseek-ai/DeepSeek-R1-0528": 0.8,
+ "deepseek-ai/DeepSeek-R1": 0.8,
+ "deepseek-ai/DeepSeek-V3-0324": 0.8,
+ "deepseek-ai/DeepSeek-V3.1": 0.8,
+}
+
+var defaultModelPrice = map[string]float64{
+ "suno_music": 0.1,
+ "suno_lyrics": 0.01,
+ "dall-e-3": 0.04,
+ "imagen-3.0-generate-002": 0.03,
+ "gpt-4-gizmo-*": 0.1,
+ "mj_video": 0.8,
+ "mj_imagine": 0.1,
+ "mj_edits": 0.1,
+ "mj_variation": 0.1,
+ "mj_reroll": 0.1,
+ "mj_blend": 0.1,
+ "mj_modal": 0.1,
+ "mj_zoom": 0.1,
+ "mj_shorten": 0.1,
+ "mj_high_variation": 0.1,
+ "mj_low_variation": 0.1,
+ "mj_pan": 0.1,
+ "mj_inpaint": 0,
+ "mj_custom_zoom": 0,
+ "mj_describe": 0.05,
+ "mj_upscale": 0.05,
+ "swap_face": 0.05,
+ "mj_upload": 0.05,
+}
+
+var defaultAudioRatio = map[string]float64{
+ "gpt-4o-audio-preview": 16,
+ "gpt-4o-mini-audio-preview": 66.67,
+ "gpt-4o-realtime-preview": 8,
+ "gpt-4o-mini-realtime-preview": 16.67,
+}
+
+var defaultAudioCompletionRatio = map[string]float64{
+ "gpt-4o-realtime": 2,
+ "gpt-4o-mini-realtime": 2,
+}
+
+var (
+ modelPriceMap map[string]float64 = nil
+ modelPriceMapMutex = sync.RWMutex{}
+)
+var (
+ modelRatioMap map[string]float64 = nil
+ modelRatioMapMutex = sync.RWMutex{}
+)
+
+var (
+ CompletionRatio map[string]float64 = nil
+ CompletionRatioMutex = sync.RWMutex{}
+)
+
+var defaultCompletionRatio = map[string]float64{
+ "gpt-4-gizmo-*": 2,
+ "gpt-4o-gizmo-*": 3,
+ "gpt-4-all": 2,
+ "gpt-image-1": 8,
+}
+
+// InitRatioSettings initializes all model related settings maps
+func InitRatioSettings() {
+ // Initialize modelPriceMap
+ modelPriceMapMutex.Lock()
+ modelPriceMap = defaultModelPrice
+ modelPriceMapMutex.Unlock()
+
+ // Initialize modelRatioMap
+ modelRatioMapMutex.Lock()
+ modelRatioMap = defaultModelRatio
+ modelRatioMapMutex.Unlock()
+
+ // Initialize CompletionRatio
+ CompletionRatioMutex.Lock()
+ CompletionRatio = defaultCompletionRatio
+ CompletionRatioMutex.Unlock()
+
+ // Initialize cacheRatioMap
+ cacheRatioMapMutex.Lock()
+ cacheRatioMap = defaultCacheRatio
+ cacheRatioMapMutex.Unlock()
+
+ // initialize imageRatioMap
+ imageRatioMapMutex.Lock()
+ imageRatioMap = defaultImageRatio
+ imageRatioMapMutex.Unlock()
+
+ // initialize audioRatioMap
+ audioRatioMapMutex.Lock()
+ audioRatioMap = defaultAudioRatio
+ audioRatioMapMutex.Unlock()
+
+ // initialize audioCompletionRatioMap
+ audioCompletionRatioMapMutex.Lock()
+ audioCompletionRatioMap = defaultAudioCompletionRatio
+ audioCompletionRatioMapMutex.Unlock()
+}
+
+func GetModelPriceMap() map[string]float64 {
+ modelPriceMapMutex.RLock()
+ defer modelPriceMapMutex.RUnlock()
+ return modelPriceMap
+}
+
+func ModelPrice2JSONString() string {
+ modelPriceMapMutex.RLock()
+ defer modelPriceMapMutex.RUnlock()
+
+ jsonBytes, err := common.Marshal(modelPriceMap)
+ if err != nil {
+ common.SysError("error marshalling model price: " + err.Error())
+ }
+ return string(jsonBytes)
+}
+
+func UpdateModelPriceByJSONString(jsonStr string) error {
+ modelPriceMapMutex.Lock()
+ defer modelPriceMapMutex.Unlock()
+ modelPriceMap = make(map[string]float64)
+ err := json.Unmarshal([]byte(jsonStr), &modelPriceMap)
+ if err == nil {
+ InvalidateExposedDataCache()
+ }
+ return err
+}
+
+// GetModelPrice 返回模型的价格，如果模型不存在则返回-1，false
+func GetModelPrice(name string, printErr bool) (float64, bool) {
+ modelPriceMapMutex.RLock()
+ defer modelPriceMapMutex.RUnlock()
+
+ name = FormatMatchingModelName(name)
+
+ price, ok := modelPriceMap[name]
+ if !ok {
+ if printErr {
+ common.SysError("model price not found: " + name)
+ }
+ return -1, false
+ }
+ return price, true
+}
+
+func UpdateModelRatioByJSONString(jsonStr string) error {
+ modelRatioMapMutex.Lock()
+ defer modelRatioMapMutex.Unlock()
+ modelRatioMap = make(map[string]float64)
+ err := common.Unmarshal([]byte(jsonStr), &modelRatioMap)
+ if err == nil {
+ InvalidateExposedDataCache()
+ }
+ return err
+}
+
+// 处理带有思考预算的模型名称，方便统一定价
+func handleThinkingBudgetModel(name, prefix, wildcard string) string {
+ if strings.HasPrefix(name, prefix) && strings.Contains(name, "-thinking-") {
+ return wildcard
+ }
+ return name
+}
+
+func GetModelRatio(name string) (float64, bool, string) {
+ modelRatioMapMutex.RLock()
+ defer modelRatioMapMutex.RUnlock()
+
+ name = FormatMatchingModelName(name)
+
+ ratio, ok := modelRatioMap[name]
+ if !ok {
+ return 37.5, operation_setting.SelfUseModeEnabled, name
+ }
+ return ratio, true, name
+}
+
+func DefaultModelRatio2JSONString() string {
+ jsonBytes, err := common.Marshal(defaultModelRatio)
+ if err != nil {
+ common.SysError("error marshalling model ratio: " + err.Error())
+ }
+ return string(jsonBytes)
+}
+
+func GetDefaultModelRatioMap() map[string]float64 {
+ return defaultModelRatio
+}
+
+func GetDefaultImageRatioMap() map[string]float64 {
+ return defaultImageRatio
+}
+
+func GetDefaultAudioRatioMap() map[string]float64 {
+ return defaultAudioRatio
+}
+
+func GetDefaultAudioCompletionRatioMap() map[string]float64 {
+ return defaultAudioCompletionRatio
+}
+
+func GetCompletionRatioMap() map[string]float64 {
+ CompletionRatioMutex.RLock()
+ defer CompletionRatioMutex.RUnlock()
+ return CompletionRatio
+}
+
+func CompletionRatio2JSONString() string {
+ CompletionRatioMutex.RLock()
+ defer CompletionRatioMutex.RUnlock()
+
+ jsonBytes, err := json.Marshal(CompletionRatio)
+ if err != nil {
+ common.SysError("error marshalling completion ratio: " + err.Error())
+ }
+ return string(jsonBytes)
+}
+
+func UpdateCompletionRatioByJSONString(jsonStr string) error {
+ CompletionRatioMutex.Lock()
+ defer CompletionRatioMutex.Unlock()
+ CompletionRatio = make(map[string]float64)
+ err := common.Unmarshal([]byte(jsonStr), &CompletionRatio)
+ if err == nil {
+ InvalidateExposedDataCache()
+ }
+ return err
+}
+
+func GetCompletionRatio(name string) float64 {
+ CompletionRatioMutex.RLock()
+ defer CompletionRatioMutex.RUnlock()
+
+ name = FormatMatchingModelName(name)
+
+ if strings.Contains(name, "/") {
+ if ratio, ok := CompletionRatio[name]; ok {
+ return ratio
+ }
+ }
+ hardCodedRatio, contain := getHardcodedCompletionModelRatio(name)
+ if contain {
+ return hardCodedRatio
+ }
+ if ratio, ok := CompletionRatio[name]; ok {
+ return ratio
+ }
+ return hardCodedRatio
+}
+
+func getHardcodedCompletionModelRatio(name string) (float64, bool) {
+
+ isReservedModel := strings.HasSuffix(name, "-all") || strings.HasSuffix(name, "-gizmo-*")
+ if isReservedModel {
+ return 2, false
+ }
+
+ if strings.HasPrefix(name, "gpt-") {
+ if strings.HasPrefix(name, "gpt-4o") {
+ if name == "gpt-4o-2024-05-13" {
+ return 3, true
+ }
+ return 4, true
+ }
+ // gpt-5 匹配
+ if strings.HasPrefix(name, "gpt-5") {
+ return 8, true
+ }
+ // gpt-4.5-preview匹配
+ if strings.HasPrefix(name, "gpt-4.5-preview") {
+ return 2, true
+ }
+ if strings.HasPrefix(name, "gpt-4-turbo") || strings.HasSuffix(name, "gpt-4-1106") || strings.HasSuffix(name, "gpt-4-1105") {
+ return 3, true
+ }
+ // 没有特殊标记的 gpt-4 模型默认倍率为 2
+ return 2, false
+ }
+ if strings.HasPrefix(name, "o1") || strings.HasPrefix(name, "o3") {
+ return 4, true
+ }
+ if name == "chatgpt-4o-latest" {
+ return 3, true
+ }
+
+ if strings.Contains(name, "claude-3") {
+ return 5, true
+ } else if strings.Contains(name, "claude-sonnet-4") || strings.Contains(name, "claude-opus-4") {
+ return 5, true
+ } else if strings.Contains(name, "claude-instant-1") || strings.Contains(name, "claude-2") {
+ return 3, true
+ }
+
+ if strings.HasPrefix(name, "gpt-3.5") {
+ if name == "gpt-3.5-turbo" || strings.HasSuffix(name, "0125") {
+ // https://openai.com/blog/new-embedding-models-and-api-updates
+ // Updated GPT-3.5 Turbo model and lower pricing
+ return 3, true
+ }
+ if strings.HasSuffix(name, "1106") {
+ return 2, true
+ }
+ return 4.0 / 3.0, true
+ }
+ if strings.HasPrefix(name, "mistral-") {
+ return 3, true
+ }
+ if strings.HasPrefix(name, "gemini-") {
+ if strings.HasPrefix(name, "gemini-1.5") {
+ return 4, true
+ } else if strings.HasPrefix(name, "gemini-2.0") {
+ return 4, true
+ } else if strings.HasPrefix(name, "gemini-2.5-pro") { // 移除preview来增加兼容性，这里假设正式版的倍率和preview一致
+ return 8, false
+ } else if strings.HasPrefix(name, "gemini-2.5-flash") { // 处理不同的flash模型倍率
+ if strings.HasPrefix(name, "gemini-2.5-flash-preview") {
+ if strings.HasSuffix(name, "-nothinking") {
+ return 4, false
+ }
+ return 3.5 / 0.15, false
+ }
+ if strings.HasPrefix(name, "gemini-2.5-flash-lite") {
+ return 4, false
+ }
+ return 2.5 / 0.3, false
+ } else if strings.HasPrefix(name, "gemini-robotics-er-1.5") {
+ return 2.5 / 0.3, false
+ }
+ return 4, false
+ }
+ if strings.HasPrefix(name, "command") {
+ switch name {
+ case "command-r":
+ return 3, true
+ case "command-r-plus":
+ return 5, true
+ case "command-r-08-2024":
+ return 4, true
+ case "command-r-plus-08-2024":
+ return 4, true
+ default:
+ return 4, false
+ }
+ }
+ // hint 只给官方上4倍率，由于开源模型供应商自行定价，不对其进行补全倍率进行强制对齐
+ if strings.HasPrefix(name, "ERNIE-Speed-") {
+ return 2, true
+ } else if strings.HasPrefix(name, "ERNIE-Lite-") {
+ return 2, true
+ } else if strings.HasPrefix(name, "ERNIE-Character") {
+ return 2, true
+ } else if strings.HasPrefix(name, "ERNIE-Functions") {
+ return 2, true
+ }
+ switch name {
+ case "llama2-70b-4096":
+ return 0.8 / 0.64, true
+ case "llama3-8b-8192":
+ return 2, true
+ case "llama3-70b-8192":
+ return 0.79 / 0.59, true
+ }
+ return 1, false
+}
+
+func GetAudioRatio(name string) float64 {
+ audioRatioMapMutex.RLock()
+ defer audioRatioMapMutex.RUnlock()
+ name = FormatMatchingModelName(name)
+ if ratio, ok := audioRatioMap[name]; ok {
+ return ratio
+ }
+ return 20
+}
+
+func GetAudioCompletionRatio(name string) float64 {
+ audioCompletionRatioMapMutex.RLock()
+ defer audioCompletionRatioMapMutex.RUnlock()
+ name = FormatMatchingModelName(name)
+ if ratio, ok := audioCompletionRatioMap[name]; ok {
+
+ return ratio
+ }
+ return 2
+}
+
+func ModelRatio2JSONString() string {
+ modelRatioMapMutex.RLock()
+ defer modelRatioMapMutex.RUnlock()
+
+ jsonBytes, err := common.Marshal(modelRatioMap)
+ if err != nil {
+ common.SysError("error marshalling model ratio: " + err.Error())
+ }
+ return string(jsonBytes)
+}
+
+var defaultImageRatio = map[string]float64{
+ "gpt-image-1": 2,
+}
+var imageRatioMap map[string]float64
+var imageRatioMapMutex sync.RWMutex
+var (
+ audioRatioMap map[string]float64 = nil
+ audioRatioMapMutex = sync.RWMutex{}
+)
+var (
+ audioCompletionRatioMap map[string]float64 = nil
+ audioCompletionRatioMapMutex = sync.RWMutex{}
+)
+
+func ImageRatio2JSONString() string {
+ imageRatioMapMutex.RLock()
+ defer imageRatioMapMutex.RUnlock()
+ jsonBytes, err := common.Marshal(imageRatioMap)
+ if err != nil {
+ common.SysError("error marshalling cache ratio: " + err.Error())
+ }
+ return string(jsonBytes)
+}
+
+func UpdateImageRatioByJSONString(jsonStr string) error {
+ imageRatioMapMutex.Lock()
+ defer imageRatioMapMutex.Unlock()
+ imageRatioMap = make(map[string]float64)
+ return common.Unmarshal([]byte(jsonStr), &imageRatioMap)
+}
+
+func GetImageRatio(name string) (float64, bool) {
+ imageRatioMapMutex.RLock()
+ defer imageRatioMapMutex.RUnlock()
+ ratio, ok := imageRatioMap[name]
+ if !ok {
+ return 1, false // Default to 1 if not found
+ }
+ return ratio, true
+}
+
+func AudioRatio2JSONString() string {
+ audioRatioMapMutex.RLock()
+ defer audioRatioMapMutex.RUnlock()
+ jsonBytes, err := common.Marshal(audioRatioMap)
+ if err != nil {
+ common.SysError("error marshalling audio ratio: " + err.Error())
+ }
+ return string(jsonBytes)
+}
+
+func UpdateAudioRatioByJSONString(jsonStr string) error {
+
+ tmp := make(map[string]float64)
+ if err := common.Unmarshal([]byte(jsonStr), &tmp); err != nil {
+ return err
+ }
+ audioRatioMapMutex.Lock()
+ audioRatioMap = tmp
+ audioRatioMapMutex.Unlock()
+ InvalidateExposedDataCache()
+ return nil
+}
+
+func GetAudioRatioCopy() map[string]float64 {
+ audioRatioMapMutex.RLock()
+ defer audioRatioMapMutex.RUnlock()
+ copyMap := make(map[string]float64, len(audioRatioMap))
+ for k, v := range audioRatioMap {
+ copyMap[k] = v
+ }
+ return copyMap
+}
+
+func AudioCompletionRatio2JSONString() string {
+ audioCompletionRatioMapMutex.RLock()
+ defer audioCompletionRatioMapMutex.RUnlock()
+ jsonBytes, err := common.Marshal(audioCompletionRatioMap)
+ if err != nil {
+ common.SysError("error marshalling audio completion ratio: " + err.Error())
+ }
+ return string(jsonBytes)
+}
+
+func UpdateAudioCompletionRatioByJSONString(jsonStr string) error {
+ tmp := make(map[string]float64)
+ if err := common.Unmarshal([]byte(jsonStr), &tmp); err != nil {
+ return err
+ }
+ audioCompletionRatioMapMutex.Lock()
+ audioCompletionRatioMap = tmp
+ audioCompletionRatioMapMutex.Unlock()
+ InvalidateExposedDataCache()
+ return nil
+}
+
+func GetAudioCompletionRatioCopy() map[string]float64 {
+ audioCompletionRatioMapMutex.RLock()
+ defer audioCompletionRatioMapMutex.RUnlock()
+ copyMap := make(map[string]float64, len(audioCompletionRatioMap))
+ for k, v := range audioCompletionRatioMap {
+ copyMap[k] = v
+ }
+ return copyMap
+}
+
+func GetModelRatioCopy() map[string]float64 {
+ modelRatioMapMutex.RLock()
+ defer modelRatioMapMutex.RUnlock()
+ copyMap := make(map[string]float64, len(modelRatioMap))
+ for k, v := range modelRatioMap {
+ copyMap[k] = v
+ }
+ return copyMap
+}
+
+func GetModelPriceCopy() map[string]float64 {
+ modelPriceMapMutex.RLock()
+ defer modelPriceMapMutex.RUnlock()
+ copyMap := make(map[string]float64, len(modelPriceMap))
+ for k, v := range modelPriceMap {
+ copyMap[k] = v
+ }
+ return copyMap
+}
+
+func GetCompletionRatioCopy() map[string]float64 {
+ CompletionRatioMutex.RLock()
+ defer CompletionRatioMutex.RUnlock()
+ copyMap := make(map[string]float64, len(CompletionRatio))
+ for k, v := range CompletionRatio {
+ copyMap[k] = v
+ }
+ return copyMap
+}
+
+// 转换模型名，减少渠道必须配置各种带参数模型
+func FormatMatchingModelName(name string) string {
+
+ if strings.HasPrefix(name, "gemini-2.5-flash-lite") {
+ name = handleThinkingBudgetModel(name, "gemini-2.5-flash-lite", "gemini-2.5-flash-lite-thinking-*")
+ } else if strings.HasPrefix(name, "gemini-2.5-flash") {
+ name = handleThinkingBudgetModel(name, "gemini-2.5-flash", "gemini-2.5-flash-thinking-*")
+ } else if strings.HasPrefix(name, "gemini-2.5-pro") {
+ name = handleThinkingBudgetModel(name, "gemini-2.5-pro", "gemini-2.5-pro-thinking-*")
+ }
+
+ if strings.HasPrefix(name, "gpt-4-gizmo") {
+ name = "gpt-4-gizmo-*"
+ }
+ if strings.HasPrefix(name, "gpt-4o-gizmo") {
+ name = "gpt-4o-gizmo-*"
+ }
+ return name
+}
diff --git a/setting/sensitive.go b/setting/sensitive.go
new file mode 100644
index 0000000000000000000000000000000000000000..08a754a2d11111bf23693a5c77441d801241d147
--- /dev/null
+++ b/setting/sensitive.go
@@ -0,0 +1,43 @@
+package setting
+
+import "strings"
+
+var CheckSensitiveEnabled = true
+var CheckSensitiveOnPromptEnabled = true
+
+//var CheckSensitiveOnCompletionEnabled = true
+
+// StopOnSensitiveEnabled 如果检测到敏感词，是否立刻停止生成，否则替换敏感词
+var StopOnSensitiveEnabled = true
+
+// StreamCacheQueueLength 流模式缓存队列长度，0表示无缓存
+var StreamCacheQueueLength = 0
+
+// SensitiveWords 敏感词
+// var SensitiveWords []string
+var SensitiveWords = []string{
+ "test_sensitive",
+}
+
+func SensitiveWordsToString() string {
+ return strings.Join(SensitiveWords, "\n")
+}
+
+func SensitiveWordsFromString(s string) {
+ SensitiveWords = []string{}
+ sw := strings.Split(s, "\n")
+ for _, w := range sw {
+ w = strings.TrimSpace(w)
+ if w != "" {
+ SensitiveWords = append(SensitiveWords, w)
+ }
+ }
+}
+
+func ShouldCheckPromptSensitive() bool {
+ return CheckSensitiveEnabled && CheckSensitiveOnPromptEnabled
+}
+
+//func ShouldCheckCompletionSensitive() bool {
+// return CheckSensitiveEnabled && CheckSensitiveOnCompletionEnabled
+//}
diff --git a/setting/system_setting/fetch_setting.go b/setting/system_setting/fetch_setting.go
new file mode 100644
index 0000000000000000000000000000000000000000..b756fd2873e49946118ee05090f3547327bb9256
--- /dev/null
+++ b/setting/system_setting/fetch_setting.go
@@ -0,0 +1,34 @@
+package system_setting
+
+import "one-api/setting/config"
+
+type FetchSetting struct {
+ EnableSSRFProtection bool `json:"enable_ssrf_protection"` // 是否启用SSRF防护
+ AllowPrivateIp bool `json:"allow_private_ip"`
+ DomainFilterMode bool `json:"domain_filter_mode"` // 域名过滤模式，true: 白名单模式，false: 黑名单模式
+ IpFilterMode bool `json:"ip_filter_mode"` // IP过滤模式，true: 白名单模式，false: 黑名单模式
+ DomainList []string `json:"domain_list"` // domain format, e.g. example.com, *.example.com
+ IpList []string `json:"ip_list"` // CIDR format
+ AllowedPorts []string `json:"allowed_ports"` // port range format, e.g. 80, 443, 8000-9000
+ ApplyIPFilterForDomain bool `json:"apply_ip_filter_for_domain"` // 对域名启用IP过滤（实验性）
+}
+
+var defaultFetchSetting = FetchSetting{
+ EnableSSRFProtection: true, // 默认开启SSRF防护
+ AllowPrivateIp: false,
+ DomainFilterMode: false,
+ IpFilterMode: false,
+ DomainList: []string{},
+ IpList: []string{},
+ AllowedPorts: []string{"80", "443", "8080", "8443"},
+ ApplyIPFilterForDomain: false,
+}
+
+func init() {
+ // 注册到全局配置管理器
+ config.GlobalConfig.Register("fetch_setting", &defaultFetchSetting)
+}
+
+func GetFetchSetting() *FetchSetting {
+ return &defaultFetchSetting
+}
diff --git a/setting/system_setting/oidc.go b/setting/system_setting/oidc.go
new file mode 100644
index 0000000000000000000000000000000000000000..e3cd6c85b64f3cb23cb8e9fb342c1aea066225e5
--- /dev/null
+++ b/setting/system_setting/oidc.go
@@ -0,0 +1,25 @@
+package system_setting
+
+import "one-api/setting/config"
+
+type OIDCSettings struct {
+ Enabled bool `json:"enabled"`
+ ClientId string `json:"client_id"`
+ ClientSecret string `json:"client_secret"`
+ WellKnown string `json:"well_known"`
+ AuthorizationEndpoint string `json:"authorization_endpoint"`
+ TokenEndpoint string `json:"token_endpoint"`
+ UserInfoEndpoint string `json:"user_info_endpoint"`
+}
+
+// 默认配置
+var defaultOIDCSettings = OIDCSettings{}
+
+func init() {
+ // 注册到全局配置管理器
+ config.GlobalConfig.Register("oidc", &defaultOIDCSettings)
+}
+
+func GetOIDCSettings() *OIDCSettings {
+ return &defaultOIDCSettings
+}
diff --git a/setting/system_setting/passkey.go b/setting/system_setting/passkey.go
new file mode 100644
index 0000000000000000000000000000000000000000..d3b26fc36db0090629d52ce7b567873256f64943
--- /dev/null
+++ b/setting/system_setting/passkey.go
@@ -0,0 +1,49 @@
+package system_setting
+
+import (
+ "net/url"
+ "one-api/common"
+ "one-api/setting/config"
+ "strings"
+)
+
+type PasskeySettings struct {
+ Enabled bool `json:"enabled"`
+ RPDisplayName string `json:"rp_display_name"`
+ RPID string `json:"rp_id"`
+ Origins string `json:"origins"`
+ AllowInsecureOrigin bool `json:"allow_insecure_origin"`
+ UserVerification string `json:"user_verification"`
+ AttachmentPreference string `json:"attachment_preference"`
+}
+
+var defaultPasskeySettings = PasskeySettings{
+ Enabled: false,
+ RPDisplayName: common.SystemName,
+ RPID: "",
+ Origins: "",
+ AllowInsecureOrigin: false,
+ UserVerification: "preferred",
+ AttachmentPreference: "",
+}
+
+func init() {
+ config.GlobalConfig.Register("passkey", &defaultPasskeySettings)
+}
+
+func GetPasskeySettings() *PasskeySettings {
+ if defaultPasskeySettings.RPID == "" && ServerAddress != "" {
+ // 从ServerAddress提取域名作为RPID
+ // ServerAddress可能是 "https://newapi.pro" 这种格式
+ serverAddr := strings.TrimSpace(ServerAddress)
+ if parsed, err := url.Parse(serverAddr); err == nil && parsed.Host != "" {
+ defaultPasskeySettings.RPID = parsed.Host
+ } else {
+ defaultPasskeySettings.RPID = serverAddr
+ }
+ }
+ if defaultPasskeySettings.Origins == "" || defaultPasskeySettings.Origins == "[]" {
+ defaultPasskeySettings.Origins = ServerAddress
+ }
+ return &defaultPasskeySettings
+}
diff --git a/setting/system_setting/system_setting_old.go b/setting/system_setting/system_setting_old.go
new file mode 100644
index 0000000000000000000000000000000000000000..7c75f502423235e4bfa9bc0d46824ad19b28a8fc
--- /dev/null
+++ b/setting/system_setting/system_setting_old.go
@@ -0,0 +1,10 @@
+package system_setting
+
+var ServerAddress = "http://localhost:3000"
+var WorkerUrl = ""
+var WorkerValidKey = ""
+var WorkerAllowHttpImageRequestEnabled = false
+
+func EnableWorker() bool {
+ return WorkerUrl != ""
+}
diff --git a/setting/user_usable_group.go b/setting/user_usable_group.go
new file mode 100644
index 0000000000000000000000000000000000000000..b55560848fd5e7cbeb4c209e107f833dd11232a2
--- /dev/null
+++ b/setting/user_usable_group.go
@@ -0,0 +1,76 @@
+package setting
+
+import (
+ "encoding/json"
+ "one-api/common"
+ "sync"
+)
+
+var userUsableGroups = map[string]string{
+ "default": "默认分组",
+ "vip": "vip分组",
+}
+var userUsableGroupsMutex sync.RWMutex
+
+func GetUserUsableGroupsCopy() map[string]string {
+ userUsableGroupsMutex.RLock()
+ defer userUsableGroupsMutex.RUnlock()
+
+ copyUserUsableGroups := make(map[string]string)
+ for k, v := range userUsableGroups {
+ copyUserUsableGroups[k] = v
+ }
+ return copyUserUsableGroups
+}
+
+func UserUsableGroups2JSONString() string {
+ userUsableGroupsMutex.RLock()
+ defer userUsableGroupsMutex.RUnlock()
+
+ jsonBytes, err := json.Marshal(userUsableGroups)
+ if err != nil {
+ common.SysLog("error marshalling user groups: " + err.Error())
+ }
+ return string(jsonBytes)
+}
+
+func UpdateUserUsableGroupsByJSONString(jsonStr string) error {
+ userUsableGroupsMutex.Lock()
+ defer userUsableGroupsMutex.Unlock()
+
+ userUsableGroups = make(map[string]string)
+ return json.Unmarshal([]byte(jsonStr), &userUsableGroups)
+}
+
+func GetUserUsableGroups(userGroup string) map[string]string {
+ groupsCopy := GetUserUsableGroupsCopy()
+ if userGroup == "" {
+ if _, ok := groupsCopy["default"]; !ok {
+ groupsCopy["default"] = "default"
+ }
+ }
+ // 如果userGroup不在UserUsableGroups中，返回UserUsableGroups + userGroup
+ if _, ok := groupsCopy[userGroup]; !ok {
+ groupsCopy[userGroup] = "用户分组"
+ }
+ // 如果userGroup在UserUsableGroups中，返回UserUsableGroups
+ return groupsCopy
+}
+
+func GroupInUserUsableGroups(groupName string) bool {
+ userUsableGroupsMutex.RLock()
+ defer userUsableGroupsMutex.RUnlock()
+
+ _, ok := userUsableGroups[groupName]
+ return ok
+}
+
+func GetUsableGroupDescription(groupName string) string {
+ userUsableGroupsMutex.RLock()
+ defer userUsableGroupsMutex.RUnlock()
+
+ if desc, ok := userUsableGroups[groupName]; ok {
+ return desc
+ }
+ return groupName
+}
diff --git a/types/channel_error.go b/types/channel_error.go
new file mode 100644
index 0000000000000000000000000000000000000000..a8545f7fdf3bedd5b4536b625bc028f124d5858e
--- /dev/null
+++ b/types/channel_error.go
@@ -0,0 +1,21 @@
+package types
+
+type ChannelError struct {
+ ChannelId int `json:"channel_id"`
+ ChannelType int `json:"channel_type"`
+ ChannelName string `json:"channel_name"`
+ IsMultiKey bool `json:"is_multi_key"`
+ AutoBan bool `json:"auto_ban"`
+ UsingKey string `json:"using_key"`
+}
+
+func NewChannelError(channelId int, channelType int, channelName string, isMultiKey bool, usingKey string, autoBan bool) *ChannelError {
+ return &ChannelError{
+ ChannelId: channelId,
+ ChannelType: channelType,
+ ChannelName: channelName,
+ IsMultiKey: isMultiKey,
+ AutoBan: autoBan,
+ UsingKey: usingKey,
+ }
+}
diff --git a/types/error.go b/types/error.go
new file mode 100644
index 0000000000000000000000000000000000000000..b482183cdeb90031f6d272a08a9e91fead02ba1a
--- /dev/null
+++ b/types/error.go
@@ -0,0 +1,353 @@
+package types
+
+import (
+ "errors"
+ "fmt"
+ "net/http"
+ "one-api/common"
+ "strings"
+)
+
+type OpenAIError struct {
+ Message string `json:"message"`
+ Type string `json:"type"`
+ Param string `json:"param"`
+ Code any `json:"code"`
+}
+
+type ClaudeError struct {
+ Type string `json:"type,omitempty"`
+ Message string `json:"message,omitempty"`
+}
+
+type ErrorType string
+
+const (
+ ErrorTypeNewAPIError ErrorType = "new_api_error"
+ ErrorTypeOpenAIError ErrorType = "openai_error"
+ ErrorTypeClaudeError ErrorType = "claude_error"
+ ErrorTypeMidjourneyError ErrorType = "midjourney_error"
+ ErrorTypeGeminiError ErrorType = "gemini_error"
+ ErrorTypeRerankError ErrorType = "rerank_error"
+ ErrorTypeUpstreamError ErrorType = "upstream_error"
+)
+
+type ErrorCode string
+
+const (
+ ErrorCodeInvalidRequest ErrorCode = "invalid_request"
+ ErrorCodeSensitiveWordsDetected ErrorCode = "sensitive_words_detected"
+
+ // new api error
+ ErrorCodeCountTokenFailed ErrorCode = "count_token_failed"
+ ErrorCodeModelPriceError ErrorCode = "model_price_error"
+ ErrorCodeInvalidApiType ErrorCode = "invalid_api_type"
+ ErrorCodeJsonMarshalFailed ErrorCode = "json_marshal_failed"
+ ErrorCodeDoRequestFailed ErrorCode = "do_request_failed"
+ ErrorCodeGetChannelFailed ErrorCode = "get_channel_failed"
+ ErrorCodeGenRelayInfoFailed ErrorCode = "gen_relay_info_failed"
+
+ // channel error
+ ErrorCodeChannelNoAvailableKey ErrorCode = "channel:no_available_key"
+ ErrorCodeChannelParamOverrideInvalid ErrorCode = "channel:param_override_invalid"
+ ErrorCodeChannelHeaderOverrideInvalid ErrorCode = "channel:header_override_invalid"
+ ErrorCodeChannelModelMappedError ErrorCode = "channel:model_mapped_error"
+ ErrorCodeChannelAwsClientError ErrorCode = "channel:aws_client_error"
+ ErrorCodeChannelInvalidKey ErrorCode = "channel:invalid_key"
+ ErrorCodeChannelResponseTimeExceeded ErrorCode = "channel:response_time_exceeded"
+
+ // client request error
+ ErrorCodeReadRequestBodyFailed ErrorCode = "read_request_body_failed"
+ ErrorCodeConvertRequestFailed ErrorCode = "convert_request_failed"
+ ErrorCodeAccessDenied ErrorCode = "access_denied"
+
+ // response error
+ ErrorCodeReadResponseBodyFailed ErrorCode = "read_response_body_failed"
+ ErrorCodeBadResponseStatusCode ErrorCode = "bad_response_status_code"
+ ErrorCodeBadResponse ErrorCode = "bad_response"
+ ErrorCodeBadResponseBody ErrorCode = "bad_response_body"
+ ErrorCodeEmptyResponse ErrorCode = "empty_response"
+ ErrorCodeAwsInvokeError ErrorCode = "aws_invoke_error"
+ ErrorCodeModelNotFound ErrorCode = "model_not_found"
+
+ // sql error
+ ErrorCodeQueryDataError ErrorCode = "query_data_error"
+ ErrorCodeUpdateDataError ErrorCode = "update_data_error"
+
+ // quota error
+ ErrorCodeInsufficientUserQuota ErrorCode = "insufficient_user_quota"
+ ErrorCodePreConsumeTokenQuotaFailed ErrorCode = "pre_consume_token_quota_failed"
+)
+
+type NewAPIError struct {
+ Err error
+ RelayError any
+ skipRetry bool
+ recordErrorLog *bool
+ errorType ErrorType
+ errorCode ErrorCode
+ StatusCode int
+}
+
+func (e *NewAPIError) GetErrorCode() ErrorCode {
+ if e == nil {
+ return ""
+ }
+ return e.errorCode
+}
+
+func (e *NewAPIError) GetErrorType() ErrorType {
+ if e == nil {
+ return ""
+ }
+ return e.errorType
+}
+
+func (e *NewAPIError) Error() string {
+ if e == nil {
+ return ""
+ }
+ if e.Err == nil {
+ // fallback message when underlying error is missing
+ return string(e.errorCode)
+ }
+ return e.Err.Error()
+}
+
+func (e *NewAPIError) MaskSensitiveError() string {
+ if e == nil {
+ return ""
+ }
+ if e.Err == nil {
+ return string(e.errorCode)
+ }
+ errStr := e.Err.Error()
+ if e.errorCode == ErrorCodeCountTokenFailed {
+ return errStr
+ }
+ return common.MaskSensitiveInfo(errStr)
+}
+
+func (e *NewAPIError) SetMessage(message string) {
+ e.Err = errors.New(message)
+}
+
+func (e *NewAPIError) ToOpenAIError() OpenAIError {
+ var result OpenAIError
+ switch e.errorType {
+ case ErrorTypeOpenAIError:
+ if openAIError, ok := e.RelayError.(OpenAIError); ok {
+ result = openAIError
+ }
+ case ErrorTypeClaudeError:
+ if claudeError, ok := e.RelayError.(ClaudeError); ok {
+ result = OpenAIError{
+ Message: e.Error(),
+ Type: claudeError.Type,
+ Param: "",
+ Code: e.errorCode,
+ }
+ }
+ default:
+ result = OpenAIError{
+ Message: e.Error(),
+ Type: string(e.errorType),
+ Param: "",
+ Code: e.errorCode,
+ }
+ }
+ if e.errorCode != ErrorCodeCountTokenFailed {
+ result.Message = common.MaskSensitiveInfo(result.Message)
+ }
+ return result
+}
+
+func (e *NewAPIError) ToClaudeError() ClaudeError {
+ var result ClaudeError
+ switch e.errorType {
+ case ErrorTypeOpenAIError:
+ if openAIError, ok := e.RelayError.(OpenAIError); ok {
+ result = ClaudeError{
+ Message: e.Error(),
+ Type: fmt.Sprintf("%v", openAIError.Code),
+ }
+ }
+ case ErrorTypeClaudeError:
+ if claudeError, ok := e.RelayError.(ClaudeError); ok {
+ result = claudeError
+ }
+ default:
+ result = ClaudeError{
+ Message: e.Error(),
+ Type: string(e.errorType),
+ }
+ }
+ if e.errorCode != ErrorCodeCountTokenFailed {
+ result.Message = common.MaskSensitiveInfo(result.Message)
+ }
+ return result
+}
+
+type NewAPIErrorOptions func(*NewAPIError)
+
+func NewError(err error, errorCode ErrorCode, ops ...NewAPIErrorOptions) *NewAPIError {
+ var newErr *NewAPIError
+ // 保留深层传递的 new err
+ if errors.As(err, &newErr) {
+ for _, op := range ops {
+ op(newErr)
+ }
+ return newErr
+ }
+ e := &NewAPIError{
+ Err: err,
+ RelayError: nil,
+ errorType: ErrorTypeNewAPIError,
+ StatusCode: http.StatusInternalServerError,
+ errorCode: errorCode,
+ }
+ for _, op := range ops {
+ op(e)
+ }
+ return e
+}
+
+func NewOpenAIError(err error, errorCode ErrorCode, statusCode int, ops ...NewAPIErrorOptions) *NewAPIError {
+ var newErr *NewAPIError
+ // 保留深层传递的 new err
+ if errors.As(err, &newErr) {
+ if newErr.RelayError == nil {
+ openaiError := OpenAIError{
+ Message: newErr.Error(),
+ Type: string(errorCode),
+ Code: errorCode,
+ }
+ newErr.RelayError = openaiError
+ }
+ for _, op := range ops {
+ op(newErr)
+ }
+ return newErr
+ }
+ openaiError := OpenAIError{
+ Message: err.Error(),
+ Type: string(errorCode),
+ Code: errorCode,
+ }
+ return WithOpenAIError(openaiError, statusCode, ops...)
+}
+
+func InitOpenAIError(errorCode ErrorCode, statusCode int, ops ...NewAPIErrorOptions) *NewAPIError {
+ openaiError := OpenAIError{
+ Type: string(errorCode),
+ Code: errorCode,
+ }
+ return WithOpenAIError(openaiError, statusCode, ops...)
+}
+
+func NewErrorWithStatusCode(err error, errorCode ErrorCode, statusCode int, ops ...NewAPIErrorOptions) *NewAPIError {
+ e := &NewAPIError{
+ Err: err,
+ RelayError: OpenAIError{
+ Message: err.Error(),
+ Type: string(errorCode),
+ },
+ errorType: ErrorTypeNewAPIError,
+ StatusCode: statusCode,
+ errorCode: errorCode,
+ }
+ for _, op := range ops {
+ op(e)
+ }
+
+ return e
+}
+
+func WithOpenAIError(openAIError OpenAIError, statusCode int, ops ...NewAPIErrorOptions) *NewAPIError {
+ code, ok := openAIError.Code.(string)
+ if !ok {
+ if openAIError.Code != nil {
+ code = fmt.Sprintf("%v", openAIError.Code)
+ } else {
+ code = "unknown_error"
+ }
+ }
+ if openAIError.Type == "" {
+ openAIError.Type = "upstream_error"
+ }
+ e := &NewAPIError{
+ RelayError: openAIError,
+ errorType: ErrorTypeOpenAIError,
+ StatusCode: statusCode,
+ Err: errors.New(openAIError.Message),
+ errorCode: ErrorCode(code),
+ }
+ for _, op := range ops {
+ op(e)
+ }
+ return e
+}
+
+func WithClaudeError(claudeError ClaudeError, statusCode int, ops ...NewAPIErrorOptions) *NewAPIError {
+ if claudeError.Type == "" {
+ claudeError.Type = "upstream_error"
+ }
+ e := &NewAPIError{
+ RelayError: claudeError,
+ errorType: ErrorTypeClaudeError,
+ StatusCode: statusCode,
+ Err: errors.New(claudeError.Message),
+ errorCode: ErrorCode(claudeError.Type),
+ }
+ for _, op := range ops {
+ op(e)
+ }
+ return e
+}
+
+func IsChannelError(err *NewAPIError) bool {
+ if err == nil {
+ return false
+ }
+ return strings.HasPrefix(string(err.errorCode), "channel:")
+}
+
+func IsSkipRetryError(err *NewAPIError) bool {
+ if err == nil {
+ return false
+ }
+
+ return err.skipRetry
+}
+
+func ErrOptionWithSkipRetry() NewAPIErrorOptions {
+ return func(e *NewAPIError) {
+ e.skipRetry = true
+ }
+}
+
+func ErrOptionWithNoRecordErrorLog() NewAPIErrorOptions {
+ return func(e *NewAPIError) {
+ e.recordErrorLog = common.GetPointer(false)
+ }
+}
+
+func ErrOptionWithHideErrMsg(replaceStr string) NewAPIErrorOptions {
+ return func(e *NewAPIError) {
+ if common.DebugEnabled {
+ fmt.Printf("ErrOptionWithHideErrMsg: %s, origin error: %s", replaceStr, e.Err)
+ }
+ e.Err = errors.New(replaceStr)
+ }
+}
+
+func IsRecordErrorLog(e *NewAPIError) bool {
+ if e == nil {
+ return false
+ }
+ if e.recordErrorLog == nil {
+ // default to true if not set
+ return true
+ }
+ return *e.recordErrorLog
+}
diff --git a/types/file_data.go b/types/file_data.go
new file mode 100644
index 0000000000000000000000000000000000000000..75e616478631a4be510ed8d07d62552c3670d2cc
--- /dev/null
+++ b/types/file_data.go
@@ -0,0 +1,8 @@
+package types
+
+type LocalFileData struct {
+ MimeType string
+ Base64Data string
+ Url string
+ Size int64
+}
diff --git a/types/price_data.go b/types/price_data.go
new file mode 100644
index 0000000000000000000000000000000000000000..5dc0d8c26589f7052c5b8e6a49f33d7e6a5f55f7
--- /dev/null
+++ b/types/price_data.go
@@ -0,0 +1,33 @@
+package types
+
+import "fmt"
+
+type GroupRatioInfo struct {
+ GroupRatio float64
+ GroupSpecialRatio float64
+ HasSpecialRatio bool
+}
+
+type PriceData struct {
+ ModelPrice float64
+ ModelRatio float64
+ CompletionRatio float64
+ CacheRatio float64
+ CacheCreationRatio float64
+ ImageRatio float64
+ AudioRatio float64
+ AudioCompletionRatio float64
+ UsePrice bool
+ ShouldPreConsumedQuota int
+ GroupRatioInfo GroupRatioInfo
+}
+
+type PerCallPriceData struct {
+ ModelPrice float64
+ Quota int
+ GroupRatioInfo GroupRatioInfo
+}
+
+func (p PriceData) ToSetting() string {
+ return fmt.Sprintf("ModelPrice: %f, ModelRatio: %f, CompletionRatio: %f, CacheRatio: %f, GroupRatio: %f, UsePrice: %t, CacheCreationRatio: %f, ShouldPreConsumedQuota: %d, ImageRatio: %f, AudioRatio: %f, AudioCompletionRatio: %f", p.ModelPrice, p.ModelRatio, p.CompletionRatio, p.CacheRatio, p.GroupRatioInfo.GroupRatio, p.UsePrice, p.CacheCreationRatio, p.ShouldPreConsumedQuota, p.ImageRatio, p.AudioRatio, p.AudioCompletionRatio)
+}
diff --git a/types/relay_format.go b/types/relay_format.go
new file mode 100644
index 0000000000000000000000000000000000000000..0e2e4adc840a06bf29709ff7ce8933f82fb98e2f
--- /dev/null
+++ b/types/relay_format.go
@@ -0,0 +1,18 @@
+package types
+
+type RelayFormat string
+
+const (
+ RelayFormatOpenAI RelayFormat = "openai"
+ RelayFormatClaude = "claude"
+ RelayFormatGemini = "gemini"
+ RelayFormatOpenAIResponses = "openai_responses"
+ RelayFormatOpenAIAudio = "openai_audio"
+ RelayFormatOpenAIImage = "openai_image"
+ RelayFormatOpenAIRealtime = "openai_realtime"
+ RelayFormatRerank = "rerank"
+ RelayFormatEmbedding = "embedding"
+
+ RelayFormatTask = "task"
+ RelayFormatMjProxy = "mj_proxy"
+)
diff --git a/types/request_meta.go b/types/request_meta.go
new file mode 100644
index 0000000000000000000000000000000000000000..44759886703d12d127952b350c14e530921c82ac
--- /dev/null
+++ b/types/request_meta.go
@@ -0,0 +1,46 @@
+package types
+
+type FileType string
+
+const (
+ FileTypeImage FileType = "image" // Image file type
+ FileTypeAudio FileType = "audio" // Audio file type
+ FileTypeVideo FileType = "video" // Video file type
+ FileTypeFile FileType = "file" // Generic file type
+)
+
+type TokenType string
+
+const (
+ TokenTypeTextNumber TokenType = "text_number" // Text or number tokens
+ TokenTypeTokenizer TokenType = "tokenizer" // Tokenizer tokens
+ TokenTypeImage TokenType = "image" // Image tokens
+)
+
+type TokenCountMeta struct {
+ TokenType TokenType `json:"token_type,omitempty"` // Type of tokens used in the request
+ CombineText string `json:"combine_text,omitempty"` // Combined text from all messages
+ ToolsCount int `json:"tools_count,omitempty"` // Number of tools used
+ NameCount int `json:"name_count,omitempty"` // Number of names in the request
+ MessagesCount int `json:"messages_count,omitempty"` // Number of messages in the request
+ Files []*FileMeta `json:"files,omitempty"` // List of files, each with type and content
+ MaxTokens int `json:"max_tokens,omitempty"` // Maximum tokens allowed in the request
+
+ ImagePriceRatio float64 `json:"image_ratio,omitempty"` // Ratio for image size, if applicable
+ //IsStreaming bool `json:"is_streaming,omitempty"` // Indicates if the request is streaming
+}
+
+type FileMeta struct {
+ FileType
+ MimeType string
+ OriginData string // url or base64 data
+ Detail string
+ ParsedData *LocalFileData
+}
+
+type RequestMeta struct {
+ OriginalModelName string `json:"original_model_name"`
+ UserUsingGroup string `json:"user_using_group"`
+ PromptTokens int `json:"prompt_tokens"`
+ PreConsumedQuota int `json:"pre_consumed_quota"`
+}
diff --git a/types/set.go b/types/set.go
new file mode 100644
index 0000000000000000000000000000000000000000..929c3c6a8fa2f65ed509d7013420d34706a3f074
--- /dev/null
+++ b/types/set.go
@@ -0,0 +1,42 @@
+package types
+
+type Set[T comparable] struct {
+ items map[T]struct{}
+}
+
+// NewSet 创建并返回一个新的 Set
+func NewSet[T comparable]() *Set[T] {
+ return &Set[T]{
+ items: make(map[T]struct{}),
+ }
+}
+
+func (s *Set[T]) Add(item T) {
+ s.items[item] = struct{}{}
+}
+
+// Remove 从 Set 中移除一个元素
+func (s *Set[T]) Remove(item T) {
+ delete(s.items, item)
+}
+
+// Contains 检查 Set 是否包含某个元素
+func (s *Set[T]) Contains(item T) bool {
+ _, exists := s.items[item]
+ return exists
+}
+
+// Len 返回 Set 中元素的数量
+func (s *Set[T]) Len() int {
+ return len(s.items)
+}
+
+// Items 返回 Set 中所有元素组成的切片
+// 注意：由于 map 的无序性，返回的切片元素顺序是随机的
+func (s *Set[T]) Items() []T {
+ items := make([]T, 0, s.Len())
+ for item := range s.items {
+ items = append(items, item)
+ }
+ return items
+}
diff --git a/web/.eslintrc.cjs b/web/.eslintrc.cjs
new file mode 100644
index 0000000000000000000000000000000000000000..6b491f2e42cab8418cc34c0d7e0717b70d3d78d0
--- /dev/null
+++ b/web/.eslintrc.cjs
@@ -0,0 +1,42 @@
+module.exports = {
+ root: true,
+ env: { browser: true, es2021: true, node: true },
+ parserOptions: {
+ ecmaVersion: 2020,
+ sourceType: 'module',
+ ecmaFeatures: { jsx: true },
+ },
+ plugins: ['header', 'react-hooks'],
+ overrides: [
+ {
+ files: ['**/*.{js,jsx}'],
+ rules: {
+ 'header/header': [
+ 2,
+ 'block',
+ [
+ '',
+ 'Copyright (C) 2025 QuantumNous',
+ '',
+ 'This program is free software: you can redistribute it and/or modify',
+ 'it under the terms of the GNU Affero General Public License as',
+ 'published by the Free Software Foundation, either version 3 of the',
+ 'License, or (at your option) any later version.',
+ '',
+ 'This program is distributed in the hope that it will be useful,',
+ 'but WITHOUT ANY WARRANTY; without even the implied warranty of',
+ 'MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the',
+ 'GNU Affero General Public License for more details.',
+ '',
+ 'You should have received a copy of the GNU Affero General Public License',
+ 'along with this program. If not, see New API
+You need to enable JavaScript to run this app.
+
+
+
+
diff --git a/web/jsconfig.json b/web/jsconfig.json
new file mode 100644
index 0000000000000000000000000000000000000000..10c2274c6da51636e109aff4d2585bddc798e2c7
--- /dev/null
+++ b/web/jsconfig.json
@@ -0,0 +1,9 @@
+{
+ "compilerOptions": {
+ "baseUrl": "./",
+ "paths": {
+ "@/*": ["src/*"]
+ }
+ },
+ "include": ["src/**/*"]
+}
\ No newline at end of file
diff --git a/web/package.json b/web/package.json
new file mode 100644
index 0000000000000000000000000000000000000000..ba781f492346875b498f6aced7dd7089ce8f1bf0
--- /dev/null
+++ b/web/package.json
@@ -0,0 +1,91 @@
+{
+ "name": "react-template",
+ "version": "0.1.0",
+ "private": true,
+ "type": "module",
+ "dependencies": {
+ "@douyinfe/semi-icons": "^2.63.1",
+ "@douyinfe/semi-ui": "^2.69.1",
+ "@lobehub/icons": "^2.0.0",
+ "@visactor/react-vchart": "~1.8.8",
+ "@visactor/vchart": "~1.8.8",
+ "@visactor/vchart-semi-theme": "~1.8.8",
+ "axios": "^0.27.2",
+ "clsx": "^2.1.1",
+ "country-flag-icons": "^1.5.19",
+ "dayjs": "^1.11.11",
+ "history": "^5.3.0",
+ "i18next": "^23.16.8",
+ "i18next-browser-languagedetector": "^7.2.0",
+ "katex": "^0.16.22",
+ "lucide-react": "^0.511.0",
+ "marked": "^4.1.1",
+ "mermaid": "^11.6.0",
+ "qrcode.react": "^4.2.0",
+ "react": "^18.2.0",
+ "react-dom": "^18.2.0",
+ "react-dropzone": "^14.2.3",
+ "react-fireworks": "^1.0.4",
+ "react-i18next": "^13.0.0",
+ "react-icons": "^5.5.0",
+ "react-markdown": "^10.1.0",
+ "react-router-dom": "^6.3.0",
+ "react-telegram-login": "^1.1.2",
+ "react-toastify": "^9.0.8",
+ "react-turnstile": "^1.0.5",
+ "rehype-highlight": "^7.0.2",
+ "rehype-katex": "^7.0.1",
+ "remark-breaks": "^4.0.0",
+ "remark-gfm": "^4.0.1",
+ "remark-math": "^6.0.0",
+ "sse.js": "^2.6.0",
+ "unist-util-visit": "^5.0.0",
+ "use-debounce": "^10.0.4"
+ },
+ "scripts": {
+ "dev": "vite",
+ "build": "vite build",
+ "lint": "prettier . --check",
+ "lint:fix": "prettier . --write",
+ "eslint": "bunx eslint \"**/*.{js,jsx}\" --cache",
+ "eslint:fix": "bunx eslint \"**/*.{js,jsx}\" --fix --cache",
+ "preview": "vite preview"
+ },
+ "eslintConfig": {
+ "extends": [
+ "react-app",
+ "react-app/jest"
+ ]
+ },
+ "browserslist": {
+ "production": [
+ ">0.2%",
+ "not dead",
+ "not op_mini all"
+ ],
+ "development": [
+ "last 1 chrome version",
+ "last 1 firefox version",
+ "last 1 safari version"
+ ]
+ },
+ "devDependencies": {
+ "@douyinfe/vite-plugin-semi": "^2.74.0-alpha.6",
+ "@so1ve/prettier-config": "^3.1.0",
+ "@vitejs/plugin-react": "^4.2.1",
+ "autoprefixer": "^10.4.21",
+ "eslint": "8.57.0",
+ "eslint-plugin-header": "^3.1.1",
+ "eslint-plugin-react-hooks": "^5.2.0",
+ "postcss": "^8.5.3",
+ "prettier": "^3.0.0",
+ "tailwindcss": "^3",
+ "typescript": "4.4.2",
+ "vite": "^5.2.0"
+ },
+ "prettier": {
+ "singleQuote": true,
+ "jsxSingleQuote": true
+ },
+ "proxy": "http://localhost:3000"
+}
diff --git a/web/postcss.config.js b/web/postcss.config.js
new file mode 100644
index 0000000000000000000000000000000000000000..d3c606d3992654197fbeada4afcf1a46adfb4393
--- /dev/null
+++ b/web/postcss.config.js
@@ -0,0 +1,25 @@
+/*
+Copyright (C) 2025 QuantumNous
+
+This program is free software: you can redistribute it and/or modify
+it under the terms of the GNU Affero General Public License as
+published by the Free Software Foundation, either version 3 of the
+License, or (at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU Affero General Public License for more details.
+
+You should have received a copy of the GNU Affero General Public License
+along with this program. If not, see
+
+ } key={location.pathname}>
+ } key={location.pathname}>
+
+
+
+
+
+
+ } key={location.pathname}>
+ } key={location.pathname}>
+
+
+
+ }
+ />
+ } key={location.pathname}>
+
+
+
+ }
+ />
+ } key={location.pathname}>
+ } key={location.pathname}>
+ }>
+ } key={location.pathname}>
+
+ } key={location.pathname}>
+
+
+ }
+ />
+
+ } key={location.pathname}>
+
+
+ }
+ />
+
+ } key={location.pathname}>
+
+
+ }
+ />
+
+
+ } key={location.pathname}>
+
+
+ }
+ />
+
+ } key={location.pathname}>
+
+
+ }
+ />
+
+ } key={location.pathname}>
+
+
+ }
+ />
+
+ }
+ key={location.pathname}
+ >
+
+
+ ) : (
+ } key={location.pathname}>
+
+ )
+ }
+ />
+ } key={location.pathname}>
+ } key={location.pathname}>
+
+ } key={location.pathname}>
+
+
+ }
+ />
+
+
+ );
+}
+
+export default App;
diff --git a/web/src/components/auth/LoginForm.jsx b/web/src/components/auth/LoginForm.jsx
new file mode 100644
index 0000000000000000000000000000000000000000..4594a3645e9c24395d4d3eab5e9a75a02cecaa9f
--- /dev/null
+++ b/web/src/components/auth/LoginForm.jsx
@@ -0,0 +1,730 @@
+/*
+Copyright (C) 2025 QuantumNous
+
+This program is free software: you can redistribute it and/or modify
+it under the terms of the GNU Affero General Public License as
+published by the Free Software Foundation, either version 3 of the
+License, or (at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU Affero General Public License for more details.
+
+You should have received a copy of the GNU Affero General Public License
+along with this program. If not, see
+
+
+
+
+ {systemName}
+
+
+
+
+
+
+ {t('登 录')}
+
+
+
+
+ {status.wechat_login && (
+
} style={{ color: '#07C160' }} />
+ }
+ onClick={onWeChatLoginClicked}
+ loading={wechatLoading}
+ >
+
{t('使用 微信 继续')}
+
+ )}
+
+ {status.github_oauth && (
+
}
+ onClick={handleGitHubClick}
+ loading={githubLoading}
+ >
+
{t('使用 GitHub 继续')}
+
+ )}
+
+ {status.oidc_enabled && (
+
}
+ onClick={handleOIDCClick}
+ loading={oidcLoading}
+ >
+
{t('使用 OIDC 继续')}
+
+ )}
+
+ {status.linuxdo_oauth && (
+
+ }
+ onClick={handleLinuxDOClick}
+ loading={linuxdoLoading}
+ >
+
{t('使用 LinuxDO 继续')}
+
+ )}
+
+ {status.telegram_oauth && (
+
+
+ )}
+
+ {status.passkey_login && passkeySupported && (
+
}
+ onClick={handlePasskeyLogin}
+ loading={passkeyLoading}
+ >
+
{t('使用 Passkey 登录')}
+
+ )}
+
+
+ {t('或')}
+
+
+
}
+ onClick={handleEmailLoginClick}
+ loading={emailLoginLoading}
+ >
+
{t('使用 邮箱或用户名 登录')}
+
+
+
+ {!status.self_use_mode_enabled && (
+
+
+ {t('没有账户？')}{' '}
+
+
+ )}
+
+
+
+
+
+
+
{systemName}
+
+
+
+
+
+ {t('登 录')}
+
+
+
+ {status.passkey_login && passkeySupported && (
+
}
+ onClick={handlePasskeyLogin}
+ loading={passkeyLoading}
+ >
+
{t('使用 Passkey 登录')}
+
+ )}
+
+
+ {(status.github_oauth ||
+ status.oidc_enabled ||
+ status.wechat_login ||
+ status.linuxdo_oauth ||
+ status.telegram_oauth) && (
+ <>
+
+ {t('或')}
+
+
+
+
+ {t('其他登录选项')}
+
+
+
+ )}
+
+ {!status.self_use_mode_enabled && (
+
+
+ {t('没有账户？')}{' '}
+
+
+ )}
+
+
+
setShowWeChatLoginModal(false)}
+ okText={t('登录')}
+ centered={true}
+ okButtonProps={{
+ loading: wechatCodeSubmitLoading,
+ }}
+ >
+
+
+
+
+ {t('微信扫码关注公众号，输入「验证码」获取验证码（三分钟内有效）')}
+
+
+ );
+ };
+
+ // 2FA验证弹窗
+ const render2FAModal = () => {
+ return (
+
+
+ 两步验证
+
+ }
+ visible={showTwoFA}
+ onCancel={handleBackToLogin}
+ footer={null}
+ width={450}
+ centered
+ >
+
+ );
+ };
+
+ return (
+
+ {/* 背景模糊晕染球 */}
+
+
+
+ {showEmailLogin ||
+ !(
+ status.github_oauth ||
+ status.oidc_enabled ||
+ status.wechat_login ||
+ status.linuxdo_oauth ||
+ status.telegram_oauth
+ )
+ ? renderEmailLoginForm()
+ : renderOAuthOptions()}
+ {renderWeChatLoginModal()}
+ {render2FAModal()}
+
+ {turnstileEnabled && (
+
+ {
+ setTurnstileToken(token);
+ }}
+ />
+
+ )}
+
+
+ {/* 背景模糊晕染球 */}
+
+
+
+
+
+
+
+
+ {systemName}
+
+
+
+
+
+
+ {t('密码重置确认')}
+
+
+
+ {!isValidResetLink && (
+
+ )}
+
+
+
+
+
+
+
+
+
+
+
+ {/* 背景模糊晕染球 */}
+
+
+
+
+
+
+
+
+ {systemName}
+
+
+
+
+
+
+ {t('密码重置')}
+
+
+
+
+
+
+
+ {t('想起来了？')}{' '}
+
+
+
+
+ {turnstileEnabled && (
+
+ {
+ setTurnstileToken(token);
+ }}
+ />
+
+ )}
+
+
+
+
+
+
+
+
+ {systemName}
+
+
+
+
+
+
+ {t('注 册')}
+
+
+
+
+ {status.wechat_login && (
+
} style={{ color: '#07C160' }} />
+ }
+ onClick={onWeChatLoginClicked}
+ loading={wechatLoading}
+ >
+
{t('使用 微信 继续')}
+
+ )}
+
+ {status.github_oauth && (
+
}
+ onClick={handleGitHubClick}
+ loading={githubLoading}
+ >
+
{t('使用 GitHub 继续')}
+
+ )}
+
+ {status.oidc_enabled && (
+
}
+ onClick={handleOIDCClick}
+ loading={oidcLoading}
+ >
+
{t('使用 OIDC 继续')}
+
+ )}
+
+ {status.linuxdo_oauth && (
+
+ }
+ onClick={handleLinuxDOClick}
+ loading={linuxdoLoading}
+ >
+
{t('使用 LinuxDO 继续')}
+
+ )}
+
+ {status.telegram_oauth && (
+
+
+ )}
+
+
+ {t('或')}
+
+
+
}
+ onClick={handleEmailRegisterClick}
+ loading={emailRegisterLoading}
+ >
+
{t('使用 用户名 注册')}
+
+
+
+
+
+ {t('已有账户？')}{' '}
+
+
+
+
+
+
+
+
+
+ {systemName}
+
+
+
+
+
+
+ {t('注 册')}
+
+
+
+
+
+ {(status.github_oauth ||
+ status.oidc_enabled ||
+ status.wechat_login ||
+ status.linuxdo_oauth ||
+ status.telegram_oauth) && (
+ <>
+
+ {t('或')}
+
+
+
+
+ {t('其他注册选项')}
+
+
+
+ )}
+
+
+
+ {t('已有账户？')}{' '}
+
+
+
+
+
setShowWeChatLoginModal(false)}
+ okText={t('登录')}
+ centered={true}
+ okButtonProps={{
+ loading: wechatCodeSubmitLoading,
+ }}
+ >
+
+
+
+
+ {t('微信扫码关注公众号，输入「验证码」获取验证码（三分钟内有效）')}
+
+
+ );
+ };
+
+ return (
+
+ {/* 背景模糊晕染球 */}
+
+
+
+ {showEmailRegister ||
+ !(
+ status.github_oauth ||
+ status.oidc_enabled ||
+ status.wechat_login ||
+ status.linuxdo_oauth ||
+ status.telegram_oauth
+ )
+ ? renderEmailRegisterForm()
+ : renderOAuthOptions()}
+ {renderWeChatLoginModal()}
+
+ {turnstileEnabled && (
+
+ {
+ setTurnstileToken(token);
+ }}
+ />
+
+ )}
+
+
+
+ 请输入认证器应用显示的验证码完成登录
+
+
+
+
+
+
+
+ {
+ setUseBackupCode(!useBackupCode);
+ setVerificationCode('');
+ }}
+ style={{ marginRight: 16, color: '#1890ff', padding: 0 }}
+ >
+ {useBackupCode ? '使用认证器验证码' : '使用备用码'}
+
+
+ {onBack && (
+
+ 返回登录
+
+ )}
+
+
+
+
+ 提示：
+
+
+
+
+
+
两步验证
+
+ 请输入认证器应用显示的验证码完成登录
+
+
+ {
+ setUseBackupCode(!useBackupCode);
+ setVerificationCode('');
+ }}
+ style={{ marginRight: 16, color: '#1890ff', padding: 0 }}
+ >
+ {useBackupCode ? '使用认证器验证码' : '使用备用码'}
+
+
+ {onBack && (
+
+ 返回登录
+
+ )}
+
+
+
+
+ 提示：
+
+
+
+
+ {t('查看密钥')}
+
+
+ {/* 安全验证模态框 */}
+ setShowKeyModal(false)}
+ footer={
+ setShowKeyModal(false)}>
+ {t('完成')}
+
+ }
+ width={700}
+ style={{ maxWidth: '90vw' }}
+ >
+
+
+ );
+};
+
+export default ChannelKeyViewExample;
\ No newline at end of file
diff --git a/web/src/components/common/logo/LinuxDoIcon.jsx b/web/src/components/common/logo/LinuxDoIcon.jsx
new file mode 100644
index 0000000000000000000000000000000000000000..e411f7d2c1e810e2849908f95c965c31e81b2548
--- /dev/null
+++ b/web/src/components/common/logo/LinuxDoIcon.jsx
@@ -0,0 +1,56 @@
+/*
+Copyright (C) 2025 QuantumNous
+
+This program is free software: you can redistribute it and/or modify
+it under the terms of the GNU Affero General Public License as
+published by the Free Software Foundation, either version 3 of the
+License, or (at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU Affero General Public License for more details.
+
+You should have received a copy of the GNU Affero General Public License
+along with this program. If not, see
+
+
+
+ );
+ }
+
+ return
+
+ );
+ }
+
+ return
+
+ );
+ }
+
+ return (
+
+
+ );
+};
+
+export default WeChatIcon;
diff --git a/web/src/components/common/markdown/MarkdownRenderer.jsx b/web/src/components/common/markdown/MarkdownRenderer.jsx
new file mode 100644
index 0000000000000000000000000000000000000000..fca024fbd630be356da00152ad0a5bb7edc5e7b7
--- /dev/null
+++ b/web/src/components/common/markdown/MarkdownRenderer.jsx
@@ -0,0 +1,654 @@
+/*
+Copyright (C) 2025 QuantumNous
+
+This program is free software: you can redistribute it and/or modify
+it under the terms of the GNU Affero General Public License as
+published by the Free Software Foundation, either version 3 of the
+License, or (at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU Affero General Public License for more details.
+
+You should have received a copy of the GNU Affero General Public License
+along with this program. If not, see viewSvgInNewWindow()}
+ >
+ {props.code}
+
+ );
+}
+
+export function PreCode(props) {
+ const ref = useRef(null);
+ const [mermaidCode, setMermaidCode] = useState('');
+ const [htmlCode, setHtmlCode] = useState('');
+ const { t } = useTranslation();
+
+ const renderArtifacts = useDebouncedCallback(() => {
+ if (!ref.current) return;
+ const mermaidDom = ref.current.querySelector('code.language-mermaid');
+ if (mermaidDom) {
+ setMermaidCode(mermaidDom.innerText);
+ }
+ const htmlDom = ref.current.querySelector('code.language-html');
+ const refText = ref.current.querySelector('code')?.innerText;
+ if (htmlDom) {
+ setHtmlCode(htmlDom.innerText);
+ } else if (
+ refText?.startsWith(' {
+ if (ref.current) {
+ const codeElements = ref.current.querySelectorAll('code');
+ const wrapLanguages = [
+ '',
+ 'md',
+ 'markdown',
+ 'text',
+ 'txt',
+ 'plaintext',
+ 'tex',
+ 'latex',
+ ];
+ codeElements.forEach((codeElement) => {
+ let languageClass = codeElement.className.match(/language-(\w+)/);
+ let name = languageClass ? languageClass[1] : '';
+ if (wrapLanguages.includes(name)) {
+ codeElement.style.whiteSpace = 'pre-wrap';
+ }
+ });
+ setTimeout(renderArtifacts, 1);
+ }
+ }, []);
+
+ return (
+ <>
+
+
+
+
+
+ {props.children}
+
+ {mermaidCode.length > 0 && (
+
+
+ {t('显示更多')}
+
+
+ );
+ }
+ return null;
+ };
+
+ return (
+
+
+ {props.children}
+
+ {renderShowMoreButton()}
+
+ );
+}
+
+function escapeBrackets(text) {
+ const pattern =
+ /(```[\s\S]*?```|`.*?`)|\\\[([\s\S]*?[^\\])\\\]|\\\((.*?)\\\)/g;
+ return text.replace(
+ pattern,
+ (match, codeBlock, squareBracket, roundBracket) => {
+ if (codeBlock) {
+ return codeBlock;
+ } else if (squareBracket) {
+ return `$$${squareBracket}$$`;
+ } else if (roundBracket) {
+ return `$${roundBracket}$`;
+ }
+ return match;
+ },
+ );
+}
+
+function tryWrapHtmlCode(text) {
+ // 尝试包装HTML代码
+ if (text.includes('```')) {
+ return text;
+ }
+ return text
+ .replace(
+ /([`]*?)(\w*?)([\n\r]*?)()/g,
+ (match, quoteStart, lang, newLine, doctype) => {
+ return !quoteStart ? '\n```html\n' + doctype : match;
+ },
+ )
+ .replace(
+ /(<\/body>)([\r\n\s]*?)(<\/html>)([\n\r]*)([`]*)([\n\r]*?)/g,
+ (match, bodyEnd, space, htmlEnd, newLine, quoteEnd) => {
+ return !quoteEnd ? bodyEnd + space + htmlEnd + '\n```\n' : match;
+ },
+ );
+}
+
+function _MarkdownContent(props) {
+ const {
+ content,
+ className,
+ animated = false,
+ previousContentLength = 0,
+ } = props;
+
+ const escapedContent = useMemo(() => {
+ return tryWrapHtmlCode(escapeBrackets(content));
+ }, [content]);
+
+ // 判断是否为用户消息
+ const isUserMessage = className && className.includes('user-message');
+
+ const rehypePluginsBase = useMemo(() => {
+ const base = [
+ RehypeKatex,
+ [
+ RehypeHighlight,
+ {
+ detect: false,
+ ignoreMissing: true,
+ },
+ ],
+ ];
+ if (animated) {
+ base.push([rehypeSplitWordsIntoSpans, { previousContentLength }]);
+ }
+ return base;
+ }, [animated, previousContentLength]);
+
+ return (
+ (
+
+ ),
+ a: (aProps) => {
+ const href = aProps.href || '';
+ if (/\.(aac|mp3|opus|wav)$/.test(href)) {
+ return (
+
+
+ );
+ }
+ if (/\.(3gp|3g2|webm|ogv|mpeg|mp4|avi)$/.test(href)) {
+ return (
+
+
+ );
+ }
+ const isInternal = /^\/#/i.test(href);
+ const target = isInternal ? '_self' : (aProps.target ?? '_blank');
+ return (
+ {
+ e.target.style.textDecoration = 'underline';
+ }}
+ onMouseLeave={(e) => {
+ e.target.style.textDecoration = 'none';
+ }}
+ />
+ );
+ },
+ h1: (props) => (
+
+ );
+}
+
+export const MarkdownContent = React.memo(_MarkdownContent);
+
+export function MarkdownRenderer(props) {
+ const {
+ content,
+ loading,
+ fontSize = 14,
+ fontFamily = 'inherit',
+ className,
+ style,
+ animated = false,
+ previousContentLength = 0,
+ ...otherProps
+ } = props;
+
+ return (
+
+ {loading ? (
+
+ ) : (
+
+ )}
+
{t('确定')}
+ }
+ width={500}
+ style={{ maxWidth: '90vw' }}
+ >
+
+
+
+ {t('需要安全验证')}
+
+
+ {t('您需要先启用两步验证或 Passkey 才能查看敏感信息。')}
+
+
+
+ {t('请前往个人设置 → 安全设置进行配置。')}
+
+
+ );
+ }
+
+ return (
+
+
+ {/* 描述信息 */}
+ {description && (
+
+ {description}
+
+ )}
+
+ {/* 验证方式选择 */}
+
+ {has2FA && (
+
+
+
+
+
+
+ }
+ style={{ width: '100%' }}
+ />
+
+
+
+ {t('从认证器应用中获取验证码，或使用备用码')}
+
+
+
+
+ {t('取消')}
+
+ onVerify(method, code)}
+ >
+ {t('验证')}
+
+
+
+ )}
+
+ {hasPasskey && passkeySupported && (
+
+
+
+
+
+ {t('使用 Passkey 验证')}
+
+
+ {t('点击验证按钮，使用您的生物特征或安全密钥')}
+
+
+
+
+
+ {t('取消')}
+
+ onVerify(method)}
+ >
+ {t('验证 Passkey')}
+
+
+
+ )}
+
+
+ );
+};
+
+export default SecureVerificationModal;
\ No newline at end of file
diff --git a/web/src/components/common/modals/TwoFactorAuthModal.jsx b/web/src/components/common/modals/TwoFactorAuthModal.jsx
new file mode 100644
index 0000000000000000000000000000000000000000..1e6b79c4771d469f8c0e60f0a7f1834d1a0202df
--- /dev/null
+++ b/web/src/components/common/modals/TwoFactorAuthModal.jsx
@@ -0,0 +1,146 @@
+/*
+Copyright (C) 2025 QuantumNous
+
+This program is free software: you can redistribute it and/or modify
+it under the terms of the GNU Affero General Public License as
+published by the Free Software Foundation, either version 3 of the
+License, or (at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU Affero General Public License for more details.
+
+You should have received a copy of the GNU Affero General Public License
+along with this program. If not, see
+
+ {title || t('安全验证')}
+
+ }
+ visible={visible}
+ onCancel={onCancel}
+ footer={
+ <>
+ {t('取消')}
+
+ {t('验证')}
+
+
+ }
+ width={500}
+ style={{ maxWidth: '90vw' }}
+ >
+
+ {/* 安全提示 */}
+
+
+
+
+
+
+ {t('安全验证')}
+
+
+ {description || t('为了保护账户安全，请验证您的两步验证码。')}
+
+
+
+
+
+ {/* 验证码输入 */}
+
+
+ {t('验证身份')}
+
+
+ {t('支持6位TOTP验证码或8位备用码，可到`个人设置-安全设置-两步验证设置`配置或查看。')}
+
+
+
+ );
+};
+
+export default TwoFactorAuthModal;
diff --git a/web/src/components/common/ui/CardPro.jsx b/web/src/components/common/ui/CardPro.jsx
new file mode 100644
index 0000000000000000000000000000000000000000..55df17e9e8bcb232a6b3fb518caad8e193bd3099
--- /dev/null
+++ b/web/src/components/common/ui/CardPro.jsx
@@ -0,0 +1,200 @@
+/*
+Copyright (C) 2025 QuantumNous
+
+This program is free software: you can redistribute it and/or modify
+it under the terms of the GNU Affero General Public License as
+published by the Free Software Foundation, either version 3 of the
+License, or (at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU Affero General Public License for more details.
+
+You should have received a copy of the GNU Affero General Public License
+along with this program. If not, see
+ {/* 统计信息区域 - 用于type2 */}
+ {type === 'type2' && statsArea && <>{statsArea}}
+
+ {/* 描述信息区域 - 用于type1和type3 */}
+ {(type === 'type1' || type === 'type3') && descriptionArea && (
+ <>{descriptionArea}
+ )}
+
+ {/* 第一个分隔线 - 在描述信息或统计信息后面 */}
+ {((type === 'type1' || type === 'type3') && descriptionArea) ||
+ (type === 'type2' && statsArea) ? (
+
+ ) : null}
+
+ {/* 类型切换/标签区域 - 主要用于type3 */}
+ {type === 'type3' && tabsArea && <>{tabsArea}}
+
+ {/* 移动端操作切换按钮 */}
+ {isMobile && hasMobileHideableContent && (
+ <>
+
+
+
+ )}
+
+ {/* 操作按钮和搜索表单的容器 */}
+
+ {/* 操作按钮区域 - 用于type1和type3 */}
+ {(type === 'type1' || type === 'type3') &&
+ actionsArea &&
+ (Array.isArray(actionsArea) ? (
+ actionsArea.map((area, idx) => (
+
+ {idx !== 0 && {area}
+
+ ))
+ ) : (
+
{actionsArea}
+ ))}
+
+ {/* 当同时存在操作区和搜索区时，插入分隔线 */}
+ {actionsArea && searchArea &&
}
+
+ {/* 搜索表单区域 - 所有类型都可能有 */}
+ {searchArea &&
{searchArea}
}
+
+
+ {paginationArea}
+
+ );
+ };
+
+ const footerContent = renderFooter();
+
+ return (
+
+ {children}
+
+ );
+};
+
+CardPro.propTypes = {
+ // 布局类型
+ type: PropTypes.oneOf(['type1', 'type2', 'type3']),
+ // 样式相关
+ className: PropTypes.string,
+ style: PropTypes.object,
+ shadows: PropTypes.oneOfType([PropTypes.string, PropTypes.bool]),
+ bordered: PropTypes.bool,
+ // 内容区域
+ statsArea: PropTypes.node,
+ descriptionArea: PropTypes.node,
+ tabsArea: PropTypes.node,
+ actionsArea: PropTypes.oneOfType([
+ PropTypes.node,
+ PropTypes.arrayOf(PropTypes.node),
+ ]),
+ searchArea: PropTypes.node,
+ paginationArea: PropTypes.node,
+ // 表格内容
+ children: PropTypes.node,
+ // 国际化函数
+ t: PropTypes.func,
+};
+
+export default CardPro;
diff --git a/web/src/components/common/ui/CardTable.jsx b/web/src/components/common/ui/CardTable.jsx
new file mode 100644
index 0000000000000000000000000000000000000000..0d7d2b6224d5c912bb9954a247607c2073231f7d
--- /dev/null
+++ b/web/src/components/common/ui/CardTable.jsx
@@ -0,0 +1,242 @@
+/*
+Copyright (C) 2025 QuantumNous
+
+This program is free software: you can redistribute it and/or modify
+it under the terms of the GNU Affero General Public License as
+published by the Free Software Foundation, either version 3 of the
+License, or (at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU Affero General Public License for more details.
+
+You should have received a copy of the GNU Affero General Public License
+along with this program. If not, see
+ {visibleCols.map((col, idx) => {
+ if (!col.title) {
+ return (
+
+
+ );
+ }
+
+ return (
+
+
+ );
+ })}
+
+
+ );
+ };
+
+ return (
+
+ {[1, 2, 3].map((i) => renderSkeletonCard(i))}
+
+ );
+ }
+
+ const isEmpty = !showSkeleton && (!dataSource || dataSource.length === 0);
+
+ const MobileRowCard = ({ record, index }) => {
+ const [showDetails, setShowDetails] = useState(false);
+ const rowKeyVal = getRowKey(record, index);
+
+ const hasDetails =
+ tableProps.expandedRowRender &&
+ (!tableProps.rowExpandable || tableProps.rowExpandable(record));
+
+ return (
+
+ {columns.map((col, colIdx) => {
+ if (
+ tableProps?.visibleColumns &&
+ !tableProps.visibleColumns[col.key]
+ ) {
+ return null;
+ }
+
+ const title = col.title;
+ const cellContent = col.render
+ ? col.render(record[col.dataIndex], record, index)
+ : record[col.dataIndex];
+
+ if (!title) {
+ return (
+
+ {cellContent}
+
+ );
+ }
+
+ return (
+
+
+ {title}
+
+
+ {cellContent !== undefined && cellContent !== null
+ ? cellContent
+ : '-'}
+
+
+
+ {tableProps.expandedRowRender(record, index)}
+
+
+
+ )}
+
+ );
+ };
+
+ if (isEmpty) {
+ if (tableProps.empty) return tableProps.empty;
+ return (
+
+
+ );
+ }
+
+ return (
+
+ {dataSource.map((record, index) => (
+
+ ))}
+ {!hidePagination && tableProps.pagination && dataSource.length > 0 && (
+
+ )}
+
+ {/* 成功状态 */}
+ {showSuccessIcon && (
+
+
+
+
+ {successText || t('验证成功')}
+
+
+ )}
+
+ {/* 密钥内容 */}
+
+
+
+ {isMultipleKeys ? t('渠道密钥列表') : t('渠道密钥')}
+
+ {isMultipleKeys && (
+
+
+ {t('共 {{count}} 个密钥', { count: parsedKeys.length })}
+
+
+ {t('复制全部')}
+
+
+ )}
+
+
+
+ {parsedKeys.map((keyItem) => (
+
+
+
+
+ {keyItem.label}
+
+
+ {keyItem.type === 'json' && (
+
+ {t('JSON')}
+
+ )}
+
+
+
+
+
+
+
+ {keyItem.content}
+
+
+
+ {keyItem.type === 'json' && (
+
+ {t('JSON格式密钥，请确保格式正确')}
+
+ )}
+
+ ))}
+
+
+ {isMultipleKeys && (
+
+
+
+
+ {t(
+ '检测到多个密钥，您可以单独复制每个密钥，或点击复制全部获取完整内容。',
+ )}
+
+
+ )}
+
+
+ {/* 安全警告 */}
+ {showWarning && (
+
+
+
+
+
+
+ {t('安全提醒')}
+
+
+ {warningText ||
+ t(
+ '请妥善保管密钥信息，不要泄露给他人。如有安全疑虑，请及时更换密钥。',
+ )}
+
+
+
+
+ )}
+
setCompactMode(!compactMode)}
+ {...props}
+ >
+ {compactMode ? t('自适应列表') : t('紧凑列表')}
+
+ );
+};
+
+CompactModeToggle.propTypes = {
+ compactMode: PropTypes.bool.isRequired,
+ setCompactMode: PropTypes.func.isRequired,
+ t: PropTypes.func.isRequired,
+ size: PropTypes.string,
+ type: PropTypes.string,
+ className: PropTypes.string,
+};
+
+export default CompactModeToggle;
diff --git a/web/src/components/common/ui/JSONEditor.jsx b/web/src/components/common/ui/JSONEditor.jsx
new file mode 100644
index 0000000000000000000000000000000000000000..966b4038768530f8998a48af3c6d288d4ea553ba
--- /dev/null
+++ b/web/src/components/common/ui/JSONEditor.jsx
@@ -0,0 +1,714 @@
+/*
+Copyright (C) 2025 QuantumNous
+
+This program is free software: you can redistribute it and/or modify
+it under the terms of the GNU Affero General Public License as
+published by the Free Software Foundation, either version 3 of the
+License, or (at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU Affero General Public License for more details.
+
+You should have received a copy of the GNU Affero General Public License
+along with this program. If not, see
+ updateValue(pairId, newValue)}
+ />
+
+ {value ? t('true') : t('false')}
+
+
+ );
+ }
+
+ if (valueType === 'number') {
+ return (
+ updateValue(pairId, newValue)}
+ style={{ width: '100%' }}
+ placeholder={t('输入数字')}
+ />
+ );
+ }
+
+ if (valueType === 'object' && value !== null) {
+ // 简化嵌套对象的处理，使用TextArea
+ return (
+ 
+ 
+ 
+ 
+ 
+
+ 
+ 
+ 
+