Subversion Repositories SmartDukaan

Rev

Rev 25505 | Rev 25530 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 25505 Rev 25520
Line 23... Line 23...
23 
 
 23 
 
24 
import com.smartdukaan.cron.migrations.RunOnceTasks;
 24 
import com.smartdukaan.cron.migrations.RunOnceTasks;
25 
import com.smartdukaan.cron.scheduled.Reconciliation;
 25 
import com.smartdukaan.cron.scheduled.Reconciliation;
26 
import com.smartdukaan.cron.scheduled.ScheduledTasks;
 26 
import com.smartdukaan.cron.scheduled.ScheduledTasks;
27 
import com.spice.profitmandi.common.solr.SolrService;
 27 
import com.spice.profitmandi.common.solr.SolrService;
28 
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 - 
 
29 
import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeRepository;
 - 
 
30 
import com.spice.profitmandi.service.scheme.SchemeService;
 28 
import com.spice.profitmandi.service.scheme.SchemeService;
31 
 
 29 
 
32 
@SpringBootApplication
 30 
@SpringBootApplication
33 
@EnableCaching
 31 
@EnableCaching
34 
@EnableScheduling
 32 
@EnableScheduling
Line 36... Line 34...
36 
public class Application implements ApplicationRunner {
 34 
public class Application implements ApplicationRunner {
37 
 
 35 
 
38 
	private static final Logger LOGGER = LogManager.getLogger(Application.class);
 36 
	private static final Logger LOGGER = LogManager.getLogger(Application.class);
39 
 
 37 
 
40 
	@Autowired
 38 
	@Autowired
41 
	private FofoStoreRepository fofoStoreRepository;
 - 
 
42
- 
 
43 
	@Autowired
 - 
 
44 
	private SchemeService schemeService;
 39 
	private SchemeService schemeService;
45
- 
 
46 
	@Autowired
 - 
 
47 
	private PartnerTypeChangeRepository partnerTypeChangeRepository;
 - 
 
48 
 
 40 
 
49 
	public static void main(String[] args) throws Throwable {
 41 
	public static void main(String[] args) throws Throwable {
50 
		new SpringApplicationBuilder(Application.class).web(WebApplicationType.NONE).run(args);
 42 
		new SpringApplicationBuilder(Application.class).web(WebApplicationType.NONE).run(args);
51 
	}
 43 
	}
52 
 
 44 
 
Line 111... Line 103...
111 
	private SolrService solrService;
 103 
	private SolrService solrService;
112 
 
 104 
 
113 
	@Override
 105 
	@Override
114 
	public void run(ApplicationArguments args) throws Exception {
 106 
	public void run(ApplicationArguments args) throws Exception {
115 
		LOGGER.info("Called run method");
 107 
		LOGGER.info("Called run method");
116
108 
 
117 
		if (args.containsOption("grouping")) {
 109 
		if (args.containsOption("grouping")) {
118 
			scheduledTasks.grouping();
 110 
			scheduledTasks.grouping();
119 
			System.exit(0);
 111 
			System.exit(0);
120 
		}
 112 
		}
121 
		if (args.containsOption("reconcileExpiredFixedSchemes")) {
 113 
		if (args.containsOption("reconcileExpiredFixedSchemes")) {
122 
			reconciliation.reconcileExpiredFixedSchemes();
 114 
			reconciliation.reconcileExpiredFixedSchemes();
123 
			System.exit(0);
 115 
			System.exit(0);
124 
		}
 116 
		}
125 
		if(args.containsOption("test")) {
 117 
		if (args.containsOption("test")) {
126 
			schemeService.processSchemeIn(9243,175138102);
 118 
			schemeService.processSchemeIn(9243, 175138102);
127 
			throw new Exception();
 119 
			throw new Exception();
128 
		}
 120 
		}
129 
		if (args.containsOption("fixSchemePayouts")) {
 121 
		if (args.containsOption("fixSchemePayouts")) {
130 
 
 122 
 
131 
			runOnceTasks.fixSchemePayouts();
 123 
			runOnceTasks.fixSchemePayouts();