Subversion Repositories SmartDukaan

package com.smartdukaan.cron;

import java.util.ArrayList;

import java.util.Formatter;

import java.util.List;

import java.util.Properties;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

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

import org.springframework.boot.ApplicationArguments;

import org.springframework.boot.ApplicationRunner;

import org.springframework.boot.WebApplicationType;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.boot.builder.SpringApplicationBuilder;

import org.springframework.cache.annotation.EnableCaching;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.ComponentScan;

import org.springframework.context.annotation.Primary;

import org.springframework.context.support.PropertySourcesPlaceholderConfigurer;

import org.springframework.core.io.ClassPathResource;

import org.springframework.http.converter.ByteArrayHttpMessageConverter;

import org.springframework.http.converter.HttpMessageConverter;

import org.springframework.mail.javamail.JavaMailSender;

import org.springframework.mail.javamail.JavaMailSenderImpl;

import org.springframework.scheduling.annotation.EnableScheduling;

import org.springframework.web.client.RestTemplate;

import com.smartdukaan.cron.migrations.RunOnceTasks;

import com.smartdukaan.cron.scheduled.ScheduledTasks;

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

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

@SpringBootApplication

@EnableCaching

@EnableScheduling

@ComponentScan("com.smartdukaan.cron.*, com.spice.profitmandi.common.*")

public class Application implements ApplicationRunner {

	private static final Logger LOGGER = LogManager.getLogger(Application.class);

	@Autowired

	private FofoStoreRepository fofoStoreRepository;

	public static void main(String[] args) throws Throwable {

		new SpringApplicationBuilder(Application.class).web(WebApplicationType.NONE).run(args);

	}

	@Bean

	public static PropertySourcesPlaceholderConfigurer propertyConfigurer1() {

		LOGGER.info("Called Configuration");

		PropertySourcesPlaceholderConfigurer propertySourcesPlaceholderConfigurer = new PropertySourcesPlaceholderConfigurer();

		propertySourcesPlaceholderConfigurer.setLocation(new ClassPathResource("/META-INF/env.properties"));

		return propertySourcesPlaceholderConfigurer;

	}

	@Bean(name = "mailSender")

	@Primary

	public JavaMailSender sendGridMailSender() {

		JavaMailSenderImpl mailSender = new JavaMailSenderImpl();

		// Using gmail

		mailSender.setHost("smtp.sendgrid.net");

		mailSender.setPort(587);

		mailSender.setUsername("shop2020");

		mailSender.setPassword("U2/=fP,t");

		Properties javaMailProperties = new Properties();

		javaMailProperties.put("mail.smtp.starttls.enable", "false");

		javaMailProperties.put("mail.smtp.auth", "true");

		javaMailProperties.put("mail.transport.protocol", "smtp");

		// javaMailProperties.put("mail.debug", "true");// Prints out everything on

		// screen

		mailSender.setJavaMailProperties(javaMailProperties);

		return mailSender;

	}

	@Bean

	public JavaMailSender googleMailSender() {

		JavaMailSenderImpl mailSender = new JavaMailSenderImpl();

		// Using gmail

		mailSender.setHost("smtp.gmail.com");

		mailSender.setPort(587);

		mailSender.setUsername("build@shop2020.in");

		mailSender.setPassword("cafe@nes");

		Properties javaMailProperties = new Properties();

		javaMailProperties.put("mail.smtp.starttls.enable", "true");

		javaMailProperties.put("mail.smtp.auth", "true");

		javaMailProperties.put("mail.transport.protocol", "smtp");

		javaMailProperties.put("mail.debug", "true");// Prints out everything on screen

		mailSender.setJavaMailProperties(javaMailProperties);

		return mailSender;

	}

	@Bean

	public RestTemplate restTemplate() {

		RestTemplate restTemplate = new RestTemplate();

		restTemplate.getMessageConverters().add(new ByteArrayHttpMessageConverter());

		return restTemplate;

	}

	@Autowired

	private RunOnceTasks runOnceTasks;

	@Autowired

	private ScheduledTasks scheduledTasks;

	@Override

	public void run(ApplicationArguments args) throws Exception {

		LOGGER.info("Called run method");

		if (args.containsOption("reco1")) {

			scheduledTasks.dryRunSchemeReco();

			System.exit(0);

		}

		if (args.containsOption("reco2")) {

			scheduledTasks.dryRunOutSchemeReco();

			System.exit(0);

		}

		if (args.containsOption("once")) {

			if (args.containsOption("1")) {

				if (args.containsOption("test")) {

					scheduledTasks.sendPartnerInvestmentDetails(args.getOptionValues("email"));

				} else {

					scheduledTasks.sendPartnerInvestmentDetails();

				}

				System.exit(0);

			}

			if (args.containsOption("2")) {

				scheduledTasks.sendAgeingReport();

				System.exit(0);

			}

			if (args.containsOption("saleHeads")) {

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

				for (SaleHeadDetails saleHeadDetail : saleHeadDetails) {

					scheduledTasks.sendMailToSalesHeadAboutTargetAndSales(saleHeadDetail);

				}

				System.exit(0);

			}

			if (args.containsOption("partners")) {

				scheduledTasks.sendMailToPartnerAboutTargetAndSales();

				System.exit(0);

			}

			if (args.containsOption("3")) {

				if (args.getOptionNames().contains("offset")) {

					int offset = Integer.parseInt(args.getOptionValues("offset").get(0));

					if (args.getOptionNames().contains("days")) {

						int durationDays = Integer.parseInt(args.getOptionValues("days").get(0));

						scheduledTasks.processScheme(offset, durationDays);

					} else {

						scheduledTasks.processScheme(offset);

					}

				} else if (args.containsOption("catalogid")) {

					// scheduledTasks.processSchemeForModel(args.getOptionValues("catalogid").get(0));

				} else {

					scheduledTasks.processScheme();

				}

				System.exit(0);

			}

			if (args.containsOption("4")) {

				scheduledTasks.evaluateExcessSchemeOut();

			}

			if (args.containsOption("5")) {

				int offset = Integer.parseInt(args.getOptionValues("offset").get(0));

				scheduledTasks.processScheme(offset);

				System.exit(0);

			}

			if (args.containsOption("cancelOrder")) {

				List<String> invoiceNumbers = args.getOptionValues("invoiceNumber");

				runOnceTasks.cancelOrder(invoiceNumbers);

			}

			if (args.containsOption("migratePurchase")) {

				runOnceTasks.migratePurchase();

			}

			if (args.containsOption("scrapejd")) {

				this.scrapeJD();

			}

			if (args.containsOption("migratepd")) {

				scheduledTasks.moveImeisToPriceDropImeis();

			}

			if (args.containsOption("walletmismatch")) {

				scheduledTasks.walletmismatch();

			}

			if (args.containsOption("schemewalletmismatch")) {

				scheduledTasks.schemewalletmismatch();

			}

			if (args.containsOption("gst")) {

				scheduledTasks.gst();

			}

			System.exit(0);

		}

	}

	private void scrapeJD() {

		String jdUrlTemplate = "https://www.justdial.com/Delhi/Mobile-Phone-Dealers/nct-11216691/page-{0}";

		Formatter formatter = new Formatter();

	}

}