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

+		}
 		Map<Integer, FofoReportingModel> partnerSalesHeadersMap = this.getPartnerIdSalesHeaders();
 		for (Integer fofoId : fofoIds) {
 			SaleTargetReportModel model = saleTargetReportModelMap.get(fofoId);
+			com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectById(fofoId);
+			Address address = addressRepository.selectById(user.getAddressId());
+			String title = "Sale Update";
+			String messageTemplate = String.format("Smartphones Rs.%.0f, Insurance Rs.%.0f, Total Rs.%.0f till %s.",
+					model.getSmartphoneSale(), model.getInsuranceSale(), model.getTotalSale(),
+					String.format(timeString, now.format(timeFormatter)));
 			SendNotificationModel sendNotificationModel = new SendNotificationModel();
 			sendNotificationModel.setCampaignName("Sales update alert");
-			sendNotificationModel.setTitle("Sale Update");
+			sendNotificationModel.setTitle(title);
-			sendNotificationModel
+			sendNotificationModel.setMessage(messageTemplate);
-					.setMessage(String.format("Smartphones Rs.%.0f, Insurance Rs.%.0f, Total Rs.%.0f till %s.",
-							model.getSmartphoneSale(), model.getInsuranceSale(), model.getTotalSale(),
-							String.format(timeString, now.format(timeFormatter))));
 			sendNotificationModel.setType("url");
 			sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/notifications");
 			sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));
 			sendNotificationModel.setMessageType(MessageType.notification);
 			int userId = userAccountRepository.selectUserIdByRetailerId(fofoId);
 			sendNotificationModel.setUserIds(Arrays.asList(userId));
 			notificationService.sendNotification(sendNotificationModel);
+			//notificationService.sendWhatsappMessage(messageTemplate, title, address.getPhoneNumber());
+		}
 		// String saleReport = this.getDailySalesReportHtml(partnerSalesHeadersMap,
 		// saleTargetReportModelMap);
 		String statewiseSaleReport = this.getStateWiseSales(saleTargetReportModelMap, partnerSalesHeadersMap);
 		String cc[] = { "tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com", "niranjan.kala@smartdukaan.com",
 		for (Lead lead : leadsToNotify) {
 			if (authUserKeyMap.get(lead.getAssignTo()) == null) {
 				LOGGER.info("Assignee no longer part of system {}", lead.getAssignTo());
 				continue;
+			}
+			String title = "Leads followup Reminder";
 			String notificationMessage = String.format(templateMessage, lead.getFirstName(), lead.getLastName(),
 					lead.getAddress(), lead.getLeadMobile(), leadTimeFormatter.format(lead.getScheduledTimestamp()));
+			String url = "https://app.smartdukaan.com/pages/home/leadUpdate?leadId=" + lead.getId();
 			SendNotificationModel sendNotificationModel = new SendNotificationModel();
 			sendNotificationModel.setCampaignName("Lead Reminder");
-			sendNotificationModel.setTitle("Leads followup Reminder");
+			sendNotificationModel.setTitle(title);
 			sendNotificationModel.setMessage(notificationMessage);
 			sendNotificationModel.setType("url");
-			sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/leadUpdate?leadId=" + lead.getId());
+			sendNotificationModel.setUrl(url);
 			sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(2));
 			sendNotificationModel.setMessageType(MessageType.reminder);
 			sendNotificationModel.setUserIds(Arrays.asList(authUserKeyMap.get(lead.getAssignTo())));
 			System.out.println(sendNotificationModel);
 			notificationService.sendNotification(sendNotificationModel);
+			AuthUser authUser = authRepository.selectById(lead.getAssignTo());
+			// notificationService.sendWhatsappMessage(notificationMessage, title, authUser.getMobileNumber());
+		}
+	}
 	public void notifyVisits() throws Exception {
 		List<FranchiseeVisit> franchiseeVisits = franchiseeVisitRepository
 						dlo.setStatus(OrderStatus.DELIVERY_SUCCESS);
 						dlo.setStatusDescription("Order Delivered");
 						dlo.setDeliveryTimestamp(LocalDateTime.now());
+					}
+					com.spice.profitmandi.dao.entity.user.User user = userUserRepository
+							.selectById(orders.get(0).getRetailerId());
+					Address address = addressRepository.selectById(user.getAddressId());
+					String title = "Order Delivered";
+					String message = String.format("Dear partner, our SmartDukaan Order " + aws
+							+ " has been delivered to you in a safe sealed bag.");
 					SendNotificationModel sendNotificationModel = new SendNotificationModel();
 					sendNotificationModel.setCampaignName("Order Delivered");
-					sendNotificationModel.setTitle("Order Delivered");
+					sendNotificationModel.setTitle(title);
-					sendNotificationModel.setMessage(String.format("Dear partner, your SmartDukaan Order " + aws
+					sendNotificationModel.setMessage(message);
-							+ "has been delivered to you in a safe sealed bag" + "."));
 					sendNotificationModel.setType("url");
 					sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/notifications");
 					sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));
 					sendNotificationModel.setMessageType(MessageType.notification);
 					int userId = userAccountRepository.selectUserIdByRetailerId(orders.get(0).getRetailerId());
 					sendNotificationModel.setUserIds(Arrays.asList(userId));
 					notificationService.sendNotification(sendNotificationModel);
+					//notificationService.sendWhatsappMessage(message, title, address.getPhoneNumber());
+				}
+			}
+		}
+	}
 				String url = "http://app.smartdukaan.com/pages/home/credit";
 				String message = "Your total pending Loan amount is Rs. "
 						+ FormattingUtils.formatDecimal(Math.abs(partnerLoanAmountEnrty.getValue()));
 				notificationService.sendNotification(fofoId, title, MessageType.notification, title, message, url);
-				// notificationService.sendWhatsappMessage(message, title,
+				//notificationService.sendWhatsappMessage(message, title, address.getPhoneNumber());
-				// address.getPhoneNumber());
+			}
+		}
 			List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(defaultLoan.getId());
 			double amount = loanStatements.stream().map(x -> x.getAmount())
 					.collect(Collectors.summingDouble(x -> x.doubleValue()));
+			com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectById(defaultLoan.getFofoId());
+			Address address = addressRepository.selectById(user.getAddressId());
 			String title = "Loan amount overdue!";
 			String url = "http://app.smartdukaan.com/pages/home/credit";
 			String message = "Your loan due date ("
 					+ defaultLoan.getDueDate().toLocalDate().format(DateTimeFormatter.ofPattern("dd-MM-yyyy"))
 					+ ") has been exceeded. Additional penal interest of " + defaultLoan.getInterestRate()
 					+ "%  + and Rs.100 shall be levied on daily basis. " + "Your total pending Loan amount is Rs."
 					+ FormattingUtils.formatDecimal(Math.abs(amount)) + ". !!Pay Now!!";
 			notificationService.sendNotification(defaultLoan.getFofoId(), title, MessageType.notification, title,
 					message, url);
+			//notificationService.sendWhatsappMessage(message, title, address.getPhoneNumber());
+		}
+	}
 	private String getMessageForDueDateExtend(List<Loan> loans) throws ProfitMandiBusinessException {
 		StringBuilder sb = new StringBuilder();
 		if (!loans.isEmpty()) {
 			for (Loan loan : loans) {
 				long noOfdaysBetween = ChronoUnit.DAYS.between(loan.getDueDate().toLocalDate(), LocalDate.now());
+				com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectById(loan.getFofoId());
+				Address address = addressRepository.selectById(user.getAddressId());
 				LOGGER.info("noOfdaysBetween {} ", noOfdaysBetween);
 				if (noOfdaysBetween <= 15 && noOfdaysBetween >= 0) {
 					List<LoanStatement> loanStatements = loanStatementRepository.selectByLoanId(loan.getId());
 					double amount = loanStatements.stream().map(x -> x.getAmount())
 							.collect(Collectors.summingDouble(x -> x.doubleValue()));
-					String title = "Alert! Credit o/s";
+					String title = "Alert!";
 					String url = "http://app.smartdukaan.com/pages/home/credit";
 					String message = "Your loan due date ("
 							+ loan.getDueDate().toLocalDate().format(DateTimeFormatter.ofPattern("dd-MM-yyyy"))
 							+ ") has been exceeded. Additional penal interest of " + loan.getInterestRate()
 							+ "% shall be levied on daily basis. Your total pending Loan amount is Rs."
 							+ FormattingUtils.formatDecimal(Math.abs(amount)) + ". !!Pay Now!!";
 					notificationService.sendNotification(loan.getFofoId(), title, MessageType.notification, title,
 							message, url);
+					//notificationService.sendWhatsappMessage(message, title, address.getPhoneNumber());
+				}
+			}
+		}
+	}
 		List<Loan> loans = loanRepository.selectAllActiveLoan();
 		if (!loans.isEmpty()) {
 			for (Loan loan : loans) {
+				com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectById(loan.getFofoId());
+				Address address = addressRepository.selectById(user.getAddressId());
 				long noOfdaysBetween = ChronoUnit.DAYS.between(LocalDate.now(), loan.getDueDate().toLocalDate());
 				LOGGER.info("noOfdaysBetween {} ", noOfdaysBetween);
 				if (noOfdaysBetween <= 4 && noOfdaysBetween >= 0) {
 								+ ", Pay Now!!";
+					}
 					notificationService.sendNotification(loan.getFofoId(), title, MessageType.notification, title,
 							message, url);
+					//notificationService.sendWhatsappMessage(message, title, address.getPhoneNumber());
+				}
+			}
+		}
+	}
+	public void userMobileNumberOptIn() throws HttpHostConnectException, ProfitMandiBusinessException {
+		List<FofoStore> fofoStores = fofoStoreRepository.selectActiveStores();
+		List<com.spice.profitmandi.dao.entity.user.User> users = userUserRepository
+				.selectByIds(fofoStores.stream().map(x -> x.getId()).collect(Collectors.toList()));
+		List<Address> addresses = addressRepository
+				.selectByIds(users.stream().map(x -> x.getAddressId()).collect(Collectors.toList()));
+		for (Address address : addresses) {
+			Map<String, String> requestheaders = new HashMap<>();
+			requestheaders.put("Content-Type", "application/x-www-form-urlencoded");
+			Map<String, String> requestParams = new HashMap<>();
+			requestParams.put("userid", String.valueOf(2000215976));
+			requestParams.put("password", "MFRd!BBL");
+			requestParams.put("send_to", address.getPhoneNumber());
+			requestParams.put("auth_scheme", "plain");
+			requestParams.put("v", "1.1");
+			requestParams.put("format", "");
+			requestParams.put("method", "OPT_IN");
+			requestParams.put("channel", "WHATSAPP");
+			String response = restClient.get("https://media.smsgupshup.com/GatewayAPI/rest", requestParams,
+					requestheaders);
+			LOGGER.info("response" + response);
+		}
+	}
+	public void authUserMobileNumberOptIn() throws HttpHostConnectException, ProfitMandiBusinessException {
+		List<AuthUser> authUsers = authRepository.selectAllActiveUser();
+		for (AuthUser authUser : authUsers) {
+			Map<String, String> requestheaders = new HashMap<>();
+			requestheaders.put("Content-Type", "application/x-www-form-urlencoded");
+			Map<String, String> requestParams = new HashMap<>();
+			requestParams.put("userid", String.valueOf(2000215976));
+			requestParams.put("password", "MFRd!BBL");
+			requestParams.put("send_to", authUser.getMobileNumber());
+			requestParams.put("auth_scheme", "plain");
+			requestParams.put("v", "1.1");
+			requestParams.put("format", "");
+			requestParams.put("method", "OPT_IN");
+			requestParams.put("channel", "WHATSAPP");
+			String response = restClient.get("https://media.smsgupshup.com/GatewayAPI/rest", requestParams,
+					requestheaders);
+			LOGGER.info("response" + response);
+		}
+	}
+}
 //2284

Subversion Repositories SmartDukaan

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