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

     @Autowired
     private BeatMissDetectorRunner beatMissDetectorRunner;
     @Autowired
+    private com.smartdukaan.cron.scheduled.remarkscore.RemarkScoreRunner remarkScoreRunner;
+    @Autowired
+    private com.smartdukaan.cron.scheduled.remarkscore.DuplicateRemarkDigestRunner duplicateRemarkDigestRunner;
+    @Autowired
     private com.spice.profitmandi.service.AgendaAutoRuleService agendaAutoRuleService;
     @Autowired
     SmartPingService smartPingService;
         } catch (Exception e) {
             LOGGER.error("detectMissedBeats failed", e);
+        }
+    }
+    // Every 30 min: score today's freshly checked-out partner-visit remarks so the
+    // Beat Journey remark-quality flags (#2/#10/#12) stay current. Idempotent — each
+    // remark is scored (committed) exactly once; a re-run scores 0 rows.
+    @Scheduled(fixedRate = 1800000)
+    public void scoreVisitRemarks() {
+        try {
+            remarkScoreRunner.scoreForDate(java.time.LocalDate.now());
+        } catch (Exception e) {
+            LOGGER.error("scoreVisitRemarks failed", e);
+        }
+    }
+    // 09:15 daily: consolidated HR mail of employees who reused one remark across
+    // agendas on more than 3 visits this month (month-to-date, so an offender stays
+    // listed for the rest of the month). Silent on a day when nobody is over the line.
+    @Scheduled(cron = "0 15 9 * * *")
+    public void duplicateRemarkDigest() {
+        try {
+            duplicateRemarkDigestRunner.sendDigestForDate(java.time.LocalDate.now());
+        } catch (Exception e) {
+            LOGGER.error("duplicateRemarkDigest failed", e);
+        }
+    }
     // Nightly PJP agenda sync: evaluate the 5 AUTO agenda rules per partner and
     // open/close user.agenda_instance rows. Scheduled from ScheduledSkeleton at
     // 23:45 — after the 23:30 activation-type cron, so the REVIVAL mirror sees
     // today's state.
     public void updatePjpAgendaInstances() {
+            }
+        }
+    }
-    public void userMobileNumberOptIn() throws Exception {
-        List<FofoStore> fofoStores = fofoStoreRepository.selectActiveStores();
-        List<com.spice.profitmandi.dao.entity.user.User> users = userUserRepository.selectByIds(fofoStores.stream().map(x -> x.getId()).collect(Collectors.toList()));
-        List<Address> addresses = addressRepository.selectByIds(users.stream().map(x -> x.getAddressId()).collect(Collectors.toList()));
-        LOGGER.info("addresses" + addresses);
-        for (Address address : addresses) {
-            notificationService.optIn(address.getPhoneNumber());
-        }
-    }
-    public void authUserMobileNumberOptIn() throws HttpHostConnectException, ProfitMandiBusinessException {
-        List<AuthUser> authUsers = authRepository.selectAllActiveUser();
-        LOGGER.info("authUsers" + authUsers);
-        for (AuthUser authUser : authUsers) {
-            Map<String, String> requestheaders = new HashMap<>();
-            requestheaders.put("Content-Type", "application/x-www-form-urlencoded");
-            Map<String, String> requestParams = new HashMap<>();
-            requestParams.put("userid", String.valueOf(2000215976));
-            requestParams.put("password", "MFRd!BBL");
-            requestParams.put("phone_number", authUser.getMobileNumber());
-            requestParams.put("auth_scheme", "plain");
-            requestParams.put("v", "1.1");
-            requestParams.put("format", "json");
-            requestParams.put("method", "OPT_IN");
-            requestParams.put("channel", "WHATSAPP");
-            String response = restClient.get("https://media.smsgupshup.com/GatewayAPI/rest", requestParams, requestheaders);
-            LOGGER.info("response" + response);
-        }
-    }
     @Autowired
     private HygieneDataRepository hygieneDataRepository;
     public void hygineAlertForPartner() throws ProfitMandiBusinessException, MessagingException, IOException {
             Exception {
         // Sort by lowest dueDate first (most overdue)
         defaultLoans.sort(Comparator.comparing(Loan::getDueDate));
-        String title = "SD Credit Alert!";
         int whatsAppCount = 0;
         for (Loan defaultLoan : defaultLoans) {
             double principal = defaultLoan.getPendingAmount().doubleValue();
             double interest = defaultLoan.getInterestAccrued().doubleValue() - defaultLoan.getInterestPaid().doubleValue();
             double total = principal + interest;
             com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectById(defaultLoan.getFofoId());
             Address address = addressRepository.selectById(user.getAddressId());
-            // WhatsApp: only top 2 most overdue loans
+            // WhatsApp: only top 2 most overdue loans. Days in default and the penalty rate are fixed
+            // copy in the approved template, so only the name and the amount are sent.
             if (whatsAppCount < 2) {
-                String whatsAppMessage = getWhatsAppMessageForDefaultLoan(defaultLoan, total, user.getName());
+                notificationService.sendLoanDefaultAlert(address.getPhoneNumber(), user.getName(),
-                notificationService.sendWhatsappMessage(whatsAppMessage, title, address.getPhoneNumber());
+                        FormattingUtils.formatDecimal(total));
                 whatsAppCount++;
+            }
             String emailMessage = getEmailMessageForDefaultLoan(defaultLoan, principal, interest, total, user.getName());
             String[] email = {user.getEmailId()};
         sb.append("<p>Team SmartDukaan</p>");
         sb.append("</body></html>");
         return sb.toString();
+    }
-    private String getWhatsAppMessageForDefaultLoan(Loan loan, double total, String name) {
-        String formattedAmount = FormattingUtils.formatDecimal(total);
-        long daysInDefault = ChronoUnit.DAYS.between(loan.getPenaltyDate(), LocalDate.now());
-        return String.format(
-                "Dear %s, Your credit payment has been in default for %d days. " +
-                "A penalty interest of %s%% per day is being charged on your outstanding amount of Rs. %s. " +
-                "Please settle immediately to avoid legal action.\n\nTeam SmartDukaan",
-                name, daysInDefault, loan.getPenaltyRate() != null ? loan.getPenaltyRate() : ProfitMandiConstants.NEW_DELAYED_INTEREST_RATE, formattedAmount);
-    }
     @Autowired
     private FofoOpeningStockRepository fofoOpeningStockRepository;
     @Autowired
     private SmartCartService smartCartService;

Subversion Repositories SmartDukaan

(root)//trunk/profitmandi-cron/src/main/java/com/smartdukaan/cron/scheduled/ScheduledTasks.java – Rev 37401 → 37417