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

 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.entity.user.Refferal;
 import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;
 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
+import com.spice.profitmandi.dao.enumuration.dtr.RefferalStatus;
 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
 import com.spice.profitmandi.dao.enumuration.transaction.PriceDropImeiStatus;
 import com.spice.profitmandi.dao.model.AddPaymentRequest;
 import com.spice.profitmandi.dao.model.AddPaymentResponse;
 import com.spice.profitmandi.dao.model.SimpleCampaign;
 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;
 import com.spice.profitmandi.dao.repository.dtr.RechargeTransactionRepository;
+import com.spice.profitmandi.dao.repository.dtr.RefferalRepository;
 import com.spice.profitmandi.dao.repository.dtr.RetailerRegisteredAddressRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserCampaignRepository;
 import com.spice.profitmandi.dao.repository.fofo.ActivatedImeiRepository;
 import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
 	@Autowired
 	private PriceDropService priceDropService;
 	@Autowired
 	private FranchiseeVisitRepository franchiseeVisitRepository;
 	@Autowired
 	private FranchiseeActivityRepository franchiseeActivityRepository;
 	@Autowired
 	private HdfcPaymentRepository hdfcPaymentRepository;
 	@Autowired
 	private CsService csService;
 	@Autowired
 	private InsurancePolicyRepository insurancePolicyRepository;
 	private Gson gson;
 	@Autowired
 	private TicketRepository ticketRepository;
+	@Autowired
+	private RefferalRepository refferalRepository;
 	private static final Logger LOGGER = LogManager.getLogger(ScheduledTasks.class);
 	private String FCM_URL = "https://fcm.googleapis.com/fcm/send";
 	private String FCM_API_KEY = "AAAASAjNcn4:APA91bG6fWRIgYJI0L9gCjP5ynaXz2hJHYKtD9dfH7Depdv31Nd9APJwhx-OPkAJ1WSz4BGNYG8lHThLFSjDGFxIwUZv241YcAJEGDLgt86mxq9FXJe-yBRu-S0_ZwHqmX-QaVKl5F_A";
 		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, 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());
 				continue;
+			}
 			List<Serializable> row = partnerIdSalesHeaderMap.get(fofoStore.getId());
 			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);
+		}
 				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);
 				// 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);
+				}
+			}
+		}
 		Map<String, Integer> dtrEmailMap = dtrUserRepository
 				.selectAllByEmailIds(new ArrayList<>(authUserEmailMap.values())).stream()
 				.collect(Collectors.toMap(x -> x.getEmailId(), x -> x.getId()));
 		System.out.printf("dtrEmailMap - %s", dtrEmailMap);
 		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));
+		}
 		System.out.println(authUserKeyMap);
 		System.out.println(leadsToNotify);
 		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;
 			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");
+			}
+		}
+	}
+	public void checkValidateReferral() throws Exception {
+		List<Refferal> referrals = refferalRepository.selectByStatus(RefferalStatus.pending);
+		if (!referrals.isEmpty()) {
+			String subject = "Referral Request";
+			String messageText = this.getMessageForReferral(referrals);
+			this.sendMailWithAttachments(subject, messageText, "tejbeer.kaur@shop2020.in");
+		}
+	}
+	private String getMessageForReferral(List<Refferal> referrals) {
+		StringBuilder sb = new StringBuilder();
+		sb.append("<html><body><p>Alert</p><p>Pending Referrals:-</p>"
+				+ "<br/><table style='border:1px solid black ;padding: 5px';>");
+		sb.append("<tbody>\n" + "	    				<tr>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>RefereeName</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Referee Email</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Referral Name</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Refferal Mobile</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>city</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>state</th>\n"
+				+ "	    				</tr>");
+		for (Refferal entry : referrals) {
+			sb.append("<tr>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + entry.getRefereeName() + "</td>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + entry.getRefereeEmail() + "</td>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + entry.getFirstName() + "</td>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + entry.getMobile() + "</td>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + entry.getCity() + "</td>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + entry.getState() + "</td>");
+			sb.append("</tr>");
+		}
+		sb.append("</tbody></table></body></html>");
+		return sb.toString();
+	}
+}

Subversion Repositories SmartDukaan

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