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

     @Autowired
     InvoiceService invoiceService;
     public void test() throws Exception {
         //invoiceService.createInvoices(Arrays.asList("NSDLUK62", "NSDL39915", "NSDLHR24036", "NSDL39831", "NSNOI5266", "NSDL39849"));
-        vendorCatalogPricingLogRepository.selectByCatalogId(1024271, VendorCatalogPricingStatus.APPROVED).stream().filter(x -> x.getVendorId() == 341).forEach(x -> {
+        /*vendorCatalogPricingLogRepository.selectByCatalogId(1024271, VendorCatalogPricingStatus.APPROVED).stream().filter(x -> x.getVendorId() == 341).forEach(x -> {
             System.out.println(x.getEffectedOn() + ", " + x.getTransferPrice());
-        });
+        });*/
+        List<AgeingSummaryModel> ageingSummaryModels = warehouseInventoryItemRepository.
+                findPartnerStockAgeingByBrand("Samsung", 0, 80);
+        System.out.println(ageingSummaryModels.size());
         //this.setInventoryItemIdToPriceDropImei();
         //fofoSolr.populateTagItems();
         //System.out.println(smartPingService.getAllAgentsByEmail());
         //System.out.println(psiSmartService.getRegistrationEndPoint("9990381569"));
         //migrateValentine();
             for (Loan loan : loans) {
                 UserWallet userWallet = userWalletRepository.selectByRetailerId(loan.getFofoId());
                 SDCreditRequirement sdCreditRequirement = sdCreditRequirementRepository.selectByFofoId(loan.getFofoId());
-                if (userWallet.getAmount() >= 100) {
-                    List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(loan.getId());
+                List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(loan.getId());
-                    LOGGER.info("loanStatements {}", loanStatements);
-                    Map<LoanReferenceType, Double> loanStatusAmount = loanStatements.stream().collect(groupingBy(x -> x.getLoanReferenceType(), Collectors.summingDouble(x -> FormattingUtils.serialize(x.getAmount()))));
+                LOGGER.info("loanStatements {}", loanStatements);
-                    LOGGER.info("loanStatusAmount {}", loanStatusAmount);
-                    Double interestAmount = loanStatusAmount.get(LoanReferenceType.INTEREST);
+                Map<LoanReferenceType, Double> loanStatusAmount = loanStatements.stream().collect(groupingBy(x -> x.getLoanReferenceType(), Collectors.summingDouble(x -> FormattingUtils.serialize(x.getAmount()))));
-                    if (interestAmount == null) {
+                LOGGER.info("loanStatusAmount {}", loanStatusAmount);
-                        interestAmount = (double) 0;
+                Double interestAmount = loanStatusAmount.get(LoanReferenceType.INTEREST);
-                    }
+                if (interestAmount == null) {
+                    interestAmount = (double) 0;
+                }
-                    double principalAmount = loanStatusAmount.get(LoanReferenceType.PRINCIPAL);
+                double principalAmount = loanStatusAmount.get(LoanReferenceType.PRINCIPAL);
+                //if it can be settled
+                if (userWallet.getAmount() >= 100 || userWallet.getAmount() >= interestAmount + principalAmount) {
                     double paidAmount = 0;
                     if (userWallet.getAmount() > Math.abs(interestAmount)) {
                         LOGGER.info("interestAmount b {}", interestAmount);
                             settledLoanStatement(LoanReferenceType.PRINCIPAL, BigDecimal.valueOf(userWalletAmount), loan.getFofoId(), loan.getId(), "Amount adjusted against loan", LocalDateTime.now());
                             paidAmount += Math.abs(userWalletAmount);
-                            BigDecimal availableLimit = sdCreditRequirement.getAvailableLimit().add(BigDecimal.valueOf(userWalletAmount)).abs();
                             BigDecimal utilizationAmount = sdCreditRequirement.getUtilizedAmount().subtract(BigDecimal.valueOf(userWalletAmount)).abs();
                             sdCreditRequirement.setUtilizedAmount(utilizationAmount);
                             CreditAccount creditAccount = creditAccountRepository.selectByFofoIdAndGateway(loan.getFofoId(), Gateway.SDDIRECT);
     public void updatePartnerLimit() throws ProfitMandiBusinessException {
         Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(true);
         Map<Integer, List<FofoSidbiSanction>> fofoSidbiSanctionMap = fofoSidbiSanctionRepository.selectAllUptoBy(ProfitMandiConstants.SIDBI_TENUERE_MONTHS).stream().collect(Collectors.groupingBy(x->x.getFofoId()));
         Map<Integer, SDCreditRequirement> sdCreditRequirementMap = sdCreditRequirementRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
-        Map<Integer, CreditAccount> creditAccountMap = creditAccountRepository.selectAllByGateays(Arrays.asList(Gateway.SIDBI, Gateway.SDDIRECT))
+        Map<Integer, CreditAccount> creditAccountMap = creditAccountRepository.selectAllByGateways(Arrays.asList(Gateway.SIDBI, Gateway.SDDIRECT))
                 .stream().filter(x -> x.isActive()).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
         Map<Integer, CurrentPartnerDailyInvestment> currentPartnerDailyInvestmentMap = currentPartnerDailyInvestmentRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
         for (Entry<Integer, CustomRetailer> customRetailerEntry : customRetailerMap.entrySet()) {
             int fofoId = customRetailerEntry.getKey();
             LocalDateTime firstBillingDate = transactionRepository.getFirstBillingDate(fofoId);

Subversion Repositories SmartDukaan

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