| Line 1... |
Line 1... |
| 1 |
package com.smartdukaan.cron;
|
1 |
package com.smartdukaan.cron;
|
| 2 |
|
2 |
|
| 3 |
import com.smartdukaan.cron.migrations.RunOnceTasks;
|
3 |
import com.smartdukaan.cron.migrations.RunOnceTasks;
|
| 4 |
import com.smartdukaan.cron.scheduled.*;
|
4 |
import com.smartdukaan.cron.scheduled.*;
|
| 5 |
import com.smartdukaan.cron.scheduled.b2b.Listing;
|
5 |
import com.smartdukaan.cron.scheduled.b2b.Listing;
|
| - |
|
6 |
import com.smartdukaan.cron.scheduled.beatmiss.BeatMissDetectorRunner;
|
| 6 |
import com.smartdukaan.cron.scheduled.leadsync.LeadSyncRunner;
|
7 |
import com.smartdukaan.cron.scheduled.leadsync.LeadSyncRunner;
|
| 7 |
import com.smartdukaan.cron.scheduled.ordertracking.OrderTrackingService;
|
8 |
import com.smartdukaan.cron.scheduled.ordertracking.OrderTrackingService;
|
| 8 |
import com.smartdukaan.cron.scheduled.purchaseorder.POScheduler;
|
9 |
import com.smartdukaan.cron.scheduled.purchaseorder.POScheduler;
|
| 9 |
import com.smartdukaan.cron.scheduled.razorpay.FetchPartnersDisbursementTask;
|
10 |
import com.smartdukaan.cron.scheduled.razorpay.FetchPartnersDisbursementTask;
|
| 10 |
import com.smartdukaan.cron.scheduled.knowlarity.KnowlarityCallMonitorScheduler;
|
11 |
import com.smartdukaan.cron.scheduled.knowlarity.KnowlarityCallMonitorScheduler;
|
| Line 89... |
Line 90... |
| 89 |
OrderTrackingService orderTrackingService;
|
90 |
OrderTrackingService orderTrackingService;
|
| 90 |
|
91 |
|
| 91 |
@Autowired
|
92 |
@Autowired
|
| 92 |
BatchScheduledTasks batchScheduledTasks;
|
93 |
BatchScheduledTasks batchScheduledTasks;
|
| 93 |
|
94 |
|
| - |
|
95 |
@Autowired
|
| - |
|
96 |
private BeatMissDetectorRunner beatMissDetectorRunner;
|
| - |
|
97 |
|
| 94 |
public static void main(String[] args) throws Throwable {
|
98 |
public static void main(String[] args) throws Throwable {
|
| 95 |
try {
|
99 |
try {
|
| 96 |
WebApplicationType webType = WebApplicationType.SERVLET;
|
100 |
WebApplicationType webType = WebApplicationType.SERVLET;
|
| 97 |
for (String arg : args) {
|
101 |
for (String arg : args) {
|
| 98 |
if (arg.contains("spring.main.web-application-type=none")) {
|
102 |
if (arg.contains("spring.main.web-application-type=none")) {
|
| Line 1103... |
Line 1107... |
| 1103 |
if (args.containsOption("convertExpiredFlagshipCredits")) {
|
1107 |
if (args.containsOption("convertExpiredFlagshipCredits")) {
|
| 1104 |
scheduledTasks.convertExpiredFlagshipCredits();
|
1108 |
scheduledTasks.convertExpiredFlagshipCredits();
|
| 1105 |
System.exit(0);
|
1109 |
System.exit(0);
|
| 1106 |
}
|
1110 |
}
|
| 1107 |
|
1111 |
|
| - |
|
1112 |
// Manual back-fill for missed-beat detection. Default: today.
|
| - |
|
1113 |
// Usage: --detectMissedBeats [--date=YYYY-MM-DD]
|
| - |
|
1114 |
if (args.containsOption("detectMissedBeats")) {
|
| - |
|
1115 |
LocalDate date = LocalDate.now();
|
| - |
|
1116 |
if (args.containsOption("date")) {
|
| - |
|
1117 |
date = LocalDate.parse(args.getOptionValues("date").get(0));
|
| - |
|
1118 |
}
|
| - |
|
1119 |
int inserted = beatMissDetectorRunner.syncMissesForDate(date);
|
| - |
|
1120 |
LOGGER.info("detectMissedBeats: {} miss rows inserted for {}", inserted, date);
|
| - |
|
1121 |
System.exit(0);
|
| - |
|
1122 |
}
|
| - |
|
1123 |
|
| 1108 |
if (args.containsOption("notifyFlagshipExpiryIn2Days")) {
|
1124 |
if (args.containsOption("notifyFlagshipExpiryIn2Days")) {
|
| 1109 |
scheduledTasks.notifyFlagshipExpiryIn2Days();
|
1125 |
scheduledTasks.notifyFlagshipExpiryIn2Days();
|
| 1110 |
System.exit(0);
|
1126 |
System.exit(0);
|
| 1111 |
}
|
1127 |
}
|
| 1112 |
|
1128 |
|