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

 	private static final String[] ITEMWISE_PENDING_INDENT_MAIL_LIST = new String[] { "kamini.sharma@smartdukaan.com",
 			"prakash.rai@smartdukaan.com", "tarun.verma@smartdukaan.com", "chaitnaya.vats@smartdukaan.com",
 			"kuldeep.kumar@smartdukaan.com" };
 	private List<OrderStatus> orderStatusList = Arrays.asList(OrderStatus.SUBMITTED_FOR_PROCESSING);
+	private List<String> REPORT_HEADERS = Arrays.asList("Store Code", "Firm Name", "Store Name", "State Manager", "Teritory Manager");
 	@Autowired
 	private ReporticoService reporticoService;
 	@Autowired
 	@Autowired
 	private PositionRepository positionRepository;
 	@Autowired
 	private FofoOrderItemRepository fofoOrderItemRepository;
 	@Autowired
 	private NotificationService notificationService;
 	@Autowired
 	private PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
 		Map<Integer, List<Serializable>> partnerIdSalesHeadersMap = new HashMap<>();
 		for (CustomRetailer cr : allCrList) {
 			FofoStore fofoStore = fofoStoresMap.get(cr.getPartnerId());
-			String code = fofoStore.getCode();
+			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(), ", ");
 	public void sendDailySalesNotificationToPartner(Integer fofoIdInt)
 			throws ProfitMandiBusinessException, MessagingException, IOException {
 		LocalDateTime now = LocalDateTime.now();
 		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);
+		}
 		DateTimeFormatter timeFormatter = DateTimeFormatter.ofPattern("h a");
-		Map<Integer, Float> dailyTarget = new HashMap<>();
+		Map<Integer, Double> salesByFofoIdMap = new HashMap<>();
+		Map<Integer, Float> partnerPolicyAmountMap = insurancePolicyRepository.selectAmountSumGroupByRetailerId(now,
+				null);
+		Map<Integer, Long> partnerPolicyQtyMap = insurancePolicyRepository.selectQtyGroupByRetailerId(now, null);
+		Map<Integer, Double> partnerOrderAmountMap = fofoOrderItemRepository.selectSumAmountGroupByRetailer(from, now,
+, true);
+		Map<Integer, Long> partnerOrderQtyMap = fofoOrderItemRepository.selectQtyGroupByRetailer(from, now, 0, true);
+		Map<Integer, SaleTargetReportModel> saleTargetReportModelMap = new HashMap<>();
+		for (int fofoId : fofoIds) {
+			SaleTargetReportModel model = new SaleTargetReportModel();
+			model.setInsuranceSale(partnerPolicyAmountMap.containsKey(fofoId) ? partnerPolicyAmountMap.get(fofoId) : 0);
+			model.setInsruanceQty(partnerPolicyQtyMap.containsKey(fofoId) ? partnerPolicyQtyMap.get(fofoId) : 0);
+			model.setSmartphoneSale(partnerOrderAmountMap.containsKey(fofoId) ? partnerOrderAmountMap.get(fofoId) : 0);
+			model.setSmartphoneQty(partnerOrderQtyMap.containsKey(fofoId) ? partnerOrderQtyMap.get(fofoId) : 0);
+			model.setTotalSale(salesByFofoIdMap.containsKey(fofoId) ? salesByFofoIdMap.get(fofoId) : 0);
+			saleTargetReportModelMap.put(fofoId, model);
+		}
+		Map<Integer, List<Serializable>> partnerSalesHeadersMap = this.getPartnerIdSalesHeaders();
 		for (Integer fofoId : fofoIds) {
-			double sale = fofoOrderRepository.selectTotalSaleSumByFofoIdBetweenDate(fofoId, from, now);
+			SaleTargetReportModel model = saleTargetReportModelMap.get(fofoId);
 			SendNotificationModel sendNotificationModel = new SendNotificationModel();
 			sendNotificationModel.setCampaignName("Sales update alert");
 			sendNotificationModel.setMessage(String.format(
-					"Smartphones Rs.%.0f, Insurance Rs.%.0f, Total Rs.%.0f till %s.", sale, now.format(timeFormatter)));
+					"Smartphones Rs.%.0f, Insurance Rs.%.0f, Total Rs.%.0f till %s.", model.getSmartphoneSale(),
+					model.getInsuranceSale(), model.getTotalSale(), 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);
+			sendNotificationModel.setUserIds(Arrays.asList(fofoId));
 			notificationService.sendNotification(sendNotificationModel);
-			salesByFofoIdMap.put(fofoId, sale);
-			LOGGER.info(sale);
+		}
-		Map<Integer, Float> parternPolicyAmountMap = insurancePolicyRepository.selectAmountSumGroupByRetailerId(now,
-				null);
-		Map<Integer, Long> parternPolicyQtyMap = insurancePolicyRepository.selectQtyGroupByRetailerId(now, null);
-		Map<Integer, Long> parternOrderQtyMap = insurancePolicyRepository.selectQtyGroupByRetailerId(now, null);
-		String saleReport = this.getDailySalesReportByPartnerId(salesByFofoIdMap, dailyTarget);
+		String saleReport = this.getDailySalesReportHtml(partnerSalesHeadersMap, saleTargetReportModelMap);
 		LOGGER.info(saleReport);
 		String cc[] = { "tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com", "prakash.rai@smartdukaan.com",
 				"chaitnaya.vats@smartdukaan.com" };
 		String subject = String.format("Sale till %s", now.format(timeFormatter));
 		this.sendMailOfHtmlFomat("amit.gupta@shop2020.in", saleReport, cc, subject);
+	}
+	public static class SaleTargetReportModel {
+		private double totalSale;
+		private double smartphoneSale;
+		private long smartphoneQty;
+		private double insuranceSale;
+		private long insruanceQty;
+		@Override
+		public int hashCode() {
+			final int prime = 31;
+			int result = 1;
+			result = prime * result + (int) (insruanceQty ^ (insruanceQty >>> 32));
+			long temp;
+			temp = Double.doubleToLongBits(insuranceSale);
+			result = prime * result + (int) (temp ^ (temp >>> 32));
+			result = prime * result + (int) (smartphoneQty ^ (smartphoneQty >>> 32));
+			temp = Double.doubleToLongBits(smartphoneSale);
+			result = prime * result + (int) (temp ^ (temp >>> 32));
+			temp = Double.doubleToLongBits(totalSale);
+			result = prime * result + (int) (temp ^ (temp >>> 32));
+			return result;
+		}
+		@Override
+		public boolean equals(Object obj) {
+			if (this == obj)
+				return true;
+			if (obj == null)
+				return false;
+			if (getClass() != obj.getClass())
+				return false;
+			SaleTargetReportModel other = (SaleTargetReportModel) obj;
+			if (insruanceQty != other.insruanceQty)
+				return false;
+			if (Double.doubleToLongBits(insuranceSale) != Double.doubleToLongBits(other.insuranceSale))
+				return false;
+			if (smartphoneQty != other.smartphoneQty)
+				return false;
+			if (Double.doubleToLongBits(smartphoneSale) != Double.doubleToLongBits(other.smartphoneSale))
+				return false;
+			if (Double.doubleToLongBits(totalSale) != Double.doubleToLongBits(other.totalSale))
+				return false;
+			return true;
+		}
+		public double getTotalSale() {
+			return totalSale;
+		}
+		public void setTotalSale(double totalSale) {
+			this.totalSale = totalSale;
+		}
+		public double getSmartphoneSale() {
+			return smartphoneSale;
+		}
+		public void setSmartphoneSale(double smartphoneSale) {
+			this.smartphoneSale = smartphoneSale;
+		}
+		public long getSmartphoneQty() {
+			return smartphoneQty;
+		}
+		public void setSmartphoneQty(long smartphoneQty) {
+			this.smartphoneQty = smartphoneQty;
+		}
+		public double getInsuranceSale() {
+			return insuranceSale;
+		}
+		public void setInsuranceSale(double insuranceSale) {
+			this.insuranceSale = insuranceSale;
+		}
+		public long getInsruanceQty() {
+			return insruanceQty;
+		}
+		public void setInsruanceQty(long insruanceQty) {
+			this.insruanceQty = insruanceQty;
+		}
+		@Override
+		public String toString() {
+			return "SaleTargetReportModel [totalSale=" + totalSale + ", smartphoneSale=" + smartphoneSale
+					+ ", smartphoneQty=" + smartphoneQty + ", insuranceSale=" + insuranceSale + ", insruanceQty="
+					+ insruanceQty + "]";
+		}
+	}
-	private String getDailySalesReportByPartnerId(Map<Integer, Double> salesByFofoIdMap,
+	private String getDailySalesReportHtml(Map<Integer, List<Serializable>> partnerSalesHeadersMap,
+			Map<Integer, SaleTargetReportModel> saleReportTargetMap)
-			Map<Integer, Float> dailyTarget) throws ProfitMandiBusinessException {
+			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'>%s</th>\n"
-				+ "	    					<th style='border:1px solid black;padding: 5px'>Partner</th>\n"
+				+ "	    					<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'>%s</th>\n"
-				+ "	    					<th style='border:1px solid black;padding: 5px'>Daily Target</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>%s</th>\n"
 				+ "	    					<th style='border:1px solid black;padding: 5px'>Sale</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Smartphone Sale</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>SmartPhone Qty</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Insurance Sale</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Insurance Qty</th>\n"
 				+ "	    				</tr>");
-		for (Integer fofoId : salesByFofoIdMap.keySet()) {
+		for (Integer fofoId : saleReportTargetMap.keySet()) {
-			try {
-				String PartnerName = retailerService.getFofoRetailer(fofoId).getBusinessName();
-				sb.append("<tr>");
+			sb.append("<tr>");
-				sb.append("<td style='border:1px solid black;padding: 5px'>" + PartnerName + "</td>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + partnerSalesHeadersMap.get(fofoId).get(0) + "</td>");
-				if (dailyTarget != null && dailyTarget.get(fofoId) != null) {
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + partnerSalesHeadersMap.get(fofoId).get(1) + "</td>");
-					sb.append("<td style='border:1px solid black;padding: 5px'>" + dailyTarget.get(fofoId) + "</td>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + partnerSalesHeadersMap.get(fofoId).get(2) + "</td>");
-				} else {
-					sb.append("<td style='border:1px solid black;padding: 5px'>" + 0.0 + "</td>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + partnerSalesHeadersMap.get(fofoId).get(3) + "</td>");
-				}
-				sb.append("<td style='border:1px solid black;padding: 5px'>" + salesByFofoIdMap.get(fofoId) + "</td>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + partnerSalesHeadersMap.get(fofoId).get(4) + "</td>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + saleReportTargetMap.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>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + saleReportTargetMap.get(fofoId).getInsruanceQty() + "</td>");
-				sb.append("</tr>");
+			sb.append("</tr>");
-			} catch (Exception e) {
-				e.printStackTrace();
-			}
+		}
 		sb.append("</tbody></table></body></html>");
-		return sb.toString();
+		return String.format(sb.toString(), REPORT_HEADERS);
+	}
 	private void sendMailOfHtmlFomat(String email, String body, String cc[], String subject)
 			throws MessagingException, ProfitMandiBusinessException, IOException {
 		MimeMessage message = mailSender.createMimeMessage();

Subversion Repositories SmartDukaan

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