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

+		}
+	}
 	public void dryRunSchemeReco() throws Exception {
+		Set<String> serialSchemeConsidered = new HashSet<>();
 		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()
 								new ArrayList<String>(inventorySerialNumberMap.values()))
 						.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();
+				List<String> toBerolledBack = new ArrayList<>();
 				for (SchemeInOut sio : sios) {
 					String serialNumber = inventoryItemRepository.selectById(sio.getInventoryItemId())
 							.getSerialNumber();
+					if (!serialSchemeConsidered.contains(serialNumber + "," + sio.getSchemeId())) {
+						serialSchemeConsidered.add(serialNumber + "," + sio.getSchemeId());
+						continue;
+					}
 					sio.setRolledBackTimestamp(LocalDateTime.now());
 					amountToRollback += sio.getAmount();
 					sio.setSchemeType(SchemeType.OUT);
 					sio.setSerialNumber(serialNumber);
 					sio.setStoreCode(fofoOrder.getInvoiceNumber().split("/")[0]);
 					rolledbackSios.add(sio);
+				}
+				if (amountToRollback > 0) {
-				uwh.setAmount(Math.round(amountToRollback));
+					uwh.setAmount(Math.round(amountToRollback));
-				uwh.setDescription(description);
+					uwh.setDescription(description);
-				uwh.setTimestamp(LocalDateTime.now());
+					uwh.setTimestamp(LocalDateTime.now());
-				uwh.setReferenceType(WalletReferenceType.SCHEME_OUT);
+					uwh.setReferenceType(WalletReferenceType.SCHEME_OUT);
-				uwh.setReference(fofoOrder.getId());
+					uwh.setReference(fofoOrder.getId());
-				uwh.setWalletId(userWalletMap.get(fofoOrder.getFofoId()));
+					uwh.setWalletId(userWalletMap.get(fofoOrder.getFofoId()));
-				uwh.setFofoId(fofoOrder.getFofoId());
+					uwh.setFofoId(fofoOrder.getFofoId());
-				uwh.setStoreCode(fofoOrder.getInvoiceNumber().split("/")[0]);
+					uwh.setStoreCode(fofoOrder.getInvoiceNumber().split("/")[0]);
-				userWalletHistory.add(uwh);
+					userWalletHistory.add(uwh);
+				}
+			}
 		});
 		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(
-				Arrays.asList("User Id", "Reference Type", "Reference", "Amount", "Description", "Timestamp"),
+				Arrays.asList("User Id", "Store Code", "Reference Type", "Reference", "Amount", "Description",
+						"Timestamp"),
+				userWalletHistory.stream()
-				userWalletHistory.stream().map(x -> Arrays.asList(x.getWalletId(), x.getReferenceType(),
+						.map(x -> Arrays.asList(x.getWalletId(), x.getStoreCode(), x.getReferenceType(),
-						x.getReference(), x.getAmount(), x.getDescription(), x.getTimestamp()))
+								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"),
 		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())) });
+	}
 	public void dryRunSchemeOutReco1() throws Exception {
-		List<Integer> references = Arrays.asList(6744,7347, 8320, 8891, 9124, 9217, 9263, 9379);
+		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) {
+			} 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.
+				List<SchemeInOut> sios = schemeInOutRepository
+						.selectByInventoryItemIds(inventorySerialNumberMap.keySet()).stream()
-						selectByInventoryItemIds(inventorySerialNumberMap.keySet()).stream().filter(x -> schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.OUT))
+						.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()
-				Map<Integer, List<SchemeInOut>> inventoryIdSouts = sios.stream().collect(Collectors.groupingBy(SchemeInOut::getInventoryItemId, Collectors.toList()));
+						.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) {
+					if (outList.size() > 1) {
+					}
+				}
 				uwh.setAmount(Math.round(amountToRollback));
 				uwh.setDescription(description);
 				uwh.setTimestamp(LocalDateTime.now());
 				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()));
+						.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(),
+						.map(x -> Arrays.asList(x.getSchemeId(), x.getSchemeType(), x.getStoreCode(),
-						x.getSerialNumber(), x.getAmount(), x.getCreateTimestamp(), x.getRolledBackTimestamp()))
+								x.getSerialNumber(), x.getAmount(), x.getCreateTimestamp(), x.getRolledBackTimestamp()))
-				.collect(Collectors.toList()));
+						.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())) });
+	}
+}
 /*
  * public void processSchemeForModel(String string) { pricingService
+ *

Subversion Repositories SmartDukaan

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