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

 package com.smartdukaan.cron.scheduled;
-import java.io.PrintStream;
 import java.sql.Timestamp;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.temporal.ChronoUnit;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
-import org.apache.commons.csv.CSVFormat;
-import org.apache.commons.csv.CSVPrinter;
 import org.apache.commons.io.output.ByteArrayOutputStream;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.transaction.annotation.Transactional;
 import com.spice.profitmandi.common.enumuration.RechargeStatus;
 import com.spice.profitmandi.common.model.CustomRetailer;
 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.dao.entity.dtr.DailyRecharge;
 import com.spice.profitmandi.dao.entity.dtr.RechargeProvider;
 import com.spice.profitmandi.dao.entity.dtr.RechargeProviderCreditWalletHistory;
 import com.spice.profitmandi.dao.entity.dtr.RechargeTransaction;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.entity.fofo.Purchase;
+import com.spice.profitmandi.dao.entity.fofo.SchemeInOut;
 import com.spice.profitmandi.dao.entity.transaction.Order;
+import com.spice.profitmandi.dao.entity.transaction.PriceDrop;
 import com.spice.profitmandi.dao.repository.dtr.DailyRechargeRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.RechargeProviderCreditWalletHistoryRepository;
 import com.spice.profitmandi.dao.repository.dtr.RechargeProviderRepository;
 import com.spice.profitmandi.dao.repository.dtr.RechargeTransactionRepository;
 import com.spice.profitmandi.dao.repository.fofo.FofoOrderRepository;
 import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
+import com.spice.profitmandi.dao.repository.fofo.SchemeInOutRepository;
 import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
+import com.spice.profitmandi.dao.repository.transaction.PriceDropRepository;
 import com.spice.profitmandi.service.inventory.InventoryService;
 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.transaction.TransactionService;
 	@Value("${think.walnut.digital.recharge.auth.key}")
 	private String thinkWalnutDigitalRechargeAuthKey;
 	@Autowired
 	private PurchaseRepository purchaseRepository;
+	@Autowired
+	private SchemeInOutRepository schemeInOutRepository;
 	@Autowired
 	private SchemeService schemeService;
 	@Autowired
 	@Autowired
 	private JavaMailSender mailSender;
 	@Autowired
+	private PriceDropRepository priceDropRepository;
+	@Autowired
-	@Qualifier(value="googleMailSender")
+	@Qualifier(value = "googleMailSender")
 	private JavaMailSender googleMailSender;
 	@Autowired
 	private InventoryService inventoryService;
 		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()));
-		try (
-				ByteArrayOutputStream baos = new ByteArrayOutputStream();
-				PrintStream writer = new PrintStream(baos);
-				CSVPrinter csvPrinter = new CSVPrinter(writer,
-						CSVFormat.EXCEL.withTrim().withHeader("Code", "StoreName", "Email", "Mobile", "WalletAmount",
-								"InStockAmount", "UnbilledStockAmount", "GrnPendingStockAmount", "MinimumInvestment",
-								"TotalInvested", "ShortAmount"));) {
-			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());
+		List<String> headers = Arrays.asList("Code", "StoreName", "Email", "Mobile", "WalletAmount", "InStockAmount",
+				"UnbilledStockAmount", "GrnPendingStockAmount", "MinimumInvestment", "TotalInvested", "ShortAmount");
+		List<List<Object>> rows = new ArrayList<>();
-				float unbilledStockAmount = 0;
+		for (FofoStore fofoStore : fofoStores) {
-				List<Order> unbilledOrders = transactionService.getInTransitOrders(fofoStore.getId());
+			CustomRetailer retailer = customRetailerMap.get(fofoStore.getId());
-				for (Order unBilledOrder : unbilledOrders) {
+			if (retailer == null) {
-					unbilledStockAmount += unBilledOrder.getTotalAmount();
+				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 grnPendingStockAmount = 0;
+			float unbilledStockAmount = 0;
-				List<Order> grnPendingOrders = orderRepository.selectPendingGrnOrders(fofoStore.getId());
+			List<Order> unbilledOrders = transactionService.getInTransitOrders(fofoStore.getId());
-				for (Order grnPendingOrder : grnPendingOrders) {
+			for (Order unBilledOrder : unbilledOrders) {
-					LOGGER.info("Grn pending for Order {} and partner {}", grnPendingOrder.getId(),
-							grnPendingOrder.getRetailerEmailId());
-					grnPendingStockAmount += grnPendingOrder.getTotalAmount();
+				unbilledStockAmount += unBilledOrder.getTotalAmount();
-				}
+			}
-				float totalInvestedAmount = walletAmount + inStockAmount + unbilledStockAmount + grnPendingStockAmount;
+			float grnPendingStockAmount = 0;
-				try {
-				csvPrinter.printRecord(fofoStore.getCode(), retailer.getBusinessName(),
+			List<Order> grnPendingOrders = orderRepository.selectPendingGrnOrders(fofoStore.getId());
-						retailer.getEmail(), retailer.getMobileNumber(), walletAmount,
+			for (Order grnPendingOrder : grnPendingOrders) {
-						inStockAmount, unbilledStockAmount, grnPendingStockAmount, fofoStore.getMinimumInvestment(), totalInvestedAmount,
+				LOGGER.info("Grn pending for Order {} and partner {}", grnPendingOrder.getId(),
-						fofoStore.getMinimumInvestment() - totalInvestedAmount);
+						grnPendingOrder.getRetailerEmailId());
-				} catch (Exception e) {
-					LOGGER.info("Could not get investment details for partner {}, re", retailer.getEmail());
+				grnPendingStockAmount += grnPendingOrder.getTotalAmount();
-					e.printStackTrace();
-				}
+			}
+			float totalInvestedAmount = walletAmount + inStockAmount + unbilledStockAmount + grnPendingStockAmount;
-			Utils.sendMailWithAttachment(googleMailSender, "kamini.sharma@smartdukaan.com",
+			List<Object> row = Arrays.asList(fofoStore.getCode(), retailer.getBusinessName(), retailer.getEmail(),
+					retailer.getMobileNumber(), walletAmount, inStockAmount, unbilledStockAmount, grnPendingStockAmount,
-					new String[] { "amandeep.singh@smartdukaan.com", "tarun.verma@smartdukaan.com"},
+					fofoStore.getMinimumInvestment(), totalInvestedAmount,
-					"Partner Investment Summary", "PFA", fileName, new ByteArrayResource(baos.toByteArray()));
+					fofoStore.getMinimumInvestment() - totalInvestedAmount);
+			rows.add(row);
+		}
+		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
+		Utils.sendMailWithAttachment(googleMailSender, "adeel.yazdani@smartdukaan.com",
+				new String[] { "amandeep.singh@smartdukaan.com", "tarun.verma@smartdukaan.com",
+						"kamini.sharma@smartdukaan.com" },
+				"Partner Investment Summary", "PFA", fileName, new ByteArrayResource(baos.toByteArray()));
+	}
+}

Subversion Repositories SmartDukaan

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