Subversion Repositories SmartDukaan

Rev

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