diff --git a/server/websocket/internal/logic/ws_statistics.go b/server/websocket/internal/logic/ws_statistics.go index 7d086c1c..ad49d752 100644 --- a/server/websocket/internal/logic/ws_statistics.go +++ b/server/websocket/internal/logic/ws_statistics.go @@ -114,13 +114,17 @@ func ConsumeWebsocketStatData(ctx context.Context) { } case TYPE_COMBINE_IMAGE_REQUEST_COUNT: //请求算法合图计数 statData, ok := mapUserWsStat.Load(key) + //不存在 if !ok { - if data.Value > 0 { - mapUserWsStat.Store(key, mapUserWsStatItem{ - CurCombineCount: data.Value, - }) + //数据是减少的 + if data.Value <= 0 { + continue } + mapUserWsStat.Store(key, mapUserWsStatItem{ + CurCombineCount: data.Value, + }) } + //存在 if stat, ok := statData.(mapUserWsStatItem); ok { stat.CurCombineCount += data.Value if stat.CurCombineCount < 0 {