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

 import java.time.format.DateTimeFormatter;
 import java.time.temporal.ChronoUnit;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
+import java.util.Comparator;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
 	PriceDropRepository priceDropRepository;
 	@Autowired
 	private SchemeService schemeService;
 	private static final String[] STOCK_AGEING_MAIL_LIST = new String[] { "uday.singh@smartudkaan.com",
 			"adeel.yazdani@smartdukaan.com", "manoj.singh@smartdukaan.com", "kamini.sharma@smartdukaan.com",
 			"mohinder.mutreja@smartdukaan.com", "ankit.bhatia@smartdukaan.com", "tarun.verma@smartdukaan.com",
-			"hemant.kaura@smartdukaan.com","rajat.gupta@smartdukaan.com", "kuldeep.kumar@smartdukaan.com", "prakash.rai@smartdukaan.com" };
+			"hemant.kaura@smartdukaan.com", "rajat.gupta@smartdukaan.com", "kuldeep.kumar@smartdukaan.com",
+			"prakash.rai@smartdukaan.com" };
 	private static final String[] ITEMWISE_PENDING_INDENT_MAIL_LIST = new String[] { "kamini.sharma@smartdukaan.com",
 			"prakash.rai@smartdukaan.com", "tarun.verma@smartdukaan.com", "uday.singh@smartdukaan.com",
 			"kuldeep.kumar@smartdukaan.com" };
 	private List<OrderStatus> orderStatusList = Arrays.asList(OrderStatus.SUBMITTED_FOR_PROCESSING);
-	private Object[] REPORT_HEADERS = { "Store Code", "Firm Name", "Store Name", "State Manager", "Teritory Manager" };
 	@Autowired
 	private ReporticoService reporticoService;
 	@Autowired
 	private PartnerInvestmentService partnerInvestmentService;
 	@Autowired
 	private TargetSlabService targetService;
 	@Value("${prod}")
 	private boolean prod;
 	@Autowired
 	private StateGstRateRepository stateGstRateRepository;
 	@Autowired
 	private RetailerService retailerService;
 			return l2;
+		}
+	}
+	private class FofoReportingModel {
+		private String code;
+		private int fofoId;
+		private String businessName;
+		private String territoryManager;
+		private String regionalManager;
+		@Override
+		public String toString() {
+			return "FofoReportingModel [code=" + code + ", fofoId=" + fofoId + ", businessName=" + businessName
+					+ ", territoryManager=" + territoryManager + ", regionalManager=" + regionalManager + "]";
+		}
+		public String getCode() {
+			return code;
+		}
+		public void setCode(String code) {
+			this.code = code;
+		}
+		public String getBusinessName() {
+			return businessName;
+		}
+		public void setBusinessName(String businessName) {
+			this.businessName = businessName;
+		}
+		public String getTerritoryManager() {
+			return territoryManager;
+		}
+		public void setTerritoryManager(String territoryManager) {
+			this.territoryManager = territoryManager;
+		}
+		public String getRegionalManager() {
+			return regionalManager;
+		}
+		public void setRegionalManager(String regionalManager) {
+			this.regionalManager = regionalManager;
+		}
+		private ScheduledTasks getOuterType() {
+			return ScheduledTasks.this;
+		}
+		@Override
+		public int hashCode() {
+			final int prime = 31;
+			int result = 1;
+			result = prime * result + getOuterType().hashCode();
+			result = prime * result + ((businessName == null) ? 0 : businessName.hashCode());
+			result = prime * result + ((code == null) ? 0 : code.hashCode());
+			result = prime * result + fofoId;
+			result = prime * result + ((regionalManager == null) ? 0 : regionalManager.hashCode());
+			result = prime * result + ((territoryManager == null) ? 0 : territoryManager.hashCode());
+			return result;
+		}
+		@Override
+		public boolean equals(Object obj) {
+			if (this == obj)
+				return true;
+			if (obj == null)
+				return false;
+			if (getClass() != obj.getClass())
+				return false;
+			FofoReportingModel other = (FofoReportingModel) obj;
+			if (!getOuterType().equals(other.getOuterType()))
+				return false;
+			if (businessName == null) {
+				if (other.businessName != null)
+					return false;
+			} else if (!businessName.equals(other.businessName))
+				return false;
+			if (code == null) {
+				if (other.code != null)
+					return false;
+			} else if (!code.equals(other.code))
+				return false;
+			if (fofoId != other.fofoId)
+				return false;
+			if (regionalManager == null) {
+				if (other.regionalManager != null)
+					return false;
+			} else if (!regionalManager.equals(other.regionalManager))
+				return false;
+			if (territoryManager == null) {
+				if (other.territoryManager != null)
+					return false;
+			} else if (!territoryManager.equals(other.territoryManager))
+				return false;
+			return true;
+		}
+		public int getFofoId() {
+			return fofoId;
+		}
+		public void setFofoId(int fofoId) {
+			this.fofoId = fofoId;
+		}
+	}
 	public void sendPartnerInvestmentDetails(List<String> sendTo) throws Exception {
 		LocalDate yesterDay = LocalDate.now().minusDays(1);
 		List<FofoStore> fofoStores = fofoStoreRepository.selectActiveStores();
 		Map<Integer, CustomRetailer> customRetailerMap = retailerService
 				.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", "Activated Stock", "Return In Transit Stock", "Unbilled Amount", "Grn Pending Amount",
+				"Wallet Amount", "In Stock Amount", "Activated Stock", "Return In Transit Stock", "Unbilled Amount",
-				"Min Investment", "Investment Amount", "Investment Short", "Unbilled Qty", "Short Days");
+				"Grn Pending Amount", "Min Investment", "Investment Amount", "Investment Short", "Unbilled Qty",
+				"Short Days");
 		List<List<?>> rows = new ArrayList<>();
 		Map<Integer, List<?>> partnerRowsMap = new HashMap<>();
-		Map<Integer, List<Serializable>> partnerIdSalesHeaderMap = this.getPartnerIdSalesHeaders();
+		Map<Integer, FofoReportingModel> partnerIdSalesHeaderMap = this.getPartnerIdSalesHeaders();
-		Map<Integer, Integer> shortDaysMap = partnerDailyInvestmentRepository.selectAll(LocalDate.now().withDayOfMonth(1), LocalDate.now())
+		Map<Integer, Integer> shortDaysMap = partnerDailyInvestmentRepository
-		.stream().collect(Collectors.groupingBy(x->x.getFofoId(),
+				.selectAll(LocalDate.now().withDayOfMonth(1), LocalDate.now()).stream().collect(Collectors.groupingBy(
-				Collectors.summingInt(x-> x.getShortPercentage() > 10 ? 1 : 0)));
+						x -> x.getFofoId(), Collectors.summingInt(x -> x.getShortPercentage() > 10 ? 1 : 0)));
 		for (FofoStore fofoStore : fofoStores) {
 			int fofoId = fofoStore.getId();
-			PartnerDailyInvestment partnerDailyInvestment = partnerInvestmentService.getInvestment(fofoId,1);
+			PartnerDailyInvestment partnerDailyInvestment = partnerInvestmentService.getInvestment(fofoId, 1);
 			partnerDailyInvestment.setDate(yesterDay);
 			try {
 				partnerDailyInvestmentRepository.persist(partnerDailyInvestment);
+				shortDaysMap.put(fofoId,
-				shortDaysMap.put(fofoId, shortDaysMap.get(fofoId) + (partnerDailyInvestment.getShortPercentage() > 10 ? 1 : 0));
+						shortDaysMap.get(fofoId) + (partnerDailyInvestment.getShortPercentage() > 10 ? 1 : 0));
 			} catch (Exception e) {
 				// ignore the exceptions during persist
+			}
 			CustomRetailer retailer = customRetailerMap.get(fofoStore.getId());
 			if (retailer == null || partnerIdSalesHeaderMap.get(fofoStore.getId()) == null) {
 				LOGGER.info("Could not find retailer with retailer Id {}", fofoStore.getId());
 				continue;
+			}
-			List<Serializable> row = partnerIdSalesHeaderMap.get(fofoStore.getId());
+			FofoReportingModel reportingModel = partnerIdSalesHeaderMap.get(fofoStore.getId());
+			List<Serializable> row = new ArrayList<>();
+			row.addAll(Arrays.asList(reportingModel.getCode(), reportingModel.getBusinessName(),
+					reportingModel.getRegionalManager(), reportingModel.getTerritoryManager()));
 			row.addAll(
 					Arrays.asList(partnerDailyInvestment.getWalletAmount(), partnerDailyInvestment.getInStockAmount(),
-							partnerDailyInvestment.getActivatedStockAmount() == 0 ? "-":"("+partnerDailyInvestment.getActivatedStockAmount()+")",
+							partnerDailyInvestment.getActivatedStockAmount() == 0 ? "-"
+									: "(" + partnerDailyInvestment.getActivatedStockAmount() + ")",
 , partnerDailyInvestment.getUnbilledAmount(), partnerDailyInvestment.getGrnPendingAmount(),
 							partnerDailyInvestment.getMinInvestment(), partnerDailyInvestment.getTotalInvestment(),
-							partnerDailyInvestment.getShortInvestment(), partnerDailyInvestment.getUnbilledQty(),shortDaysMap.get(fofoId)));
+							partnerDailyInvestment.getShortInvestment(), partnerDailyInvestment.getUnbilledQty(),
+							shortDaysMap.get(fofoId)));
 			partnerRowsMap.put(fofoStore.getId(), row);
 			rows.add(row);
+		}
 		Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Franchise Investment Summary", "PFA",
 				fileName, new ByteArrayResource(baos.toByteArray()));
+	}
-	private Map<Integer, List<Serializable>> getPartnerIdSalesHeaders() {
+	private Map<Integer, FofoReportingModel> getPartnerIdSalesHeaders() {
 		Map<String, SaleRoles> partnerEmailSalesMap = new HashMap<>();
 		List<Position> positions = positionRepository
 				.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_SALES);
 		Map<Integer, AuthUser> authUsersMap = authRepository.selectAllActiveUser().stream()
 				if (!partnerEmailSalesMap.containsKey(cr.getEmail())) {
 					partnerEmailSalesMap.put(cr.getEmail(), new SaleRoles());
+				}
 				SaleRoles saleRoles = partnerEmailSalesMap.get(cr.getEmail());
 				AuthUser authUser = authUsersMap.get(position.getAuthUserId());
-				if(authUser==null) {
+				if (authUser == null) {
 					continue;
+				}
 				String name = authUser.getFirstName() + " " + authUser.getLastName();
 				if (position.getEscalationType().equals(EscalationType.L1)) {
 					saleRoles.getL1().add(name);
+		}
 		Map<Integer, FofoStore> fofoStoresMap = fofoStoreRepository.selectActiveStores().stream()
 				.collect(Collectors.toMap(x -> x.getId(), x -> x));
-		Map<Integer, List<Serializable>> partnerIdSalesHeadersMap = new HashMap<>();
+		Map<Integer, FofoReportingModel> partnerIdSalesHeadersMap = new HashMap<>();
 		for (CustomRetailer cr : allCrList) {
 			FofoStore fofoStore = fofoStoresMap.get(cr.getPartnerId());
 			if (fofoStore == null) {
 				LOGGER.info("Could not find Store {} in active Store", cr.getBusinessName());
 				continue;
+			}
-			String code = fofoStore.getCode() + "";
+			String code = fofoStore.getCode();
+			// String storeName = "SmartDukaan-" +
-			String storeName = "SmartDukaan-" + fofoStore.getCode().replaceAll("[a-zA-Z]", "");
+			// 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<>(
+				FofoReportingModel reportingModel = new FofoReportingModel();
+				reportingModel.setBusinessName(businessName);
+				reportingModel.setCode(code);
+				reportingModel.setFofoId(fofoStore.getId());
+				reportingModel.setRegionalManager(stateManager);
-						Arrays.asList(code, businessName, storeName, stateManager, territoryManager));
+				reportingModel.setTerritoryManager(territoryManager);
-				partnerIdSalesHeadersMap.put(cr.getPartnerId(), row);
+				partnerIdSalesHeadersMap.put(fofoStore.getId(), reportingModel);
 			} catch (Exception e) {
 				LOGGER.warn("Could not find partner with email - {}", cr.getEmail());
+			}
+		}
 		return partnerIdSalesHeadersMap;
 			sendTo = Arrays.asList("tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com",
 					"amit.gupta@shop2020.in", "amod.sen@smartdukaan.com", "prakash.rai@smartdukaan.com");
+		}
 		Map<Integer, List<Serializable>> partnerSalesTargetRowsMap = targetService.getDailySaleReportVsTarget();
-		Map<Integer, List<Serializable>> partnerIdSalesHeadersMap = this.getPartnerIdSalesHeaders();
+		Map<Integer, FofoReportingModel> partnerIdSalesHeadersMap = this.getPartnerIdSalesHeaders();
-		List<String> headers = Arrays.asList("Code", "Firm Name", "Store Name", "State Manager", "Teritory Manager",
+		List<String> headers = Arrays.asList("Code", "Firm Name", "State Manager", "Teritory Manager",
 				"Current Category", "Target Value", "Target Achieved", "Achived Percentage", "Remaining Target",
 				"Today's Target", "Today's achievement");
 		List<List<?>> rows = new ArrayList<>();
 		Map<Integer, List<? extends Serializable>> partnerRowMap = new HashMap<>();
 		for (Map.Entry<Integer, List<Serializable>> partnerSalesTargetRowEntry : partnerSalesTargetRowsMap.entrySet()) {
-			List<Serializable> row = partnerIdSalesHeadersMap.get(partnerSalesTargetRowEntry.getKey());
+			FofoReportingModel fofoReportingModel = partnerIdSalesHeadersMap.get(partnerSalesTargetRowEntry.getKey());
-			if (row == null) {
+			if (fofoReportingModel == null) {
 				LOGGER.warn("Could not find headers for partner ID - {}", partnerSalesTargetRowEntry.getKey());
+				continue;
+			}
+			List<Serializable> row = Arrays.asList(fofoReportingModel.getCode(), fofoReportingModel.getBusinessName(),
+					fofoReportingModel.getRegionalManager(), fofoReportingModel.getTerritoryManager());
 			row.addAll(partnerSalesTargetRowEntry.getValue());
 			partnerRowMap.put(partnerSalesTargetRowEntry.getKey(), row);
 			rows.add(row);
+		}
 		throw new Exception();
+	}
-	public void sendDailySalesNotificationToPartner(Integer fofoIdInt)
+	public void sendDailySalesNotificationToPartner(Integer fofoIdInt) throws Exception {
-			throws ProfitMandiBusinessException, MessagingException, IOException {
 		LocalDateTime now = LocalDateTime.now();
 		LocalDateTime from = now.with(LocalTime.MIN);
 		String timeString = "Today %s";
 		// Send yesterday's report
 		DateTimeFormatter timeFormatter = DateTimeFormatter.ofPattern("h:m a");
 		Map<Integer, Float> partnerPolicyAmountMap = insurancePolicyRepository.selectAmountSumGroupByRetailerId(now,
 				null);
 		Map<Integer, Long> partnerPolicyQtyMap = insurancePolicyRepository.selectQtyGroupByRetailerId(now, null);
-		Map<Integer, Double> spPartnerOrderValMap = fofoOrderItemRepository.selectSumAmountGroupByRetailer(from, now,
+		Map<Integer, Double> spPartnerOrderValMap = fofoOrderItemRepository.selectSumAmountGroupByRetailer(from, now, 0,
-, true);
+				true);
+		Map<Integer, Double> spPartner3DaysOrderValMap = fofoOrderItemRepository
+				.selectSumAmountGroupByRetailer(from.minusDays(3), now, 0, true);
 		Map<Integer, Long> spPartnerOrderQtyMap = fofoOrderItemRepository.selectQtyGroupByRetailer(from, now, 0, true);
-		Map<Integer, Double> partnerOrderValMap = fofoOrderItemRepository.selectSumAmountGroupByRetailer(from, now,
+		Map<Integer, Double> partnerOrderValMap = fofoOrderItemRepository.selectSumAmountGroupByRetailer(from, now, 0,
-, false);
+				false);
 		Map<Integer, Long> partnerOrderQtyMap = fofoOrderItemRepository.selectQtyGroupByRetailer(from, now, 0, false);
 		Map<Integer, SaleTargetReportModel> saleTargetReportModelMap = new HashMap<>();
 		for (int fofoId : fofoIds) {
 			SaleTargetReportModel model = new SaleTargetReportModel();
 			model.setInsuranceSale(
 					partnerPolicyAmountMap.containsKey(fofoId) ? partnerPolicyAmountMap.get(fofoId).doubleValue() : 0);
 			model.setInsruanceQty(partnerPolicyQtyMap.containsKey(fofoId) ? partnerPolicyQtyMap.get(fofoId) : 0);
 			model.setSmartphoneSale(spPartnerOrderValMap.containsKey(fofoId) ? spPartnerOrderValMap.get(fofoId) : 0);
 			model.setSmartphoneQty(spPartnerOrderQtyMap.containsKey(fofoId) ? spPartnerOrderQtyMap.get(fofoId) : 0);
 			model.setTotalSale(partnerOrderValMap.containsKey(fofoId) ? partnerOrderValMap.get(fofoId) : 0);
 			model.setTotalQty(partnerOrderQtyMap.containsKey(fofoId) ? partnerOrderQtyMap.get(fofoId) : 0);
+			model.setPast3daysSale(
+					spPartner3DaysOrderValMap.containsKey(fofoId) ? spPartner3DaysOrderValMap.get(fofoId) : 0);
 			model.setFofoId(fofoId);
 			saleTargetReportModelMap.put(fofoId, model);
+		}
-		Map<Integer, List<Serializable>> partnerSalesHeadersMap = this.getPartnerIdSalesHeaders();
+		Map<Integer, FofoReportingModel> partnerSalesHeadersMap = this.getPartnerIdSalesHeaders();
 		for (Integer fofoId : fofoIds) {
 			SaleTargetReportModel model = saleTargetReportModelMap.get(fofoId);
 			SendNotificationModel sendNotificationModel = new SendNotificationModel();
 			sendNotificationModel.setCampaignName("Sales update alert");
 			sendNotificationModel.setTitle("Sale Update");
 			sendNotificationModel.setMessageType(MessageType.notification);
 			int userId = userAccountRepository.selectUserIdByRetailerId(fofoId);
 			sendNotificationModel.setUserIds(Arrays.asList(userId));
 			notificationService.sendNotification(sendNotificationModel);
+		}
-		String saleReport = this.getDailySalesReportHtml(partnerSalesHeadersMap, saleTargetReportModelMap);
+		// String saleReport = this.getDailySalesReportHtml(partnerSalesHeadersMap,
+		// saleTargetReportModelMap);
-		String statewiseSaleReport = this.getStateWiseSales(saleTargetReportModelMap);
+		String statewiseSaleReport = this.getStateWiseSales(saleTargetReportModelMap, partnerSalesHeadersMap);
-		LOGGER.info(saleReport);
 		String cc[] = { "tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com", "prakash.rai@smartdukaan.com",
-				"niranjan.kala@smartdukaan.com", "up.singh@smartdukaan.com", "shankar.mushra@smartdukaan.com" };
+				"niranjan.kala@smartdukaan.com", "up.singh@smartdukaan.com", "sm@smartdukaan.com" };
 		String subject = String.format("Sale till %s", String.format(timeString, now.format(timeFormatter)));
-		this.sendMailOfHtmlFomat("amit.gupta@smartukaan.com", saleReport, cc, subject);
+		// this.sendMailOfHtmlFomat("amit.gupta@smartukaan.com", saleReport, cc,
+		// subject);
-		this.sendMailOfHtmlFomat("amit.gupta@smartdukaan.com", statewiseSaleReport, cc, "Statewise" + subject);
+		this.sendMailOfHtmlFormat("amit.gupta@smartdukaan.com", statewiseSaleReport, cc, "Statewise" + subject);
+	}
 	public static class SaleTargetReportModel {
 		private double totalSale;
 		private long totalQty;
+		private double past3daysSale;
 		private int fofoId;
 		public int getFofoId() {
 			return fofoId;
+		}
 		private double smartphoneSale;
 		private long smartphoneQty;
 		private double insuranceSale;
 		private long insruanceQty;
 		public long getTotalQty() {
 			return totalQty;
+		}
 		public void setTotalQty(long totalQty) {
 			this.totalQty = totalQty;
+		}
+		public double getPast3daysSale() {
+			return past3daysSale;
+		}
+		public void setPast3daysSale(double past3daysSale) {
+			this.past3daysSale = past3daysSale;
+		}
 		@Override
 		public int hashCode() {
 			final int prime = 31;
 			int result = 1;
 			result = prime * result + fofoId;
 			this.insruanceQty = insruanceQty;
+		}
 		@Override
 		public String toString() {
-			return "SaleTargetReportModel [totalSale=" + totalSale + ", totalQty=" + totalQty + ", fofoId=" + fofoId
+			return "SaleTargetReportModel [totalSale=" + totalSale + ", totalQty=" + totalQty + ", past3daysSale="
-					+ ", smartphoneSale=" + smartphoneSale + ", smartphoneQty=" + smartphoneQty + ", insuranceSale="
+					+ past3daysSale + ", fofoId=" + fofoId + ", smartphoneSale=" + smartphoneSale + ", smartphoneQty="
-					+ insuranceSale + ", insruanceQty=" + insruanceQty + "]";
+					+ smartphoneQty + ", insuranceSale=" + insuranceSale + ", insruanceQty=" + insruanceQty + "]";
+		}
+	}
-	private String getStateWiseSales(Map<Integer, SaleTargetReportModel> saleTargetReportModelMap) {
+	private String getStateWiseSales(Map<Integer, SaleTargetReportModel> saleTargetReportModelMap,
+			Map<Integer, FofoReportingModel> partnerSalesHeadersMap) throws Exception {
 		List<FofoStore> stores = fofoStoreRepository.selectActiveStores();
-		Map<String, List<Integer>> stateMap = stores.stream().collect(Collectors.groupingBy(
+		Map<String, List<Integer>> stateMap = stores.stream().collect(Collectors
-									x->x.getCode().substring(0,2),
-									Collectors.mapping(x->x.getId(), Collectors.toList())));
+				.groupingBy(x -> x.getCode().substring(0, 2), Collectors.mapping(x -> x.getId(), Collectors.toList())));
 		List<List<Serializable>> stateWiseSales = new ArrayList<>();
 		for (Map.Entry<String, List<Integer>> stateMapEntry : stateMap.entrySet()) {
+			long totalQty = stateMapEntry.getValue().stream()
-			long totalQty = stateMapEntry.getValue().stream().collect(Collectors.summingLong(x->saleTargetReportModelMap.get(x).getTotalQty()));
+					.collect(Collectors.summingLong(x -> saleTargetReportModelMap.get(x).getTotalQty()));
+			double totalSale = stateMapEntry.getValue().stream()
-			double totalSale = stateMapEntry.getValue().stream().collect(Collectors.summingDouble(x->saleTargetReportModelMap.get(x).getTotalSale()));
+					.collect(Collectors.summingDouble(x -> saleTargetReportModelMap.get(x).getTotalSale()));
+			long smartPhoneQty = stateMapEntry.getValue().stream()
-			long smartPhoneQty = stateMapEntry.getValue().stream().collect(Collectors.summingLong(x->saleTargetReportModelMap.get(x).getSmartphoneQty()));
+					.collect(Collectors.summingLong(x -> saleTargetReportModelMap.get(x).getSmartphoneQty()));
+			double smartPhoneSale = stateMapEntry.getValue().stream()
-			double smartPhoneSale = stateMapEntry.getValue().stream().collect(Collectors.summingDouble(x->saleTargetReportModelMap.get(x).getSmartphoneSale()));
+					.collect(Collectors.summingDouble(x -> saleTargetReportModelMap.get(x).getSmartphoneSale()));
+			stateWiseSales
-			stateWiseSales.add(Arrays.asList(stateMapEntry.getKey(), smartPhoneQty, smartPhoneSale, totalQty, totalSale));
+					.add(Arrays.asList(stateMapEntry.getKey(), smartPhoneQty, smartPhoneSale, totalQty, totalSale));
+		}
 		StringBuilder sb = new StringBuilder();
+		sb.append("<html><body>");
-		sb.append("<html><body><p>Statewise Sale Report:</p><br/><table style='border:1px solid black';cellspacing=0>");
+		sb.append("<p>Statewise Sale Report:</p><br/><table style='border:1px solid black';cellspacing=0>");
 		sb.append("<tbody>\n" + "	    <tr>"
 				+ "	    					<th style='border:1px solid black;padding: 5px'>State</th>"
 				+ "	    					<th style='border:1px solid black;padding: 5px'>SmartPhone Qty</th>"
 				+ "	    					<th style='border:1px solid black;padding: 5px'>SmartPhone Value</th>"
 				+ "	    					<th style='border:1px solid black;padding: 5px'>Total Qty</th>"
 			sb.append("<td style='border:1px solid black;padding: 5px'>" + stateSale.get(2) + "</td>");
 			sb.append("<td style='border:1px solid black;padding: 5px'>" + stateSale.get(3) + "</td>");
 			sb.append("<td style='border:1px solid black;padding: 5px'>" + stateSale.get(4) + "</td>");
 			sb.append("</tr>");
+		}
-		sb.append("</tbody></table></body></html>");
+		sb.append("</tbody></table><br><br>");
-		return sb.toString();
-	}
-	private String getDailySalesReportHtml(Map<Integer, List<Serializable>> partnerSalesHeadersMap,
-			Map<Integer, SaleTargetReportModel> saleReportTargetMap) 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("<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'>%s</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Code</th>"
-				+ "	    					<th style='border:1px solid black;padding: 5px'>%s</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Business Name</th>"
-				+ "	    					<th style='border:1px solid black;padding: 5px'>%s</th>\n"
-				+ "	    					<th style='border:1px solid black;padding: 5px'>%s</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Regional Manager</th>"
-				+ "	    					<th style='border:1px solid black;padding: 5px'>%s</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Territory Manager</th>"
-				+ "	    					<th style='border:1px solid black;padding: 5px'>Sale</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Sale</th>"
-				+ "	    					<th style='border:1px solid black;padding: 5px'>Smartphone Sale</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Smartphone Sale</th>"
-				+ "	    					<th style='border:1px solid black;padding: 5px'>SmartPhone Qty</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>SmartPhone Qty</th>"
-				+ "	    					<th style='border:1px solid black;padding: 5px'>Insurance Sale</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Insurance Sale</th>"
-				+ "	    					<th style='border:1px solid black;padding: 5px'>Insurance Qty</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Insurance Qty</th>"
 				+ "	    				</tr>");
-		List<Integer> sortedPartnerSalesHeaders = partnerSalesHeadersMap.entrySet().stream()
+		List<Integer> sortedPartnerSalesHeaders = partnerSalesHeadersMap.values().stream()
-				.sorted((x, y) -> ((String) (x.getValue().get(3))).compareTo((String) (y.getValue().get(3))))
+				.sorted(Comparator.comparing(FofoReportingModel::getBusinessName)
+						.thenComparing(FofoReportingModel::getRegionalManager))
-				.map(x -> x.getKey()).collect(Collectors.toList());
+				.map(FofoReportingModel::getFofoId).collect(Collectors.toList());
 		for (Integer fofoId : sortedPartnerSalesHeaders) {
+			if(saleTargetReportModelMap.get(fofoId).getPast3daysSale()==0) {
-			sb.append("<tr>");
+				sb.append("<tr>");
+			} else {
-			sb.append("<td style='border:1px solid black;padding: 5px'>" + partnerSalesHeadersMap.get(fofoId).get(0)
+				sb.append("<tr style='background-color:red'>");
-					+ "</td>");
+			}
-			sb.append("<td style='border:1px solid black;padding: 5px'>" + partnerSalesHeadersMap.get(fofoId).get(1)
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + partnerSalesHeadersMap.get(fofoId).getCode()
 					+ "</td>");
-			sb.append("<td style='border:1px solid black;padding: 5px'>" + partnerSalesHeadersMap.get(fofoId).get(2)
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + partnerSalesHeadersMap.get(fofoId).getBusinessName()
 					+ "</td>");
-			sb.append("<td style='border:1px solid black;padding: 5px'>" + partnerSalesHeadersMap.get(fofoId).get(3)
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + partnerSalesHeadersMap.get(fofoId).getRegionalManager()
 					+ "</td>");
-			sb.append("<td style='border:1px solid black;padding: 5px'>" + partnerSalesHeadersMap.get(fofoId).get(4)
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + partnerSalesHeadersMap.get(fofoId).getTerritoryManager()
 					+ "</td>");
 			sb.append("<td style='border:1px solid black;padding: 5px'>"
-					+ saleReportTargetMap.get(fofoId).getTotalSale() + "</td>");
+					+ saleTargetReportModelMap.get(fofoId).getTotalSale() + "</td>");
-			sb.append("<td style='border:1px solid black;padding: 5px'>"
-					+ saleReportTargetMap.get(fofoId).getSmartphoneSale() + "</td>");
-			sb.append("<td style='border:1px solid black;padding: 5px'>"
-					+ saleReportTargetMap.get(fofoId).getSmartphoneQty() + "</td>");
 			sb.append("<td style='border:1px solid black;padding: 5px'>"
-					+ saleReportTargetMap.get(fofoId).getInsuranceSale() + "</td>");
+					+ saleTargetReportModelMap.get(fofoId).getSmartphoneSale() + "</td>");
 			sb.append("<td style='border:1px solid black;padding: 5px'>"
-					+ saleReportTargetMap.get(fofoId).getInsruanceQty() + "</td>");
+					+ saleTargetReportModelMap.get(fofoId).getSmartphoneQty() + "</td>");
 			sb.append("</tr>");
+		}
+		sb.append("</tr>");
-		sb.append("</tbody></table></body></html>");
+		sb.append("</body></html>");
-		return String.format(sb.toString(), REPORT_HEADERS);
+		return sb.toString();
+	}
-	private void sendMailOfHtmlFomat(String email, String body, String cc[], String subject)
+	private void sendMailOfHtmlFormat(String email, String body, String cc[], String subject)
 			throws MessagingException, ProfitMandiBusinessException, IOException {
 		MimeMessage message = mailSender.createMimeMessage();
 		MimeMessageHelper helper = new MimeMessageHelper(message);
 		helper.setSubject(subject);
 		helper.setText(body, true);
 					if (response.getStatusLine().getStatusCode() == 200) {
 						pushNotification.setSentTimestamp(LocalDateTime.now());
 					} else {
 						pushNotification.setSentTimestamp(LocalDateTime.of(1970, 1, 1, 00, 00));
 						LOGGER.info("message" + "not sent");
+						response.toString();
+					}
 				} catch (Exception e) {
 					e.printStackTrace();
 					pushNotification.setSentTimestamp(LocalDateTime.of(1970, 1, 1, 00, 00));
 				// check if pricedrop has been rolled out
 				List<UserWalletHistory> uwh = walletService.getAllByReference(inventoryItem.getFofoId(),
 						priceDropIMEI.getPriceDropId(), WalletReferenceType.PRICE_DROP);
 				if (uwh.size() > 0) {
 					Item item = itemRepository.selectById(inventoryItem.getItemId());
-					System.out.println(String.join("\t",
+					System.out.println(String.join("\t", Arrays.asList(priceDropIMEI.getImei(),
-							Arrays.asList(priceDropIMEI.getImei(), inventoryItem.getItemId() + "", item.getBrand(),
-									item.getModelName(), item.getModelNumber(), inventoryItem.getFofoId() + "",
+							inventoryItem.getItemId() + "", item.getBrand(), item.getModelName(), item.getModelNumber(),
-									customRetailer.getBusinessName(), inventoryItem.getCreateTimestamp().format(dtf),
+							inventoryItem.getFofoId() + "", customRetailer.getBusinessName(),
-									priceDrop.getAffectedOn().format(dtf),
+							inventoryItem.getCreateTimestamp().format(dtf), priceDrop.getAffectedOn().format(dtf),
-									priceDropIMEI.getUpdateTimestamp().format(dtf),
+							priceDropIMEI.getUpdateTimestamp().format(dtf),
-									inventoryItem.getUpdateTimestamp().format(dtf), priceDrop.getAutoPartnerPayout() + "",
+							inventoryItem.getUpdateTimestamp().format(dtf), priceDrop.getAutoPartnerPayout() + "",
-									inventoryItem.getLastScanType().equals(ScanType.DOA_OUT) + "")));
+							inventoryItem.getLastScanType().equals(ScanType.DOA_OUT) + "")));
+				}
+			}
+		}
+	}
 					FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(scanRecord.getOrderId());
 					String rollbackReason = "Scheme reversed for "
 							+ itemRepository.selectById(inventoryItem.getItemId()).getItemDescription() + "/Inv - "
 							+ fofoOrder.getInvoiceNumber();
 					walletService.rollbackAmountFromWallet(scanRecord.getFofoId(), sio.getAmount(),
-							scanRecord.getOrderId(), WalletReferenceType.SCHEME_OUT, rollbackReason, LocalDateTime.now());
+							scanRecord.getOrderId(), WalletReferenceType.SCHEME_OUT, rollbackReason,
+							LocalDateTime.now());
 					System.out.printf("Amount %f,SchemeId %d,Reason %s\n", sio.getAmount(), sio.getSchemeId(),
 							rollbackReason);
+				}
+			}
+		}
 			sendNotificationModel.setUserIds(Arrays.asList(authUserKeyMap.get(lead.getAssignTo())));
 			System.out.println(sendNotificationModel);
 			notificationService.sendNotification(sendNotificationModel);
+		}
+	}
 	public void notifyVisits() throws Exception {
-		List<FranchiseeVisit> franchiseeVisits = franchiseeVisitRepository.selectVisitsScheduledBetweenDate(LocalDateTime.now().minusDays(15),
+		List<FranchiseeVisit> franchiseeVisits = franchiseeVisitRepository
-				LocalDateTime.now().plusHours(4));
+				.selectVisitsScheduledBetweenDate(LocalDateTime.now().minusDays(15), LocalDateTime.now().plusHours(4));
 		Map<Integer, String> authUserEmailMap = authRepository.selectAllActiveUser().stream()
 				.collect(Collectors.toMap(x -> x.getId(), x -> x.getEmailId()));
 		Map<String, Integer> dtrEmailMap = dtrUserRepository
 				.selectAllByEmailIds(new ArrayList<>(authUserEmailMap.values())).stream()
 				.collect(Collectors.toMap(x -> x.getEmailId(), x -> x.getId()));
 		Map<Integer, Integer> authUserKeyMap = new HashMap<>();
 		for (Map.Entry<Integer, String> authUserEmail : authUserEmailMap.entrySet()) {
 			int authId = authUserEmail.getKey();
 			String email = authUserEmail.getValue();
 			authUserKeyMap.put(authId, dtrEmailMap.get(email));
+		}
 			if (authUserKeyMap.containsKey(visit.getAuthId())) {
 				continue;
+			}
 			SendNotificationModel sendNotificationModel = new SendNotificationModel();
 			String message = null;
-			if(visit.getFranchiseActivityId()==0) {
+			if (visit.getFranchiseActivityId() == 0) {
-				 message = String.format(visitTemplate, visit.getPartnerName(), timeFormatter.format(visit.getSchelduleTimestamp()));
+				message = String.format(visitTemplate, visit.getPartnerName(),
+						timeFormatter.format(visit.getSchelduleTimestamp()));
-				 sendNotificationModel.setCampaignName("Franchisee visit Reminder");
+				sendNotificationModel.setCampaignName("Franchisee visit Reminder");
 			} else {
-				message = String.format(followupTemplate, visit.getPartnerName(), timeFormatter.format(visit.getSchelduleTimestamp()));
+				message = String.format(followupTemplate, visit.getPartnerName(),
+						timeFormatter.format(visit.getSchelduleTimestamp()));
 				sendNotificationModel.setCampaignName("Franchisee followup Reminder");
+			}
 			sendNotificationModel.setMessage(message);
 			sendNotificationModel.setType("url");
 			sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/notifications");

Subversion Repositories SmartDukaan

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