修改日志可以按照日期进行输出，并自动清理超过30天的旧日志文件

refactor(utils): 替换日志库实现
- 导入自定义日志包 git.magicany.cc/black1552/gf-common/log - 将 g.Log().Infof 替换为 log.Info 方法调用 - 将 g.Log().Errorf 替换为 log.Error 方法调用 - 统一所有 HTTP 请求方法的日志记录方式 - 移除上下文参数 ctx 在日志记录中的传递
2026-03-28 17:52:52 +08:00 · 2026-03-10 10:04:26 +08:00 · 2026-03-06 17:00:37 +08:00 · 2026-03-06 13:54:20 +08:00 · 2026-03-06 11:35:25 +08:00 · 2026-03-06 11:14:10 +08:00
4 changed files with 209 additions and 16 deletions
--- a/log/index.go
+++ b/log/index.go
@ -1 +0,0 @@
-package log
--- a/log/log.go
+++ b/log/log.go
@ -5,6 +5,7 @@ import (
 	"io"
 	"log"
 	"os"
+	"path/filepath"
 	"regexp"
 	"runtime/debug"
 	"strings"
@ -16,8 +17,11 @@ import (
 )

 var (
-	logPath string
-	sysLog  *log.Logger
+	logPath     string
+	sysLog      *log.Logger
+	filePath    string
+	currentDate string // 当前日志文件对应的日期
+	fileLogger  *lumberjack.Logger
 )

 const (
@ -59,10 +63,103 @@ func (w *logWriter) Write(p []byte) (n int, err error) {
 	return len(p), nil
 }

-func init() {
+// cleanOldLogs 删除指定天数之前的日志文件（包括主文件和备份文件）
+func cleanOldLogs(days int) {
+	if !gfile.Exists(logPath) {
+		return
+	}
+
+	// 获取所有日志文件
+	files, err := gfile.DirNames(logPath)
+	if err != nil {
+		return
+	}
+
+	now := time.Now()
+	for _, file := range files {
+		path := filepath.Join(logPath, file)
+		if gfile.IsDir(path) {
+			continue
+		}
+
+		var dateStr string
+		var matched bool
+
+		// 匹配主日志文件格式：log-YYYY-MM-DD.log
+		if strings.HasPrefix(file, "log-") && strings.HasSuffix(file, ".log") {
+			// 检查是否是主文件（没有备份时间戳）
+			// 主文件格式：log-2026-04-25.log
+			// 备份文件格式：log-2026-04-25-2026-04-25T10-30-45.123.log
+			parts := strings.Split(strings.TrimSuffix(file, ".log"), "-")
+			if len(parts) == 4 {
+				// 主文件：log-YYYY-MM-DD
+				dateStr = parts[1] + "-" + parts[2] + "-" + parts[3]
+				matched = true
+			} else if len(parts) > 4 {
+				// 备份文件：log-YYYY-MM-DD-YYYY-MM-DDTHH-MM-SS.mmm
+				// 提取主日期部分（第一个日期）
+				dateStr = parts[1] + "-" + parts[2] + "-" + parts[3]
+				matched = true
+			}
+		}
+
+		if !matched {
+			continue
+		}
+
+		// 解析日期
+		fileTime, err := time.Parse("2006-01-02", dateStr)
+		if err != nil {
+			continue // 日期格式不正确，跳过
+		}
+
+		// 计算文件年龄
+		tage := now.Sub(fileTime)
+		if tage.Hours() > float64(days*24) {
+			// 超过指定天数，删除文件
+			err = os.Remove(path)
+			if err == nil {
+				Info(fmt.Sprintf("已删除过期日志文件：%s", file))
+			}
+		}
+	}
+}
+
+// checkAndRotateLogFile 检查是否需要切换日志文件（跨天时）
+func checkAndRotateLogFile() {
+	date := gtime.Date()
+	if currentDate != date {
+		// 日期变化，需要重新初始化
+		currentDate = date
+		filePath = gfile.Join(logPath, fmt.Sprintf("log-%s.log", currentDate))
+		fileLogger = &lumberjack.Logger{
+			Filename:   filePath,
+			MaxSize:    2,     // 单个文件最大 10MB
+			MaxBackups: 5,     // 最多保留 5 个备份
+			MaxAge:     30,    // 保留 30 天
+			Compress:   false, // 启用压缩
+		}
+		// 创建新的 writer
+		multiWriter := &logWriter{
+			console: os.Stdout,
+			file:    fileLogger,
+		}
+		sysLog = log.New(multiWriter, "", 0)
+
+		// 清理 30 天前的旧日志
+		cleanOldLogs(30)
+	}
+}
+
+func Init() {
+	if sysLog != nil {
+		checkAndRotateLogFile() // 检查是否需要切换文件
+		return
+	}
 	logPath = gfile.Join(gfile.Pwd(), "logs")
-	filePath := gfile.Join(logPath, fmt.Sprintf("log-%s.log", gtime.Date()))
-	fileLogger := &lumberjack.Logger{
+	currentDate = gtime.Date()
+	filePath = gfile.Join(logPath, fmt.Sprintf("log-%s.log", currentDate))
+	fileLogger = &lumberjack.Logger{
 		Filename:   filePath,
 		MaxSize:    2,     // 单个文件最大 10MB
 		MaxBackups: 5,     // 最多保留 5 个备份
@ -75,22 +172,29 @@ func init() {
 		file:    fileLogger,
 	}
 	sysLog = log.New(multiWriter, "", 0)
+
+	// 启动时清理 30 天前的旧日志
+	cleanOldLogs(30)
 }

 func Info(v ...any) {
+	Init()
 	sysLog.SetPrefix(fmt.Sprintf("[%s] %s[INFO]%s ", time.Now().Format("2006-01-02 15:04:05"), Green, Reset))
 	sysLog.Println(fmt.Sprint(v...))
 }
 func Error(v ...any) {
+	Init()
 	sysLog.SetPrefix(fmt.Sprintf("[%s] %s[ERROR]%s ", time.Now().Format("2006-01-02 15:04:05"), Red, Reset))
 	msg := fmt.Sprint(v...)
 	sysLog.Println(msg, strings.TrimSpace(string(debug.Stack())))
 }
 func Warn(v ...any) {
+	Init()
 	sysLog.SetPrefix(fmt.Sprintf("[%s] %s[WARN]%s ", time.Now().Format("2006-01-02 15:04:05"), Yellow, Reset))
 	sysLog.Println(fmt.Sprint(v...))
 }
 func Debug(v ...any) {
+	Init()
 	sysLog.SetPrefix(fmt.Sprintf("[%s] %s[DEBUG]%s ", time.Now().Format("2006-01-02 15:04:05"), Blue, Reset))
 	sysLog.Println(fmt.Sprint(v...))
 }
--- a/server/gateway.go
+++ b/server/gateway.go
@ -0,0 +1,89 @@
+package server
+
+import (
+	"fmt"
+	"io"
+	"net/http"
+	"net/http/httputil"
+	"net/url"
+	"strings"
+
+	"git.magicany.cc/black1552/gf-common/log"
+	"github.com/gogf/gf/v2/net/gclient"
+	"github.com/gogf/gf/v2/net/ghttp"
+	"github.com/gogf/gf/v2/os/gctx"
+	"github.com/gogf/gf/v2/text/gstr"
+)
+
+// hasProtocol 检查字符串是否包含协议前缀
+func hasProtocol(s string) bool {
+	return strings.HasPrefix(s, "http://") ||
+		strings.HasPrefix(s, "https://") ||
+		strings.HasPrefix(s, "ws://") ||
+		strings.HasPrefix(s, "wss://")
+}
+
+// BuildRequest 反向代理请求到指定主机
+// 自动支持所有 HTTP 方法及 WebSocket 连接
+func BuildRequest(r *ghttp.Request, host string) {
+	if gstr.Contains(r.RequestURI, "/ws") {
+		proxyWebSocket(r, host)
+		return
+	}
+	client := gclient.New()
+	// 构建目标URL而不是直接复制RequestURI
+	targetURL := host + r.URL.Path
+	if r.URL.RawQuery != "" {
+		targetURL += "?" + r.URL.RawQuery
+	}
+	// 复制请求头
+	for key, values := range r.Header {
+		for _, value := range values {
+			client.SetHeader(key, value)
+		}
+	}
+	response, err := client.DoRequest(gctx.New(), r.Method, targetURL, r.GetBody())
+	if err != nil {
+		log.Error(gctx.New(), "request error:", err)
+		panic(fmt.Sprintf("request error: %v", err))
+	}
+	defer response.Body.Close()
+	// 读取响应体
+	respBody, err := io.ReadAll(response.Body)
+	if err != nil {
+		log.Error(gctx.New(), "read response body error:", err)
+		panic(fmt.Sprintf("read response body error: %v", err))
+	}
+
+	// 复制响应头
+	for key, values := range response.Header {
+		for _, value := range values {
+			r.Response.Header().Add(key, value)
+		}
+	}
+	// 设置响应状态码并写入响应体
+	r.Response.Status = response.StatusCode
+	r.Response.Write(respBody)
+}
+
+// proxyWebSocket 处理 WebSocket 连接的代理
+func proxyWebSocket(r *ghttp.Request, targetHost string) {
+	// 解析目标主机 URL
+	targetURL, err := url.Parse(targetHost)
+	if err != nil {
+		log.Error(gctx.New(), "parse target host error:", err)
+		r.Response.WriteStatus(http.StatusInternalServerError)
+		r.Response.Write([]byte("Invalid target host"))
+		return
+	}
+
+	// 创建反向代理
+	proxy := httputil.NewSingleHostReverseProxy(targetURL)
+
+	// 修改请求 URL，保留原始路径和查询参数
+	r.URL.Scheme = targetURL.Scheme
+	r.URL.Host = targetURL.Host
+	log.Info(gctx.New(), r.GetBodyString())
+	// 处理 WebSocket 连接
+	proxy.ServeHTTP(r.Response.Writer, r.Request)
+}
--- a/utils/sql.go
+++ b/utils/sql.go
@ -3,6 +3,7 @@ package utils
 import (
 	"context"

+	"git.magicany.cc/black1552/gf-common/log"
 	_ "github.com/gogf/gf/contrib/drivers/mysql/v2"
 	"github.com/gogf/gf/v2/crypto/gmd5"
 	"github.com/gogf/gf/v2/database/gdb"
@ -51,51 +52,51 @@ func NewClient[R any](request any, url string, header map[string]string) *SClien
 	return s
 }
 func (w *SClient[R]) Post(ctx context.Context) (res *R, err error) {
-	g.Log().Infof(ctx, "请求Url:%s,请求头:%v,请求方法：%s,请求内容：%s", w.url, w.header, "post", w.request)
+	log.Info("请求Url:%s,请求头:%v,请求方法：%s,请求内容：%s", w.url, w.header, "post", w.request)
 	resp := w.client.PostVar(ctx, w.url, w.request)
 	err = gconv.Struct(resp, &res)
 	if err != nil {
-		g.Log().Errorf(ctx, "解析响应体异常：%s", err)
+		log.Error("请求异常：", err)
 		return nil, err
 	}
 	return
 }
 func (w *SClient[R]) Get(ctx context.Context) (res *R, err error) {
-	g.Log().Infof(ctx, "请求Url:%s,请求头:%v,请求方法：%s,请求内容：%s", w.url, w.header, "get", w.request)
+	log.Info("请求Url:%s,请求头:%v,请求方法：%s,请求内容：%s", w.url, w.header, "get", w.request)
 	resp := w.client.GetVar(ctx, w.url, w.request)
 	err = gconv.Struct(resp, &res)
 	if err != nil {
-		g.Log().Errorf(ctx, "解析响应体异常：%s", err)
+		log.Error("解析响应体异常：", err)
 		return nil, err
 	}
 	return
 }
 func (w *SClient[R]) Put(ctx context.Context) (res *R, err error) {
-	g.Log().Infof(ctx, "请求Url:%s,请求头:%v,请求方法：%s,请求内容：%s", w.url, w.header, "put", w.request)
+	log.Info("请求Url:%s,请求头:%v,请求方法：%s,请求内容：%s", w.url, w.header, "put", w.request)
 	resp := w.client.PutVar(ctx, w.url, w.request)
 	err = gconv.Struct(resp, &res)
 	if err != nil {
-		g.Log().Errorf(ctx, "解析响应体异常：%s", err)
+		log.Error("解析响应体异常：", err)
 		return nil, err
 	}
 	return
 }
 func (w *SClient[R]) Delete(ctx context.Context) (res *R, err error) {
-	g.Log().Infof(ctx, "请求Url:%s,请求头:%v,请求方法：%s,请求内容：%s", w.url, w.header, "delete", w.request)
+	log.Info("请求Url:%s,请求头:%v,请求方法：%s,请求内容：%s", w.url, w.header, "delete", w.request)
 	resp := w.client.DeleteVar(ctx, w.url, w.request)
 	err = gconv.Struct(resp, &res)
 	if err != nil {
-		g.Log().Errorf(ctx, "解析响应体异常：%s", err)
+		log.Error("解析响应体异常：", err)
 		return nil, err
 	}
 	return
 }
 func (w *SClient[R]) Patch(ctx context.Context) (res *R, err error) {
-	g.Log().Infof(ctx, "请求Url:%s,请求头:%v,请求方法：%s,请求内容：%s", w.url, w.header, "patch", w.request)
+	log.Info("请求Url:%s,请求头:%v,请求方法：%s,请求内容：%s", w.url, w.header, "patch", w.request)
 	resp := w.client.PatchVar(ctx, w.url, w.request)
 	err = gconv.Struct(resp, &res)
 	if err != nil {
-		g.Log().Errorf(ctx, "解析响应体异常：%s", err)
+		log.Error("解析响应体异常：", err)
 		return nil, err
 	}
 	return
Author	SHA1	Message	Date
maguodong	342d39a1a0	修改日志可以按照日期进行输出，并自动清理超过30天的旧日志文件	2026-03-28 17:52:52 +08:00
black1552	8add85cea7	refactor(utils): 替换日志库实现 - 导入自定义日志包 git.magicany.cc/black1552/gf-common/log - 将 g.Log().Infof 替换为 log.Info 方法调用 - 将 g.Log().Errorf 替换为 log.Error 方法调用 - 统一所有 HTTP 请求方法的日志记录方式 - 移除上下文参数 ctx 在日志记录中的传递	2026-03-10 10:04:26 +08:00
black1552	95623f3802	refactor(gateway): 重构反向代理实现以支持 WebSocket 和 HTTP 请求 - 添加 gclient 和 gstr 依赖包用于 HTTP 客户端操作 - 实现新的 BuildRequest 函数，使用 gclient 处理普通 HTTP 请求 - 分离 WebSocket 请求处理到独立的 proxyWebSocket 函数 - 移除旧的 hasProtocol 函数和相关逻辑 - 添加完整的请求头和响应头复制机制 - 实现响应状态码和响应体的正确传递 - 简化 WebSocket 代理逻辑，使用标准反向代理处理	2026-03-06 17:00:37 +08:00
black1552	45262d8f88	fix(gateway): 修复代理响应头传递和JSON写入问题 - 添加 ModifyResponse 函数以正确传递原始响应头 - 实现响应头从代理服务器到客户端的完整传递 - 修复 WebSocket 升级处理中的响应写入逻辑 - 确保 JSON 数据通过 RawWriter 正确写入响应	2026-03-06 13:54:20 +08:00
black1552	f958579981	fix(gateway): 解决 WebSocket 升级和 HTTP 请求处理问题 - 使用 RawWriter() 获取原始的 http.ResponseWriter，避免 gf 框架的封装影响 - 确保代理能够正确处理 WebSocket 连接升级 - 修复了因框架封装导致的响应写入问题	2026-03-06 11:35:25 +08:00
black1552	737fd041a0	feat(gateway): 添加协议自动检测和补全功能 - 实现 hasProtocol 函数检查字符串是否包含协议前缀 - 支持 http、https、ws、wss 协议检测 - 自动为没有协议的主机地址添加相应协议前缀 - 根据请求类型判断协议：WebSocket 使用 ws，HTTP 使用 http - 优化反向代理请求构建逻辑	2026-03-06 11:14:10 +08:00
black1552	969322a912	refactor(server): 重构网关请求代理实现 - 使用标准库 httputil.NewSingleHostReverseProxy 替代自定义 HTTP 客户端 - 移除 gclient、gcache 和相关依赖包导入 - 添加自定义 Director 函数处理目标 URL 设置 - 实现错误处理机制和 Bad Gateway 响应 - 简化 WebSocket 连接支持逻辑 - 优化请求头和响应头处理流程	2026-03-06 10:52:26 +08:00
black1552	f9fae10c76	feat(server): 添加网关代理功能 - 实现了 HTTP 请求转发功能，支持请求头和响应头的完整复制 - 添加了目标 URL 构建逻辑，处理路径和查询参数的正确拼接 - 集成了响应体读取和状态码设置功能 - 实现了 WebSocket 连接的反向代理处理 - 添加了缓存机制用于临时存储主机信息 - 集成了日志记录功能用于错误跟踪和调试	2026-03-06 10:31:06 +08:00