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

 import javax.mail.internet.InternetAddress;
 import javax.mail.internet.MimeMessage;
 import com.smartdukaan.cron.itelImeiActivation.ItelImeiActivationNewService;
 import com.spice.profitmandi.dao.enumuration.transaction.SchemePayoutStatus;
+import com.spice.profitmandi.service.*;
 import org.apache.commons.io.output.ByteArrayOutputStream;
 import org.apache.commons.lang.StringUtils;
 import org.apache.http.client.methods.CloseableHttpResponse;
 import org.apache.http.client.methods.HttpPost;
 import org.apache.http.conn.HttpHostConnectException;
 import com.spice.profitmandi.dao.repository.user.UserRepository;
 import com.spice.profitmandi.dao.repository.warehouse.BilledImeiModel;
 import com.spice.profitmandi.dao.repository.warehouse.BrandRegionMappingRepository;
 import com.spice.profitmandi.dao.repository.warehouse.WarehouseInventoryItemRepository;
 import com.spice.profitmandi.dao.service.solr.FofoSolr;
-import com.spice.profitmandi.service.NotificationService;
-import com.spice.profitmandi.service.PartnerInvestmentService;
-import com.spice.profitmandi.service.PartnerStatsService;
-import com.spice.profitmandi.service.PerformanceService;
 import com.spice.profitmandi.service.integrations.CCAvenuePaymentService;
 import com.spice.profitmandi.service.integrations.RazorpayPaymentService;
 import com.spice.profitmandi.service.integrations.bharti.model.BAGInsuranceModel;
 import com.spice.profitmandi.service.integrations.toffee.ToffeeService;
 import com.spice.profitmandi.service.inventory.AgeingModel;
+                }
+            }
+        }
         if (upgradedCount > 0) {
-            sendMailHtmlFormat(
+            sendMailOfHtmlFormat(googleMailSender,
                     new String[]{"amit.gupta@smartdukaan.com", "tarun.verma@smartdukaan.com", "neeraj.gupta@smartdukaan.com"}, sb.toString(), null, "Few Partners Category have been Upgraded");
         } else {
-            sendMailHtmlFormat(
+            sendMailOfHtmlFormat(googleMailSender,
                     new String[]{"amit.gupta@smartdukaan.com", "tarun.verma@smartdukaan.com", "neeraj.gupta@smartdukaan.com"}, sb.toString(), null, "No partners Category have been upgraded today");
+        }
+    }
     @Autowired
     @Autowired
     StandAlone standAlone;
     @Autowired
     ItelImeiActivationNewService itelImeiActivationNewService;
-    public void checkItelImeiActivationNew(LocalDate date, Integer day)  throws Exception {
+    public void checkItelImeiActivationNew(LocalDate date, Integer day) throws Exception {
         try {
             itelImeiActivationNewService.checkItelImeiActivationNew(date, day);
         } catch (Throwable e) {
             throw new Exception(e);
+        }
+    }
     public void test() throws Exception {
         try {
+            this.sendUnscheduledFollowUpMail();
             //itelImeiActivationNewService.checkItelImeiActivationNew(LocalDate.now(), 15);
         } catch (Throwable e) {
             throw new Exception(e);
+        }
                 Utils.sendHtmlMailWithAttachments(googleMailSender, new String[]{email}, null, "Statewise " + subject, statewiseSaleReport, attachment);
+            }
+        }
+    }
-    private void sendMailOfHtmlFormat(String email, String body, String cc[], String subject) throws MessagingException, ProfitMandiBusinessException, IOException {
+    private void sendMailOfHtmlFormat(JavaMailSender sender, String[] email, String body, String cc[], String subject) throws MessagingException, ProfitMandiBusinessException, IOException {
-        MimeMessage message = mailSender.createMimeMessage();
+        MimeMessage message = sender.createMimeMessage();
         MimeMessageHelper helper = new MimeMessageHelper(message);
         helper.setSubject(subject);
         helper.setText(body, true);
         helper.setTo(email);
         if (cc != null) {
             // notificationService.sendWhatsappMessage(notificationMessage, title,
             // authUser.getMobileNumber());
+        }
+    }
+    @Autowired
+    AuthService authService;
+    public void sendUnscheduledFollowUpMail() throws Exception {
+        List<Lead> missedScheduleLeads = leadRepository.selectLeadsScheduledBetweenDate(null, LocalDate.now().atStartOfDay().minusDays(30), LocalDateTime.now().toLocalDate().atStartOfDay());
+        List<Lead> leadsScheduledForToday = leadRepository.selectLeadsScheduledBetweenDate(null, LocalDate.now().atStartOfDay(), LocalDate.now().atTime(LocalTime.MAX));
+        List<Integer> authIds = missedScheduleLeads.stream().map(x -> x.getAssignTo()).distinct().collect(Collectors.toList());
+        LOGGER.info(authIds.size());
+        Map<Integer, AuthUser> authUserMap = authRepository.selectAllAuthUserByIds(authIds).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
+        LOGGER.info(authUserMap.size());
+        //if(true) return;
+        missedScheduleLeads = missedScheduleLeads.stream().sorted(Comparator.comparing(Lead::getState, String.CASE_INSENSITIVE_ORDER).thenComparing(Lead::getAssignTo).thenComparing(Lead::getScheduledTimestamp)).collect(Collectors.toList());
+        //leadsScheduledForToday
+        List<AuthUser> authUsers = authRepository.selectAllActiveUser();
+        LOGGER.info("Auth Users Size - {}", authUsers.size());
+        for (AuthUser authUser : authUsers) {
+            LOGGER.info("Auth Name - {}", authUser.getFullName());
+            List<Integer> reporteeAuthIds = authService.getAllReportees(authUser.getId());
+            reporteeAuthIds.add(authUser.getId());
+            StringBuilder sb = new StringBuilder();
+            sb.append("<html><body>");
+            List<Lead> authMissedScheduledLeads = missedScheduleLeads.stream().filter(x -> reporteeAuthIds.contains(x.getAssignTo())).collect(Collectors.toList());
+            LOGGER.info("authMissedScheduledLeads {}", authMissedScheduledLeads.size());
+            if (authMissedScheduledLeads.size() > 0) {
+                addMissedScheduledLeadsTable(sb, authMissedScheduledLeads, authUserMap);
+                sb.append("</body></html>");
+                String subject = "Lead Updates Summary";
+                //TODO: Uncomment it later
+                // String[] email = Arrays.asList(authUser.getEmailId()).toArray(new String[1]);
+                String[] email = Arrays.asList("amit.gupta@smartdukaan.com").toArray(new String[1]);
+                this.sendMailOfHtmlFormat(googleMailSender, email, sb.toString(), null, subject);
+                break;
+            }
+        }
+    }
+    private void addMissedScheduledLeadsTable(StringBuilder sb, List<Lead> missedScheduleLeads, Map<Integer, AuthUser> authUserMap) {
+        sb.append("<h3>Leads That Missed the schedule</h3>");
+        sb.append("<table style='border:1px solid black' cellspacing='0'>")
+                .append("<tr>")
+                .append("<th style='border:1px solid black;padding: 5px'>").append("Lead Id").append("</th>")
+                .append("<th style='border:1px solid black;padding: 5px'>").append("Lead Name").append("</th>")
+                .append("<th style='border:1px solid black;padding: 5px'>").append("Mobile No").append("</th>")
+                .append("<th style='border:1px solid black;padding: 5px'>").append("City").append("</th>")
+                .append("<th style='border:1px solid black;padding: 5px'>").append("State").append("</th>")
+                .append("<th style='border:1px solid black;padding: 5px'>").append("Created On").append("</th>")
+                .append("<th style='border:1px solid black;padding: 5px'>").append("Assigned To").append("</th>")
+                .append("<th style='border:1px solid black;padding: 5px'>").append("Scheduled On").append("</th>")
+                .append("</tr>");
+        for (Lead lead : missedScheduleLeads) {
+            sb.append("<tr style='background-color:").append(lead.getColor()).append("'>")
+                    .append("<td style='border:1px solid black;padding: 5px'>").append(lead.getId()).append("</td>")
+                    .append("<td style='border:1px solid black;padding: 5px'>").append(lead.getFullName()).append("</td>")
+                    .append("<td style='border:1px solid black;padding: 5px'>").append(lead.getLeadMobile()).append("</td>")
+                    .append("<td style='border:1px solid black;padding: 5px'>").append(lead.getCity()).append("</td>")
+                    .append("<td style='border:1px solid black;padding: 5px'>").append(lead.getState()).append("</td>")
+                    .append("<td style='border:1px solid black;padding: 5px'>").append(FormattingUtils.formatDate(lead.getCreatedTimestamp())).append("</td>")
+                    .append("<td style='border:1px solid black;padding: 5px'>").append(
+                            authUserMap.containsKey(lead.getAssignTo()) ? authUserMap.get(lead.getAssignTo()).getFullName() : lead.getAssignTo()).append("</td>")
+                    .append("<td style='border:1px solid black;padding: 5px'>").append(FormattingUtils.formatDate(lead.getScheduledTimestamp())).append("</td>")
+                    .append("</tr>");
+        }
+        sb.append("</table>");
+    }
     public void notifyVisits() throws Exception {
         List<FranchiseeVisit> franchiseeVisits = franchiseeVisitRepository.selectVisitsScheduledBetweenDate(LocalDateTime.now().minusDays(15), LocalDateTime.now().plusHours(4));
         Map<Integer, String> authUserEmailMap = authRepository.selectAllActiveUser().stream().collect(Collectors.toMap(x -> x.getId(), x -> x.getEmailId()));
         Map<String, Integer> dtrEmailMap = dtrUserRepository.selectAllByEmailIds(new ArrayList<>(authUserEmailMap.values())).stream().collect(Collectors.toMap(x -> x.getEmailId(), x -> x.getId()));
         Map<Integer, Integer> authUserKeyMap = new HashMap<>();
+        }
         sb.append("</tbody></table><br><br>");
         String subject = "Partner Problem Alert!";
         String[] email = sendTo.toArray(new String[sendTo.size()]);
-        this.sendMailHtmlFormat(email, sb.toString(), null, subject);
+        this.sendMailOfHtmlFormat(googleMailSender, email, sb.toString(), null, subject);
         Map<Integer, List<Integer>> authUserPartnerMapping = csService.getAuthUserIdPartnerIdMapping();
         for (Entry<Integer, List<Integer>> authUserPartner : authUserPartnerMapping.entrySet()) {
             AuthUser authUser = authRepository.selectById(authUserPartner.getKey());
+                        }
+                    }
                     sbbuilder.append("</tbody></table><br><br>");
-                    this.sendMailOfHtmlFormat(authUser.getEmailId(), sbbuilder.toString(), null, subject);
+                    this.sendMailOfHtmlFormat(googleMailSender, new String[]{authUser.getEmailId()}, sbbuilder.toString(), null, subject);
+                }
+            }
+        }
+    }
-    private void sendMailHtmlFormat(String email[], String body, String cc[], String subject) throws MessagingException, ProfitMandiBusinessException, IOException {
-        MimeMessage message = mailSender.createMimeMessage();
-        MimeMessageHelper helper = new MimeMessageHelper(message);
-        helper.setSubject(subject);
-        helper.setText(body, true);
-        helper.setTo(email);
-        if (cc != null) {
-            helper.setCc(cc);
-        }
-        InternetAddress senderAddress = new InternetAddress("noreply@smartdukaan.com", "Smart Dukaan");
-        helper.setFrom(senderAddress);
-        mailSender.send(message);
-    }
     @Autowired
     WarehouseRepository warehouseRepository;
     public void getVendorWarehouses(int warehouseId) {
         LOGGER.info("Warehouses - {}", warehouseRepository.getVendorWarehouses().get(warehouseId));
+            }
             if (!filteredRows.isEmpty()) {
                 String messageText = this.getMessageForDueDateExtend(filteredRows);
                 String[] email = new String[]{storeGuyEntry.getKey()};
-                this.sendMailHtmlFormat(email, messageText, null, subject);
+                this.sendMailOfHtmlFormat(googleMailSender, email, messageText, null, subject);
+            }
+        }
+            }
             if (!filteredRows.isEmpty()) {
                 String messageText = this.getMessageForDueDateCross(filteredRows);
                 String[] email = new String[]{storeGuyEntry.getKey()};
-                this.sendMailHtmlFormat(email, messageText, null, "Due Date Cross");
+                this.sendMailOfHtmlFormat(googleMailSender, email, messageText, null, "Due Date Cross");
+            }
+        }
         if (!dueDateCrossLoans.isEmpty()) {
+                }
                 sb.append("</tbody></table></body></html>");
                 String subject = "Customer Info - Hygiene Alert";
-                this.sendMailOfHtmlFormat(customRetailer.getEmail(), sb.toString(), null, subject);
+                this.sendMailOfHtmlFormat(mailSender, new String[]{customRetailer.getEmail()}, sb.toString(), null, subject);
+            }
+        }
             boolean partnerYearMonth = partnerYearMonthData.values().stream().allMatch(Objects::isNull);
             if (!partnerDateWise && !partnerYearMonth) {
                 String sb = this.getMessageHygieneAlertForPartner(partnerYearMonthData, partnerDateWiseData);
-                this.sendMailOfHtmlFormat(email, sb, null, subject);
+                this.sendMailOfHtmlFormat(googleMailSender, new String[]{email}, sb, null, subject);
+            }
+        }
+    }
                 StringBuilder sb = new StringBuilder();
                 sb.append("<html><body><p>Dear Partner,\n");
                 sb.append("<p>Pls note your agreed monthly target is Rs." + purchaseTarget + " and your achievement till date is Rs." + purchase + "</p>");
                 sb.append("<p>Pls note that your balance target is Rs." + balanceTarget + "</p>\n");
                 sb.append(
-                        "<p>We wish you all the best and we are confident that this focussed approach towards our outlet sales will help us take our outlet to the best SmartDukaan in your city.\n" + "</p>\n");
+                        "<p>We wish you all the best and we are confident that this focused approach towards our outlet sales will help us take our outlet to the best SmartDukaan in your city.\n" + "</p>\n");
-                this.sendMailOfHtmlFormat(customRetailer.getEmail(), sb.toString(), null, subject);
-                // this.sendMailOfHtmlFormat("tejbeer.kaur@smartdukaan.com", sb.toString(),
-                // null, subject);
+                this.sendMailOfHtmlFormat(mailSender, new String[]{customRetailer.getEmail()}, sb.toString(), null, subject);
+            }
+        }
+    }
                     sb.append("</tr>\n");
+                }
-                this.sendMailOfHtmlFormat(email, sb.toString(), null, subject);
+                this.sendMailOfHtmlFormat(googleMailSender, new String[]{email}, sb.toString(), null, subject);
                 // this.sendMailOfHtmlFormat("tejbeer.kaur@smartdukaan.com", sb.toString(),
                 // null, subject);
+            }
     public void migrateVendorItemPricing() {
         List<VendorItemPricing> vendorItemPricings = vendorItemPricingRepository.selectAll();
+        LOGGER.info("At migrate VendorItemPricing");
         Map<Integer, Item> items = itemRepository.selectByIds(vendorItemPricings.stream().map(x -> x.getItemId()).collect(Collectors.toSet())).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
         for (VendorItemPricing vendorItemPricing : vendorItemPricings) {
             Item item = null;
             if (items.get(vendorItemPricing.getItemId()) != null) {
                 item = items.get(vendorItemPricing.getItemId());
             vendorCatalogPricingModel.setAuthId(13);
             vendorCatalogPricingModel.setDp(vendorItemPricing.getDp());
             vendorCatalogPricingModel.setTp(vendorItemPricing.getTp());
             vendorCatalogPricingModel.setMop(vendorItemPricing.getMop());
-            vendorCatalogPricingModel.setEffectedOn(LocalDate.now().minusDays(1));
+            vendorCatalogPricingModel.setEffectedOn(LocalDate.of(2023,8, 22));
             vendorCatalogPricingModel.setVendorId(vendorItemPricing.getVendorId());
             try {
                 vendorCatalogPricingService.createVendorCatalogPricingLog(vendorCatalogPricingModel);

Subversion Repositories SmartDukaan

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