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

 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.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.repository.cs.PositionRepository;
 import com.spice.profitmandi.dao.repository.cs.TicketRepository;
 import com.spice.profitmandi.dao.repository.dtr.*;
 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.UserRepository;
 import com.spice.profitmandi.dao.repository.warehouse.*;
 import com.spice.profitmandi.dao.service.SidbiService;
 import com.spice.profitmandi.service.*;
 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;
     RedisCacheManager redisFortnightlyCacheManage;
     @Autowired
     GstProAuthService gstProAuthService;
+    @Autowired
+    GstProService gstProService;
+    @Autowired
+    WarehouseProviderRepository warehouseProviderRepository;
     public void test() throws Exception {
         List<SDCreditRequirement> sdCreditRequirements = sdCreditRequirementRepository.selectAll();
-        for (SDCreditRequirement sdCreditRequirement : sdCreditRequirements) {
+        /*for (SDCreditRequirement sdCreditRequirement : sdCreditRequirements) {
             long utilizationAmount = sdCreditService.getUtilizationAmount(sdCreditRequirement.getFofoId());
             if (Math.abs(sdCreditRequirement.getUtilizedAmount().doubleValue() - utilizationAmount) > 5) {
                 sdCreditRequirement.setUtilizedAmount(BigDecimal.valueOf(utilizationAmount));
+            }
+        }*/
+        //warehouseProviderRepository.selectAllByWarehouseId(1);
+        /*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);
         }
+        Map<String, String> authMap = gstProAuthService.getAuthHeaders(sellerGstin);
+        String authToken = respAuthPl.getData().getAuthToken();
+        authMap.put("AuthToken", authToken);
+        authMap.put("QrCodeSize", "250");
+        authMap.put("ParseIrnResp", "1");
+        authMap.put("Content-Type", "application/json; charset=utf-8");
+        authMap.put("AuthToken", authToken);
+        authMap.put("QrCodeSize", "250");
+        authMap.put("ParseIrnResp", "1");
+        authMap.put("Content-Type", "application/json; charset=utf-8");
+        System.out.println(gstProService.getEInvoiceByIrn(authMap, "5d95f5759fdfe48aeb86a7605727f37fc472d779a0f7bfbff98669e06dfd5ab2"));*/
+        //List<Loan> loans = loanRepository.selectAllLoan();
+        /*System.out.println(ageingService.getAllAgeingForWarehouseBilling(8718, Arrays.asList(34354)));
+        System.out.println(ageingService.getAllAgeingForWarehouseBilling(8646, Arrays.asList(36323)));
+        System.out.println(ageingService.getAllAgeingForWarehouseBilling(8954, Arrays.asList(34358)));*/
+        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) {
+                }
+            }
+        }
+    }
-    public void test2() throws Exception {
-        System.out.println("Starting test");
-        processScheme(LocalDate.of(2023, 05, 06).atStartOfDay(), LocalDate.of(2023, 05, 9).atStartOfDay(), false);
-        /*partnerTypeChangeService.getTypeOnDate(175139287, LocalDate.of(2023,02, 01));
-        partnerTypeChangeService.getTypeOnDate(175139287, LocalDate.of(2023,03, 01));
-        partnerTypeChangeService.getTypeOnDate(175139287, LocalDate.of(2023,04, 01));
-        FofoStore fs = fofoStoreRepository.selectByRetailerId(175139287);
-        this.rolloutMarginForStoreOnMonth(fs, LocalDate.of(2023, 2, 1));
-        this.rolloutMarginForStoreOnMonth(fs, LocalDate.of(2023, 3, 1));*/
-        //this.sendMailForSamsungRebilling();
-        /*List<PurchaseReturnItem> purchaseReturnItems = purchaseReturnItemRepository.selectPurchaseReturnByStatuses(Arrays.asList(PurchaseReturnStatus.DEBIT_NOTE_CREATED));
-        Map<Integer, List<PurchaseReturnItem>> inventoryItemsMap = purchaseReturnItems.stream().collect(Collectors.groupingBy(x -> x.getDebitNoteId()));
-        for (Map.Entry<Integer, List<PurchaseReturnItem>> debitNotePurcahseReturnMap : inventoryItemsMap.entrySet()) {
-            List<InventoryItem> inventoryItems = inventoryItemRepository.selectAllByIds(debitNotePurcahseReturnMap.getValue().stream().map(x -> x.getInventoryItemId()).collect(Collectors.toList()));
-            offerService.reverseAdditionalSelloutSchemes(debitNotePurcahseReturnMap.getValue().get(0).getFofoId(), inventoryItems);
-        }*/
-        //this.sendMailForAgeingAlert();
-        //this.sendMailForAgeingAlert();
-        //System.out.println(brandRegionMappingRepository.getAvailabilityToVendorWarehouse(Arrays.asList(33353), 7720));
-    }
     public void sendMailForSamsungRebilling() throws Exception {
         List<BilledImeiModel> samsungModels = warehouseInventoryItemRepository.findByBillingDateBrand(LocalDate.now(), "Samsung");
         LOGGER.info("SamsungModels {}", samsungModels);
         samsungModels = samsungModels.stream().sorted(Comparator.comparing(x -> x.getPcmDate() == null ? -1 : 1)).collect(Collectors.toList());
         if (samsungModels.size() > 0) {
     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);
+        //TODO:Remove this code
+        Loan specificLoan = loanRepository.selectByLoanId(20230);
+        loans.add(0, specificLoan);
+        //TODO:Upto here
         if (!loans.isEmpty()) {
             for (Loan loan : loans) {
                 double settledAmount = sdCreditService.settleLoan(loan);

Subversion Repositories SmartDukaan

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