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

 	public void migrateChallansToInvoices() throws Exception {
 		Map<String, List<Order>> invoiceOrdersMap = orderRepository.selectAllChallans().stream()
 				.filter(x -> !x.getLineItem().getHsnCode().equals("NOGST"))
 				.collect(Collectors.groupingBy(Order::getInvoiceNumber, Collectors.toList()));
-		List<List<? extends Serializable>> rows = new ArrayList<>();
+		List<List<?>> rows = new ArrayList<>();
 		for (String invoice : invoiceOrdersMap.keySet()) {
 			Order oneOrder = invoiceOrdersMap.get(invoice).get(0);
 			int totalOrders = invoiceOrdersMap.get(invoice).size();
 			LineItem lineItem = oneOrder.getLineItem();
 			oneOrder.setBillingTimestamp(LocalDateTime.now());
 		s.setCreatedBy(175120474);
 		return s;
+	}
 	public void findMismatchesInIndent() throws Exception {
-		/*
-		 * List<SaholicInventorySnapshot> saholicInventorySnapshots =
-		 * saholicInventorySnapshotRepository.selectAll(); Map<Integer, Integer>
-		 * itemReservedMap = saholicInventorySnapshots.stream().filter(x ->
-		 * x.getReserved() > 0)
-		 * .collect(Collectors.groupingBy(SaholicInventorySnapshot::getItemId,
-		 * Collectors.summingInt(SaholicInventorySnapshot::getReserved)));
-		 */
 		List<Order> allInProcessOrders = orderRepository.selectAllOrder(OrderStatus.SUBMITTED_FOR_PROCESSING);
-		/*
-		 * Map<Integer, Integer> lineItemQtyMap = allInProcessOrders
-		 * .stream().collect(Collectors.groupingBy(y -> y.getLineItem().getItemId(),
-		 * Collectors.summingInt(y -> y.getLineItem().getQuantity())));
-		 */
-		/*
-		 * Map<Integer, Order> orderMap =
-		 * allInProcessOrders.stream().collect(Collectors.toMap(Order::getId, x->x));
-		 * Map<Integer, List<Order>> itemOrdersMap = allInProcessOrders.stream()
-		 * .collect(Collectors.groupingBy(o->o.getLineItem().getItemId(),
-		 * Collectors.toList()));
-		 */
 		Map<String, Integer> lineItemWhQtyMap = allInProcessOrders.stream()
 				.collect(Collectors.groupingBy(y -> y.getLineItem().getItemId() + "-" + y.getFulfilmentWarehouseId(),
 						Collectors.summingInt(y -> y.getLineItem().getQuantity())));
-		/*
-		 * itemReservedMap.forEach((itemId, reserved)->{
-		 * if(lineItemQtyMap.containsKey(itemId)) { int orderedQty =
-		 * lineItemQtyMap.get(itemId); System.out.printf("%d\t%d\t%d\n",itemId,
-		 * orderedQty, reserved); } else {
-		 * saholicInventorySnapshotRepository.removeAllReservations(itemId);
-		 * System.out.printf("%d\t%d\t%d\n",itemId, 0, reserved); } });
-		 */
 		lineItemWhQtyMap.forEach((key, value) -> {
 			int itemId = Integer.parseInt(key.split("-")[0]);
 			int warehouseId = Integer.parseInt(key.split("-")[1]);
 			System.out.printf("%d\t%d\t%d\n", itemId, warehouseId, value);
 				cis.setAvailability(0);
 				saholicInventorySnapshotRepository.persist(cis);
+			}
 			cis.setReserved(value);
 		});
-		/*
-		 * List<SaholicReservationInventorySnapshot> reservationInventorySnapshots =
-		 * saholicReservationInventorySnapshotRepository.selectAll(); Map<Integer,
-		 * SaholicReservationInventorySnapshot> reservationInventorySnapshotsMap
-		 * =reservationInventorySnapshots.stream()
-		 * .collect(Collectors.toMap(x->x.getOrderId(), x->x));
-		 *
-		 * List<Integer> orderIds =
-		 * reservationInventorySnapshots.stream().map(x->x.getOrderId()).collect(
-		 * Collectors.toList()); List<Order> orders =
-		 * orderRepository.selectByOrderIds(orderIds);
-		 * orders.stream().filter(x->Arrays.asList(OrderStatus.PAYMENT_PENDING,
-		 * OrderStatus.PAYMENT_FAILED). contains(x.getStatus())).forEach(x->{
-		 * SaholicReservationInventorySnapshot snapshot =
-		 * reservationInventorySnapshotsMap.get(x.getId()); try {
-		 * saholicInventorySnapshotRepository.reduceReservationCount(snapshot.getItemId(
-		 * ), snapshot.getWarehouseId(), snapshot.getReserved(), snapshot.getOrderId());
-		 * System.out.printf("%d Reduced by %d for Order Id %d\n",snapshot.getItemId(),
-		 * snapshot.getReserved(), snapshot.getOrderId()); }
-		 * catch(ProfitMandiBusinessException e) {
-		 * LOGGER.info("Problem whiile reducing count for Order Id - {}",
-		 * snapshot.getOrderId()); } });
-		 */
-		// throw new Exception();
+	}
 	public void fixSchemePayouts() throws Exception {
 		LOGGER.info("In fix scheme Payouts");
 		LocalDateTime startDate = LocalDate.of(2019, 9, 1).atStartOfDay();
+	}
 	public void mailDashboardScreenshots() throws Exception {
 		System.setProperty("webdriver.chrome.driver", "/usr/bin/chromedriver");
 		ChromeOptions options = new ChromeOptions();
 		options.addArguments("--headless");
 		options.addArguments("--no-sandbox");
 		options.addArguments("start-maximized");
 		options.addArguments("disable-infobars");
 		driver.manage().deleteAllCookies();
 		// Specifiying pageLoadTimeout and Implicit wait
 		driver.manage().timeouts().pageLoadTimeout(40, TimeUnit.SECONDS);
 		driver.manage().timeouts().implicitlyWait(30, TimeUnit.SECONDS);
 		Map<String, Set<Integer>> authUserPartnerIdMapping = csService.getAuthUserPartnerIdMapping();
 		Set<Integer> allPartners = new HashSet<>();
 		Map<Integer, File> partnerSnapshotMap = new HashMap<>();
 		authUserPartnerIdMapping.values().stream().forEach(x -> allPartners.addAll(x));
 		System.out.println(allPartners.size());
 			Map<Integer, File> emailSnapshotMap = new HashMap<>();
 			for (int fofoId : partnerIds) {
 				body.append(String.format("<br/><img src=\"cid:%d\"/>", fofoId));
 				emailSnapshotMap.put(fofoId, partnerSnapshotMap.get(fofoId));
+			}
-			Utils.sendEmbeddedHtmlMail(mailSender,
+			Utils.sendEmbeddedHtmlMail(mailSender, new String[] { email }, new String[] {},
-					new String[] { email },
-					new String[] {},
 					String.format("Franchise Screenshots - %s", FormattingUtils.formatDate(LocalDateTime.now())),
-					body.toString(), emailSnapshotMap );
+					body.toString(), emailSnapshotMap);
+		}
 		driver.quit();
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/migrations/RunOnceTasks.java – Rev 25785 → 25837