Subversion Repositories SmartDukaan

            Utils.Attachment attachment1 = null;

            if(!filteredAllActiveLoans.isEmpty()){

                 byteArrayOutputStream = this.generateLoanCsv(filteredAllActiveLoans);

                 attachment1 = new Utils.Attachment("partnner-credit.csv", new ByteArrayResource(byteArrayOutputStream.toByteArray()));

                if(attachment1 != null){

                }else {

                this.sendMailOfHtmlFormat(googleMailSender, email, messageText, null, "Due Date Cross");

                }

    private ByteArrayOutputStream generateLoanCsv(List<Loan> loans) throws ProfitMandiBusinessException {

        org.apache.commons.io.output.ByteArrayOutputStream byteArrayOutputStream = null;

        if (!loans.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 : loans) {

                    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),

                            df.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);

            }

        }

        return byteArrayOutputStream;

    }