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();