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

         sb.append("</tbody></table></body></html>");
         return sb.toString();
+    }
-    private String getMessageForDueDateCross(List<Loan> loans) throws ProfitMandiBusinessException {
+    private String getMessageForDueDateCross(List<Loan> dueDateCrossLoans) throws ProfitMandiBusinessException {
         Map<Integer, com.spice.profitmandi.dao.model.FofoReportingModel> fofoReportingModelMap = csService.getPartnerIdSalesHeaders();
         Map<Integer, FofoRBMReportingModel> fofoRbmReportingModelMap = csService.getPartnerIdRBMHeaders();
         List<AST> asts = astRepository.selectAll();
         Map<Integer, AST> astMap = asts.stream()
                 .collect(Collectors.toMap(AST::getId, ast -> ast));
                 "<th style='border:1px solid black;padding: 5px'>Sales L1</th>\n" +
                 "<th style='border:1px solid black;padding: 5px'>Sales L2</th>\n" +
                 "<th style='border:1px solid black;padding: 5px'>Limit Assigned</th>\n" +
                 "</tr>");
-        for (Loan entry : loans) {
+        for (Loan entry : dueDateCrossLoans) {
+            DecimalFormat df = new DecimalFormat("#.##");
             List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(entry.getId());
             double amount = loanStatements.stream().map(x -> x.getAmount()).collect(Collectors.summingDouble(x -> x.doubleValue()));
             sb.append("<td style='border:1px solid black;padding: 5px'>" + new DecimalFormat("#.##").format(Math.abs(amount)) + "</td>");
             sb.append("<td style='border:1px solid black;padding: 5px'>" + fofoRbmReportingModelMap.get(entry.getFofoId()).getL1Manager() + "</td>");
             sb.append("<td style='border:1px solid black;padding: 5px'>" + fofoRbmReportingModelMap.get(entry.getFofoId()).getL2Manager() + "</td>");
             sb.append("<td style='border:1px solid black;padding: 5px'>" + fofoReportingModelMap.get(entry.getFofoId()).getTerritoryManager() + "</td>");
             sb.append("<td style='border:1px solid black;padding: 5px'>" + fofoReportingModelMap.get(entry.getFofoId()).getRegionalManager() + "</td>");
-            sb.append("<td style='border:1px solid black;padding: 5px'>" + sdCreditRequirement.getLimit() + "</td>");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + df.format(sdCreditRequirement.getLimit())  + "</td>");
             sb.append("</tr>");
+        }
         sb.append("</tbody></table></body></html>");
         return sb.toString();
+    }
     public void notifyLoanDueDateCross() throws Exception {
-        List<Loan> dueDateCrossLoans = sdCreditService.getAllActiveLoan();
+        List<Loan> dueDateCrossLoans = sdCreditService.getDueDateCrossLoan();
+        List<Loan> allActiveLoans = sdCreditService.getAllActiveLoan();
         if (!dueDateCrossLoans.isEmpty()) {
-            this.sendDueDateCrossLoanAlert(dueDateCrossLoans);
+            this.sendDueDateCrossLoanAlert(dueDateCrossLoans,allActiveLoans);
+        }
+    }
-    private void sendDueDateCrossLoanAlert(List<Loan> dueDateCrossLoans) throws Exception {
+    private void sendDueDateCrossLoanAlert(List<Loan> dueDateCrossLoans,List<Loan> allActiveLoans) throws Exception {
         List<Integer> categoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_CATEGORY, ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES,ProfitMandiConstants.TICKET_CATEGORY_ABM, ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS, ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT);
         for (Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(categoryIds, false).entrySet()) {
             List<Loan> filteredRows = new ArrayList<>();
             for (Loan loan : dueDateCrossLoans) {
                 if (storeGuyEntry.getValue().contains(loan.getFofoId())) {
                     filteredRows.add(loan);
+                }
+            }
+            List<Loan> filteredRowsAllLoans = new ArrayList<>();
+            for (Loan loan : allActiveLoans) {
+                if (storeGuyEntry.getValue().contains(loan.getFofoId())) {
+                    filteredRowsAllLoans.add(loan);
+                }
+            }
+            org.apache.commons.io.output.ByteArrayOutputStream byteArrayOutputStream = null;
+            if (!filteredRowsAllLoans.isEmpty()) {
+                Map<Integer, com.spice.profitmandi.dao.model.FofoReportingModel> fofoReportingModelMap = csService.getPartnerIdSalesHeaders();
+                Map<Integer, FofoRBMReportingModel> fofoRbmReportingModelMap = csService.getPartnerIdRBMHeaders();
+                List<AST> asts = astRepository.selectAll();
+                Map<Integer, AST> astMap = asts.stream()
+                        .collect(Collectors.toMap(AST::getId, ast -> ast));
+                try {
+                    List<String> headers = Arrays.asList(
+                            "PartnerName", "State Name", "Area", "Territory",
+                            "Due Date", "Days", "Pending Amount",
+                            "RBM L2", "RBM L1", "Sales L1", "Sales L2", "Limit Assigned"
+                    );
+                    List<List<?>> rows = new ArrayList<>();
+                    for (Loan entry : allActiveLoans) {
+                        List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(entry.getId());
+                        double amount = loanStatements.stream().map(x -> x.getAmount()).collect(Collectors.summingDouble(x -> x.doubleValue()));
+                        long noOfdaysBetween = ChronoUnit.DAYS.between(entry.getDueDate().toLocalDate(), LocalDateTime.now());
+                        CustomRetailer customRetailer = retailerService.getFofoRetailer(entry.getFofoId());
+                        SDCreditRequirement sdCreditRequirement = sdCreditRequirementRepository.selectByFofoId(customRetailer.getPartnerId());
+                        DecimalFormat df = new DecimalFormat("#.##");
+                        List<String> row = Arrays.asList(
+                                customRetailer.getBusinessName() + "(" + customRetailer.getCode() + ")",
+                                customRetailer.getAddress().getState(),
+                                astMap.get(customRetailer.getAstId()).getArea(),
+                                astMap.get(customRetailer.getAstId()).getTerritory(),
+                                entry.getDueDate().format(DateTimeFormatter.ofPattern("dd/MM/yyyy")),
+                                String.valueOf(noOfdaysBetween),
+                                new DecimalFormat("#.##").format(Math.abs(amount)),
+                                fofoRbmReportingModelMap.get(entry.getFofoId()).getL1Manager(),
+                                fofoRbmReportingModelMap.get(entry.getFofoId()).getL2Manager(),
+                                fofoReportingModelMap.get(entry.getFofoId()).getTerritoryManager(),
+                                fofoReportingModelMap.get(entry.getFofoId()).getRegionalManager(),
+                                df.format(sdCreditRequirement.getLimit())
+                        );
+                        rows.add(row);
+                    }
+                     byteArrayOutputStream = FileUtil.getCSVByteStream(headers, rows);
+                } catch (Exception e) {
+                    throw new RuntimeException(e);
+                }
+            }
+            Utils.Attachment attachment1 = new Utils.Attachment("partnner-credit.csv", new ByteArrayResource(byteArrayOutputStream.toByteArray()));
             if (!filteredRows.isEmpty()) {
                 String messageText = this.getMessageForDueDateCross(filteredRows);
                 String[] email = new String[]{storeGuyEntry.getKey()};
+                Utils.sendMailWithAttachments(googleMailSender, email, null, null, "Partner Credit Report", messageText, true, attachment1);
-                this.sendMailOfHtmlFormat(googleMailSender, email, messageText, null, "Due Date Cross");
+//                this.sendMailOfHtmlFormat(googleMailSender, email, messageText, null, "Due Date Cross");
+            }
+        }
-        String messageText = this.getMessageForDueDateCross(dueDateCrossLoans);
+//        String messageText = this.getMessageForDueDateCross(dueDateCrossLoans);
-        this.sendMailOfHtmlFormat(googleMailSender, new String[]{"puneet.wahi@smartdukaan.com", "rahul.latwal@smartdukaan.com", "sdtech@smartdukaan.com"}, messageText, null, "Due Date Cross");
+//        this.sendMailOfHtmlFormat(googleMailSender, new String[]{"puneet.wahi@smartdukaan.com", "rahul.latwal@smartdukaan.com", "sdtech@smartdukaan.com"}, messageText, null, "Due Date Cross");
         if (!dueDateCrossLoans.isEmpty()) {
             for (Loan loan : dueDateCrossLoans) {

Subversion Repositories SmartDukaan

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