fix
This commit is contained in:
parent
e916b572c5
commit
5721bb31c8
|
@ -226,13 +226,13 @@ 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
|
||||||
//保存统计
|
//保存统计
|
||||||
mapUserWsStat.Store(key, stat)
|
mapUserWsStat.Store(key, stat)
|
||||||
|
@ -240,13 +240,13 @@ func ConsumeWebsocketStatData() {
|
||||||
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
|
||||||
//保存统计
|
//保存统计
|
||||||
mapUserWsStat.Store(key, stat)
|
mapUserWsStat.Store(key, stat)
|
||||||
|
@ -254,13 +254,13 @@ func ConsumeWebsocketStatData() {
|
||||||
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)
|
||||||
|
@ -268,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)
|
||||||
|
|
Loading…
Reference in New Issue
Block a user