fcm

server/fcm.go

@@ -129,22 +129,22 @@ func (f *FirebaseMessageServer) queueRun(ctx context.Context) {
 			}
 
 			for _, queue := range queues {
-				var remainingRetries int = queue.RemainingRetries
-				remainingRetries = remainingRetries - 1
-				if remainingRetries > 0 {
-					queue.LastRetryTime = Now(time.Now().UTC())
-					queue.RemainingRetries = remainingRetries
-					// 使用一次, 如果次数用完删除
-					if err := f.repos.FirebaseMessageQueueRepository.Save(ctx, &queue); err != nil {
-						zap.L().Error("[firebase] 更新队列信息错误", zap.Any("queue", queue), zap.Error(err))
-						continue
-					}
-				} else {
-					if err := f.repos.FirebaseMessageQueueRepository.Delete(ctx, queue.ID); err != nil {
-						zap.L().Error("[firebase] 删除队列错误", zap.Any("queue", queue), zap.Error(err))
-						continue
-					}
-				}
+				// var remainingRetries int = queue.RemainingRetries
+				// remainingRetries = remainingRetries - 1
+				// if remainingRetries > 0 {
+				// 	queue.LastRetryTime = Now(time.Now().UTC())
+				// 	queue.RemainingRetries = remainingRetries
+				// 	// 使用一次, 如果次数用完删除
+				// 	if err := f.repos.FirebaseMessageQueueRepository.Save(ctx, &queue); err != nil {
+				// 		zap.L().Error("[firebase] 更新队列信息错误", zap.Any("queue", queue), zap.Error(err))
+				// 		continue
+				// 	}
+				// } else {
+				// 	if err := f.repos.FirebaseMessageQueueRepository.Delete(ctx, queue.ID); err != nil {
+				// 		zap.L().Error("[firebase] 删除队列错误", zap.Any("queue", queue), zap.Error(err))
+				// 		continue
+				// 	}
+				// }
 
 				receiver := queue.Receiver
 				firebaseToken, err := f.repos.FirebaseMessageRepository.GetFirebaseToken(ctx, receiver)