Subversion Repositories SmartDukaan

    @Override

    public void restoreAdditionalSelloutSchemes(List<InventoryItem> inventoryItems, String restoreReason)

            throws ProfitMandiBusinessException {

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

                .collect(Collectors.groupingBy(InventoryItem::getFofoId));

        for (Map.Entry<Integer, List<InventoryItem>> entry : fofoInventoryItemsMap.entrySet()) {

            int fofoId = entry.getKey();

            List<InventoryItem> partnerItems = entry.getValue();

            List<InventoryItem> serializedItems = partnerItems.stream()

                    .filter(x -> x.getSerialNumber() != null)

                    .collect(Collectors.toList());

            if (!serializedItems.isEmpty()) {

                Set<String> serialNumbers = serializedItems.stream()

                        .map(InventoryItem::getSerialNumber).collect(Collectors.toSet());

                List<OfferPayout> offerPayouts = offerPayoutRepository

                        .selectAllBySerialNumbers(fofoId, serialNumbers).stream()

                        .filter(x -> x.getRejectTimestamp() != null

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

                        .collect(Collectors.toList());

                for (OfferPayout offerPayout : offerPayouts) {

                    offerPayout.setStatus(SchemePayoutStatus.CREDITED);

                    offerPayout.setRejectTimestamp(null);

                }

                Map<Long, Double> offerPayoutAmountMap = offerPayouts.stream()

                        .collect(Collectors.groupingBy(OfferPayout::getOfferId,

                                Collectors.summingDouble(OfferPayout::getAmount)));

                for (Map.Entry<Long, Double> offerEntry : offerPayoutAmountMap.entrySet()) {

                    if (offerEntry.getValue() > 0) {

                        walletService.addAmountToWallet(fofoId, offerEntry.getKey().intValue(),

                                WalletReferenceType.ADDITIONAL_SCHEME, restoreReason,

                                offerEntry.getValue().floatValue(), LocalDateTime.now());

                    }

                }

            }

        }

    }