WebSVN – SmartDukaan – Diff – /trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/migrations/RunOnceTasks.java

 	public void testIrnLive(String invoiceNumber) throws Exception {
 		List<Order> orders = orderRepository.selectByInvoiceNumber(invoiceNumber);
 		gstProService.getEInvoice(orders);
+	}
+	public void processSchemeByIds(List<Integer> schemeIds) throws Exception {
+		List<Scheme> schemes = schemeRepository.selectBySchemeIds(schemeIds);
+		for (Scheme scheme : schemes) {
+			if (Arrays.asList(SchemeType.SPECIAL_SUPPORT, SchemeType.ACTIVATION, SchemeType.CATEGORY, SchemeType.INVESTMENT, SchemeType.ACTIVATION, SchemeType.SPECIAL_SUPPORT).contains(scheme.getType())) {
+				List<Integer> catalogIds = schemeItemRepository.selectBySchemeIds(new HashSet<>(Arrays.asList(scheme.getId()))).stream().map(x -> x.getCatalogId()).collect(Collectors.toList());
+				List<FofoOrder> fofoOrders = fofoOrderRepository.selectOrderByModelAndSaleBetween(catalogIds, scheme.getStartDateTime(), scheme.getEndDateTime());
+				for (FofoOrder fofoOrder : fofoOrders) {
+					schemeService.processSchemeOut(fofoOrder.getId(), fofoOrder.getFofoId());
+				}
+			}
+			/*else if (Arrays.asList(SchemeType.IN).contains(scheme.getType())) {
+				List<FofoOrder> fofoOrders = fofoOrderRepository.selectOrderByModelAndSaleBetween(catalogIds, scheme.getStartDateTime(), scheme.getEndDateTime());
+			}*/
+		}
+	}
+}
 //7015845171

Subversion Repositories SmartDukaan