WebSVN – SmartDukaan – Diff – /trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java

 import java.util.*;
 import java.util.Map.Entry;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 import static java.util.stream.Collectors.groupingBy;
 import static java.util.stream.Collectors.mapping;
 @Component
         sb.append("</tbody></table></body></html>");
         return sb.toString();
+    }
-    private String getMessageForRBMEscalatedPartners(List<PartnerCollectionRemark> pcrs) throws
+    private String getMessageForUncontacblePartner(List<PartnerCollectionRemark> pcrs) throws
             ProfitMandiBusinessException {
         StringBuilder sb = new StringBuilder();
-        sb.append("<html><body><p>Alert</p><p>Escalated by RBM-L1:-</p>" + "<br/><table style='border:1px solid black ;padding: 5px';>");
+        sb.append("<html><body><p>Alert</p><p>Not Responding Partner:-</p>" + "<br/><table style='border:1px solid black ;padding: 5px';>");
-        sb.append("<tbody>" +
-                "<tr>" +
-                "<th style='border:1px solid black;padding: 5px'>PartnerName</th>" +
+        sb.append("<tbody>\n" + "	    				<tr>\n" + "	    					<th style='border:1px solid black;padding: 5px'>PartnerName</th>\n" + "	    					<th style='border:1px solid black;padding: 5px'>from</th>\n"
-                "<th style='border:1px solid black;padding: 5px'>Escalated Since</th>" +
-                "<th style='border:1px solid black;padding: 5px'>Message</th>" +
-                "</tr>");
+                + "	    				</tr>");
         for (PartnerCollectionRemark entry : pcrs) {
             CustomRetailer customRetailer = retailerService.getFofoRetailer(entry.getFofoId());
             sb.append("<tr>");
             sb.append("<td style='border:1px solid black;padding: 5px'>" + customRetailer.getBusinessName() + "(" + customRetailer.getCode() + ")" + "</td>");
             sb.append("<td style='border:1px solid black;padding: 5px'>" + entry.getCreateTimestamp().format(DateTimeFormatter.ofPattern("dd/MM/yyyy")) + "</td>");
-            sb.append("<td style='border:1px solid black;padding: 5px'>" + entry.getMessage() + "</td>");
             sb.append("</tr>");
+        }
         if (!orders.isEmpty()) {
             Set<String> airwayBillNo = orders.stream().map(x -> x.getAirwayBillNumber()).collect(Collectors.toSet());
             LOGGER.info("airwayBill" + airwayBillNo);
-            //String url = "https://api.bluedart.com/servlet/RoutingServlet?handler=tnt&action=custawbquery";
+            String url = "https://api.bluedart.com/servlet/RoutingServlet?handler=tnt&action=custawbquery";
-            String url = "https://apigateway.bluedart.com/in/transportation/tracking/v1/shipment?scan=1";
-            // String dataheader="eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJzdWIiOiJzdWJqZWN0LXN1YmplY3QiLCJhdWQiOlsiYXVkaWVuY2UxIiwiYXVkaWVuY2UyIl0sIkNsaWVudFNlY3JldCI6IkV5SGp5OFNVcmtGNzZVc2ciLCJpc3MiOiJ1cm46XC9cL2FwaWdlZS1lZGdlLUpXVC1wb2xpY3ktdGVzdCIsIkNsaWVudElEIjoiRWJGSEdrazdOODU2R0dJZjlkclUzZ3BuRjZLbGNxUnUiLCJleHAiOjE3MDQzNjA1OTQsImlhdCI6MTcwNDI3NDE5NCwianRpIjoiNGVjZjZjMjEtYTE4MC00OGMwLThkYzUtNTM4OWRlYWFlM2JmIn0.miLZjZkqvgpr4N3eDEeahSXwK0jJSKuRMdnZRTXoF98";
-            String response = restClient.get(url + "&loginid=" + loginId + "&awb=awb&numbers=" + String.join(",", airwayBillNo) + "&format=xml&lickey=" + licencekey + "&verno=1.3", null, null);
+            String response = restClient.get(url + "&loginid=" + loginId + "&awb=awb&numbers=" + String.join(",", airwayBillNo) + "&format=xml&lickey=" + licencekey + "&verno=1.3&scan=1", null, null);
-            LOGGER.info("API Response: " + response);
             JSONObject updateJson = XML.toJSONObject(response);
             JSONObject shipmentData = updateJson.getJSONObject("ShipmentData");
             Object shipmentObject = shipmentData.get("Shipment");
                     String status = jsonObject.getString("Status");
                     if (status.equals("SHIPMENT DELIVERED")) {
                         airwaybillStatus.add(awb.toString());
+                    }
-                    System.out.println("AWB: " + awb + ", Status: " + status);
+                }
             } else {
                 JSONObject jsonObject = (JSONObject) shipmentObject;
                 Number awb = jsonObject.getNumber("WaybillNo");
                 String status = jsonObject.getString("Status");
                 if (status.equals("SHIPMENT DELIVERED")) {
                     airwaybillStatus.add(awb.toString());
+                }
-                System.out.println("AWB: " + awb + ", Status: " + status);
+            }
             LOGGER.info("airwaybillStatus" + airwaybillStatus);
+    }
     @Autowired
     private PartnerCollectionRemarkRepository partnerCollectionRemarkRepository;
-    //RBM L2 Escalations
     public void reviewUncontactablePartner() throws
             ProfitMandiBusinessException, MessagingException, UnsupportedEncodingException {
         Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(true);
-        List<Integer> partnerLastCollectionRemarkIds = partnerCollectionRemarkRepository.selectMaxRemarkId(new ArrayList<>(customRetailerMap.keySet()));
+        List<Integer> pcrms = partnerCollectionRemarkRepository.selectMaxRemarkId(new ArrayList<>(customRetailerMap.keySet()));
-        if (!partnerLastCollectionRemarkIds.isEmpty()) {
-            List<PartnerCollectionRemark> partnerCollectionRemarks = partnerCollectionRemarkRepository.selectByIds(partnerLastCollectionRemarkIds);
-            Map<Integer, PartnerCollectionRemark> rbmEscalatedRemarksMap = partnerCollectionRemarks.stream().filter(x -> x.getRemark().equals(CollectionRemark.COLLECTION_PLAN)).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
-            Map<Integer, PartnerCollectionRemark> salesEscalatedRemarksMap = partnerCollectionRemarks.stream().filter(x -> x.getRemark().equals(CollectionRemark.SALES_ESCALATION)).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
-            if (!rbmEscalatedRemarksMap.isEmpty()) {
-                //
-                for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_RBM), true).entrySet()) {
-                    List<PartnerCollectionRemark> filteredRows = storeGuyEntry.getValue().stream()
-                            .map(x -> rbmEscalatedRemarksMap.get(x)).filter(x -> x != null).collect(Collectors.toList());
-                    String subject = "Partners escalated to RBM-L2";
-                    String messageText = this.getMessageForRBMEscalatedPartners(filteredRows);
-                    MimeMessage message = mailSender.createMimeMessage();
-                    MimeMessageHelper helper = new MimeMessageHelper(message, true);
-                    String[] email = new String[]{storeGuyEntry.getKey()};
-                    helper.setSubject(subject);
-                    helper.setText(messageText, true);
-                    helper.setTo(email);
-                    InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
-                    helper.setFrom(senderAddress);
-                    mailSender.send(message);
+        if (!pcrms.isEmpty()) {
-                    LOGGER.info("filteredRows {}", filteredRows);
+            Map<Integer, PartnerCollectionRemark> partnerCollectionRemarksMap = partnerCollectionRemarkRepository.selectByIds(pcrms).stream().filter(x -> x.getRemark().equals(CollectionRemark.NOT_RESPONDING)).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
-                }
-            }
-            if (!salesEscalatedRemarksMap.isEmpty()) {
+            if (!partnerCollectionRemarksMap.isEmpty()) {
-                //
-                for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_RBM), true).entrySet()) {
+                for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMapping().entrySet()) {
-                    List<PartnerCollectionRemark> filteredRows = storeGuyEntry.getValue().stream()
-                            .map(x -> salesEscalatedRemarksMap.get(x)).filter(x -> x != null).collect(Collectors.toList());
+                    List<PartnerCollectionRemark> filteredRows = storeGuyEntry.getValue().stream().map(x -> partnerCollectionRemarksMap.get(x)).filter(x -> x != null).collect(Collectors.toList());
-                    String subject = "Partners escalated to Sales";
+                    String subject = "UNCONTACTABLE PARTNERS";
-                    String messageText = this.getMessageForSalesEscalatedPartners(filteredRows);
+                    String messageText = this.getMessageForUncontacblePartner(filteredRows);
                     MimeMessage message = mailSender.createMimeMessage();
                     MimeMessageHelper helper = new MimeMessageHelper(message, true);
                     String[] email = new String[]{storeGuyEntry.getKey()};
             vendorCatalogPricingService.createVendorCatalogPricing(vendorCatalogPricingLog);
+        }
+    }
+    public void sendMailWhatsAppAfterLoanDueDate() throws Exception {
+        sdCreditService.updateRisk();
+        List<Loan> defaultLoans = sdCreditService.getLoanALert();
+        if (!defaultLoans.isEmpty()) {
+            this.sendLoanAlert(defaultLoans);
+        }
+    }
+    public void sendLoanAlert(List<Loan> defaultLoans) throws
+            Exception {
+        String subject = "Default Partners";
+        List<Integer> categoryIds = Arrays.asList(
+                ProfitMandiConstants.TICKET_CATEGORY_CATEGORY,
+                ProfitMandiConstants.TICKET_CATEGORY_RBM,
+                ProfitMandiConstants.TICKET_CATEGORY_SALES,
+                ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS,
+                ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT);
+        /*for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(categoryIds, false).entrySet()) {
+            List<Loan> filteredRows = defaultLoans.stream()
+                    .filter(loan -> storeGuyEntry.getValue().contains(loan.getFofoId()))
+                    .collect(Collectors.toList());
+            if (!filteredRows.isEmpty()) {
+                for (Loan defaultLoan : filteredRows) {
+                    List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(defaultLoan.getId());
+                    double amount = loanStatements.stream().map(LoanStatement::getAmount).collect(Collectors.summingDouble(BigDecimal::doubleValue));
+                    String messageText = getMessageForDueDateExtend(defaultLoan,amount);
+                   // String[] email = new String[]{storeGuyEntry.getKey()};
+                    String[] email = {"ranu.rajput@smartdukaan.com"};
+                    sendMailOfHtmlFormat(mailSender, email, messageText, null, subject);
+                }
+            }
+        }*/
+        for (Loan defaultLoan : defaultLoans) {
+            List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(defaultLoan.getId());
+            double amount = loanStatements.stream().map(LoanStatement::getAmount).collect(Collectors.summingDouble(BigDecimal::doubleValue));
+            com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectById(defaultLoan.getFofoId());
+            Address address = addressRepository.selectById(user.getAddressId());
+            String title = "Alert!";
+            String url = "http://app.smartdukaan.com/pages/home/credit";
+            String message = getMessageForDueDateExtend(defaultLoan,amount);
+            String whatsAppMessage = getWhatsAppMessageForDueDateExtend(defaultLoan,amount);
+            notificationService.sendWhatsappMessage(whatsAppMessage, title, address.getPhoneNumber());
+            String[] email = {user.getEmailId()};
+            sendMailOfHtmlFormat(mailSender, email, message, null, "Loan Alert - SmartDukaan");
+        }
+    }
+    private String getMessageForDueDateExtend(Loan defaultLoan, double amount) throws ProfitMandiBusinessException {
+        double absoluteAmount = Math.abs(amount);
+        long roundedAmount = Math.round(absoluteAmount);
+        String formattedAmount = (amount < 0) ? "" + roundedAmount : "" + roundedAmount;
+        LocalDate dueDate = defaultLoan.getDueDate().toLocalDate();
+        LocalDate defaultDate = defaultLoan.getDueDate().toLocalDate().plusDays(15);
+        // Retrieve the name of the user associated with the loan
+        String name = userUserRepository.selectById(defaultLoan.getFofoId()).getName();
+        // Initialize a StringBuilder to construct the HTML message
+        StringBuilder sb = new StringBuilder();
+        if(LocalDate.now().isBefore(dueDate)){
+            long noOfdaysBetween = ChronoUnit.DAYS.between(LocalDate.now() , defaultLoan.getDueDate().toLocalDate());
+            String payDate = defaultLoan.getDueDate().toLocalDate().format(DateTimeFormatter.ofPattern("dd-MM-yyyy"));
+            // 5 Days Before Due Date - daily
+            if (noOfdaysBetween <= 5) {
+                sb.append("<html><body><p><b>Loan Repayment Alert !</b></p></br><p>Dear " + name + "</p>");
+                sb.append("<p>This is a friendly reminder that your loan payment is due in " + noOfdaysBetween + "days, on " +
+                        payDate +
+                        ". Please ensure that the payment is made on time to avoid any late fees or penalties.</p>");
+                sb.append("<p>As per the terms of your loan agreement, the total amount due is Rs. " + formattedAmount + ". " +
+                        "You can make the payment by adding money to your wallet. If you have any questions or need assistance, " +
+                        "our customer service team is available to help you.</p>");
+                sb.append("<p>Thank you for your cooperation and prompt attention to this matter.</p></br><p> Smart Dukaan Team !!</p>");
+            }
+        }else if(LocalDate.now().isBefore(defaultDate)){
+            long noOfdaysBetween = ChronoUnit.DAYS.between(defaultDate, LocalDate.now());
+            // After Due Date – Alternate days
+            if ((noOfdaysBetween % 2 == 0) && (noOfdaysBetween > 5)) {
+                sb.append("<html><body><p><b>Loan Repayment Alert !</b></p></br><p>Dear " + name + "</p>");
+                sb.append("<p>We would like to remind you that your payment for the outstanding balance on your account is now overdue. " +
+                        "As per our terms and conditions, a higher interest rate will be levied on the overdue amount Rs. " + formattedAmount + ".</p>");
+                sb.append("<p>To avoid further charges and any negative impact on your CIBIL score, we kindly request that you settle the " +
+                        "outstanding balance as soon as possible.</p>");
+                sb.append("<p>Thank you for your attention to this matter.</p></br><p> Smart Dukaan Team !!</p>");
+            }
+            // 5 Days before default - daily
+            if (noOfdaysBetween <= 5 ) {
+                sb.append("<html><body><p><b>Loan Repayment Alert !</b></p></br>");
+                sb.append("<p>Attention: High Alert</p>");
+                sb.append("<p>Dear " + name + "</p>");
+                sb.append("<p>This is to inform you that the due date for your payment of Rs. " + formattedAmount + " has been crossed, " +
+                        "and you are approaching the default date on " + defaultDate.format(DateTimeFormatter.ofPattern("dd-MM-yyyy")) + ". " +
+                        "Please be aware that this will have a significant impact on your CIBIL score and may result in substantial penalties as well.</p>");
+                sb.append("<p>To rectify this situation, it is imperative that you take immediate action. " +
+                        "Please make the necessary payment immediately to avoid further consequences.</p>");
+                sb.append("<p>Thank you for your attention to this matter.</p></br><p> Smart Dukaan Team !!</p>");
+            }
+        }else{
+            // Post Default - Daily
+                sb.append("<html><body><p><b>Loan Repayment Alert !</b></p></br><p>Dear " + name + "</p>");
+                sb.append("<p>We regret to inform you that you are currently in loan default. As a result, " +
+                        "higher penalties are being charged, which is also negatively impacting your CIBIL score. " +
+                        "It is imperative that you make an immediate payment to rectify this situation.</p>");
+                sb.append("<p>Please note that failing to make the payment promptly will result in further consequences, " +
+                        "including potential legal action and additional financial penalties. " +
+                        "We strongly urge you to take this matter seriously and settle the outstanding amount as soon as possible.</p>");
+                sb.append("<p>To make the payment, please add Rs. " + formattedAmount + " to your wallet. We are here to help you resolve this issue and get back on track.</p>");
+                sb.append("<p>Thank you for your attention to this matter.</p></br><p> Smart Dukaan Team !!</p>");
+        }
+        // Return the constructed HTML message
+        sb.append("</body></html>");
+        return sb.toString();
+    }
+    private String getWhatsAppMessageForDueDateExtend(Loan defaultLoan, double amount) throws ProfitMandiBusinessException {
+        double absoluteAmount = Math.abs(amount);
+        long roundedAmount = Math.round(absoluteAmount);
+        String formattedAmount = (amount < 0) ? "" + roundedAmount : "" + roundedAmount;
+        LocalDate dueDate = defaultLoan.getDueDate().toLocalDate();
+        LocalDate defaultDate = defaultLoan.getDueDate().toLocalDate().plusDays(15);
+        // Retrieve the name of the user associated with the loan
+        String name = userUserRepository.selectById(defaultLoan.getFofoId()).getName();
+        // Initialize a StringBuilder to construct the HTML message
+        String message = null;
+        if(LocalDate.now().isBefore(dueDate)){
+            long noOfdaysBetween = ChronoUnit.DAYS.between(LocalDate.now(), defaultLoan.getDueDate().toLocalDate());
+            String payDate = defaultLoan.getDueDate().toLocalDate().format(DateTimeFormatter.ofPattern("dd-MM-yyyy"));
+            // 5 Days Before Due Date - daily
+            if (noOfdaysBetween <= 5) {
+                message = "Dear %s, This is a friendly reminder that your loan payment is due in %d days, on %s.\n" +
+                        "\n" +
+                        "Please ensure that the payment is made on time to avoid any late fees or penalties.As per the terms of your loan agreement, the total amount due is Rs. %s. You can make the payment by adding money to wallet.\n" +
+                        "\n" +
+                        "If you have any questions or need assistance, our customer service team is available to help you.\n" +
+                        "Thank you for your cooperation and prompt attention to this matter.\n" +
+                        "\n" +
+                        "Team SmartDukaan";
+                message = String.format(message, name, noOfdaysBetween, payDate,formattedAmount);
+                  }
+        }else if(LocalDate.now().isBefore(defaultDate)){
+            long noOfdaysBetween = ChronoUnit.DAYS.between(defaultDate, LocalDate.now());
+            // After Due Date – Alternate days
+            if ((noOfdaysBetween % 2 == 0) && (noOfdaysBetween > 5)) {
+                message = "Dear %s, We would like to remind you that your payment for the outstanding balance on your account is now overdue. \n" +
+                        "As per our terms and conditions, a higher interest rate will be levied on the overdue amount Rs.%s.\n" +
+                        "To avoid further charges and any negative impact on your CIBIL score, we kindly request that you settle the outstanding balance as soon as possible.\n" +
+                        "Thank you for your attention to this matter. \n" +
+                        "\n" +
+                        "Team SmartDukaan";
+                message = String.format(message, name, formattedAmount);
+            }
+            // 5 Days before default - daily
+            if (noOfdaysBetween <= 5 ) {
+                String defaultPayDate = defaultDate.format(DateTimeFormatter.ofPattern("dd-MM-yyyy"));
+                message = "Attention: High Alert!! Dear %s, \n" +
+                        "\n" +
+                        "This is to inform you that the due date for your payment of Rs. %s has been crossed, and as a result, you are now about to reach default date %s.\n" +
+                        "Please be aware that this will have a significant impact on your CIBIL score and may result in substantial penalties as well. To rectify this situation, it is imperative that you take immediate action.\n" +
+                        "\n" +
+                        "Please make the necessary payment immediately to avoid further consequences. Thank you for your attention to this matter.\n" +
+                        "\n" +
+                        "Team SmartDukaan";
+                message = String.format(message, name, formattedAmount, defaultPayDate);
+            }
+        }else {
+            // Post Default - Daily
+            message = "Dear %s, We regret to inform you that you are currently in loan default. As a result, higher penalties are being charged, which is also negatively impacting your CIBIL score. \n" +
+                    "\n" +
+                    "It is imperative that you make an immediate payment to rectify this situation. \n" +
+                    "\n" +
+                    "Please note that failing to make the payment promptly will result in further consequences, including potential legal action and additional financial penalties. \n" +
+                    "\n" +
+                    "We strongly urge you to take this matter seriously and settle the outstanding amount as soon as possible. \n" +
+                    "\n" +
+                    "To make the payment, please add Rs. %s  to wallet. We are here to help you resolve this issue and get back on track. Thank you for your attention to this matter. \n" +
+                    "\n" +
+                    "Team SmartDukaan";
+            message = String.format(message, name, formattedAmount);
+        }
+        // Return the constructed HTML message
+        return message;
+    }
+}
 // 2284'

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java – Rev 32818 → 32822