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

 import com.spice.profitmandi.dao.enumuration.dtr.RefferalStatus;
 import com.spice.profitmandi.dao.enumuration.fofo.Gateway;
 import com.spice.profitmandi.dao.enumuration.fofo.PaymentStatus;
 import com.spice.profitmandi.dao.enumuration.fofo.ReturnType;
 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
+import com.spice.profitmandi.dao.enumuration.inventory.CatalogMovingEnum;
 import com.spice.profitmandi.dao.enumuration.inventory.VendorCatalogPricingStatus;
 import com.spice.profitmandi.dao.enumuration.onBorading.onBoardingFormEnums.LoiStatus;
 import com.spice.profitmandi.dao.enumuration.transaction.CreditRisk;
 import com.spice.profitmandi.dao.enumuration.transaction.LoanReferenceType;
 import com.spice.profitmandi.dao.enumuration.transaction.PriceDropImeiStatus;
 import java.text.DecimalFormat;
 import java.time.*;
 import java.time.format.DateTimeFormatter;
 import java.time.temporal.ChronoField;
 import java.time.temporal.ChronoUnit;
+import java.time.temporal.WeekFields;
 import java.util.*;
 import java.util.Map.Entry;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
+        }
         return partnerIdSalesHeadersMap;
+    }
-    public void persistRbmTodayTargets() throws Exception {
+    public void persistRbmTodayTargets() throws Exception{
         rbmTargetService.setMovementWiseRbmTargets();
+    }
-    public void persistRbmTodayAchievements() throws Exception {
+    public void persistRbmTodayAchievements() throws Exception{
         rbmTargetService.setMovementWiseRbmAchievement();
+    }
     public void sendPartnerInvestmentDetails() throws Exception {
         this.sendPartnerInvestmentDetails(null);
                     httpPost.setHeader("Content-Type", "application/json");
                     StringEntity entity = new StringEntity(payload.toString());
                     httpPost.setEntity(entity);
                     CloseableHttpResponse response = client.execute(httpPost);
-                    LOGGER.info("google FCM status code: {}", response.getStatusLine().getStatusCode());
+                    LOGGER.info("google FCM status code: {}",response.getStatusLine().getStatusCode());
                     String responseBody = new BufferedReader(new InputStreamReader(response.getEntity().getContent()))
                             .lines().collect(Collectors.joining("\n"));
                     if (response.getStatusLine().getStatusCode() == 200) {
                         pushNotification.setSentTimestamp(LocalDateTime.now());
                     } else {
                 fm.setPendingIndentQty(processingQty);
                 fm.setShortageQty(shortageQty);
                 fm.setPoAvailability(allColorPoAvailability);
                 fm.setDp(tagListing.getSellingPrice());
                 fm.setWarehouseName(warehouseMap.get(customRetailer.getWarehouseId()));
-                if (partnerIdSalesHeadersMap.get(fofoId) != null) {
+                if(partnerIdSalesHeadersMap.get(fofoId) != null){
                     fm.setStateManager(partnerIdSalesHeadersMap.get(fofoId).getRegionalManager());
                     fm.setTerritoryManager(partnerIdSalesHeadersMap.get(fofoId).getTerritoryManager());
-                } else {
+                }else {
-                    LOGGER.info("else fofoId - {}", fofoId);
+                    LOGGER.info("else fofoId - {}",fofoId);
                     fm.setStateManager("");
                     fm.setTerritoryManager("");
+                }
                 fm.setItemName(items.get(0).getBrand() + items.get(0).getModelNumber() + items.get(0).getModelName());
                 focusedModelShortageList.add(fm);
+            }
+        }
-        LOGGER.info("focusedModelShortageReportMap {}", focusedModelShortageReportMap);
+        LOGGER.info("focusedModelShortageReportMap {}",focusedModelShortageReportMap);
         if (!focusedModelShortageReportMap.isEmpty()) {
             String fileName = "Stock Alert-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
             Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
             Map<String, List<List<?>>> emailRowsMap = new HashMap<>();
                 } catch (Exception e2) {
                     e2.printStackTrace();
+                }
                 String[] sendToArray = new String[]{
-                        entry.getKey(), "alok.divedi@smartdukaan.com", "ranu.rajput@smartdukaan.com"
+                        entry.getKey(), "alok.divedi@smartdukaan.com","ranu.rajput@smartdukaan.com"
                 };
                 try {
     public void loanSettlement() throws Exception {
         List<Loan> blockedLoans = loanRepository.selectAllActiveLoan().stream().filter(x -> x.getFreeDays() >= 365).collect(toList());
         List<Loan> loans = loanRepository.selectAllActiveLoan().stream().filter(x -> x.getFreeDays() < 365).collect(toList());
         //Settle blocked loans only when normal loans are settled
-        loans.addAll(blockedLoans);
+            loans.addAll(blockedLoans);
-        //TODO:Remove this code
+            //TODO:Remove this code
-        Loan specificLoan = loanRepository.selectByLoanId(20073);
+            Loan specificLoan = loanRepository.selectByLoanId(20073);
-        loans.add(0, specificLoan);
+            loans.add(0, specificLoan);
-        //TODO:Upto here
+            //TODO:Upto here
-        if (!loans.isEmpty()) {
+            if (!loans.isEmpty()) {
-            for (Loan loan : loans) {
+                for (Loan loan : loans) {
-                double settledAmount = sdCreditService.settleLoan(loan);
+                    double settledAmount = sdCreditService.settleLoan(loan);
-                List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectHoldSanctionByFofoId(loan.getFofoId());
+                    List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectHoldSanctionByFofoId(loan.getFofoId());
-                for (SanctionRequest sanctionRequest : sanctionRequests) {
+                    for (SanctionRequest sanctionRequest : sanctionRequests) {
+                        List<Order> orders = orderRepository.selectAllByTransactionId(sanctionRequest.getTransactionId());
+                        if (orders.size() == 0) {
+                            LOGGER.info("Could not find orders - for Sanction Request {}", sanctionRequest);
+                            continue;
+                        }
-                    List<Order> orders = orderRepository.selectAllByTransactionId(sanctionRequest.getTransactionId());
+                        if (settledAmount >= sanctionRequest.getPendingAmount().doubleValue()) {
-                    if (orders.size() == 0) {
+                            settledAmount -= sanctionRequest.getPendingAmount().doubleValue();
-                        LOGGER.info("Could not find orders - for Sanction Request {}", sanctionRequest);
+                            sanctionRequest.setPendingAmount(BigDecimal.valueOf(0));
+                            this.sendUnholdEmail(orders);
-                        continue;
+                        } else {
+                            double pendinAmount = sanctionRequest.getPendingAmount().doubleValue() - settledAmount;
+                            System.out.println("Pending Amount - " + pendinAmount);
+                            sanctionRequest.setPendingAmount(BigDecimal.valueOf(pendinAmount));
-                    }
+                            break;
-                    if (settledAmount >= sanctionRequest.getPendingAmount().doubleValue()) {
-                        settledAmount -= sanctionRequest.getPendingAmount().doubleValue();
-                        sanctionRequest.setPendingAmount(BigDecimal.valueOf(0));
-                        this.sendUnholdEmail(orders);
-                    } else {
-                        double pendinAmount = sanctionRequest.getPendingAmount().doubleValue() - settledAmount;
-                        System.out.println("Pending Amount - " + pendinAmount);
-                        sanctionRequest.setPendingAmount(BigDecimal.valueOf(pendinAmount));
-                        break;
+                        }
+                    }
+                }
+            }
-        }
+    }
+            }
+        }
         String messageText = this.getMessageForDueDateExtend(defaultLoans);
-        this.sendMailOfHtmlFormat(googleMailSender, new String[]{"puneet.wahi@smartdukaan.com", "rahul.latwal@smartdukaan.com"}, messageText, null, subject);
+        this.sendMailOfHtmlFormat(googleMailSender, new String[]{"puneet.wahi@smartdukaan.com","rahul.latwal@smartdukaan.com"}, messageText, null, subject);
         for (Loan defaultLoan : defaultLoans) {
             List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(defaultLoan.getId());
             double amount = loanStatements.stream().map(x -> x.getAmount()).collect(Collectors.summingDouble(x -> x.doubleValue()));
     public void createOpeningStockPartyWise() throws Exception {
         // Get all partner stock data
         Map<Integer, List<PartnerOpeningStockByTodayModel>> partnerOpeningStockByTodayMap = currentInventorySnapshotRepository.getAllPartnerTodayStock();
         for (Map.Entry<Integer, List<PartnerOpeningStockByTodayModel>> entry : partnerOpeningStockByTodayMap.entrySet()) {
             int fofoId = entry.getKey();
             List<PartnerOpeningStockByTodayModel> partnerStockList = entry.getValue();
+//            if stock is vaialble in snapshot
             for (PartnerOpeningStockByTodayModel partnerStock : partnerStockList) {
                 int catalogId = partnerStock.getCatalogId();
-                int stockQty = partnerStock.getOpeningQty();
+                int partnerCurrentQty = partnerStock.getOpeningQty();
                 LocalDate openingDate = partnerStock.getOpeningDate();
                 // Check if an entry already exists in the FofoOpeningStock table
                 FofoOpeningStock existingStock = fofoOpeningStockRepository.findByFofoIdAndCatalogId(fofoId, catalogId);
                 if (existingStock != null) {
-                    if(stockQty < 1 && existingStock.getOpeningDate().isBefore(LocalDate.now().minusDays(7))){
+                    if(partnerCurrentQty < 1 && existingStock.getOpeningDate().isBefore(LocalDate.now().minusDays(7))){
                         fofoOpeningStockRepository.delete(existingStock);
+                    }
-                    if (existingStock.getOpeningQty() < stockQty) {
+                    if (existingStock.getOpeningQty() < partnerCurrentQty) {
-                        existingStock.setOpeningQty(stockQty);
+                        existingStock.setOpeningQty(partnerCurrentQty);
-                        existingStock.setCurrentQty(stockQty);
+                        existingStock.setCurrentQty(partnerCurrentQty);
                         existingStock.setOpeningDate(openingDate);
                         LOGGER.info("if condition exist {}");
-                    } else if (existingStock.getCurrentQty() >= existingStock.getOpeningQty()) {
+                    }else if(existingStock.getCurrentQty() >= existingStock.getOpeningQty()){
-                        existingStock.setOpeningQty(existingStock.getCurrentQty());
+                            existingStock.setOpeningQty(existingStock.getCurrentQty());
-                        existingStock.setOpeningDate(LocalDate.now());
+                            existingStock.setOpeningDate(LocalDate.now());
                     } else if (existingStock.getOpeningDate().isBefore(LocalDate.now().minusDays(7))) {
                         int averageQty = Math.round((existingStock.getCurrentQty() + existingStock.getOpeningQty()) / 2.0f);
                         if (averageQty == 1 && existingStock.getOpeningQty() == 1 && existingStock.getCurrentQty() == 0) {
                             // Delete the existing stock entry from the table
                 } else {
                     LOGGER.info("else condition exist");
                     FofoOpeningStock newStock = new FofoOpeningStock();
                     newStock.setFofoId(fofoId);
                     newStock.setCatalogId(catalogId);
-                    newStock.setOpeningQty(stockQty);
+                    newStock.setOpeningQty(partnerCurrentQty);
-                    newStock.setCurrentQty(stockQty);
+                    newStock.setCurrentQty(partnerCurrentQty);
                     newStock.setOpeningDate(openingDate);
                     fofoOpeningStockRepository.persist(newStock);
+                }
+            }
+//            if stock is not available in snapshot but available in opening stock
+              List<FofoOpeningStock> fofoOpeningStockList = fofoOpeningStockRepository.selectAllByFofoId(fofoId);
+              for(FofoOpeningStock fofoOpeningStock : fofoOpeningStockList){
+                  if(!partnerStockList.stream().anyMatch(partnerStock -> partnerStock.getCatalogId() == fofoOpeningStock.getCatalogId())){
+                      if(fofoOpeningStock.getOpeningDate().isBefore(LocalDate.now().minusDays(7))){
+                          LOGGER.info("not match stock{}",fofoOpeningStock);
+                          fofoOpeningStockRepository.delete(fofoOpeningStock);
+                      }else{
+                          LOGGER.info("not match stock2{}",fofoOpeningStock);
+                          fofoOpeningStock.setCurrentQty(0);
+                      }
+                  }
+              }
+        }
+    }
+    @Autowired
+    private CategorisedCatalogRepository categorisedCatalogRepository;
+    public void groupHidCatalogsByWeeks() throws ProfitMandiBusinessException, MessagingException, IOException {
+        List<CategorisedCatalogListModel> categorisedCatalogs = categorisedCatalogRepository.getListByStatus(CatalogMovingEnum.HID);
+        LocalDate currentDate = LocalDate.now();
+        LocalDate oneWeekAgo = currentDate.minusDays(7);
+        LocalDate twoWeeksAgo = currentDate.minusDays(14);
+        LocalDate threeWeeksAgo = currentDate.minusDays(21);
+        // This Week (inclusive of the current date)
+        List<CategorisedCatalogListModel> thisWeekCatalogs = categorisedCatalogs.stream()
+                .filter(catalog -> !catalog.getStatusCreatedDate().isBefore(oneWeekAgo))
+                .collect(Collectors.toList());
+        // Last Week (from one week ago to two weeks ago, exclusive of this week)
+        List<CategorisedCatalogListModel> lastWeekCatalogs = categorisedCatalogs.stream()
+                .filter(catalog -> catalog.getStatusCreatedDate().isBefore(oneWeekAgo) && !catalog.getStatusCreatedDate().isBefore(twoWeeksAgo))
+                .collect(Collectors.toList());
+        // Two Weeks Ago (from two weeks ago to three weeks ago, exclusive of last week)
+        List<CategorisedCatalogListModel> twoWeeksAgoCatalogs = categorisedCatalogs.stream()
+                .filter(catalog -> catalog.getStatusCreatedDate().isBefore(twoWeeksAgo) && !catalog.getStatusCreatedDate().isBefore(threeWeeksAgo))
+                .collect(Collectors.toList());
+        // Older than Two Weeks Ago (anything older than three weeks ago)
+        List<CategorisedCatalogListModel> olderCatalogs = categorisedCatalogs.stream()
+                .filter(catalog -> catalog.getStatusCreatedDate().isBefore(threeWeeksAgo))
+                .collect(Collectors.toList());
+        String subject = "Hid Catalogs";
+        StringBuilder sb = new StringBuilder();
+        sb.append("<html><body><p>Hi Catagory Team,\n");
+        sb.append("<p style='font-weight:500;'>Please review the HID catalogs for this week:</p>\n" + "<table style='border:1px solid black ;padding: 5px; border-collapse: collapse;'>");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Brand</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Model Number</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Model Name</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Catalog Id</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Start Date</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>End Date</th>\n");
+        sb.append("</tr>\n");
+        for (CategorisedCatalogListModel catalog : thisWeekCatalogs) {
+            sb.append("<tr>");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getBrand() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getModelNumber() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getModelId() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getCurrentStatus() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getStatusCreatedDate() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getStatusEndDate() + "</td>\n");
+            sb.append("</tr>\n");
+        }
+        sb.append("</table>");
+        sb.append("</br>");
+        sb.append("</br>");
+        sb.append("</br>");
+        sb.append("<p style='font-weight:500;'>Please review the HID catalogs for last week:</p>\n" + "<table style='border:1px solid black ;padding: 5px; border-collapse: collapse;'>");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Brand</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Model Number</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Model Name</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Catalog Id</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Start Date</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>End Date</th>\n");
+        sb.append("</tr>\n");
+        for (CategorisedCatalogListModel catalog : lastWeekCatalogs) {
+            sb.append("<tr>");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getBrand() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getModelNumber() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getModelId() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getCurrentStatus() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getStatusCreatedDate() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getStatusEndDate() + "</td>\n");
+            sb.append("</tr>\n");
+        }
+        sb.append("</table>");
+        sb.append("</br>");
+        sb.append("</br>");
+        sb.append("</br>");
+        sb.append("<p style='font-weight:500;'>Please review the HID catalogs for two week ago:</p>\n" + "<table style='border:1px solid black ;padding: 5px; border-collapse: collapse;'>");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Brand</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Model Number</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Model Name</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Catalog Id</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Start Date</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>End Date</th>\n");
+        sb.append("</tr>\n");
+        for (CategorisedCatalogListModel catalog : twoWeeksAgoCatalogs) {
+            sb.append("<tr>");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getBrand() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getModelNumber() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getModelId() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getCurrentStatus() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getStatusCreatedDate() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getStatusEndDate() + "</td>\n");
+            sb.append("</tr>\n");
+        }
+        sb.append("</table>");
+        sb.append("</br>");
+        sb.append("</br>");
+        sb.append("</br>");
+        sb.append("<p style='font-weight:500;'>Please review the HID catalogs for older than two weeks ago:</p>\n" + "<table style='border:1px solid black ;padding: 5px; border-collapse: collapse;'>");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Brand</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Model Number</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Model Name</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Catalog Id</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>Start Date</th>\n");
+        sb.append("<th style='border:1px solid black;padding: 5px'>End Date</th>\n");
+        sb.append("</tr>\n");
+        for (CategorisedCatalogListModel catalog : olderCatalogs) {
+            sb.append("<tr>");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getBrand() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getModelNumber() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getModelId() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getCurrentStatus() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getStatusCreatedDate() + "</td>\n");
+            sb.append("<td style='border:1px solid black;padding: 5px'>" + catalog.getStatusEndDate() + "</td>\n");
+            sb.append("</tr>\n");
+        }
+        sb.append("</table>");
+        sb.append("</body></html>");
+        List<String> sendTo = Arrays.asList("uday.singh@smartdukaan.com", "kuldeep.kumar@smartdukaan.com", "nishant.ohri@smartdukaan.com", "ritesh.chauhan1@smartdukaan.com","shobhit.tandon@smartdukaan.com","tarun.verma@smartdukaan.com","niranjan.kala@smartdukaan.com");
+        String[] email = sendTo.toArray(new String[sendTo.size()]);
+        this.sendMailOfHtmlFormat(mailSender, email, sb.toString(), null, subject);
+    }
+}
 // 2284"

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java – Rev 34160 → 34162