feat: 支持流式和非解析HTTP请求及单条DB查询

重构HTTP请求模块，提取doRequestRaw基础方法，新增流式请求(PostStream)、非解析请求(GetNotParse/PostNotParse)及原始响应读取能力；同时在Gfdb接口中新增GetOne单条记录查询方法。

.dockerignore

@@ -0,0 +1 @@
+.git

db/gfdb/gfdb.go

@@ -7,10 +7,11 @@ import (
 	"fmt"
 	"regexp"
 	"strings"
+	"sync"
 	"time"
 
-	"gitea.com/red-future/common/beans"
+	"gitea.redpowerfuture.com/red-future/common/beans"
-	"gitea.com/red-future/common/utils"
+	"gitea.redpowerfuture.com/red-future/common/utils"
 	"github.com/bwmarrin/snowflake"
 	"github.com/gogf/gf/v2/crypto/gmd5"
 	"github.com/gogf/gf/v2/database/gdb"
@@ -27,9 +28,30 @@ import (
 // ==================== 缓存管理器（单例） ====================
 
 var (
-	localCache *gcache.Cache
+	localCache    *gcache.Cache
+	snowflakeNode *snowflake.Node
+	snowflakeOnce sync.Once
 )
 
+func init() {
+	ctx := context.Background()
+	snowflakeOnce.Do(func() {
+		nodeId := genv.Get("APP_NODE", 1).Int64()
+		// 安全范围 0~1023
+		if nodeId < 0 || nodeId > 1023 {
+			nodeId = 1
+		}
+
+		node, err := snowflake.NewNode(nodeId)
+		if err != nil {
+			g.Log().Errorf(ctx, "snowflake init failed: %v", err)
+			return
+		}
+
+		snowflakeNode = node
+	})
+}
+
 // getLocalCache 获取本地缓存实例
 func getLocalCache() *gcache.Cache {
 	if localCache == nil {
@@ -165,18 +187,13 @@ func insertHook(ctx context.Context, in *gdb.HookInsertInput) (result sql.Result
 		return nil, err
 	}
 
-	nodeId := genv.Get("APP_NODE", "").Int64()
+	if g.IsEmpty(snowflakeNode) {
-	if g.IsEmpty(nodeId) {
+		return nil, fmt.Errorf("snowflakeNode is nil")
-		nodeId = 1
 	}
 
-	node, err := snowflake.NewNode(nodeId)
-	if err != nil {
-		return nil, err
-	}
 	for i := range in.Data {
 		if _, ok := in.Data[i]["id"]; ok {
-			in.Data[i]["id"] = node.Generate().Int64()
+			in.Data[i]["id"] = snowflakeNode.Generate().Int64()
 		}
 		if _, ok := in.Data[i]["tenant_id"]; ok {
 			if g.IsEmpty(in.Data[i]["tenant_id"]) {
@@ -422,6 +439,7 @@ var (
 
 type Gfdb interface {
 	GetAll(ctx context.Context, sql string, args ...any) (gdb.Result, error)
+	GetOne(ctx context.Context, sql string, args ...any) (gdb.Record, error)
 	Exec(ctx context.Context, sql string, args ...any) (sql.Result, error)
 	Model(ctx context.Context, tableNameOrStruct ...any) *model
 	Transaction(ctx context.Context, f func(ctx context.Context, tx gdb.TX) error) error

db/mongo/connection.go

@@ -16,7 +16,7 @@ import (
 	"syscall"
 	"time"
 
-	"gitea.com/red-future/common/log/consts"
+	"gitea.redpowerfuture.com/red-future/common/log/consts"
 
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/os/glog"

db/mongo/mongo.go

@@ -11,12 +11,12 @@ import (
 	"fmt"
 	"time"
 
-	"gitea.com/red-future/common/log/consts"
+	"gitea.redpowerfuture.com/red-future/common/log/consts"
 	"go.mongodb.org/mongo-driver/v2/event"
 
-	"gitea.com/red-future/common/beans"
+	"gitea.redpowerfuture.com/red-future/common/beans"
-	"gitea.com/red-future/common/log/model/entity"
+	"gitea.redpowerfuture.com/red-future/common/log/model/entity"
-	"gitea.com/red-future/common/utils"
+	"gitea.redpowerfuture.com/red-future/common/utils"
 	"github.com/gogf/gf/v2/container/gvar"
 	"github.com/gogf/gf/v2/errors/gerror"
 	"github.com/gogf/gf/v2/frame/g"

full-text-search/meilisearch/meilisearch.go

@@ -10,8 +10,8 @@ import (
 	"fmt"
 	"time"
 
-	"gitea.com/red-future/common/beans"
+	"gitea.redpowerfuture.com/red-future/common/beans"
-	"gitea.com/red-future/common/utils"
+	"gitea.redpowerfuture.com/red-future/common/utils"
 	"github.com/gogf/gf/v2/container/gvar"
 	"github.com/gogf/gf/v2/errors/gerror"
 	"github.com/gogf/gf/v2/frame/g"

go.mod

@@ -1,4 +1,4 @@
-module gitea.com/red-future/common
+module gitea.redpowerfuture.com/red-future/common
 
 go 1.26.0
 

http/http.go

@@ -4,14 +4,15 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"io"
 	"net/http"
 	"reflect"
 	"regexp"
 	"strings"
 
-	_ "gitea.com/red-future/common/consul"
+	_ "gitea.redpowerfuture.com/red-future/common/consul"
-	"gitea.com/red-future/common/jaeger"
+	"gitea.redpowerfuture.com/red-future/common/jaeger"
-	"gitea.com/red-future/common/utils"
+	"gitea.redpowerfuture.com/red-future/common/utils"
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/net/gclient"
 	"github.com/gogf/gf/v2/net/ghttp"
@@ -69,10 +70,10 @@ func SkipMiddleware(h func(r *ghttp.Request), path string) (handler ghttp.Handle
 }
 
 func RouteRegister(controllers []interface{}) {
-	//Httpserver.Group("/log", func(group *ghttp.RouterGroup) {
+	Httpserver.Group("/log", func(group *ghttp.RouterGroup) {
-	//	group.Middleware(jaeger.NewTracer)
+		group.Middleware(jaeger.NewTracer)
-	//	group.Bind(controller.OperationLog)
+		//group.Bind(controller.OperationLog)
-	//})
+	})
 	re := regexp.MustCompile("[A-Z]")
 	for _, t := range controllers {
 		sName := reflect.ValueOf(t).Elem().Type().Name()
@@ -80,19 +81,15 @@ func RouteRegister(controllers []interface{}) {
 			return fmt.Sprintf("/%s", strings.ToLower(s))
 		})
 		Httpserver.Group(convertedStr, func(group *ghttp.RouterGroup) {
-			group.Middleware(jaeger.NewTracer)
 			group.Bind(t)
 		})
 	}
 	go Httpserver.Run()
 }
 
-// doRequest 统一HTTP请求处理（DELETE用ContentJson发送body，gconv.Struct增加err检查）
+// doRequestRaw 执行HTTP请求，返回gclient.Response，调用方需自行Close
-func doRequest(ctx context.Context, method string, url string, headers map[string]string, target any, data ...any) (err error) {
+// 统一处理：client克隆、ContentJson设置、请求头注入、GET查询参数转换
-	err = utils.ValidStructPtr(target)
+func doRequestRaw(ctx context.Context, method string, url string, headers map[string]string, data ...any) (*gclient.Response, error) {
-	if err != nil {
-		return
-	}
 	client := Httpclient.Clone()
 
 	// POST/PUT/DELETE请求都需要显式用ContentJson序列化body
@@ -110,9 +107,9 @@ func doRequest(ctx context.Context, method string, url string, headers map[strin
 	// 修复：避免data...展开导致的双重包装问题
 	// 当只有一个元素时，直接传递该元素，避免被包装成数组
 	var response *gclient.Response
+	var err error
 	// 对于GET请求，将参数转换为map
 	if method == http.MethodGet && len(data) > 0 && len(data)%2 == 0 {
-		// 构建query参数map
 		queryParams := make(map[string]string)
 		for i := 0; i < len(data); i += 2 {
 			if key, ok := data[i].(string); ok && i+1 < len(data) {
@@ -126,17 +123,33 @@ func doRequest(ctx context.Context, method string, url string, headers map[strin
 	} else {
 		response, err = client.DoRequest(ctx, method, url, data...)
 	}
+	return response, err
+}
+
+// doRequest 统一HTTP请求处理（同步/异步，解析内部API响应格式并填充target）
+func doRequest(ctx context.Context, method string, url string, headers map[string]string, target any, respParse bool, data ...any) (res []byte, err error) {
+	if target != nil || respParse {
+		err = utils.ValidStructPtr(target)
+		if err != nil {
+			return
+		}
+	}
+
+	response, err := doRequestRaw(ctx, method, url, headers, data...)
 	if err != nil {
 		return
 	}
 	defer response.Close()
 	result := response.ReadAll()
 
+	if !respParse {
+		return result, nil
+	}
 	// 统一处理内部API响应格式：{code:200,message:"",data:{...}}
 	resultStrut := &ghttp.DefaultHandlerResponse{}
 
 	if err = gconv.Struct(result, &resultStrut); err != nil { // 修复：增加err检查
-		return errors.New("响应解析失败: " + err.Error())
+		return nil, errors.New("响应解析失败: " + err.Error())
 	}
 
 	// 添加调试日志：打印解析后的结构
@@ -145,7 +158,7 @@ func doRequest(ctx context.Context, method string, url string, headers map[strin
 
 	if resultStrut.Code == 200 || resultStrut.Code == 0 {
 		if err = gconv.Struct(resultStrut.Data, target); err != nil { // 修复：增加err检查
-			return errors.New("数据解析失败: " + err.Error())
+			return nil, errors.New("数据解析失败: " + err.Error())
 		}
 		// 添加调试日志：打印最终的target
 		g.Log().Debugf(ctx, "[HTTP] 最终target: %+v", target)
@@ -154,19 +167,52 @@ func doRequest(ctx context.Context, method string, url string, headers map[strin
 	}
 	return
 }
+
 func Get(ctx context.Context, url string, headers map[string]string, target any, data ...any) (err error) {
-	err = doRequest(ctx, http.MethodGet, url, headers, target, data...)
+	_, err = doRequest(ctx, http.MethodGet, url, headers, target, true, data...)
 	return
 }
 func Post(ctx context.Context, url string, headers map[string]string, target any, data ...any) (err error) {
-	err = doRequest(ctx, http.MethodPost, url, headers, target, data...)
+	_, err = doRequest(ctx, http.MethodPost, url, headers, target, true, data...)
 	return
 }
 func Put(ctx context.Context, url string, headers map[string]string, target any, data ...any) (err error) {
-	err = doRequest(ctx, http.MethodPut, url, headers, target, data...)
+	_, err = doRequest(ctx, http.MethodPut, url, headers, target, true, data...)
 	return
 }
 func Delete(ctx context.Context, url string, headers map[string]string, target any, data ...any) (err error) {
-	err = doRequest(ctx, http.MethodDelete, url, headers, target, data...)
+	_, err = doRequest(ctx, http.MethodDelete, url, headers, target, true, data...)
 	return
 }
+
+func GetNotParse(ctx context.Context, url string, headers map[string]string, data ...any) (res []byte, err error) {
+	res, err = doRequest(ctx, http.MethodGet, url, headers, nil, false, data...)
+	return
+}
+func PostNotParse(ctx context.Context, url string, headers map[string]string, data ...any) (res []byte, err error) {
+	res, err = doRequest(ctx, http.MethodPost, url, headers, nil, false, data...)
+	return
+}
+
+// DoStream 流式HTTP请求，返回响应体io.ReadCloser，由调用方自行控制读取和关闭
+// 注意：返回的是原始响应流，不会解析内部API响应格式，调用方必须在使用后Close
+func doStream(ctx context.Context, method string, url string, headers map[string]string, data ...any) (io.ReadCloser, error) {
+	response, err := doRequestRaw(ctx, method, url, headers, data...)
+	if err != nil {
+		return nil, err
+	}
+
+	// 检查HTTP状态码，提前返回错误
+	if response.StatusCode < 200 || response.StatusCode >= 300 {
+		bodyBytes, _ := io.ReadAll(response.Body)
+		response.Close()
+		return nil, fmt.Errorf("[HTTP][Stream] 状态码异常: %d, body=%s", response.StatusCode, string(bodyBytes))
+	}
+
+	return response.Body, nil
+}
+
+// PostStream POST流式请求，返回响应体io.ReadCloser
+func PostStream(ctx context.Context, url string, headers map[string]string, data ...any) (io.ReadCloser, error) {
+	return doStream(ctx, http.MethodPost, url, headers, data...)
+}

log/controller/log_controller.go

@@ -3,8 +3,8 @@ package controller
 import (
 	"context"
 
-	"gitea.com/red-future/common/log/model/dto"
+	"gitea.redpowerfuture.com/red-future/common/log/model/dto"
-	"gitea.com/red-future/common/log/service"
+	"gitea.redpowerfuture.com/red-future/common/log/service"
 )
 
 type operationLog struct{}

log/dao/log_dao.go

@@ -3,15 +3,15 @@ package dao
 import (
 	"context"
 
-	"gitea.com/red-future/common/beans"
+	"gitea.redpowerfuture.com/red-future/common/beans"
-	"gitea.com/red-future/common/db/mongo"
+	"gitea.redpowerfuture.com/red-future/common/db/mongo"
 
 	"strings"
 	"time"
 
-	"gitea.com/red-future/common/log/consts"
+	"gitea.redpowerfuture.com/red-future/common/log/consts"
-	"gitea.com/red-future/common/log/model/dto"
+	"gitea.redpowerfuture.com/red-future/common/log/model/dto"
-	"gitea.com/red-future/common/log/model/entity"
+	"gitea.redpowerfuture.com/red-future/common/log/model/entity"
 	"go.mongodb.org/mongo-driver/v2/bson"
 )
 

log/model/dto/log_dto.go

@@ -1,7 +1,7 @@
 package dto
 
 import (
-	"gitea.com/red-future/common/beans"
+	"gitea.redpowerfuture.com/red-future/common/beans"
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/os/gtime"
 )

log/model/entity/log.go

@@ -1,7 +1,7 @@
 package entity
 
 import (
-	"gitea.com/red-future/common/beans"
+	"gitea.redpowerfuture.com/red-future/common/beans"
 )
 
 // OperationLog 操作日志实体 - 用于记录数据增删改操作行为

log/service/log_service.go

@@ -2,11 +2,11 @@ package service
 
 import (
 	"context"
-	"gitea.com/red-future/common/beans"
+	"gitea.redpowerfuture.com/red-future/common/beans"
-	"gitea.com/red-future/common/log/dao"
+	"gitea.redpowerfuture.com/red-future/common/log/dao"
-	"gitea.com/red-future/common/log/model/dto"
+	"gitea.redpowerfuture.com/red-future/common/log/model/dto"
-	logEntity "gitea.com/red-future/common/log/model/entity"
+	logEntity "gitea.redpowerfuture.com/red-future/common/log/model/entity"
-	"gitea.com/red-future/common/utils"
+	"gitea.redpowerfuture.com/red-future/common/utils"
 	"github.com/gogf/gf/v2/util/gconv"
 )
 

middleware/circuit_breaker.go

@@ -9,7 +9,7 @@ import (
 	"sync/atomic"
 	"time"
 
-	"gitea.com/red-future/common/utils"
+	"gitea.redpowerfuture.com/red-future/common/utils"
 	"github.com/alibaba/sentinel-golang/api"
 	"github.com/alibaba/sentinel-golang/core/circuitbreaker"
 	"github.com/gogf/gf/v2/frame/g"

middleware/module_tenant_check.go

@@ -4,9 +4,9 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	"gitea.com/red-future/common/beans"
+	"gitea.redpowerfuture.com/red-future/common/beans"
-	commonHttp "gitea.com/red-future/common/http"
+	commonHttp "gitea.redpowerfuture.com/red-future/common/http"
-	"gitea.com/red-future/common/utils"
+	"gitea.redpowerfuture.com/red-future/common/utils"
 	"github.com/gogf/gf/v2/database/gredis"
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/net/ghttp"

middleware/rate_limiter.go

@@ -5,7 +5,7 @@ import (
 	"fmt"
 	"strings"
 
-	"gitea.com/red-future/common/utils"
+	"gitea.redpowerfuture.com/red-future/common/utils"
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/net/ghttp"
 	"github.com/gogf/gf/v2/util/gconv"
@@ -92,7 +92,7 @@ func UserLimiter(r *ghttp.Request) {
 	var userName string
 	user, err := utils.GetUserInfo(r.GetCtx())
 	if err != nil {
-		r.Response.WriteStatusExit(429, err.Error())
+		r.Response.WriteStatusExit(401, err.Error())
 		return
 	}
 	userName = gconv.String(user.UserName)

swagger/swagger.go

@@ -2,8 +2,8 @@ package swagger
 
 import (
 	"fmt"
-	"gitea.com/red-future/common/consul"
+	"gitea.redpowerfuture.com/red-future/common/consul"
-	"gitea.com/red-future/common/http"
+	"gitea.redpowerfuture.com/red-future/common/http"
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/net/ghttp"
 	"github.com/gogf/gf/v2/util/gconv"

utils/utils.go

@@ -13,7 +13,7 @@ import (
 	"sync/atomic"
 	"time"
 
-	"gitea.com/red-future/common/beans"
+	"gitea.redpowerfuture.com/red-future/common/beans"
 	"github.com/gogf/gf/v2/container/gvar"
 	"github.com/gogf/gf/v2/database/gredis"
 	"github.com/gogf/gf/v2/errors/gcode"
@@ -460,3 +460,134 @@ func IsLocalIP(ip string) bool {
 	}
 	return false
 }
+
+// GetLocalIP 获取本机有效的局域网 IPv4 地址
+func GetLocalIP() string {
+	addrs, err := net.InterfaceAddrs()
+	if err != nil {
+		return "127.0.0.1"
+	}
+
+	var validIPs []string
+
+	for _, addr := range addrs {
+		ipnet, ok := addr.(*net.IPNet)
+		if !ok {
+			continue
+		}
+
+		ip := ipnet.IP
+
+		if isIPValid(ip) {
+			validIPs = append(validIPs, ip.String())
+		}
+	}
+
+	// 优先返回非 169.254.x.x 的 IP
+	for _, ip := range validIPs {
+		if !strings.HasPrefix(ip, "169.254.") {
+			return ip
+		}
+	}
+
+	// 其次返回 169.254.x.x（最后的选择）
+	if len(validIPs) > 0 {
+		return validIPs[0]
+	}
+
+	return "127.0.0.1"
+}
+
+// isIPValid 判断 IP 是否有效
+func isIPValid(ip net.IP) bool {
+	// 不是 loopback (127.0.0.1)
+	if ip.IsLoopback() {
+		return false
+	}
+
+	// 是 IPv4
+	if ip.To4() == nil {
+		return false
+	}
+
+	// 不是链路本地地址 (169.254.0.0/16)
+	if ip[0] == 169 && ip[1] == 254 {
+		return false
+	}
+
+	// 不是组播地址
+	if ip.IsMulticast() {
+		return false
+	}
+
+	// 不是未指定地址 (0.0.0.0)
+	if ip.IsUnspecified() {
+		return false
+	}
+
+	return true
+}
+
+func GetServerPort(ctx context.Context) string {
+	address := g.Cfg().MustGet(ctx, "server.address", ":8080").String()
+	// address 格式如 ":3009"，去掉冒号
+	if strings.HasPrefix(address, ":") {
+		return address[1:]
+	}
+	return "8080"
+}
+
+// GetLocalAddress 获取局域网地址（IP:端口）
+func GetLocalAddress(ctx context.Context) string {
+	ip := GetLocalIP()
+	port := GetServerPort(ctx)
+
+	if port == "80" || port == "443" {
+		return ip
+	}
+	return ip + ":" + port
+}
+
+// GetSchemaFromRequest 从当前请求中获取协议（http/https）
+func GetSchemaFromRequest(ctx context.Context) string {
+	r := g.RequestFromCtx(ctx)
+	if r == nil {
+		return "http"
+	}
+
+	// 1. 代理场景：X-Forwarded-Proto
+	if proto := r.Header.Get("X-Forwarded-Proto"); proto != "" {
+		return proto
+	}
+
+	// 2. 代理场景：X-Forwarded-Scheme
+	if proto := r.Header.Get("X-Forwarded-Scheme"); proto != "" {
+		return proto
+	}
+
+	// 3. TLS 连接（直接 HTTPS）
+	if r.TLS != nil {
+		return "https"
+	}
+
+	// 4. 默认 HTTP（这行很重要！）
+	return "http" // ← 确保有这行
+}
+
+// GetLocalBaseURL 获取局域网基础 URL（动态协议 + IP + 端口）
+func GetLocalBaseURL(ctx context.Context) string {
+	schema := GetSchemaFromRequest(ctx)
+	addr := GetLocalAddress(ctx)
+	return schema + "://" + addr
+}
+
+// GetCallbackURL 获取回调地址（完整 URL）
+func GetCallbackURL(ctx context.Context, path string) string {
+	//baseURL := GetLocalBaseURL(ctx)
+	baseURL := "http://" + GetLocalAddress(ctx)
+	// 确保 path 以 / 开头
+	if !strings.HasPrefix(path, "/") {
+		path = "/" + path
+	}
+	return baseURL + path
+}