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

 import java.io.IOException;
 import java.io.InputStream;
 import java.sql.Timestamp;
 import java.text.MessageFormat;
+import java.time.Duration;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.LocalTime;
+import java.time.ZoneOffset;
+import java.time.format.DateTimeFormatter;
 import java.time.temporal.ChronoUnit;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Map;
+import java.util.Map.Entry;
 import java.util.Optional;
 import java.util.Set;
 import java.util.stream.Collectors;
 import javax.mail.MessagingException;
 import com.spice.profitmandi.common.model.RechargeCredential;
 import com.spice.profitmandi.common.util.FileUtil;
 import com.spice.profitmandi.common.util.FormattingUtils;
 import com.spice.profitmandi.common.util.Utils;
 import com.spice.profitmandi.common.util.Utils.Attachment;
+import com.spice.profitmandi.dao.entity.auth.AuthUser;
 import com.spice.profitmandi.dao.entity.catalog.Scheme;
 import com.spice.profitmandi.dao.entity.cs.Ticket;
 import com.spice.profitmandi.dao.entity.cs.TicketAssigned;
 import com.spice.profitmandi.dao.entity.dtr.DailyRecharge;
+import com.spice.profitmandi.dao.entity.dtr.NotificationCampaigns;
 import com.spice.profitmandi.dao.entity.dtr.RechargeProvider;
 import com.spice.profitmandi.dao.entity.dtr.RechargeProviderCreditWalletHistory;
 import com.spice.profitmandi.dao.entity.dtr.RechargeTransaction;
+import com.spice.profitmandi.dao.entity.fofo.ActivityType;
 import com.spice.profitmandi.dao.entity.fofo.CustomerAddress;
 import com.spice.profitmandi.dao.entity.fofo.FofoLineItem;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrderItem;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.entity.fofo.InventoryItem;
 import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
+import com.spice.profitmandi.dao.entity.fofo.PartnerTarget;
 import com.spice.profitmandi.dao.entity.fofo.PartnerTargetDetails;
 import com.spice.profitmandi.dao.entity.fofo.Purchase;
 import com.spice.profitmandi.dao.entity.fofo.SaleHeadDetails;
 import com.spice.profitmandi.dao.entity.fofo.ScanRecord;
 import com.spice.profitmandi.dao.entity.fofo.SchemeInOut;
 import com.spice.profitmandi.dao.entity.transaction.PriceDrop;
 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.enumuration.catalog.SchemeType;
+import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
 import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
 import com.spice.profitmandi.dao.repository.catalog.SchemeRepository;
 import com.spice.profitmandi.dao.repository.cs.TicketAssignedRepository;
 import com.spice.profitmandi.dao.repository.cs.TicketRepository;
+import com.spice.profitmandi.dao.repository.cs.TicketSubCategoryRepository;
 import com.spice.profitmandi.dao.repository.dtr.DailyRechargeRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
+import com.spice.profitmandi.dao.repository.dtr.Mongo;
 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.RetailerRegisteredAddressRepository;
 import com.spice.profitmandi.dao.repository.fofo.CustomerAddressRepository;
 import com.spice.profitmandi.dao.repository.transaction.UserWalletHistoryRepository;
 import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
 import com.spice.profitmandi.dao.repository.user.AddressRepository;
 import com.spice.profitmandi.service.PartnerInvestmentService;
 import com.spice.profitmandi.service.inventory.InventoryService;
-import com.spice.profitmandi.service.order.OrderService;
 import com.spice.profitmandi.service.pricing.PriceDropService;
 import com.spice.profitmandi.service.recharge.provider.OxigenRechargeProviderService;
 import com.spice.profitmandi.service.recharge.provider.ThinkWalnutDigitalRechargeProviderService;
 import com.spice.profitmandi.service.scheme.SchemeService;
 import com.spice.profitmandi.service.slab.TargetSlabService;
 	@Autowired
 	private SchemeService schemeService;
 	@Autowired
-	private OrderService orderService;
-	@Autowired
 	private PartnerInvestmentService partnerInvestmentService;
 	@Autowired
 	private FofoOrderItemRepository fofoOrderItemRepository;
 	private AddressRepository addressRepository;
 	@Autowired
 	private RetailerRegisteredAddressRepository retailerRegisteredAddressRepository;
+	@Autowired
+	private TicketSubCategoryRepository ticketSubCategoryRepository;
+	@Autowired
+	private Mongo mongoClient;
 	private static final Logger LOGGER = LogManager.getLogger(ScheduledTasks.class);
 	public void generateDailyRecharge() {
 		List<RechargeProviderCreditWalletHistory> allCreditHistory = rechargeProviderCreditWalletHistoryRepository
 				.selectAll(0, 2000);
+		}
+	}
 	public void escalateTicket() throws ProfitMandiBusinessException {
-		List<Ticket> tickets = ticketRepository.selectAllNotClosedTickets();
+		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());
 		LocalDateTime startDate = LocalDate.of(2018, 9, 1).atStartOfDay();
 		LocalDateTime endDate = LocalDate.now().atStartOfDay();
 		List<FofoOrder> allOrders = fofoOrderRepository.selectBetweenSaleDate(startDate, endDate);
 		// Collections.reverse(allOrders);
 		// List<FofoOrder> allOrders =
+		// List<FofoOrder> allOrders =
 		// Arrays.asList(fofoOrderRepository.selectByInvoiceNumber("UPGZ019/25"));
 		Set<String> serialNumbersConsidered = new HashSet<>();
 		allOrders.stream().forEach(fofoOrder -> {
 			String description = "Adjustment of Duplicate Scheme for Sale Invoice " + fofoOrder.getInvoiceNumber();
 			Map<Integer, String> inventorySerialNumberMap = new HashMap<>();
 		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().isAfter(LocalDateTime.now())).map(x -> x.getL1AuthUser())
+				.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);
+		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<>();
+		List<Integer> fofoIds = targetService.getfofoIdsFromfofoStore();
+		List<PartnerTargetDetails> partnerTargetDetails = partnerTargetRepository
+				.selectAllGeEqAndLeEqStartDateAndEndDate(now);
+		DateTimeFormatter timeFormatter = DateTimeFormatter
+	            .ofPattern("h a");
+		Map<Integer,Float> dailyTarget=new HashMap<>();
+		for (Integer fofoId : fofoIds) {
+			Map<Integer,Float> dailyAverageSale=null;
+			double sale = fofoOrderRepository.selectTotalSaleSumByFofoIdBrtweenDate(fofoId, from, now);
+			for (PartnerTargetDetails partnerTargetDetail : partnerTargetDetails) {
+				Map<Integer, Float> targetValues = targetService.getTargetValueByFofoIdAndTargetId(fofoId,
+						partnerTargetDetail.getId());
+				if (targetValues.size() == 0) {
+					continue;
+				} else {
+					List<Integer> partnerIds = new ArrayList<>();
+					partnerIds.add(fofoId);
+					dailyAverageSale = targetService.getDailyAverageSaleForCurrentForSingleFofoIdAndBrand(partnerIds,
+							targetValues, partnerTargetDetail.getStartDate(), partnerTargetDetail.getEndDate(),
+							partnerTargetDetail.getBrandName());
+					dailyTarget.put(fofoId, dailyAverageSale.get(fofoId));
+					break;
+				}
+			}
+			NotificationCampaigns notification = new NotificationCampaigns();
+			notification.setName("Today's Sale");
+			if(dailyAverageSale!=null && dailyAverageSale.get(fofoId)!=null) {
+				LOGGER.info("Your today sale till" + " " + now.format(timeFormatter) +" "+ "is" + " " + sale+" "+"vs" +" "+"daily target="+dailyAverageSale.get(fofoId));
+			notification.setTitle("Your today sale till" + " " + now.format(timeFormatter) +" "+ "is" + " " + sale+" "+"vs" +" "+"daily target="+dailyAverageSale.get(fofoId));
+			}
+			else
+			{
+				notification.setTitle("Your today sale till" + " " + now.format(timeFormatter) +" "+"is" + " " + sale+" "+"vs" +" "+"daily target = 0.0");
+				LOGGER.info("Your today sale till" + " " + now.format(timeFormatter) +" "+ "is" + " " + sale+" "+"vs" +" "+"daily target = 0.0");
+			}
+			// notification.setMessage("Your sale is "+salesbyfofoId.get(fofoId));
+			notification.setType("Url");
+			notification.setUrl("http://app.profitmandi.com/pages/home/dashboard");
+			notification
+					.setSql(MessageFormat.format("SELECT distinct d1.user_id from devices d1 left join devices d2 on"
+							+ "(d1.imeinumber = d2.imeinumber and d1.created < d2.created) "
+							+ " where d2.id is null and d1.user_id in ({0})", fofoId));
+			notification.setExpiresat(LocalDateTime.now().toEpochSecond(ZoneOffset.ofHoursMinutes(5, 30)));
+			notification.setStatus("active");
+			notification.setSmsprocessed(0);
+			notification.setNotification_processed(0);
+			notification.setNotification_type("GENERAL_NOTIFICATION");
+		//	mongoClient.persistNotificationCmpInfo(notification);
+			salesByFofoIdMap.put(fofoId, sale);
+			LOGGER.info(sale);
+		}
+		String saleReport = this.getDailySalesReportByPartnerId(salesByFofoIdMap,dailyTarget);
+		LOGGER.info(saleReport);
+		String cc[] = { "Tarun.verma@smartdukaan.com", "Kamini.sharma@smartdukaan.com",
+				"chaitnaya.vats@smartdukaan.com" };
+		String subject = "sale report till" + " " + now.format(timeFormatter);
+		this.sendMailOfHtmlFomat("govind.kumar@shop2020.in", saleReport, null, subject);
+	}
+	public String getDailySalesReportByPartnerId(Map<Integer, Double> salesByFofoIdMap,Map<Integer, Float> dailyTarget)
+			throws ProfitMandiBusinessException {
+		StringBuilder sb = new StringBuilder();
+		sb.append("<html><body><p>Sale Report:</p><br/><table style='border:1px solid black ;padding: 5px';>");
+		sb.append("<tbody>\n" + "	    				<tr>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Partner</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Daily Target</th>\n"
+				+ "	    					<th style='border:1px solid black;padding: 5px'>Sale</th>\n"
+				+ "	    				</tr>");
+		for (Integer fofoId : salesByFofoIdMap.keySet()) {
+			sb.append("<tr>");
+			sb.append("<td style='border:1px solid black;padding: 5px'>"
+					+ retailerService.getFofoRetailer(fofoId).getBusinessName() + "</td>");
+			if(dailyTarget!=null && dailyTarget.get(fofoId)!=null) {
+			sb.append("<td style='border:1px solid black;padding: 5px'>" + dailyTarget.get(fofoId) + "</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'>" + salesByFofoIdMap.get(fofoId) + "</td>");
+			sb.append("</tr>");
+		}
+		sb.append("</tbody></table></body></html>");
+		return sb.toString();
+	}
+}
 /*
  * public void processSchemeForModel(String string) { pricingService
+ *

Subversion Repositories SmartDukaan

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