Subversion Repositories SmartDukaan

Rev

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