Subversion Repositories SmartDukaan

package com.smartdukaan.cron.scheduled;

import java.io.IOException;

import java.time.LocalDateTime;

import java.util.List;

import javax.mail.MessagingException;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.apache.poi.EncryptedDocumentException;

import org.apache.poi.openxml4j.exceptions.InvalidFormatException;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;

import com.smartdukaan.cron.monitored.NagiosMonitorTasks;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.dao.entity.fofo.SaleHeadDetails;

import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;

@Component

public class ScheduledSkeleton {

	private static final Logger log = LogManager.getLogger(ScheduledSkeleton.class);

	@Autowired

	private ScheduledTasks scheduledTasks;

	@Autowired

	private Reconciliation reconciliation;

	@Autowired

	NagiosMonitorTasks nagiosMonitorTasks;

	@Autowired

	private FofoStoreRepository fofoStoreRepository;

	@Autowired

	private TicketRelatedScheduledTask ticketRelatedScheduledTask;

	@Scheduled(cron = "0 0 2 * * *")

	public void processDailySchemes() throws Exception {

		scheduledTasks.processScheme(LocalDateTime.now().minusDays(21), LocalDateTime.now());

	}

	@Scheduled(cron = "0 15 0 * * *")

	public void reconcileRecharge() throws Exception {

		scheduledTasks.reconcileRecharge();

	}

	@Scheduled(cron = "0 05 0 1,16 * ?")

	public void processRechargeCashback() throws Throwable {

		scheduledTasks.processRechargeCashback();

	}

	@Scheduled(cron = "0 0 1 * * *")

	public void sendPartnerInvestmentDetails() throws Throwable {

		scheduledTasks.sendPartnerInvestmentDetails();

	}

	@Scheduled(cron = "0 0 8 * * *")

	public void sendStockAgeingReport() throws Throwable {

		scheduledTasks.sendAgeingReport();

	}

	@Scheduled(cron = " 0 0 23 * * *")

	public void sendMail() throws MessagingException, ProfitMandiBusinessException, IOException {

		log.info("sending mail");

		List<SaleHeadDetails> saleHeadDetails = fofoStoreRepository.selectAllSalesHeadDetails();

		for (SaleHeadDetails saleHeadDetail : saleHeadDetails) {

			scheduledTasks.sendMailToSalesHeadAboutTargetAndSales(saleHeadDetail);

		}

	}

	@Scheduled(cron = "0 30 23 * * *")

	public void sendMailToPartner() throws MessagingException, ProfitMandiBusinessException, IOException,

			EncryptedDocumentException, InvalidFormatException {

		log.info("sending mail To Partner");

		scheduledTasks.sendMailToPartnerAboutTargetAndSales();

	}

	@Scheduled(cron = "0 0/30 * * * *")

	public void escalateTicket() throws ProfitMandiBusinessException {

		log.info("escalate ticket");

		ticketRelatedScheduledTask.escalateTicket();

	}

	@Scheduled(cron = "0 0 11 * * *")

	public void alertTicketToUser() throws Exception {

		log.info("alert for ticket");

		ticketRelatedScheduledTask.alertforTicket();

	}

	@Scheduled(cron = "0 0 15,17,19,23 ? * *")

	public void dailySaleNotification() throws Exception {

		log.info("daily send Notification");

		scheduledTasks.sendDailySalesReportNotificationToPartner();

	}

	@Scheduled(cron = "0 0 6 * * *")

	public void dailyReconciliation() throws Exception {

		reconciliation.dailyReconciliation();

	}

}