2

Author: wuwei

.gitignore

@@ -32,6 +32,7 @@ rss.opml
 
 # 报告文件
 report-*.md
+*.md
 
 #数据文件
 articles.db

.golangci.yml

@@ -4,33 +4,25 @@
 run:
   # 默认并发数为可用CPU数
   concurrency: 4
-  
+
   # 超时设置，默认1分钟
   timeout: 1m
-  
+
   # 退出代码，如果至少有一个问题被发现
   issues-exit-code: 1
-  
+
   # 包含测试文件
   tests: true
-  
-  # 允许跳过目录
-  skip-dirs:
-    - vendor
-    - data
-  
-  # 允许跳过文件
-  skip-files:
-    - '.*_test\.go$'
 
 # 输出配置选项
 output:
   # 输出格式: colored-line-number|line-number|json|tab|checkstyle|code-climate|junit-xml|github-actions
-  format: colored-line-number
-  
+  formats:
+    - format: colored-line-number
+
   # 打印行号
   print-issued-lines: true
-  
+
   # 打印linter名称
   print-linter-name: true
 
@@ -39,25 +31,17 @@ linters:
   # 启用所有linters
   enable-all: false
 
-  # 禁用特定linters
-  disable:
-    - exhaustivestruct # 已弃用
-    - golint           # 已弃用，使用revive代替
-    - interfacer       # 已弃用
-    - maligned         # 已弃用，使用govet代替
-    - scopelint        # 已弃用，使用exportloopref代替
-    - varcheck         # 已弃用，使用unused代替
-    - deadcode         # 已弃用，使用unused代替
-    - structcheck      # 已弃用，使用unused代替
+  # 禁用特定linters (移除已废弃的检查器以避免警告)
+  disable: []
 
   # 启用特定linters
   enable:
     - asciicheck       # 检查非ASCII标识符
     - bodyclose        # 检查HTTP响应体是否关闭
+    - copyloopvar      # 检查循环变量引用 (替代exportloopref)
     - dogsled          # 检查过多的空白标识符
     - dupl             # 代码克隆检测器
     - errcheck         # 检查未处理的错误
-    - exportloopref    # 检查循环变量引用
     - funlen           # 检查函数长度
     - gochecknoinits   # 检查init函数
     - goconst          # 查找可以替换为常量的重复字符串
@@ -113,45 +97,21 @@ linters-settings:
     min-occurrences: 3
 
   gocritic:
-    # 启用特定检查器
+    # 启用特定检查器 (只列出非默认启用的检查器)
     enabled-checks:
       - appendCombine
-      - argOrder
-      - assignOp
-      - badCond
       - boolExprSimplify
       - builtinShadow
-      - captLocal
-      - caseOrder
       - commentedOutCode
       - commentedOutImport
-      - defaultCaseOrder
-      - dupBranchBody
-      - dupCase
-      - dupSubExpr
-      - elseif
       - emptyFallthrough
       - equalFold
-      - flagDeref
-      - ifElseChain
       - importShadow
       - indexAlloc
-      - mapKey
-      - newDeref
-      - offBy1
       - rangeExprCopy
-      - regexpMust
-      - sloppyLen
       - stringXbytes
-      - switchTrue
       - typeAssertChain
-      - typeSwitchVar
-      - underef
-      - unlambda
       - unnecessaryBlock
-      - unslice
-      - valSwap
-      - wrapperFunc
 
   misspell:
     # 美式英语
@@ -195,7 +155,16 @@ issues:
   max-issues-per-linter: 0
   # 每个文件修复相同问题的最大数量
   max-same-issues: 0
-  
+
+  # 排除特定目录
+  exclude-dirs:
+    - vendor
+    - data
+
+  # 排除特定文件
+  exclude-files:
+    - '.*_test\.go$'
+
   # 排除特定问题
   exclude-rules:
     # 排除测试文件中的一些问题

internal/application/service/rss_processor_service.go

@@ -585,85 +585,6 @@ func (s *rssProcessorService) processResponse(resp *http.Response, config model.
 	return content, nil
 }
 
-			// 检查是否是可重试的错误
-			if lastErr != nil && !s.isRetryableError(lastErr) {
-				logger.Warn("遇到不可重试的错误，停止重试", "error", lastErr)
-				break
-			}
-
-			time.Sleep(backoffTime)
-		}
-
-		start := time.Now()
-
-		// 为每次请求创建新的上下文，避免使用已取消的上下文
-		ctx, cancel := context.WithTimeout(context.Background(), apiTimeout)
-
-		// 创建新的请求，使用新的上下文
-		reqWithCtx := req.WithContext(ctx)
-		resp, lastErr = client.Do(reqWithCtx)
-		requestDuration = time.Since(start)
-
-		// 请求完成后取消上下文
-		cancel()
-
-		// 处理错误情况
-		if lastErr != nil {
-			// 特别处理超时错误
-			if strings.Contains(lastErr.Error(), "context deadline exceeded") || strings.Contains(lastErr.Error(), "timeout") {
-				logger.Warn("API请求超时，准备重试", "error", lastErr, "attempt", retryCount+1, "duration_ms", requestDuration.Milliseconds())
-			} else {
-				logger.Warn("发送API请求失败，准备重试", "error", lastErr, "attempt", retryCount+1, "duration_ms", requestDuration.Milliseconds())
-			}
-			continue
-		}
-
-		// 读取响应
-		responseBody, err := s.readAPIResponse(resp, config)
-		// 立即关闭响应体，避免在循环中使用defer
-		if resp != nil && resp.Body != nil {
-			if closeErr := resp.Body.Close(); closeErr != nil {
-				logger.Warn("关闭响应体失败", "error", closeErr)
-			}
-		}
-
-		if err != nil {
-			return "", err
-		}
-
-		// 检查响应状态码并处理错误
-		if resp.StatusCode != http.StatusOK {
-			return "", s.handleAPIError(resp.StatusCode, responseBody, requestDuration)
-		}
-
-		// 记录原始响应内容（仅记录预览，避免日志过大）
-		responsePreview := string(responseBody)
-		if len(responsePreview) > 200 {
-			responsePreview = responsePreview[:200] + "..."
-		}
-		logger.Debug("Deepseek API原始响应", "response_length", len(responseBody), "response_preview", responsePreview)
-
-		// 处理响应
-		content, err := s.processAPIResponse(responseBody, responsePreview)
-		if err != nil {
-			return "", err
-		}
-
-		logger.Info("成功获取Deepseek API响应", "content_length", len(content), "duration_ms", requestDuration.Milliseconds())
-		logger.Debug("API响应内容", "content", content)
-
-		return content, nil
-	}
-
-	// 所有重试都失败
-	if lastErr != nil {
-		logger.Error("发送API请求失败，已达到最大重试次数", "error", lastErr, "max_retries", maxRetries)
-		return "", fmt.Errorf("发送API请求失败: %w", lastErr)
-	}
-
-	return "", nil
-}
-
 // isRetryableError 判断错误是否可重试
 func (s *rssProcessorService) isRetryableError(err error) bool {
 	if err == nil {