Subversion Repositories SmartDukaan

    public void fixSchemePayouts() throws Exception {

        LOGGER.info("In fix scheme Payouts");

        LocalDateTime startDate = LocalDate.of(2019, 9, 1).atStartOfDay();

        List<SchemeInOut> sios = schemeInOutRepository.selectAllByCreateDate(startDate, LocalDateTime.now());

        for (SchemeInOut sio : sios) {

            if (sio.getSchemeId() != 347) {

                LOGGER.info("Skipping {}", sio.getSchemeId());

                continue;

            }

            genericRepository.delete(sio);

            InventoryItem ii = inventoryItemRepository.selectById(sio.getInventoryItemId());

            UserWallet userWallet = userWalletRepository.selectByRetailerId(ii.getFofoId());

            Scheme scheme = schemeRepository.selectById(sio.getSchemeId());

            if (scheme.getType().equals(SchemeType.IN)) {

                List<UserWalletHistory> historyList = userWalletHistoryRepository

                        .selectAllByreferenceIdandreferenceType(ii.getPurchaseId(), WalletReferenceType.SCHEME_IN);

                for (UserWalletHistory uwh : historyList) {

                    if (uwh.getTimestamp().isAfter(startDate)) {

                        genericRepository.delete(uwh);

                        userWallet.setAmount(userWallet.getAmount() - uwh.getAmount());

                    }

                }

            } else {

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

                int orderId = scanRecords.get(0).getOrderId();

                List<UserWalletHistory> historyList = userWalletHistoryRepository

                        .selectAllByreferenceIdandreferenceType(orderId, WalletReferenceType.SCHEME_OUT);

                for (UserWalletHistory uwh : historyList) {

                    if (uwh.getTimestamp().isAfter(startDate)) {

                        userWallet.setAmount(userWallet.getAmount() - uwh.getAmount());

                        genericRepository.delete(uwh);

                    }

                }

                List<UserWalletHistory> historyListBroken = userWalletHistoryRepository

                        .selectAllByreferenceIdandreferenceType(ii.getPurchaseId(), WalletReferenceType.SCHEME_OUT);

                for (UserWalletHistory uwh : historyListBroken) {

                    if (uwh.getTimestamp().isAfter(startDate)) {

                        genericRepository.delete(uwh);

                        userWallet.setAmount(userWallet.getAmount() - uwh.getAmount());

                    }

                }

            }

            // System.out.println("Total Amount Rolled Back is " + totalRollbackAmount);

        }

        scheduledTasks.processScheme(startDate, startDate.plusDays(10), true);

    }