Subversion Repositories SmartDukaan

import java.util.function.Function;

	public void dryRunSchemeOutReco1() throws Exception {

		List<Integer> references = Arrays.asList(6744,7347, 8320, 8891, 9124, 9217, 9263, 9379);

		List<UserWalletHistory> userWalletHistory = new ArrayList<>();

		List<SchemeInOut> rolledbackSios = new ArrayList<>();

		Map<Integer, Integer> userWalletMap = userWalletRepository.selectAll().stream()

				.collect(Collectors.toMap(UserWallet::getUserId, UserWallet::getId));

		Map<Integer, SchemeType> schemeTypeMap = schemeRepository.selectAll().stream()

				.collect(Collectors.toMap(Scheme::getId, Scheme::getType));

		references.stream().forEach(reference -> {

			FofoOrder fofoOrder = null;

			try {

				fofoOrder = fofoOrderRepository.selectByOrderId(reference);

			} catch(Exception e) {

			}

			String description = "Adjustment of Duplicate Scheme for Sale Invoice " + fofoOrder.getInvoiceNumber();

			Map<Integer, String> inventorySerialNumberMap = new HashMap<>();

			float amountToRollback = 0;

			List<FofoOrderItem> orderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());

			orderItems.forEach(x -> {

				inventorySerialNumberMap.putAll(x.getFofoLineItems().stream().filter(li -> li.getSerialNumber() != null)

						.collect(Collectors.toMap(FofoLineItem::getInventoryItemId, FofoLineItem::getSerialNumber)));

			});

			if (inventorySerialNumberMap.size() > 0) {

				List<SchemeInOut> sios = schemeInOutRepository.

						selectByInventoryItemIds(inventorySerialNumberMap.keySet()).stream().filter(x -> schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.OUT))

						.collect(Collectors.toList());

				LOGGER.info("Found {} duplicate schemeouts for Orderid {}", sios.size(), fofoOrder.getId());

				UserWalletHistory uwh = new UserWalletHistory();

				Map<Integer, List<SchemeInOut>> inventoryIdSouts = sios.stream().collect(Collectors.groupingBy(SchemeInOut::getInventoryItemId, Collectors.toList()));

				for (Map.Entry<Integer, List<SchemeInOut>> inventorySioEntry : inventoryIdSouts.entrySet()) {

					List<SchemeInOut> outList = inventorySioEntry.getValue();

					if(outList.size()>1) {

					}

				}

				uwh.setAmount(Math.round(amountToRollback));

				uwh.setDescription(description);

				uwh.setTimestamp(LocalDateTime.now());

				uwh.setReferenceType(WalletReferenceType.SCHEME_OUT);

				uwh.setReference(fofoOrder.getId());

				uwh.setWalletId(userWalletMap.get(fofoOrder.getFofoId()));

				uwh.setFofoId(fofoOrder.getFofoId());

				uwh.setStoreCode(fofoOrder.getInvoiceNumber().split("/")[0]);

				userWalletHistory.add(uwh);

			}

		});

		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(

				Arrays.asList("User Id", "Reference Type", "Reference", "Amount", "Description", "Timestamp"),

				userWalletHistory.stream().map(x -> Arrays.asList(x.getWalletId(), x.getReferenceType(),

						x.getReference(), x.getAmount(), x.getDescription(), x.getTimestamp()))

				.collect(Collectors.toList()));

		ByteArrayOutputStream baosOuts = FileUtil.getCSVByteStream(

				Arrays.asList("Scheme ID", "SchemeType", "Store Code", "Serial Number", "Amount", "Created",

						"Rolledback"),

				rolledbackSios.stream()

				.map(x -> Arrays.asList(x.getSchemeId(), x.getSchemeType(), x.getStoreCode(),

						x.getSerialNumber(), x.getAmount(), x.getCreateTimestamp(), x.getRolledBackTimestamp()))

				.collect(Collectors.toList()));

		Utils.sendMailWithAttachments(googleMailSender, new String[] { "amit.gupta@shop2020.in" }, null,

				"Partner Excess Amount", "PFA",

				new Attachment[] { new Attachment("WalletSummary.csv", new ByteArrayResource(baos.toByteArray())),

						new Attachment("SchemeOutRolledback.csv", new ByteArrayResource(baosOuts.toByteArray())) });

	}