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

 import com.spice.profitmandi.common.model.CustomRetailer;
 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.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.RechargeProvider;
 import com.spice.profitmandi.dao.entity.dtr.RechargeProviderCreditWalletHistory;
 import com.spice.profitmandi.dao.entity.dtr.RechargeTransaction;
 import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
 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.enumuration.catalog.SchemeType;
 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.dtr.DailyRechargeRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.RechargeProviderCreditWalletHistoryRepository;
 import com.spice.profitmandi.dao.repository.dtr.RechargeProviderRepository;
 import com.spice.profitmandi.dao.repository.dtr.RechargeTransactionRepository;
 @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 PriceDropService priceDropService;
 	@Value("${oxigen.recharge.auth.key}")
 	private String oxigenRechargeAuthKey;
 	private JavaMailSender googleMailSender;
 	@Autowired
 	private InventoryService inventoryService;
+	@Autowired
+	private TicketRepository ticketRepository;
+	@Autowired
+	private TicketAssignedRepository ticketAssignedRepository;
+	@Autowired
+	private AuthRepository authRepository;
 	private static final Logger LOGGER = LogManager.getLogger(ScheduledTasks.class);
 	public void generateDailyRecharge() {
 		List<RechargeProviderCreditWalletHistory> allCreditHistory = rechargeProviderCreditWalletHistoryRepository
 				.selectAll(0, 2000);
 	public void processScheme(int offset) throws Exception {
 		LocalDateTime startDate = LocalDateTime.of(LocalDate.now(), LocalTime.MIDNIGHT).minusDays(offset);
 		LocalDateTime endDate = startDate.plusDays(30);
 		processScheme(startDate, endDate);
+	}
 	public void processScheme(int offset, int durationDays) throws Exception {
 		LocalDateTime startDate = LocalDateTime.of(LocalDate.now(), LocalTime.MIDNIGHT).minusDays(offset);
 		LocalDateTime endDate = startDate.plusDays(durationDays);
 		processScheme(startDate, endDate);
+	}
 			CustomRetailer retailer = customRetailerMap.get(fofoStore.getId());
 			if (retailer == null) {
 				LOGGER.info("Could not find retailer with retailer Id {}", fofoStore.getId());
 				continue;
+			}
-			PartnerDailyInvestment partnerDailyInvestment = partnerInvestmentService
+			PartnerDailyInvestment partnerDailyInvestment = partnerInvestmentService.getInvestment(fofoStore.getId(),
-					.getInvestment(fofoStore.getId(), 1);
+);
 			partnerDailyInvestment.setDate(yesterDay);
 			partnerDailyInvestmentRepository.persist(partnerDailyInvestment);
 			List<Object> row = Arrays.asList(fofoStore.getCode(), retailer.getBusinessName(), retailer.getEmail(),
 					retailer.getMobileNumber(), partnerDailyInvestment.getWalletAmount(),
 					partnerDailyInvestment.getSalesAmount(), partnerDailyInvestment.getInStockAmount(), 0,
 					partnerDailyInvestment.getUnbilledAmount(), partnerDailyInvestment.getGrnPendingAmount(),
-					partnerDailyInvestment.getMinInvestment(), partnerDailyInvestment.getTotalInvestment(), partnerDailyInvestment.getShortInvestment());
+					partnerDailyInvestment.getMinInvestment(), partnerDailyInvestment.getTotalInvestment(),
+					partnerDailyInvestment.getShortInvestment());
 			rows.add(row);
+		}
 		String fileName = "InvestmentSummary-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
 		ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
 			this.sendMailWithAttachmentsForPartners(fofoIdsAndCustomRetailer.get(fofoId).getEmail(), message, subject,
 					is);
+		}
+	}
-	public void moveImeisToPriceDropImeis() throws Exception{
+	public void moveImeisToPriceDropImeis() throws Exception {
 		List<PriceDrop> priceDrops = priceDropRepository.selectAll();
-		for(PriceDrop priceDrop : priceDrops) {
+		for (PriceDrop priceDrop : priceDrops) {
 			priceDropService.priceDropStatus(priceDrop.getId());
+		}
+	}
+	public void escalateTicket() throws ProfitMandiBusinessException {
+		List<Ticket> tickets = ticketRepository.selectAllNotClosedTickets();
+		for (Ticket ticket : tickets) {
+			if ((ticket.getL2EscalationTimestamp().isBefore(LocalDateTime.now())
+					|| ticket.getL2EscalationTimestamp().isEqual(LocalDateTime.now()))
+					&& ticket.getL3EscalationTimestamp().isAfter(LocalDateTime.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(LocalDateTime.now())
+					|| ticket.getL3EscalationTimestamp().isEqual(LocalDateTime.now()))
+					&& ticket.getLastEscalationTimestamp().isAfter(LocalDateTime.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");
+		}
+	}
+}

Subversion Repositories SmartDukaan

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