Subversion Repositories SmartDukaan

Rev

Rev 32147 | Rev 32223 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
23755 amit.gupta 1
package com.smartdukaan.cron;
23723 amit.gupta 2
 
31753 tejbeer 3
import java.io.FileInputStream;
4
import java.io.IOException;
5
import java.time.LocalDate;
6
import java.time.LocalDateTime;
7
import java.time.YearMonth;
8
import java.util.ArrayList;
9
import java.util.Arrays;
10
import java.util.List;
11
import java.util.Properties;
12
import java.util.stream.Collectors;
13
 
23723 amit.gupta 14
import org.apache.logging.log4j.LogManager;
15
import org.apache.logging.log4j.Logger;
28389 amit.gupta 16
import org.apache.velocity.app.VelocityEngine;
17
import org.apache.velocity.exception.VelocityException;
23898 amit.gupta 18
import org.springframework.beans.factory.annotation.Autowired;
19
import org.springframework.boot.ApplicationArguments;
20
import org.springframework.boot.ApplicationRunner;
23723 amit.gupta 21
import org.springframework.boot.WebApplicationType;
22
import org.springframework.boot.autoconfigure.SpringBootApplication;
23
import org.springframework.boot.builder.SpringApplicationBuilder;
24
import org.springframework.context.annotation.Bean;
25
import org.springframework.context.annotation.ComponentScan;
23935 amit.gupta 26
import org.springframework.context.annotation.Primary;
23723 amit.gupta 27
import org.springframework.context.support.PropertySourcesPlaceholderConfigurer;
28
import org.springframework.core.io.ClassPathResource;
23906 amit.gupta 29
import org.springframework.mail.javamail.JavaMailSender;
30
import org.springframework.mail.javamail.JavaMailSenderImpl;
31755 amit.gupta 31
import org.springframework.scheduling.annotation.EnableScheduling;
28389 amit.gupta 32
import org.springframework.ui.velocity.VelocityEngineFactoryBean;
23723 amit.gupta 33
 
31753 tejbeer 34
import com.smartdukaan.cron.migrations.RunOnceTasks;
35
import com.smartdukaan.cron.scheduled.CaptchaService;
36
import com.smartdukaan.cron.scheduled.InvestmentRelatedTasks;
37
import com.smartdukaan.cron.scheduled.OnBoardingRelatedSchelduleTask;
38
import com.smartdukaan.cron.scheduled.Reconciliation;
39
import com.smartdukaan.cron.scheduled.ScheduledTasks;
40
import com.smartdukaan.cron.scheduled.StandAlone;
41
import com.smartdukaan.cron.scheduled.TicketRelatedScheduledTask;
42
import com.smartdukaan.cron.scheduled.b2b.Listing;
43
import com.smartdukaan.cron.scheduled.leadsync.LeadSyncRunner;
44
import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
45
import com.spice.profitmandi.dao.repository.cs.CsService;
46
import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
47
import com.spice.profitmandi.dao.util.ContentPojoPopulator;
48
import com.spice.profitmandi.service.integrations.samsung.upgradeoffer.UpgradeOfferService;
23724 amit.gupta 49
 
23723 amit.gupta 50
@SpringBootApplication
32214 jai.hind 51
 
52
//@EnableScheduling
23755 amit.gupta 53
@ComponentScan("com.smartdukaan.cron.*, com.spice.profitmandi.common.*")
24122 govind 54
public class Application implements ApplicationRunner {
55
 
31753 tejbeer 56
    private static final Logger LOGGER = LogManager.getLogger(Application.class);
24122 govind 57
 
31753 tejbeer 58
    @Autowired
59
    LeadSyncRunner leadSyncRunner;
30120 amit.gupta 60
 
31753 tejbeer 61
    @Autowired
62
    StandAlone standAlone;
30209 amit.gupta 63
 
31753 tejbeer 64
    @Autowired
65
    UpgradeOfferService upgradeOfferService;
27392 amit.gupta 66
 
31753 tejbeer 67
    @Autowired
68
    private TicketRelatedScheduledTask ticketRelatedScheduledTask;
28368 tejbeer 69
 
31753 tejbeer 70
    @Autowired
71
    private OnBoardingRelatedSchelduleTask onBoardingRelatedSchelduleTask;
28921 tejbeer 72
 
31753 tejbeer 73
    @Autowired
74
    private InvestmentRelatedTasks investmentRelatedTasks;
27392 amit.gupta 75
 
31753 tejbeer 76
    @Autowired
77
    private CsService csService;
29814 tejbeer 78
 
31753 tejbeer 79
    @Autowired
80
    private FofoOrderItemRepository fofoOrderItemRepository;
24603 amit.gupta 81
 
31753 tejbeer 82
    @Autowired
83
    private ContentPojoPopulator contentPojoPopulator;
29361 tejbeer 84
 
31753 tejbeer 85
    @Autowired
86
    private Listing listing;
24122 govind 87
 
88
 
31753 tejbeer 89
    public static void main(String[] args) throws Throwable {
90
        try {
91
            new SpringApplicationBuilder(Application.class).web(WebApplicationType.NONE).run(args);
92
        } catch (Throwable t) {
93
            t.printStackTrace();
94
        }
95
    }
28389 amit.gupta 96
 
31753 tejbeer 97
    @Bean
98
    public static PropertySourcesPlaceholderConfigurer propertyConfigurer1() {
99
        LOGGER.info("Called Configuration");
100
        PropertySourcesPlaceholderConfigurer propertySourcesPlaceholderConfigurer = new PropertySourcesPlaceholderConfigurer();
101
        propertySourcesPlaceholderConfigurer.setLocation(new ClassPathResource("/META-INF/env.properties"));
102
        return propertySourcesPlaceholderConfigurer;
103
    }
28389 amit.gupta 104
 
31753 tejbeer 105
    @Bean(name = "veloctyEngine")
106
    public VelocityEngine velocityEngine() throws VelocityException, IOException {
107
        VelocityEngineFactoryBean factory = new VelocityEngineFactoryBean();
28389 amit.gupta 108
 
31753 tejbeer 109
        Properties velocityProperties = new Properties();
110
        velocityProperties.put("resource.loader", "class");
111
        velocityProperties.put("class.resource.loader.class", "org.apache.velocity.runtime.resource.loader.ClasspathResourceLoader");
112
        velocityProperties.put("file.resource.loader.cache", true);
113
        velocityProperties.put("file.resource.loader.unicode", true);
114
        velocityProperties.put("input.encoding", "UTF-8");
115
        velocityProperties.put("output.encoding", "UTF-8");
116
        velocityProperties.put("response.encoding", "UTF-8");
117
        velocityProperties.put("overrideLogging", true);
28389 amit.gupta 118
 
31753 tejbeer 119
        // velocityProperties.put("file.resource.loader.path", ".");
28389 amit.gupta 120
 
31753 tejbeer 121
        factory.setVelocityProperties(velocityProperties);
28389 amit.gupta 122
 
31753 tejbeer 123
        return factory.createVelocityEngine();
23723 amit.gupta 124
 
31753 tejbeer 125
    }
24122 govind 126
 
31753 tejbeer 127
    @Bean(name = "mailSender")
128
    @Primary
129
    public JavaMailSender sendGridMailSender() {
130
        JavaMailSenderImpl mailSender = new JavaMailSenderImpl();
24122 govind 131
 
31753 tejbeer 132
        // Using gmail
133
        mailSender.setHost("smtp.sendgrid.net");
134
        mailSender.setPort(587);
135
        mailSender.setUsername("apikey");
136
        mailSender.setPassword("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");
24122 govind 137
 
31753 tejbeer 138
        Properties javaMailProperties = new Properties();
139
        javaMailProperties.put("mail.smtp.starttls.enable", "false");
140
        javaMailProperties.put("mail.smtp.auth", "true");
141
        javaMailProperties.put("mail.transport.protocol", "smtp");
142
        // javaMailProperties.put("mail.debug", "true");// Prints out everything on
143
        // screen
24122 govind 144
 
31753 tejbeer 145
        mailSender.setJavaMailProperties(javaMailProperties);
146
        return mailSender;
147
    }
23935 amit.gupta 148
 
31753 tejbeer 149
    @Bean
150
    public JavaMailSender googleMailSender() {
151
        JavaMailSenderImpl mailSender = new JavaMailSenderImpl();
152
        // Using gmail
153
        mailSender.setHost("smtp.gmail.com");
154
        mailSender.setPort(587);
155
        mailSender.setUsername("build@shop2020.in");
156
        mailSender.setPassword("cafe@nes");
24122 govind 157
 
31753 tejbeer 158
        Properties javaMailProperties = new Properties();
159
        javaMailProperties.put("mail.smtp.starttls.enable", "true");
160
        javaMailProperties.put("mail.smtp.auth", "true");
161
        javaMailProperties.put("mail.transport.protocol", "smtp");
162
        javaMailProperties.put("mail.debug", "true");// Prints out everything on screen
163
        mailSender.setJavaMailProperties(javaMailProperties);
164
        return mailSender;
165
    }
24848 amit.gupta 166
 
31753 tejbeer 167
    @Autowired
168
    private RunOnceTasks runOnceTasks;
24122 govind 169
 
31753 tejbeer 170
    @Autowired
171
    private ScheduledTasks scheduledTasks;
30335 amit.gupta 172
 
31753 tejbeer 173
    @Autowired
174
    private Reconciliation reconciliation;
30309 amit.gupta 175
 
31753 tejbeer 176
    @Autowired
177
    CaptchaService captchaService;
28921 tejbeer 178
 
31753 tejbeer 179
    @Override
180
    public void run(ApplicationArguments args) throws Exception {
32008 amit.gupta 181
        //scheduledTasks.test();
182
        //System.exit();
31753 tejbeer 183
        LOGGER.info("Called run method");
184
        if (args.containsOption("tc")) {
185
            System.out.println("Toffee service called");
186
            scheduledTasks.toffeeRollback();
187
            System.exit(0);
188
        }
189
        if (args.containsOption("bag")) {
190
            System.out.println("Bag service called");
191
            runOnceTasks.testBag();
192
            System.exit(0);
193
        }
29814 tejbeer 194
 
31753 tejbeer 195
        if (args.containsOption("rw")) {
196
            System.out.println("Reverse wallet");
197
            scheduledTasks.reverseWallet();
198
            System.exit(0);
199
        }
200
        if (args.containsOption("sendIndentTertiary")) {
201
            System.out.println("sendIndentTertiary");
202
            scheduledTasks.sendIndentTertiary();
203
            System.exit(0);
204
        }
205
        if (args.containsOption("checkPartnerActiveStore")) {
206
            System.out.println("checkPartnerActiveStore");
207
            scheduledTasks.checkPartnerActiveStore();
208
            System.exit(0);
209
        }
29800 manish 210
 
31753 tejbeer 211
        if (args.containsOption("selectFinServiceFollowUpDateByCurrDate")) {
212
            System.out.println("selectfinServiceFollowUpDateByCurrDate");
28368 tejbeer 213
 
31753 tejbeer 214
            scheduledTasks.selectFinServiceFollowUpDateByCurrDate(LocalDate.now());
215
            System.exit(0);
216
        }
25073 amit.gupta 217
 
31753 tejbeer 218
        if (args.containsOption("addHdfcPayment")) {
219
            runOnceTasks.addPayment();
220
            System.exit(0);
221
        }
222
        if (args.containsOption("processSchemeOut")) {
223
            System.out.println("Process schemeOut");
224
            int orderId = Integer.parseInt(args.getOptionValues("orderid").get(0));
225
            int fofoId = Integer.parseInt(args.getOptionValues("fofoid").get(0));
226
            runOnceTasks.processSchemeOut(fofoId, orderId);
227
            System.exit(0);
228
        }
229
        if (args.containsOption("at")) {
230
            System.out.println("Toffee service called");
231
            ticketRelatedScheduledTask.alertforTicket();
232
            System.exit(0);
233
        }
234
        if (args.containsOption("et")) {
235
            ticketRelatedScheduledTask.escalateTicket();
236
            ;
237
            System.exit(0);
238
        }
239
        if (args.containsOption("sr")) {
240
            List<String> schemeIds = args.getOptionValues("schemeId");
241
            System.out.println(schemeIds);
242
            scheduledTasks.schemeRollback(schemeIds);
243
            System.exit(0);
244
        }
245
        if (args.containsOption("processActivation")) {
246
            scheduledTasks.processActivation();
247
            System.exit(0);
248
        }
249
        if (args.containsOption("sendAttendanceMorningAlert")) {
250
            scheduledTasks.sendAttendanceMorningAlert();
251
            System.exit(0);
252
        }
253
        if (args.containsOption("sendAttendanceEveningAlert")) {
254
            scheduledTasks.sendAttendanceEveningAlert();
255
            System.exit(0);
256
        }
25721 tejbeer 257
 
31753 tejbeer 258
        if (args.containsOption("checkRazorPayPaymentStatus")) {
259
            scheduledTasks.checkRazorPayPaymentStatus();
260
            System.exit(0);
261
        }
262
        if (args.containsOption("grouping")) {
263
            scheduledTasks.grouping();
264
            System.exit(0);
265
        }
266
        if (args.containsOption("fixWallet")) {
267
            runOnceTasks.fixWallet();
268
            System.exit(0);
269
        }
270
        if (args.containsOption("reconcileExpiredFixedSchemes")) {
271
            reconciliation.reconcileExpiredFixedSchemes();
272
            System.exit(0);
273
        }
274
        if (args.containsOption("dailyReconciliation")) {
275
            if (args.containsOption("date")) {
276
                LocalDate date = LocalDate.parse(args.getOptionValues("date").get(0));
277
                reconciliation.dailyReconciliation(date);
278
            } else {
279
                reconciliation.dailyReconciliation(LocalDate.now().minusDays(1));
280
            }
281
            System.exit(0);
282
        }
283
        /*
284
         * if (args.containsOption("test")) { schemeService.processSchemeIn(9243,
285
         * 175138102); throw new Exception(); }
286
         */
287
        if (args.containsOption("fixSchemePayouts")) {
28921 tejbeer 288
 
31753 tejbeer 289
            runOnceTasks.fixSchemePayouts();
290
            System.exit(0);
291
        }
292
        if (args.containsOption("sendNotification")) {
293
            scheduledTasks.sendNotification();
294
            System.exit(0);
295
        }
26291 tejbeer 296
 
31753 tejbeer 297
        if (args.containsOption("ticketClosed")) {
298
            scheduledTasks.ticketClosed();
299
            System.exit(0);
300
        }
28207 tejbeer 301
 
31753 tejbeer 302
        if (args.containsOption("getVendorWarehouses")) {
303
            int warehouseId = Integer.parseInt(args.getOptionValues("warehouseId").get(0));
304
            scheduledTasks.getVendorWarehouses(warehouseId);
305
            System.exit(0);
306
        }
29776 tejbeer 307
 
31753 tejbeer 308
        if (args.containsOption("checkfocusedModelInPartnerStock")) {
309
            scheduledTasks.checkfocusedModelInPartnerStock();
310
            System.exit(0);
311
        }
29451 manish 312
 
31753 tejbeer 313
        if (args.containsOption("checkImeiActivation")) {
314
            scheduledTasks.checkImeiActivation();
315
            System.exit(0);
316
        }
29776 tejbeer 317
 
31753 tejbeer 318
        if (args.containsOption("checkTecnoImeiActivation")) {
29776 tejbeer 319
 
31753 tejbeer 320
            LocalDate dateTechno = LocalDate.now();
29532 manish 321
 
31753 tejbeer 322
            int days = 25;
323
            if (args.containsOption("days")) {
324
                days = Integer.parseInt(args.getOptionValues("days").get(0));
325
            }
326
            scheduledTasks.checkTecnoImeiActivation(dateTechno, days);
327
            System.exit(0);
328
        }
28921 tejbeer 329
 
31753 tejbeer 330
        if (args.containsOption("checkItelImeiActivation")) {
331
            LocalDate dateItel = LocalDate.now();
332
            int days = 25;
333
            if (args.containsOption("days")) {
334
                days = Integer.parseInt(args.getOptionValues("days").get(0));
335
            }
336
            scheduledTasks.checkItelImeiActivation(dateItel, days);
337
            System.exit(0);
338
        }
28921 tejbeer 339
 
31753 tejbeer 340
        if (args.containsOption("partnerProblemAlert")) {
341
            scheduledTasks.partnerProblemAlert();
342
            System.exit(0);
343
        }
344
        if (args.containsOption("notify")) {
345
            if (args.containsOption("fofoId")) {
346
                int fofoId = Integer.parseInt(args.getOptionValues("fofoId").get(0));
347
                scheduledTasks.sendDailySalesNotificationToPartner(fofoId);
348
            }
349
            System.exit(0);
350
        }
351
        if (args.containsOption("findMismatchesInIndent")) {
352
            runOnceTasks.findMismatchesInIndent();
353
            System.exit(0);
354
        }
29035 tejbeer 355
 
31753 tejbeer 356
        if (args.containsOption("onboardingEventDelays")) {
357
            onBoardingRelatedSchelduleTask.onboardingEventDelays();
358
            System.exit(0);
359
        }
28982 tejbeer 360
 
31753 tejbeer 361
        if (args.containsOption("onBoardingCompleteEventEmail")) {
362
            onBoardingRelatedSchelduleTask.onBoardingCompleteEventEmail();
363
            System.exit(0);
364
        }
28921 tejbeer 365
 
31753 tejbeer 366
        if (args.containsOption("onBoardingDocumentsPending")) {
367
            onBoardingRelatedSchelduleTask.onBoardingDocumentsPending();
368
            System.exit(0);
369
        }
370
        if (args.containsOption("onBoardingMigration")) {
371
            onBoardingRelatedSchelduleTask.onBoardingMigration();
372
            System.exit(0);
373
        }
28921 tejbeer 374
 
31753 tejbeer 375
        if (args.containsOption("advancePaymentPendingAlert")) {
376
            onBoardingRelatedSchelduleTask.advancePaymentPendingAlert();
377
            System.exit(0);
378
        }
28963 tejbeer 379
 
31753 tejbeer 380
        if (args.containsOption("fullPaymentPendingAlert")) {
381
            onBoardingRelatedSchelduleTask.fullPaymentPendingAlert();
382
            System.exit(0);
383
        }
29308 tejbeer 384
 
31753 tejbeer 385
        if (args.containsOption("advancePaymentPendinglegalAlert")) {
386
            onBoardingRelatedSchelduleTask.advancePaymentPendinglegalAlert();
387
            System.exit(0);
388
        }
31117 tejbeer 389
 
31753 tejbeer 390
        if (args.containsOption("markDelhiveryOrderDelivered")) {
391
            scheduledTasks.markDelhiveryOrderDelivered();
392
            System.exit(0);
393
        }
29255 tejbeer 394
 
31753 tejbeer 395
        if (args.containsOption("markBlueDartOrderDelivered")) {
396
            scheduledTasks.markBlueDartOrderDelivered();
397
            System.exit(0);
398
        }
29255 tejbeer 399
 
31753 tejbeer 400
        if (args.containsOption("mergingdata")) {
401
            onBoardingRelatedSchelduleTask.mergingdata();
402
            System.exit(0);
403
        }
404
        if (args.containsOption("brandingAlert")) {
405
            onBoardingRelatedSchelduleTask.brandingAlert();
406
            System.exit(0);
407
        }
31089 amit.gupta 408
 
31753 tejbeer 409
        if (args.containsOption("storeTimelinePromoterPending")) {
410
            onBoardingRelatedSchelduleTask.storeTimelinePromoterPending();
411
            System.exit(0);
412
        }
31249 tejbeer 413
 
31753 tejbeer 414
        if (args.containsOption("ppl")) {
415
            runOnceTasks.printPendingLeads();
416
            System.exit(0);
417
        }
31249 tejbeer 418
 
31753 tejbeer 419
        if (args.containsOption("sweets")) {
420
            runOnceTasks.getSweet();
421
        }
422
        if (args.containsOption("notifyAll")) {
423
            scheduledTasks.sendDailySalesNotificationToPartner(null);
424
            System.exit(0);
425
        }
31249 tejbeer 426
 
31753 tejbeer 427
        if (args.containsOption("monthlyTargetForInternalTeam")) {
428
            scheduledTasks.monthlyTargetForInternalTeam();
429
            System.exit(0);
430
        }
31249 tejbeer 431
 
31753 tejbeer 432
        if (args.containsOption("monthlyTargetForPartner")) {
433
            scheduledTasks.monthlyTargetForPartner();
434
            System.exit(0);
435
        }
28921 tejbeer 436
 
31753 tejbeer 437
        if (args.containsOption("hygineAlertForPartner")) {
438
            scheduledTasks.hygineAlertForPartner();
439
            System.exit(0);
440
        }
28921 tejbeer 441
 
31753 tejbeer 442
        if (args.containsOption("hygineAlertForInternalTeam")) {
443
            scheduledTasks.hygineAlertForInternalTeam();
444
            System.exit(0);
445
        }
446
 
447
        if (args.containsOption("OutSchemeReco")) {
448
            scheduledTasks.dryRunOutSchemeReco();
449
            // runOnceTasks.migrateChallansToInvoices();
450
            // reconciliation.dailyReconciliation();
451
            System.exit(0);
452
        }
453
        if (args.containsOption("dryRunSchemeReco")) {
454
            scheduledTasks.dryRunSchemeReco();
455
            // runOnceTasks.migrateChallansToInvoices();
456
            // reconciliation.dailyReconciliation();
457
            System.exit(0);
458
        }
459
        if (args.containsOption("OutReco1")) {
460
            scheduledTasks.dryRunSchemeOutReco1();
461
            System.exit(0);
462
        }
32214 jai.hind 463
 
464
        if (args.containsOption("checkItelImeiActivationNew")) {
465
            scheduledTasks.checkItelImeiActivationNew(LocalDate.now(), 15);
466
            System.exit(0);
467
        }
31753 tejbeer 468
        if (args.containsOption("once")) {
469
            if (args.containsOption("cancelOnceAssist")) {
470
                if (args.containsOption("invoiceNumber")) {
471
                    String oneAssistInvoiceNumber = args.getOptionValues("invoiceNumber").get(0);
472
                    runOnceTasks.cancelOnceAssist(oneAssistInvoiceNumber);
473
                }
474
 
475
            }
476
            if (args.containsOption("1")) {
477
                if (args.containsOption("test")) {
31618 amit.gupta 478
                    //scheduledTasks.sendPartnerInvestmentDetails(args.getOptionValues("email"));
31753 tejbeer 479
                    System.out.println("Calling test method");
32214 jai.hind 480
                 //  scheduledTasks.test();
32083 tejbeer 481
 
482
 
483
                    if (args.containsOption("migrateVendorItemPricing")) {
484
                        scheduledTasks.migrateVendorItemPricing();
485
                        System.exit(0);
486
                    }
487
 
488
 
489
                    if (args.containsOption("approveVendorCatalogPricing")) {
490
                        scheduledTasks.approveVendorCatalogPricing();
491
                        System.exit(0);
492
                    }
32080 tejbeer 493
                } else if (args.containsOption("test1")) {
32008 amit.gupta 494
                    scheduledTasks.test1();
32147 amit.gupta 495
                }else {
31753 tejbeer 496
                    System.out.println("Called sendPartnerInvestmentDetails");
497
                    scheduledTasks.sendPartnerInvestmentDetails();
498
                }
499
                System.exit(0);
500
            }
501
            if (args.containsOption("2")) {
502
                if (args.containsOption("test")) {
503
                    String[] emails = new String[args.getOptionValues("email").size()];
504
                    scheduledTasks.sendAgeingReport(args.getOptionValues("email").toArray(emails));
505
                } else {
506
                    scheduledTasks.sendAgeingReport();
507
                }
508
                System.exit(0);
509
            }
510
            if (args.containsOption("3")) {
511
                if (args.getOptionNames().contains("offset")) {
512
                    int offset = Integer.parseInt(args.getOptionValues("offset").get(0));
513
                    if (args.getOptionNames().contains("days")) {
514
                        int durationDays = Integer.parseInt(args.getOptionValues("days").get(0));
515
                        scheduledTasks.processScheme(offset, durationDays, args.containsOption("dryRun"));
516
                    } else {
517
                        scheduledTasks.processScheme(offset, args.containsOption("dryRun"));
518
                    }
519
                } else if (args.containsOption("catalogid")) {
520
                    // scheduledTasks.processSchemeForModel(args.getOptionValues("catalogid").get(0));
521
                } else {
522
                    scheduledTasks.processScheme(args.containsOption("dryRun"));
523
                }
524
                System.exit(0);
525
            }
526
            if (args.containsOption("4")) {
527
                scheduledTasks.evaluateExcessSchemeOut();
528
            }
529
            if (args.containsOption("5")) {
530
                int offset = Integer.parseInt(args.getOptionValues("offset").get(0));
531
                scheduledTasks.processScheme(offset, args.containsOption("dryRun"));
532
                System.exit(0);
533
            }
534
            if (args.containsOption("cancelOrder")) {
535
                List<String> invoiceNumbers = args.getOptionValues("invoiceNumber");
536
                runOnceTasks.cancelOrder(invoiceNumbers);
537
            }
538
            if (args.containsOption("migratePurchase")) {
539
                runOnceTasks.migratePurchase();
540
            }
541
            if (args.containsOption("migratepd")) {
542
                scheduledTasks.moveImeisToPriceDropImeis();
543
            }
544
            if (args.containsOption("walletmismatch")) {
545
                scheduledTasks.walletmismatch();
546
            }
547
            if (args.containsOption("schemewalletmismatch")) {
548
                scheduledTasks.schemewalletmismatch();
549
            }
550
            if (args.containsOption("gst")) {
551
                scheduledTasks.gst();
552
            }
553
            if (args.containsOption("mailDashboardScreenshots")) {
554
                runOnceTasks.mailDashboardScreenshots();
555
            }
556
            if (args.containsOption("notifyLead")) {
557
                scheduledTasks.notifyLead();
558
                scheduledTasks.notifyVisits();
559
            }
560
            if (args.containsOption("fixgrn")) {
561
                runOnceTasks.fixGrn();
562
            }
563
            if (args.containsOption("pbfix")) {
564
                runOnceTasks.pbfix();
565
            }
566
            if (args.containsOption("mongom")) {
567
                runOnceTasks.mongom();
568
            }
569
            if (args.containsOption("processPd")) {
570
                int priceDropId = Integer.parseInt(args.getOptionValues("processPd").get(0));
571
                runOnceTasks.processPd(priceDropId);
572
            }
573
            if (args.containsOption("samsung")) {
574
                if (args.containsOption("ym")) {
575
                    int ym = Integer.parseInt(args.getOptionValues("ym").get(0));
576
                    runOnceTasks.fetchImeiActivation(ym);
577
                }
578
                runOnceTasks.fetchImeiActivation(0);
579
            }
580
            if (args.containsOption("fixdupimeigrn")) {
581
                runOnceTasks.fixDupGrns();
582
            }
583
            if (args.containsOption("cancel")) {
584
                runOnceTasks.cancelDn(args.getOptionValues("dn").get(0));
585
            }
586
            if (args.containsOption("fixScheme")) {
587
                runOnceTasks.fixScheme();
588
            }
589
            if (args.containsOption("syncLeads")) {
590
                leadSyncRunner.syncLeads();
591
            }
592
            if (args.containsOption("testCs")) {
593
                int category = Integer.parseInt(args.getOptionValues("category").get(0));
594
                EscalationType escalationType = EscalationType.valueOf(args.getOptionValues("escalation").get(0));
595
                int fofoId = Integer.parseInt(args.getOptionValues("fofoid").get(0));
596
                csService.getAuthUserId(category, escalationType, fofoId);
597
            }
598
            if (args.containsOption("duporder")) {
599
                runOnceTasks.removeDuplicateOrders();
600
            }
601
            if (args.containsOption("createDummyInvoices")) {
602
                runOnceTasks.createDummyInvoices();
603
            }
28921 tejbeer 604
 
31753 tejbeer 605
            if (args.containsOption("createGeofence")) {
606
                runOnceTasks.createGeofence();
607
            }
608
            if (args.containsOption("getAllGeofences")) {
609
                runOnceTasks.getAllGeofences();
610
            }
611
            if (args.containsOption("payMonthlyInvestment")) {
612
                investmentRelatedTasks.payMonthlyInvestment();
613
            }
614
            if (args.containsOption("evaluateActualInvestmentPayout")) {
615
                investmentRelatedTasks.evaluateActualInvestmentPayout();
616
            }
617
            if (args.containsOption("deleteGeofences")) {
618
                List<String> geofenceIds = args.getOptionValues("geofenceId");
619
                runOnceTasks.deleteGeofences(geofenceIds);
620
            }
621
            if (args.containsOption("createOffers")) {
622
                if (args.containsOption("fileName")) {
623
                    String fileName = args.getOptionValues("fileName").get(0);
624
                    FileInputStream stream = new FileInputStream(fileName);
625
                    runOnceTasks.createOffers(stream);
626
                }
627
            }
628
            if (args.containsOption("schemeout")) {
629
                if (args.containsOption("invoices")) {
630
                    String invoicesString = args.getOptionValues("invoices").get(0);
631
                    List<String> invoices = Arrays.asList(invoicesString.split(","));
632
                    scheduledTasks.processSchemeOut(invoices);
633
                }
634
            }
635
            if (args.containsOption("schemein")) {
636
                if (args.containsOption("invoices")) {
637
                    String invoicesString = args.getOptionValues("invoices").get(0);
638
                    List<String> invoices = Arrays.asList(invoicesString.split(","));
639
                    scheduledTasks.processSchemeIn(invoices);
640
                }
641
            }
28921 tejbeer 642
 
31753 tejbeer 643
            if (args.containsOption("fixScans")) {
644
                runOnceTasks.fixScans();
645
            }
646
            if (args.containsOption("fixPrebookingOrderGrn")) {
647
                runOnceTasks.genericCreateCurrentInventorySnapshot();
648
            }
649
            if (args.containsOption("fixOurSerialized")) {
650
                if (args.containsOption("orderIds")) {
651
                    String orderIdsString = args.getOptionValues("orderIds").get(0);
652
                    List<Integer> orderIds = Arrays.asList(orderIdsString.split(",")).stream().map(x -> Integer.parseInt(x)).collect(Collectors.toList());
653
                    // runOnceTasks.fixOurSerialized(orderIds);
654
                }
655
            }
29776 tejbeer 656
 
31753 tejbeer 657
            if (args.containsOption("reverseMaa")) {
658
                runOnceTasks.reverseMaa();
659
            }
29776 tejbeer 660
 
31753 tejbeer 661
            if (args.containsOption("fixOffer")) {
662
                runOnceTasks.fixOffer();
663
            }
29794 tejbeer 664
 
31753 tejbeer 665
            if (args.containsOption("opporeno")) {
666
                runOnceTasks.opporeno();
667
            }
30309 amit.gupta 668
 
31753 tejbeer 669
            if (args.containsOption("fixorders")) {
670
                runOnceTasks.fixOrders();
671
            }
672
            if (args.containsOption("fixreservations")) {
673
                runOnceTasks.fixReservations();
674
            }
675
            if (args.containsOption("addinvestment")) {
676
                runOnceTasks.addInvestment();
677
            }
678
            if (args.containsOption("brandregion")) {
679
                runOnceTasks.brandRegion();
680
            }
681
            if (args.containsOption("rollOutUpgardedMargins")) {
682
                scheduledTasks.rollOutUpgardedMargins();
683
            }
684
            if (args.containsOption("rollOutUpgardedMarginsNextMonth")) {
685
                scheduledTasks.rollOutUpgardedMarginsNextMonth();
686
            }
687
            if (args.containsOption("checkCancellationMargin")) {
688
                scheduledTasks.checkCancellationMargin();
689
            }
690
            if (args.containsOption("reviewUncontactablePartner")) {
691
                scheduledTasks.reviewUncontactablePartner();
692
            }
693
            if (args.containsOption("sendWelcomeEmail")) {
694
                onBoardingRelatedSchelduleTask.sendWelcomeEmail();
695
            }
29814 tejbeer 696
 
31753 tejbeer 697
            if (args.containsOption("partnerOnboardingLegalMigration")) {
698
                onBoardingRelatedSchelduleTask.partnerOnboardingLegalMigration();
699
            }
31031 amit.gupta 700
 
31753 tejbeer 701
            if (args.containsOption("addKycLegalMigration")) {
702
                onBoardingRelatedSchelduleTask.addKycLegalMigration();
703
            }
29776 tejbeer 704
 
705
 
31753 tejbeer 706
            if (args.containsOption("pushDataToSolr")) {
707
                listing.pushDataToSolr();
708
            }
30120 amit.gupta 709
 
31753 tejbeer 710
            if (args.containsOption("testGstPro")) {
711
                System.out.println("TestGstProc called");
712
                try {
713
                    runOnceTasks.updateIrnsToInvoices();
714
                } catch (Exception e) {
715
                    e.printStackTrace();
716
                }
717
            }
29308 tejbeer 718
 
31753 tejbeer 719
            if (args.containsOption("reverseSchemeCancelInvoice")) {
720
                if (args.containsOption("invoice")) {
721
                    String invoice = args.getOptionValues("invoice").get(0);
722
                    runOnceTasks.reverseSchemes(invoice);
723
                }
724
            }
29863 tejbeer 725
 
31753 tejbeer 726
            if (args.containsOption("reverseInvalidActivation")) {
727
                if (args.containsOption("inventoryids")) {
728
                    String inventoryItemIdsString = args.getOptionValues("inventoryids").get(0);
729
                    List<Integer> inventoryItemIds = new ArrayList<>();
730
                    for (String inventoryItemIdString : inventoryItemIdsString.split(",")) {
731
                        int inventoryItemId = Integer.parseInt(inventoryItemIdString.trim());
732
                        inventoryItemIds.add(inventoryItemId);
733
                    }
734
                    runOnceTasks.reverseInvalidActivation(inventoryItemIds);
735
                }
736
            }
29863 tejbeer 737
 
31753 tejbeer 738
            if (args.containsOption("partnerWiseCreditAccount")) {
739
                scheduledTasks.partnerWiseCreditAccount();
740
            }
741
            if (args.containsOption("runme")) {
742
                runOnceTasks.runMe();
30209 amit.gupta 743
 
31753 tejbeer 744
            }
745
            if (args.containsOption("" + "")) {
746
                upgradeOfferService.authenticateUser();
30449 amit.gupta 747
 
31753 tejbeer 748
            }
749
            if (args.containsOption("mandiiUser")) {
750
                runOnceTasks.mandiiUser(args.getOptionValues("firstName").get(0), args.getOptionValues("lastName").get(0), args.getOptionValues("pan").get(0), args.getOptionValues("dob").get(0), args.getOptionValues("aadhaar").get(0), args.getOptionValues("gender").get(0), args.getOptionValues("father").get(0));
30335 amit.gupta 751
 
31753 tejbeer 752
            }
30335 amit.gupta 753
 
31753 tejbeer 754
            if (args.containsOption("mandiiUsers")) {
755
                if (args.containsOption("pan")) {
756
                    runOnceTasks.mandiiUsers(args.getOptionValues("pan").get(0));
757
                } else {
758
                    runOnceTasks.mandiiUsers();
759
                }
30313 amit.gupta 760
 
31753 tejbeer 761
            }
30576 amit.gupta 762
 
31753 tejbeer 763
            if (args.containsOption("checkOppoImeiStatus")) {
764
                try {
765
                    standAlone.checkOppoImeiStatus();
766
                } catch (Exception e) {
767
                    e.printStackTrace();
768
                }
769
            }
30616 amit.gupta 770
 
31753 tejbeer 771
            /*
772
             * if (args.containsOption("checkRealmeImeiStatus")) { try {
773
             * standAlone.checkRealmeImeiStatus(); } catch (Exception e) {
774
             * e.printStackTrace(); } }
775
             */
30616 amit.gupta 776
 
31753 tejbeer 777
            if (args.containsOption("amazonPurchase")) {
778
                try {
779
                    runOnceTasks.amazonPurchase();
780
                } catch (Exception e) {
781
                    e.printStackTrace();
782
                }
783
            }
30641 amit.gupta 784
 
31753 tejbeer 785
            if (args.containsOption("getCaptchaCode")) {
786
                try {
787
                    captchaService.getCaptchaCode("/home/amit/Desktop/generatingCodes.jpg");
788
                } catch (Exception e) {
789
                    e.printStackTrace();
790
                }
791
            }
30641 amit.gupta 792
 
31753 tejbeer 793
            if (args.containsOption("testIrnLive")) {
794
                try {
795
                    runOnceTasks.testIrnLive(args.getOptionValues("invoiceNumber").get(0));
796
                } catch (Exception e) {
797
                    e.printStackTrace();
798
                }
799
            }
30659 amit.gupta 800
 
31753 tejbeer 801
            if (args.containsOption("createoffercriteria")) {
802
                try {
803
                    runOnceTasks.createOfferCriteria();
804
                } catch (Exception e) {
805
                    e.printStackTrace();
806
                }
807
            }
30659 amit.gupta 808
 
31753 tejbeer 809
            if (args.containsOption("fix-price-drops")) {
810
                runOnceTasks.fixPriceDrop();
30739 amit.gupta 811
 
31753 tejbeer 812
            }
29035 tejbeer 813
 
31753 tejbeer 814
            if (args.containsOption("processSchemeByIds")) {
815
                List<String> schemeIds = Arrays.asList(args.getOptionValues("ids").get(0).split(","));
816
                List<Integer> schemeIdsInt = schemeIds.stream().map(x -> Integer.parseInt(x)).collect(Collectors.toList());
817
                runOnceTasks.processSchemeByIds(schemeIdsInt);
30859 tejbeer 818
 
31753 tejbeer 819
            }
30859 tejbeer 820
 
31753 tejbeer 821
            if (args.containsOption("updateSaholicCISTable")) {
822
                runOnceTasks.updateSaholicCISTable();
30859 tejbeer 823
 
31753 tejbeer 824
            }
30859 tejbeer 825
 
31753 tejbeer 826
            if (args.containsOption("mapbag")) {
827
                runOnceTasks.mapBag();
828
            }
30859 tejbeer 829
 
31753 tejbeer 830
            System.exit(0);
831
        }
30859 tejbeer 832
 
31753 tejbeer 833
        if (args.containsOption("calculateInterestAccured")) {
30929 tejbeer 834
 
31753 tejbeer 835
            scheduledTasks.calculateInterestAccured();
836
            System.exit(0);
837
        }
30929 tejbeer 838
 
31753 tejbeer 839
        if (args.containsOption("loanSettlement")) {
30890 amit.gupta 840
 
31753 tejbeer 841
            scheduledTasks.loanSettlement();
842
            System.exit(0);
843
        }
30896 amit.gupta 844
 
31753 tejbeer 845
        if (args.containsOption("dailyLoanAlert")) {
30936 tejbeer 846
 
31753 tejbeer 847
            scheduledTasks.dailyLoanAlert();
848
            System.exit(0);
849
        }
30982 tejbeer 850
 
31753 tejbeer 851
        if (args.containsOption("updatePartnerLimit")) {
852
            scheduledTasks.updatePartnerLimit();
853
            System.exit(0);
854
        }
30982 tejbeer 855
 
31753 tejbeer 856
        if (args.containsOption("notifyDefaultLoans")) {
857
            scheduledTasks.notifyDefaultLoans();
858
            System.exit(0);
859
        }
31446 amit.gupta 860
 
31753 tejbeer 861
        if (args.containsOption("fixinsurance")) {
862
            runOnceTasks.addMissingWalletDebitsForInsurance();
863
            System.exit(0);
864
        }
31604 tejbeer 865
 
31753 tejbeer 866
        if (args.containsOption("processActivatedImeisForSchemes")) {
867
            scheduledTasks.processActivatedImeisForSchemes();
868
            System.exit(0);
869
        }
31604 tejbeer 870
 
31753 tejbeer 871
        if (args.containsOption("notifyLoanDueDateCross")) {
872
            scheduledTasks.notifyLoanDueDateCross();
873
            System.exit(0);
874
        }
31604 tejbeer 875
 
31753 tejbeer 876
        if (args.containsOption("alertForDueDate")) {
877
            scheduledTasks.alertForDueDate();
878
            System.exit(0);
879
        }
31648 tejbeer 880
 
31753 tejbeer 881
        if (args.containsOption("userMobileNumberOptIn")) {
882
            scheduledTasks.userMobileNumberOptIn();
883
            System.exit(0);
884
        }
885
 
886
        if (args.containsOption("fetchParnterStats")) {
887
            scheduledTasks.fetchParnterStats();
888
            System.exit(0);
889
        }
890
 
891
        if (args.containsOption("authUserMobileNumberOptIn")) {
892
            scheduledTasks.authUserMobileNumberOptIn();
893
            System.exit(0);
894
        }
895
        if (args.containsOption("morning")) {
896
            if (args.containsOption("0")) {
897
                scheduledTasks.sendPartnerInvestmentDetails();
898
            }
899
            if (args.containsOption("1")) {
900
                scheduledTasks.sendIndentTertiary();
901
            }
902
            // 0
903
            if (args.containsOption("2")) {
904
                scheduledTasks.calculateInterestAccured();
905
            }
906
            System.out.println("scheduledTasks.calculateInterestAccured()");
907
            // 0
908
            if (args.containsOption("3")) {
909
                scheduledTasks.markDelhiveryOrderDelivered();
910
            }
911
            System.out.println("scheduledTasks.markDelhiveryOrderDelivered()");
912
            // 1
913
            if (args.containsOption("4")) {
914
                scheduledTasks.processActivatedImeisForSchemes();
915
            }
916
            System.out.println("scheduledTasks.processActivatedImeisForSchemes()");
917
            // 2
918
            if (args.containsOption("5")) {
919
                scheduledTasks.processActivation();
920
            }
921
            System.out.println("scheduledTasks.processActivation()");
922
            // 4
923
            if (args.containsOption("6")) {
924
                scheduledTasks.processPriceDrop();
925
            }
926
            System.out.println("scheduledTasks.processPriceDrop()");
927
            // 5
928
            if (args.containsOption("7")) {
929
                scheduledTasks.loanSettlement();
930
            }
931
            System.out.println("scheduledTasks.loanSettlement()");
932
            // 8
933
            if (args.containsOption("8")) {
934
                scheduledTasks.reviewUncontactablePartner();
935
            }
936
            // 9
937
            if (args.containsOption("9")) {
938
                onBoardingRelatedSchelduleTask.storeTimelinePromoterPending();
939
            }
940
            // 9
941
            if (args.containsOption("10")) {
942
                onBoardingRelatedSchelduleTask.advancePaymentPendinglegalAlert();
943
            }
944
            // sendPartnerInvestment
945
            if (args.containsOption("11")) {
946
                scheduledTasks.sendPartnerInvestmentDetails();
947
            }
948
            if (args.containsOption("sendCreditNote")) {
949
                LocalDateTime localDateTime = LocalDateTime.now().minusDays(10);
950
                YearMonth yearMonth = YearMonth.from(localDateTime);
951
                /*
952
                 * if
953
                 * (localDateTime.toLocalDate().equals(yearMonth.atEndOfMonth().getDayOfMonth())
954
                 * && Arrays.asList(20,21,22,23).contains(localDateTime.getHour())) {
955
                 * scheduledTasks.sendCreditNote(yearMonth); }
956
                 */
957
                scheduledTasks.sendCreditNote(yearMonth);
958
            }
959
            System.exit(0);
960
        }
961
    }
24848 amit.gupta 962
}