refactor: 移除内部API响应解析逻辑

db/gfdb/gfdb.go

@@ -179,17 +179,21 @@ func insertHook(ctx context.Context, in *gdb.HookInsertInput) (result sql.Result
 			in.Data[i]["id"] = node.Generate().Int64()
 		}
 		if _, ok := in.Data[i]["tenant_id"]; ok {
-			if !g.IsEmpty(userInfo.TenantId) {
-				in.Data[i]["tenant_id"] = userInfo.TenantId
-			} else {
-				return nil, fmt.Errorf("tenantId cannot be empty")
+			if g.IsEmpty(in.Data[i]["tenant_id"]) {
+				if !g.IsEmpty(userInfo.TenantId) {
+					in.Data[i]["tenant_id"] = userInfo.TenantId
+				} else {
+					return nil, fmt.Errorf("tenantId cannot be empty")
+				}
 			}
 		}
 		if _, ok := in.Data[i]["creator"]; ok {
-			if !g.IsEmpty(userInfo.UserName) {
-				in.Data[i]["creator"] = userInfo.UserName
-			} else {
-				return nil, fmt.Errorf("user info cannot be empty")
+			if g.IsEmpty(in.Data[i]["tenant_id"]) {
+				if !g.IsEmpty(userInfo.UserName) {
+					in.Data[i]["creator"] = userInfo.UserName
+				} else {
+					return nil, fmt.Errorf("user info cannot be empty")
+				}
 			}
 		}
 		if _, ok := in.Data[i]["updater"]; ok {

http/http.go

@@ -2,7 +2,6 @@ package http
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"net/http"
 	"reflect"
@@ -130,28 +129,28 @@ func doRequest(ctx context.Context, method string, url string, headers map[strin
 		return
 	}
 	defer response.Close()
-	result := response.ReadAll()
-
-	// 统一处理内部API响应格式：{code:200,message:"",data:{...}}
-	resultStrut := &ghttp.DefaultHandlerResponse{}
-
-	if err = gconv.Struct(result, &resultStrut); err != nil { // 修复：增加err检查
-		return errors.New("响应解析失败: " + err.Error())
-	}
-
-	// 添加调试日志：打印解析后的结构
-	g.Log().Debugf(ctx, "[HTTP] 解析后结构: Code=%d, Message=%s, Data类型=%T, Data值=%+v",
-		resultStrut.Code, resultStrut.Message, resultStrut.Data, resultStrut.Data)
-
-	if resultStrut.Code == 200 || resultStrut.Code == 0 {
-		if err = gconv.Struct(resultStrut.Data, target); err != nil { // 修复：增加err检查
-			return errors.New("数据解析失败: " + err.Error())
-		}
-		// 添加调试日志：打印最终的target
-		g.Log().Debugf(ctx, "[HTTP] 最终target: %+v", target)
-	} else {
-		err = errors.New(resultStrut.Message)
-	}
+	//result := response.ReadAll()
+	//
+	//// 统一处理内部API响应格式：{code:200,message:"",data:{...}}
+	//resultStrut := &ghttp.DefaultHandlerResponse{}
+	//
+	//if err = gconv.Struct(result, &resultStrut); err != nil { // 修复：增加err检查
+	//	return errors.New("响应解析失败: " + err.Error())
+	//}
+	//
+	//// 添加调试日志：打印解析后的结构
+	//g.Log().Debugf(ctx, "[HTTP] 解析后结构: Code=%d, Message=%s, Data类型=%T, Data值=%+v",
+	//	resultStrut.Code, resultStrut.Message, resultStrut.Data, resultStrut.Data)
+	//
+	//if resultStrut.Code == 200 || resultStrut.Code == 0 {
+	//	if err = gconv.Struct(resultStrut.Data, target); err != nil { // 修复：增加err检查
+	//		return errors.New("数据解析失败: " + err.Error())
+	//	}
+	//	// 添加调试日志：打印最终的target
+	//	g.Log().Debugf(ctx, "[HTTP] 最终target: %+v", target)
+	//} else {
+	//	err = errors.New(resultStrut.Message)
+	//}
 	return
 }
 func Get(ctx context.Context, url string, headers map[string]string, target any, data ...any) (err error) {