diff --git a/model/subscription.go b/model/subscription.go
index 3096e2fcd..f9e20da47 100644
--- a/model/subscription.go
+++ b/model/subscription.go
@@ -838,7 +838,11 @@ func PreConsumeUserSubscription(requestId string, userId int, modelName string,
 
 	err := DB.Transaction(func(tx *gorm.DB) error {
 		var existing SubscriptionPreConsumeRecord
-		if err := tx.Where("request_id = ?", requestId).First(&existing).Error; err == nil {
+		query := tx.Where("request_id = ?", requestId).Limit(1).Find(&existing)
+		if query.Error != nil {
+			return query.Error
+		}
+		if query.RowsAffected > 0 {
 			if existing.Status == "refunded" {
 				return errors.New("subscription pre-consume already refunded")
 			}