Subversion Repositories SmartDukaan

Rev

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