WebSVN – SmartDukaan – Diff – /trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasksTest.java

 import javax.mail.internet.InternetAddress;
 import javax.mail.internet.MimeMessage;
 import java.io.*;
 import java.math.BigDecimal;
 import java.time.*;
+import java.time.format.DateTimeFormatter;
 import java.time.temporal.ChronoUnit;
 import java.util.*;
 import java.util.stream.Collectors;
 @Component
             // Otherwise, use today
             startOfToday = LocalDate.now().atStartOfDay();
             previousDay = startOfToday.with(LocalTime.MAX).minusDays(1);
+        }
-        Map<Integer, CustomRetailer> customRetailers = retailerService.getAllFofoRetailersInternalFalse();
+/*        Map<Integer, CustomRetailer> customRetailers = retailerService.getAllFofoRetailersInternalFalse();
-        List<Integer> retailerIds = customRetailers.values().stream().map(CustomRetailer::getPartnerId).collect(Collectors.toList());
+        List<Integer> retailerIds = customRetailers.values().stream().map(CustomRetailer::getPartnerId).collect(Collectors.toList());*/
-/*        List<Integer> retailerIds = Arrays.asList(175139494);
+        List<Integer> retailerIds = Arrays.asList(175139440,175139441);
-        Map<Integer,CustomRetailer> customRetailers = retailerService.getFofoRetailers(retailerIds);*/
+        Map<Integer,CustomRetailer> customRetailers = retailerService.getFofoRetailers(retailerIds);
         //partner daily investment
         List<Loan> defaultLoans = sdCreditService.getDefaultLoans();
         Map<Integer,List<Loan>> defaultLoanMap = defaultLoans.stream().collect(Collectors.groupingBy(Loan::getFofoId));
         Map<Integer, Long> currentMonthPartnerReturnOrderInfoModelMap = currentMonthReturnOrderInfoModels.stream().collect(Collectors.groupingBy(x -> x.getRetailerId(), Collectors.summingLong(x -> Math.round(x.getRefundAmount()))));
         List<Order> currentMonthRtoRefundOrders = orderRepository.selectAllOrderDatesBetweenByStatus(currentMonthStartDate, currentMonthEndDate, OrderStatus.RTO_REFUNDED);
         Map<Integer, Long> currentMonthRtoRefundOrderMap = currentMonthRtoRefundOrders.stream().collect(Collectors.groupingBy(x -> x.getRetailerId(), Collectors.summingLong(x -> Math.round(x.getTotalAmount()))));
+        List<ReturnOrderInfoModel> yesterdayReturnOrderInfoModels = returnOrderInfoRepository.selectAllByBetweenDate(previousDay.toLocalDate().atStartOfDay(), previousDay);
+        Map<Integer, Long> yesterdayReturnOrderInfoModelMap = yesterdayReturnOrderInfoModels.stream().collect(Collectors.groupingBy(x -> x.getRetailerId(), Collectors.summingLong(x -> Math.round(x.getRefundAmount()))));
+        List<Order> yesterdayRtoRefundOrders = orderRepository.selectAllOrderDatesBetweenByStatus(previousDay.toLocalDate().atStartOfDay(), previousDay, OrderStatus.RTO_REFUNDED);
+        Map<Integer, Long> yesterdayRtoRefundOrderMap = yesterdayRtoRefundOrders.stream().collect(Collectors.groupingBy(x -> x.getRetailerId(), Collectors.summingLong(x -> Math.round(x.getTotalAmount()))));
+        List<ReturnOrderInfoModel> dayBeforeYesterdayReturnOrderInfoModels = returnOrderInfoRepository.selectAllByBetweenDate(previousDay.toLocalDate().atStartOfDay().minusDays(1), previousDay.minusDays(1));
+        Map<Integer, Long> dayBeforeYesterdayReturnOrderInfoModelMap = dayBeforeYesterdayReturnOrderInfoModels.stream().collect(Collectors.groupingBy(x -> x.getRetailerId(), Collectors.summingLong(x -> Math.round(x.getRefundAmount()))));
+        List<Order> dayBeforeYesterdayRtoRefundOrders = orderRepository.selectAllOrderDatesBetweenByStatus(previousDay.toLocalDate().atStartOfDay().minusDays(1), previousDay.minusDays(1), OrderStatus.RTO_REFUNDED);
+        Map<Integer, Long> dayBeforeYesterdayRtoRefundOrderMap = dayBeforeYesterdayRtoRefundOrders.stream().collect(Collectors.groupingBy(x -> x.getRetailerId(), Collectors.summingLong(x -> Math.round(x.getTotalAmount()))));
-    //  last month return data
+        //  last month return data
         YearMonth lastMonth = currentMonth.minusMonths(1);
         String lastMonthStringValue = String.valueOf(lastMonth);
         LocalDateTime lastMontStartDate = lastMonth.atDay(1).atStartOfDay();
         LocalDateTime lastMonthEndDate = lastMonth.atEndOfMonth().atTime(23, 59, 59);
         LocalDateTime twoMonthsAgoStartDate = twoMonthsAgo.atDay(1).atStartOfDay();
         LocalDateTime twoMonthsAgoEndDate = twoMonthsAgo.atEndOfMonth().atTime(23, 59, 59);
         List<ReturnOrderInfoModel> twoMonthAgoReturnOrderInfoModels = returnOrderInfoRepository.selectAllByBetweenDate(twoMonthsAgoStartDate, twoMonthsAgoEndDate);
         Map<Integer, Long> twoMonthAgoPartnerReturnOrderInfoModelMap = twoMonthAgoReturnOrderInfoModels.stream().collect(Collectors.groupingBy(x -> x.getRetailerId(), Collectors.summingLong(x -> Math.round(x.getRefundAmount()))));
-LOGGER.info("twoMonthAgoReturnOrderInfoModels {}",twoMonthAgoReturnOrderInfoModels);
         List<Order> twoMonthRtoRefundOrders = orderRepository.selectAllOrderDatesBetweenByStatus(twoMonthsAgoStartDate, twoMonthsAgoEndDate, OrderStatus.RTO_REFUNDED);
         Map<Integer, Long> twoMonthAgoRtoRefundOrderMap = twoMonthRtoRefundOrders.stream().collect(Collectors.groupingBy(x -> x.getRetailerId(), Collectors.summingLong(x -> Math.round(x.getTotalAmount()))));
-        LOGGER.info("twoMonthRtoRefundOrders {}",twoMonthRtoRefundOrders);
         Map<Integer , String> assessmentMap = new HashMap<>();
         Map<Integer , String> zeroBillingMap = new HashMap<>();
         Map<Integer , Float> billingNeededMap = new HashMap<>();
         Map<Integer , Integer> countAMap = new HashMap<>();
         Map<Integer,Map<String, BrandStockPrice>> fofoBrandStockPriceMap = new HashMap<>();
         Map<Integer,Long> fofoTotalMtdSecondaryMap = new HashMap<>();
+        Map<Integer,Long> fofoYesterdaySecondaryMap = new HashMap<>();
+        Map<Integer,Long> fofoDayBeforeYesterdaySecondaryMap = new HashMap<>();
         Map<Integer,Map<String, Long>> fofoBrandWiseMtdSecondaryMap = new HashMap<>();
         Map<Integer,Double> fofoTotalMtdTertiaryMap = new HashMap<>();
             Map<Integer, Double> secondaryMtd = orderRepository.selectOrderValueBetweenBillingDatesGroupByFofoId(Arrays.asList(fofoId),
                     startOfToday.withDayOfMonth(1), previousDay).stream().collect(Collectors.toMap(x -> x.getId(), x -> x.getAmount()));
+            //yesterday secondary
+            Map<Integer, Double> dayBeforeYesterdaySecondary = orderRepository.selectOrderValueBetweenBillingDatesGroupByFofoId(Arrays.asList(fofoId),
+                    previousDay.toLocalDate().atStartOfDay().minusDays(1), previousDay.minusDays(1)).stream().collect(Collectors.toMap(x -> x.getId(), x -> x.getAmount()));
+            double dayBeforeYesterdayAfterReturnSecondary = dayBeforeYesterdaySecondary.getOrDefault(fofoId,0d) - (dayBeforeYesterdayReturnOrderInfoModelMap.getOrDefault(fofoId,0l) + dayBeforeYesterdayRtoRefundOrderMap.getOrDefault(fofoId,0l));
+            fofoDayBeforeYesterdaySecondaryMap.put(fofoId, (long) dayBeforeYesterdayAfterReturnSecondary);
+            //day before secondary
+            Map<Integer, Double> yesterDaySecondary = orderRepository.selectOrderValueBetweenBillingDatesGroupByFofoId(Arrays.asList(fofoId),
+                    previousDay.toLocalDate().atStartOfDay(), previousDay).stream().collect(Collectors.toMap(x -> x.getId(), x -> x.getAmount()));
+            double yesterDayAfterReturnSecondary = yesterDaySecondary.getOrDefault(fofoId,0d) - (yesterdayReturnOrderInfoModelMap.getOrDefault(fofoId,0l) + yesterdayRtoRefundOrderMap.getOrDefault(fofoId,0l));
+            fofoYesterdaySecondaryMap.put(fofoId, (long) yesterDayAfterReturnSecondary);
             double secondaryAchievedMtd = secondaryMtd.getOrDefault(fofoId, 0.0);
             double currentMonthNetSecondary = secondaryAchievedMtd - currentMonthReturn;
             double currentMonthSecondaryPercent = currentSecondaryTarget == 0 ? 0.0 : Math.round(Math.abs((secondaryAchievedMtd / currentSecondaryTarget) * 100));
                     zeroBilling = "-";
+                }
                 zeroBillingMap.put(fofoId,zeroBilling);
                 float billingNeeded = 0f;
-                if(drrPercentDisplay >= 110 ){
+                if(drrPercentDisplay >= 110 && todayRequiredDrr > 0 ){
                     billingNeeded = (float) todayRequiredDrr;
                 }else {
                     billingNeeded = 0f;
+                }
                 billingNeededMap.put(fofoId,billingNeeded);
                 currentMonthStringValue, "", "", "", "", "", "",
                 "","", "", "", "", "", "", "", "", "", "", "", "", "",
                 "", "", "", "", "", "", "", "", "", "", "", "", "",
-                "", "", "", "", "", "", "", "", "", "", "", "", ""
+                "", "", "", "", "", "", "", "", "", "", "", "", "","",""
         );
         List<String> headers2 = Arrays.asList(
                 "Assessment","Zero billing","Billing needed","Counta",
                 "Counter Potential", "Short investment", "Default", "INVESTMENT LEVEL", "Loan", "PO value", "Agreed investment",
                 "Wallet", "po+bill", "MONTH BEGINNING DRR", "REQ DRR", "Drr %", "Last billing Done", "Slab",
               "Total Stock",  "Apple","Xiaomi", "Vivo", "Tecno", "Samsung", "Realme", "Oppo", "OnePlus", "POCO", "Lava", "Itel", "Almost New",
               "Total Secondary", "Apple", "Xiaomi", "Vivo", "Tecno", "Samsung", "Realme", "Oppo", "OnePlus", "POCO", "Lava", "Itel", "Almost New",
-              "Total Tertiary",  "Apple", "Xiaomi", "Vivo", "Tecno", "Samsung", "Realme", "Oppo", "OnePlus", "POCO", "Lava", "Itel", "Almost New"
+              "Total Tertiary",  "Apple", "Xiaomi", "Vivo", "Tecno", "Samsung", "Realme", "Oppo", "OnePlus", "POCO", "Lava", "Itel", "Almost New",
+                "YesterDay Seconday","Day Before Yesterday Secondary"
         );
         headerGroup.add(headers1);
         headerGroup.add(headers2);
         List<List<?>> rows = new ArrayList<>();
         for (Map.Entry<Integer, BIRetailerModel> entry : biRetailerModelMap.entrySet()) {
+            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("dd/MM/yyyy");
             Integer fofoId = entry.getKey();
             User user = userRepository.selectById(fofoId);
             LocalDateTime walletCreationDate = userWalletHistoryRepository.selectFirstCreatedDate(fofoId);
             BIRetailerModel retailer = entry.getValue();
             BiSecondaryModel twoAgo = monthlyData.getOrDefault(currentMonth.minusMonths(2), new BiSecondaryModel(0,0,0,0,0,0,0));
             List<Object> row = new ArrayList<>();
             row.addAll(Arrays.asList(
                     assessmentMap.get(fofoId),zeroBillingMap.get(fofoId),billingNeededMap.get(fofoId),countAMap.get(fofoId),
-                    retailer.getBmName(),fofoId ,"https://partners.smartdukaan.com/partnerPerformance?fofoId="+fofoId,walletCreationDate,user.getCreateTimestamp(), retailer.getCode(), retailer.getArea(), retailer.getCity(),  retailer.getStoreName(), retailer.getStatus(),
+                    retailer.getBmName(),fofoId ,"https://partners.smartdukaan.com/partnerPerformance?fofoId="+fofoId,walletCreationDate.format(formatter),(user.getCreateTimestamp()).format(formatter), retailer.getCode(), retailer.getArea(), retailer.getCity(),  retailer.getStoreName(), retailer.getStatus(),
                     retailer.getCategory(),  retailer.getSalesManager(), retailer.getRbm()
             ));
                     brandTertiaryMap.getOrDefault("POCO", 0d),
                     brandTertiaryMap.getOrDefault("Lava", 0d),
                     brandTertiaryMap.getOrDefault("Itel", 0d),
                     brandTertiaryMap.getOrDefault("Almost New", 0d)
             ));
+            row.addAll(Arrays.asList(
+                    fofoYesterdaySecondaryMap.get(fofoId),
+                    fofoDayBeforeYesterdaySecondaryMap.get(fofoId)
+            ));
             rows.add(row);
+        }
         // Send to email
 //        ByteArrayOutputStream csvStream = FileUtil.getCSVByteStreamWithMultiHeaders(headerGroup, rows);
         ByteArrayOutputStream csvStream = getExcelStreamWithMultiHeaders(headerGroup, rows);
         String fileName = "BI-Retailer-Monthly-Report-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".xlsx";
-        String[] sendToArray = new String[]{"ranu.rajput@smartdukaan.com","ashutosh.verma@smartdukaan.com","sm@smartdukaan.com","raj.singh@smartdukaan.com"};
+//        String[] sendToArray = new String[]{"ranu.rajput@smartdukaan.com","ashutosh.verma@smartdukaan.com","sm@smartdukaan.com","raj.singh@smartdukaan.com"};
-//        String[] sendToArray = new String[]{"ranu.rajput@smartdukaan.com"};
+        String[] sendToArray = new String[]{"ranu.rajput@smartdukaan.com"};
         Utils.sendMailWithAttachment(googleMailSender, sendToArray, new String[]{}, "BI Retailer Monthly Report", "Please find attached the BI retailer secondary/tertiary monthly report.", fileName, new ByteArrayResource(csvStream.toByteArray()));
+    }
         CellStyle defaultHeaderStyle = workbook.createCellStyle();
         defaultHeaderStyle.setFillForegroundColor(IndexedColors.WHITE.getIndex());
         defaultHeaderStyle.setFillPattern(FillPatternType.SOLID_FOREGROUND);
         defaultHeaderStyle.setFont(font1);
+        CellStyle numberStyle = workbook.createCellStyle();
+        DataFormat format = workbook.createDataFormat();
+        numberStyle.setDataFormat(format.getFormat("#,##0")); // or "#,##0.00" for two decimals
         Map<String, Integer> headerCount = new HashMap<>();
         for (int headerRowIndex = 0; headerRowIndex < headerGroup.size(); headerRowIndex++) {
             List<String> headerRow = headerGroup.get(headerRowIndex);
                     hyperlink.setAddress(value.toString());
                     cell.setCellValue("View Link"); // Display text
                     cell.setHyperlink(hyperlink);
                     cell.setCellStyle(hyperlinkStyle);
                 } else if (value instanceof Number) {
-                    cell.setCellValue(((Number) value).doubleValue());
+                    double numeric = ((Number) value).doubleValue();
+                    cell.setCellValue(Math.round(numeric));
+                    cell.setCellStyle(numberStyle);
                 } else {
                     cell.setCellValue(value != null ? value.toString() : "");
+                }
+            }

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasksTest.java – Rev 34743 → 34749