Subversion Repositories SmartDukaan

    public void restoreSchemes(List<Integer> inventoryItemIds, String debitNoteNumber) throws Exception {

        String rollbackDescription = "Schemes rolled back for DebitNote #" + debitNoteNumber;

        List<InventoryItem> inventoryItems = inventoryItemRepository.selectAllByIds(inventoryItemIds);

        Map<Integer, InventoryItem> inventoryItemMap = inventoryItems.stream()

                .collect(Collectors.toMap(InventoryItem::getId, x -> x));

        Map<Integer, Integer> purchasePartnerMap = inventoryItems.stream()

                .collect(Collectors.toMap(InventoryItem::getPurchaseId, InventoryItem::getFofoId, (u, v) -> u));

        List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(inventoryItemIds));

        List<Integer> schemeIds = schemeInOuts.stream().map(SchemeInOut::getSchemeId).distinct()

                .collect(Collectors.toList());

        if (schemeIds.isEmpty()) return;

        List<Scheme> schemes = schemeRepository.selectBySchemeIds(schemeIds);

        Map<Integer, Scheme> schemesMap = schemes.stream().collect(Collectors.toMap(Scheme::getId, x -> x));

        Map<Integer, Float> inSchemesRestoreMap = new HashMap<>();

        for (SchemeInOut schemeInOut : schemeInOuts) {

            if (schemeInOut.getStatus() != null

                    && schemeInOut.getStatus().equals(SchemePayoutStatus.REJECTED)

                    && rollbackDescription.equals(schemeInOut.getStatusDescription())) {

                Scheme scheme = schemesMap.get(schemeInOut.getSchemeId());

                if (scheme != null && scheme.getType().getTransactionType().equals(StockTransactionType.IN)) {

                    int inventoryItemId = schemeInOut.getInventoryItemId();

                    inSchemesRestoreMap.merge(inventoryItemId, schemeInOut.getAmount(), Float::sum);

                }

                schemeInOut.setStatus(SchemePayoutStatus.CREDITED);

                schemeInOut.setStatusDescription("Restored: DN rejection reversal #" + debitNoteNumber);

                schemeInOut.setRolledBackTimestamp(null);

            }

        }

        Map<Integer, Double> purchaseRestoreAmountMap = inSchemesRestoreMap.entrySet().stream()

                .collect(Collectors.groupingBy(

                        x -> inventoryItemMap.get(x.getKey()).getPurchaseId(),

                        Collectors.summingDouble(Map.Entry::getValue)));

        String restoreReason = "Scheme restored: DN rejection reversal #" + debitNoteNumber;

        for (Map.Entry<Integer, Double> entry : purchaseRestoreAmountMap.entrySet()) {

            int purchaseId = entry.getKey();

            Double amountToRestore = entry.getValue();

            if (amountToRestore != null && amountToRestore > 0) {

                walletService.addAmountToWallet(purchasePartnerMap.get(purchaseId), purchaseId,

                        WalletReferenceType.SCHEME_IN, restoreReason,

                        amountToRestore.floatValue(), LocalDateTime.now());

            }

        }

    }

    @Override