WebSVN – SmartDukaan – Diff – /trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/Application.java

 import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
 import com.spice.profitmandi.dao.repository.cs.CsService;
 import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
 import com.spice.profitmandi.dao.service.shopify.ShopifyProductSyncService;
 import com.spice.profitmandi.dao.util.ContentPojoPopulator;
+import com.spice.profitmandi.service.NotificationService;
+import com.spice.profitmandi.service.integrations.icicilombard.IciciLombardService;
+import com.spice.profitmandi.service.integrations.icicilombard.model.LastTransactionsResponseModel;
 import com.spice.profitmandi.service.integrations.samsung.upgradeoffer.UpgradeOfferService;
 import com.spice.profitmandi.service.mail.MailOutboxService;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.apache.velocity.app.VelocityEngine;
     BatchScheduledTasks batchScheduledTasks;
     @Autowired
     private BeatMissDetectorRunner beatMissDetectorRunner;
+    @Autowired
+    private IciciLombardService iciciLombardService;
     public static void main(String[] args) throws Throwable {
         try {
             WebApplicationType webType = WebApplicationType.SERVLET;
             for (String arg : args) {
                 if (arg.contains("spring.main.web-application-type=none")) {
     KnowlarityCallMonitorScheduler knowlarityCallMonitorScheduler;
     @Autowired
     MailOutboxService mailOutboxService;
+    @Autowired
+    NotificationService notificationService;
     @Override
     public void run(ApplicationArguments args) throws Exception {
         //scheduledTasks.test();
         //System.exit();
         LOGGER.info("Called run method");
         if (args.containsOption("et")) {
             ticketRelatedScheduledTask.escalateTicket();
+            ;
             System.exit(0);
+        }
+        if (args.containsOption("iciciBalance")) {
+            System.out.println("Fetching ICICI CD balance manually");
+            try {
+                LastTransactionsResponseModel response = iciciLombardService.getLastTwentyFiveTransactions(null);
+                System.out.println("Response: " + response);
+                if (response != null
+                        && response.getTransactionsDetails() != null
+                        && !response.getTransactionsDetails().isEmpty()) {
+                    LastTransactionsResponseModel.TransactionDetail latest = response.getTransactionsDetails().get(0);
+                    System.out.println("Current available balance = " + latest.getAvailableBalance()
+                            + " (as of " + latest.getEffectiveDate() + " — status: " + latest.getStatus() + ")");
+                    System.out.println("Last 25 transactions:");
+                    response.getTransactionsDetails().forEach(t -> System.out.println("  " + t));
+                }
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+            System.exit(0);
+        }
         if (args.containsOption("sr")) {
             List<String> schemeIds = args.getOptionValues("schemeId");
             System.out.println(schemeIds);
             scheduledTasks.schemeRollback(schemeIds);
             System.exit(0);
             System.out.println("Processing pending mails...");
             mailOutboxService.processPendingMails();
             System.exit(0);
+        }
+        // Dispatch any notification_schedule rows whose scheduled_timestamp <= now.
+        // Same code path as the hourly cron in NotificationDispatchScheduler, but callable
+        // on demand from dev / staging where the isProd gate normally blocks the cron.
+        // Usage: --dispatchScheduledNotifications [--batch=200]
+        if (args.containsOption("dispatchScheduledNotifications")) {
+            int batch = 200;
+            if (args.containsOption("batch")) {
+                try { batch = Integer.parseInt(args.getOptionValues("batch").get(0)); }
+                catch (Exception ignored) { }
+            }
+            System.out.println("Dispatching due scheduled notifications (batch=" + batch + ")...");
+            int attempted = notificationService.dispatchDueScheduled(batch);
+            System.out.println("Attempted: " + attempted + " row(s)");
+            System.exit(0);
+        }
         if (args.containsOption("ticketClosed")) {
             // Redirected to TicketRelatedScheduledTask which handles auto-close as part of escalateTicket
             ticketRelatedScheduledTask.escalateTicket();
             System.exit(0);
+        }
                 scheduledTasks.rollOutUpgardedMargins(Arrays.asList(175140172, 175140189));
+            }
             if (args.containsOption("pushRbmTargets")) {
                 scheduledTasks.persistRbmTodayTargets();
+            }
+            if (args.containsOption("pushSalesTargets")) {
+                // Run this AFTER pushRbmTargets so today's RBM snapshots exist to roll up.
+                scheduledTasks.persistSalesTodayTargets();
+            }
+            if (args.containsOption("pushSalesTargetsForDate")) {
+                // Backfill / seed for a specific date, e.g. --pushSalesTargetsForDate=2026-08-25
+                LocalDate d = LocalDate.parse(args.getOptionValues("pushSalesTargetsForDate").get(0));
+                scheduledTasks.persistSalesTargetsForDate(d);
+            }
+            if (args.containsOption("pushSalesAchievements")) {
+                // Daily Sales achievement snapshot (audit/history). Independent
+                // of pushSalesTargets — can run any time after orders settle.
+                scheduledTasks.persistSalesTodayAchievements();
+            }
+            if (args.containsOption("pushSalesAchievementsForDate")) {
+                // Backfill / seed for a specific date, e.g. --pushSalesAchievementsForDate=2026-08-25
+                LocalDate d = LocalDate.parse(args.getOptionValues("pushSalesAchievementsForDate").get(0));
+                scheduledTasks.persistSalesAchievementsForDate(d);
+            }
             if (args.containsOption("rollOutUpgardedMarginsNextMonth")) {
                 System.out.println("In rollOutUpgardedMarginsNextMonth");
                 scheduledTasks.rollOutUpgardedMarginsNextMonth(Arrays.asList(175140172, 175140189, 175138897));
+            }
             if (args.containsOption("checkCancellationMargin")) {

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/Application.java – Rev 37480 → 37499