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

 import com.spice.profitmandi.dao.entity.dtr.*;
 import com.spice.profitmandi.dao.entity.fofo.*;
 import com.spice.profitmandi.dao.entity.inventory.*;
 import com.spice.profitmandi.dao.entity.logistics.AST;
 import com.spice.profitmandi.dao.entity.logistics.ASTRepository;
-import com.spice.profitmandi.dao.entity.onBoarding.LoiForm;
 import com.spice.profitmandi.dao.entity.transaction.*;
 import com.spice.profitmandi.dao.entity.user.*;
 import com.spice.profitmandi.dao.entity.warehouse.WarehouseInventoryItem;
 import com.spice.profitmandi.dao.entity.warehouse.WarehouseScan;
 import com.spice.profitmandi.dao.enumuration.auth.CollectionRemark;
 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.*;
-import com.spice.profitmandi.dao.enumuration.transaction.LoanReferenceType;
-import com.spice.profitmandi.dao.enumuration.transaction.PriceDropImeiStatus;
-import com.spice.profitmandi.dao.enumuration.transaction.SchemePayoutStatus;
 import com.spice.profitmandi.dao.model.*;
-import com.spice.profitmandi.dao.model.purchaseSaleRatio.CatalogAgedModel;
 import com.spice.profitmandi.dao.repository.GenericRepository;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.auth.NonSdBuyingRepository;
 import com.spice.profitmandi.dao.repository.auth.PartnerCollectionRemarkRepository;
 import com.spice.profitmandi.dao.repository.catalog.*;
 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;
     @Autowired
     StoreTimelineTatService storeTimelineTatService;
     @Autowired
     PartnerDealerRepository partnerDealerRepository;
+    @Autowired
+    PurSaleService purSaleService;
     public void test() throws Exception {
         System.out.println("test start");
+//        this.send10OrMoreOrderStockReport();
         System.out.println("test end");
+    }
     public void test4() throws Exception {
+        }
         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) {
-                    double settledAmount = sdCreditService.settleLoan(loan);
-                    List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectHoldSanctionByFofoId(loan.getFofoId());
-                    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;
-                        }
-                        if (settledAmount >= sanctionRequest.getPendingAmount().doubleValue()) {
-                            settledAmount -= sanctionRequest.getPendingAmount().doubleValue();
-                            sanctionRequest.setPendingAmount(BigDecimal.valueOf(0));
-                            this.sendUnholdEmail(orders);
-                        } else {
+            for (Loan loan : loans) {
-                            double pendinAmount = sanctionRequest.getPendingAmount().doubleValue() - settledAmount;
-                            System.out.println("Pending Amount - " + pendinAmount);
+                double settledAmount = sdCreditService.settleLoan(loan);
-                            sanctionRequest.setPendingAmount(BigDecimal.valueOf(pendinAmount));
-                            break;
+                List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectHoldSanctionByFofoId(loan.getFofoId());
+                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;
-                        }
+                    }
+                    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;
+                    }
-                }
+                }
+            }
+        }
+    }
             CreditRisk creditRisk = sdCreditService.getCurrentRisk(sdCreditRequirement, firstBillingDate);
             sdCreditRequirement.setRisk(creditRisk);
             sdCreditRequirement.setSuggestedLimit(suggestedAmount);
-            if(!sdCreditRequirement.isHardLimit()){
+            if (!sdCreditRequirement.isHardLimit()) {
                 sdCreditRequirement.setLimit(suggestedAmount);
+            }
             BigDecimal utilizedLimit = new BigDecimal(sdCreditService.getUtilizationAmount(fofoId));
             BigDecimal availableLimit = sdCreditRequirement.getLimit().subtract(utilizedLimit);
+            }
+        }
         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()));
+            }
+        }
         String messageText = this.getMessageForDueDateCross(dueDateCrossLoans);
-        this.sendMailOfHtmlFormat(googleMailSender, new String[]{"puneet.wahi@smartdukaan.com","rahul.latwal@smartdukaan.com"}, messageText, null, "Due Date Cross");
+        this.sendMailOfHtmlFormat(googleMailSender, new String[]{"puneet.wahi@smartdukaan.com", "rahul.latwal@smartdukaan.com"}, messageText, null, "Due Date Cross");
         if (!dueDateCrossLoans.isEmpty()) {
             for (Loan loan : dueDateCrossLoans) {
                 // Check if an entry already exists in the FofoOpeningStock table
                 FofoOpeningStock existingStock = fofoOpeningStockRepository.findByFofoIdAndCatalogId(fofoId, catalogId);
                 if (existingStock != null) {
-                    if(partnerCurrentQty < 1 && existingStock.getOpeningDate().isBefore(LocalDate.now().minusDays(7))){
+                    if (partnerCurrentQty < 1 && existingStock.getOpeningDate().isBefore(LocalDate.now().minusDays(7))) {
                         fofoOpeningStockRepository.delete(existingStock);
+                    }
                     if (existingStock.getOpeningQty() < partnerCurrentQty) {
                         existingStock.setOpeningQty(partnerCurrentQty);
                         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.setCurrentQty(partnerCurrentQty);
+                        existingStock.setCurrentQty(partnerCurrentQty);
-                            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
                             existingStock.setOpeningQty(averageQty);
                             existingStock.setCurrentQty(partnerCurrentQty);
                             existingStock.setOpeningDate(LocalDate.now());
                             LOGGER.info("Updated due to date being older than 7 days with average quantity: {}", averageQty);
+                        }
-                    }else {
+                    } else {
                         existingStock.setCurrentQty(partnerCurrentQty);
+                    }
                 } else {
                     LOGGER.info("else condition exist");
                     FofoOpeningStock newStock = new FofoOpeningStock();
+                }
+            }
 //            if stock is not available in snapshot but available in opening stock
-              List<FofoOpeningStock> fofoOpeningStockList = fofoOpeningStockRepository.selectAllByFofoId(fofoId);
+            List<FofoOpeningStock> fofoOpeningStockList = fofoOpeningStockRepository.selectAllByFofoId(fofoId);
-              for(FofoOpeningStock fofoOpeningStock : fofoOpeningStockList){
+            for (FofoOpeningStock fofoOpeningStock : fofoOpeningStockList) {
-                  if(!partnerStockList.stream().anyMatch(partnerStock -> partnerStock.getCatalogId() == fofoOpeningStock.getCatalogId())){
+                if (!partnerStockList.stream().anyMatch(partnerStock -> partnerStock.getCatalogId() == fofoOpeningStock.getCatalogId())) {
-                      if(fofoOpeningStock.getOpeningDate().isBefore(LocalDate.now().minusDays(7))){
+                    if (fofoOpeningStock.getOpeningDate().isBefore(LocalDate.now().minusDays(7))) {
-                          LOGGER.info("not match stock{}",fofoOpeningStock);
+                        LOGGER.info("not match stock{}", fofoOpeningStock);
-                          fofoOpeningStockRepository.delete(fofoOpeningStock);
+                        fofoOpeningStockRepository.delete(fofoOpeningStock);
-                      }else{
+                    } else {
-                          LOGGER.info("not match stock2{}",fofoOpeningStock);
+                        LOGGER.info("not match stock2{}", fofoOpeningStock);
-                          fofoOpeningStock.setCurrentQty(0);
+                        fofoOpeningStock.setCurrentQty(0);
-                      }
+                    }
-                  }
+                }
-              }
+            }
+        }
+    }
+        }
         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");
+        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);
+    }
+    public void send10OrMoreOlderStockReport() throws Exception {
+       purSaleService.moreThen10DaysEgedStockReport();
+    }
+}
 // 2284"

Subversion Repositories SmartDukaan

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