debug: Arreglo de consulta de sql para limites de planes

Author: rioslucas1

src/main/java/com/outfitlab/project/infrastructure/repositories/UserSubscriptionRepositoryImpl.java

@@ -15,35 +15,35 @@ public class UserSubscriptionRepositoryImpl implements UserSubscriptionRepositor
     private final UserSubscriptionJpaRepository jpaRepository;
     private final UserJpaRepository userJpaRepository;
     private final SubscriptionJpaRepository subscriptionJpaRepository;
-    
+
     public UserSubscriptionRepositoryImpl(UserSubscriptionJpaRepository jpaRepository,
-                                         UserJpaRepository userJpaRepository,
-                                         SubscriptionJpaRepository subscriptionJpaRepository) {
+            UserJpaRepository userJpaRepository,
+            SubscriptionJpaRepository subscriptionJpaRepository) {
         this.jpaRepository = jpaRepository;
         this.userJpaRepository = userJpaRepository;
         this.subscriptionJpaRepository = subscriptionJpaRepository;
     }
-    
+
     @Override
     @Transactional(readOnly = true)
     public UserSubscriptionModel findByUserEmail(String userEmail) throws SubscriptionNotFoundException {
         return jpaRepository.findByUserEmail(userEmail)
-            .map(UserSubscriptionEntity::convertToModel)
-            .orElseThrow(() -> new SubscriptionNotFoundException(
-                "No se encontró suscripción para el usuario: " + userEmail));
+                .map(UserSubscriptionEntity::convertToModel)
+                .orElseThrow(() -> new SubscriptionNotFoundException(
+                        "No se encontró suscripción para el usuario: " + userEmail));
     }
-    
+
     @Override
     @Transactional
     public UserSubscriptionModel save(UserSubscriptionModel subscription) {
         UserEntity user = userJpaRepository.findByEmail(subscription.getUserEmail());
         if (user == null) {
             throw new RuntimeException("Usuario no encontrado: " + subscription.getUserEmail());
         }
-        
+
         SubscriptionEntity subscriptionEntity = subscriptionJpaRepository.findByPlanCode(subscription.getPlanCode())
-            .orElseThrow(() -> new RuntimeException("Plan no encontrado: " + subscription.getPlanCode()));
-        
+                .orElseThrow(() -> new RuntimeException("Plan no encontrado: " + subscription.getPlanCode()));
+
         UserSubscriptionEntity entity = new UserSubscriptionEntity();
         entity.setUser(user);
         entity.setSubscription(subscriptionEntity);
@@ -56,20 +56,21 @@ public UserSubscriptionModel save(UserSubscriptionModel subscription) {
         entity.setSubscriptionStart(subscription.getSubscriptionStart());
         entity.setSubscriptionEnd(subscription.getSubscriptionEnd());
         entity.setStatus(subscription.getStatus());
-        
+
         UserSubscriptionEntity saved = jpaRepository.save(entity);
         return UserSubscriptionEntity.convertToModel(saved);
     }
-    
+
     @Override
     @Transactional
     public UserSubscriptionModel update(UserSubscriptionModel subscription) {
         UserSubscriptionEntity entity = jpaRepository.findByUserEmail(subscription.getUserEmail())
-            .orElseThrow(() -> new RuntimeException("Suscripción no encontrada para: " + subscription.getUserEmail()));
-        
+                .orElseThrow(
+                        () -> new RuntimeException("Suscripción no encontrada para: " + subscription.getUserEmail()));
+
         SubscriptionEntity subscriptionEntity = subscriptionJpaRepository.findByPlanCode(subscription.getPlanCode())
-            .orElseThrow(() -> new RuntimeException("Plan no encontrado: " + subscription.getPlanCode()));
-        
+                .orElseThrow(() -> new RuntimeException("Plan no encontrado: " + subscription.getPlanCode()));
+
         entity.setSubscription(subscriptionEntity);
         entity.setCombinationsUsed(subscription.getCombinationsUsed());
         entity.setFavoritesCount(subscription.getFavoritesCount());
@@ -80,32 +81,43 @@ public UserSubscriptionModel update(UserSubscriptionModel subscription) {
         entity.setSubscriptionStart(subscription.getSubscriptionStart());
         entity.setSubscriptionEnd(subscription.getSubscriptionEnd());
         entity.setStatus(subscription.getStatus());
-        
+
         UserSubscriptionEntity updated = jpaRepository.save(entity);
         return UserSubscriptionEntity.convertToModel(updated);
     }
-    
+
     @Override
     @Transactional
     public void incrementCounter(String userEmail, String counterType) {
-        switch(counterType) {
+        // Obtener el user_id desde el email
+        UserEntity user = userJpaRepository.findByEmail(userEmail);
+        if (user == null) {
+            throw new RuntimeException("Usuario no encontrado: " + userEmail);
+        }
+
+        switch (counterType) {
             case "combinations":
-                jpaRepository.incrementCombinations(userEmail);
+                jpaRepository.incrementCombinationsByUserId(user.getId());
                 break;
             case "favorites":
-                jpaRepository.incrementFavorites(userEmail);
+                jpaRepository.incrementFavoritesByUserId(user.getId());
                 break;
             case "3d_models":
-                jpaRepository.incrementModels(userEmail);
+                jpaRepository.incrementModelsByUserId(user.getId());
                 break;
         }
     }
-    
+
     @Override
     @Transactional
     public void decrementCounter(String userEmail, String counterType) {
         if ("favorites".equals(counterType)) {
-            jpaRepository.decrementFavorites(userEmail);
+            // Obtener el user_id desde el email
+            UserEntity user = userJpaRepository.findByEmail(userEmail);
+            if (user == null) {
+                throw new RuntimeException("Usuario no encontrado: " + userEmail);
+            }
+            jpaRepository.decrementFavoritesByUserId(user.getId());
         }
     }
 }

src/main/java/com/outfitlab/project/infrastructure/repositories/interfaces/UserSubscriptionJpaRepository.java

@@ -9,23 +9,23 @@
 import java.util.Optional;
 
 public interface UserSubscriptionJpaRepository extends JpaRepository<UserSubscriptionEntity, Long> {
-    
+
     @Query("SELECT us FROM UserSubscriptionEntity us JOIN FETCH us.user u JOIN FETCH us.subscription WHERE u.email = :email")
     Optional<UserSubscriptionEntity> findByUserEmail(@Param("email") String email);
-    
+
     @Modifying
-    @Query("UPDATE UserSubscriptionEntity u SET u.combinationsUsed = u.combinationsUsed + 1 WHERE u.user.email = :email")
-    void incrementCombinations(@Param("email") String email);
-    
+    @Query("UPDATE UserSubscriptionEntity u SET u.combinationsUsed = u.combinationsUsed + 1 WHERE u.user.id = :userId")
+    void incrementCombinationsByUserId(@Param("userId") Long userId);
+
     @Modifying
-    @Query("UPDATE UserSubscriptionEntity u SET u.favoritesCount = u.favoritesCount + 1 WHERE u.user.email = :email")
-    void incrementFavorites(@Param("email") String email);
-    
+    @Query("UPDATE UserSubscriptionEntity u SET u.favoritesCount = u.favoritesCount + 1 WHERE u.user.id = :userId")
+    void incrementFavoritesByUserId(@Param("userId") Long userId);
+
     @Modifying
-    @Query("UPDATE UserSubscriptionEntity u SET u.favoritesCount = u.favoritesCount - 1 WHERE u.user.email = :email AND u.favoritesCount > 0")
-    void decrementFavorites(@Param("email") String email);
-    
+    @Query("UPDATE UserSubscriptionEntity u SET u.favoritesCount = u.favoritesCount - 1 WHERE u.user.id = :userId AND u.favoritesCount > 0")
+    void decrementFavoritesByUserId(@Param("userId") Long userId);
+
     @Modifying
-    @Query("UPDATE UserSubscriptionEntity u SET u.modelsGenerated = u.modelsGenerated + 1 WHERE u.user.email = :email")
-    void incrementModels(@Param("email") String email);
+    @Query("UPDATE UserSubscriptionEntity u SET u.modelsGenerated = u.modelsGenerated + 1 WHERE u.user.id = :userId")
+    void incrementModelsByUserId(@Param("userId") Long userId);
 }