Subversion Repositories SmartDukaan

Rev

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

Rev 25751 Rev 25837
Line 1... Line 1...
1
package com.smartdukaan.cron;
1
package com.smartdukaan.cron;
2
 
2
 
-
 
3
import java.time.LocalDateTime;
3
import java.util.List;
4
import java.util.List;
4
import java.util.Properties;
5
import java.util.Properties;
5
 
6
 
6
import org.apache.logging.log4j.LogManager;
7
import org.apache.logging.log4j.LogManager;
7
import org.apache.logging.log4j.Logger;
8
import org.apache.logging.log4j.Logger;
Line 24... Line 25...
24
import com.smartdukaan.cron.migrations.RunOnceTasks;
25
import com.smartdukaan.cron.migrations.RunOnceTasks;
25
import com.smartdukaan.cron.scheduled.Reconciliation;
26
import com.smartdukaan.cron.scheduled.Reconciliation;
26
import com.smartdukaan.cron.scheduled.ScheduledSkeleton;
27
import com.smartdukaan.cron.scheduled.ScheduledSkeleton;
27
import com.smartdukaan.cron.scheduled.ScheduledTasks;
28
import com.smartdukaan.cron.scheduled.ScheduledTasks;
28
import com.spice.profitmandi.common.solr.SolrService;
29
import com.spice.profitmandi.common.solr.SolrService;
-
 
30
import com.spice.profitmandi.dao.repository.dtr.InsurancePolicyRepository;
29
import com.spice.profitmandi.service.integrations.toffee.ToffeeService;
31
import com.spice.profitmandi.service.integrations.toffee.ToffeeService;
30
import com.spice.profitmandi.service.scheme.SchemeService;
32
import com.spice.profitmandi.service.scheme.SchemeService;
31
 
33
 
32
@SpringBootApplication
34
@SpringBootApplication
33
@EnableCaching
35
@EnableCaching
Line 107... Line 109...
107
	@Autowired
109
	@Autowired
108
	private SolrService solrService;
110
	private SolrService solrService;
109
	
111
	
110
	@Autowired
112
	@Autowired
111
	private ToffeeService toffeeService;
113
	private ToffeeService toffeeService;
-
 
114
	
-
 
115
	@Autowired
-
 
116
	private InsurancePolicyRepository insurancePolicyRepository;
112
 
117
 
113
	@Override
118
	@Override
114
	public void run(ApplicationArguments args) throws Exception {
119
	public void run(ApplicationArguments args) throws Exception {
115
		LOGGER.info("Called run method");
120
		LOGGER.info("Called run method");
116
 
121
 
117
		if (args.containsOption("tc")) {
122
		if (args.containsOption("tc")) {
-
 
123
			LOGGER.info("Insurance Sum Summary --- {}", 
-
 
124
					insurancePolicyRepository.selectAmountSumGroupByRetailerId(LocalDateTime.now().minusDays(1), null));
-
 
125
			LOGGER.info("Insurance Qty Summary --- {}", 
-
 
126
					insurancePolicyRepository.selectQtyGroupByRetailerId(LocalDateTime.now().minusDays(1), null));
118
			System.out.println("Toffee service called");
127
			//System.out.println("Toffee service called");
119
			scheduledTasks.testToffee();
128
			//scheduledTasks.testToffee();
120
			System.exit(0);
129
			System.exit(0);
121
		}
130
		}
122
		if(args.containsOption("sr")) {
131
		if(args.containsOption("sr")) {
123
			List<String> schemeIds = args.getOptionValues("schemeId");
132
			List<String> schemeIds = args.getOptionValues("schemeId");
124
			System.out.println(schemeIds);
133
			System.out.println(schemeIds);
Line 160... Line 169...
160
			System.exit(0);
169
			System.exit(0);
161
		}
170
		}
162
		if (args.containsOption("notify")) {
171
		if (args.containsOption("notify")) {
163
			if (args.containsOption("fofoId")) {
172
			if (args.containsOption("fofoId")) {
164
				int fofoId = Integer.parseInt(args.getOptionValues("fofoId").get(0));
173
				int fofoId = Integer.parseInt(args.getOptionValues("fofoId").get(0));
165
				scheduledTasks.sendDailySalesReportNotificationToPartner(fofoId);
174
				scheduledTasks.sendDailySalesNotificationToPartner(fofoId);
166
			}
175
			}
167
			System.exit(0);
176
			System.exit(0);
168
		}
177
		}
169
		if (args.containsOption("findMismatchesInIndent")) {
178
		if (args.containsOption("findMismatchesInIndent")) {
170
			runOnceTasks.findMismatchesInIndent();
179
			runOnceTasks.findMismatchesInIndent();
171
			System.exit(0);
180
			System.exit(0);
172
		}
181
		}
173
		if (args.containsOption("notifyAll")) {
182
		if (args.containsOption("notifyAll")) {
174
			scheduledTasks.sendDailySalesReportNotificationToPartner(null);
183
			scheduledTasks.sendDailySalesNotificationToPartner(null);
175
			System.exit(0);
184
			System.exit(0);
176
		}
185
		}
177
		if (args.containsOption("OutSchemeReco")) {
186
		if (args.containsOption("OutSchemeReco")) {
178
			scheduledTasks.dryRunOutSchemeReco();
187
			scheduledTasks.dryRunOutSchemeReco();
179
			// runOnceTasks.migrateChallansToInvoices();
188
			// runOnceTasks.migrateChallansToInvoices();