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

     @Autowired
     private PartnerRegionRepository partnerRegionRepository;
     @Autowired
-    private EmployeeAttendanceRepository employeeAttendanceRepository;
-    @Autowired
     VivoImeiActivationService vivoImeiActivationService;
     @Autowired
     CarlcareImeiActivationService carlcareImeiActivationService;
     private RetailerBlockBrandsRepository retailerBlockBrandsRepository;
     @Autowired
     private LiquidationService liquidationService;
-    private static final String[] STOCK_AGEING_MAIL_LIST = new String[]{"uday.singh@smartudkaan.com", "mohinder.mutreja@smartdukaan.com", "ankit.bhatia@smartdukaan.com", "tarun.verma@smartdukaan.com", "kuldeep.kumar@smartdukaan.com"};
+    private static final String[] STOCK_AGEING_MAIL_LIST = new String[]{"uday.singh@smartdukaan.com", "mohinder.mutreja@smartdukaan.com", "tarun.verma@smartdukaan.com", "kuldeep.kumar@smartdukaan.com"};
     private static final String[] ITEMWISE_PENDING_INDENT_MAIL_LIST = new String[]{"kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com", "uday.singh@smartdukaan.com", "kuldeep.kumar@smartdukaan.com", "niranjan.kala@smartdukaan.com"};
     private static final String[] INDENT_TERTIARY_MAIL_LIST = new String[]{"uday.singh@smartdukaan.com", "kuldeep.kumar@smartdukaan.com", "vinay.p@smartdukaan.com", "deena.nath@smartdukaan.com", "shobhit.tandon@smartdukaan.com", "ritesh.chauhan1@smartdukaan.com"};
-    private static final String[] EMPLOYEE_ATTENDANCE_MAIL_LIST = new String[]{"sm@smartdukaan.com", "sm@smartdukaan.com"};
     private List<OrderStatus> orderStatusList = Arrays.asList(OrderStatus.SUBMITTED_FOR_PROCESSING);
     @Autowired
     private ReporticoService reporticoService;
             for (BilledImeiModel billedImeiModel : samsungModels) {
                 List<Serializable> row = Arrays.asList(billedImeiModel.getFofoId(), billedImeiModel.getStoreCode(), billedImeiModel.getStoreName(), billedImeiModel.getStoreCity(), billedImeiModel.getBrand(), billedImeiModel.getModelName(), billedImeiModel.getModelNumber(), billedImeiModel.getColor(), billedImeiModel.getSerialNumber(), billedImeiModel.getPcmDate() == null ? "PCM date Missing" : "Rebill Imeis");
                 rows.add(row);
+            }
             ByteArrayOutputStream baos = FileUtil.getCSVByteStream(headers, rows);
-            String[] sendToArray = new String[]{"kamini.sharma@smartdukaan.com", "praveen.sharma@smartdukaan.com"};
+            String[] sendToArray = new String[]{"kamini.sharma@smartdukaan.com"};
             String fileName = "Imeis need Rebilling -" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv";
             Utils.sendMailWithAttachment(googleMailSender, sendToArray, new String[]{"tarun.verma@smartdukaan.com"}, "Samsung Rebilling IMEI Summary", "PFA", fileName, new ByteArrayResource(baos.toByteArray()));
+        }
+    }
                 "indentandtertiary-report-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv", isr);
         mailOutboxService.queueMailWithAttachmentsViaGoogle(INDENT_TERTIARY_MAIL_LIST, null, "Indent Tertiary Report", "PFA", "ScheduledTasks.sendIndentTertiary", attachment);
+    }
-    public void sendAttendanceMorningAlert() throws Exception {
-        LocalDateTime moriningTime = LocalDate.now().atTime(10, 31);
-        List<AuthUser> authUsers = authRepository.selectAllActiveUser();
-        Map<String, AuthUser> authUserEmailMap = authUsers.stream().filter(x -> x.isActive()).collect(Collectors.toMap(x -> x.getEmailId(), x -> x));
-        List<User> users = dtrUserRepository.selectAllByEmailIds(new ArrayList<>(authUserEmailMap.keySet()));
-        Map<String, User> userMap = users.stream().collect(Collectors.toMap(x -> x.getEmailId(), x -> x));
-        List<EmployeeAttendance> employeeAttendances = employeeAttendanceRepository.selectAllByDatesBetween(LocalDate.now().atStartOfDay(), LocalDateTime.now());
-        Map<Integer, Optional<EmployeeAttendance>> employeeMorningAttendance = employeeAttendances.stream().collect(groupingBy(EmployeeAttendance::getUserId, Collectors.minBy(Comparator.comparing(EmployeeAttendance::getCreateTimestamp))));
-        for (AuthUser authUser : authUsers) {
-            User user = userMap.get(authUser.getEmailId());
-            Optional<EmployeeAttendance> employeeAttendanceOptional = employeeMorningAttendance.get(user.getId());
-            LOGGER.info("AuthUser - {}, employeeAttendanceOptional {}", authUser.getName(), employeeAttendanceOptional);
-            if (employeeAttendanceOptional != null) {
-                LOGGER.info("employeeAttendanceOptional.orElse {}", employeeAttendanceOptional.orElse(null));
-                if (employeeAttendanceOptional.orElse(null) != null) {
-                    LOGGER.info("employeeAttendanceOptional.get().getCreateTimestamp() {}", employeeAttendanceOptional.get().getCreateTimestamp());
-                }
-            }
-            if (employeeAttendanceOptional == null || employeeAttendanceOptional.orElse(null) == null || employeeAttendanceOptional.get().getCreateTimestamp().isAfter(moriningTime)) {
-                LOGGER.info("Will Send Email to {}", authUser.getFullName());
-                String body = String.format(
-                        "Dear %s,\n Pls note that you haven't punched your attendance by 10:30am%s. You have been marked absent for half the day.\n\nRegards\nHR Team", authUser.getFullName(), (employeeAttendanceOptional == null || employeeAttendanceOptional.orElse(null) == null) ? "" : "(Punched at " + FormattingUtils.format(employeeAttendanceOptional.get().getCreateTimestamp()) + ")");
-                mailOutboxService.queueMailViaGoogle(new String[]{authUser.getEmailId()}, new String[]{"kangan.monga@smartdukaan.com"}, "Attendance Alert", body, "ScheduledTasks.sendAttendanceMorningAlert");
-            }
-        }
-    }
-    public void sendAttendanceEveningAlert() throws Exception {
-        List<AuthUser> authUsers = authRepository.selectAllActiveUser();
-        Map<String, AuthUser> authUserEmailMap = authUsers.stream().filter(x -> x.isActive()).collect(Collectors.toMap(x -> x.getEmailId(), x -> x));
-        List<User> users = dtrUserRepository.selectAllByEmailIds(new ArrayList<>(authUserEmailMap.keySet()));
-        Map<String, User> userMap = users.stream().collect(Collectors.toMap(x -> x.getEmailId(), x -> x));
-        Map<Integer, List<EmployeeAttendance>> employeeAttendancesMap = employeeAttendanceRepository.selectAllByDatesBetween(LocalDate.now().atStartOfDay(), LocalDateTime.now()).stream().collect(groupingBy(x -> x.getUserId()));
-        for (AuthUser authUser : authUsers) {
-            User user = userMap.get(authUser.getEmailId());
-            String body = null;
-            List<EmployeeAttendance> employeeAttendances = employeeAttendancesMap.get(user.getId());
-            if (employeeAttendances == null) {
-                body = String.format(
-                        "Dear %s,\n No attendance has been registered by you today. You have been marked absent for the day.\n\nRegards\nHR Team", authUser.getFullName());
-            } else {
-                List<LocalDateTime> punchTimes = employeeAttendances.stream().sorted(Comparator.comparing(EmployeeAttendance::getCreateTimestamp)).map(x -> x.getCreateTimestamp()).collect(Collectors.toList());
-                if (punchTimes.size() == 1) {
-                    // body = String.format("Dear %s,\n Pls note that you haven't punched out yet.
-                    // You have been marked absent for half the day. You may contact your manager
-                    // and get it regularise.\n\nRegards\nHR Team", authUser.getFullName());
-                } else {
-                    LocalDateTime firstPunch = punchTimes.get(0);
-                    LocalDateTime lastPunch = punchTimes.get(punchTimes.size() - 1);
-                    Duration duration = Duration.between(firstPunch, lastPunch);
-                    boolean hoursCompleted = lastPunch.isAfter(firstPunch.plusHours(8).plusMinutes(30));
-                    if (!hoursCompleted) {
-                        body = String.format(
-                                "Dear %s,\n Pls note that you haven't completed 8.30 Hrs (%d.%d Hrs). You have been marked absent for half the day.\n\nRegards\nHR Team", authUser.getFullName(), duration.toHours(), duration.toMinutes() - duration.toHours() * 60);
-                    }
-                }
-            }
-            if (body != null) {
-                mailOutboxService.queueMailViaGoogle(new String[]{authUser.getEmailId()}, new String[]{"kangan.monga@smartdukaan.com"}, "Attendance Alert", body, "ScheduledTasks.sendAttendanceEveningAlert");
-            }
-        }
-        this.sendMailToHR();
-    }
-    private void sendMailToHR() throws Exception {
-        Map<String, String> map = new HashMap<>();
-        String reporticoDate = FormattingUtils.formatReporitcoDate(LocalDateTime.now());
-        map.put("MANUAL_datesBetween_FROMDATE", reporticoDate);
-        map.put("MANUAL_datesBetween_FROMDATE", reporticoDate);
-        InputStreamSource isr = reporticoService.getReportInputStreamSource(ReporticoProject.FOCO, "employeeattendance.xml");
-        Attachment attachment = new Attachment("attendance-" + FormattingUtils.formatDate(LocalDateTime.now()) + ".csv", isr);
-        mailOutboxService.queueMailWithAttachmentsViaGoogle(EMPLOYEE_ATTENDANCE_MAIL_LIST, null, "Attendance - " + FormattingUtils.formatDate(LocalDateTime.now()), "PFA Attendance", "ScheduledTasks.sendMailToHR", attachment);
-    }
     public void checkPartnerActiveStore() throws Exception {
         List<FofoStore> fofoStores = fofoStoreRepository.selectByStatus(true);
         LocalDateTime currentDate = LocalDate.now().atStartOfDay();
                         Customer customer = customerRepository.selectById(po.getCustomerId());
                         String[] customerEmail = null;
                         if (customer.getEmailId() != null) {
                             customerEmail = new String[]{customer.getEmailId()};
+                        }
-                        List<String> bccTo = Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com", "niranjan.kala@smartdukaan.com", "sm@smartdukaan.com", "tejbeer.kaur@shop2020.in", customRetailer.getEmail());
+                        List<String> bccTo = Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com", "niranjan.kala@smartdukaan.com", "tejbeer.kaur@shop2020.in", customRetailer.getEmail());
                         List<String> authUserEmails = csService.getAuthUserByPartnerId(customRetailer.getPartnerId());
                         if (authUserEmails != null) {
                             authUserEmails = new ArrayList<>();
+                        }
                         authUserEmails.addAll(bccTo);
         List<Integer> assignTo = Arrays.asList(15, 9, 54, 53);
         Map<Integer, AuthUser> assignAuthUserMap = authRepository.selectByIds(assignTo).stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
-        List<String> sendTo = Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com", "sm@smartdukaan.com");
+        List<String> sendTo = Arrays.asList("kamini.sharma@smartdukaan.com", "tarun.verma@smartdukaan.com");
         LOGGER.info("partnerProblem" + partnerProblems);
         StringBuilder sb = new StringBuilder();
         sb.append("<htl><body>");
         sb.append(
                 "<p>Number against MTD or Investment are the count of days the MTD is low VS LMTD OR Investment is below 75%.</p><br/><p>These partners needs immediate attention.</p><br/><table style='border:1px solid black';cellspacing=0>");
+            }
+        }
         String messageText = this.getMessageForDueDateExtend(defaultLoans);
-        this.sendMailOfHtmlFormat(googleMailSender, new String[]{"puneet.wahi@smartdukaan.com", "rahul.latwal@smartdukaan.com", "dilbag.singh@smartdukaan.com"}, messageText, null, subject);
+        this.sendMailOfHtmlFormat(googleMailSender, new String[]{"dilbag.singh@smartdukaan.com"}, messageText, null, subject);
         for (Loan defaultLoan : defaultLoans) {
             double principal = defaultLoan.getPendingAmount().doubleValue();
             double interest = defaultLoan.getInterestAccrued().doubleValue() - defaultLoan.getInterestPaid().doubleValue();
             double total = principal + interest;
                     sb.append("</tr>\n");
+                }
                 this.sendMailOfHtmlFormat(googleMailSender, new String[]{email}, sb.toString(), null, subject);
-                // this.sendMailOfHtmlFormat("tejbeer.kaur@smartdukaan.com", sb.toString(),
-                // null, subject);
+            }
+        }
                 "This is a gentle reminder to kindly update the brand-wise market share data for the current quarter.\n\n" +
                 "Best regards,\n" +
                 "SmartDukaan Team";
         mailOutboxService.queueMailViaGoogle(
-                new String[]{"sm.@smartdukaan.com"},
                 new String[]{"tech@smartdukaan.com"},
+                null,
                 subject,
                 body,
                 "ScheduledTasks.sendUpdateMobileBrandMarketShareQuaterlyMail"
         );
+    }

Subversion Repositories SmartDukaan

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