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

 import com.spice.profitmandi.dao.repository.inventory.*;
 import com.spice.profitmandi.dao.repository.transaction.*;
 import com.spice.profitmandi.dao.repository.user.AddressRepository;
 import com.spice.profitmandi.dao.repository.user.UserRepository;
 import com.spice.profitmandi.dao.repository.warehouse.*;
+import com.spice.profitmandi.dao.service.SidbiService;
 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.integrations.CCAvenuePaymentService;
     @Autowired
     InvoiceService invoiceService;
     public void test() throws Exception {
+        //this.test1();
+        this.processSidbiDeductions();
         /*List<Order> orders = orderRepository.selectByInvoiceNumber("NSDL43328");
         invoiceService.saveInvoice(orders);*/
-        for ( int fofoId : Arrays.asList(4149607,175138674,175138854,175138934,175138958,175139138,175139150,175139245,175139259,175139306,175139324,175139344,175139346,175139362,175139386,175139395,175139412,175139452,175139455,175139460,175139462,175139463,175139488,175139489,175139499,175139504,175139508,175139511,175139513,175139521,175139524,175139531,175139532,175139557,175139559,175139576,175139603,175139605,175139608,175139612,175139621,175139630,175139638,175139657,175139661,175139690,175139697,175139716,175139731)) {
+        /*for ( int fofoId : Arrays.asList(4149607,175138674,175138854,175138934,175138958,175139138,175139150,175139245,175139259,175139306,175139324,175139344,175139346,175139362,175139386,175139395,175139412,175139452,175139455,175139460,175139462,175139463,175139488,175139489,175139499,175139504,175139508,175139511,175139513,175139521,175139524,175139531,175139532,175139557,175139559,175139576,175139603,175139605,175139608,175139612,175139621,175139630,175139638,175139657,175139661,175139690,175139697,175139716,175139731)) {
             try {
                 sdCreditService.fundWallet(fofoId);
             } catch (ProfitMandiBusinessException pbse) {
                 LOGGER.info("Failed to fund wallet for - {}", fofoId);
+            }
-        }
+        }*/
         //transactionService.moveOrdersFulfimentWarehouseByBillingWarehouseId(7573);
+    }
     public void test3() throws Exception {
         //this.updatePartnerLimit();
         //creditNoteService.sendCnMails(YearMonth.now().minusMonths(2));
         //orderService.createMissingScratchOffers();
         LocalDateTime debitNoteDate = LocalDate.of(2024, Month.APRIL, 30).atStartOfDay();
         Map<Integer, Set<String>> fofoIdImeiReturnMap = new LinkedHashMap<>();
-        fofoIdImeiReturnMap.put(175139690,	new HashSet<>(Arrays.asList("862054078463472","863862077158219","866202075810858","866202077654494","866335072023651","866518078002718")));
+        /*fofoIdImeiReturnMap.put(175139690,	new HashSet<>(Arrays.asList("862054078463472","863862077158219","866202075810858","866202077654494","866335072023651","866518078002718")));
         fofoIdImeiReturnMap.put(175139414,	new HashSet<>(Arrays.asList("356494471684303","356494471857164","356494472062590","861753065078075","863511068904178","863511069732933","864179068109203","864179068112504","864259078789978","866202076254130","866202076254775","866657078259165","866657078272846","867492065809718","867907071107955","868565073021423","868565073022223","868565073386347")));
         fofoIdImeiReturnMap.put(175139603,	new HashSet<>(Arrays.asList("350886063151961","356412387787135","357594162824701","357594162874771","860600078193972","863862077025350","863862077875796","863967075815072","866335073794995","866335074287874","869116067546048")));
         fofoIdImeiReturnMap.put(175139657,	new HashSet<>(Arrays.asList("350933415734746","354324787135850","354324788766356","354990352512960","354990352580181","358142881241184","866611064207332","869116067600464")));
         fofoIdImeiReturnMap.put(175139223,	new HashSet<>(Arrays.asList("350210770983048","350210771169027","350210771179844","350210771180784","863975067090596","866611060326797","868565075758196","869452074016992","869452074609515","869452074609556","869452074976674","869452074978654")));
         fofoIdImeiReturnMap.put(175139557,	new HashSet<>(Arrays.asList("861977073551795","861977073552678","861977074486819","862046062571245","862046067278226","862046067734921","862046067756866","864468070394741","864468071225506","864468071668341","864468073604740","864468074854625","866993074734475")));
         fofoIdImeiReturnMap.put(175139366,	new HashSet<>(Arrays.asList("354324783144864","354324788632608","354889661849990","354990353239423","863967070558271","864718076129396","866657077789543","866657078285368","866657078508066","869116060977828","869116061054429","869116061208546")));
         fofoIdImeiReturnMap.put(175139412,	new HashSet<>(Arrays.asList("351115165488595","351115165491318","351115165491359","351115165491458","351115165492332","355358278026573","355358278081610","861888063460717","861977073052018","863816078633919","865883069477035","866335074538870","866993071639594")));
         fofoIdImeiReturnMap.put(175139504,	new HashSet<>(Arrays.asList("862054072660792","862054075971873","862054076312374","862054077948630","863816075363171","863862075442334","864718075894230","868938062122017","868938065268932","869452071940632","869452073034897","869452073158233","869452073158498","869452074159735")));
         fofoIdImeiReturnMap.put(175139201,	new HashSet<>(Arrays.asList("863718061956671","863862075497734","863862075596915","864718076078510","864718076134834","866335070211639","866611060437032","866611061133812")));
         fofoIdImeiReturnMap.put(175139362,	new HashSet<>(Arrays.asList("350201087545646","350201087547048","350201087547709","350201087548764","350201087597043","350201087597167","350201087597464","350201087597787","350201087598165","350201087600789","863718062929271","865883069477191","865883069477530","866335071174133","866518078023870","866518078243072","868938061053494")));
-        fofoIdImeiReturnMap.put(175139661,	new HashSet<>(Arrays.asList("860946077691031","861977074661155","862054073218855","866335070523694","867940069973476","868938062656477")));
+        fofoIdImeiReturnMap.put(175139661,	new HashSet<>(Arrays.asList("860946077691031","861977074661155","862054073218855","866335070523694","867940069973476","868938062656477")));*/
         fofoIdImeiReturnMap.put(175139556,	new HashSet<>(Arrays.asList("863718063534013","866335072895173","866335073390810")));
         fofoIdImeiReturnMap.put(175139721,	new HashSet<>(Arrays.asList("358250294549067","865883067508138","866993072210619")));
-        fofoIdImeiReturnMap.put(175139455,	new HashSet<>(Arrays.asList("358293804087913","866518078020694","866518078021650","866518078243676","866518078571936")));
+        /*fofoIdImeiReturnMap.put(175139455,	new HashSet<>(Arrays.asList("358293804087913","866518078020694","866518078021650","866518078243676","866518078571936")));
         fofoIdImeiReturnMap.put(175138674,	new HashSet<>(Arrays.asList("351115165482275","359197386868583","862054074428875","862054077945693","862054078556879","863967070559535","863975068705671","863975068705770","864468076196124","866186064235971","866186066185117","866186066186917","866518073607370","866518079641514","868938060476456","868938060501535","868938060717990","868938062656931")));
         fofoIdImeiReturnMap.put(175139559,	new HashSet<>(Arrays.asList("863718069016890","863816078879256","864468075283881","866335073245436","866335073403571","866657074268327","868024065473853","868956065899993","869452070362895","869452074030274")));
         fofoIdImeiReturnMap.put(175139575,	new HashSet<>(Arrays.asList("354324786659199","860388067452035","861220078009919","863816078878134","863862075841154","865388070857498","867907071407116")));
-        fofoIdImeiReturnMap.put(175139686,	new HashSet<>(Arrays.asList("866657078019106","866657078032869")));
+        fofoIdImeiReturnMap.put(175139686,	new HashSet<>(Arrays.asList("866657078019106","866657078032869")));*/
-        this.processOrdersToRebill(fofoIdImeiReturnMap, debitNoteDate);
+        //this.processOrdersToRebill(fofoIdImeiReturnMap, debitNoteDate);
-        purchaseReturnService.processReturn(fofoIdImeiReturnMap, debitNoteDate);
+        purchaseReturnService.fixReturns(fofoIdImeiReturnMap, debitNoteDate);
+    }
     private void processOrdersToRebill(Map<Integer, Set<String>> fofoIdImeiReturnMap, LocalDateTime debitNoteDate) throws Exception {
     public void processActivatedImeisForSchemes() throws ProfitMandiBusinessException {
         schemeService.processActivatedImeisForSchemes();
+    }
     @Autowired
+    SidbiService sidbiService;
+    public void processSidbiDeductions() {
-    FofoSidbiSanctionRepository fofoSidbiSanctionRepository;
+        sidbiService.migrateSanctions();
+        sidbiService.processDeductions();
+    }
     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, 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))
                 .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()) {
             LocalDateTime firstBillingDate = transactionRepository.getFirstBillingDate(fofoId);
             CreditAccount creditAccount = creditAccountMap.get(fofoId);
             CurrentPartnerDailyInvestment currentPartnerDailyInvestment = currentPartnerDailyInvestmentMap.get(fofoId);
-            List<FofoSidbiSanction> fofoSidbiSanctions = fofoSidbiSanctionMap.get(fofoId);
-            BigDecimal suggestedAmount = this.getSuggestedAmount(creditAccount, currentPartnerDailyInvestment, fofoSidbiSanctions);
+            BigDecimal suggestedAmount = this.getSuggestedAmount(creditAccount, currentPartnerDailyInvestment, fofoSidbiLimitMap.get(fofoId));
             SDCreditRequirement sdCreditRequirement = sdCreditRequirementMap.get(fofoId);
             LOGGER.info("suggestedAmount {} ", suggestedAmount);
             if (sdCreditRequirement == null) {
+        }
+    }
-    private BigDecimal getSuggestedAmount(CreditAccount creditAccount, CurrentPartnerDailyInvestment currentPartnerDailyInvestment, List<FofoSidbiSanction> fofoSidbiSanctions) {
+    private BigDecimal getSuggestedAmount(CreditAccount creditAccount, CurrentPartnerDailyInvestment currentPartnerDailyInvestment, BigDecimal sidbiLimit) {
         BigDecimal suggestedAmount = BigDecimal.ZERO;
         //1 LAC
         double limitValue = 100000;
         if (creditAccount == null || creditAccount.getGateway().equals(Gateway.SDDIRECT)) {
                 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) {
+        } else if (creditAccount.getGateway().equals(Gateway.SIDBI) && sidbiLimit != null) {
             //Left
-            FofoSidbiSanction fofoSidbiSanction = fofoSidbiSanctions.get(0);
-            int monthsLeft = fofoSidbiSanction.getMonthsLeft(ProfitMandiConstants.SIDBI_TENUERE_MONTHS);
-            if (monthsLeft >= 0) {
+            suggestedAmount = sidbiLimit;
-                suggestedAmount = BigDecimal.valueOf(fofoSidbiSanction.getSanctionAmount() * monthsLeft / ProfitMandiConstants.SIDBI_TENUERE_MONTHS);
-            }
+        }
         return suggestedAmount;
+    }
     public void notifyDefaultLoans() throws ProfitMandiBusinessException, MessagingException, IOException {

Subversion Repositories SmartDukaan

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