Subversion Repositories SmartDukaan

    @Autowired

    com.spice.profitmandi.dao.repository.transaction.CreditNoteRepository creditNoteRepository;

    public void testReissueOneCN() throws Exception {

        YearMonth marginMonth = YearMonth.of(2026, 3);

        java.time.LocalDate bookDate = java.time.LocalDate.of(2026, 3, 31);

        String suffix = "/A";

        java.util.List<com.spice.profitmandi.dao.entity.transaction.CreditNote> allCNs =

                creditNoteRepository.selectAllMarginsTypeByMonth(marginMonth);

        LOGGER.info("testReissueOneCN: found {} non-cancelled MARGINS CNs for {}", allCNs.size(), marginMonth);

        // Pick first non-Delhi CN for testing

        com.spice.profitmandi.dao.entity.transaction.CreditNote testCN = null;

        for (com.spice.profitmandi.dao.entity.transaction.CreditNote cn : allCNs) {

            String prefix = cn.getCreditNoteNumber().substring(3).replaceAll("\\d", "");

            if (!prefix.startsWith("NSDL")) {

                testCN = cn;

                break;

            }

        }

        if (testCN == null) {

            throw new RuntimeException("No non-Delhi CN found for testing");

        }

        LOGGER.info("testReissueOneCN: testing with CN={} fofoId={}", testCN.getCreditNoteNumber(), testCN.getFofoId());

        // Override partner email to send to sdtech for testing

        creditNoteService.reissueMarginsCN(marginMonth, bookDate, suffix, testCN.getId(), "sdtech@smartdukaan.com");

    }

    public void reissueMarginsCN() throws Exception {

        YearMonth marginMonth = YearMonth.of(2026, 3);

        java.time.LocalDate bookDate = java.time.LocalDate.of(2026, 3, 31);

        String suffix = "/A";

        java.util.List<com.spice.profitmandi.dao.entity.transaction.CreditNote> existing =

                creditNoteRepository.selectAllMarginsTypeByMonth(marginMonth);

        LOGGER.info("reissueMarginsCN: found {} non-cancelled MARGINS CNs for {}", existing.size(), marginMonth);

        creditNoteService.reissueMarginsCN(marginMonth, bookDate, suffix);

    }

        this.fixStuckLimitBlocks(9999);

    private void fixStuckLimitBlocks(int maxFixes) {

        LocalDate fromDate = LocalDate.of(2026, 4, 27);

        LocalDate toDate = LocalDate.of(2026, 4, 29);

        List<Loan> allBlockedLoans = loanRepository.selectAllBlockedLoans();

        List<Loan> stuckLoans = allBlockedLoans.stream()

                .filter(l -> {

                    LocalDate created = l.getCreatedOn().toLocalDate();

                    return !created.isBefore(fromDate) && !created.isAfter(toDate);

                })

                .collect(toList());

        System.out.println("Found " + stuckLoans.size() + " stuck limit blocks between " + fromDate + " and " + toDate);

        System.out.println("Max fixes this run: " + maxFixes);

        int fixed = 0, skipped = 0, failed = 0;

        for (Loan blockedLoan : stuckLoans) {

            if (fixed >= maxFixes) {

                System.out.println("Reached max fixes limit (" + maxFixes + "), stopping.");

                break;

            }

            try {

                LoanTransaction loanTransaction = loanTransactionRepository.selectByLoanId(blockedLoan.getId());

                if (loanTransaction == null) {

                    System.out.println("SKIP loan " + blockedLoan.getId() + " - no LoanTransaction found");

                    skipped++;

                    continue;

                }

                int transactionId = loanTransaction.getTransactionId();

                List<Order> billedOrders = orderRepository.selectAllByTransactionId(transactionId).stream()

                        .filter(o -> o.getBillingTimestamp() != null && o.getRefundTimestamp() == null)

                        .collect(toList());

                if (billedOrders.isEmpty()) {

                    System.out.println("SKIP loan " + blockedLoan.getId() + " txn " + transactionId + " - no billed orders");

                    skipped++;

                    continue;

                }

                Map<String, List<Order>> byInvoice = billedOrders.stream()

                        .filter(o -> o.getInvoiceNumber() != null)

                        .collect(Collectors.groupingBy(Order::getInvoiceNumber));

                for (Map.Entry<String, List<Order>> entry : byInvoice.entrySet()) {

                    String invoiceNumber = entry.getKey();

                    double invoiceAmount = entry.getValue().stream().mapToDouble(Order::getWalletAmount).sum();

                    Loan existingLoan = loanRepository.selectLoanByInvoice(invoiceNumber);

                    if (existingLoan != null) {

                        System.out.println("SKIP loan " + blockedLoan.getId() + " invoice " + invoiceNumber + " - loan already exists (id=" + existingLoan.getId() + ")");

                        continue;

                    }

                    System.out.println("FIX loan " + blockedLoan.getId() + " fofo " + blockedLoan.getFofoId() + " txn " + transactionId + " invoice " + invoiceNumber + " invoiceAmt " + invoiceAmount + " pending " + blockedLoan.getPendingAmount());

                    sdCreditService.createLoanForBilling(transactionId, invoiceAmount, invoiceNumber);

                    fixed++;

                }

            } catch (Exception e) {

                System.out.println("FAIL loan " + blockedLoan.getId() + " fofo " + blockedLoan.getFofoId() + " - " + e.getMessage());

                e.printStackTrace();

                failed++;

            }

        }

        System.out.println("Done. fixed=" + fixed + " skipped=" + skipped + " failed=" + failed);

    }

    private void compensateAlreadyFixedLoans() {

        int[] alreadyFixedLoanIds = {106138, 106139, 106140, 106141, 106142, 106143, 106144, 106145, 106146, 106147};

        System.out.println("Compensating " + alreadyFixedLoanIds.length + " already-fixed loans");

        int done = 0, failed = 0;

        for (int loanId : alreadyFixedLoanIds) {

            try {

                Loan loan = loanRepository.selectByLoanId(loanId);

                if (loan == null) {

                    System.out.println("SKIP compensate loan " + loanId + " - not found");

                    continue;

                }

                double compensateAmount = loan.getIntialAmount().doubleValue();

                String compensateDesc = "Compensating double credit - forced loan " + loan.getId() + " against invoice " + loan.getInvoiceNumber();

                walletService.consumeAmountFromWallet(loan.getFofoId(), loan.getId(),

                        WalletReferenceType.CREDIT_UTILIZED, compensateDesc, (float) compensateAmount, LocalDateTime.now());

                System.out.println("COMPENSATE fofo " + loan.getFofoId() + " loan " + loan.getId() + " amount -" + compensateAmount);

                String forcedLoanReason = "Forced loan against invoice " + loan.getInvoiceNumber() + " (limit fix)";

                Loan forcedLoan = sdCreditService.createLoan(loan.getFofoId(), compensateAmount, loan.getFreeDays(), forcedLoanReason);

                System.out.println("FORCED LOAN fofo " + loan.getFofoId() + " loan " + forcedLoan.getId() + " amount " + compensateAmount + " freeDays " + loan.getFreeDays());

                done++;

            } catch (Exception e) {

                System.out.println("FAIL compensate loan " + loanId + " - " + e.getMessage());

                e.printStackTrace();

                failed++;

            }

        }

        System.out.println("Compensate done. done=" + done + " failed=" + failed);

    }