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

     public void testInvoiceFormat() throws ProfitMandiBusinessException {
         InvoicePdfModel invoicePdfModel = orderService.getInvoicePdfModel(560280);
         //System.out.println(InvoiceFormatter.buildInvoiceLines(invoicePdfModel, InvoiceFormatter.WIDTH_80MM));
+    }
+    public void sendTrialExpiry() {
+        List<FofoStore> stores = fofoStoreRepository.selectAllTrial();
+        List<FofoStore> twoDaysToExpiry = stores.stream().filter(x->x.getTrialEnd().minusDays(2).equals(LocalDate.now())).collect(Collectors.toList());
+        List<FofoStore> fiveDaysToExpiry = stores.stream().filter(x->x.getTrialEnd().minusDays(5).equals(LocalDate.now())).collect(Collectors.toList());
+        List<FofoStore> expiredToday = stores.stream().filter(x->x.getTrialEnd().equals(LocalDate.now())).collect(Collectors.toList());
+        List<FofoStore> expired = stores.stream().filter(x->x.getTrialEnd().isAfter(LocalDate.now())).collect(Collectors.toList());
+    }
     /*public void processCashDiscount() throws ProfitMandiBusinessException {
         System.out.println("processing cash discount");
         List<Loan> loansSettledYesterday = loanRepository.selectLoansSettledOn(LocalDate.now().minusDays(1));
         loansSettledYesterday.addAll(loanRepository.selectLoansSettledOn(LocalDate.now()));
         Map<Integer, List<Loan>> partnerSettledLoans = loansSettledYesterday.stream().collect(Collectors.groupingBy(x -> x.getFofoId()));
     public void test() throws Exception {
         //System.out.println(trialFormRepository.selectByEmailOrMobile("9990381568"));
         /*CreditBlockedExceptionPartner creditBlockedExceptionPartner = creditBlockedExceptionPartnersRepository.select(175139430);
         System.out.println(creditBlockedExceptionPartner);*/
+        this.updatePartnerLimit(175139595);
-        sdCreditService.resetHardLimit();
+        //sdCreditService.resetHardLimit();
         //migrations.migrateSerialInvoiceMap();
         //runOnceTasks.checkRewardsEligibility();
         //hybridEncryptor.getJwt();
         /*System.out.printf("Date|Transaction Id|Serial Number|Sale Amount|Swipe Payout|Discount Payout%n");
         for(int i=0;i<10;i++){
     public void processSidbiDeductions() throws ProfitMandiBusinessException {
         //sidbiService.migrateSanctions();
         sidbiService.processDeductions();
+    }
+    public void updatePartnerLimit(int fofoId) throws ProfitMandiBusinessException {
+        LocalDateTime firstBillingDate = transactionRepository.getFirstBillingDate(fofoId);
+        CreditAccount creditAccount = creditAccountRepository.selectByFofoIdAndGateway(fofoId, Gateway.SDDIRECT);
+        long utilizationAmount = sdCreditService.getUtilizationAmount(fofoId);
+        PartnerDailyInvestment partnerDailyInvestment = partnerInvestmentService.getInvestment(fofoId, 0);
+        BigDecimal suggestedAmount = this.getSuggestedAmount(creditAccount, partnerDailyInvestment, utilizationAmount, null);
+        SDCreditRequirement sdCreditRequirement = sdCreditRequirementRepository.selectByFofoId(fofoId);
+        LOGGER.info("suggestedAmount {} ", suggestedAmount);
+        if (sdCreditRequirement == null) {
+            sdCreditRequirement = new SDCreditRequirement();
+            sdCreditRequirement.setFofoId(fofoId);
+            sdCreditRequirement.setCreditDays(15);
+            sdCreditRequirement.setInterestRate(ProfitMandiConstants.NEW_INTEREST_RATE);
+            sdCreditRequirement.setRisk(CreditRisk.HIGH_RISK);
+            sdCreditRequirement.setUtilizedAmount(BigDecimal.ZERO);
+            sdCreditRequirement.setCreateTimestamp(LocalDateTime.now());
+            sdCreditRequirement.setUpdateTimestamp(LocalDateTime.now());
+            sdCreditRequirementRepository.persist(sdCreditRequirement);
+        }
+        CreditRisk creditRisk = sdCreditService.getCurrentRisk(sdCreditRequirement, firstBillingDate);
+        sdCreditRequirement.setRisk(creditRisk);
+        LOGGER.info("Suggested Amount - {}", suggestedAmount);
+        sdCreditRequirement.setSuggestedLimit(suggestedAmount);
+        if (!sdCreditRequirement.isHardLimit()) {
+            sdCreditRequirement.setLimit(suggestedAmount);
+        }
+        BigDecimal utilizedLimit = new BigDecimal(sdCreditService.getUtilizationAmount(fofoId));
+        BigDecimal availableLimit = sdCreditRequirement.getLimit().subtract(utilizedLimit);
+        LOGGER.info("utilizedLimit {} ", utilizedLimit);
+        LOGGER.info("availableLimit {} ", availableLimit);
+        sdCreditRequirement.setUtilizedAmount(utilizedLimit);
+        sdCreditRequirement.setUpdateTimestamp(LocalDateTime.now());
+        if (creditAccount != null) {
+            creditAccount.setInterestRate(sdCreditRequirement.getInterestRate().floatValue());
+            creditAccount.setSanctionedAmount(sdCreditRequirement.getLimit().floatValue());
+            creditAccount.setAvailableAmount(availableLimit.floatValue());
+            creditAccount.setFreeDays(sdCreditRequirement.getFreeDays());
+            creditAccount.setUpdatedOn(LocalDateTime.now());
+        }
+    }
     public void updatePartnerLimit() throws ProfitMandiBusinessException {
         Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(true);
         Map<Integer, BigDecimal> fofoSidbiLimitMap = sidbiService.getSuggestedLimitMap();
         Map<Integer, SDCreditRequirement> sdCreditRequirementMap = sdCreditRequirementRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
         Map<Integer, CreditAccount> creditAccountMap = creditAccountRepository.selectAllByGateways(Arrays.asList(Gateway.SIDBI, Gateway.SDDIRECT))

Subversion Repositories SmartDukaan

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