fix(prompt): 修复OSS内容解析问题
This commit is contained in:
@@ -2,6 +2,7 @@ package prompt
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
|
"encoding/json"
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"prompts-core/common/util"
|
"prompts-core/common/util"
|
||||||
@@ -14,7 +15,6 @@ import (
|
|||||||
|
|
||||||
"gitea.redpowerfuture.com/red-future/common/beans"
|
"gitea.redpowerfuture.com/red-future/common/beans"
|
||||||
"gitea.redpowerfuture.com/red-future/common/utils"
|
"gitea.redpowerfuture.com/red-future/common/utils"
|
||||||
"github.com/gogf/gf/v2/encoding/gjson"
|
|
||||||
"github.com/gogf/gf/v2/frame/g"
|
"github.com/gogf/gf/v2/frame/g"
|
||||||
"github.com/gogf/gf/v2/util/gconv"
|
"github.com/gogf/gf/v2/util/gconv"
|
||||||
)
|
)
|
||||||
@@ -154,7 +154,9 @@ func Callback(ctx context.Context, req *dto.CallbackReq) error {
|
|||||||
// 3) 解析 OSS 内容为消息
|
// 3) 解析 OSS 内容为消息
|
||||||
var messages map[string]any
|
var messages map[string]any
|
||||||
if len(ossContent) > 0 {
|
if len(ossContent) > 0 {
|
||||||
messages = gjson.New(ossContent).Map()
|
if err := json.Unmarshal(ossContent, &messages); err != nil {
|
||||||
|
g.Log().Warningf(ctx, "[回调处理] 解析OSS内容失败 taskId=%s err=%v", req.TaskId, err)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// 4) 处理失败
|
// 4) 处理失败
|
||||||
|
|||||||
Reference in New Issue
Block a user