WebSVN – SmartDukaan – Diff – /trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/PerformanceServiceImpl.java

 package com.spice.profitmandi.service;
+import java.text.DecimalFormat;
+import java.text.NumberFormat;
+import java.time.Duration;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Locale;
+import java.util.Map;
+import java.util.Map.Entry;
+import java.util.Set;
+import java.util.stream.Collectors;
+import javax.mail.internet.InternetAddress;
+import javax.mail.internet.MimeMessage;
+import com.spice.profitmandi.dao.model.*;
+import com.spice.profitmandi.service.transaction.SDCreditService;
+import org.apache.commons.io.output.ByteArrayOutputStream;
+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.core.io.InputStreamSource;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.mail.javamail.MimeMessageHelper;
+import org.springframework.stereotype.Component;
 import com.spice.profitmandi.common.model.CustomRetailer;
 import com.spice.profitmandi.common.util.FileUtil;
 import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
 import com.spice.profitmandi.dao.entity.fofo.RetailerFilter;
 import com.spice.profitmandi.dao.entity.transaction.Loan;
-import com.spice.profitmandi.dao.model.BillingDaysAvg;
-import com.spice.profitmandi.dao.model.LastSaleDateModel;
-import com.spice.profitmandi.dao.model.RetailerFilterModel;
-import com.spice.profitmandi.dao.model.RetailerPeformanceFilterModel;
 import com.spice.profitmandi.dao.repository.cs.CsService;
 import com.spice.profitmandi.dao.repository.dtr.RetailerFilterRepository;
 import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
 import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
 import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
 import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
-import com.spice.profitmandi.service.transaction.SDCreditService;
+import com.spice.profitmandi.service.transaction.SDCreditServiceImpl;
 import com.spice.profitmandi.service.user.RetailerService;
-import org.apache.commons.io.output.ByteArrayOutputStream;
-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.core.io.InputStreamSource;
-import org.springframework.mail.javamail.JavaMailSender;
-import org.springframework.mail.javamail.MimeMessageHelper;
-import org.springframework.stereotype.Component;
-import javax.mail.internet.InternetAddress;
-import javax.mail.internet.MimeMessage;
-import java.text.DecimalFormat;
-import java.text.NumberFormat;
-import java.time.Duration;
-import java.time.LocalDate;
-import java.time.LocalDateTime;
-import java.time.LocalTime;
-import java.util.*;
-import java.util.Map.Entry;
-import java.util.stream.Collectors;
 @Component
 public class PerformanceServiceImpl implements PerformanceService {
     @Autowired
     private FofoOrderItemRepository fofoOrderItemRepository;
     @Autowired
-    private SDCreditService sdCreditServiceImpl;
+    private SDCreditService sdCreditService;
     @Autowired
     private RetailerService retailerService;
     @Autowired
         Map<Integer, Double> tertiaryPartner = new HashMap<Integer, Double>();
         if (retailerFilter.isCredit()) {
-            List<Loan> dueDateLoans = sdCreditServiceImpl.getDueDateCrossLoan();
+            List<Loan> dueDateLoans = sdCreditService.getDueDateCrossLoan();
-            List<Loan> defaultLoans = sdCreditServiceImpl.getDefaultLoan();
+            List<Loan> defaultLoans = sdCreditService.getDefaultLoan();
             if (!defaultLoans.isEmpty()) {
                 defaultdateMap = defaultLoans.stream().collect(Collectors.groupingBy(x -> x.getFofoId()));
+            }
             if (!dueDateLoans.isEmpty()) {
         for (Entry<Integer, CustomRetailer> customRetailerEntry : customRetailers.entrySet()) {
             int fofoId = customRetailerEntry.getKey();
             RetailerPeformanceFilterModel retailerPeformanceFilterModel = new RetailerPeformanceFilterModel();
-            retailerPeformanceFilterModel.setActivationType(customRetailerEntry.getValue().getActivationType());
-            retailerPeformanceFilterModel.setState(customRetailerEntry.getValue().getAddress().getState());
             if (retailerFilter.isCredit()) {
                 if (!duedateMap.isEmpty()) {
                     if (duedateMap.containsKey(fofoId)) {
                         retailerPeformanceFilterModel.setCredit("Due");
         return retailerPerPeformanceFilterModels;
+    }
     public void sendPartnerPerformanceEmail(Map<Integer, RetailerPeformanceFilterModel> partnersPerformanceMap, RetailerFilterModel retailerFilterModel, Map<Integer, CustomRetailer> customRetailers) throws Exception {
         Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
+        Map<Integer, FofoReportingModel> fofoReportingModelMap = csService.getPartnerIdSalesHeaders();
         LOGGER.info("retailerFilterModel {}", retailerFilterModel);
         for (Entry<String, Set<Integer>> storeGuyEntry : storeGuyMap.entrySet()) {
             Set<Integer> fofoIds = storeGuyEntry.getValue();
             List<List<?>> rows = new ArrayList<>();
-            List<String> headers = Arrays.asList("Partner Name", "Code", "ActivationType", "State", "Credit- Due/Default", "Billing To Deliver", "Investment- Lower Than " + retailerFilterModel.getInvestmentPct() + "%", "Last Secondary-" + retailerFilterModel.getSecondaryDays() + "days", "Last Tertiary-" + retailerFilterModel.getTertiaryDays() + "days", "MTD Secondary < LMTD-" + retailerFilterModel.getMtdsPct() + "%", "MTD Tertiary < LMTD-" + retailerFilterModel.getMtdtPct() + "%");
+            List<String> headers = Arrays.asList("Partner Name", "Code","Territory Manager","Regional Manager","Credit- Due/Default", "Billing To Deliver", "Investment- Lower Than " + retailerFilterModel.getInvestmentPct() + "%", "Last Secondary-" + retailerFilterModel.getSecondaryDays() + "days", "Last Tertiary-" + retailerFilterModel.getTertiaryDays() + "days", "MTD Secondary < LMTD-" + retailerFilterModel.getMtdsPct() + "%", "MTD Tertiary < LMTD-" + retailerFilterModel.getMtdtPct() + "%");
             LOGGER.info("headers {}", headers);
             for (Integer fofoId : fofoIds) {
                 RetailerPeformanceFilterModel retailerPerformanceFilterModel = partnersPerformanceMap.get(fofoId);
                 LOGGER.info("retailerPerformanceFilterModel {}", retailerPerformanceFilterModel);
                 if (retailerPerformanceFilterModel != null) {
-                    rows.add(Arrays.asList(customRetailers.get(fofoId).getBusinessName(), customRetailers.get(fofoId).getCode(), retailerPerformanceFilterModel.getActivationType(), retailerPerformanceFilterModel.getState(), retailerPerformanceFilterModel.getCredit(), retailerPerformanceFilterModel.getBilling(), retailerPerformanceFilterModel.getInvestment(), retailerPerformanceFilterModel.getSecondaryDays(), retailerPerformanceFilterModel.getTertiaryDays(), retailerPerformanceFilterModel.getMtds(), retailerPerformanceFilterModel.getMtdt()));
+                    rows.add(Arrays.asList(customRetailers.get(fofoId).getBusinessName(), customRetailers.get(fofoId).getCode(), fofoReportingModelMap.get(fofoId).getTerritoryManager(),fofoReportingModelMap.get(fofoId).getRegionalManager(), retailerPerformanceFilterModel.getCredit(), retailerPerformanceFilterModel.getBilling(), retailerPerformanceFilterModel.getInvestment(), retailerPerformanceFilterModel.getSecondaryDays(),retailerPerformanceFilterModel.getTertiaryDays(), retailerPerformanceFilterModel.getMtds(), retailerPerformanceFilterModel.getMtdt()));
+                }
+            }
             if (!rows.isEmpty()) {
                 ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
                 this.sendMailWithAttachment(mailSender, new String[]{storeGuyEntry.getKey()}, null, "Partner Performance", "PFA", "PartnerPerformance.csv", new ByteArrayResource(baos.toByteArray()));
+            }
+        }
+    }
     public void sendMailWithAttachment(JavaMailSender mailSender, String[] emailTo, String[] cc, String subject, String body, String fileName, InputStreamSource inputStreamSource) throws Exception {
         MimeMessage message = mailSender.createMimeMessage();
         MimeMessageHelper helper = new MimeMessageHelper(message, true);

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/service/PerformanceServiceImpl.java – Rev 32229 → 32245