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

 import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
 import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
-import com.spice.profitmandi.dao.entity.fofo.PartnerTargetDetails;
 import com.spice.profitmandi.dao.entity.fofo.Purchase;
 import com.spice.profitmandi.dao.entity.fofo.ScanRecord;
 import com.spice.profitmandi.dao.entity.fofo.SchemeInOut;
 import com.spice.profitmandi.dao.entity.transaction.PriceDrop;
 import com.spice.profitmandi.dao.entity.transaction.PriceDropIMEI;
 import com.spice.profitmandi.dao.repository.catalog.SchemeRepository;
 import com.spice.profitmandi.dao.repository.cs.CsService;
 import com.spice.profitmandi.dao.repository.cs.PositionRepository;
 import com.spice.profitmandi.dao.repository.dtr.DailyRechargeRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
+import com.spice.profitmandi.dao.repository.dtr.InsurancePolicyRepository;
 import com.spice.profitmandi.dao.repository.dtr.Mongo;
 import com.spice.profitmandi.dao.repository.dtr.NotificationCampaignRepository;
 import com.spice.profitmandi.dao.repository.dtr.PushNotificationRepository;
 import com.spice.profitmandi.dao.repository.dtr.RechargeProviderCreditWalletHistoryRepository;
 import com.spice.profitmandi.dao.repository.dtr.RechargeProviderRepository;
 	@Autowired
 	private PriceDropService priceDropService;
 	@Autowired
 	private CsService csService;
+	@Autowired
+	private InsurancePolicyRepository insurancePolicyRepository;
 	@Autowired
 	private ToffeeService toffeeService;
 	@Value("${oxigen.recharge.auth.key}")
 	// Temporary Method
 	public void evaluateExcessSchemeOut() throws Exception {
 		Map<Integer, String> userNameMap = retailerService.getAllFofoRetailerIdNameMap();
 		Map<Integer, Float> userAmountMap = new HashMap<>();
-		List<List<? extends Serializable>> 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
 		public List<String> getL1() {
 			return l1;
+		}
-		public void setL1(List<String> l1) {
-			this.l1 = l1;
-		}
 		public List<String> getL2() {
 			return l2;
+		}
-		public void setL2(List<String> l2) {
-			this.l2 = l2;
-		}
+	}
 	public void sendPartnerInvestmentDetails(List<String> sendTo) throws Exception {
 		if (sendTo == null) {
 			sendTo = Arrays.asList("tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com",
 				.getFofoRetailers(fofoStores.stream().map(x -> x.getId()).collect(Collectors.toList()));
 		List<String> headers = Arrays.asList("Code", "Firm Name", "Store Name", "State Manager", "Teritory/Team Lead",
 				"Wallet Amount", "In Stock Amount", "Return In Transit Stock", "Unbilled Amount", "Grn Pending Amount",
 				"Min Investment", "Investment Amount", "Investment Short", "Unbilled Qty");
-		List<List<? extends Serializable>> rows = new ArrayList<>();
+		List<List<?>> rows = new ArrayList<>();
-		Map<String, List<? extends Serializable>> partnerRow = new HashMap<>();
+		Map<Integer, List<? extends Serializable>> partnerRowsMap = new HashMap<>();
-		Map<String, SaleRoles> partnerEmailSalesMap = this.getPartnerEmailSalesMap();
+		Map<Integer, List<Serializable>> partnerIdSalesHeaderMap = this.getPartnerIdSalesHeaders();
 		for (FofoStore fofoStore : fofoStores) {
 			PartnerDailyInvestment partnerDailyInvestment = partnerInvestmentService.getInvestment(fofoStore.getId(),
 );
 			partnerDailyInvestment.setDate(yesterDay);
 			} catch (Exception e) {
 				// ignore the exceptions during persist
+			}
 			CustomRetailer retailer = customRetailerMap.get(fofoStore.getId());
-			if (retailer == null || partnerEmailSalesMap.get(retailer.getEmail()) == null) {
+			if (retailer == null || partnerIdSalesHeaderMap.get(fofoStore.getId()) == null) {
 				LOGGER.info("Could not find retailer with retailer Id {}", fofoStore.getId());
 				continue;
+			}
-			List<? extends Serializable> row = Arrays.asList(fofoStore.getCode(), retailer.getBusinessName(),
+			List<Serializable> row = partnerIdSalesHeaderMap.get(fofoStore.getId());
-					"SmartDukaan-" + fofoStore.getCode().replaceAll("[a-zA-Z]+", ""),
-					StringUtils.join(partnerEmailSalesMap.get(retailer.getEmail()).getL2(), ", "),
-					StringUtils.join(partnerEmailSalesMap.get(retailer.getEmail()).getL1(), ", "),
-					partnerDailyInvestment.getWalletAmount(), partnerDailyInvestment.getInStockAmount(), 0,
-					partnerDailyInvestment.getUnbilledAmount(), partnerDailyInvestment.getGrnPendingAmount(),
-					partnerDailyInvestment.getMinInvestment(), partnerDailyInvestment.getTotalInvestment(),
-					partnerDailyInvestment.getShortInvestment(), partnerDailyInvestment.getUnbilledQty());
-			partnerRow.put(retailer.getEmail(), row);
+			partnerRowsMap.put(fofoStore.getId(), row);
 			rows.add(row);
+		}
 		String fileName = "InvestmentSummary-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
-		for (Map.Entry<String, Set<String>> storeGuyEntry : csService.getAuthUserPartnerEmailMapping().entrySet()) {
+		for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMapping().entrySet()) {
-			List<List<? extends Serializable>> filteredRows = storeGuyEntry.getValue().stream()
+			List<List<?>> filteredRows = storeGuyEntry.getValue().stream().map(x -> partnerRowsMap.get(x))
-					.map(x -> partnerRow.get(x)).filter(x -> x != null).collect(Collectors.toList());
+					.filter(x -> x != null).collect(Collectors.toList());
 			ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, filteredRows);
 			String[] sendToArray = new String[] { storeGuyEntry.getKey() };
 			Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Franchise Investment Summary", "PFA",
 					fileName, new ByteArrayResource(baos.toByteArray()));
+		}
 		Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Franchise Investment Summary", "PFA",
 				fileName, new ByteArrayResource(baos.toByteArray()));
+	}
-	private Map<String, SaleRoles> getPartnerEmailSalesMap() {
+	private Map<Integer, List<Serializable>> getPartnerIdSalesHeaders() {
 		Map<String, SaleRoles> partnerEmailSalesMap = new HashMap<>();
 		List<Position> positions = positionRepository
 				.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_SALES);
 		Map<Integer, AuthUser> authUsersMap = authRepository.selectAllActiveUser().stream()
 				} else if (position.getEscalationType().equals(EscalationType.L2)) {
 					saleRoles.getL2().add(name);
+				}
+			}
+		}
+		Set<CustomRetailer> allCrList = new HashSet<>();
+		for (List<CustomRetailer> cr : positionIdRetailerMap.values()) {
+			allCrList.addAll(cr);
+		}
+		Map<Integer, FofoStore> fofoStoresMap = fofoStoreRepository.selectActiveStores().stream()
+				.collect(Collectors.toMap(x -> x.getId(), x -> x));
+		Map<Integer, List<Serializable>> partnerIdSalesHeadersMap = new HashMap<>();
+		for (CustomRetailer cr : allCrList) {
+			FofoStore fofoStore = fofoStoresMap.get(cr.getPartnerId());
+			String code = fofoStore.getCode();
+			String storeName = "SmartDukaan-" + fofoStore.getCode().replaceAll("[a-zA-Z]", "");
+			String businessName = cr.getBusinessName();
+			try {
+				String stateManager = StringUtils.join(partnerEmailSalesMap.get(cr.getEmail()).getL2(), ", ");
+				String territoryManager = StringUtils.join(partnerEmailSalesMap.get(cr.getEmail()).getL1(), ", ");
+				List<Serializable> row = new ArrayList<>(
+						Arrays.asList(code, businessName, storeName, stateManager, territoryManager));
+				partnerIdSalesHeadersMap.put(cr.getPartnerId(), row);
+			} catch (Exception e) {
+				LOGGER.warn("Could not find partner with email - {}", cr.getEmail());
+			}
+		}
-		return partnerEmailSalesMap;
+		return partnerIdSalesHeadersMap;
+	}
 	public void sendPartnerInvestmentDetails() throws Exception {
 		this.sendPartnerInvestmentDetails(null);
+	}
 	public void sendTargetVsSalesReport(List<String> sendTo) throws Exception {
 		if (sendTo == null) {
 			sendTo = Arrays.asList("tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com",
 					"amit.gupta@shop2020.in", "amod.sen@smartdukaan.com", "prakash.rai@smartdukaan.com");
+		}
-		Map<String, List<? extends Serializable>> partnerSalesTargetRowsMap = targetService.getDailySaleReportVsTarget();
+		Map<Integer, List<Serializable>> partnerSalesTargetRowsMap = targetService.getDailySaleReportVsTarget();
-		Map<Integer, FofoStore> fofoStoresMap = fofoStoreRepository.selectActiveStores().stream()
-				.collect(Collectors.toMap(x -> x.getId(), x -> x));
-		Map<Integer, CustomRetailer> customRetailerMap = retailerService
-				.getFofoRetailers(new ArrayList<>(fofoStoresMap.keySet()));
-		Map<String, CustomRetailer> customRetailerEmailMap = customRetailerMap.values().stream()
-				.collect(Collectors.toMap(x -> x.getEmail(), x -> x));
-		Map<String, SaleRoles> partnerEmailSalesMap = this.getPartnerEmailSalesMap();
+		Map<Integer, List<Serializable>> partnerIdSalesHeadersMap = this.getPartnerIdSalesHeaders();
-		List<String> headers = Arrays.asList("Code", "Firm Name", "Store Name","State Manager",
+		List<String> headers = Arrays.asList("Code", "Firm Name", "Store Name", "State Manager", "Teritory Manager",
-				"Teritory Manager", "Current Category", "Target Value", "Target Achieved",
+				"Current Category", "Target Value", "Target Achieved", "Achived Percentage", "Remaining Target",
-				"Achived Percentage", "Remaining Target", "Today's Target", "Today's achievement");
+				"Today's Target", "Today's achievement");
-		List<List<? extends Serializable>> rows = new ArrayList<>();
+		List<List<?>> rows = new ArrayList<>();
-		Map<String, List<? extends Serializable>> partnerRowMap = new HashMap<>();
+		Map<Integer, List<? extends Serializable>> partnerRowMap = new HashMap<>();
-		for (Map.Entry<String, List<? extends Serializable>> partnerSalesTargetRowEntry : partnerSalesTargetRowsMap
+		for (Map.Entry<Integer, List<Serializable>> partnerSalesTargetRowEntry : partnerSalesTargetRowsMap.entrySet()) {
-				.entrySet()) {
-			CustomRetailer retailer = customRetailerEmailMap.get(partnerSalesTargetRowEntry.getKey());
+			List<Serializable> row = partnerIdSalesHeadersMap.get(partnerSalesTargetRowEntry.getKey());
-			FofoStore fofoStore = fofoStoresMap.get(retailer.getPartnerId());
-			Serializable code = fofoStore.getCode();
-			Serializable storeName = "SmartDukaan-" + fofoStore.getCode().replaceAll("[a-zA-Z]", "");
-			Serializable businessName = retailer.getBusinessName();
-			try {
-				Serializable stateManager = StringUtils.join(partnerEmailSalesMap.get(retailer.getEmail()).getL2(),
-						", ");
-				Serializable territoryManager = StringUtils.join(partnerEmailSalesMap.get(retailer.getEmail()).getL1(),
-						", ");
-				List<Serializable> row = new ArrayList<>(
-						Arrays.asList(code, businessName, storeName, stateManager, territoryManager));
-				if (partnerSalesTargetRowsMap.get(retailer.getEmail()) != null) {
-					row.addAll(partnerSalesTargetRowsMap.get(retailer.getEmail()));
-					partnerRowMap.put(retailer.getEmail(), row);
-					rows.add(row);
+			if (row == null) {
-				}
-			} catch (Exception e) {
-				LOGGER.warn("Could not find partner with email - {}", retailer.getEmail());
+				LOGGER.warn("Could not find headers for partner ID - {}", partnerSalesTargetRowEntry.getKey());
+			}
+			row.addAll(partnerSalesTargetRowEntry.getValue());
+			partnerRowMap.put(partnerSalesTargetRowEntry.getKey(), row);
+			rows.add(row);
+		}
 		String fileName = "TargetVsSales-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
 		Map<String, Set<String>> storeGuysMap = csService.getAuthUserPartnerEmailMapping();
 		for (Map.Entry<String, Set<String>> storeGuyEntry : storeGuysMap.entrySet()) {
 			if (storeGuyEntry.getValue().size() == 0)
 				continue;
-			List<List<? extends Serializable>> storeGuyRows = storeGuyEntry.getValue().stream()
+			List<List<?>> storeGuyRows = storeGuyEntry.getValue().stream().map(x -> partnerRowMap.get(x))
-					.map(x -> partnerRowMap.get(x)).collect(Collectors.toList());
+					.collect(Collectors.toList());
 			ByteArrayOutputStream authUserStream = FileUtil.getCSVByteStream(headers, storeGuyRows);
 			Attachment attache = new Attachment(fileName, new ByteArrayResource(authUserStream.toByteArray()));
 			System.out.println(storeGuyEntry.getValue());
 			Utils.sendMailWithAttachments(googleMailSender, new String[] { storeGuyEntry.getKey() }, null,
 					"Franchise Stock Report", "PFA", attache);
 		throw new Exception();
+	}
-	public void sendDailySalesReportNotificationToPartner(Integer fofoIdInt)
+	public void sendDailySalesNotificationToPartner(Integer fofoIdInt)
 			throws ProfitMandiBusinessException, MessagingException, IOException {
 		LocalDateTime now = LocalDateTime.now();
-		LocalDateTime from = LocalDateTime.of(now.getYear(), now.getMonth(), now.getDayOfMonth(), 00, 00);
+		LocalDateTime from = now.with(LocalTime.MIN);
 		Map<Integer, Double> salesByFofoIdMap = new HashMap<>();
 		List<Integer> fofoIds = null;
 		if (fofoIdInt == null) {
 			fofoIds = fofoStoreRepository.selectAll().stream().filter(x -> x.isActive()).map(x -> x.getId())
 					.collect(Collectors.toList());
 		} else {
 			fofoIds = Arrays.asList(fofoIdInt);
+		}
-		List<PartnerTargetDetails> partnerTargetDetails = partnerTargetRepository
-				.selectAllGeEqAndLeEqStartDateAndEndDate(now);
 		DateTimeFormatter timeFormatter = DateTimeFormatter.ofPattern("h a");
 		Map<Integer, Float> dailyTarget = new HashMap<>();
 		for (Integer fofoId : fofoIds) {
-			Map<Integer, Float> dailyAverageSale = null;
-			double sale = fofoOrderRepository.selectTotalSaleSumByFofoIdBrtweenDate(fofoId, from, now);
+			double sale = fofoOrderRepository.selectTotalSaleSumByFofoIdBetweenDate(fofoId, from, now);
-			for (PartnerTargetDetails partnerTargetDetail : partnerTargetDetails) {
-				Map<Integer, Float> targetValues = targetService.getTargetValueByFofoIdAndTargetId(fofoId,
-						partnerTargetDetail.getId());
-				if (targetValues.size() == 0) {
-					continue;
-				} else {
-					List<Integer> partnerIds = new ArrayList<>();
-					partnerIds.add(fofoId);
-					dailyAverageSale = targetService.getDailyAverageSaleForCurrentForSingleFofoIdAndBrand(partnerIds,
-							targetValues, partnerTargetDetail.getStartDate(), partnerTargetDetail.getEndDate(),
-							partnerTargetDetail.getBrandName());
-					dailyTarget.put(fofoId, dailyAverageSale.get(fofoId));
-					break;
-				}
-			}
 			SendNotificationModel sendNotificationModel = new SendNotificationModel();
 			sendNotificationModel.setCampaignName("Sales update alert");
-			if (dailyAverageSale != null && dailyAverageSale.get(fofoId) != null) {
-				sendNotificationModel.setMessage(String.format("Rs.%.0f till %s. Today's Target is Rs.%.0f", sale,
+			sendNotificationModel.setMessage(String.format(
-						now.format(timeFormatter), dailyAverageSale.get(fofoId)));
-			} else {
-				sendNotificationModel.setMessage(String.format("Rs.%.0f till %s", sale, now.format(timeFormatter)));
+					"Smartphones Rs.%.0f, Insurance Rs.%.0f, Total Rs.%.0f till %s.", sale, now.format(timeFormatter)));
-			}
 			sendNotificationModel.setType("url");
 			sendNotificationModel.setUrl("http://app.profitmandi.com/pages/home/notifications");
 			sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));
 			sendNotificationModel.setMessageType(MessageType.notification);
 			salesByFofoIdMap.put(fofoId, sale);
 			LOGGER.info(sale);
+		}
+		Map<Integer, Float> parternPolicyAmountMap = insurancePolicyRepository.selectAmountSumGroupByRetailerId(now, null);
+		Map<Integer, Float> parternPolicyQtyMap = insurancePolicyRepository.selectAmountSumGroupByRetailerId(now, null);
 		String saleReport = this.getDailySalesReportByPartnerId(salesByFofoIdMap, dailyTarget);
 		LOGGER.info(saleReport);
-		String cc[] =
-							  { "tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com",
+		String cc[] = { "tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com", "prakash.rai@smartdukaan.com",
-							  "prakash.rai@smartdukaan.com", "chaitnaya.vats@smartdukaan.com",
+				"chaitnaya.vats@smartdukaan.com"};
-							  "adeel.yazdani@smartdukaan.com", "mohinder.mutreja@smartdukaan.com" };
 		String subject = String.format("Sale till %s", now.format(timeFormatter));
 		this.sendMailOfHtmlFomat("amit.gupta@shop2020.in", saleReport, cc, subject);
-		// this.sendMailOfHtmlFomat("amod.sen@smartdukaan.com", saleReport, cc,
-		// subject);
+	}
-	public String getDailySalesReportByPartnerId(Map<Integer, Double> salesByFofoIdMap, Map<Integer, Float> dailyTarget)
+	private String getDailySalesReportByPartnerId(Map<Integer, Double> salesByFofoIdMap,
-			throws ProfitMandiBusinessException {
+			Map<Integer, Float> dailyTarget) throws ProfitMandiBusinessException {
 		StringBuilder sb = new StringBuilder();
 		sb.append("<html><body><p>Sale Report:</p><br/><table style='border:1px solid black';cellspacing=0>");
 		sb.append("<tbody>\n" + "	    				<tr>\n"
 				+ "	    					<th style='border:1px solid black;padding: 5px'>Partner</th>\n"
 				+ "	    					<th style='border:1px solid black;padding: 5px'>Daily Target</th>\n"
 									inventoryItem.getUpdateTimestamp().format(dtf), priceDrop.getPartnerPayout() + "",
 									inventoryItem.getLastScanType().equals(ScanType.DOA_OUT) + "")));
+				}
+			}
+		}
-		/*
-		 * for (FofoStore fofoStore : fofoStoreRepository.selectAll()) {
-		 * LOGGER.info("{}, {}", fofoStore.getId(),
-		 * partnerTypeChangeService.getTypeOnDate(fofoStore.getId(),
-		 * LocalDate.now().plusDays(1))); UserWallet userWallet =
-		 * userWalletRepository.selectByRetailerId(fofoStore.getId());
-		 * if(userWallet==null) continue;
-		 * System.out.printf("Store Code %s, Wallet amount %d, Sum amount %f%n",
-		 * fofoStore.getCode(), userWallet.getAmount(),
-		 * walletService.getWalletAmount(fofoStore.getId())); }
-		 */
-		/*
-		 * for (Map.Entry<String, Set<String>> storeGuyEntry :
-		 * csService.getAuthUserPartnerEmailMapping().entrySet()) {
-		 * System.out.println(storeGuyEntry.getKey() + " = " +
-		 * storeGuyEntry.getValue()); }
-		 */
+	}
 	public void testToffee() throws Exception {
 		// LOGGER.info("{}", toffeeService.getAuthToken());
 		LOGGER.info("{}", toffeeService.getProducts());
 		if (!focusedModelShortageReportMap.isEmpty())
+		{
 			String fileName = "Stock Alert-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
 			Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
-			Map<String, List<List<? extends Serializable>>> emailRowsMap = new HashMap<>();
+			Map<String, List<List<?>>> emailRowsMap = new HashMap<>();
 			focusedModelShortageReportMap.entrySet().forEach(x -> {
 				storeGuyMap.entrySet().forEach(y -> {
 					if (y.getValue().contains(x.getKey())) {
 				});
 			});
 			List<String> headers = Arrays.asList("Partner Id", "Partner Name", "Model Name", "Shortage Qty");
-			emailRowsMap.entrySet().forEach(e -> {
+			emailRowsMap.entrySet().forEach(entry -> {
 				ByteArrayOutputStream baos = null;
 				try {
-					baos = FileUtil.getCSVByteStream(headers, e.getValue());
+					baos = FileUtil.getCSVByteStream(headers, entry.getValue());
 				} catch (Exception e2) {
 					e2.printStackTrace();
+				}
-				String[] sendToArray = new String[] { e.getKey() };
+				String[] sendToArray = new String[] { entry.getKey() };
 				try {
-					LOGGER.info("email" + e.getKey());
-					LOGGER.info("list" + e.getValue());
 					Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Stock Alert", "PFA", fileName,
 							new ByteArrayResource(baos.toByteArray()));
 				} catch (Exception e1) { // TODO Auto-generated catch block
 					e1.printStackTrace();
+				}

Subversion Repositories SmartDukaan

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