Subversion Repositories SmartDukaan

Rev

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