Subversion Repositories SmartDukaan

import org.hibernate.Session;

import org.hibernate.query.NativeQuery;

    public void evaluateExcessSchemeOut() throws Exception {

        Map<Integer, String> userNameMap = retailerService.getAllFofoRetailerIdNameMap();

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

        List<List<?>> rows = new ArrayList<>();

        List<String> headers = Arrays.asList("Scheme", "Item", "Partner", "Amount", "Credited On", "Invoice Number", "Sale On", "Scheme Start", "Scheme End", "Active On", "Expired On");

        for (Scheme scheme : schemeRepository.selectAll()) {

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

                List<SchemeInOut> sioList = schemeInOutRepository.selectBySchemeIds(new HashSet<>(Arrays.asList(scheme.getId())));

                if (scheme.getActiveTimestamp() != null) {

                    LocalDateTime endDateTime = scheme.getEndDateTime();

                    if (scheme.getExpireTimestamp() != null && scheme.getExpireTimestamp().isBefore(scheme.getEndDateTime())) {

                        endDateTime = scheme.getExpireTimestamp();

                    }

                    for (SchemeInOut sio : sioList) {

                        InventoryItem inventoryItem = null;

                        inventoryItem = inventoryItemRepository.selectById(sio.getInventoryItemId());

                        FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndSerialNumber(

                                inventoryItem.getFofoId(), inventoryItem.getSerialNumber(), null, null, 0, 1).get(0);

                        Optional<ScanRecord> record = scanRecordRepository.selectByInventoryItemId(sio.getInventoryItemId()).stream().filter(y -> y.getType().equals(ScanType.SALE)).findFirst();

                        if (record.isPresent()) {

                            int fofoId = record.get().getFofoId();

                            if (record.get().getCreateTimestamp().isAfter(endDateTime) || record.get().getCreateTimestamp().isBefore(scheme.getStartDateTime())) {

                                if (!userAmountMap.containsKey(fofoId)) {

                                    userAmountMap.put(fofoId, 0f);

                                }

                                userAmountMap.put(fofoId, sio.getAmount() + userAmountMap.get(fofoId));

                                try {

                                    rows.add(Arrays.asList(scheme.getDescription(), itemRepository.selectById(inventoryItem.getItemId()).getItemDescription(), userNameMap.get(fofoId), sio.getAmount(), FormattingUtils.formatDate(sio.getCreateTimestamp()), fofoOrder.getInvoiceNumber(), FormattingUtils.formatDate(record.get().getCreateTimestamp()), FormattingUtils.formatDate(scheme.getStartDateTime()), FormattingUtils.formatDate(scheme.getEndDateTime()), FormattingUtils.formatDate(scheme.getActiveTimestamp()), FormattingUtils.formatDate(scheme.getExpireTimestamp())));

                                } catch (Exception e) {

                                    e.printStackTrace();

                                }

                            }

                        }

                    }

                }

            }

        }

        userAmountMap.entrySet().stream().forEach(x -> LOGGER.info("{} to be deducted from {}({}) for wrongly disbursed due to technical error.", x.getValue(), userNameMap.get(x.getKey())));

        ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);

        Utils.sendMailWithAttachment(googleMailSender, new String[]{"amit.gupta@shop2020.in"}, null, "Partner Excess Amount", "PFA", "ListofSchemes.csv", new ByteArrayResource(baos.toByteArray()));

    }

    private void checkAllPayoutsDuplicate() throws Exception {

        final Session session = sessionFactory.getCurrentSession();

        final NativeQuery<Object[]> nativeQuery = session.createNativeQuery("select sio.inventory_item_id, sio.scheme_id, sio.status, count(*) c\n" + "from fofo.scheme_in_out sio\n" + "         join catalog.scheme s on s.id = sio.scheme_id\n" + "where (sio.status = 'CREDITED'\n" + "    or sio.status = 'PENDING')\n" + "  and s.type != 'INVESTMENT'\n" + " and sio.create_timestamp >= '2023-01-01' " + "group by sio.inventory_item_id, sio.scheme_id, sio.status\n" + "having c > 1");

        List<Object[]> resultList = nativeQuery.getResultList();

        for (Object[] tuple : resultList) {

            LOGGER.info("RESULT -- {}, {}, {}", tuple[0], tuple[1], tuple[2]);

            int inventoryItemId = (Integer) tuple[0];

            int schemeId = (Integer) tuple[1];

            SchemePayoutStatus schemePayoutStatus = SchemePayoutStatus.valueOf((String) tuple[2]);

            List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectByScheme(schemeId, inventoryItemId);

            List<SchemeInOut> statusSpecificSchemeInOuts = schemeInOuts.stream().filter(x -> x.getStatus().equals(schemePayoutStatus)).collect(Collectors.toList());

            if (statusSpecificSchemeInOuts.size() > 0) {

                InventoryItem inventoryItem = inventoryItemRepository.selectById(inventoryItemId);

                Scheme scheme = schemeRepository.selectById(schemeId);

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

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

                    LOGGER.info("Skipping -- {}", inventoryItem.getSerialNumber());

                } else {

                    int fofoOrderId = scanRecords.stream().filter(x -> x.getOrderId() != 0).max(Comparator.comparing(x -> x.getOrderId())).get().getOrderId();

                    WalletReferenceType walletReferenceType = SchemeType.ACTIVATION.equals(scheme.getType()) ? WalletReferenceType.ACTIVATION_SCHEME : SchemeType.SPECIAL_SUPPORT.equals(scheme.getType()) ? WalletReferenceType.SPECIAL_SUPPORT : WalletReferenceType.SCHEME_OUT;

                    List<UserWalletHistory> userWalletHistoryList = userWalletHistoryRepository.selectAllByreferenceIdandreferenceType(fofoOrderId, walletReferenceType).stream().filter(x -> x.getAmount() == Math.round(statusSpecificSchemeInOuts.get(0).getAmount())).collect(Collectors.toList());

                    LOGGER.info("UserwalletHistory Entry --> {}, Sios --> {}", userWalletHistoryList.size(), statusSpecificSchemeInOuts.size());

                    if (userWalletHistoryList.size() != statusSpecificSchemeInOuts.size()) {

                        //Skipping them in first run as it is the special casw of upgrade where mismatch has happend.

                        LOGGER.info("problem with {}, sio status - {}, inventoryItem id {}, schemeID {} ", fofoOrderId, statusSpecificSchemeInOuts.stream().map(x -> x.getStatus()).collect(Collectors.toList()), inventoryItemId, schemeId);

                        //Primarily multiple pending cases

                        statusSpecificSchemeInOuts.stream().skip(1).forEach(schemeInOut -> {

                            schemeInOut.setStatus(SchemePayoutStatus.REJECTED);

                            schemeInOut.setStatusDescription("Rejected as entry is duplicate");

                        });

                    } else {

                        userWalletHistoryList.stream().skip(1).forEach(userWalletHistory -> {

                            try {

                                walletService.rollbackAmountFromWallet(inventoryItem.getFofoId(), userWalletHistory.getAmount(), userWalletHistory.getReference(), userWalletHistory.getReferenceType(), "Reversal as multiple entries created", userWalletHistory.getBusinessTimestamp());

                            } catch (ProfitMandiBusinessException e) {

                                throw new RuntimeException(e);

                            }

                        });

                        statusSpecificSchemeInOuts.stream().skip(1).forEach(schemeInOut -> {

                            schemeInOut.setStatus(SchemePayoutStatus.REJECTED);

                            if (schemePayoutStatus.equals(SchemePayoutStatus.CREDITED)) {

                                schemeInOut.setRolledBackTimestamp(LocalDateTime.now());

                                schemeInOut.setStatusDescription("Rolled back as entry is duplicate");

                            } else {

                                LOGGER.info("This seems higly unreachable should not come here");

                                schemeInOut.setStatusDescription("Rejected as entry is duplicate");

                            }

                        });

                    }

                }

            }

        }

    }

    public void dryRunSchemeReco() throws Exception {

        Map<Integer, Integer> userWalletMap = userWalletRepository.selectAll().stream().collect(Collectors.toMap(UserWallet::getUserId, UserWallet::getId));

        List<UserWalletHistory> userWalletHistory = new ArrayList<>();

        List<SchemeInOut> rolledbackSios = new ArrayList<>();

        Map<Integer, SchemeType> schemeTypeMap = schemeRepository.selectAll().stream().collect(Collectors.toMap(Scheme::getId, Scheme::getType));

        Set<String> serialNumbersConsidered = new HashSet<>();

        LocalDateTime startDate = LocalDate.of(2018, 3, 1).atStartOfDay();

        LocalDateTime endDate = LocalDate.now().atStartOfDay();

        List<Purchase> purchases = purchaseRepository.selectAllBetweenPurchaseDate(startDate, endDate);

        Map<Integer, String> storeNameMap = fofoStoreRepository.getStoresMap();

        for (Purchase purchase : purchases) {

            float amountToRollback = 0;

            String description = "Adjustment of Duplicate Scheme for Purchase Invoice " + purchase.getPurchaseReference();

            Map<Integer, String> inventorySerialNumberMap = inventoryItemRepository.selectByPurchaseId(purchase.getId()).stream().filter(ii -> ii.getSerialNumber() != null).collect(Collectors.toMap(InventoryItem::getId, InventoryItem::getSerialNumber));

            if (inventorySerialNumberMap.size() > 0) {

                for (Entry<Integer, String> inventorySerialNumberEntry : inventorySerialNumberMap.entrySet()) {

                    String serialNumber = inventorySerialNumberEntry.getValue();

                    int inventoryItemId = inventorySerialNumberEntry.getKey();

                    if (serialNumbersConsidered.contains(serialNumber)) {

                        // This will rollback scheme for differenct orders for same serial

                        List<SchemeInOut> sios = schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItemId))).stream().filter(x -> x.getRolledBackTimestamp() == null && schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.IN)).collect(Collectors.toList());

                        Collections.reverse(sios);

                        for (SchemeInOut sio : sios) {

                            sio.setRolledBackTimestamp(LocalDateTime.now());

                            amountToRollback += sio.getAmount();

                            // sio.setSchemeType(SchemeType.OUT);

                            sio.setSerialNumber(serialNumber);

                            rolledbackSios.add(sio);

                        }

                        description = description.concat(" " + serialNumber + " ");

                    } else {

                        serialNumbersConsidered.add(serialNumber);

                        List<Integer> schemesConsidered = new ArrayList<>();

                        List<SchemeInOut> sios = schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItemId))).stream().filter(x -> x.getRolledBackTimestamp() == null && schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.IN)).collect(Collectors.toList());

                        Collections.reverse(sios);

                        for (SchemeInOut sio : sios) {

                            if (!schemesConsidered.contains(sio.getSchemeId())) {

                                schemesConsidered.add(sio.getSchemeId());

                                continue;

                            }

                            sio.setRolledBackTimestamp(LocalDateTime.now());

                            amountToRollback += sio.getAmount();

                            // sio.setSchemeType(SchemeType.OUT);

                            sio.setSerialNumber(serialNumber);

                            sio.setStoreCode(storeNameMap.get(purchase.getFofoId()));

                            sio.setReference(purchase.getId());

                            rolledbackSios.add(sio);

                        }

                    }

                }

            }

            if (amountToRollback > 0) {

                // Address address =

                // addressRepository.selectAllByRetailerId(purchase.getFofoId(), 0, 10).get(0);

                UserWalletHistory uwh = new UserWalletHistory();

                uwh.setAmount(Math.round(amountToRollback));

                uwh.setDescription(description);

                uwh.setTimestamp(LocalDateTime.now());

                uwh.setReferenceType(WalletReferenceType.SCHEME_IN);

                uwh.setReference(purchase.getId());

                uwh.setWalletId(userWalletMap.get(purchase.getFofoId()));

                uwh.setFofoId(purchase.getFofoId());

                uwh.setStoreCode(storeNameMap.get(purchase.getFofoId()));

                userWalletHistory.add(uwh);

            }

        }

        ByteArrayOutputStream baos = FileUtil.getCSVByteStream(

                Arrays.asList("User Id", "Store Code", "Reference Type", "Reference", "Amount", "Description", "Timestamp"), userWalletHistory.stream().map(x -> Arrays.asList(x.getWalletId(), x.getStoreCode(), x.getReferenceType(), x.getReference(), x.getAmount(), x.getDescription(), x.getTimestamp())).collect(Collectors.toList()));

        ByteArrayOutputStream baosOuts = FileUtil.getCSVByteStream(

                Arrays.asList("Scheme ID", "SchemeType", "Reference", "Store Code", "Serial Number", "Amount", "Created", "Rolledback"), rolledbackSios.stream().map(x -> Arrays.asList(x.getSchemeId(), x.getSchemeType(), x.getReference(), x.getStoreCode(), x.getSerialNumber(), x.getAmount(), x.getCreateTimestamp(), x.getRolledBackTimestamp())).collect(Collectors.toList()));

        Utils.sendMailWithAttachments(googleMailSender, new String[]{"amit.gupta@shop2020.in"}, null, "Partner Excess Amount Scheme In", "PFA", new Attachment[]{new Attachment("WalletSummary.csv", new ByteArrayResource(baos.toByteArray())), new Attachment("SchemeInRolledback.csv", new ByteArrayResource(baosOuts.toByteArray()))});

        throw new Exception();

    }

    public void dryRunOutSchemeReco() throws Exception {

        List<UserWalletHistory> userWalletHistory = new ArrayList<>();

        List<SchemeInOut> rolledbackSios = new ArrayList<>();

        Map<Integer, Integer> userWalletMap = userWalletRepository.selectAll().stream().collect(Collectors.toMap(UserWallet::getUserId, UserWallet::getId));

        Map<Integer, SchemeType> schemeTypeMap = schemeRepository.selectAll().stream().collect(Collectors.toMap(Scheme::getId, Scheme::getType));

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

        LocalDateTime endDate = LocalDate.now().atStartOfDay();

        List<FofoOrder> allOrders = fofoOrderRepository.selectBetweenSaleDate(startDate, endDate);

        // Collections.reverse(allOrders);

        // List<FofoOrder> allOrders =

        // List<FofoOrder> allOrders =

        // Arrays.asList(fofoOrderRepository.selectByInvoiceNumber("UPGZ019/25"));

        Set<String> serialNumbersConsidered = new HashSet<>();

        for (FofoOrder fofoOrder : allOrders) {

            String description = "Adjustment of Duplicate Scheme for Sale Invoice " + fofoOrder.getInvoiceNumber();

            Map<Integer, String> inventorySerialNumberMap = new HashMap<>();

            float amountToRollback = 0;

            List<FofoOrderItem> orderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());

            orderItems.forEach(x -> {

                inventorySerialNumberMap.putAll(x.getFofoLineItems().stream().filter(li -> li.getSerialNumber() != null).collect(Collectors.toMap(FofoLineItem::getInventoryItemId, FofoLineItem::getSerialNumber)));

            });

            if (inventorySerialNumberMap.size() > 0) {

                for (Entry<Integer, String> inventorySerialNumberEntry : inventorySerialNumberMap.entrySet()) {

                    String serialNumber = inventorySerialNumberEntry.getValue();

                    int inventoryItemId = inventorySerialNumberEntry.getKey();

                    if (serialNumbersConsidered.contains(serialNumber)) {

                        // This will rollback scheme for differenct orders for same serial

                        List<SchemeInOut> sios = new ArrayList<>();

                        for (SchemeInOut schemeInOut : schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItemId)))) {

                            if (schemeInOut.getRolledBackTimestamp() == null && schemeTypeMap.get(schemeInOut.getSchemeId()).equals(SchemeType.OUT)) {

                                sios.add(schemeInOut);

                            }

                        }

                        Collections.reverse(sios);

                        for (SchemeInOut sio : sios) {

                            sio.setRolledBackTimestamp(LocalDateTime.now());

                            amountToRollback += sio.getAmount();

                            // sio.setSchemeType(SchemeType.OUT);

                            sio.setSerialNumber(serialNumber);

                            sio.setStoreCode(fofoOrder.getInvoiceNumber().split("/")[0]);

                            sio.setReference(fofoOrder.getId());

                            rolledbackSios.add(sio);

                        }

                        description = description.concat(" " + serialNumber + " ");

                    } else {

                        serialNumbersConsidered.add(serialNumber);

                        List<Integer> schemesConsidered = new ArrayList<>();

                        List<SchemeInOut> sios = schemeInOutRepository.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItemId))).stream().filter(x -> x.getRolledBackTimestamp() == null && schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.OUT)).collect(Collectors.toList());

                        Collections.reverse(sios);

                        for (SchemeInOut sio : sios) {

                            if (!schemesConsidered.contains(sio.getSchemeId())) {

                                schemesConsidered.add(sio.getSchemeId());

                                continue;

                            }

                            sio.setRolledBackTimestamp(LocalDateTime.now());

                            amountToRollback += sio.getAmount();

                            // sio.setSchemeType(SchemeType.OUT);

                            sio.setReference(fofoOrder.getId());

                            sio.setSerialNumber(serialNumber);

                            sio.setStoreCode(fofoOrder.getInvoiceNumber().split("/")[0]);

                            rolledbackSios.add(sio);

                        }

                    }

                }

            }

            if (amountToRollback > 0) {

                UserWalletHistory uwh = new UserWalletHistory();

                uwh.setAmount(Math.round(amountToRollback));

                uwh.setDescription(description);

                uwh.setTimestamp(LocalDateTime.now());

                uwh.setReferenceType(WalletReferenceType.SCHEME_OUT);

                uwh.setReference(fofoOrder.getId());

                uwh.setWalletId(userWalletMap.get(fofoOrder.getFofoId()));

                uwh.setFofoId(fofoOrder.getFofoId());

                uwh.setStoreCode(fofoOrder.getInvoiceNumber().split("/")[0]);

                userWalletHistory.add(uwh);

            }

        }

        ByteArrayOutputStream baos = FileUtil.getCSVByteStream(

                Arrays.asList("Wallet Id", "Store Code", "Reference Type", "Reference", "Amount", "Description", "Timestamp"), userWalletHistory.stream().map(x -> Arrays.asList(x.getWalletId(), x.getStoreCode(), x.getReferenceType(), x.getReference(), x.getAmount(), x.getDescription(), x.getTimestamp())).collect(Collectors.toList()));

        ByteArrayOutputStream baosOuts = FileUtil.getCSVByteStream(

                Arrays.asList("Scheme ID", "SchemeType", "Store Code", "Serial Number", "Amount", "Created", "Rolledback"), rolledbackSios.stream().map(x -> Arrays.asList(x.getSchemeId(), x.getSchemeType(), x.getStoreCode(), x.getSerialNumber(), x.getAmount(), x.getCreateTimestamp(), x.getRolledBackTimestamp())).collect(Collectors.toList()));

        Utils.sendMailWithAttachments(googleMailSender, new String[]{"amit.gupta@shop2020.in"}, null, "Partner Excess Amount Scheme Out", "PFA", new Attachment[]{new Attachment("WalletSummary.csv", new ByteArrayResource(baos.toByteArray())), new Attachment("SchemeOutRolledback.csv", new ByteArrayResource(baosOuts.toByteArray()))});

        throw new Exception();

    }

    public void dryRunSchemeOutReco1() throws Exception {

        List<Integer> references = Arrays.asList(6744, 7347, 8320, 8891, 9124, 9217, 9263, 9379);

        List<UserWalletHistory> userWalletHistory = new ArrayList<>();

        List<SchemeInOut> rolledbackSios = new ArrayList<>();

        Map<Integer, Integer> userWalletMap = userWalletRepository.selectAll().stream().collect(Collectors.toMap(UserWallet::getUserId, UserWallet::getId));

        Map<Integer, SchemeType> schemeTypeMap = schemeRepository.selectAll().stream().collect(Collectors.toMap(Scheme::getId, Scheme::getType));

        for (Integer reference : references) {

            FofoOrder fofoOrder = null;

            try {

                fofoOrder = fofoOrderRepository.selectByOrderId(reference);

            } catch (Exception e) {

            }

            String description = "Adjustment of Duplicate Scheme for Sale Invoice " + fofoOrder.getInvoiceNumber();

            Map<Integer, String> inventorySerialNumberMap = new HashMap<>();

            float amountToRollback = 0;

            List<FofoOrderItem> orderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());

            orderItems.forEach(x -> {

                inventorySerialNumberMap.putAll(x.getFofoLineItems().stream().filter(li -> li.getSerialNumber() != null).collect(Collectors.toMap(FofoLineItem::getInventoryItemId, FofoLineItem::getSerialNumber)));

            });

            if (inventorySerialNumberMap.size() > 0) {

                List<SchemeInOut> sios = schemeInOutRepository.selectByInventoryItemIds(inventorySerialNumberMap.keySet()).stream().filter(x -> schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.OUT)).collect(Collectors.toList());

                LOGGER.info("Found {} duplicate schemeouts for Orderid {}", sios.size(), fofoOrder.getId());

                UserWalletHistory uwh = new UserWalletHistory();

                Map<Integer, List<SchemeInOut>> inventoryIdSouts = sios.stream().collect(groupingBy(SchemeInOut::getInventoryItemId, Collectors.toList()));

                for (Entry<Integer, List<SchemeInOut>> inventorySioEntry : inventoryIdSouts.entrySet()) {

                    List<SchemeInOut> outList = inventorySioEntry.getValue();

                    if (outList.size() > 1) {

                    }

                }

                uwh.setAmount(Math.round(amountToRollback));

                uwh.setDescription(description);

                uwh.setTimestamp(LocalDateTime.now());

                uwh.setReferenceType(WalletReferenceType.SCHEME_OUT);

                uwh.setReference(fofoOrder.getId());

                uwh.setWalletId(userWalletMap.get(fofoOrder.getFofoId()));

                uwh.setFofoId(fofoOrder.getFofoId());

                uwh.setStoreCode(fofoOrder.getInvoiceNumber().split("/")[0]);

                userWalletHistory.add(uwh);

            }

        }

        ByteArrayOutputStream baos = FileUtil.getCSVByteStream(

                Arrays.asList("User Id", "Reference Type", "Reference", "Amount", "Description", "Timestamp"), userWalletHistory.stream().map(x -> Arrays.asList(x.getWalletId(), x.getReferenceType(), x.getReference(), x.getAmount(), x.getDescription(), x.getTimestamp())).collect(Collectors.toList()));

        ByteArrayOutputStream baosOuts = FileUtil.getCSVByteStream(

                Arrays.asList("Scheme ID", "SchemeType", "Store Code", "Serial Number", "Amount", "Created", "Rolledback"), rolledbackSios.stream().map(x -> Arrays.asList(x.getSchemeId(), x.getSchemeType(), x.getStoreCode(), x.getSerialNumber(), x.getAmount(), x.getCreateTimestamp(), x.getRolledBackTimestamp())).collect(Collectors.toList()));

        Utils.sendMailWithAttachments(googleMailSender, new String[]{"amit.gupta@shop2020.in", "neeraj.gupta@smartdukaan.com"}, null, "Partner Excess Amount", "PFA", new Attachment[]{new Attachment("WalletSummary.csv", new ByteArrayResource(baos.toByteArray())), new Attachment("SchemeOutRolledback.csv", new ByteArrayResource(baosOuts.toByteArray()))});

        throw new Exception();

    }