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-16 14:29:25 +08:00
parent 7d2c2ab025
commit 6e78e4f209
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
server/websocket/internal/logic/ws_render_image_logic.go
View File

@ -31,6 +31,11 @@ type renderImageControlChanItem struct {
// 渲染发送到组装数据组装数据 // 渲染发送到组装数据组装数据
func (w *wsConnectItem) renderImage(data []byte) { func (w *wsConnectItem) renderImage(data []byte) {
defer func() {
if err := recover(); err != nil {
logx.Error("renderImage panic:", err)
}
}()
var renderImageData websocket_data.RenderImageReqMsg var renderImageData websocket_data.RenderImageReqMsg
if err := json.Unmarshal(data, &renderImageData); err != nil { if err := json.Unmarshal(data, &renderImageData); err != nil {
w.sendToOutChan(w.respondDataFormat(constants.WEBSOCKET_ERR_DATA_FORMAT, "invalid format of websocket render image message:"+string(data))) w.sendToOutChan(w.respondDataFormat(constants.WEBSOCKET_ERR_DATA_FORMAT, "invalid format of websocket render image message:"+string(data)))
@ -114,7 +119,7 @@ func (w *wsConnectItem) renderImage(data []byte) {
func (w *wsConnectItem) assembleRenderData(taskId string, info websocket_data.RenderImageReqMsg) { func (w *wsConnectItem) assembleRenderData(taskId string, info websocket_data.RenderImageReqMsg) {
defer func() { defer func() {
if err := recover(); err != nil { if err := recover(); err != nil {
logx.Error("MqConsumerRenderAssemble panic:", err) logx.Error("assembleRenderData panic:", err)
} }
}() }()
//根据templateTag获取templateTagId(后续模板表的tag改成template_tag后可能就不需要这个步骤了) //根据templateTag获取templateTagId(后续模板表的tag改成template_tag后可能就不需要这个步骤了)