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

 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.catalog.SchemeType;
 import com.spice.profitmandi.dao.enumuration.catalog.StockTransactionType;
 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
 import com.spice.profitmandi.dao.enumuration.dtr.RefferalStatus;
 import com.spice.profitmandi.dao.enumuration.fofo.Gateway;
 import com.spice.profitmandi.dao.enumuration.fofo.PaymentStatus;
     PartnerDealerRepository partnerDealerRepository;
     @Autowired
     PurSaleService purSaleService;
+    @Autowired
+    CatalogRepository catalogRepository;
+    private void reverseOppoPayout() throws Exception {
+        List<Integer> schemeIds = Arrays.asList(5540, 5542, 5544,5918, 5919, 5920, 5921, 5922);
+        /*List<Integer> schemeIds = Arrays.asList(5540, 5542, 5544, 5545, 5550, 5555, 5556, 5557, 5564, 5565, 5566, 5567, 5569, 5570, 5582, 5590, 5592, 5593, 5594,
+, 5598, 5602, 5604, 5605, 5606, 5607, 5608, 5611, 5618, 5620, 5621, 5622, 5623, 5624, 5625, 5626, 5629, 5631,
+, 5634, 5635, 5637, 5644, 5649, 5655, 5659, 5662, 5668, 5672, 5674, 5679, 5683, 5684, 5685, 5688, 5689, 5690,
+, 5694, 5697, 5699, 5700, 5706, 5718, 5729, 5730, 5754, 5756, 5758, 5759, 5761, 5762, 5766, 5769, 5771, 5772,
+, 5774, 5775, 5776, 5781, 5782, 5783, 5786, 5788, 5790, 5795, 5800, 5803, 5804, 5807, 5809, 5815, 5816, 5819,
+, 5821, 5822, 5823, 5824, 5825, 5826, 5827, 5828, 5829, 5830, 5832, 5833, 5834, 5835, 5836, 5837, 5839, 5840,
+, 5842, 5843, 5844, 5845, 5846, 5847, 5848, 5849, 5850, 5851, 5852, 5853, 5854, 5855, 5857, 5859, 5860, 5863,
+, 5866, 5869, 5870, 5871, 5872, 5873, 5874, 5875, 5877, 5878, 5879, 5880, 5885, 5888, 5889, 5891, 5892, 5894,
+, 5901, 5903, 5905, 5908, 5910, 5913, 5916, 5917, 5918, 5919, 5920, 5921, 5922, 5923, 5924, 5925, 5926, 5927,
+, 5929, 5930, 5931, 5932, 5933, 5934, 5935, 5936, 5938, 5939, 5940, 5941, 5942, 5943, 5944, 5945, 5946, 5947,
+, 5949, 5950, 5951, 5952, 5953, 5954, 5955, 5956, 5957, 5958, 5959, 5960, 5961, 5962, 5963, 5964, 5965, 5966,
+, 5968, 5969, 5970, 5971, 5972, 5973, 5974, 5975, 5976, 5977, 5979, 5980, 5981, 5982, 5983, 5984, 5985, 5986,
+, 5989, 5990, 5991, 5992, 5996, 5997, 5998, 5999, 6000, 6001, 6002, 6003, 6004, 6005, 6006, 6007, 6008, 6010,
+, 6012, 6013, 6014, 6015, 6016, 6017, 6018, 6019, 6020, 6021, 6022, 6023, 6024, 6025, 6026, 6028, 6029, 6030,
+, 6032, 6033, 6034, 6035, 6036, 6037, 6038, 6039, 6040, 6041, 6042, 6043, 6044, 6045, 6046, 6047, 6048, 6049,
+, 6051, 6052, 6053, 6054, 6055, 6056, 6057, 6058, 6059, 6060, 6061, 6062, 6063, 6064, 6065, 6066, 6067, 6068,
+, 6070, 6071, 6072, 6073, 6078, 6079, 6080, 6081, 6082, 6083, 6084, 6085, 6086, 6087, 6088, 6089, 6091, 6092,
+, 6094, 6095, 6098, 6102);*/
+        Map<Integer, List<SchemeInOut>> inventoryItemSiosMap = schemeInOutRepository.selectBySchemeIds(new HashSet<>(schemeIds)).stream().collect(Collectors.groupingBy(x -> x.getInventoryItemId()));
+        Map<Integer, InventoryItem> inventoryItemMap = inventoryItemRepository.selectByIds(inventoryItemSiosMap.keySet()).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
+        Set<Integer> itemIds = itemRepository.selectAllByBrand("Oppo", 10006).stream().map(x -> x.getId()).collect(toSet());
+        List<InventoryItem> filteredInventoryItems = inventoryItemMap.values().stream().filter(x -> itemIds.contains(x.getItemId())).collect(Collectors.toList());
+        for (InventoryItem filteredInventoryItem : filteredInventoryItems) {
+            System.out.println("Serial Number is - " + filteredInventoryItem.getSerialNumber());
+            List<ScanRecord> scanRecords = scanRecordRepository.selectByInventoryItemId(filteredInventoryItem.getId());
+            ScanRecord scanRecord = scanRecords.stream().filter(x -> x.getType().equals(ScanType.SALE)).findFirst().orElse(null);
+            if (scanRecord == null) {
+                System.out.println("Could not find sale scan record for " + filteredInventoryItem.getSerialNumber());
+                continue;
+                //schemeService.reverseSchemes(inventoryItems, fofoOrder.getId(), reversalReason, Arrays.asList(SchemeType.INVESTMENT));
+            }
+            int orderId = scanRecord.getOrderId();
+            schemeService.reverseSchemes(Arrays.asList(filteredInventoryItem), orderId, "Reissuing margins as incorrect margin disbursed", SchemeType.OUT_SCHEME_TYPES);
+        }
+        Map<Integer, List<InventoryItem>> purchaseInventoryItemsMap = filteredInventoryItems.stream().filter(x -> x.getCreateTimestamp().isAfter(YearMonth.now().atDay(1).atStartOfDay())).collect(Collectors.groupingBy(x -> x.getPurchaseId()));
+        List<Purchase> purchases = purchaseRepository.selectAllByIds(new ArrayList<>(purchaseInventoryItemsMap.keySet()));
+        for (Purchase purchase : purchases) {
+            String invoiceNumber = purchase.getPurchaseReference();
+            LocalDateTime billingTime =  orderRepository.selectByInvoiceNumber(invoiceNumber).get(0).getBillingTimestamp();
+            if(billingTime.isAfter(YearMonth.now().atDay(1).atStartOfDay()) ) {
+                List<Integer> inventoryItems = purchaseInventoryItemsMap.get(purchase.getId()).stream().map(x -> x.getId()).collect(toList());
+                schemeService.rollbackSchemes(inventoryItems, "Reissuing margins as incorrect margin disbursed");
+            }
+        }
+    }
     public void test() throws Exception {
+        this.reverseOppoPayout();
         //List<TotalLoanAmountDueModel> totalLoanAmountDueModels = loanRepository.getDueLoansByFofoId(175139438);
         //System.out.println(totalLoanAmountDueModels);
         //runOnceTasks.findCNDiff();
         /*this.updatePartnerLimit();
         System.out.println(getSuggestedLimit(300000d));
+    }
     public void checkfocusedModelInPartnerStock() throws Exception {
         //List<FofoStore> fofoStores = fofoStoreRepository.selectAll().stream().filter(x -> x.isActive()).limit(20).collect(Collectors.toList());
-        Map<Integer, FofoStore> fofoStoreMap = fofoStoreRepository.selectActiveStores().stream().collect(Collectors.toMap(x->x.getId(),x->x));
+        Map<Integer, FofoStore> fofoStoreMap = fofoStoreRepository.selectActiveStores().stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
         Map<Integer, Map<Integer, List<SaholicCIS>>> warehouseItemAvailabilityMap = saholicInventoryService.getSaholicStock();
         Map<Integer, String> warehouseMap = ProfitMandiConstants.WAREHOUSE_MAP;
         Map<Integer, FofoReportingModel> partnerIdSalesHeadersMap = this.getPartnerIdSalesHeaders();
         Map<Integer, List<FocusedModel>> regionFocusedModelsMap = focusedModelRepository.selectAll().stream().collect(Collectors.groupingBy(x -> x.getRegionId()));
         LOGGER.info("/ - {}", regionFocusedModelsMap);
         LOGGER.info("regionPartnerMap  - {}", regionPartnerMap.keySet());
         for (Map.Entry<Set<Integer>, List<Integer>> regionPartnerEntry : regionPartnerMap.entrySet()) {
             //LOGGER.info("regionPartnerEntry - {}", regionPartnerEntry.getKey());
             Set<Integer> regionIds = regionPartnerEntry.getKey();
             List<Integer> partnerIds = regionPartnerEntry.getValue();
-            if(regionIds.stream().anyMatch(x->!regionFocusedModelsMap.containsKey(x))) continue;
+            if (regionIds.stream().anyMatch(x -> !regionFocusedModelsMap.containsKey(x))) continue;
             LOGGER.info("regionIds" + regionIds);
             if (regionIds == null || regionIds.size() == 0) {
                 LOGGER.info("No region found for partner {}", partnerIds);
                 continue;
+            }
-            if(regionIds.contains(5)) {
+            if (regionIds.contains(5)) {
                 partnerIds.addAll(fofoStoreMap.keySet());
+            }
             Map<Integer, Optional<Integer>> focusedCatalogIdAndQtyMap = regionIds.stream().map(regionFocusedModelsMap::get).flatMap(x -> x != null ? x.stream() : Stream.empty())
                     .collect(groupingBy(FocusedModel::getCatalogId, mapping(FocusedModel::getObsMinimumQty, Collectors.maxBy(Integer::compareTo))));
             //LOGGER.info("focusedCatalogIdAndQtyMap {}",focusedCatalogIdAndQtyMap);
-            if(focusedCatalogIdAndQtyMap.size() == 0) continue;
+            if (focusedCatalogIdAndQtyMap.size() == 0) continue;
             for (int partnerId : partnerIds) {
-                if(partnerId==0) continue;
+                if (partnerId == 0) continue;
                 FofoStore fofoStore = fofoStoreMap.get(partnerId);
                 List<FocusedModelShortageModel> focusedModelShortageList = new ArrayList<>();
                 focusedModelShortageReportMap.put(fofoStore.getId(), focusedModelShortageList);
                 LOGGER.info("Before retailerService.getFofoRetailer(fofoId)");
                 CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoStore.getId());
             focusedModelShortageReportMap.entrySet().forEach(x -> {
                 storeGuyMap.entrySet().stream()
                         //.filter(entry->entry.getKey().equals(email))
                         .forEach(y -> {
-                    if (y.getValue().contains(x.getKey())) {
+                            if (y.getValue().contains(x.getKey())) {
-                        if (!emailRowsMap.containsKey(y.getKey())) {
+                                if (!emailRowsMap.containsKey(y.getKey())) {
-                            emailRowsMap.put(y.getKey(), new ArrayList<>());
+                                    emailRowsMap.put(y.getKey(), new ArrayList<>());
-                        }
+                                }
-                        List<List<? extends Serializable>> fms = x.getValue().stream().map(r -> Arrays.asList(r.getStoreCode(), r.getStoreName(), r.getBrandName(), r.getModelName(), r.getModelNumber(), r.getDp(), r.getWarehouseName(), r.getStateManager(), r.getTerritoryManager(), r.getPendingIndentQty(), r.getGrnStockQty(), r.getShortageQty(), r.getAvailability())).collect(Collectors.toList());
+                                List<List<? extends Serializable>> fms = x.getValue().stream().map(r -> Arrays.asList(r.getStoreCode(), r.getStoreName(), r.getBrandName(), r.getModelName(), r.getModelNumber(), r.getDp(), r.getWarehouseName(), r.getStateManager(), r.getTerritoryManager(), r.getPendingIndentQty(), r.getGrnStockQty(), r.getShortageQty(), r.getAvailability())).collect(Collectors.toList());
-                        emailRowsMap.get(y.getKey()).addAll(fms);
+                                emailRowsMap.get(y.getKey()).addAll(fms);
-                    }
+                            }
-                });
+                        });
             });
             //LOGGER.info("emailRowsMap {}", emailRowsMap);
             List<String> headers = Arrays.asList("Store Code", "Store Name", "Brand", "Model Name", "Model Number", "DP", "Warehouse Name", "State Manager", "Territory Manager", "Pending Indent", "InStock", "Shortage Qty", "Availability");
+            }
+        }
+    }
     private static final NavigableMap<Double, Double> discountMap = new TreeMap<>();
     static {
-        discountMap.put(4*ProfitMandiConstants.ONE_LAC-1, 0.2);   // Up to 6 -> 20%
+        discountMap.put(4 * ProfitMandiConstants.ONE_LAC - 1, 0.2);   // Up to 6 -> 20%
-        discountMap.put(10*ProfitMandiConstants.ONE_LAC-1, 0.25);  // 6-10 -> 25%
+        discountMap.put(10 * ProfitMandiConstants.ONE_LAC - 1, 0.25);  // 6-10 -> 25%
-        discountMap.put(20*ProfitMandiConstants.ONE_LAC-1, 0.3); // Above 10 -> 30%
+        discountMap.put(20 * ProfitMandiConstants.ONE_LAC - 1, 0.3); // Above 10 -> 30%
         discountMap.put(Double.MAX_VALUE, 0.4); // Above 10 -> 30%
+    }
-    public  BigDecimal getSuggestedLimit(double investmentValue) {
+    public BigDecimal getSuggestedLimit(double investmentValue) {
         double percentageValue = discountMap.ceilingEntry(investmentValue).getValue();
         return BigDecimal.valueOf(investmentValue * percentageValue);
+    }
-    private BigDecimal getSuggestedAmount(CreditAccount creditAccount, CurrentPartnerDailyInvestment currentPartnerDailyInvestment, long utilizationAmount,  BigDecimal sidbiLimit) {
+    private BigDecimal getSuggestedAmount(CreditAccount creditAccount, CurrentPartnerDailyInvestment
+            currentPartnerDailyInvestment, long utilizationAmount, BigDecimal sidbiLimit) {
         BigDecimal suggestedAmount = BigDecimal.ZERO;
         //1 LAC
         if (creditAccount == null || creditAccount.getGateway().equals(Gateway.SDDIRECT)) {
             if (currentPartnerDailyInvestment != null) {
+        }
+    }
+    public void findAllLiveDemoBrandItemsByBillingDate() throws
-    public void findAllLiveDemoBrandItemsByBillingDate() throws MessagingException, ProfitMandiBusinessException, IOException {
+            MessagingException, ProfitMandiBusinessException, IOException {
         LocalDateTime endDate = LocalDate.now().atStartOfDay().minusDays(8);
         List<LiveDemoOrderLineItemModel> liveDemoOrderLineItemModels = orderRepository.findAllLiveDemoBrandItemsByBillingDate(endDate.minusDays(60), endDate);
         LOGGER.info("liveDemoOrderLineItemModels {}", liveDemoOrderLineItemModels);
         String subject = "Billed Live Demo Model";
         // Return the constructed HTML message
         sb.append("</body></html>");
         return sb.toString();
+    }
-    private String getWhatsAppMessageForDueDateExtend(Loan defaultLoan, double amount) throws ProfitMandiBusinessException {
+    private String getWhatsAppMessageForDueDateExtend(Loan defaultLoan, double amount) throws
+            ProfitMandiBusinessException {
         double absoluteAmount = Math.abs(amount);
         long roundedAmount = Math.round(absoluteAmount);
         String formattedAmount = (amount < 0) ? "" + roundedAmount : "" + roundedAmount;
     public void createOpeningStockPartyWise() throws Exception {
         // Get all partner stock data
         Map<Integer, List<PartnerOpeningStockByTodayModel>> partnerOpeningStockByTodayMap = currentInventorySnapshotRepository.getAllPartnerTodayStock();
         Map<Integer, Map<Integer, Integer>> activatedButNotBilledCatalogQtyMap = smartCartService.activatedButNotBilledCatalogQtyMap();
-         LOGGER.info("PartnerOpeningStockByTodayModel {}",partnerOpeningStockByTodayMap);
+        LOGGER.info("PartnerOpeningStockByTodayModel {}", partnerOpeningStockByTodayMap);
         for (Map.Entry<Integer, List<PartnerOpeningStockByTodayModel>> entry : partnerOpeningStockByTodayMap.entrySet()) {
             int fofoId = entry.getKey();
             List<PartnerOpeningStockByTodayModel> partnerStockList = entry.getValue();
             // Get the sold (activated-but-not-billed) quantity for this fofo and catalog
             Map<Integer, Integer> activatedButNotBilledQtyMap = activatedButNotBilledCatalogQtyMap.getOrDefault(fofoId, Collections.emptyMap());

Subversion Repositories SmartDukaan

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