diff --git a/backend/cron/openrouter-api/openrouter-price.go b/backend/cron/openrouter-api/openrouter-price.go index afb87a5..727793f 100644 --- a/backend/cron/openrouter-api/openrouter-price.go +++ b/backend/cron/openrouter-api/openrouter-price.go @@ -149,7 +149,7 @@ func FetchAndSavePrices() error { log.Printf("更新价格记录: %s", modelData.Slug) processedCount++ } else { - log.Printf("价格无变化,跳过更新: %s", modelData.Slug) + // log.Printf("价格无变化,跳过更新: %s", modelData.Slug) skippedCount++ } } else { @@ -162,7 +162,7 @@ func FetchAndSavePrices() error { } if changed { - log.Printf("创建新价格记录: %s", modelData.Slug) + // log.Printf("创建新价格记录: %s", modelData.Slug) processedCount++ } else { log.Printf("价格创建失败: %s", modelData.Slug) diff --git a/backend/cron/openrouter-api/update-other-price.go b/backend/cron/openrouter-api/update-other-price.go index 9170bae..85d8314 100644 --- a/backend/cron/openrouter-api/update-other-price.go +++ b/backend/cron/openrouter-api/update-other-price.go @@ -89,7 +89,7 @@ func UpdateOtherPrices() error { // 检查是否支持的厂商 channelType, ok := authorToChannelType[author] if !ok { - log.Printf("跳过不支持的厂商: %s", author) + // log.Printf("跳过不支持的厂商: %s", author) skippedCount++ continue } @@ -123,7 +123,7 @@ func UpdateOtherPrices() error { // 检查是否已处理过这个模型 if processedModels[uniqueModelKey] { - log.Printf("跳过已处理的模型: %s (厂商: %s)", modelName, author) + // log.Printf("跳过已处理的模型: %s (厂商: %s)", modelName, author) skippedCount++ continue } @@ -195,7 +195,7 @@ func UpdateOtherPrices() error { log.Printf("更新价格记录: %s (厂商: %s)", modelName, author) processedCount++ } else { - log.Printf("价格无变化,跳过更新: %s (厂商: %s)", modelName, author) + // log.Printf("价格无变化,跳过更新: %s (厂商: %s)", modelName, author) skippedCount++ } } else { @@ -207,7 +207,7 @@ func UpdateOtherPrices() error { } if pendingCount > 0 { - log.Printf("已存在待审核的相同模型记录,跳过创建: %s (厂商: %s)", modelName, author) + // log.Printf("已存在待审核的相同模型记录,跳过创建: %s (厂商: %s)", modelName, author) skippedCount++ continue } @@ -221,7 +221,7 @@ func UpdateOtherPrices() error { } if changed { - log.Printf("创建新价格记录: %s (厂商: %s)", modelName, author) + // log.Printf("创建新价格记录: %s (厂商: %s)", modelName, author) processedCount++ } else { log.Printf("价格创建失败: %s (厂商: %s)", modelName, author) @@ -267,25 +267,25 @@ func isInBlacklist(modelName string) bool { modelNameLower := strings.ToLower(modelName) // 记录黑名单匹配过程 - log.Printf("检查模型是否在黑名单中: %s", modelNameLower) + // log.Printf("检查模型是否在黑名单中: %s", modelNameLower) for _, blacklistItem := range blacklist { blacklistItemLower := strings.ToLower(blacklistItem) // 1. 完全匹配 - 模型名称与黑名单项完全相同 if modelNameLower == blacklistItemLower { - log.Printf("模型【%s】完全匹配黑名单项【%s】", modelNameLower, blacklistItemLower) + // log.Printf("模型【%s】完全匹配黑名单项【%s】", modelNameLower, blacklistItemLower) return true } // 2. 包含匹配 - 模型名称中包含黑名单项 if strings.Contains(modelNameLower, blacklistItemLower) { - log.Printf("模型【%s】包含黑名单项【%s】", modelNameLower, blacklistItemLower) + // log.Printf("模型【%s】包含黑名单项【%s】", modelNameLower, blacklistItemLower) return true } } // 记录未匹配的情况 - log.Printf("模型【%s】不在黑名单中", modelNameLower) + // log.Printf("模型【%s】不在黑名单中", modelNameLower) return false } diff --git a/backend/cron/siliconflow-api/update-price.go b/backend/cron/siliconflow-api/update-price.go index e5a4478..dbc3a6e 100644 --- a/backend/cron/siliconflow-api/update-price.go +++ b/backend/cron/siliconflow-api/update-price.go @@ -2,6 +2,7 @@ package siliconflow_api import ( "encoding/json" + "errors" "fmt" "io" "log" @@ -15,6 +16,8 @@ import ( "aimodels-prices/handlers" "aimodels-prices/handlers/rates" "aimodels-prices/models" + + "gorm.io/gorm" ) // 常量定义 @@ -93,7 +96,6 @@ func UpdateSiliconFlowPrices() error { // 检查是否已处理过这个模型 if processedModels[modelName] { - log.Printf("跳过已处理的模型: %s", modelName) skippedCount++ continue } @@ -161,10 +163,11 @@ func UpdateSiliconFlowPrices() error { // 检查是否已存在相同模型的价格记录 var existingPrice models.Price + // 使用静默查询,不输出"record not found"错误 result := db.Where("model = ? AND channel_type = ?", modelName, SiliconFlowChannelType).First(&existingPrice) if result.Error == nil { - // 使用processPrice函数处理更新,第三个参数设置为true表示直接审核通过 + // 记录存在,执行更新 _, changed, err := handlers.ProcessPrice(price, &existingPrice, true, CreatedBy) if err != nil { log.Printf("更新价格记录失败 %s: %v", modelName, err) @@ -173,13 +176,12 @@ func UpdateSiliconFlowPrices() error { } if changed { - log.Printf("更新价格记录: %s", modelName) processedCount++ } else { - log.Printf("价格无变化,跳过更新: %s", modelName) skippedCount++ } - } else { + } else if errors.Is(result.Error, gorm.ErrRecordNotFound) { + // 记录不存在,需要创建新记录 // 检查是否存在相同模型名称的待审核记录 var pendingCount int64 if err := db.Model(&models.Price{}).Where("model = ? AND channel_type = ? AND status = 'pending'", @@ -193,7 +195,7 @@ func UpdateSiliconFlowPrices() error { continue } - // 使用processPrice函数处理创建,第三个参数设置为true表示直接审核通过 + // 创建新记录 _, changed, err := handlers.ProcessPrice(price, nil, true, CreatedBy) if err != nil { log.Printf("创建价格记录失败 %s: %v", modelName, err) @@ -202,12 +204,16 @@ func UpdateSiliconFlowPrices() error { } if changed { - log.Printf("创建新价格记录: %s", modelName) processedCount++ } else { log.Printf("价格创建失败: %s", modelName) skippedCount++ } + } else { + // 其他错误 + log.Printf("查询价格记录时发生错误 %s: %v", modelName, result.Error) + skippedCount++ + continue } }