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

 import com.smartdukaan.cron.scheduled.runnables.PurchaseMigration;
 import com.spice.profitmandi.common.enumuration.*;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.*;
 import com.spice.profitmandi.common.services.ReporticoService;
-import com.spice.profitmandi.common.services.mandii.AccountStatusResponseOut;
-import com.spice.profitmandi.common.services.mandii.EligibilityStatusEnum;
 import com.spice.profitmandi.common.services.mandii.MandiiService;
 import com.spice.profitmandi.common.util.FileUtil;
 import com.spice.profitmandi.common.util.FormattingUtils;
 import com.spice.profitmandi.common.util.PdfUtils;
 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.dao.entity.dtr.*;
 import com.spice.profitmandi.dao.entity.fofo.*;
 import com.spice.profitmandi.dao.entity.inventory.*;
 import com.spice.profitmandi.dao.entity.logistics.AST;
 import com.spice.profitmandi.dao.entity.logistics.ASTRepository;
-import com.spice.profitmandi.dao.entity.logistics.WarehouseProvider;
+import com.spice.profitmandi.dao.entity.onBoarding.LoiForm;
 import com.spice.profitmandi.dao.entity.transaction.*;
 import com.spice.profitmandi.dao.entity.user.*;
 import com.spice.profitmandi.dao.entity.warehouse.WarehouseInventoryItem;
 import com.spice.profitmandi.dao.entity.warehouse.WarehouseScan;
 import com.spice.profitmandi.dao.enumuration.auth.CollectionRemark;
 import com.spice.profitmandi.dao.enumuration.fofo.Gateway;
 import com.spice.profitmandi.dao.enumuration.fofo.PaymentStatus;
 import com.spice.profitmandi.dao.enumuration.fofo.ReturnType;
 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
 import com.spice.profitmandi.dao.enumuration.inventory.VendorCatalogPricingStatus;
+import com.spice.profitmandi.dao.enumuration.onBorading.onBoardingFormEnums.LoiStatus;
 import com.spice.profitmandi.dao.enumuration.transaction.CreditRisk;
 import com.spice.profitmandi.dao.enumuration.transaction.LoanReferenceType;
 import com.spice.profitmandi.dao.enumuration.transaction.PriceDropImeiStatus;
 import com.spice.profitmandi.dao.enumuration.transaction.SchemePayoutStatus;
 import com.spice.profitmandi.dao.model.*;
 import com.spice.profitmandi.dao.repository.fofo.*;
 import com.spice.profitmandi.dao.repository.inventory.*;
 import com.spice.profitmandi.dao.repository.logistics.WarehouseProviderRepository;
 import com.spice.profitmandi.dao.repository.transaction.*;
 import com.spice.profitmandi.dao.repository.user.AddressRepository;
+import com.spice.profitmandi.dao.repository.user.LoiFormRepository;
 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.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.gstpro.api.model.E_InvoiceCommon;
 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;
 import com.spice.profitmandi.service.transaction.CreditNoteService;
 import com.spice.profitmandi.service.transaction.SDCreditService;
 import com.spice.profitmandi.service.transaction.TransactionService;
 import com.spice.profitmandi.service.transaction.invoicing.InvoiceService;
 import com.spice.profitmandi.service.user.RetailerService;
+import com.spice.profitmandi.service.user.StoreTimelineTatService;
 import com.spice.profitmandi.service.wallet.CommonPaymentService;
 import com.spice.profitmandi.service.wallet.WalletService;
 import com.spice.profitmandi.service.warehouse.PurchaseOrderService;
 import com.spice.profitmandi.service.warehouse.WarehouseInventoryService;
 import com.spice.profitmandi.service.warehouse.WarehouseService;
 import in.shop2020.model.v1.order.OrderStatus;
 import in.shop2020.model.v1.order.WalletReferenceType;
 import org.apache.commons.io.output.ByteArrayOutputStream;
 import org.apache.commons.lang.StringUtils;
-import org.apache.commons.lang3.tuple.Pair;
 import org.apache.http.client.methods.CloseableHttpResponse;
 import org.apache.http.client.methods.HttpPost;
 import org.apache.http.conn.HttpHostConnectException;
 import org.apache.http.entity.StringEntity;
 import org.apache.http.impl.client.CloseableHttpClient;
     @Autowired
     GstProService gstProService;
     @Autowired
     WarehouseProviderRepository warehouseProviderRepository;
-    public void test() throws Exception {
-        //runOnceTasks.migratePurchaseFix();
-        //sdCreditService.fundWallet(175139079);
-        //runOnceTasks.migratePurchase();
-        //this.persistRbmTodayTargets();
-        //this.persistRbmTodayAchievements();
-        //Should return 22792
-        //sdCreditService.createLoan(175139262,76000,0,"Amount added for loan adjustment");
-        //this.checkfocusedModelInPartnerStock();
-       // List<SDCreditRequirement> sdCreditRequirements = sdCreditRequirementRepository.selectAll();
-        /*for (SDCreditRequirement sdCreditRequirement : sdCreditRequirements) {
-            long utilizationAmount = sdCreditService.getUtilizationAmount(sdCreditRequirement.getFofoId());
-            if (Math.abs(sdCreditRequirement.getUtilizedAmount().doubleValue() - utilizationAmount) > 5) {
-                sdCreditRequirement.setUtilizedAmount(BigDecimal.valueOf(utilizationAmount));
-            }
-        }*/
+    @Autowired
-        //warehouseProviderRepository.selectAllByWarehouseId(1);
+    LoiFormRepository loiFormRepository;
-        /*String sellerGstin = GstProService.SANDBOX_GST_NUMBER;
-        E_InvoiceCommon.RespAuthPl respAuthPl = gstProAuthService.getAuthToken(sellerGstin);
-        if (LocalDateTime.now().isAfter(respAuthPl.getData().TokenExpiry)) {
-            redisFortnightlyCacheManage.getCache("gstAuthToken").evict(sellerGstin);
-            respAuthPl = gstProAuthService.getAuthToken(sellerGstin);
-        }
+    @Autowired
-        Map<String, String> authMap = gstProAuthService.getAuthHeaders(sellerGstin);
+    PartnerOnBoardingPanelRepository partnerOnBoardingPanelRepository;
-        String authToken = respAuthPl.getData().getAuthToken();
-        authMap.put("AuthToken", authToken);
-        authMap.put("QrCodeSize", "250");
+    @Autowired
-        authMap.put("ParseIrnResp", "1");
-        authMap.put("Content-Type", "application/json; charset=utf-8");
-        authMap.put("AuthToken", authToken);
+    StoreTimelineTatService storeTimelineTatService;
-        authMap.put("QrCodeSize", "250");
+    @Autowired
-        authMap.put("ParseIrnResp", "1");
+    PartnerDealerRepository partnerDealerRepository;
-        authMap.put("Content-Type", "application/json; charset=utf-8");
-        System.out.println(gstProService.getEInvoiceByIrn(authMap, "5d95f5759fdfe48aeb86a7605727f37fc472d779a0f7bfbff98669e06dfd5ab2"));*/
-        //List<Loan> loans = loanRepository.selectAllLoan();
+    public void test() throws Exception {
-        /*System.out.println(ageingService.getAllAgeingForWarehouseBilling(8718, Arrays.asList(34354)));
+        System.out.println("test start");
-        System.out.println(ageingService.getAllAgeingForWarehouseBilling(8646, Arrays.asList(36323)));
+//        csService.getPartnerIdSalesHeaders();
-        System.out.println(ageingService.getAllAgeingForWarehouseBilling(8954, Arrays.asList(34358)));*/
+        System.out.println("test end");
-        //System.out.println(ageingService.getAgeingForWarehouseBilling(8718, Arrays.asList(new ItemIdQuantity(34354,10))));
+    }
     public void test4() throws Exception {
         List<Integer> offerIds = Arrays.asList(2882, 2881, 2880, 2879, 2878, 2877, 2876, 2875, 2874, 2873, 2872, 2871, 2870, 2869, 2868, 2867, 2866, 2865, 2864, 2863, 2862, 2861, 2860, 2859, 2858, 2857, 2856, 2855, 2854, 2853, 2852, 2851, 2850, 2849, 2847, 2846, 2845, 2844, 2843, 2842, 2841, 2840, 2839, 2838, 2837, 2836, 2835, 2834, 2833, 2832, 2831, 2830, 2829, 2828, 2827, 2826, 2825, 2824, 2823, 2822, 2821, 2820, 2819, 2818, 2817, 2816, 2815, 2814, 2813, 2812, 2811, 2810, 2809, 2808, 2807, 2806, 2805, 2804, 2803, 2802, 2801, 2800, 2799, 2798, 2797, 2796, 2795, 2794, 2793, 2792, 2791, 2790, 2789, 2788, 2787, 2786, 2785, 2784, 2783, 2782, 2781, 2780, 2777, 2776, 2775, 2774, 2773, 2772, 2771, 2770, 2769, 2768, 2767, 2766, 2765, 2764, 2763, 2762, 2761, 2760, 2759, 2758, 2757, 2756, 2755, 2754, 2753, 2752, 2751, 2750, 2749, 2748, 2747, 2746, 2745, 2744, 2723, 2722, 2721, 2720, 2719, 2718, 2717, 2716, 2715, 2714, 2713, 2712, 2711, 2710, 2709, 2708, 2707, 2706, 2705, 2704, 2703, 2702, 2701, 2700, 2699, 2698, 2697, 2696, 2695, 2694, 2693, 2692, 2691, 2690, 2494, 2493, 2492, 2491, 2490, 2489, 2488, 2487, 2486, 2485, 2484, 2483, 2482, 2481, 2480, 2479, 2478, 2477, 2476, 2475, 2474, 2473, 2472, 2471, 2470, 2469, 2466, 2465, 2464, 2463, 2462, 2461, 2460, 2459, 2458, 2457, 2456, 2455, 2454, 2453, 2452, 2451, 2450, 2449, 2448, 2447, 2446, 2445, 2444, 2443, 2442, 2441, 2440, 2439, 2407, 2406, 2405, 2404, 2403, 2402, 2401, 2400, 2399, 2398, 2397, 2396, 2395, 2394, 2393, 2392, 2391, 2390, 2389, 2388, 2387, 2386, 2385, 2384, 2383, 2382, 2381, 2117, 2116, 2115, 2114, 2113, 2112, 2111, 2110, 2109, 2108, 2107, 2106, 2105, 2104, 2103, 2102, 2101, 2100, 2099, 2098, 2077);
         for (Integer offerId : offerIds) {
             Offer fromOffer = offerRepository.selectById(offerId);
             CreateOfferRequest createOfferRequest = offerService.getCreateOfferRequest(fromOffer);
             System.out.println("Processing offer Id " + fromOffer);
             offerService.processActivationtOffer(createOfferRequest);
+        }
-        //sdCreditService.checkLoans();
-        /*System.out.println(warehouseService.moveToBad(Arrays.asList("860374066889716",
-                "863587077946699",
-                "865883067303639",
-                "868116066180113",
-                "868116066179719")));*/
-        /*System.out.println(warehouseService.moveToGood(Arrays.asList("354814720314877",
-                "43356/c21100001116",
-                "34850/c21100054629")));*/
-        //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)) {
-            try {
-                sdCreditService.fundWallet(fofoId);
-            } catch (ProfitMandiBusinessException pbse) {
-                LOGGER.info("Failed to fund wallet for - {}", fofoId);
-            }
-        }*/
-        //transactionService.moveOrdersFulfimentWarehouseByBillingWarehouseId(7573);
+        this.processSidbiDeductions();
+    }
     public void test3() throws Exception {
         List<Long> payoutIds = Arrays.asList();
         List<OfferPayout> offerPayouts = offerPayoutRepository.selectAllByIds(payoutIds);
+        }
         return partnerIdSalesHeadersMap;
+    }
-    public void persistRbmTodayTargets() throws Exception{
+    public void persistRbmTodayTargets() throws Exception {
         rbmTargetService.setMovementWiseRbmTargets();
+    }
-    public void persistRbmTodayAchievements() throws Exception{
+    public void persistRbmTodayAchievements() throws Exception {
         rbmTargetService.setMovementWiseRbmAchievement();
+    }
     public void sendPartnerInvestmentDetails() throws Exception {
         this.sendPartnerInvestmentDetails(null);
                     httpPost.setHeader("Content-Type", "application/json");
                     StringEntity entity = new StringEntity(payload.toString());
                     httpPost.setEntity(entity);
                     CloseableHttpResponse response = client.execute(httpPost);
-                    LOGGER.info("google FCM status code: {}",response.getStatusLine().getStatusCode());
+                    LOGGER.info("google FCM status code: {}", response.getStatusLine().getStatusCode());
                     String responseBody = new BufferedReader(new InputStreamReader(response.getEntity().getContent()))
                             .lines().collect(Collectors.joining("\n"));
                     if (response.getStatusLine().getStatusCode() == 200) {
                         pushNotification.setSentTimestamp(LocalDateTime.now());
                     } else {
                 fm.setPendingIndentQty(processingQty);
                 fm.setShortageQty(shortageQty);
                 fm.setPoAvailability(allColorPoAvailability);
                 fm.setDp(tagListing.getSellingPrice());
                 fm.setWarehouseName(warehouseMap.get(customRetailer.getWarehouseId()));
-                if(partnerIdSalesHeadersMap.get(fofoId) != null){
+                if (partnerIdSalesHeadersMap.get(fofoId) != null) {
                     fm.setStateManager(partnerIdSalesHeadersMap.get(fofoId).getRegionalManager());
                     fm.setTerritoryManager(partnerIdSalesHeadersMap.get(fofoId).getTerritoryManager());
-                }else {
+                } else {
-                    LOGGER.info("else fofoId - {}",fofoId);
+                    LOGGER.info("else fofoId - {}", fofoId);
                     fm.setStateManager("");
                     fm.setTerritoryManager("");
+                }
                 fm.setItemName(items.get(0).getBrand() + items.get(0).getModelNumber() + items.get(0).getModelName());
                 focusedModelShortageList.add(fm);
+            }
+        }
-        LOGGER.info("focusedModelShortageReportMap {}",focusedModelShortageReportMap);
+        LOGGER.info("focusedModelShortageReportMap {}", focusedModelShortageReportMap);
         if (!focusedModelShortageReportMap.isEmpty()) {
             String fileName = "Stock Alert-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
             Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
             Map<String, List<List<?>>> emailRowsMap = new HashMap<>();
                 } catch (Exception e2) {
                     e2.printStackTrace();
+                }
                 String[] sendToArray = new String[]{
-                        entry.getKey(), "alok.divedi@smartdukaan.com","ranu.rajput@smartdukaan.com"
+                        entry.getKey(), "alok.divedi@smartdukaan.com", "ranu.rajput@smartdukaan.com"
                 };
                 try {
     public void loanSettlement() throws Exception {
         List<Loan> blockedLoans = loanRepository.selectAllActiveLoan().stream().filter(x -> x.getFreeDays() >= 365).collect(toList());
         List<Loan> loans = loanRepository.selectAllActiveLoan().stream().filter(x -> x.getFreeDays() < 365).collect(toList());
         //Settle blocked loans only when normal loans are settled
-            loans.addAll(blockedLoans);
+        loans.addAll(blockedLoans);
-            //TODO:Remove this code
+        //TODO:Remove this code
-            Loan specificLoan = loanRepository.selectByLoanId(20073);
+        Loan specificLoan = loanRepository.selectByLoanId(20073);
-            loans.add(0, specificLoan);
+        loans.add(0, specificLoan);
-            //TODO:Upto here
+        //TODO:Upto here
-            if (!loans.isEmpty()) {
+        if (!loans.isEmpty()) {
-                for (Loan loan : loans) {
-                    double settledAmount = sdCreditService.settleLoan(loan);
-                    List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectHoldSanctionByFofoId(loan.getFofoId());
-                    for (SanctionRequest sanctionRequest : sanctionRequests) {
-                        List<Order> orders = orderRepository.selectAllByTransactionId(sanctionRequest.getTransactionId());
-                        if (orders.size() == 0) {
-                            LOGGER.info("Could not find orders - for Sanction Request {}", sanctionRequest);
-                            continue;
-                        }
-                        if (settledAmount >= sanctionRequest.getPendingAmount().doubleValue()) {
-                            settledAmount -= sanctionRequest.getPendingAmount().doubleValue();
-                            sanctionRequest.setPendingAmount(BigDecimal.valueOf(0));
-                            this.sendUnholdEmail(orders);
-                        } else {
+            for (Loan loan : loans) {
-                            double pendinAmount = sanctionRequest.getPendingAmount().doubleValue() - settledAmount;
-                            System.out.println("Pending Amount - " + pendinAmount);
+                double settledAmount = sdCreditService.settleLoan(loan);
-                            sanctionRequest.setPendingAmount(BigDecimal.valueOf(pendinAmount));
-                            break;
+                List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectHoldSanctionByFofoId(loan.getFofoId());
+                for (SanctionRequest sanctionRequest : sanctionRequests) {
+                    List<Order> orders = orderRepository.selectAllByTransactionId(sanctionRequest.getTransactionId());
+                    if (orders.size() == 0) {
+                        LOGGER.info("Could not find orders - for Sanction Request {}", sanctionRequest);
+                        continue;
-                        }
+                    }
+                    if (settledAmount >= sanctionRequest.getPendingAmount().doubleValue()) {
+                        settledAmount -= sanctionRequest.getPendingAmount().doubleValue();
+                        sanctionRequest.setPendingAmount(BigDecimal.valueOf(0));
+                        this.sendUnholdEmail(orders);
+                    } else {
+                        double pendinAmount = sanctionRequest.getPendingAmount().doubleValue() - settledAmount;
+                        System.out.println("Pending Amount - " + pendinAmount);
+                        sanctionRequest.setPendingAmount(BigDecimal.valueOf(pendinAmount));
+                        break;
+                    }
-                }
+                }
+            }
+        }
+    }
+            }
+        }
         String messageText = this.getMessageForDueDateExtend(defaultLoans);
-        this.sendMailOfHtmlFormat(googleMailSender, new String[]{"puneet.wahi@smartdukaan.com","rahul.latwal@smartdukaan.com"}, messageText, null, subject);
+        this.sendMailOfHtmlFormat(googleMailSender, new String[]{"puneet.wahi@smartdukaan.com", "rahul.latwal@smartdukaan.com"}, messageText, null, subject);
         for (Loan defaultLoan : defaultLoans) {
             List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(defaultLoan.getId());
             double amount = loanStatements.stream().map(x -> x.getAmount()).collect(Collectors.summingDouble(x -> x.doubleValue()));
                 // Check if an entry already exists in the FofoOpeningStock table
                 FofoOpeningStock existingStock = fofoOpeningStockRepository.findByFofoIdAndCatalogId(fofoId, catalogId);
                 if (existingStock != null) {
+                    if(stockQty < 1 && existingStock.getOpeningDate().isBefore(LocalDate.now().minusDays(7))){
+                        fofoOpeningStockRepository.delete(existingStock);
+                    }
                     if (existingStock.getOpeningQty() < stockQty) {
                         existingStock.setOpeningQty(stockQty);
                         existingStock.setCurrentQty(stockQty);
                         existingStock.setOpeningDate(openingDate);
                         LOGGER.info("if condition exist {}");
-                    }else if(existingStock.getCurrentQty() >= existingStock.getOpeningQty()){
+                    } else if (existingStock.getCurrentQty() >= existingStock.getOpeningQty()) {
-                            existingStock.setOpeningQty(existingStock.getCurrentQty());
+                        existingStock.setOpeningQty(existingStock.getCurrentQty());
-                            existingStock.setOpeningDate(LocalDate.now());
+                        existingStock.setOpeningDate(LocalDate.now());
                     } else if (existingStock.getOpeningDate().isBefore(LocalDate.now().minusDays(7))) {
                         int averageQty = Math.round((existingStock.getCurrentQty() + existingStock.getOpeningQty()) / 2.0f);
                         if (averageQty == 1 && existingStock.getOpeningQty() == 1 && existingStock.getCurrentQty() == 0) {
                             // Delete the existing stock entry from the table

Subversion Repositories SmartDukaan

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