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

 import com.spice.profitmandi.dao.cart.CartService;
 import com.spice.profitmandi.dao.cart.SmartCartService;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
 import com.spice.profitmandi.dao.entity.auth.PartnerCollectionRemark;
 import com.spice.profitmandi.dao.entity.catalog.*;
+import com.spice.profitmandi.dao.entity.catalog.Offer;
 import com.spice.profitmandi.dao.entity.cs.NonSdBuying;
 import com.spice.profitmandi.dao.entity.cs.Position;
 import com.spice.profitmandi.dao.entity.cs.Ticket;
 import com.spice.profitmandi.dao.entity.dtr.*;
 import com.spice.profitmandi.dao.entity.dtr.User;
 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.gstpro.GstProAuthService;
 import com.spice.profitmandi.service.integrations.gstpro.GstProService;
+import com.spice.profitmandi.service.integrations.pinelabs.dto.*;
 import com.spice.profitmandi.service.integrations.psismart.PsiSmartService;
 import com.spice.profitmandi.service.integrations.smartping.SmartPingService;
 import com.spice.profitmandi.service.integrations.toffee.ToffeeService;
 import com.spice.profitmandi.service.inventory.*;
 import com.spice.profitmandi.service.offers.OfferService;
     CreditBlockedExceptionPartnersRepository creditBlockedExceptionPartnersRepository;
     @Autowired
     SDCreditService sdCreditService;
+    @Autowired
+    com.spice.profitmandi.service.integrations.pinelabs.PinelabsAffordabilityService pinelabsAffordabilityService;
+    @Autowired
+    com.spice.profitmandi.service.integrations.pinelabs.PinelabsAuthService pinelabsAuthService;
+    public void testAffordability() {
+        Money orderAmount = new Money("1000000", "INR");
+        Money discountAmount = new Money("0", "INR");
+        List<ProductDetails> productDetails = Arrays.asList(new ProductDetails(orderAmount, discountAmount, "Alpha_2"));
+        OfferDiscoveryRequest offerDiscoveryRequest = new com.spice.profitmandi.service.integrations.pinelabs.dto.OfferDiscoveryRequest(orderAmount, productDetails, new AffordabilityIssuer("12345678"));
+        OfferDiscoveryResponse offerDiscoveryResponse = pinelabsAffordabilityService.discoverOffers(offerDiscoveryRequest);
+        System.out.println(offerDiscoveryResponse);
+    }
     public void test() throws Exception {
+        System.out.println(pinelabsAuthService.getAccessToken());
+        testAffordability();
         //System.out.println(trialFormRepository.selectByEmailOrMobile("9990381568"));
         /*CreditBlockedExceptionPartner creditBlockedExceptionPartner = creditBlockedExceptionPartnersRepository.select(175139430);
         System.out.println(creditBlockedExceptionPartner);*/
         //this.updatePartnerLimit(175139595);
-        this.releaseBlockedLimit();
+        //this.releaseBlockedLimit();
         //sdCreditService.resetHardLimit();
         //migrations.migrateSerialInvoiceMap();
         //runOnceTasks.checkRewardsEligibility();
         //hybridEncryptor.getJwt();
         /*System.out.printf("Date|Transaction Id|Serial Number|Sale Amount|Swipe Payout|Discount Payout%n");
     public void sendUnscheduledFollowUpMail() throws Exception {
         List<Lead> missedScheduleLeads = leadRepository.selectLeadsScheduledBetweenDate(null, LocalDate.now().atStartOfDay().minusDays(30), LocalDateTime.now().toLocalDate().atStartOfDay());
         List<Lead> leadsScheduledForToday = leadRepository.selectLeadsScheduledBetweenDate(null, LocalDate.now().atStartOfDay(), LocalDate.now().atTime(LocalTime.MAX));
         List<Integer> authIds = missedScheduleLeads.stream().map(x -> x.getAssignTo()).distinct().collect(Collectors.toList());
         LOGGER.info(authIds.size());
-        Map<Integer, AuthUser> authUserMap = authRepository.selectAllAuthUserByIds(authIds).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
+        Map<Integer, AuthUser> authUserMap = authRepository.selectByIds(authIds).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
         LOGGER.info(authUserMap.size());
         //if(true) return;
         missedScheduleLeads = missedScheduleLeads.stream().sorted(Comparator.comparing(Lead::getState, String.CASE_INSENSITIVE_ORDER).thenComparing(Lead::getAssignTo).thenComparing(Lead::getScheduledTimestamp)).collect(Collectors.toList());
         //leadsScheduledForToday
         Map<Integer, CustomRetailer> customRetailers = retailerService.getAllFofoRetailers();
         List<Integer> assignTo = Arrays.asList(15, 9, 54, 53);
-        Map<Integer, AuthUser> assignAuthUserMap = authRepository.selectAllAuthUserByIds(assignTo).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
+        Map<Integer, AuthUser> assignAuthUserMap = authRepository.selectByIds(assignTo).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
         List<String> sendTo = Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com", "sm@smartdukaan.com");
         LOGGER.info("partnerProblem" + partnerProblems);
         StringBuilder sb = new StringBuilder();
         sb.append("<htl><body>");
+    }
     public void updatePartnerLimit(int fofoId) throws ProfitMandiBusinessException {
         LocalDateTime firstBillingDate = transactionRepository.getFirstBillingDate(fofoId);
         CreditAccount creditAccount = creditAccountRepository.selectByFofoIdAndGateway(fofoId, Gateway.SDDIRECT);
-        long utilizationAmount = sdCreditService.getUtilizationAmount(fofoId);
+        BigDecimal 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);
         LOGGER.info("Suggested Amount - {}", suggestedAmount);
         sdCreditRequirement.setSuggestedLimit(suggestedAmount);
         if (!sdCreditRequirement.isHardLimit()) {
             sdCreditRequirement.setLimit(suggestedAmount);
+        }
-        BigDecimal utilizedLimit = new BigDecimal(sdCreditService.getUtilizationAmount(fofoId));
+        BigDecimal utilizedLimit = sdCreditService.getUtilizationAmount(fofoId);
         BigDecimal availableLimit = sdCreditRequirement.getLimit().subtract(utilizedLimit);
         LOGGER.info("utilizedLimit {} ", utilizedLimit);
         for (Entry<Integer, CustomRetailer> customRetailerEntry : customRetailerMap.entrySet()) {
             int fofoId = customRetailerEntry.getKey();
             LocalDateTime firstBillingDate = transactionRepository.getFirstBillingDate(fofoId);
             CreditAccount creditAccount = creditAccountMap.get(fofoId);
-            long utilizationAmount = sdCreditService.getUtilizationAmount(fofoId);
+            BigDecimal utilizationAmount = sdCreditService.getUtilizationAmount(fofoId);
             PartnerDailyInvestment partnerDailyInvestment = partnerInvestmentService.getInvestment(fofoId, 0);
             BigDecimal suggestedAmount = this.getSuggestedAmount(creditAccount, partnerDailyInvestment, utilizationAmount, fofoSidbiLimitMap.get(fofoId));
             SDCreditRequirement sdCreditRequirement = sdCreditRequirementMap.get(fofoId);
             LOGGER.info("suggestedAmount {} ", suggestedAmount);
             sdCreditRequirement.setSuggestedLimit(suggestedAmount);
             if (!sdCreditRequirement.isHardLimit()) {
                 sdCreditRequirement.setLimit(suggestedAmount);
+            }
-            BigDecimal utilizedLimit = new BigDecimal(sdCreditService.getUtilizationAmount(fofoId));
+            BigDecimal utilizedLimit = sdCreditService.getUtilizationAmount(fofoId);
             BigDecimal availableLimit = sdCreditRequirement.getLimit().subtract(utilizedLimit);
             LOGGER.info("utilizedLimit {} ", utilizedLimit);
     );*/
     private static List<Integer> hundredPercentLimitPartnerIds = Arrays.asList();
     private BigDecimal getSuggestedAmount(CreditAccount creditAccount, PartnerDailyInvestment
-            partnerDailyInvestment, long utilizationAmount, BigDecimal sidbiLimit) {
+            partnerDailyInvestment, BigDecimal utilizationAmount, BigDecimal sidbiLimit) {
         BigDecimal suggestedAmount = BigDecimal.ZERO;
+        double utilization = utilizationAmount != null ? utilizationAmount.doubleValue() : 0;
         //1 LAC
         if (creditAccount == null || creditAccount.getGateway().equals(Gateway.SDDIRECT)) {
             if (partnerDailyInvestment != null) {
                 if (hundredPercentLimitPartnerIds.contains(partnerDailyInvestment.getFofoId())) {
-                    suggestedAmount = getSuggestedAmount(partnerDailyInvestment.getTotalInvestment() - utilizationAmount, 1);
+                    suggestedAmount = getSuggestedAmount(partnerDailyInvestment.getTotalInvestment() - utilization, 1);
                     suggestedAmount = suggestedAmount.min(BigDecimal.valueOf(1500000));
                 } else {
-                    suggestedAmount = getSuggestedLimit(partnerDailyInvestment.getTotalInvestment() - utilizationAmount);
+                    suggestedAmount = getSuggestedLimit(partnerDailyInvestment.getTotalInvestment() - utilization);
+                }
+            }
             if (suggestedAmount.doubleValue() < 0) {
                 suggestedAmount = BigDecimal.ZERO;
+            }
         } else if (creditAccount.getGateway().equals(Gateway.SIDBI) && sidbiLimit != null) {
-            suggestedAmount = getSuggestedLimit(partnerDailyInvestment.getTotalInvestment() - utilizationAmount);
+            suggestedAmount = getSuggestedLimit(partnerDailyInvestment.getTotalInvestment() - utilization);
             suggestedAmount = suggestedAmount.max(sidbiLimit);
+        }
         return suggestedAmount;

Subversion Repositories SmartDukaan

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