fusen/fusenapi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
laodaming 2023-08-10 19:12:07 +08:00
parent 34a055aa05
commit d101d241f4
2 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/render/consumer/assemble_render_data.go
View File

@ -33,6 +33,11 @@ type MqConsumerRenderAssemble struct {
} }
func (m *MqConsumerRenderAssemble) Run(ctx context.Context, data []byte) error { func (m *MqConsumerRenderAssemble) Run(ctx context.Context, data []byte) error {
defer func() {
if err := recover(); err != nil {
logx.Error("MqConsumerRenderAssemble panic:", err)
}
}()
logx.Info("收到需要组装的消息:", string(data)) logx.Info("收到需要组装的消息:", string(data))
var parseInfo websocket_data.AssembleRenderData var parseInfo websocket_data.AssembleRenderData
if err := json.Unmarshal(data, &parseInfo); err != nil { if err := json.Unmarshal(data, &parseInfo); err != nil {
@ -244,6 +249,7 @@ func getCombineImage(ctx context.Context, svcCtx *svc.ServiceContext, parseInfo
logx.Error("failed to parse python api rsp:", err) logx.Error("failed to parse python api rsp:", err)
return "", err return "", err
} }
//fmt.Println("××××××××××××××××××××：", pythonApiInfo)
//上传刀版图 //上传刀版图
var upload = file.Upload{ var upload = file.Upload{
Ctx: ctx, Ctx: ctx,

5
server/websocket/internal/logic/mq_consumer.go
View File

@ -13,6 +13,11 @@ type MqConsumerRenderResult struct {
} }
func (m *MqConsumerRenderResult) Run(ctx context.Context, data []byte) error { func (m *MqConsumerRenderResult) Run(ctx context.Context, data []byte) error {
defer func() {
if err := recover(); err != nil {
logx.Error("MqConsumerRenderResult panic:", err)
}
}()
logx.Info("接收到MqConsumerRenderResult数据:", string(data)) logx.Info("接收到MqConsumerRenderResult数据:", string(data))
var parseInfo websocket_data.RenderImageNotify var parseInfo websocket_data.RenderImageNotify
if err := json.Unmarshal(data, &parseInfo); err != nil { if err := json.Unmarshal(data, &parseInfo); err != nil {