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

 	private static final DateTimeFormatter leadTimeFormatter = DateTimeFormatter.ofPattern("d LLL, hh:mm a");
 	@Autowired
 	private PartnerRegionRepository partnerRegionRepository;
 	@Autowired
 	private EmployeeAttendanceRepository employeeAttendanceRepository;
 	@Autowired
 	private PartnerTypeChangeService partnerTypeChangeService;
 			"niranjan.kala@smartdukaan.com" };
 	private static final String[] INDENT_TERTIARY_MAIL_LIST = new String[] { "uday.singh@smartdukaan.com",
 			"kuldeep.kumar@smartdukaan.com" };
+	private static final String[] EMPLOYEE_ATTENDANCE_MAIL_LIST = new String[] { "jyoti.rawat@smartdukaan.com",
+			"sm@smartdukaan.com" };
 	private List<OrderStatus> orderStatusList = Arrays.asList(OrderStatus.SUBMITTED_FOR_PROCESSING);
 	@Autowired
 	private ReporticoService reporticoService;
 				isr);
 		Utils.sendMailWithAttachments(googleMailSender, INDENT_TERTIARY_MAIL_LIST, null, "Indent Tertiary Report",
 				"PFA", attachment);
+	}
 	public void sendAttendanceMorningAlert() throws Exception {
 		LocalDateTime moriningTime = LocalDate.now().atTime(10, 30);
 		List<AuthUser> authUsers = authRepository.selectAllActiveUser();
-		Map<String, AuthUser> authUserEmailMap = authUsers.stream().filter(x->x.isActive()).collect(Collectors.toMap(x->x.getEmailId(), x->x));
+		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<String, User> userMap = users.stream().collect(Collectors.toMap(x -> x.getEmailId(), x -> x));
+		List<EmployeeAttendance> employeeAttendances = employeeAttendanceRepository
-		List<EmployeeAttendance> employeeAttendances = employeeAttendanceRepository.selectAllByDatesBetween(LocalDate.now().atStartOfDay(), LocalDateTime.now());
+				.selectAllByDatesBetween(LocalDate.now().atStartOfDay(), LocalDateTime.now());
-		Map<Integer, Optional<EmployeeAttendance>> employeeMorningAttendance = employeeAttendances.stream().collect(Collectors.groupingBy(EmployeeAttendance::getUserId,
+		Map<Integer, Optional<EmployeeAttendance>> employeeMorningAttendance = employeeAttendances.stream()
+				.collect(Collectors.groupingBy(EmployeeAttendance::getUserId,
-				Collectors.minBy(Comparator.comparing(EmployeeAttendance::getCreateTimestamp)
+						Collectors.minBy(Comparator.comparing(EmployeeAttendance::getCreateTimestamp))));
-			)));
+		int i = 0;
-		for(AuthUser authUser: authUsers) {
+		for (AuthUser authUser : authUsers) {
 			User user = userMap.get(authUser.getEmailId());
 			Optional<EmployeeAttendance> employeeAttendanceOptional = employeeMorningAttendance.get(user.getId());
-			if(employeeAttendanceOptional==null
-					|| employeeAttendanceOptional.orElse(null)==null
+			if (employeeAttendanceOptional == null || employeeAttendanceOptional.orElse(null) == null
 					|| employeeAttendanceOptional.get().getCreateTimestamp().isAfter(moriningTime)) {
+				String body = String.format(
-				String body = String.format("Dear %s,\n Pls note that you haven't punched your attendance by 10:30am. You have been marked absent for half the day. You may contact your manager and get it regularise.\n\nRegards\nHR Team", authUser.getFullName());
+						"Dear %s,\n Pls note that you haven't punched your attendance by 10:30am. You have been marked absent for half the day. You may contact your manager and get it regularise.\n\nRegards\nHR Team",
+						authUser.getFullName());
+				// Utils.sendMailWithAttachments(googleMailSender, new String[] {
+				// authUser.getEmailId() }, new String[] { "jyoti.rawat@smartdukaan.com" },
+				// "Attendance Alert",
-				Utils.sendMailWithAttachments(googleMailSender, new String[] { authUser.getEmailId() }, new String[] { "jyoti.rawat@smartdukaan.com" }, "Attendance Alert",
+				Utils.sendMailWithAttachments(googleMailSender, new String[] { "amit.gupta@shop2020.in" },
+						new String[] { "jyoti.rawat@smartdukaan.com" }, "Attendance Alert", body);
+				if (i == 5)
-						body);
+					break;
+			}
+		}
+	}
 	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));
+		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<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(Collectors.groupingBy(x->x.getUserId()));
+		Map<Integer, List<EmployeeAttendance>> employeeAttendancesMap = employeeAttendanceRepository
+				.selectAllByDatesBetween(LocalDate.now().atStartOfDay(), LocalDateTime.now()).stream()
+				.collect(Collectors.groupingBy(x -> x.getUserId()));
-		for(AuthUser authUser: authUsers) {
+		for (AuthUser authUser : authUsers) {
 			User user = userMap.get(authUser.getEmailId());
 			String body = null;
 			List<EmployeeAttendance> employeeAttendances = employeeAttendancesMap.get(user.getId());
-			if(employeeAttendances==null ) {
+			if (employeeAttendances == null) {
+				body = String.format(
-				body = String.format("Dear %s,\n No attendance has been registered by you today. You have been marked absent for the day. You may contact your manager and get it regularise.\n\nRegards\nHR Team", authUser.getFullName());
+						"Dear %s,\n No attendance has been registered by you today. You have been marked absent for the day. You may contact your manager and get it regularise.\n\nRegards\nHR Team",
+						authUser.getFullName());
 			} else {
+				List<LocalDateTime> punchTimes = employeeAttendances.stream()
-				List<LocalDateTime> punchTimes = employeeAttendances.stream().sorted(Comparator.comparing(EmployeeAttendance::getCreateTimestamp)).map(x->x.getCreateTimestamp()).collect(Collectors.toList());
+						.sorted(Comparator.comparing(EmployeeAttendance::getCreateTimestamp))
+						.map(x -> x.getCreateTimestamp()).collect(Collectors.toList());
-				if(punchTimes.size()==1) {
+				if (punchTimes.size() == 1) {
+					// body = String.format("Dear %s,\n Pls note that you haven't punched out yet.
-					//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());
+					// 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);
+					LocalDateTime lastPunch = punchTimes.get(punchTimes.size() - 1);
 					boolean hoursCompleted = lastPunch.isAfter(firstPunch.plusHours(8).plusMinutes(30));
-					if(!hoursCompleted) {
+					if (!hoursCompleted) {
+						body = String.format(
-						body = String.format("Dear %s,\n Pls note that you have punched your attendance before 6pm. You have been marked absent for half the day. You may contact your manager and get it regularise.\n\nRegards\nHR Team", authUser.getFullName());
+								"Dear %s,\n Pls note that you have punched your attendance before 6pm. You have been marked absent for half the day. You may contact your manager and get it regularise.\n\nRegards\nHR Team",
+								authUser.getFullName());
+					}
+				}
+			}
-			if(body != null) {
+			if (body != null) {
-				Utils.sendMailWithAttachments(googleMailSender, new String[] { authUser.getEmailId() }, new String[] { "jyoti.rawat@smartdukaan.com" }, "Attendance Alert",
+				Utils.sendMailWithAttachments(googleMailSender, new String[] { authUser.getEmailId() },
-						body);
+						new String[] { "jyoti.rawat@smartdukaan.com" }, "Attendance Alert", body);
+			}
+		}
+		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);
+		Utils.sendMailWithAttachments(googleMailSender, EMPLOYEE_ATTENDANCE_MAIL_LIST, null,
+				"Attendance - " + FormattingUtils.formatDate(LocalDateTime.now()), "PFA Attendance", attachment);
+	}
 	public void checkPartnerActiveStore() throws Exception {
 		List<FofoStore> fofoStores = fofoStoreRepository.selectByStatus(true);
 		LocalDateTime currentDate = LocalDate.now().atStartOfDay();
 		mailSender.send(message);
+	}
 	@Autowired
 	WarehouseRepository warehouseRepository;
 	public void getVendorWarehouses(int warehouseId) {
 		LOGGER.info("Warehouses - {}", warehouseRepository.getVendorWarehouses().get(warehouseId));
+	}
+}
 //2284

Subversion Repositories SmartDukaan

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