diff --git a/server/websocket/internal/logic/ws_statistics.go b/server/websocket/internal/logic/ws_statistics.go index ad49d752..7be069ad 100644 --- a/server/websocket/internal/logic/ws_statistics.go +++ b/server/websocket/internal/logic/ws_statistics.go @@ -94,12 +94,10 @@ func ConsumeWebsocketStatData(ctx context.Context) { case TYPE_CONNECT_COUNT: //ws连接计数 statData, ok := mapUserWsStat.Load(key) if !ok { - if data.Value <= 0 { - continue - } mapUserWsStat.Store(key, mapUserWsStatItem{ CurWsConnectCount: data.Value, }) + continue } stat, ok := statData.(mapUserWsStatItem) if !ok { @@ -107,22 +105,12 @@ func ConsumeWebsocketStatData(ctx context.Context) { continue } stat.CurWsConnectCount += data.Value - if stat.CurWsConnectCount <= 0 { //小于等于0则移除 - mapUserWsStat.Delete(key) - } else { - mapUserWsStat.Store(key, stat) - } + mapUserWsStat.Store(key, stat) case TYPE_COMBINE_IMAGE_REQUEST_COUNT: //请求算法合图计数 statData, ok := mapUserWsStat.Load(key) //不存在 if !ok { - //数据是减少的 - if data.Value <= 0 { - continue - } - mapUserWsStat.Store(key, mapUserWsStatItem{ - CurCombineCount: data.Value, - }) + continue } //存在 if stat, ok := statData.(mapUserWsStatItem); ok {