Rev 35061 | Rev 35078 | Go to most recent revision | 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.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 org.apache.logging.log4j.LogManager;import org.apache.logging.log4j.Logger;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.mail.javamail.JavaMailSender;import org.springframework.mail.javamail.MimeMessageHelper;import org.springframework.stereotype.Service;import org.springframework.transaction.annotation.Transactional;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;@Service@Transactional(rollbackFor = Throwable.class)public class PurSaleServiceImpl implements PurSaleService {private static final Logger LOGGER = LogManager.getLogger(PurSaleServiceImpl.class);@AutowiredWarehouseSupplierInvoiceRepository warehouseSupplierInvoiceRepository;@AutowiredJavaMailSender mailSender;@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'>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'>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());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.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>");if (catalogAgedModel.getBrand().equals("Samsung")) {sb.append("<td style='border:1px solid black;padding: 5px'>" + catalogAgedModel.getModel() + "</td>");} else {sb.append("<td style='border:1px solid black;padding: 5px'>" + catalogAgedModel.getModelName() + "</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> warehouseAgeQtyModel = getAgeingModelsGtDays(startDate, endDate, 4);sb.append("<br /><br /><b>Warehouse Stock</b>");sb.append("<table style='border:1px solid black;border-collapse: collapse;' ><thead>").append("<th>No.</th>").append("<th>Vendor</th>").append("<th>Category</th>").append("<th>Brand</th>").append("<th>Model</th>").append("<th>Color</th>").append("<th>Age</th>").append("<th>Warehouse</th>").append("<th>Grn On</th>").append("<th>In Stock</th>").append("</thead>").append("<tbody>");i = 0;for (WarehouseItemAgeingModel warehouseItemAgeingModel : warehouseAgeQtyModel) {sb.append("<tr>").append("<td style='border:1px solid black;padding:5px'>").append(++i).append("</td>").append("<td style='border:1px solid black;padding:5px'>").append(warehouseItemAgeingModel.getSupplierName()).append("</td>").append("<td style='border:1px solid black;padding:5px'>").append(warehouseItemAgeingModel.getStatus()).append("</td>").append("<td style='border:1px solid black;padding:5px'>").append(warehouseItemAgeingModel.getBrand()).append("</td>").append("<td style='border:1px solid black;padding:5px'>").append(warehouseItemAgeingModel.getModelName() + " " + warehouseItemAgeingModel.getModelNumber()).append("</td>").append("<td style='border:1px solid black;padding:5px'>").append(warehouseItemAgeingModel.getColor()).append("</td>").append("<td style='border:1px solid black;padding:5px'>").append(warehouseItemAgeingModel.getAge()).append("</td>").append("<td style='border:1px solid black;padding:5px'>").append(warehouseItemAgeingModel.getWarehouseName()).append("</td>").append("<td style='border:1px solid black;padding:5px'>").append(warehouseItemAgeingModel.getCreated()).append("</td>").append("<td style='border:1px solid black;padding:5px'>").append(warehouseItemAgeingModel.getCurrentQuantity()).append("</td>").append("</tr>");}sb.append("</tbody></table></body></html>");String subject = "Aging Stock Report: 4 Days or Older";String messageText = sb.toString();MimeMessage message = mailSender.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","tarun.verma@smartdukaan.com","amit.gupta@smartdukaan.com"));// niranjan kala(authId -54) Team Emails,List<Integer> allReportees = authService.getAllReportees(54);List<AuthUser> authUsers = authRepository.selectAllAuthUserByIds(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);mailSender.send(message);}@Overridepublic List<CatalogAgedModel> getCatalogModelsOlderThan10Days(LocalDateTime startDate, LocalDateTime endDate) {List<CatalogAgedModel> fiterCatalogAgedModels =warehouseSupplierInvoiceRepository.selectCatalogAge(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;}}