2 Commits

Author SHA1 Message Date
qhd
960dca6a50 fix: 修正 creator 字段空值检查逻辑 2026-04-22 15:03:39 +08:00
qhd
518d45d296 feat: 启用API响应解析逻辑 2026-04-22 14:52:23 +08:00
2 changed files with 24 additions and 23 deletions

View File

@@ -188,7 +188,7 @@ func insertHook(ctx context.Context, in *gdb.HookInsertInput) (result sql.Result
} }
} }
if _, ok := in.Data[i]["creator"]; ok { if _, ok := in.Data[i]["creator"]; ok {
if g.IsEmpty(in.Data[i]["tenant_id"]) { if g.IsEmpty(in.Data[i]["creator"]) {
if !g.IsEmpty(userInfo.UserName) { if !g.IsEmpty(userInfo.UserName) {
in.Data[i]["creator"] = userInfo.UserName in.Data[i]["creator"] = userInfo.UserName
} else { } else {

View File

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