feat : using blaze multiselect views

src/main/java/com/learning/mfscreener/repository/CustomUserCASDetailsEntityRepository.java

@@ -0,0 +1,8 @@
+package com.learning.mfscreener.repository;
+
+import com.learning.mfscreener.models.entityviews.UserCASDetailsEntityView;
+
+public interface CustomUserCASDetailsEntityRepository {
+
+    UserCASDetailsEntityView findByInvestorEmailAndName(String email, String name);
+}

src/main/java/com/learning/mfscreener/repository/CustomUserCASDetailsEntityRepositoryImpl.java

@@ -0,0 +1,39 @@
+package com.learning.mfscreener.repository;
+
+import com.blazebit.persistence.CriteriaBuilderFactory;
+import com.blazebit.persistence.view.EntityViewManager;
+import com.blazebit.persistence.view.EntityViewSetting;
+import com.learning.mfscreener.entities.UserCASDetailsEntity;
+import com.learning.mfscreener.models.entityviews.UserCASDetailsEntityView;
+import jakarta.persistence.EntityManager;
+
+public class CustomUserCASDetailsEntityRepositoryImpl implements CustomUserCASDetailsEntityRepository {
+
+    private final EntityManager entityManager;
+
+    private final CriteriaBuilderFactory criteriaBuilderFactory;
+
+    private final EntityViewManager entityViewManager;
+
+    public CustomUserCASDetailsEntityRepositoryImpl(
+            EntityManager entityManager,
+            CriteriaBuilderFactory criteriaBuilderFactory,
+            EntityViewManager entityViewManager) {
+        this.entityManager = entityManager;
+        this.criteriaBuilderFactory = criteriaBuilderFactory;
+        this.entityViewManager = entityViewManager;
+    }
+
+    @Override
+    public UserCASDetailsEntityView findByInvestorEmailAndName(String email, String name) {
+        return entityViewManager
+                .applySetting(
+                        EntityViewSetting.create(UserCASDetailsEntityView.class),
+                        criteriaBuilderFactory.create(entityManager, UserCASDetailsEntity.class))
+                .where("investorInfoEntity.email")
+                .eq(email)
+                .where("investorInfoEntity.name")
+                .eq(name) // Adding condition for the name
+                .getSingleResult();
+    }
+}

src/main/java/com/learning/mfscreener/repository/UserCASDetailsEntityRepository.java

@@ -11,7 +11,8 @@
 import org.springframework.transaction.annotation.Transactional;
 
 @Repository
-public interface UserCASDetailsEntityRepository extends JpaRepository<UserCASDetailsEntity, Long> {
+public interface UserCASDetailsEntityRepository
+        extends JpaRepository<UserCASDetailsEntity, Long>, CustomUserCASDetailsEntityRepository {
 
     @Transactional(readOnly = true)
     @Query(
@@ -55,11 +56,4 @@ utd.type NOT IN ('STAMP_DUTY_TAX', 'STT_TAX')
                     """)
     List<PortfolioDetailsProjection> getPortfolioDetails(
             @Param("pan") String panNumber, @Param("asOfDate") LocalDate asOfDate);
-
-    @Query(
-            """
-              select u from UserCASDetailsEntity u join fetch u.folioEntities join fetch u.investorInfoEntity as i
-              where i.email = :email and i.name = :name
-              """)
-    UserCASDetailsEntity findByInvestorEmailAndName(@Param("email") String email, @Param("name") String name);
 }

src/main/java/com/learning/mfscreener/service/PortfolioService.java

@@ -11,6 +11,8 @@
 import com.learning.mfscreener.mapper.CasDetailsMapper;
 import com.learning.mfscreener.models.MFSchemeDTO;
 import com.learning.mfscreener.models.PortfolioDetailsDTO;
+import com.learning.mfscreener.models.entityviews.UserCASDetailsEntityView;
+import com.learning.mfscreener.models.entityviews.UserFolioDetailsEntityView;
 import com.learning.mfscreener.models.portfolio.CasDTO;
 import com.learning.mfscreener.models.portfolio.UserFolioDTO;
 import com.learning.mfscreener.models.portfolio.UserSchemeDTO;
@@ -93,7 +95,8 @@ UploadResponseHolder findDelta(String email, String name, CasDTO casDTO) {
         List<UserTransactionDetailsEntity> userTransactionDetailsEntityList =
                 this.userTransactionDetailsEntityRepository.findAllTransactionsByEmailAndName(email, name);
 
-        UserCASDetailsEntity userCASDetailsEntity = casDetailsEntityRepository.findByInvestorEmailAndName(email, name);
+        UserCASDetailsEntityView userCASDetailsEntityView =
+                casDetailsEntityRepository.findByInvestorEmailAndName(email, name);
 
         if (userTransactionDTOListCount == userTransactionDetailsEntityList.size()) {
             log.info("No new transactions are added");
@@ -104,16 +107,16 @@ UploadResponseHolder findDelta(String email, String name, CasDTO casDTO) {
         AtomicInteger transactionsCounter = new AtomicInteger();
 
         // Verify if new folios are added
-        List<String> existingFolios = userCASDetailsEntity.getFolioEntities().stream()
-                .map(UserFolioDetailsEntity::getFolio)
+        List<String> existingFolios = userCASDetailsEntityView.getFolioEntities().stream()
+                .map(UserFolioDetailsEntityView::getFolio)
                 .toList();
 
         folioDTOList.forEach(userFolioDTO -> {
             String folio = userFolioDTO.folio();
             if (!existingFolios.contains(folio)) {
                 log.info("New folio: {} created that is not present in the database", folio);
-                userCASDetailsEntity.addFolioEntity(
-                        casDetailsMapper.mapUserFolioDTOToUserFolioDetailsEntity(userFolioDTO));
+                // userCASDetailsEntityView.addFolioEntity(
+                //         casDetailsMapper.mapUserFolioDTOToUserFolioDetailsEntity(userFolioDTO));
                 folioCounter.incrementAndGet();
                 int newTransactions = userFolioDTO.schemes().stream()
                         .map(UserSchemeDTO::transactions)
@@ -176,7 +179,8 @@ UploadResponseHolder findDelta(String email, String name, CasDTO casDTO) {
                     });
                 }
             });
-            userCASDetailsEntity.setFolioEntities(existingUserFolioDetailsEntityList);
+            // TODO
+            //     userCASDetailsEntityView.setFolioEntities(existingUserFolioDetailsEntityList);
 
             // Check if all new transactions are added as part of adding schemes
             if (userTransactionDTOListCount == (userTransactionDetailsEntityList.size() + transactionsCounter.get())) {
@@ -236,7 +240,7 @@ UploadResponseHolder findDelta(String email, String name, CasDTO casDTO) {
                 });
             }
         }
-        return new UploadResponseHolder(userCASDetailsEntity, folioCounter.get(), transactionsCounter.get());
+        return new UploadResponseHolder(null, folioCounter.get(), transactionsCounter.get());
     }
 
     public PortfolioResponse getPortfolioByPAN(String panNumber, LocalDate asOfDate) {