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-07-25 17:12:37 +08:00
parent 9c72a8a4c9
commit 17aac7ad66
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/websocket/internal/handler/datatransferhandler.go
View File

@ -214,7 +214,7 @@ func (w *wsConnectItem) dealwithReciveData(data []byte) {
defer w.mutex.Unlock() defer w.mutex.Unlock()
//把需要渲染的图片加进去 //把需要渲染的图片加进去
for _, v := range renderImageData { for _, v := range renderImageData {
key := getRenderImageMapKey(v.ProductId, v.SizeId, v.TemplateId) key := w.getRenderImageMapKey(v.ProductId, v.SizeId, v.TemplateId)
w.renderImage[key] = struct{}{} w.renderImage[key] = struct{}{}
} }
default: default:
@ -223,6 +223,6 @@ func (w *wsConnectItem) dealwithReciveData(data []byte) {
} }
// 获取需要渲染图片的map key // 获取需要渲染图片的map key
func getRenderImageMapKey(productId, sizeId, templateId int64) string { func (w *wsConnectItem) getRenderImageMapKey(productId, sizeId, templateId int64) string {
return fmt.Sprintf("%d-%d-%d", productId, sizeId, templateId) return fmt.Sprintf("%d-%d-%d", productId, sizeId, templateId)
} }

2
server/websocket/internal/handler/rendernotifyhandler.go
View File

@ -39,7 +39,7 @@ func setOutRenderImage(req types.RenderNotifyReq, ws wsConnectItem) {
ws.mutex.Lock() ws.mutex.Lock()
defer ws.mutex.Unlock() defer ws.mutex.Unlock()
for _, notifyItem := range req.NotifyList { for _, notifyItem := range req.NotifyList {
renderKey := getRenderImageMapKey(notifyItem.ProductId, notifyItem.SizeId, notifyItem.TemplateId) renderKey := ws.getRenderImageMapKey(notifyItem.ProductId, notifyItem.SizeId, notifyItem.TemplateId)
//加载并删除 //加载并删除
_, ok := ws.renderImage[renderKey] _, ok := ws.renderImage[renderKey]
if !ok { if !ok {