WebSVN – SmartDukaan – Diff – /trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/scheme/SchemeServiceImpl.java

 import com.spice.profitmandi.dao.entity.catalog.SchemeRegion;
 import com.spice.profitmandi.dao.entity.catalog.SchemesImeisModel;
 import com.spice.profitmandi.dao.entity.fofo.*;
 import com.spice.profitmandi.dao.entity.inventory.PartnerAgeingModel;
 import com.spice.profitmandi.dao.entity.transaction.PriceDrop;
+import com.spice.profitmandi.dao.entity.transaction.UserWallet;
 import com.spice.profitmandi.dao.entity.transaction.UserWalletHistory;
 import com.spice.profitmandi.dao.enumuration.catalog.AmountType;
 import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;
 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
 import com.spice.profitmandi.dao.enumuration.transaction.SchemePayoutStatus;
 import com.spice.profitmandi.dao.repository.catalog.*;
 import com.spice.profitmandi.dao.repository.dtr.RetailerRepository;
 import com.spice.profitmandi.dao.repository.fofo.*;
 import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;
 import com.spice.profitmandi.dao.repository.transaction.UserWalletHistoryRepository;
+import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
 import com.spice.profitmandi.service.NotificationService;
 import com.spice.profitmandi.service.authentication.RoleManager;
 import com.spice.profitmandi.service.inventory.AgeingService;
 import com.spice.profitmandi.service.inventory.PurchaseService;
 import com.spice.profitmandi.service.pricecircular.CatalogSummaryModel;
+            }
+        }
+    }
     @Autowired
+    UserWalletRepository userWalletRepository;
+    @Autowired
     UserWalletHistoryRepository userWalletHistoryRepository;
     @Override
     // Always being called from cancel order/bad return means no SCHEME IN is considered
     public void reverseSchemes(List<InventoryItem> inventoryItems, int reversalReference, String reversalReason,
         LOGGER.info("inventoryItems" + inventoryItems);
         Map<SchemeType, SchemeInOut> schemeTypeMap = new HashMap<>();
         List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectByInventoryItemIds(inventoryItemsMap.keySet());
-        LOGGER.info("schemeInOuts" + schemeInOuts);
+        List<SchemeInOut> rolledBacks = schemeInOuts.stream().filter(x -> x.getStatusDescription().equals(reversalReason)).collect(Collectors.toList());
         float amountToRollback = 0;
         if (!schemeInOuts.isEmpty()) {
             List<Integer> schemeIds = schemeInOuts.stream().map(x -> x.getSchemeId()).collect(Collectors.toList());
             LOGGER.info("schemeIds" + schemeIds);
             Map<Integer, Scheme> schemesMap = schemeRepository.selectBySchemeIds(schemeIds, 0, schemeIds.size())
                     .stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
+            if (rolledBacks.size() > 0) {
-            for (SchemeInOut schemeInOut : schemeInOuts) {
+                for (SchemeInOut schemeInOut : rolledBacks) {
-                Scheme scheme = schemesMap.get(schemeInOut.getSchemeId());
+                    Scheme scheme = schemesMap.get(schemeInOut.getSchemeId());
-                if (schemeTypes.contains(scheme.getType())) {
+                    if (schemeTypes.contains(scheme.getType())) {
-                    schemeTypeMap.put(scheme.getType(), schemeInOut);
+                        schemeTypeMap.put(scheme.getType(), schemeInOut);
-                    if (schemeInOut.getRolledBackTimestamp() == null) {
+                        if (schemeInOut.getCreditTimestamp() != null) {
-                        schemeInOut.setRolledBackTimestamp(LocalDateTime.now());
-                        if (schemeInOut.getCreditTimestamp() != null || schemeInOut.getStatus().equals(SchemePayoutStatus.CREDITED)) {
                             amountToRollback += schemeInOut.getAmount();
+                        }
+                    }
+                }
+            } else {
+                for (SchemeInOut schemeInOut : schemeInOuts) {
+                    Scheme scheme = schemesMap.get(schemeInOut.getSchemeId());
+                    if (schemeTypes.contains(scheme.getType())) {
+                        if (schemeInOut.getRolledBackTimestamp() == null) {
+                            schemeInOut.setRolledBackTimestamp(LocalDateTime.now());
+                            if (schemeInOut.getStatus().equals(SchemePayoutStatus.CREDITED)) {
+                                amountToRollback += schemeInOut.getAmount();
+                            }
-                        schemeInOut.setStatus(SchemePayoutStatus.REJECTED);
+                            schemeInOut.setStatus(SchemePayoutStatus.REJECTED);
-                        schemeInOut.setStatusDescription(reversalReason);
+                            schemeInOut.setStatusDescription(reversalReason);
+                        }
+                    }
+                }
+            }
+        }
         int fofoId = inventoryItems.get(0).getFofoId();
         WalletReferenceType walletReferenceType = schemeTypes.containsAll(SchemeService.OUT_SCHEME_TYPES) ? WalletReferenceType.SCHEME_OUT
                 : schemeTypes.contains(SchemeType.ACTIVATION) ? WalletReferenceType.ACTIVATION_SCHEME
                 : schemeTypes.contains(SchemeType.SPECIAL_SUPPORT) ? WalletReferenceType.SPECIAL_SUPPORT
-                : schemeTypes.contains(SchemeType.INVESTMENT) ? WalletReferenceType.INVESTMENT_PAYOUT : null;
+                : schemeTypes.contains(SchemeType.INVESTMENT) ? WalletReferenceType.SCHEME_OUT : null;
+        List<UserWalletHistory> userWalletHistoryList = null;
         if (amountToRollback > 0 && walletReferenceType != null) {
             // Mark appropriate reference of rollback investment margin
-            if (schemeTypes.contains(SchemeType.INVESTMENT)) {
+            if (schemeTypes.contains(SchemeType.INVESTMENT) && schemeTypeMap.containsKey(SchemeType.INVESTMENT)) {
+                LocalDateTime creditTime = schemeTypeMap.get(SchemeType.INVESTMENT).getCreditTimestamp();
+                if (creditTime == null) return;
+                int investmentReversalReference = Integer.parseInt(FormattingUtils.getYearMonth(creditTime.minusMonths(1)));
+                UserWallet userWallet = userWalletRepository.selectByRetailerId(fofoId);
+                userWalletHistoryList = userWalletHistoryRepository.selectAllByreferenceIdandreferenceType(userWallet.getUserId(), investmentReversalReference, WalletReferenceType.INVESTMENT_PAYOUT);
+                if (userWalletHistoryList.size() > 0) {
+                    walletReferenceType = WalletReferenceType.INVESTMENT_PAYOUT;
+                } else {
+                    userWalletHistoryList = null;
+                }
+            }
+            if (userWalletHistoryList == null) {
-                List<UserWalletHistory> userWalletHistoryList = userWalletHistoryRepository.selectAllByreferenceIdandreferenceType(reversalReference, walletReferenceType);
+                userWalletHistoryList = userWalletHistoryRepository.selectAllByreferenceIdandreferenceType(reversalReference, walletReferenceType);
+            }
-                if (userWalletHistoryList.size() == 0) {
+            if (userWalletHistoryList.size() > 0) {
+                int maxDeductible = userWalletHistoryList.stream().collect(Collectors.summingInt(x -> x.getAmount()));
-                    reversalReference = Integer
+                if (maxDeductible > 0) {
+                    LOGGER.info("----------> maxDeductible {}, amountToRollback {}, reversalReference {}, walletReferenceType {} ",maxDeductible, amountToRollback, reversalReference, walletReferenceType);
-                            .parseInt(FormattingUtils.getYearMonth(schemeTypeMap.get(SchemeType.INVESTMENT).getCreditTimestamp().minusMonths(1)));
+                    walletService.rollbackAmountFromWallet(fofoId, Math.min(maxDeductible, amountToRollback), reversalReference, walletReferenceType,
+                            reversalReason, LocalDateTime.now());
+                }
+            }
-            walletService.rollbackAmountFromWallet(fofoId, amountToRollback, reversalReference, walletReferenceType,
-                    reversalReason, LocalDateTime.now());
+        }
+    }
     @Override
     public double getTotalMargin(int itemId, PartnerType partnerType, LocalDateTime dateTime) {
         Session session = sessionFactory.getCurrentSession();
         CriteriaBuilder cb = session.getCriteriaBuilder();
         CriteriaQuery<Double> criteriaQuery = cb.createQuery(Double.class);

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/scheme/SchemeServiceImpl.java – Rev 32059 → 32060