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