Subversion Repositories SmartDukaan

    public void rejectActivatedSchemeIds(List<Integer> schemeIds) throws ProfitMandiBusinessException {

        List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectBySchemeIds(new HashSet<>(schemeIds));

        // Filter to CREDITED records that haven't been rolled back

        List<SchemeInOut> creditedPayouts = schemeInOuts.stream()

                .filter(x -> SchemePayoutStatus.CREDITED.equals(x.getStatus()) && x.getRolledBackTimestamp() == null)

                .collect(Collectors.toList());

        if (creditedPayouts.isEmpty()) return;

        Map<Integer, Scheme> schemesMap = schemeRepository.selectBySchemeIds(schemeIds).stream()

                .filter(x -> SchemeType.SPECIAL_SUPPORT.equals(x.getType()))

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

        creditedPayouts = creditedPayouts.stream().filter(x -> schemesMap.containsKey(x.getSchemeId()))

                .collect(Collectors.toList());

        if (creditedPayouts.isEmpty()) return;

        Set<Integer> inventoryIds = creditedPayouts.stream().map(SchemeInOut::getInventoryItemId).collect(Collectors.toSet());

        Map<Integer, InventoryItem> inventoryItemMap = inventoryItemRepository.selectByIds(inventoryIds).stream()

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

        List<String> serialNumbers = inventoryItemMap.values().stream().map(InventoryItem::getSerialNumber).collect(Collectors.toList());

        Map<String, ActivatedImei> activatedImeiMap = activatedImeiRepository.selectBySerialNumbers(serialNumbers).stream()

                .collect(Collectors.toMap(x -> x.getSerialNumber().toLowerCase(), x -> x, (a, b) -> a));

        for (SchemeInOut payout : creditedPayouts) {

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

            InventoryItem ii = inventoryItemMap.get(payout.getInventoryItemId());

            if (ii == null) continue;

            ActivatedImei activatedImei = activatedImeiMap.get(ii.getSerialNumber().toLowerCase());

            if (activatedImei == null || activatedImei.getActivationTimestamp() == null) continue;

            if (!scheme.isWithinRange(activatedImei.getActivationTimestamp())) {

                payout.setStatus(SchemePayoutStatus.REJECTED);

                payout.setRolledBackTimestamp(LocalDateTime.now());

                payout.setStatusDescription("Rejected, activation on " + FormattingUtils.formatDate(activatedImei.getActivationTimestamp()) + " outside scheme period");

                List<ScanRecord> scanRecords = scanRecordRepository.selectByInventoryItemId(ii.getId());

                int orderId = scanRecords.stream()

                        .filter(x -> x.getOrderId() > 0)

                        .sorted(Comparator.comparing(ScanRecord::getCreateTimestamp).reversed()).findFirst()

                        .map(ScanRecord::getOrderId).orElse(0);

                if (orderId > 0) {

                    walletService.rollbackAmountFromWallet(ii.getFofoId(), payout.getAmount(), orderId,

                            WalletReferenceType.SPECIAL_SUPPORT,

                            "Rejected, activation on " + FormattingUtils.formatDate(activatedImei.getActivationTimestamp()) + " outside scheme period",

                            LocalDateTime.now());

                }

            }

        }

    }

    @Override