Subversion Repositories SmartDukaan

    public void convertExpiredFlagshipCredits() {

        synchronized (SD_CREDIT_LOCK) {

            try {

                sdCreditService.convertExpiredFlagshipCredits();

            } catch (Exception e) {

                LOGGER.error("Error converting expired flagship credits", e);

            }

        }

    }

    public void notifyFlagshipExpiryIn2Days() {

        try {

            java.time.LocalDate expiryDate = java.time.LocalDate.now().plusDays(2);

            List<Loan> expiringLoans = loanRepository.selectFlagshipLoansExpiringOn(expiryDate);

            LOGGER.info("Found {} flagship credits expiring on {}", expiringLoans.size(), expiryDate);

            Map<Integer, List<Loan>> byPartner = expiringLoans.stream()

                    .collect(java.util.stream.Collectors.groupingBy(Loan::getFofoId));

            for (Map.Entry<Integer, List<Loan>> entry : byPartner.entrySet()) {

                int fofoId = entry.getKey();

                List<Loan> loans = entry.getValue();

                double totalAmount = loans.stream().mapToDouble(l -> l.getPendingAmount().doubleValue()).sum();

                String title = "Flagship Credit Expiring Soon";

                String message = String.format(

                        "Your flagship credit of Rs.%.0f will convert to a regular loan on %s. " +

                        "Sell the items before then to avoid interest charges.",

                        totalAmount, expiryDate.format(java.time.format.DateTimeFormatter.ofPattern("dd-MMM-yyyy")));

                try {

                    int userId = userAccountRepository.selectUserIdByRetailerId(fofoId);

                    SendNotificationModel model = new SendNotificationModel();

                    model.setCampaignName("Flagship credit expiry reminder");

                    model.setTitle(title);

                    model.setMessage(message);

                    model.setType("url");

                    model.setUrl("https://app.smartdukaan.com/pages/home/credit");

                    model.setExpiresat(java.time.LocalDateTime.now().plusDays(2));

                    model.setMessageType(MessageType.reminder);

                    model.setUserIds(java.util.Arrays.asList(userId));

                    notificationService.sendNotification(model);

                } catch (Exception e) {

                    LOGGER.error("Failed to send flagship expiry notification to fofoId {}", fofoId, e);

                }

            }

        } catch (Exception e) {

            LOGGER.error("Error sending flagship expiry notifications", e);

        }

    }