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

 import java.text.MessageFormat;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.time.temporal.ChronoUnit;
-import java.time.temporal.TemporalAmount;
-import java.time.temporal.TemporalUnit;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
 import com.spice.profitmandi.dao.repository.fofo.ScanRecordRepository;
 import com.spice.profitmandi.dao.repository.fofo.SchemeInOutRepository;
 import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
 import com.spice.profitmandi.service.inventory.InventoryService;
+import com.spice.profitmandi.service.order.OrderService;
 import com.spice.profitmandi.service.recharge.provider.OxigenRechargeProviderService;
 import com.spice.profitmandi.service.recharge.provider.ThinkWalnutDigitalRechargeProviderService;
 import com.spice.profitmandi.service.scheme.SchemeService;
 import com.spice.profitmandi.service.slab.TargetSlabService;
 import com.spice.profitmandi.service.transaction.TransactionService;
 	@Autowired
 	private SchemeService schemeService;
 	@Autowired
+	private OrderService orderService;
+	@Autowired
 	private SchemeInOutRepository schemeInOutRepository;
 	@Autowired
 	private RechargeTransactionRepository rechargeTransactionRepository;
 	public void evaluateExcessSchemeOut() throws Exception {
 		Map<Integer, String> userNameMap = retailerService.getAllFofoRetailerIdNameMap();
 		Map<Integer, Float> userAmountMap = new HashMap<>();
 		List<List<Object>> rows = new ArrayList<>();
-		List<String> headers = Arrays.asList("Scheme", "Item","Partner", "Amount", "Credited On",
+		List<String> headers = Arrays.asList("Scheme", "Item", "Partner", "Amount", "Credited On", "Invoice Number",
-				"Invoice Number", "Sale On", "Scheme Start", "Scheme End", "Active On", "Expired On");
+				"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
 						.selectBySchemeIds(new HashSet<>(Arrays.asList(x.getId())));
 				if (x.getActiveTimestamp() != null) {
 						endDateTime = x.getExpireTimestamp();
+					}
 					for (SchemeInOut sio : sioList) {
 						InventoryItem inventoryItem = null;
 						inventoryItem = inventoryItemRepository.selectById(sio.getInventoryItemId());
-						FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndSerialNumber(inventoryItem.getFofoId(), inventoryItem.getSerialNumber(),
+						FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndSerialNumber(
-								null, null, 0, 1).get(0);
+								inventoryItem.getFofoId(), inventoryItem.getSerialNumber(), null, null, 0, 1).get(0);
 						Optional<ScanRecord> record = scanRecordRepository
 								.selectByInventoryItemId(sio.getInventoryItemId()).stream()
 								.filter(y -> y.getType().equals(ScanType.SALE)).findFirst();
 						if (record.isPresent()) {
 							int fofoId = record.get().getFofoId();
 		userAmountMap.entrySet().stream()
 				.forEach(x -> LOGGER.info("{} to be deducted from {}({}) for wrongly disbursed due to technical error.",
 						x.getValue(), userNameMap.get(x.getKey())));
 		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
-		Utils.sendMailWithAttachment(googleMailSender, "adeel.yazdani@smartdukaan.com",
+		Utils.sendMailWithAttachment(googleMailSender,
-				new String[] { "amit.gupta@shop2020.in" }, "Partner Excess Amount", "PFA"
+				new String[] { "amit.gupta@shop2020.in", "adeel.yazdani@smartdukaan.com" }, null,
-				, "ListofSchemes.csv", new ByteArrayResource(baos.toByteArray()));
+				"Partner Excess Amount", "PFA", "ListofSchemes.csv", new ByteArrayResource(baos.toByteArray()));
+	}
 	public void processScheme(int offset) throws Exception {
-		LocalDateTime startDate = LocalDateTime.of(LocalDate.now(), LocalTime.MIDNIGHT).minusDays(30*offset);
+		LocalDateTime startDate = LocalDateTime.of(LocalDate.now(), LocalTime.MIDNIGHT).minusDays(30 * offset);
 		LocalDateTime endDate = startDate.plusDays(30);
 		processScheme(startDate, endDate);
+	}
 	public void processScheme() throws Exception {
 		LocalDateTime fromDate = LocalDateTime.now().minusDays(30);
 		processScheme(fromDate, LocalDateTime.now());
+	}
 	public void processScheme(LocalDateTime startDate, LocalDateTime endDate) throws Exception {
 		LOGGER.info("Started execution at {}", LocalDateTime.now());
 		List<Purchase> purchases = purchaseRepository.selectAllBetweenPurchaseDate(startDate, endDate);
 		for (Purchase purchase : purchases) {
 			try {
 				schemeService.processSchemeIn(purchase.getId(), purchase.getFofoId());
 			} catch (Exception e) {
 				LOGGER.error("Error while processing purchase {} for scheme In ", purchase.getId());
 				e.printStackTrace();
+			}
+		}
 		List<FofoOrder> fofoOrders = fofoOrderRepository.selectBetweenSaleDate(startDate, endDate);
 		for (FofoOrder fofoOrder : fofoOrders) {
 			try {
 			rechargeTransactionRepository.persist(rt);
+		}
 		LOGGER.info("Cashbacks for Recharge processed Successfully");
+	}
-	public void sendPartnerInvestmentDetails() throws Exception {
+	public void sendPartnerInvestmentDetails(List<String> sendTo) throws Exception {
-		String fileName = "InvestmentSummary-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
 		List<FofoStore> fofoStores = fofoStoreRepository.selectAll();
 		Map<Integer, CustomRetailer> customRetailerMap = retailerService
 				.getFofoRetailers(fofoStores.stream().map(x -> x.getId()).collect(Collectors.toList()));
-		List<String> headers = Arrays.asList("Code", "StoreName", "Email", "Mobile", "WalletAmount", "InStockAmount",
+		List<String> headers = Arrays.asList("Code", "StoreName", "Email", "Mobile", "Wallet Amount",
+				"Yesterday's Sale", "In Stock Amount", "Return In Transit Stock", "Unbilled Amount",
-				"UnbilledStockAmount", "GrnPendingStockAmount", "MinimumInvestment", "TotalInvested", "ShortAmount");
+				"Grn Pending Amount", "Min Investment", "Investment Amount", "Investment Short");
 		List<List<Object>> 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;
+			}
 			float walletAmount = walletService.getUserWallet(fofoStore.getId()).getAmount();
 			float inStockAmount = inventoryService.getTotalAmountInStock(fofoStore.getId());
+			float salesAmount = orderService.getSales(fofoStore.getId(), LocalDate.now().minusDays(1));
 			float unbilledStockAmount = 0;
 			List<Order> unbilledOrders = transactionService.getInTransitOrders(fofoStore.getId());
 			for (Order unBilledOrder : unbilledOrders) {
 				unbilledStockAmount += unBilledOrder.getTotalAmount();
 						grnPendingOrder.getRetailerEmailId());
 				grnPendingStockAmount += grnPendingOrder.getTotalAmount();
+			}
 			float totalInvestedAmount = walletAmount + inStockAmount + unbilledStockAmount + grnPendingStockAmount;
 			List<Object> row = Arrays.asList(fofoStore.getCode(), retailer.getBusinessName(), retailer.getEmail(),
-					retailer.getMobileNumber(), walletAmount, inStockAmount, unbilledStockAmount, grnPendingStockAmount,
+					retailer.getMobileNumber(), salesAmount, walletAmount, inStockAmount, 0, unbilledStockAmount,
-					fofoStore.getMinimumInvestment(), totalInvestedAmount,
+					grnPendingStockAmount, fofoStore.getMinimumInvestment(), totalInvestedAmount,
 					fofoStore.getMinimumInvestment() - totalInvestedAmount);
 			rows.add(row);
+		}
+		String fileName = "InvestmentSummary-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
 		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
+		String[] sendToArray = sendTo.toArray(new String[sendTo.size()]);
-		Utils.sendMailWithAttachment(googleMailSender, "adeel.yazdani@smartdukaan.com",
+		Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Partner Investment Summary", "PFA", fileName,
+				new ByteArrayResource(baos.toByteArray()));
+	}
+	public void sendPartnerInvestmentDetails() throws Exception {
-				new String[] { "amandeep.singh@smartdukaan.com", "tarun.verma@smartdukaan.com",
+		List<String> sendTo = Arrays.asList("adeel.yazdani@smartdukaan.com", "amandeep.singh@smartdukaan.com",
-						"kamini.sharma@smartdukaan.com", "dhruv.kathpal@smartdukaan.com" },
+				"tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com", "dhruv.kathpal@smartdukaan.com",
+				"neeraj.gupta@smartdukaan.com");
-				"Partner Investment Summary", "PFA", fileName, new ByteArrayResource(baos.toByteArray()));
+		this.sendPartnerInvestmentDetails(sendTo);
+	}
 	private void sendMailWithAttachments(String[] email, String[] ccEmails, String body, String subject,
 			Map<String, InputStream> inputStreams)
 			throws MessagingException, ProfitMandiBusinessException, IOException {
 			inputStreams.put(partnerTargetDetail.getTargetName(), is);
+		}
 		// String[] ccEmails = null;
-		if (partnerTargetDetails.size()>0) {
+		if (partnerTargetDetails.size() > 0) {
 			String[] ccEmails = { "Tarun.verma@smartdukaan.com", "Kamini.sharma@smartdukaan.com",
 					"chaitnaya.vats@smartdukaan.com", "dhruv.kathpal@smartdukaan.com" };
 			String subject = "Daily Sales Report ";
 			String message = MessageFormat.format("Sale Target summary for {0}", LocalDate.now());
 			LOGGER.info("message" + message);
 			if (salesHeadDetail.getName().equals("Kamal")) {
 				LOGGER.info("salesHeadDetail.getName()" + salesHeadDetail.getName());
 				String[] to = { salesHeadDetail.getEmail(), "mohinder.mutreja@smartdukaan.com" };
-			this.sendMailWithAttachments(to, ccEmails, message, subject, inputStreams);
+				this.sendMailWithAttachments(to, ccEmails, message, subject, inputStreams);
-		} else {
+			} else {
-			LOGGER.info("salesHeadDetail.getName()" + salesHeadDetail.getName());
+				LOGGER.info("salesHeadDetail.getName()" + salesHeadDetail.getName());
-			String[] to = { salesHeadDetail.getEmail() };
+				String[] to = { salesHeadDetail.getEmail() };
-			this.sendMailWithAttachments(to, ccEmails, message, subject, inputStreams);
+				this.sendMailWithAttachments(to, ccEmails, message, subject, inputStreams);
-		}
+			}
+		}
+	}
 	public void sendMailToPartnerAboutTargetAndSales() throws ProfitMandiBusinessException, MessagingException,
 			IOException, EncryptedDocumentException, InvalidFormatException {

Subversion Repositories SmartDukaan

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