nfs写入加log

backend/internal/service/request_capture_service.go

@@ -63,6 +63,11 @@ func NewRequestCaptureService(repo RequestCaptureLogRepository, cfg *config.Conf
 	if cfg != nil {
 		nfsPath = cfg.RequestCapture.NFSPath
 	}
+	if nfsPath != "" {
+		logger.L().Info("request_capture: NFS storage enabled", zap.String("nfs_path", nfsPath))
+	} else {
+		logger.L().Info("request_capture: NFS storage disabled (nfs_path not configured), DB-only mode")
+	}
 	return &RequestCaptureService{
 		repo:    repo,
 		nfsPath: nfsPath,
@@ -86,6 +91,10 @@ func (s *RequestCaptureService) Capture(
 		nfsFilePath = s.buildNFSFilePath(apiKeyID, requestID, now)
 		bodyCopy := make([]byte, len(body))
 		copy(bodyCopy, body)
+		logger.L().Debug("request_capture: launching nfs request write",
+			zap.Int64("api_key_id", apiKeyID),
+			zap.String("nfs_file", nfsFilePath),
+		)
 		go s.writeToNFS(nfsFilePath, apiKeyID, userID, requestID, path, method, ipAddr, bodyCopy, now)
 	}
 
@@ -141,6 +150,10 @@ func (s *RequestCaptureService) CaptureResponse(captureID int64, responseBody st
 		// NFS 响应文件：与请求文件同目录，文件名加 _response 后缀
 		if nfsFilePath != "" {
 			respPath := nfsResponseFilePath(nfsFilePath)
+			logger.L().Debug("request_capture: launching nfs response write",
+				zap.Int64("capture_id", captureID),
+				zap.String("nfs_file", respPath),
+			)
 			s.writeResponseToNFS(respPath, captureID, responseBody)
 		}
 	}()
@@ -202,6 +215,8 @@ func (s *RequestCaptureService) writeToNFS(
 			zap.String("file", filePath),
 			zap.Error(err),
 		)
+	} else {
+		logger.L().Debug("request_capture: nfs request file written", zap.String("file", filePath))
 	}
 }
 
@@ -254,5 +269,7 @@ func (s *RequestCaptureService) writeResponseToNFS(filePath string, captureID in
 			zap.String("file", filePath),
 			zap.Error(err),
 		)
+	} else {
+		logger.L().Debug("request_capture: nfs response file written", zap.String("file", filePath))
 	}
 }