Subversion Repositories SmartDukaan

Rev

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