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 14:37:05 +08:00
parent 33c8712c72
commit 2709af041b
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -498,10 +498,10 @@ 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
//} }
row, _ := addRes.RowsAffected() row, _ := addRes.RowsAffected()
addCount += row addCount += row
//删除缓存 //删除缓存