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

 import com.spice.profitmandi.dao.entity.transaction.PriceDropIMEI;
 import com.spice.profitmandi.dao.entity.transaction.UserWallet;
 import com.spice.profitmandi.dao.entity.transaction.UserWalletHistory;
 import com.spice.profitmandi.dao.entity.user.Address;
 import com.spice.profitmandi.dao.entity.user.Device;
+import com.spice.profitmandi.dao.entity.user.FranchiseeVisit;
 import com.spice.profitmandi.dao.entity.user.Lead;
 import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;
 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
 import com.spice.profitmandi.dao.enumuration.transaction.PriceDropImeiStatus;
 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.FranchiseeActivityRepository;
+import com.spice.profitmandi.dao.repository.dtr.FranchiseeVisitRepository;
 import com.spice.profitmandi.dao.repository.dtr.InsurancePolicyRepository;
 import com.spice.profitmandi.dao.repository.dtr.LeadRepository;
 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.service.transaction.TransactionService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.service.wallet.WalletService;
 import in.shop2020.model.v1.order.OrderStatus;
-import in.shop2020.model.v1.order.WalletReferenceType;;
+import in.shop2020.model.v1.order.WalletReferenceType;
+import javassist.tools.framedump;;
 @Component
 @Transactional(rollbackFor = Throwable.class)
 public class ScheduledTasks {
 	@Autowired
 	private PartnerTypeChangeService partnerTypeChangeService;
 	@Autowired
 	private LeadRepository leadRepository;
 	@Autowired
 	private AuthRepository authRepository;
 	@Autowired
 	private PriceDropService priceDropService;
+	@Autowired
+	private FranchiseeVisitRepository franchiseeVisitRepository;
+	@Autowired
+	private FranchiseeActivityRepository franchiseeActivityRepository;
 	@Autowired
 	private CsService csService;
 	@Autowired
 	private InsurancePolicyRepository insurancePolicyRepository;
 	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 Object[] REPORT_HEADERS = {"Store Code", "Firm Name", "Store Name", "State Manager", "Teritory Manager"};
+	private Object[] REPORT_HEADERS = { "Store Code", "Firm Name", "Store Name", "State Manager", "Teritory Manager" };
 	@Autowired
 	private ReporticoService reporticoService;
 	@Autowired
 	@Autowired
 	private UserAccountRepository userAccountRepository;
 	@Autowired
-	private UserRepository userRepository;
+	private UserRepository userUserRepository;
+	@Autowired
+	private com.spice.profitmandi.dao.repository.dtr.UserRepository dtrUserRepository;
 	@Autowired
 	private UserCampaignRepository userCampaignRepository;
 	@Autowired
 			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());
+			row.addAll(
- 			row.addAll(Arrays.asList(partnerDailyInvestment.getWalletAmount(), partnerDailyInvestment.getInStockAmount(), 0,
+					Arrays.asList(partnerDailyInvestment.getWalletAmount(), partnerDailyInvestment.getInStockAmount(),
-					partnerDailyInvestment.getUnbilledAmount(), partnerDailyInvestment.getGrnPendingAmount(),
+, partnerDailyInvestment.getUnbilledAmount(), partnerDailyInvestment.getGrnPendingAmount(),
-					partnerDailyInvestment.getMinInvestment(), partnerDailyInvestment.getTotalInvestment(),
+							partnerDailyInvestment.getMinInvestment(), partnerDailyInvestment.getTotalInvestment(),
-					partnerDailyInvestment.getShortInvestment(), partnerDailyInvestment.getUnbilledQty()));
+							partnerDailyInvestment.getShortInvestment(), partnerDailyInvestment.getUnbilledQty()));
 			partnerRowsMap.put(fofoStore.getId(), row);
 			rows.add(row);
+		}
 		String fileName = "InvestmentSummary-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
-		if(sendTo==null) {
+		if (sendTo == null) {
 			for (Map.Entry<String, Set<Integer>> storeGuyEntry : csService.getAuthUserPartnerIdMapping().entrySet()) {
 				List<List<?>> filteredRows = storeGuyEntry.getValue().stream().map(x -> partnerRowsMap.get(x))
 						.filter(x -> x != null).collect(Collectors.toList());
 				ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, filteredRows);
 				String[] sendToArray = new String[] { storeGuyEntry.getKey() };
 						fileName, new ByteArrayResource(baos.toByteArray()));
+			}
 			sendTo = Arrays.asList("tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com",
 					"prakash.rai@smartdukaan.com", "amit.gupta@shop2020.in", "amod.sen@smartdukaan.com");
+		}
 		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
 		String[] sendToArray = sendTo.toArray(new String[sendTo.size()]);
 		Utils.sendMailWithAttachment(googleMailSender, sendToArray, null, "Franchise Investment Summary", "PFA",
 				fileName, new ByteArrayResource(baos.toByteArray()));
 		Map<Integer, List<Serializable>> partnerIdSalesHeadersMap = new HashMap<>();
 		for (CustomRetailer cr : allCrList) {
 			FofoStore fofoStore = fofoStoresMap.get(cr.getPartnerId());
-			if(fofoStore==null) {
+			if (fofoStore == null) {
 				LOGGER.info("Could not find Store {} in active Store", cr.getBusinessName());
 				continue;
+			}
 			String code = fofoStore.getCode() + "";
 			String storeName = "SmartDukaan-" + fofoStore.getCode().replaceAll("[a-zA-Z]", "");
 		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<?>> storeGuyRows = storeGuyEntry.getValue().stream().filter(x -> partnerRowMap.containsKey(x)).map(x -> partnerRowMap.get(x))
+			List<List<?>> storeGuyRows = storeGuyEntry.getValue().stream().filter(x -> partnerRowMap.containsKey(x))
-					.collect(Collectors.toList());
+					.map(x -> partnerRowMap.get(x)).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);
+	}
 	public void sendDailySalesNotificationToPartner(Integer fofoIdInt)
 			throws ProfitMandiBusinessException, MessagingException, IOException {
 		LocalDateTime now = LocalDateTime.now();
 		LocalDateTime from = now.with(LocalTime.MIN);
 		String timeString = "Today %s";
-		//Send yesterday's report
+		// Send yesterday's report
-		if(now.getHour() < 13) {
+		if (now.getHour() < 13) {
 			timeString = "Yesterday %s";
 			from = now.minusDays(1);
 			now = from.with(LocalTime.MAX);
+		}
 		List<Integer> fofoIds = null;
 		if (fofoIdInt == null) {
 			fofoIds = fofoStoreRepository.selectAll().stream().filter(x -> x.isActive()).map(x -> x.getId())
 					.collect(Collectors.toList());
 , 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(
-			model.setInsuranceSale(partnerPolicyAmountMap.containsKey(fofoId) ? partnerPolicyAmountMap.get(fofoId).doubleValue() : 0);
+					partnerPolicyAmountMap.containsKey(fofoId) ? partnerPolicyAmountMap.get(fofoId).doubleValue() : 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);
 			model.setFofoId(fofoId);
 		for (Integer fofoId : fofoIds) {
 			SaleTargetReportModel model = saleTargetReportModelMap.get(fofoId);
 			SendNotificationModel sendNotificationModel = new SendNotificationModel();
 			sendNotificationModel.setCampaignName("Sales update alert");
 			sendNotificationModel.setTitle("Sale Update");
-			sendNotificationModel.setMessage(String.format(
+			sendNotificationModel
-					"Smartphones Rs.%.0f, Insurance Rs.%.0f, Total Rs.%.0f till %s.", model.getSmartphoneSale(),
+					.setMessage(String.format("Smartphones Rs.%.0f, Insurance Rs.%.0f, Total Rs.%.0f till %s.",
+							model.getSmartphoneSale(), model.getInsuranceSale(), model.getTotalSale(),
-					model.getInsuranceSale(), model.getTotalSale(), String.format(timeString, now.format(timeFormatter))));
+							String.format(timeString, 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);
 			int userId = userAccountRepository.selectUserIdByRetailerId(fofoId);
 				+ "	    					<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>");
 		List<Integer> sortedPartnerSalesHeaders = partnerSalesHeadersMap.entrySet().stream()
 				.sorted((x, y) -> ((String) (x.getValue().get(3))).compareTo((String) (y.getValue().get(3))))
-				.map(x->x.getKey()).collect(Collectors.toList());
+				.map(x -> x.getKey()).collect(Collectors.toList());
-		for (Integer fofoId : sortedPartnerSalesHeaders)
+		for (Integer fofoId : sortedPartnerSalesHeaders) {
-		{
 			sb.append("<tr>");
 			sb.append("<td style='border:1px solid black;padding: 5px'>" + partnerSalesHeadersMap.get(fofoId).get(0)
 					+ "</td>");
 			sb.append("<td style='border:1px solid black;padding: 5px'>" + partnerSalesHeadersMap.get(fofoId).get(1)
 					+ "</td>");
 		sb.append("</tbody></table></body></html>");
 		return sb.toString();
+	}
-	public void notifyLead() throws Exception{
+	public void notifyLead() throws Exception {
-		List<Lead> leadsToNotify = leadRepository.selectLeadsScheduledBetweenDate(LocalDateTime.now().minusDays(15), LocalDateTime.now().plusHours(2));
+		List<Lead> leadsToNotify = leadRepository.selectLeadsScheduledBetweenDate(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));
+		}
+		String templateMessage = "Lead followup for %s %s, %s is due by %s";
+		DateTimeFormatter timeFormatter = DateTimeFormatter.ofPattern("h:m a");
+		for (Lead lead : leadsToNotify) {
+			if (authUserKeyMap.get(lead.getAuthId()) == null) {
+				continue;
+			}
+			String notificationMessage = String.format(templateMessage, lead.getFirstName(), lead.getLastName(),
+					lead.getAddress(), String.format(templateMessage,
+							timeFormatter.format(lead.getLeadActivity().getSchelduleTimestamp())));
+			SendNotificationModel sendNotificationModel = new SendNotificationModel();
+			sendNotificationModel.setCampaignName("Lead Reminder");
+			sendNotificationModel.setTitle("Leads followup Reminder");
+			sendNotificationModel.setMessage(notificationMessage);
+			sendNotificationModel.setType("url");
+			sendNotificationModel.setUrl("http://app.profitmandi.com/pages/home/notifications");
+			sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(2));
+			sendNotificationModel.setMessageType(MessageType.reminder);
+			sendNotificationModel.setUserIds(Arrays.asList(authUserKeyMap.get(lead.getAuthId())));
+			notificationService.sendNotification(sendNotificationModel);
+		}
+	}
+	public void notifyVisits() throws Exception {
+		List<FranchiseeVisit> franchiseeVisits = franchiseeVisitRepository.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 notificationMessage = "";
+			String email = authUserEmail.getValue();
+			authUserKeyMap.put(authId, dtrEmailMap.get(email));
+		}
+		String visitTemplate = "Planned visit to franchisee %s is due by %s";
+		String followupTemplate = "Lead followup for franchisee %s is due by %s";
+		DateTimeFormatter timeFormatter = DateTimeFormatter.ofPattern("MMM 7, EEEE h:m a");
+		for (FranchiseeVisit visit : franchiseeVisits) {
+			if (authUserKeyMap.containsKey(visit.getAuthId())) {
+				continue;
+			}
-		SendNotificationModel sendNotificationModel = new SendNotificationModel();
+			SendNotificationModel sendNotificationModel = new SendNotificationModel();
+			String message = null;
+			if(visit.getFranchiseActivityId()==0) {
+				 message = String.format(visitTemplate, visit.getPartnerName(), timeFormatter.format(visit.getSchelduleTimestamp()));
-		sendNotificationModel.setCampaignName("Stock Alert");
+				 sendNotificationModel.setCampaignName("Franchisee visit Reminder");
+			} else {
+				message = String.format(followupTemplate, visit.getPartnerName(), timeFormatter.format(visit.getSchelduleTimestamp()));
-		sendNotificationModel.setTitle("Alert");
+				sendNotificationModel.setCampaignName("Franchisee followup Reminder");
+			}
-		sendNotificationModel.setMessage(notificationMessage);
+			sendNotificationModel.setMessage(message);
-		sendNotificationModel.setType("url");
+			sendNotificationModel.setType("url");
-		sendNotificationModel.setUrl("http://app.profitmandi.com/pages/home/notifications");
+			sendNotificationModel.setUrl("http://app.profitmandi.com/pages/home/notifications");
-		sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(2));
+			sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(2));
-		sendNotificationModel.setMessageType(MessageType.reminder);
+			sendNotificationModel.setMessageType(MessageType.reminder);
-		int userId = userAccountRepository.selectUserIdByRetailerId(0);
-		sendNotificationModel.setUserIds(Arrays.asList(userId));
+			sendNotificationModel.setUserIds(Arrays.asList(authUserKeyMap.get(visit.getAuthId())));
-		notificationService.sendNotification(sendNotificationModel);
+			notificationService.sendNotification(sendNotificationModel);
+		}
+	}
+}

Subversion Repositories SmartDukaan

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