新增写失败也会跳过，下次再执行

2025-09-03 14:37:05 +08:00
parent 33c8712c72
commit 4d5d6f401b
1 changed files with 4 additions and 4 deletions
--- a/internal/logic/gameAct/gameAct.go
+++ b/internal/logic/gameAct/gameAct.go
@@ -498,10 +498,10 @@ func (s *sGameAct) Cache2SqlChan(ctx context.Context, addChan, updateChan chan *
 				g.Log().Error(ctx, err2)
 				continue
 			}
-			//if row, _ := addRes.RowsAffected(); row == 0 {
-			//	g.Log().Error(ctx, "本次新增为0，新增数据失败: %v", v)
-			//	continue
-			//}
+			if row, _ := addRes.RowsAffected(); row == 0 {
+				//g.Log().Error(ctx, "本次新增为0，新增数据失败: %v", v)
+				continue
+			}
 			row, _ := addRes.RowsAffected()
 			addCount += row
 			//删除缓存