Subversion Repositories SmartDukaan

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

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

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

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

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

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

		Set<String> serialNumbersConsidered = new HashSet<>();

		LocalDateTime startDate = LocalDate.of(2018, 9, 1).atStartOfDay();

		LocalDateTime endDate = LocalDate.now().atStartOfDay();

		List<Purchase> purchases = purchaseRepository.selectAllBetweenPurchaseDate(startDate, endDate);

		purchases.stream().forEach(purchase -> {

			float amountToRollback = 0;

			String description = "Adjustment of Duplicate Scheme for Purchase Invoice "

					+ purchase.getPurchaseReference();

			Map<Integer, String> inventorySerialNumberMap = inventoryItemRepository.selectByPurchaseId(purchase.getId())

					.stream().filter(ii -> ii.getSerialNumber() != null)

					.collect(Collectors.toMap(InventoryItem::getId, InventoryItem::getSerialNumber));

			if (inventorySerialNumberMap.size() > 0) {

				for (Map.Entry<Integer, String> inventorySerialNumberEntry : inventorySerialNumberMap.entrySet()) {

					String serialNumber = inventorySerialNumberEntry.getValue();

					int inventoryItemId = inventorySerialNumberEntry.getKey();

					if (serialNumbersConsidered.contains(serialNumber)) {

						// This will rollback scheme for differenct orders for same serial

						List<SchemeInOut> sios = schemeInOutRepository

								.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItemId))).stream()

								.filter(x -> x.getRolledBackTimestamp() == null

										&& schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.IN))

								.collect(Collectors.toList());

						Collections.reverse(sios);

						for (SchemeInOut sio : sios) {

							sio.setRolledBackTimestamp(LocalDateTime.now());

							amountToRollback += sio.getAmount();

							// sio.setSchemeType(SchemeType.OUT);

							sio.setSerialNumber(serialNumber);

							rolledbackSios.add(sio);

						}

						description = description.concat(" " + serialNumber + " ");

					} else {

						serialNumbersConsidered.add(serialNumber);

						List<Integer> schemesConsidered = new ArrayList<>();

						List<SchemeInOut> sios = schemeInOutRepository

								.selectByInventoryItemIds(new HashSet<>(Arrays.asList(inventoryItemId))).stream()

								.filter(x -> x.getRolledBackTimestamp() == null

										&& schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.IN))

								.collect(Collectors.toList());

						Collections.reverse(sios);

						for (SchemeInOut sio : sios) {

							if (!schemesConsidered.contains(sio.getSchemeId())) {

								schemesConsidered.add(sio.getSchemeId());

								continue;

							}

							sio.setRolledBackTimestamp(LocalDateTime.now());

							amountToRollback += sio.getAmount();

							// sio.setSchemeType(SchemeType.OUT);

							sio.setSerialNumber(serialNumber);

							rolledbackSios.add(sio);

						}

					}

				}

			}

			if (amountToRollback > 0) {

				Address address = addressRepository.selectAllByRetailerId(purchase.getFofoId(), 0, 10).get(0);

				UserWalletHistory uwh = new UserWalletHistory();

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

				uwh.setDescription(description);

				uwh.setTimestamp(LocalDateTime.now());

				uwh.setReferenceType(WalletReferenceType.SCHEME_OUT);

				uwh.setReference(purchase.getId());

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

				uwh.setFofoId(purchase.getFofoId());

				uwh.setStoreCode(address.getName());

				userWalletHistory.add(uwh);

			}

		});

		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(

				Arrays.asList("User Id", "Store Code", "Reference Type", "Reference", "Amount", "Description",

						"Timestamp"),

				userWalletHistory.stream()

						.map(x -> Arrays.asList(x.getWalletId(), x.getStoreCode(), 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", "neeraj.gupta@smartdukaan.com" }, null,

				"Partner Excess Amount", "PFA",

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

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

		throw new Exception();

	}

	public void dryRunOutSchemeReco() throws Exception {

								.filter(x -> x.getRolledBackTimestamp() == null

								.filter(x -> x.getRolledBackTimestamp() == null