Subversion Repositories SmartDukaan

Rev

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