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

 package com.smartdukaan.cron.migrations;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
+import org.apache.commons.io.output.ByteArrayOutputStream;
 import org.apache.commons.lang.StringUtils;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.core.io.ByteArrayResource;
+import org.springframework.mail.javamail.JavaMailSender;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
+import com.spice.profitmandi.common.util.FileUtil;
+import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.dao.entity.fofo.CurrentInventorySnapshot;
 import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
 import com.spice.profitmandi.dao.entity.fofo.Purchase;
 import com.spice.profitmandi.dao.entity.fofo.ScanRecord;
 import com.spice.profitmandi.dao.entity.transaction.LineItem;
 import com.spice.profitmandi.dao.entity.transaction.LineItemImei;
 import com.spice.profitmandi.dao.entity.transaction.Order;
+import com.spice.profitmandi.dao.entity.transaction.UserWallet;
+import com.spice.profitmandi.dao.entity.transaction.UserWalletHistory;
 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
 import com.spice.profitmandi.dao.repository.GenericRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
 import com.spice.profitmandi.dao.repository.fofo.DebitNoteRepository;
 import com.spice.profitmandi.dao.repository.fofo.ScanRecordRepository;
 import com.spice.profitmandi.dao.repository.fofo.SchemeInOutRepository;
 import com.spice.profitmandi.dao.repository.transaction.LineItemImeisRepository;
 import com.spice.profitmandi.dao.repository.transaction.LineItemRepository;
 import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
+import com.spice.profitmandi.dao.repository.transaction.UserWalletHistoryRepository;
+import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
 import com.spice.profitmandi.dao.repository.user.UserRepository;
 import com.spice.profitmandi.service.inventory.InventoryService;
 import com.spice.profitmandi.service.order.OrderService;
 import com.spice.profitmandi.service.pricing.PriceDropService;
 import com.spice.profitmandi.service.scheme.SchemeService;
 import com.spice.profitmandi.service.transaction.TransactionService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.service.wallet.WalletService;
+import in.shop2020.model.v1.order.OrderStatus;
 import in.shop2020.model.v1.order.WalletReferenceType;
 @Component
 @Transactional(rollbackFor = Throwable.class)
 public class RunOnceTasks {
 	@Autowired
 	private LineItemRepository lineItemRepository;
 	@Autowired
+	private UserWalletRepository userWalletRepository;
+	@Autowired
+	private UserWalletHistoryRepository userWalletHistoryRepository;
+	@Autowired
 	private UserRepository userRepository;
 	@Autowired
 	private WalletService walletService;
 	private InventoryService inventoryService;
 	@Autowired
 	private TransactionService transactionService;
-	@Autowired
-	private OrderRepository orderRepository;
 	// Service for Tertiary/Partner Orders
 	@Autowired
 	private OrderService orderService;
 	@Autowired
 	@Autowired
 	private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;
 	@Autowired
+	private OrderRepository orderRepository;
+	@Autowired
 	private ScanRecordRepository scanRecordRepository;
+	@Autowired
+	private JavaMailSender mailSender;
 	public void dropCorrection() throws Exception {
 		walletService.rollbackAmountFromWallet(175128034, 274, 4, WalletReferenceType.PRICE_DROP,
 				"Scheme  differential for Price Drop of Rs.712 on Samsung J6 J600GG, on 01-08-2018 for missing 1pc");
 		walletService.rollbackAmountFromWallet(175128034, -259, 4, WalletReferenceType.PRICE_DROP,
 										quantityToReduce = quantityToReduce - ii.getGoodQuantity();
 										ii.setGoodQuantity(0);
 										cis.setAvailability(cis.getAvailability() - ii.getGoodQuantity());
 										purchase.setUnfullfilledNonSerializedQuantity(
 												purchase.getUnfullfilledNonSerializedQuantity() + quantityToReduce);
-										LOGGER.info("Rectified {}, {}, {}, {}, {}, {}",
+										LOGGER.info("Rectified {}, {}, {}, {}, {}, {}", purchase.getPurchaseReference(),
-												purchase.getPurchaseReference(), ii.getId(), ii.getItemId(),
-												ii.getInitialQuantity(), ii.getGoodQuantity(),
+												ii.getId(), ii.getItemId(), ii.getInitialQuantity(),
-												quantityToReduce);
+												ii.getGoodQuantity(), quantityToReduce);
 										break;
+									}
+								}
+							}
+						}
+					}
+				}
+			}
+		}
-		//throw new Exception();
+		// throw new Exception();
+	}
+	// Lets work it up for The Mobile Planet
+	// HRFB002 - 157112773
+	public void dailyReconciliation() throws Exception {
+		List<List<?>> rows = new ArrayList<>();
+		UserWallet uw = userWalletRepository.selectByRetailerId(157112773);
+		List<UserWalletHistory> walletHistory = userWalletHistoryRepository.selectByWalletId(uw.getId());
+		Map<LocalDate, List<UserWalletHistory>> dateWiseWalletHistory = walletHistory.stream()
+				.collect(Collectors.groupingBy(x -> x.getTimestamp().toLocalDate(), Collectors.toList()));
+		for (Map.Entry<LocalDate, List<UserWalletHistory>> entry : dateWiseWalletHistory.entrySet()) {
+			LocalDate dateToReconcile = entry.getKey();
+			List<UserWalletHistory> history = entry.getValue();
+			rows.add(reconcileOrdersAndWallet(uw.getUserId(), dateToReconcile, history));
+		}
+		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(Arrays.asList("Date", "Wallet Total", "Order Total"),
+				rows);
+		Utils.sendMailWithAttachment(mailSender, new String[] { "amit.gupta@shop2020.in" }, new String[] {}, "Test",
+				"test", "File.csv", new ByteArrayResource(baos.toByteArray()));
+	}
+	private List<?> reconcileOrdersAndWallet(int fofoId, LocalDate localDate, List<UserWalletHistory> history)
+			throws Exception {
+		Map<Integer, Integer> transactionsOnThatDate = history.stream()
+				.filter(x -> x.getReferenceType().equals(WalletReferenceType.PURCHASE))
+				.collect(Collectors.groupingBy(x -> x.getReference(), Collectors.summingInt(x -> x.getAmount())));
+		int walletConsumed = 0;
+		float totalOrderAmount = 0;
+		for (int transactionId : transactionsOnThatDate.keySet()) {
+			walletConsumed -= transactionsOnThatDate.get(transactionId);
+			List<Order> orders = orderRepository.selectAllByTransactionId(transactionId);
+			for (Order o : orders) {
+				if (o.getRefundTimestamp() == null) {
+					if (Arrays.asList(OrderStatus.PAYMENT_PENDING, OrderStatus.PAYMENT_FAILED)
+							.contains(o.getStatus())) {
+						totalOrderAmount -= o.getWalletAmount();
+					} else {
+						totalOrderAmount += o.getWalletAmount();
+					}
+				} else {
+					totalOrderAmount -= o.getWalletAmount();
+				}
+			}
+		}
+		return Arrays.asList(localDate, walletConsumed, totalOrderAmount);
+	}
+	private void reconcileDailySchemeIn() {
+	}
+	private void reconcileDailySchemeOut() {
+	}
+}

Subversion Repositories SmartDukaan

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