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

 import com.spice.profitmandi.common.model.GstRate;
 import com.spice.profitmandi.common.model.RechargeCredential;
 import com.spice.profitmandi.common.util.FileUtil;
 import com.spice.profitmandi.common.util.FormattingUtils;
 import com.spice.profitmandi.common.util.Utils;
+import com.spice.profitmandi.common.util.Utils.Attachment;
 import com.spice.profitmandi.dao.entity.catalog.Scheme;
 import com.spice.profitmandi.dao.entity.cs.Ticket;
 import com.spice.profitmandi.dao.entity.cs.TicketAssigned;
 import com.spice.profitmandi.dao.entity.dtr.DailyRecharge;
 import com.spice.profitmandi.dao.entity.dtr.RechargeProvider;
 	// Temporary Method
 	public void evaluateExcessSchemeOut() throws Exception {
 		Map<Integer, String> userNameMap = retailerService.getAllFofoRetailerIdNameMap();
 		Map<Integer, Float> userAmountMap = new HashMap<>();
-		List<List<Object>> rows = new ArrayList<>();
+		List<List<?>> rows = new ArrayList<>();
 		List<String> headers = Arrays.asList("Scheme", "Item", "Partner", "Amount", "Credited On", "Invoice Number",
 				"Sale On", "Scheme Start", "Scheme End", "Active On", "Expired On");
 		schemeRepository.selectAll().stream().forEach(x -> {
 			if (x.getType().equals(SchemeType.OUT)) {
 				List<SchemeInOut> sioList = schemeInOutRepository
 				.getFofoRetailers(fofoStores.stream().map(x -> x.getId()).collect(Collectors.toList()));
 		List<String> headers = Arrays.asList("Code", "StoreName", "Email", "Mobile", "Wallet Amount",
 				"Yesterday's Sale", "In Stock Amount", "Return In Transit Stock", "Unbilled Amount",
 				"Grn Pending Amount", "Min Investment", "Investment Amount", "Investment Short");
-		List<List<Object>> rows = new ArrayList<>();
+		List<List<?>> rows = new ArrayList<>();
 		for (FofoStore fofoStore : fofoStores) {
 			CustomRetailer retailer = customRetailerMap.get(fofoStore.getId());
 			if (retailer == null) {
 				LOGGER.info("Could not find retailer with retailer Id {}", fofoStore.getId());
 				continue;
+			}
+		}
+	}
-	public void dryRunSchemeReco() {
+	public void dryRunSchemeReco() throws Exception {
+		List<UserWalletHistory> userWalletHistory = new ArrayList<>();
+		List<SchemeInOut> rolledbackSios = new ArrayList<>();
+		Map<Integer, Integer> userWalletMap = userWalletRepository
+				.selectByRetailerIds(
+						fofoStoreRepository.selectAll().stream().map(x -> x.getId()).collect(Collectors.toSet()))
+				.stream().collect(Collectors.toMap(UserWallet::getUserId, UserWallet::getId));
 		Map<Integer, SchemeType> schemeTypeMap = schemeRepository.selectAll().stream()
 				.collect(Collectors.toMap(Scheme::getId, Scheme::getType));
 		LocalDateTime startDate = LocalDate.of(2018, 9, 4).atStartOfDay();
-		LocalDateTime endDate = startDate.plusDays(1);
+		LocalDateTime endDate = startDate.plusDays(4);
 		List<FofoOrder> allOrders = fofoOrderRepository.selectBetweenSaleDate(startDate, endDate);
 		allOrders.stream().forEach(fofoOrder -> {
+			String description = "Adjustment of Duplicate Scheme for Sale Invoice " + fofoOrder.getInvoiceNumber();
 			List<Integer> inventoryItemIds = new ArrayList<>();
+			float amountToRollback = 0;
 			List<FofoOrderItem> orderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
 			orderItems.forEach(x -> {
 				inventoryItemIds.addAll(x.getFofoLineItems().stream().map(FofoLineItem::getInventoryItemId)
 						.collect(Collectors.toSet()));
 			});
-			List<SchemeType> sios = schemeInOutRepository.selectAllDuplicate(inventoryItemIds).stream()
+			List<SchemeInOut> sios = schemeInOutRepository.selectAllDuplicate(inventoryItemIds).stream()
-					.map(x -> schemeTypeMap.get(x.getSchemeId()))
+					.filter(x -> schemeTypeMap.get(x.getSchemeId()).equals(SchemeType.OUT))
-					.filter(schemeType -> schemeType.equals(SchemeType.OUT)).collect(Collectors.toList());
+					.collect(Collectors.toList());
 			if (sios.size() > 0) {
-				LOGGER.info("Found {} duplicate scheme outs for Orderid {}", sios.size(), fofoOrder.getId());
+				LOGGER.info("Found {} duplicate schemeouts for Orderid {}", sios.size(), fofoOrder.getId());
+				UserWalletHistory uwh = new UserWalletHistory();
+				for (SchemeInOut sio : sios) {
+					List<SchemeInOut> souts = schemeInOutRepository.selectByScheme(sio.getSchemeId(),
+							sio.getInventoryItemId());
+					if (souts.size() > 2) {
+						LOGGER.info("Ignoring Scheme outs for Scheme {}, InventoryItem {} as Qty is {}",
+								sio.getSchemeId(), sio.getInventoryItemId(), souts.size());
+					} else {
+						String serialNumber = inventoryItemRepository.selectById(sio.getInventoryItemId())
+								.getSerialNumber();
+						souts.get(0).setRolledBackTimestamp(LocalDateTime.now());
+						amountToRollback += souts.get(0).getAmount();
+						souts.get(0).setSchemeType(SchemeType.OUT);
+						souts.get(0).setSerialNumber(serialNumber);
+						souts.get(0).setStoreCode(fofoOrder.getInvoiceNumber().split("/")[0]);
+						rolledbackSios.add(souts.get(0));
+					}
+				}
+				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())) }
+		);
+	}
+}
 /*
  * public void processSchemeForModel(String string) { pricingService

Subversion Repositories SmartDukaan

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