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

 import com.spice.profitmandi.dao.repository.warehouse.*;
 import com.spice.profitmandi.dao.service.biuedart.BluedartAuthService;
 import com.spice.profitmandi.dao.service.biuedart.BluedartService;
 import com.spice.profitmandi.dao.service.solr.FofoSolr;
 import com.spice.profitmandi.service.*;
-import com.spice.profitmandi.service.catalog.BrandsService;
 import com.spice.profitmandi.service.integrations.CCAvenuePaymentService;
 import com.spice.profitmandi.service.integrations.RazorpayPaymentService;
 import com.spice.profitmandi.service.integrations.bharti.model.BAGInsuranceModel;
 import com.spice.profitmandi.service.integrations.psismart.PsiSmartService;
 import com.spice.profitmandi.service.integrations.smartping.SmartPingService;
 import javax.mail.internet.MimeMessage;
 import java.io.*;
 import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.nio.file.Files;
-import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.sql.Timestamp;
 import java.text.DecimalFormat;
 import java.time.*;
 import java.time.format.DateTimeFormatter;
     @Autowired
     InvoiceService invoiceService;
     public void test() throws Exception {
-        invoiceService.createInvoices(Arrays.asList("NSDLUK62", "NSDL39915", "NSDLHR24036", "NSDL39831", "NSNOI5266", "NSDL39849"));
+        //invoiceService.createInvoices(Arrays.asList("NSDLUK62", "NSDL39915", "NSDLHR24036", "NSDL39831", "NSNOI5266", "NSDL39849"));
+        vendorCatalogPricingLogRepository.selectByCatalogId(1024271, VendorCatalogPricingStatus.APPROVED).stream().filter(x -> x.getVendorId() == 341).forEach(x -> {
+            System.out.println(x.getEffectedOn() + ", " + x.getTransferPrice());
+        });
         //this.setInventoryItemIdToPriceDropImei();
         //fofoSolr.populateTagItems();
         //System.out.println(smartPingService.getAllAgentsByEmail());
         //System.out.println(psiSmartService.getRegistrationEndPoint("9990381569"));
         //migrateValentine();
         if (!unAuthorizedBuyingMap.isEmpty()) {
             for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES), true).entrySet()) {
                 List<NonSdBuying> unAuthorizedfilteredRows = storeGuyEntry.getValue().stream()
                         .map(x -> unAuthorizedBuyingMap.get(x)).filter(x -> x != null).collect(Collectors.toList());
-                if(!unAuthorizedfilteredRows.isEmpty()){
+                if (!unAuthorizedfilteredRows.isEmpty()) {
                     String subject = "Unauthorized Buying";
                     String messageText = this.getMessageForUnauthorizedBuying(unAuthorizedfilteredRows);
                     MimeMessage message = mailSender.createMimeMessage();
                     MimeMessageHelper helper = new MimeMessageHelper(message, true);
                     String[] email = new String[]{storeGuyEntry.getKey()};
-                   // String[] email = {"ranu.rajput@smartdukaan.com"};
+                    // String[] email = {"ranu.rajput@smartdukaan.com"};
                     helper.setSubject(subject);
                     helper.setText(messageText, true);
                     helper.setTo(email);
                     InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smartdukaan Alerts");
     public void processActivatedImeisForSchemes() throws ProfitMandiBusinessException {
         schemeService.processActivatedImeisForSchemes();
+    }
+    @Autowired
+    FofoSidbiSanctionRepository fofoSidbiSanctionRepository;
     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))
+                .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));
-        double limitValue = 100000;
         for (Entry<Integer, CustomRetailer> customRetailerEntry : customRetailerMap.entrySet()) {
             int fofoId = customRetailerEntry.getKey();
-            SDCreditRequirement sdCreditRequirement = sdCreditRequirementMap.get(customRetailerEntry.getKey());
             LocalDateTime firstBillingDate = transactionRepository.getFirstBillingDate(fofoId);
-            CurrentPartnerDailyInvestment currentPartnerDailyInvestment = currentPartnerDailyInvestmentMap.get(fofoId);
-            BigDecimal suggestedAmount = BigDecimal.ZERO;
+            CreditAccount creditAccount = creditAccountMap.get(fofoId);
-            if (currentPartnerDailyInvestment != null) {
-                suggestedAmount = BigDecimal.valueOf(currentPartnerDailyInvestment.getTotalInvestment() * 0.1);
-            }
-            if (suggestedAmount.doubleValue() > limitValue) {
-                suggestedAmount = BigDecimal.valueOf(limitValue);
+            CurrentPartnerDailyInvestment currentPartnerDailyInvestment = currentPartnerDailyInvestmentMap.get(fofoId);
-            }
+            List<FofoSidbiSanction> fofoSidbiSanctions = fofoSidbiSanctionMap.get(fofoId);
-            if (suggestedAmount.doubleValue() < 0) {
+            BigDecimal suggestedAmount = this.getSuggestedAmount(creditAccount, currentPartnerDailyInvestment, fofoSidbiSanctions);
-                suggestedAmount = BigDecimal.ZERO;
+            SDCreditRequirement sdCreditRequirement = sdCreditRequirementMap.get(fofoId);
-            }
             LOGGER.info("suggestedAmount {} ", suggestedAmount);
             if (sdCreditRequirement == null) {
                 sdCreditRequirement = new SDCreditRequirement();
             sdCreditRequirement.setUtilizedAmount(utilizedLimit);
             sdCreditRequirement.setUpdateTimestamp(LocalDateTime.now());
-            CreditAccount creditAccount = creditAccountRepository.selectByFofoIdAndGateway(sdCreditRequirement.getFofoId(), Gateway.SDDIRECT);
             if (creditAccount != null) {
                 creditAccount.setInterestRate(sdCreditRequirement.getInterestRate().floatValue());
                 creditAccount.setSanctionedAmount(sdCreditRequirement.getLimit().floatValue());
                 creditAccount.setAvailableAmount(availableLimit.floatValue());
+        }
+    }
+    private BigDecimal getSuggestedAmount(CreditAccount creditAccount, CurrentPartnerDailyInvestment currentPartnerDailyInvestment, List<FofoSidbiSanction> fofoSidbiSanctions) {
+        BigDecimal suggestedAmount = BigDecimal.ZERO;
+        //1 LAC
+        double limitValue = 100000;
+        if (creditAccount.getGateway().equals(Gateway.SDDIRECT)) {
+            if (currentPartnerDailyInvestment != null) {
+                suggestedAmount = BigDecimal.valueOf(Math.min(currentPartnerDailyInvestment.getTotalInvestment() * 0.1, limitValue));
+            }
+            if (suggestedAmount.doubleValue() < 0) {
+                suggestedAmount = BigDecimal.ZERO;
+            }
+        } else if(creditAccount.getGateway().equals(Gateway.SIDBI) && fofoSidbiSanctions!= null && fofoSidbiSanctions.size() > 0){
+            //Left
+            FofoSidbiSanction fofoSidbiSanction = fofoSidbiSanctions.get(0);
+            int monthsLeft = fofoSidbiSanction.getMonthsLeft(ProfitMandiConstants.SIDBI_TENUERE_MONTHS);
+            if(monthsLeft >=0) {
+                suggestedAmount = BigDecimal.valueOf(fofoSidbiSanction.getSanctionAmount()*monthsLeft/ProfitMandiConstants.SIDBI_TENUERE_MONTHS);
+            }
+        }
+        return suggestedAmount;
+    }
     public void notifyDefaultLoans() throws ProfitMandiBusinessException, MessagingException, IOException {
         sdCreditService.updateRisk();
         List<Loan> defaultLoans = sdCreditService.getDefaultLoan();
         if (!defaultLoans.isEmpty()) {

Subversion Repositories SmartDukaan

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