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

 @Component
 @Transactional(rollbackFor = Throwable.class)
 public class ScheduledTasks {
-	private static final String Escalate_TICKET = "Dear {0},Your Ticket created by {1} is escalated and assigned to {2}. Regards \nSmartdukaan";
 	@Value("${oxigen.recharge.transaction.url}")
 	private String oxigenRechargeTransactionUrl;
 	@Value("${oxigen.recharge.enquiry.url}")
 	private String oxigenRechargeEnquiryUrl;
 	@Autowired
 	private InventoryService inventoryService;
 	@Autowired
-	private TicketRepository ticketRepository;
-	@Autowired
-	private TicketAssignedRepository ticketAssignedRepository;
-	@Autowired
-	private AuthRepository authRepository;
-	@Autowired
 	private AddressRepository addressRepository;
 	@Autowired
 	private RetailerRegisteredAddressRepository retailerRegisteredAddressRepository;
 	@Autowired
-	private TicketSubCategoryRepository ticketSubCategoryRepository;
-	@Autowired
 	private Mongo mongoClient;
 	@Autowired
 	private UserAccountRepository userAccountRepository;
 			PartnerDailyInvestment partnerDailyInvestment = partnerInvestmentService.getInvestment(fofoStore.getId(),
 );
 			partnerDailyInvestment.setDate(yesterDay);
 			partnerDailyInvestmentRepository.persist(partnerDailyInvestment);
-			List<? extends Serializable> row = Arrays.asList(fofoStore.getCode(), retailer.getBusinessName(), retailer.getEmail(),
+			List<? extends Serializable> row = Arrays.asList(fofoStore.getCode(), retailer.getBusinessName(),
-					retailer.getMobileNumber(), partnerDailyInvestment.getWalletAmount(),
+					retailer.getEmail(), retailer.getMobileNumber(), partnerDailyInvestment.getWalletAmount(),
 					partnerDailyInvestment.getSalesAmount(), partnerDailyInvestment.getInStockAmount(), 0,
 					partnerDailyInvestment.getUnbilledAmount(), partnerDailyInvestment.getGrnPendingAmount(),
 					partnerDailyInvestment.getMinInvestment(), partnerDailyInvestment.getTotalInvestment(),
 					partnerDailyInvestment.getShortInvestment());
 			rows.add(row);
 				"ItemwiseOverallPendingIndent.xml");
 		Attachment attachment = new Attachment(
 				"aeging-report-" + FormattingUtils.formatDate(LocalDateTime.now().minusDays(1)) + ".csv", isr);
 		Attachment attachment1 = new Attachment(
 				"aeging-report-" + FormattingUtils.formatDate(LocalDateTime.now().minusDays(1)) + ".csv", isr1);
-		Utils.sendMailWithAttachments(googleMailSender, sendTo, null, "Stock Aeging Report", "PFA", attachment, attachment1);
+		Utils.sendMailWithAttachments(googleMailSender, sendTo, null, "Stock Aeging Report", "PFA", attachment,
+				attachment1);
+	}
 	public void sendAgeingReport() throws Exception {
 		sendAgeingReport("amod.sen@smartdukaan.com", "adeel.yazdani@smartdukaan.com", "kamini.sharma@smartdukaan.com",
 				"tarun.verma@smartdukaan.com", "chaitnaya.vats@smartdukaan.com", "mohinder.mutreja@smartdukaan.com");
 			for (PartnerDailyInvestment investment : Lists
 					.reverse(partnerDailyInvestmentRepository.selectAll(fofoId, null, null))) {
 				float statementAmount = walletService.getOpeningTill(fofoId,
 						investment.getDate().plusDays(1).atTime(LocalTime.of(4, 0)));
 				CustomRetailer retailer = retailerService.getFofoRetailer(fofoId);
-				LOGGER.info("{}\t{}\t{}\t{}\t{}", fofoId, retailer.getBusinessName(), retailer.getMobileNumber(), investment.getDate().toString(),
+				LOGGER.info("{}\t{}\t{}\t{}\t{}", fofoId, retailer.getBusinessName(), retailer.getMobileNumber(),
-						investment.getWalletAmount(), statementAmount);
+						investment.getDate().toString(), investment.getWalletAmount(), statementAmount);
+			}
+		}
+	}
-	public void escalateTicket() throws ProfitMandiBusinessException {
-		List<Ticket> tickets = ticketRepository.selectAllNotClosedTickets().stream()
-				.filter(x -> x.getLastActivity() != ActivityType.RESOLVED).collect(Collectors.toList());
-		LocalDateTime now = LocalDateTime.now();
-		for (Ticket ticket : tickets) {
-			if (ticket.getL2EscalationTimestamp().isBefore(now) && ticket.getL3EscalationTimestamp().isAfter(now)) {
-				TicketAssigned ticketAssigned = ticketAssignedRepository
-						.selectByAssigneeIdAndTicketId(ticket.getL2AuthUser(), ticket.getId());
-				if (ticketAssigned == null) {
-					ticketAssigned = new TicketAssigned();
-					ticketAssigned.setAssineeId(ticket.getL2AuthUser());
-					ticketAssigned.setTicketId(ticket.getId());
-					ticketAssignedRepository.persist(ticketAssigned);
-					String subject = "Escalated Ticket";
-					LOGGER.info(subject);
-					String message = MessageFormat.format(Escalate_TICKET,
-							authRepository.selectById(ticket.getL1AuthUser()).getFirstName(),
-							retailerService.getFofoRetailer(ticket.getFofoId()).getBusinessName(),
-							authRepository.selectById(ticket.getL2AuthUser()).getFirstName());
-					LOGGER.info(message);
-					String[] cc = { authRepository.selectById(ticket.getL2AuthUser()).getEmailId() };
-					LOGGER.info(cc[0]);
-					String to = authRepository.selectById(ticket.getL1AuthUser()).getEmailId();
-					LOGGER.info(to);
-					this.sendEscaltedTicketMail(to, subject, message, cc);
-					LOGGER.info(subject + " " + message + " " + to + " " + cc[0]);
-				}
-			} else if (ticket.getL3EscalationTimestamp().isBefore(now)
-					&& ticket.getLastEscalationTimestamp().isAfter(now)) {
-				TicketAssigned ticketAssigned = ticketAssignedRepository
-						.selectByAssigneeIdAndTicketId(ticket.getL3AuthUser(), ticket.getId());
-				if (ticketAssigned == null) {
-					ticketAssigned = new TicketAssigned();
-					ticketAssigned.setAssineeId(ticket.getL3AuthUser());
-					ticketAssigned.setTicketId(ticket.getId());
-					ticketAssignedRepository.persist(ticketAssigned);
-					String subject = "Escalated Ticket";
-					String message = MessageFormat.format(Escalate_TICKET,
-							authRepository.selectById(ticket.getL2AuthUser()).getFirstName(),
-							retailerService.getFofoRetailer(ticket.getFofoId()).getBusinessName(),
-							authRepository.selectById(ticket.getL3AuthUser()).getFirstName());
-					LOGGER.info(subject);
-					LOGGER.info(message);
-					String[] cc = { authRepository.selectById(ticket.getL3AuthUser()).getEmailId() };
-					LOGGER.info(cc[0]);
-					String to = authRepository.selectById(ticket.getL2AuthUser()).getEmailId();
-					LOGGER.info(to);
-					this.sendEscaltedTicketMail(to, subject, message, cc);
-					LOGGER.info(subject);
-				}
-			}
-		}
-	}
-	private void sendEscaltedTicketMail(String to, String subject, String message, String[] cc)
-			throws ProfitMandiBusinessException {
-		try {
-			Utils.sendMailWithAttachments(mailSender, to, cc, subject, message, null);
-			LOGGER.info("mail send successfully");
-		} catch (Exception e) {
-			throw new ProfitMandiBusinessException("Escalated Ticket", to, "Could not send Escalated ticket mail");
-		}
-	}
 	public void gst() throws Exception {
 		List<FofoOrder> fofoOrders = fofoOrderRepository.selectBetweenSaleDate(LocalDate.of(2019, 1, 26).atStartOfDay(),
 				LocalDate.of(2019, 1, 27).atTime(LocalTime.MAX));
 		for (FofoOrder fofoOrder : fofoOrders) {
 			int retailerAddressId = retailerRegisteredAddressRepository
 				new String[] { "amit.gupta@shop2020.in", "neeraj.gupta@smartdukaan.com" }, null,
 				"Partner Excess Amount Scheme In", "PFA",
 				new Attachment[] { new Attachment("WalletSummary.csv", new ByteArrayResource(baos.toByteArray())),
 						new Attachment("SchemeInRolledback.csv", new ByteArrayResource(baosOuts.toByteArray())) });
-		//throw new Exception();
+		// throw new Exception();
+	}
 	public void dryRunOutSchemeReco() throws Exception {
 		List<UserWalletHistory> userWalletHistory = new ArrayList<>();
 				new String[] { "amit.gupta@shop2020.in", "neeraj.gupta@smartdukaan.com" }, null,
 				"Partner Excess Amount Scheme Out", "PFA",
 				new Attachment[] { new Attachment("WalletSummary.csv", new ByteArrayResource(baos.toByteArray())),
 						new Attachment("SchemeOutRolledback.csv", new ByteArrayResource(baosOuts.toByteArray())) });
-		//throw new Exception();
+		// throw new Exception();
+	}
 	public void dryRunSchemeOutReco1() throws Exception {
 		List<Integer> references = Arrays.asList(6744, 7347, 8320, 8891, 9124, 9217, 9263, 9379);
 		List<UserWalletHistory> userWalletHistory = new ArrayList<>();
 		throw new Exception();
+	}
-	public void alertforTicket() throws Exception {
-		List<Ticket> tickets = ticketRepository.selectAllNotClosedTickets();
-		Map<Integer, List<Ticket>> l1AuthUserAndTicketMap = new HashMap<>();
-		Map<Integer, List<Ticket>> l2AuthUserAndTicketMap = new HashMap<>();
-		Set<Integer> l1AuthUsers = tickets.stream().map(x -> x.getL1AuthUser()).collect(Collectors.toSet());
-		Set<Integer> l2AuthUsers = tickets.stream()
-				.filter(x -> x.getL2EscalationTimestamp().isBefore(LocalDateTime.now())).map(x -> x.getL2AuthUser())
-				.collect(Collectors.toSet());
-		for (Integer l1AuthUser : l1AuthUsers) {
-			List<Ticket> ticketsForl1AuthUser = tickets.stream().filter(ticket -> l1AuthUser == ticket.getL1AuthUser())
-					.collect(Collectors.toList());
-			l1AuthUserAndTicketMap.put(l1AuthUser, ticketsForl1AuthUser);
-		}
-		for (Integer l2AuthUser : l2AuthUsers) {
-			List<Ticket> ticketsForl2AuthUser = tickets.stream().filter(ticket -> l2AuthUser == ticket.getL2AuthUser())
-					.collect(Collectors.toList());
-			l2AuthUserAndTicketMap.put(l2AuthUser, ticketsForl2AuthUser);
-		}
-		for (Entry<Integer, List<Ticket>> entry : l1AuthUserAndTicketMap.entrySet()) {
-			List<Ticket> ticketsForAuthUser = entry.getValue();
-			AuthUser authUser = authRepository.selectById(entry.getKey());
-			String message = this.getMessageForAlertTicket(ticketsForAuthUser, EscalationType.L1);
-			this.sendMailOfHtmlFomat(authUser.getEmailId(), message, null, "Daily Pending Ticket");
-		}
-		for (Entry<Integer, List<Ticket>> entry : l2AuthUserAndTicketMap.entrySet()) {
-			List<Ticket> ticketsForAuthUser = entry.getValue();
-			AuthUser authUser = authRepository.selectById(entry.getKey());
-			String message = this.getMessageForAlertTicket(ticketsForAuthUser, EscalationType.L2);
-			this.sendMailOfHtmlFomat(authUser.getEmailId(), message, null, "Daily Pending Ticket");
-		}
-	}
-	public String getMessageForAlertTicket(List<Ticket> tickets, EscalationType escalationType)
-			throws ProfitMandiBusinessException {
-		StringBuilder sb = new StringBuilder();
-		sb.append("<html><body><p>Your Pending Tickets</p><br/><table style='border:1px solid black ;padding: 5px';>");
-		sb.append("<tbody>\n" + "	    				<tr>\n"
-				+ "	    					<th style='border:1px solid black;padding: 5px'>Ticket Id</th>\n"
-				+ "	    					<th style='border:1px solid black;padding: 5px'>Partner</th>\n"
-				+ "	    					<th style='border:1px solid black;padding: 5px'>SubCategory</th>\n"
-				+ "	    					<th style='border:1px solid black;padding: 5px'>Remaining Time To Escalate</th>\n"
-				+ "	    					<th style='border:1px solid black;padding: 5px'>Escalated</th>\n"
-				+ "	    				</tr>");
-		for (Ticket ticket : tickets) {
-			sb.append("<tr>");
-			sb.append("<td style='border:1px solid black;padding: 5px'>" + ticket.getId() + "</td>");
-			sb.append("<td style='border:1px solid black;padding: 5px'>"
-					+ retailerService.getFofoRetailer(ticket.getFofoId()).getBusinessName() + "</td>");
-			sb.append("<td style='border:1px solid black;padding: 5px'>"
-					+ ticketSubCategoryRepository.selectById(ticket.getSubCategoryId()).getDescription() + "</td>");
-			if (escalationType == EscalationType.L1) {
-				if (ticket.getL2EscalationTimestamp().isBefore(LocalDateTime.now())) {
-					sb.append("<td style='border:1px solid black;padding: 5px'>" + 0 + "</td>");
-					sb.append("<td style='border:1px solid black;padding: 5px'>YES</td>");
-				} else {
-					Duration duration = Duration.between(LocalDateTime.now(), ticket.getL2EscalationTimestamp());
-					sb.append("<td style='border:1px solid black;padding: 5px'>" + duration.toHours() + "hrs</td>");
-					sb.append("<td style='border:1px solid black;padding: 5px'>NO</td>");
-				}
-			} else if (escalationType == EscalationType.L2) {
-				if (ticket.getL3EscalationTimestamp().isBefore(LocalDateTime.now())) {
-					Duration duration = Duration.between(ticket.getL3EscalationTimestamp(), LocalDateTime.now());
-					sb.append("<td style='border:1px solid black;padding: 5px'>" + duration.toHours() + " hrs</td>");
-					sb.append("<td style='border:1px solid black;padding: 5px'>YES</td>");
-				} else {
-					sb.append("<td style='border:1px solid black;padding: 5px'>NO</td>");
-				}
-			}
-			sb.append("</tr>");
-		}
-		sb.append("</tbody></table></body></html>");
-		return sb.toString();
-	}
-	private void sendMailOfHtmlFomat(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);
-		helper.setTo(email);
-		if (cc != null) {
-			helper.setCc(cc);
-		}
-		InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smart Dukaan");
-		helper.setFrom(senderAddress);
-		mailSender.send(message);
-	}
 	public void sendDailySalesReportNotificationToPartner()
 			throws ProfitMandiBusinessException, MessagingException, IOException {
 		LocalDateTime now = LocalDateTime.now();
 		LocalDateTime from = LocalDateTime.of(now.getYear(), now.getMonth(), now.getDayOfMonth(), 00, 00);
 		Map<Integer, Double> salesByFofoIdMap = new HashMap<>();
+		}
 		sb.append("</tbody></table></body></html>");
 		return sb.toString();
+	}
+	private void sendMailOfHtmlFomat(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);
+		helper.setTo(email);
+		if (cc != null) {
+			helper.setCc(cc);
+		}
+		InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smart Dukaan");
+		helper.setFrom(senderAddress);
+		mailSender.send(message);
+	}
+}

Subversion Repositories SmartDukaan

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