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
+                }
+            }
+        }
         if (upgradedCount > 0) {
-            sendMailOfHtmlFormat(googleMailSender,
-                    new String[]{"amit.gupta@smartdukaan.com", "tarun.verma@smartdukaan.com", "neeraj.gupta@smartdukaan.com"}, sb.toString(), null, "Few Partners Category have been Upgraded");
+            sendMailOfHtmlFormat(googleMailSender, new String[]{"amit.gupta@smartdukaan.com", "tarun.verma@smartdukaan.com", "neeraj.gupta@smartdukaan.com"}, sb.toString(), null, "Few Partners Category have been Upgraded");
         } else {
-            sendMailOfHtmlFormat(googleMailSender,
-                    new String[]{"amit.gupta@smartdukaan.com", "tarun.verma@smartdukaan.com", "neeraj.gupta@smartdukaan.com"}, sb.toString(), null, "No partners Category have been upgraded today");
+            sendMailOfHtmlFormat(googleMailSender, new String[]{"amit.gupta@smartdukaan.com", "tarun.verma@smartdukaan.com", "neeraj.gupta@smartdukaan.com"}, sb.toString(), null, "No partners Category have been upgraded today");
+        }
+    }
     @Autowired
     private PartnerStatsService partnerStatsService;
     @Autowired
     SessionFactory sessionFactory;
     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" +
+        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");
-                "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];
+    }
     private void addMissedScheduledLeadsTable(StringBuilder sb, List<Lead> missedScheduleLeads, Map<Integer, AuthUser> authUserMap) {
         sb.append("<h3>Leads That Missed the schedule</h3>");
-        sb.append("<table style='border:1px solid black' cellspacing='0'>")
+        sb.append("<table style='border:1px solid black' cellspacing='0'>").append("<tr>").append("<th style='border:1px solid black;padding: 5px'>").append("Lead Id").append("</th>").append("<th style='border:1px solid black;padding: 5px'>").append("Lead Name").append("</th>").append("<th style='border:1px solid black;padding: 5px'>").append("Mobile No").append("</th>").append("<th style='border:1px solid black;padding: 5px'>").append("City").append("</th>").append("<th style='border:1px solid black;padding: 5px'>").append("State").append("</th>").append("<th style='border:1px solid black;padding: 5px'>").append("Created On").append("</th>").append("<th style='border:1px solid black;padding: 5px'>").append("Assigned To").append("</th>").append("<th style='border:1px solid black;padding: 5px'>").append("Scheduled On").append("</th>").append("</tr>");
-                .append("<tr>")
-                .append("<th style='border:1px solid black;padding: 5px'>").append("Lead Id").append("</th>")
-                .append("<th style='border:1px solid black;padding: 5px'>").append("Lead Name").append("</th>")
-                .append("<th style='border:1px solid black;padding: 5px'>").append("Mobile No").append("</th>")
-                .append("<th style='border:1px solid black;padding: 5px'>").append("City").append("</th>")
-                .append("<th style='border:1px solid black;padding: 5px'>").append("State").append("</th>")
-                .append("<th style='border:1px solid black;padding: 5px'>").append("Created On").append("</th>")
-                .append("<th style='border:1px solid black;padding: 5px'>").append("Assigned To").append("</th>")
-                .append("<th style='border:1px solid black;padding: 5px'>").append("Scheduled On").append("</th>")
-                .append("</tr>");
         for (Lead lead : missedScheduleLeads) {
-            sb.append("<tr style='background-color:").append(lead.getColor()).append("'>")
+            sb.append("<tr style='background-color:").append(lead.getColor()).append("'>").append("<td style='border:1px solid black;padding: 5px'>").append(lead.getId()).append("</td>").append("<td style='border:1px solid black;padding: 5px'>").append(lead.getFullName()).append("</td>").append("<td style='border:1px solid black;padding: 5px'>").append(lead.getLeadMobile()).append("</td>").append("<td style='border:1px solid black;padding: 5px'>").append(lead.getCity()).append("</td>").append("<td style='border:1px solid black;padding: 5px'>").append(lead.getState()).append("</td>").append("<td style='border:1px solid black;padding: 5px'>").append(FormattingUtils.formatDate(lead.getCreatedTimestamp())).append("</td>").append("<td style='border:1px solid black;padding: 5px'>").append(
-                    .append("<td style='border:1px solid black;padding: 5px'>").append(lead.getId()).append("</td>")
-                    .append("<td style='border:1px solid black;padding: 5px'>").append(lead.getFullName()).append("</td>")
-                    .append("<td style='border:1px solid black;padding: 5px'>").append(lead.getLeadMobile()).append("</td>")
-                    .append("<td style='border:1px solid black;padding: 5px'>").append(lead.getCity()).append("</td>")
-                    .append("<td style='border:1px solid black;padding: 5px'>").append(lead.getState()).append("</td>")
-                    .append("<td style='border:1px solid black;padding: 5px'>").append(FormattingUtils.formatDate(lead.getCreatedTimestamp())).append("</td>")
-                    .append("<td style='border:1px solid black;padding: 5px'>").append(
-                            authUserMap.containsKey(lead.getAssignTo()) ? authUserMap.get(lead.getAssignTo()).getFullName() : lead.getAssignTo()).append("</td>")
-                    .append("<td style='border:1px solid black;padding: 5px'>").append(FormattingUtils.formatDate(lead.getScheduledTimestamp())).append("</td>")
+                    authUserMap.containsKey(lead.getAssignTo()) ? authUserMap.get(lead.getAssignTo()).getFullName() : lead.getAssignTo()).append("</td>").append("<td style='border:1px solid black;padding: 5px'>").append(FormattingUtils.formatDate(lead.getScheduledTimestamp())).append("</td>").append("</tr>");
-                    .append("</tr>");
+        }
         sb.append("</table>");
+    }
     public void notifyVisits() throws Exception {
                         // userWallet.setAmount(0);
+                    }
-                }
-            }
-            List<Order> allOrders = orderRepository.selectHoldOrder();
+                    List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectHoldSanctionByFofoId(loan.getFofoId());
-            LOGGER.info("allOrders {}", allOrders);
+                    double settledAmount = paidAmount;
+                    for (SanctionRequest sanctionRequest : sanctionRequests) {
-            if (!allOrders.isEmpty()) {
-                Map<Integer, List<Order>> transactionOrdersMap = allOrders.stream().collect(groupingBy(Order::getTransactionId, Collectors.toList()));
+                        List<Order> orders = orderRepository.selectAllByTransactionId(sanctionRequest.getTransactionId());
-                LinkedHashMap<Integer, List<Order>> sortedTransactionOrdersMap = new LinkedHashMap<>();
-                transactionOrdersMap.entrySet().stream().sorted(Map.Entry.comparingByKey()).forEachOrdered(x -> sortedTransactionOrdersMap.put(x.getKey(), x.getValue()));
-                LOGGER.info("sortedTransactionOrdersMap {}", sortedTransactionOrdersMap);
-                for (Entry<Integer, List<Order>> transactionOrdersEntry : sortedTransactionOrdersMap.entrySet()) {
-                    List<Order> orders = transactionOrdersEntry.getValue();
+                        if (settledAmount >= sanctionRequest.getPendingAmount().doubleValue()) {
+                            settledAmount = settledAmount - sanctionRequest.getPendingAmount().doubleValue();
-                    double totalAmount = orders.stream().collect(Collectors.summingDouble(x -> x.getTotalAmount()));
+                            sanctionRequest.setPendingAmount(BigDecimal.valueOf(0));
+                            this.sendUnholdEmail(orders);
+                        } else {
-                    LocalDateTime createDate = orders.get(0).getCreateTimestamp();
+                            settledAmount = sanctionRequest.getPendingAmount().doubleValue() - settledAmount;
-                    int fofoId = orders.get(0).getRetailerId();
+                            sanctionRequest.setPendingAmount(BigDecimal.valueOf(settledAmount));
-                    int transactionId = transactionOrdersEntry.getKey();
+                            break;
-                    SanctionRequest sanctionRequest = sanctionRequestRepository.selectByTransactionId(transactionId);
+                        }
-                    double loanSettleAmount = loanStatementRepository.selectByDateAndFofoId(createDate, fofoId).stream().filter(x -> x.getAmount().doubleValue() > 0).collect(Collectors.summingDouble(x -> x.getAmount().doubleValue()));
+                    }
+                }
-                    LOGGER.info("loanSettleAmount {}", loanSettleAmount);
+            }
-                    LOGGER.info("totalAmount {}", totalAmount);
-                    if (loanSettleAmount >= sanctionRequest.getUtilizationAmount().doubleValue()) {
-                        LOGGER.info("totalAmount {}", totalAmount);
+        }
-                        orders.forEach(x -> x.setShipmentHold(false));
+    }
-                        List<String> authUserEmail = csService.getAuthUserIdByPartnerId(orders.get(0).getRetailerId()).stream().map(x -> x.getEmailId()).collect(Collectors.toList());
-                        authUserEmail.add("vinay.p@smartdukaan.com");
-                        authUserEmail.add("shivam.gupta@smartdukaan.com");
-                        String[] emailTo = authUserEmail.toArray(new String[authUserEmail.size()]);
+    private void sendUnholdEmail(List<Order> orders) throws Exception {
-                        String[] ccTo = {"tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com"};
-                        String subject = "Dispatched " + (orders.get(0).getRetailerName());
+        orders.forEach(x -> x.setShipmentHold(false));
-                        String message = String.format("Dear Team, \n" + "kindly note the material for the " + orders.get(0).getRetailerName() + "of Rs." + totalAmount + "is dispatched.");
+        double totalAmount = orders.stream().collect(Collectors.summingDouble(x -> x.getTotalAmount()));
+        List<String> authUserEmail = csService.getAuthUserIdByPartnerId(orders.get(0).getRetailerId()).stream().map(x -> x.getEmailId()).collect(Collectors.toList());
+        authUserEmail.add("vinay.p@smartdukaan.com");
-                        Utils.sendMailWithAttachments(mailSender, emailTo, ccTo, subject, message);
+        authUserEmail.add("shivam.gupta@smartdukaan.com");
-                    }
+        String[] emailTo = authUserEmail.toArray(new String[authUserEmail.size()]);
+        String[] ccTo = {"tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com"};
-                }
+        String subject = "Dispatched " + (orders.get(0).getRetailerName());
+        String message = String.format("Dear Team, \n" + "kindly note the material for the " + orders.get(0).getRetailerName() + "of Rs." + totalAmount + "is dispatched.");
-            }
+        Utils.sendMailWithAttachments(mailSender, emailTo, ccTo, subject, message);
-        }
+    }
     private void settledLoanStatement(LoanReferenceType loanReferneceType, BigDecimal amount, int fofoId, int loanId, String description, LocalDateTime now) {
+        }
+    }
     private String getMessageHygieneAlertForPartner(
-            Map<Integer, Map<YearMonth, List<HygieneData>>> partnerYearMonthData, Map<Integer, Map<LocalDate, List<HygieneData>>> partnerDateWiseData) {
+                                                    Map<Integer, Map<YearMonth, List<HygieneData>>> partnerYearMonthData, Map<Integer, Map<LocalDate, List<HygieneData>>> partnerDateWiseData) {
         Map<Integer, CustomRetailer> customeRetailerMap = retailerService.getAllFofoRetailers();
         LocalDateTime startDate = LocalDate.now().withDayOfMonth(1).atStartOfDay();
         LocalDateTime endDate = LocalDateTime.now();

Subversion Repositories SmartDukaan

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