Subversion Repositories SmartDukaan

Rev

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