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

     @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,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,
+        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,
 , 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);*/
+, 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());
+            //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);
+            schemeService.reverseSchemes(Arrays.asList(filteredInventoryItem), orderId, "Reissuing margins as incorrect margin disbursed", Arrays.asList(SchemeType.SPECIAL_SUPPORT));
+            System.out.println("Out\t" + filteredInventoryItem.getId() + "\t" + filteredInventoryItem.getSerialNumber());
+        }
         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<InventoryItem> inventoryItems = purchaseInventoryItemsMap.get(purchase.getId());
-                List<Integer> inventoryItems = purchaseInventoryItemsMap.get(purchase.getId()).stream().map(x -> x.getId()).collect(toList());
+                List<Integer> inventoryItemIds =  inventoryItems.stream().map(x -> x.getId()).collect(toList());
-                schemeService.rollbackSchemes(inventoryItems, "Reissuing margins as incorrect margin disbursed");
+                schemeService.rollbackSchemes(inventoryItemIds, "Reissuing margins as incorrect margin disbursed");
+                for (InventoryItem inventoryItem : inventoryItems) {
+                    System.out.println("In\t" + inventoryItem.getId() + "\t" + inventoryItem.getSerialNumber());
+                }
+            }
+        }
+    }
     public void test() throws Exception {

Subversion Repositories SmartDukaan

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