Subversion Repositories SmartDukaan

    private String getMessageForUnauthorizedBuying(List<NonSdBuying> nsb) throws

            ProfitMandiBusinessException {

        StringBuilder sb = new StringBuilder();

        sb.append("<html><body><p>Alert</p><p>Unauthorized Buying-</p>" + "<br/>" +

                "<table style='border:1px solid black ;padding: 5px';>");

        sb.append("<tbody>" +

                "<tr>" +

                "<th style='border:1px solid black;padding: 5px'>PartnerName</th>" +

                "<th style='border:1px solid black;padding: 5px'>Brand Name</th>" +

                "<th style='border:1px solid black;padding: 5px'>Brand Value</th>" +

                "<th style='border:1px solid black;padding: 5px'>Created At</th>" +

                "<th style='border:1px solid black;padding: 5px'>Reason</th>" +

                "</tr>");

        for (NonSdBuying entry : nsb) {

            CustomRetailer customRetailer = retailerService.getFofoRetailer(entry.getFofoId());

            List<Integer> brandIds = Collections.singletonList(entry.getBrandId());

            BrandCatalog brandsDisplay = brandsRepository.selectByIds(brandIds).get(0);

            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'>" + brandsDisplay.getName() + "</td>");

            sb.append("<td style='border:1px solid black;padding: 5px'>" + entry.getBrandValue() + "</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.getReason() + "</td>");

            sb.append("</tr>");

        }

        sb.append("</tbody></table></body></html>");

        return sb.toString();

    }

    //Non Sd Buying

    public void reviewNonSdBuyingBrand() throws

            ProfitMandiBusinessException, MessagingException, UnsupportedEncodingException {

        List<NonSdBuying> nonSdByuingActiveList = nonSdBuyingRepository.selectAllActiveNonSDBuyingList(true);

        Map<Integer, NonSdBuying> unAuthorizedBuyingMap = nonSdByuingActiveList.stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));

        if (!unAuthorizedBuyingMap.isEmpty()) {

            for (Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_ABM), true).entrySet()) {

                List<NonSdBuying> unAuthorizedfilteredRows = storeGuyEntry.getValue().stream()

                        .map(x -> unAuthorizedBuyingMap.get(x)).filter(x -> x != null).collect(Collectors.toList());

                if (!unAuthorizedfilteredRows.isEmpty()) {

                    String subject = "Unauthorized Buying";

                    String messageText = this.getMessageForUnauthorizedBuying(unAuthorizedfilteredRows);

                    MimeMessage message = gmailRelaySender.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);

                    gmailRelaySender.send(message);

                    LOGGER.info("unAuthorizedfilteredRows {}", unAuthorizedfilteredRows);

                }

            }

        }

    }