Subversion Repositories SmartDukaan

Rev

Rev 34632 | Rev 34710 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

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