public_project/utility_go
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

去掉更新日志

Browse Source
This commit is contained in:
ayflying
2025-09-03 13:46:39 +08:00
parent 26763c04e3
commit 33c8712c72
1 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
internal/logic/gameAct/gameAct.go
View File

@@ -471,9 +471,9 @@ func (s *sGameAct) Cache2Sql(ctx context.Context, add, update []*entity.GameAct)
// Cache2AddChan 批量添加数据库 // Cache2AddChan 批量添加数据库
func (s *sGameAct) Cache2SqlChan(ctx context.Context, addChan, updateChan chan *entity.GameAct) { func (s *sGameAct) Cache2SqlChan(ctx context.Context, addChan, updateChan chan *entity.GameAct) {
//批量写入数据库计数 //批量写入数据库计数
var addCount int var addCount int64
//批量更新数据库计数 //批量更新数据库计数
var updateCount int var updateCount int64
//通道关闭标志 //通道关闭标志
addClosed := false addClosed := false
updateClosed := false updateClosed := false
@@ -498,11 +498,12 @@ func (s *sGameAct) Cache2SqlChan(ctx context.Context, addChan, updateChan chan *
g.Log().Error(ctx, err2) g.Log().Error(ctx, err2)
continue continue
} }
if row, _ := addRes.RowsAffected(); row == 0 { //if row, _ := addRes.RowsAffected(); row == 0 {
g.Log().Error(ctx, "本次新增为0，新增数据失败: %v", v) // g.Log().Error(ctx, "本次新增为0，新增数据失败: %v", v)
continue // continue
} //}
addCount++ row, _ := addRes.RowsAffected()
addCount += row
//删除缓存 //删除缓存
s.DelCacheKey(ctx, v.ActId, v.Uid) s.DelCacheKey(ctx, v.ActId, v.Uid)
@@ -521,7 +522,7 @@ func (s *sGameAct) Cache2SqlChan(ctx context.Context, addChan, updateChan chan *
continue continue
} }
if row, _ := updateRes.RowsAffected(); row == 0 { if row, _ := updateRes.RowsAffected(); row == 0 {
g.Log().Error(ctx, "本次更新为0，更新数据失败: %v", v) //g.Log().Error(ctx, "本次更新为0，更新数据失败: %v", v)
continue continue
} }
//删除缓存 //删除缓存