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

Merge branch 'develop' of gitee.com:fusenpack/fusenapi into develop

Browse Source
This commit is contained in:
momo 2023-11-02 15:58:15 +08:00
commit d9e854ca45
1 changed files with 4 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
server/websocket/internal/logic/ws_statistics.go
View File

@ -226,47 +226,41 @@ func ConsumeWebsocketStatData() {
if !ok { if !ok {
continue continue
} }
curCombineTotalCount += data.Num
//存在 //存在
stat, ok := statData.(mapUserWsStatItem) stat, ok := statData.(mapUserWsStatItem)
if !ok { if !ok {
logx.Error("断言mapUserWsStatItem错误") logx.Error("断言mapUserWsStatItem错误")
continue continue
} }
curCombineTotalCount += data.Num
stat.CurCombineCount += data.Num stat.CurCombineCount += data.Num
if stat.CurCombineCount < 0 {
stat.CurCombineCount = 0
}
//保存统计 //保存统计
mapUserWsStat.Store(key, stat) mapUserWsStat.Store(key, stat)
case TYPE_CUR_UNITY_HANDLE_COUNT: //unity处理计数 case TYPE_CUR_UNITY_HANDLE_COUNT: //unity处理计数
if !ok { if !ok {
continue continue
} }
curUnityHandleTotalCount += data.Num
//存在 //存在
stat, ok := statData.(mapUserWsStatItem) stat, ok := statData.(mapUserWsStatItem)
if !ok { if !ok {
logx.Error("断言mapUserWsStatItem错误") logx.Error("断言mapUserWsStatItem错误")
continue continue
} }
curUnityHandleTotalCount += data.Num
stat.CurUnityHandleCount += data.Num stat.CurUnityHandleCount += data.Num
if stat.CurUnityHandleCount < 0 {
stat.CurUnityHandleCount = 0
}
//保存统计 //保存统计
mapUserWsStat.Store(key, stat) mapUserWsStat.Store(key, stat)
case TYPE_CUR_COMBINE_IMAGE_ERR_COUNT: //合图失败计数 case TYPE_CUR_COMBINE_IMAGE_ERR_COUNT: //合图失败计数
if !ok { if !ok {
continue continue
} }
combineErrTotalCount += data.Num
//存在 //存在
stat, ok := statData.(mapUserWsStatItem) stat, ok := statData.(mapUserWsStatItem)
if !ok { if !ok {
logx.Error("断言mapUserWsStatItem错误") logx.Error("断言mapUserWsStatItem错误")
continue continue
} }
combineErrTotalCount += data.Num
stat.CombineErrCount += data.Num stat.CombineErrCount += data.Num
//保存统计 //保存统计
mapUserWsStat.Store(key, stat) mapUserWsStat.Store(key, stat)
@ -274,13 +268,13 @@ func ConsumeWebsocketStatData() {
if !ok { if !ok {
continue continue
} }
unityErrTotalCount += data.Num
//存在 //存在
stat, ok := statData.(mapUserWsStatItem) stat, ok := statData.(mapUserWsStatItem)
if !ok { if !ok {
logx.Error("断言mapUserWsStatItem错误") logx.Error("断言mapUserWsStatItem错误")
continue continue
} }
unityErrTotalCount += data.Num
stat.UnityErrCount += data.Num stat.UnityErrCount += data.Num
//保存统计 //保存统计
mapUserWsStat.Store(key, stat) mapUserWsStat.Store(key, stat)