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

 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.GenericRepository;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.auth.NonSdBuyingRepository;
 import com.spice.profitmandi.dao.repository.auth.PartnerCollectionRemarkRepository;
 import com.spice.profitmandi.dao.repository.catalog.*;
 import com.spice.profitmandi.dao.repository.cs.CsService;
 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.order.OrderService;
+import com.spice.profitmandi.service.pricecircular.PriceCircularService;
 import com.spice.profitmandi.service.pricing.PriceDropService;
 import com.spice.profitmandi.service.recharge.provider.OxigenRechargeProviderService;
 import com.spice.profitmandi.service.recharge.provider.ThinkWalnutDigitalRechargeProviderService;
+import com.spice.profitmandi.service.scheme.InventoryPayoutModel;
 import com.spice.profitmandi.service.scheme.SchemeService;
 import com.spice.profitmandi.service.serviceConfig.ServiceConfigService;
 import com.spice.profitmandi.service.transaction.CreditNoteService;
 import com.spice.profitmandi.service.transaction.SDCreditService;
 import com.spice.profitmandi.service.transaction.TransactionService;
+    }
     @Autowired
     private ReporticoCacheTableRepository reporticoCacheTableRepository;
-    public void processScheme(int offset, boolean dryRun) throws Exception {
-        LocalDateTime startDate = LocalDateTime.of(LocalDate.now(), LocalTime.MIDNIGHT).minusDays(offset);
-        LocalDateTime endDate = startDate.plusDays(30);
-        processScheme(startDate, endDate, dryRun);
-    }
     public void processSchemeOut(List<String> invoiceNumbers) throws Exception {
         for (String invoiceNumber : invoiceNumbers) {
             System.out.println("Invoice Number - " + invoiceNumber);
             FofoOrder fofoOrder = fofoOrderRepository.selectByInvoiceNumber(invoiceNumber);
             //orderService.reverseScheme(fofoOrder);
             Purchase purchase = purchaseRepository.selectByPurchaseReference(invoiceNumber);
             schemeService.processSchemeIn(purchase.getId(), purchase.getFofoId());
+        }
+    }
-    public void processScheme(int offset, int durationDays, boolean dryRun) throws Exception {
-        LocalDateTime startDate = LocalDateTime.of(LocalDate.now(), LocalTime.MIDNIGHT).minusDays(offset);
-        LocalDateTime endDate = startDate.plusDays(durationDays);
-        processScheme(startDate, endDate, dryRun);
-    }
-    public void processScheme(boolean dryRun) throws Exception {
-        LocalDateTime fromDate = LocalDateTime.now().minusDays(30);
-        processScheme(fromDate, LocalDateTime.now(), dryRun);
-    }
     public void processScheme(LocalDateTime startDate, LocalDateTime endDate, boolean dryRun) throws Exception {
         LOGGER.info("Started execution at {}", LocalDateTime.now());
         System.out.println(
                 "InventoryId\tSerialNumber\tItem Id\tScheme Id\tScheme Name\tScheme Type\tAmount Type\tDP\tTaxable\tScheme Amount\tAmount Paid");
         try {
         LocalDateTime cashbackTime = LocalDateTime.now();
         int referenceId = (int) Timestamp.valueOf(cashbackTime).getTime() / 1000;
         List<RechargeTransaction> pendingTransactions = rechargeTransactionRepository.getPendingCashBackRehargeTransactions();
         Map<Object, Double> totalRetailerCashbacks = pendingTransactions.stream().collect(
                 groupingBy(x -> x.getRetailerId(), Collectors.summingDouble(x -> x.getCommission())));
-        for (Map.Entry<Object, Double> totalRetailerCashback : totalRetailerCashbacks.entrySet()) {
+        for (Entry<Object, Double> totalRetailerCashback : totalRetailerCashbacks.entrySet()) {
             int retailerId = (Integer) totalRetailerCashback.getKey();
             float amount = totalRetailerCashback.getValue().floatValue();
             if (Math.round(amount) > 0) {
                 walletService.addAmountToWallet(retailerId, referenceId, WalletReferenceType.CASHBACK, "Recharge Cashback", Math.round(amount), LocalDateTime.now());
+            }
         System.out.println(ageingModelMap.size());
         List<PartnerAgeingModel> partnerAgeingModels = ageingService.getAllAgeingForTertiary();
-        org.apache.commons.io.output.ByteArrayOutputStream byteArrayOutputStream = FileUtil.getCSVByteStream(Arrays.asList("InventoryItemId", "Serial Number", "Item Id", "Brand", "Model Name", "ModelNumber", "Color", "Exceed Days", "Last ScanType", "Supplier Name", "Current Warehouse", "First Warehouse", "Invoice Number", "Invoice Date"), ageingModelMap.values().stream().map(x -> Arrays.asList(x.getInventoryItemId(), x.getSerialNumber(), x.getItemId(), x.getBrand(), x.getModelName(), x.getModelNumber(), x.getColor(), x.getExceedDays(), x.getLastScanType(), x.getSupplierName(), x.getCurrentWarehouse(), x.getFirstWarehouse(), x.getInvoiceNumber(), FormattingUtils.formatDate(x.getInvoiceDate()))).collect(Collectors.toList()));
+        ByteArrayOutputStream byteArrayOutputStream = FileUtil.getCSVByteStream(Arrays.asList("InventoryItemId", "Serial Number", "Item Id", "Brand", "Model Name", "ModelNumber", "Color", "Exceed Days", "Last ScanType", "Supplier Name", "Current Warehouse", "First Warehouse", "Invoice Number", "Invoice Date"), ageingModelMap.values().stream().map(x -> Arrays.asList(x.getInventoryItemId(), x.getSerialNumber(), x.getItemId(), x.getBrand(), x.getModelName(), x.getModelNumber(), x.getColor(), x.getExceedDays(), x.getLastScanType(), x.getSupplierName(), x.getCurrentWarehouse(), x.getFirstWarehouse(), x.getInvoiceNumber(), FormattingUtils.formatDate(x.getInvoiceDate()))).collect(Collectors.toList()));
-        org.apache.commons.io.output.ByteArrayOutputStream byteArrayOutputStream2 = FileUtil.getCSVByteStream(Arrays.asList("InventoryItemId", "Serial Number", "Item Id", "Brand", "Model Name", "ModelNumber", "Color", "Partner Id", "Partner Code", "Partner Name", "Activation Type", "City", "State", "Billing Date", "Exceed Days", "Max Ageing", "Activation Date"), partnerAgeingModels.stream().map(x -> Arrays.asList(x.getInventoryItemId(), x.getSerialNumber(), x.getItemId(), x.getBrand(), x.getModelName(), x.getModelNumber(), x.getColor(), x.getFofoId(), x.getFofoCode(), x.getFofoName(), x.getActivationType(), x.getFofoCity(), x.getFofoState(), FormattingUtils.formatDate(x.getBillingDate()), x.getExceedDays(), x.getMaxAgeingDays(), x.getActivationDate())).collect(Collectors.toList()));
+        ByteArrayOutputStream byteArrayOutputStream2 = FileUtil.getCSVByteStream(Arrays.asList("InventoryItemId", "Serial Number", "Item Id", "Brand", "Model Name", "ModelNumber", "Color", "Partner Id", "Partner Code", "Partner Name", "Activation Type", "City", "State", "Billing Date", "Exceed Days", "Max Ageing", "Activation Date"), partnerAgeingModels.stream().map(x -> Arrays.asList(x.getInventoryItemId(), x.getSerialNumber(), x.getItemId(), x.getBrand(), x.getModelName(), x.getModelNumber(), x.getColor(), x.getFofoId(), x.getFofoCode(), x.getFofoName(), x.getActivationType(), x.getFofoCity(), x.getFofoState(), FormattingUtils.formatDate(x.getBillingDate()), x.getExceedDays(), x.getMaxAgeingDays(), x.getActivationDate())).collect(Collectors.toList()));
-        Utils.Attachment attachment1 = new Utils.Attachment("secondary-alert.csv", new ByteArrayResource(byteArrayOutputStream.toByteArray()));
+        Attachment attachment1 = new Attachment("secondary-alert.csv", new ByteArrayResource(byteArrayOutputStream.toByteArray()));
-        Utils.Attachment attachment2 = new Utils.Attachment("tertiary-alert.csv", new ByteArrayResource(byteArrayOutputStream2.toByteArray()));
+        Attachment attachment2 = new Attachment("tertiary-alert.csv", new ByteArrayResource(byteArrayOutputStream2.toByteArray()));
         String mailSubject = "Stock ageing Alert";
         Utils.sendMailWithAttachments(mailSender, new String[]{"deena.nath@smartdukaan.com"}, null, mailSubject, "PFA", attachment1, attachment2);
+    }
     InvoiceService invoiceService;
     @Autowired
     WarehouseService warehouseService;
+    @Autowired
+    GenericRepository genericRepository;
+    @Autowired
+    PriceCircularService priceCircularService;
     public void test() throws Exception {
+        LocalDate startDate = LocalDate.of(2024, Month.MAY, 1);
+        List<PriceDropIMEI> priceDropIMEIList = priceDropIMEIRepository.selectAllByCreditedBetween(startDate.atStartOfDay(), startDate.plusMonths(1).atTime(Utils.MAX_TIME));
+        Set<Integer> inventoryItemIds = priceDropIMEIList.stream().map(x -> x.getInventoryItemId()).collect(Collectors.toSet());
+        List<InventoryItem> inventoryItems = inventoryItemRepository.selectByIds(inventoryItemIds);
+        List<String> headers = Arrays.asList("FofoId", "Serial Number", "Original DP", "DP(Inc PDs)", "PDs credited", "Fixed amount", "Discount", "Percentage Amount", "Margins Calc.", "Margins credited", "SoldOut");
+        List<List<?>> rows = new ArrayList<>();
+        for (InventoryItem inventoryItem : inventoryItems) {
+            InventoryPayoutModel ipm = priceCircularService.getPayouts(inventoryItem);
+            ipm.getActualRolloutAmount();
+            rows.add(Arrays.asList(inventoryItem.getFofoId(), inventoryItem.getSerialNumber(), ipm.getDp() + ipm.getPriceDropAmount(), ipm.getDp(), 0d,//PDs credited
+                    ipm.getFixedAmount(), ipm.getDiscountAmount(), ipm.getPercentageAmount(), ipm.getActualRolloutAmount(), ipm.getPaidAmount(), inventoryItem.getLastScanType().equals(ScanType.SALE)));
+        }
+        ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
+        FileOutputStream fos = new FileOutputStream(new File("/Users/amit/data.csv"));
+        baos.writeTo(fos);
+    }
+    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",
+    }
     public void test3() throws Exception {
         List<Long> payoutIds = Arrays.asList();
         List<OfferPayout> offerPayouts = offerPayoutRepository.selectAllByIds(payoutIds);
-        Map<Integer, List<OfferPayout>> offerPayoutMap = offerPayouts.stream().collect(Collectors.groupingBy(x -> (int) x.getOfferId()));
+        Map<Integer, List<OfferPayout>> offerPayoutMap = offerPayouts.stream().collect(groupingBy(x -> (int) x.getOfferId()));
-        for (Map.Entry<Integer, List<OfferPayout>> offerPayoutEntry : offerPayoutMap.entrySet()) {
+        for (Entry<Integer, List<OfferPayout>> offerPayoutEntry : offerPayoutMap.entrySet()) {
             int offerId = offerPayoutEntry.getKey();
             List<OfferPayout> offerPayoutList = offerPayoutEntry.getValue();
-            Map<Integer, List<OfferPayout>> partnerOfferPayoutMap = offerPayoutList.stream().collect(Collectors.groupingBy(x -> (int) x.getFofoId()));
+            Map<Integer, List<OfferPayout>> partnerOfferPayoutMap = offerPayoutList.stream().collect(groupingBy(x -> (int) x.getFofoId()));
             for (Entry<Integer, List<OfferPayout>> partnerOfferPayoutEntry : partnerOfferPayoutMap.entrySet()) {
                 int fofoId = partnerOfferPayoutEntry.getKey();
                 List<OfferPayout> partnerPayouts = partnerOfferPayoutEntry.getValue();
                 float amount = 0;
                 for (OfferPayout offerPayout : partnerPayouts) {
         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(175139556,	new HashSet<>(Arrays.asList("863718063534013","866335072895173","866335073390810")));
+        fofoIdImeiReturnMap.put(175139556, new HashSet<>(Arrays.asList("863718063534013", "866335072895173", "866335073390810")));
-        fofoIdImeiReturnMap.put(175139721,	new HashSet<>(Arrays.asList("358250294549067","865883067508138","866993072210619")));
+        fofoIdImeiReturnMap.put(175139721, new HashSet<>(Arrays.asList("358250294549067", "865883067508138", "866993072210619")));
         /*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")));*/
                 debitNote.setCreateTimestamp(debitNoteDate);
                 //Try to refund amount per debit note
                 cartItems.addAll(this.refundDnAmount(debitNote));
+            }
             //If order created
-            Map<Integer, List<CartItem>> warehouseCartItemsMap = cartItems.stream().collect(Collectors.groupingBy(x -> x.getWarehouseId()));
+            Map<Integer, List<CartItem>> warehouseCartItemsMap = cartItems.stream().collect(groupingBy(x -> x.getWarehouseId()));
-            for (Map.Entry<Integer, List<CartItem>> warehouseCartItemsEntry : warehouseCartItemsMap.entrySet()) {
+            for (Entry<Integer, List<CartItem>> warehouseCartItemsEntry : warehouseCartItemsMap.entrySet()) {
                 List<CartItem> warehouseCartItems = warehouseCartItemsEntry.getValue();
                 List<CartItem> mergedCartItems = warehouseCartItems.stream()
                         .collect(Collectors.collectingAndThen(
-                                Collectors.groupingBy(x -> x.getItemId(), Collectors.collectingAndThen(
+                                groupingBy(x -> x.getItemId(), Collectors.collectingAndThen(
                                         Collectors.reducing((a, b) -> {
                                             a.setQuantity(a.getQuantity() + b.getQuantity());
                                             return a;
                                         }), Optional::get)),
                                 m -> new ArrayList<>(m.values())));
     //Also create order
     private List<CartItem> refundDnAmount(DebitNote debitNote) throws ProfitMandiBusinessException {
         List<Integer> inventoryItemIds = purchaseReturnItemRepository.selectAllByDebitNoteId(debitNote.getId()).stream().map(x -> x.getInventoryItemId()).collect(Collectors.toList());
-        Map<Integer, Long> inventoryItemCountMap = inventoryItemIds.stream().collect(Collectors.groupingBy(x -> x, Collectors.counting()));
+        Map<Integer, Long> inventoryItemCountMap = inventoryItemIds.stream().collect(groupingBy(x -> x, Collectors.counting()));
         List<InventoryItem> inventoryItems = inventoryItemRepository.selectAllByIds(new ArrayList<>(inventoryItemCountMap.keySet()));
         Purchase purchase = purchaseRepository.selectById(inventoryItems.get(0).getPurchaseId());
         String invoice = purchase.getPurchaseReference();
         List<Order> orders = orderRepository.selectByInvoiceNumber(invoice);
         Set<Integer> orderIds = orders.stream().map(x -> x.getId()).collect(Collectors.toSet());
+        }
         String fileName = "InvestmentSummary-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
         if (sendTo == null) {
-            for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMapping().entrySet()) {
+            for (Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMapping().entrySet()) {
                 List<List<?>> filteredRows = storeGuyEntry.getValue().stream().map(x -> partnerRowsMap.get(x)).filter(x -> x != null).collect(Collectors.toList());
                 ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, filteredRows);
                 String[] sendToArray = new String[]{storeGuyEntry.getKey()};
                 Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Franchise Investment Summary", "PFA", fileName, new ByteArrayResource(baos.toByteArray()));
+            }
         Utils.sendMailWithAttachments(googleMailSender, ITEMWISE_PENDING_INDENT_MAIL_LIST, null, "Itemwise Pending indent", "PFA", attachment1);
         // Reports to be sent to mapped partners
         Map<String, Set<String>> storeGuysMap = csService.getAuthUserPartnerEmailMapping();
-        for (Map.Entry<String, Set<String>> storeGuyEntry : storeGuysMap.entrySet()) {
+        for (Entry<String, Set<String>> storeGuyEntry : storeGuysMap.entrySet()) {
             Map<String, String> params = new HashMap<>();
             if (storeGuyEntry.getValue().size() == 0)
                 continue;
             params.put("MANUAL_email", String.join(",", storeGuyEntry.getValue()));
             InputStreamSource isr3 = reporticoService.getReportInputStreamSource(ReporticoProject.FOCO, "focostockreport.xml", params);
             Map<Integer, Double> userSchemeRefundedMap = inventoryItemRepository.selectByIds(inventoryItemSchemeIORefunded.keySet()).stream().collect(groupingBy(x -> x.getFofoId(), Collectors.summingDouble(x -> inventoryItemSchemeIORefunded.get(x.getId()))));
             Map<Integer, Double> finalUserSchemeAmountMap = new HashMap<>();
-            for (Map.Entry<Integer, Double> schemeAmount : userSchemeRefundedMap.entrySet()) {
+            for (Entry<Integer, Double> schemeAmount : userSchemeRefundedMap.entrySet()) {
                 if (!finalUserSchemeAmountMap.containsKey(schemeAmount.getKey())) {
                     finalUserSchemeAmountMap.put(schemeAmount.getKey(), schemeAmount.getValue());
                 } else {
                     finalUserSchemeAmountMap.put(schemeAmount.getKey(), finalUserSchemeAmountMap.get(schemeAmount.getKey()) + schemeAmount.getValue());
+                }
+            }
             Map<Integer, Integer> userWalletMap = userWalletRepository.selectByRetailerIds(finalUserSchemeAmountMap.keySet()).stream().collect(Collectors.toMap(UserWallet::getUserId, UserWallet::getId));
             Map<Integer, Double> walletAmountMap = history.stream().collect(groupingBy(
                     UserWalletHistory::getWalletId, Collectors.summingDouble((UserWalletHistory::getAmount))));
-            for (Map.Entry<Integer, Double> userAmount : walletAmountMap.entrySet()) {
+            for (Entry<Integer, Double> userAmount : walletAmountMap.entrySet()) {
                 double diff = Math.abs(finalUserSchemeAmountMap.get(userAmount.getKey()) - userAmount.getValue());
                 if (diff > 5) {
                     LOGGER.info("Partner scheme mismatched for Userid {}", userWalletMap.get(userAmount.getKey()));
+                }
+            }
                 List<FofoStore> stores = fofoStoreRepository.selectActivePartnersByRetailerIds(new ArrayList<>(fofoIds));
                 Map<String, List<Integer>> stateMap = stores.stream().collect(groupingBy(
                         x -> x.getCode().substring(0, 2), mapping(x -> x.getId(), Collectors.toList())));
                 List<List<Serializable>> stateWiseSales = new ArrayList<>();
-                for (Map.Entry<String, List<Integer>> stateMapEntry : stateMap.entrySet()) {
+                for (Entry<String, List<Integer>> stateMapEntry : stateMap.entrySet()) {
                     long totalQty = stateMapEntry.getValue().stream().collect(Collectors.summingLong(x -> saleTargetReportModelMap.get(x).getTotalQty()));
                     double totalSale = stateMapEntry.getValue().stream().collect(Collectors.summingDouble(x -> saleTargetReportModelMap.get(x).getTotalSale()));
                     long smartPhoneQty = stateMapEntry.getValue().stream().collect(Collectors.summingLong(x -> saleTargetReportModelMap.get(x).getSmartphoneQty()));
                     double smartPhoneSale = stateMapEntry.getValue().stream().collect(
                             Collectors.summingDouble(x -> saleTargetReportModelMap.get(x).getSmartphoneSale()));
             LOGGER.info("focusedCatalogIdAndQtyMap" + focusedCatalogIdAndQtyMap);
             Map<String, RetailerBlockBrands> retailerBlockBrands = retailerBlockBrandsRepository.selectAllByRetailer(fofoId).stream().collect(Collectors.toMap(x -> x.getBlockBrands(), x -> x));
-            for (Map.Entry<Integer, Optional<Integer>> entry : focusedCatalogIdAndQtyMap.entrySet()) {
+            for (Entry<Integer, Optional<Integer>> entry : focusedCatalogIdAndQtyMap.entrySet()) {
                 int minQty = entry.getValue().get();
                 int inStockQty = 0;
                 int processingQty = 0;
                 int grnPendingQty = 0;
                 int allColorNetAvailability = 0;
         LOGGER.info("dtrEmailMap {}", dtrEmailMap);
         Map<Integer, Integer> authUserKeyMap = new HashMap<>();
-        for (Map.Entry<Integer, String> authUserEmail : authUserEmailMap.entrySet()) {
+        for (Entry<Integer, String> authUserEmail : authUserEmailMap.entrySet()) {
             int authId = authUserEmail.getKey();
             String email = authUserEmail.getValue();
             authUserKeyMap.put(authId, dtrEmailMap.get(email));
+        }
         LOGGER.info("authUserKeyMap", authUserKeyMap);
         List<FranchiseeVisit> franchiseeVisits = franchiseeVisitRepository.selectVisitsScheduledBetweenDate(LocalDateTime.now().minusDays(15), LocalDateTime.now().plusHours(4));
         Map<Integer, String> authUserEmailMap = authRepository.selectAllActiveUser().stream().collect(Collectors.toMap(x -> x.getId(), x -> x.getEmailId()));
         Map<String, Integer> dtrEmailMap = dtrUserRepository.selectAllByEmailIds(new ArrayList<>(authUserEmailMap.values())).stream().collect(Collectors.toMap(x -> x.getEmailId(), x -> x.getId()));
         Map<Integer, Integer> authUserKeyMap = new HashMap<>();
-        for (Map.Entry<Integer, String> authUserEmail : authUserEmailMap.entrySet()) {
+        for (Entry<Integer, String> authUserEmail : authUserEmailMap.entrySet()) {
             int authId = authUserEmail.getKey();
             String email = authUserEmail.getValue();
             authUserKeyMap.put(authId, dtrEmailMap.get(email));
+        }
         String visitTemplate = "Planned visit to franchisee %s is due by %s";
                         // fofoLineItemRepository.delete(fli);
                         inventoryItemId = fli.getInventoryItemId();
+                    }
+                }
                 List<SchemeInOut> schemeInOuts = schemeInOutRepository.selectByInventoryItemIds(
-                        java.util.stream.Stream.of(inventoryItemId).collect(Collectors.toSet()));
+                        Stream.of(inventoryItemId).collect(Collectors.toSet()));
                 for (SchemeInOut sio : schemeInOuts) {
                     if (sio.getCreateTimestamp().toLocalDate().equals(localDate)) {
                         LOGGER.info("SIO - {}", sio);
                         sio.setRolledBackTimestamp(LocalDateTime.now());
+                    }
                  */
                 if (inventoryItem.getLastScanType().equals(ScanType.SALE) || inventoryItem.getLastScanType().equals(ScanType.SALE_RET)) {
                     Map<String, Double> map = schemeInOuts.stream().collect(
                             groupingBy(
                                     x -> DateTimeFormatter.ofPattern("yyyyMMddHH").format(x.getCreateTimestamp()) + "- " + x.getSchemeId(), Collectors.summingDouble(x -> x.getAmount())));
-                    for (Map.Entry<String, Double> entry : map.entrySet()) {
+                    for (Entry<String, Double> entry : map.entrySet()) {
                         LOGGER.info("{} = {}", entry.getKey(), entry.getValue());
+                    }
                     LOGGER.info("id- {}, imei- {}, lastScan = {}, Scheme sum - {}", inventoryItem.getId(), inventoryItem.getSerialNumber(), inventoryItem.getLastScanType(), schemeSum);
+                }
+            }
             Map<Integer, PartnerCollectionRemark> salesEscalatedRemarksMap = partnerCollectionRemarks.stream().filter(x -> x.getRemark().equals(CollectionRemark.SALES_ESCALATION)).collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
             if (!rbmEscalatedRemarksMap.isEmpty()) {
                 //
-                for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_RBM), true).entrySet()) {
+                for (Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_RBM), true).entrySet()) {
                     List<PartnerCollectionRemark> filteredRows = storeGuyEntry.getValue().stream()
                             .map(x -> rbmEscalatedRemarksMap.get(x)).filter(x -> x != null).collect(Collectors.toList());
                     String subject = "Partners escalated to RBM-L2";
                     String messageText = this.getMessageForRBMEscalatedPartners(filteredRows);
+                }
+            }
             if (!salesEscalatedRemarksMap.isEmpty()) {
                 //
-                for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_RBM), true).entrySet()) {
+                for (Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_RBM), true).entrySet()) {
                     List<PartnerCollectionRemark> filteredRows = storeGuyEntry.getValue().stream()
                             .map(x -> salesEscalatedRemarksMap.get(x)).filter(x -> x != null).collect(Collectors.toList());
                     String subject = "Partners escalated to Sales";
                     String messageText = this.getMessageForSalesEscalatedPartners(filteredRows);
             ProfitMandiBusinessException, MessagingException, UnsupportedEncodingException {
         List<NonSdBuying> nonSdByuingActiveList = nonSdBuyingRepository.selectAllActiveNonSDBuyingList(true);
         Map<Integer, NonSdBuying> unAuthorizedBuyingMap = nonSdByuingActiveList.stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
         if (!unAuthorizedBuyingMap.isEmpty()) {
-            for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES), true).entrySet()) {
+            for (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()) {
                     String subject = "Unauthorized Buying";
                     String messageText = this.getMessageForUnauthorizedBuying(unAuthorizedfilteredRows);
     private void sendUnholdEmail(List<Order> orders) throws Exception {
         orders.forEach(x -> x.setShipmentHold(false));
-        orders = orders.stream().filter(x->x.getRefundTimestamp()!= null).collect(Collectors.toList());
+        orders = orders.stream().filter(x -> x.getRefundTimestamp() != null).collect(Collectors.toList());
         double totalAmount = orders.stream().collect(Collectors.summingDouble(x -> x.getTotalAmount()));
         List<String> authUserEmail = csService.getAuthUserIdByPartnerId(orders.get(0).getRetailerId()).stream().map(x -> x.getEmailId()).collect(Collectors.toList());
         authUserEmail.add("vinay.p@smartdukaan.com");
             if (sdCreditRequirement == null) {
                 sdCreditRequirement = new SDCreditRequirement();
                 sdCreditRequirement.setFofoId(fofoId);
                 sdCreditRequirement.setCreditDays(15);
-                sdCreditRequirement.setInterestRate(BigDecimal.valueOf(0.05));
+                sdCreditRequirement.setInterestRate(ProfitMandiConstants.NEW_INTEREST_RATE);
                 sdCreditRequirement.setRisk(CreditRisk.HIGH_RISK);
                 sdCreditRequirement.setUtilizedAmount(BigDecimal.ZERO);
                 sdCreditRequirement.setCreateTimestamp(LocalDateTime.now());
                 sdCreditRequirement.setUpdateTimestamp(LocalDateTime.now());
                 sdCreditRequirementRepository.persist(sdCreditRequirement);
             ProfitMandiBusinessException, MessagingException, IOException {
         String subject = "Default Partners";
         List<Integer> categoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_CATEGORY, ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS, ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT);
-        for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(categoryIds, false).entrySet()) {
+        for (Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(categoryIds, false).entrySet()) {
             List<Loan> filteredRows = new ArrayList<>();
             for (Loan loan : defaultLoans) {
                 if (storeGuyEntry.getValue().contains(loan.getFofoId())) {
         return sb.toString();
+    }
     private String getMessageForDueDateCross(List<Loan> loans) throws ProfitMandiBusinessException {
         Map<Integer, com.spice.profitmandi.dao.model.FofoReportingModel> fofoReportingModelMap = csService.getPartnerIdSalesHeaders();
-        Map<Integer, com.spice.profitmandi.dao.model.FofoRBMReportingModel> fofoRbmReportingModelMap = csService.getPartnerIdRBMHeaders();
+        Map<Integer, FofoRBMReportingModel> fofoRbmReportingModelMap = csService.getPartnerIdRBMHeaders();
         StringBuilder sb = new StringBuilder();
         sb.append("<html><body><p>Alert</p><p>Due Date Cross Partners :-</p>" + "<br/><p>Additional penal interest of  shall be levied on daily basis.</p>" + "<br/>" +
                 "<table style='border:1px solid black ;padding: 5px';>");
         sb.append("<tbody>\n" + "<tr>\n" +
                 "<th style='border:1px solid black;padding: 5px'>PartnerName</th>\n" +
+    }
     private void sendDueDateCrossLoanAlert(List<Loan> dueDateCrossLoans) throws Exception {
         List<Integer> categoryIds = Arrays.asList(ProfitMandiConstants.TICKET_CATEGORY_CATEGORY, ProfitMandiConstants.TICKET_CATEGORY_RBM, ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS, ProfitMandiConstants.TICKET_CATEGORY_BUSINESSINTELLIGENT);
-        for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(categoryIds, false).entrySet()) {
+        for (Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMappingByCategoryIds(categoryIds, false).entrySet()) {
             List<Loan> filteredRows = new ArrayList<>();
             for (Loan loan : dueDateCrossLoans) {
                 if (storeGuyEntry.getValue().contains(loan.getFofoId())) {

Subversion Repositories SmartDukaan

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