Rev 35577 | Blame | Compare with Previous | Last modification | View Log | RSS feed
package com.spice.profitmandi.dao.service;import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;import com.spice.profitmandi.common.model.ProfitMandiConstants;import com.spice.profitmandi.common.util.FileUtil;import com.spice.profitmandi.common.util.Utils;import com.spice.profitmandi.dao.entity.auth.AuthUser;import com.spice.profitmandi.dao.enumuration.cs.EscalationType;import com.spice.profitmandi.dao.model.WarehouseItemAgeingModel;import com.spice.profitmandi.dao.model.purchaseSaleRatio.CatalogAgedModel;import com.spice.profitmandi.dao.repository.auth.AuthRepository;import com.spice.profitmandi.dao.repository.cs.CsService;import com.spice.profitmandi.dao.repository.warehouse.WarehouseSupplierInvoiceRepository;import com.spice.profitmandi.service.AuthService;import com.spice.profitmandi.service.mail.MailOutboxService;import org.apache.logging.log4j.LogManager;import org.apache.logging.log4j.Logger;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.core.io.ByteArrayResource;import org.springframework.mail.javamail.JavaMailSender;import org.springframework.mail.javamail.MimeMessageHelper;import org.springframework.stereotype.Service;import javax.mail.MessagingException;import javax.mail.internet.InternetAddress;import javax.mail.internet.MimeMessage;import java.io.UnsupportedEncodingException;import java.time.LocalDateTime;import java.util.ArrayList;import java.util.Arrays;import java.util.Comparator;import java.util.List;import java.util.stream.Collectors;@Servicepublic class PurSaleServiceImpl implements PurSaleService {private static final Logger LOGGER = LogManager.getLogger(PurSaleServiceImpl.class);@AutowiredWarehouseSupplierInvoiceRepository warehouseSupplierInvoiceRepository;@AutowiredJavaMailSender googleMailSender;@AutowiredMailOutboxService mailOutboxService;@AutowiredAuthService authService;@AutowiredAuthRepository authRepository;@AutowiredCsService csService;@Overridepublic void moreThen10DaysEgedStockReport() throws MessagingException, UnsupportedEncodingException, ProfitMandiBusinessException {LocalDateTime startDate = LocalDateTime.now().minusMonths(3);LocalDateTime endDate = LocalDateTime.now();List<CatalogAgedModel> moreThen10DaysAgedCatalogModels = getCatalogModelsOlderThan10Days(startDate, endDate);StringBuilder sb = new StringBuilder();sb.append("<html><body><b>Aging Stock List: Items that are 4 days old or older (Date Range - " + startDate.toLocalDate() + " To " + endDate.toLocalDate() + " )</b>" + "<br/><table style='border:1px solid black ;padding: 5px ;bgColor=green'>");sb.append("<tbody>" +"<tr>" +"<th style='border:1px solid black;padding: 5px'>No.</th>" +"<th style='border:1px solid black;padding: 5px'>Item Id.</th>" +"<th style='border:1px solid black;padding: 5px'>Brand</th>" +"<th style='border:1px solid black;padding: 5px'>Vendor</th>" +"<th style='border:1px solid black;padding: 5px'>Category</th>" +"<th style='border:1px solid black;padding: 5px'>Model</th>" +"<th style='border:1px solid black;padding: 5px'>Model Name</th>" +"<th style='border:1px solid black;padding: 5px'>Colour</th>" +"<th style='border:1px solid black;padding: 5px'>Purchase</th>" +"<th style='border:1px solid black;padding: 5px'>Sold</th>" +"<th style='border:1px solid black;padding: 5px'>Unsold</th>" +"<th style='border:1px solid black;padding: 5px'>Age</th>" +"</tr>");moreThen10DaysAgedCatalogModels.sort(Comparator.comparingInt(CatalogAgedModel::getAge).reversed());// Log first few records to verify itemId is populatedLOGGER.info("moreThen10DaysEgedStockReport - Total records: {}", moreThen10DaysAgedCatalogModels.size());moreThen10DaysAgedCatalogModels.stream().limit(5).forEach(model ->LOGGER.info("ItemId: {}, Brand: {}, Model: {}", model.getItemId(), model.getBrand(), model.getModel()));int i = 1;for (CatalogAgedModel catalogAgedModel : moreThen10DaysAgedCatalogModels) {sb.append("<tr>");sb.append("<td style='border:1px solid black;padding: 5px'>" + (i++) + "</td>");sb.append("<td style='border:1px solid black;padding: 5px'>" + catalogAgedModel.getItemId() + "</td>");sb.append("<td style='border:1px solid black;padding: 5px'>" + catalogAgedModel.getBrand() + "</td>");sb.append("<td style='border:1px solid black;padding: 5px'>" + catalogAgedModel.getSupplier() + "</td>");sb.append("<td style='border:1px solid black;padding: 5px'>" + catalogAgedModel.getStatus() + "</td>");sb.append("<td style='border:1px solid black;padding: 5px'>" + catalogAgedModel.getModelName() + "</td>");sb.append("<td style='border:1px solid black;padding: 5px'>" + catalogAgedModel.getModel() + "</td>");sb.append("<td style='border:1px solid black;padding: 5px'>" + catalogAgedModel.getColor().replaceFirst("f_", "") + "</td>");sb.append("<td style='border:1px solid black;padding: 5px'>" + catalogAgedModel.getPurchase() + "</td>");sb.append("<td style='border:1px solid black;padding: 5px'>" + catalogAgedModel.getSold() + "</td>");sb.append("<td style='border:1px solid black;padding: 5px'>" + catalogAgedModel.getUnsold() + "</td>");sb.append("<td style='border:1px solid black;padding: 5px'>" + catalogAgedModel.getAge() + "</td>");sb.append("</tr>");}sb.append("</tbody>");sb.append("</table>");List<WarehouseItemAgeingModel> warehouseAgeQtyModels = getAgeingModelsGtDays(startDate, endDate, 4);org.apache.commons.io.output.ByteArrayOutputStream byteArrayOutputStream = null;try {byteArrayOutputStream = FileUtil.getCSVByteStream(Arrays.asList("Vendor", "Category", "Brand", "Model", "Color","Age", "Warehouse", "Grn On", "In Stock"),warehouseAgeQtyModels.stream().map(x -> x.toRow()).collect(Collectors.toList()));} catch (Exception e) {throw new RuntimeException(e);}sb.append("</body></html>");Utils.Attachment attachment1 = new Utils.Attachment("warehousewise-aged.csv", new ByteArrayResource(byteArrayOutputStream.toByteArray()));System.out.println("Sending mail ....");//Utils.sendMailWithAttachments(mailSender, new String[]{"amit.gupta@smartdukaan.com"}, new String[]{"cnc.center@shop2020.in"}, mailSubject, "Dear Partner, \nPlease find attached Credit Note(s)", attachments.toArray(new Utils.Attachment[0]));//System.out.println("Mail sent ....");//break;//Utils.sendMailWithAttachments(mailSender, new String[]{customRetailer.getEmail()}, new String[]{"cnc.center@shop2020.in"}, mailSubject, "Dear Partner, \nPlease find attached Credit Note(s)", attachments.toArray(new Utils.Attachment[0]));String subject = "Aging Stock Report: 4 Days or Older";String messageText = sb.toString();MimeMessage message = googleMailSender.createMimeMessage();MimeMessageHelper helper = new MimeMessageHelper(message, true);List<AuthUser> accountsAuthUserList = csService.getAuthUserIds(ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS, Arrays.asList(EscalationType.L1, EscalationType.L2));List<String> accountTeamMails = accountsAuthUserList.stream().map(x -> x.getEmailId()).collect(Collectors.toList());accountTeamMails.add("neeraj.gupta@smartdukaan.com");List<AuthUser> salesAuthUserList = csService.getAuthUserIds(ProfitMandiConstants.TICKET_CATEGORY_SALES, Arrays.asList(EscalationType.L1, EscalationType.L2));List<String> salesTeamMails = salesAuthUserList.stream().map(x -> x.getEmailId()).collect(Collectors.toList());List<AuthUser> abmAuthUserList = csService.getAuthUserIds(ProfitMandiConstants.TICKET_CATEGORY_ABM, Arrays.asList(EscalationType.L1, EscalationType.L2));List<String> abmTeamMails = abmAuthUserList.stream().map(x -> x.getEmailId()).collect(Collectors.toList());List<AuthUser> categoryAuthUserList = csService.getAuthUserIds(ProfitMandiConstants.TICKET_CATEGORY_ABM, Arrays.asList(EscalationType.L1, EscalationType.L2, EscalationType.L3));List<String> categoryTeamMails = categoryAuthUserList.stream().map(x -> x.getEmailId()).collect(Collectors.toList());List<String> allEmails = new ArrayList<>(Arrays.asList("sm@smartdukaan.com","raj.singh@smartdukaan.com","ranu.rajput@smartdukaan.com","tarun.verma@smartdukaan.com"));// niranjan kala(authId -54) Team Emails,List<Integer> allReportees = authService.getAllReportees(54);List<AuthUser> authUsers = authRepository.selectByIds(allReportees);List<String> categotyTeamEmails = authUsers.stream().map(x -> x.getEmailId()).collect(Collectors.toList());allEmails.addAll(categotyTeamEmails);String[] emailTo = allEmails.toArray(new String[allEmails.size()]);helper.setSubject(subject);helper.setText(messageText, true);helper.setTo(emailTo);List<String> bccEmails = new ArrayList<>();bccEmails.addAll(salesTeamMails);bccEmails.addAll(accountTeamMails);bccEmails.addAll(categoryTeamMails);bccEmails.addAll(abmTeamMails);String[] emailBcc = bccEmails.toArray(new String[0]);helper.setBcc(emailBcc);InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smart Dukaan");helper.setFrom(senderAddress);try {mailOutboxService.queueMailWithAttachmentsViaGoogle(emailTo, null, emailBcc, subject, messageText, true, "PurSaleServiceImpl.moreThen10DaysEgedStockReport", attachment1);//Utils.sendMailWithAttachments(googleMailSender, new String[]{"amit.gupta@smartdukaan.com"}, null, null, subject, messageText, true, attachment1);} catch (Exception e) {throw new RuntimeException(e);}}@Overridepublic List<CatalogAgedModel> getCatalogModelsOlderThan10Days(LocalDateTime startDate, LocalDateTime endDate) {// Using selectCatalogAgeWithItemId to get itemId for email reportList<CatalogAgedModel> fiterCatalogAgedModels =warehouseSupplierInvoiceRepository.selectCatalogAgeWithItemId(startDate, endDate, null, 0, null).stream().filter(x -> x.getAge() >= 4 && x.getUnsold() > 0).collect(Collectors.toList());LOGGER.info("fiterCatalogAgedModels - " + fiterCatalogAgedModels);return fiterCatalogAgedModels;}private List<WarehouseItemAgeingModel> getAgeingModelsGtDays(LocalDateTime startDate, LocalDateTime endDate, int days) {List<WarehouseItemAgeingModel> fiterCatalogAgedModels =warehouseSupplierInvoiceRepository.selectWarehouseItemAgeing(startDate, endDate, null, 0, null).stream().filter(x -> x.getAge() >= days).sorted(Comparator.comparing(WarehouseItemAgeingModel::getAge).reversed()).collect(Collectors.toList());return fiterCatalogAgedModels;}}