/modules/uoa-goldoa-service/branches/hibernate/src/main/java/eu/dnetlib/goldoa/service/UserManagerImpl.java - Annotate - D-Net - D-Net project tracking tool

dnet40/modules/uoa-goldoa-service/branches/hibernate/src/main/java/eu/dnetlib/goldoa/service/UserManagerImpl.java @ 47598

-            antonis.le
+package eu.dnetlib.goldoa.service;
             panagiotis
-            panagiotis
+import eu.dnetlib.goldoa.domain.*;
-            panagiotis
+import eu.dnetlib.goldoa.service.dao.UserDAO;
-            panagiotis
+import eu.dnetlib.goldoa.service.utils.EmailUtils;
-            antonis.le
+import org.apache.commons.codec.digest.DigestUtils;
-            panagiotis
+import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
-            antonis.le
+import org.springframework.beans.factory.annotation.Autowired;
-            panagiotis
+import org.springframework.stereotype.Service;
-            antonis.le
+import org.springframework.transaction.annotation.Transactional;
             antonis.le
-            panagiotis
+import javax.mail.MessagingException;
-            antonis.le
+import java.math.BigInteger;
-            panagiotis
+import java.nio.charset.Charset;
-            antonis.le
+import java.security.SecureRandom;
-            panagiotis
+import java.util.ArrayList;
-            antonis.le
+import java.util.List;
-            antonis.le
+import java.util.UUID;
-            antonis.le
+import java.util.concurrent.ExecutorService;
             antonis.le
-            panagiotis
+//import eu.dnetlib.goldoa.service.utils.EmailUtils;
             panagiotis
-            antonis.le
+/**
  * Created by antleb on 3/4/15.
  */
-            panagiotis
+@Service("userManager")
-            panagiotis
+@Transactional
-            panagiotis
+public class UserManagerImpl implements UserManager {
             antonis.le
-            antonis.le
+	@Autowired
-            panagiotis
+	private UserDAO userDAO;
             panagiotis
-            antonis.le
+	@Autowired
-            panagiotis
+	private EmailUtils emailUtils;
             panagiotis
-            antonis.le
+	@Autowired
 	ExecutorService executorService;
             antonis.le
-            antonis.le
+	private int tokenTTL = 30;
             antonis.le
-            panagiotis
+	private Log log = LogFactory.getLog(UserManagerImpl.class);
-            antonis.le
+	public static int generateId(Affiliation affiliation) {
 		StringBuilder sb = new StringBuilder();
             antonis.le
-            panagiotis
+		if (affiliation.getUsers().get(0) != null)
 			sb.append(affiliation.getUsers().get(0).getId());
 		if (affiliation.getOrganization() != null)
 			sb.append(affiliation.getOrganization().getId());
             antonis.le
-            antonis.le
+		return DigestUtils.md5Hex(sb.toString()).hashCode();
+	}
             antonis.le
-            antonis.le
+	@Override
-            panagiotis
+	public User getById(String personId) throws PersonManagerException {
-            panagiotis
+		return userDAO.getUserById(personId);
             antonis.le
             antonis.le
-            antonis.le
+	@Override
-            panagiotis
+	public User getByEmail(final String email) throws PersonManagerException {
-            panagiotis
+		return userDAO.getUserByEmail(email);
             antonis.le
             antonis.le
-            antonis.le
+	@Override
-            panagiotis
+	// register or update
-            panagiotis
+	public User saveUser(final User user) throws PersonManagerException {
-            panagiotis
+		final List<UserRole> previousRoles;
             antonis.le
-            panagiotis
+		if (user.getId() == null) {
 			user.setId(generateId(user));
 			user.setSource("portal");
             stefania.m
-            panagiotis
+			previousRoles = new ArrayList<UserRole>();
-            antonis.le
+		} else {
-            panagiotis
+			previousRoles = user.getRoles();
+		}
             panagiotis
-            panagiotis
+		userDAO.saveUser(user);
             antonis.le
-            panagiotis
+		final List<User> moderators = userDAO.getModerators();
             panagiotis
-            panagiotis
+		executorService.submit(new Runnable() {
 			@Override
 			public void run() {
-            panagiotis
+				try {
-            panagiotis
+					List<Role> roles = new ArrayList<>();
 					for (UserRole pRole : user.getRoles()) {
-            panagiotis
+						//!previousRoles.contains(pRole) &&
 						if ( !pRole.isApproved())
-            panagiotis
+							roles.add(pRole.getPk().getRole());
+					}
 					if (roles.size() > 0) {
 						emailUtils.sendUserRoleRequestedEmail(user, roles);
 						for (User moderator : moderators)
 							emailUtils.sendModeratorRoleRequestedEmail(moderator, user, roles);
+					}
 				} catch (MessagingException e) {
 					e.printStackTrace();
             panagiotis
             panagiotis
 		});
-            panagiotis
+		return user;
             antonis.le
             antonis.le
-            antonis.le
+	@Override
-            panagiotis
+	public void register(final User user) throws PersonManagerException {
-            antonis.le
+		final String token = UUID.randomUUID().toString();
             panagiotis
-            panagiotis
+		try {
-            panagiotis
+			User u = userDAO.getUserByEmail(user.getEmail());
 			if (u != null)
 				throw new PersonManagerException(PersonManagerException.ErrorCause.ALREADY_EXISTS);
-            antonis.le
+		} catch (PersonManagerException e) {
 			throw e;
 		} catch (RuntimeException e) {
 			e.printStackTrace();
 			throw e;
             panagiotis
             panagiotis
-            panagiotis
+		user.setPassword(org.springframework.util.DigestUtils.md5DigestAsHex( user.getPassword().getBytes(Charset.forName("UTF-8"))));
-            panagiotis
+		this.saveUser(user);
-            panagiotis
+		userDAO.saveToken(user.getEmail(), token, tokenTTL);
             antonis.le
-            antonis.le
+		executorService.submit(new Runnable() {
 			@Override
 			public void run() {
-            panagiotis
+				try {
-            panagiotis
+					emailUtils.sendActivationEmail(user, token);
 				} catch (MessagingException e) {
 					e.printStackTrace();
             panagiotis
             antonis.le
 		});
             antonis.le
-            antonis.le
+	@Override
-            panagiotis
+	public User login(String email, String password) throws PersonManagerException {
             antonis.le
-            antonis.le
+		try {
 			if (userDAO.verifyLogin(email, password)) {
 				System.out.println("verified login");
 				User user = getByEmail(email);
 				if (user.isActive()) {
 					System.out.println("user is active");
 					return user;
+				}
 				else
 					throw new PersonManagerException(PersonManagerException.ErrorCause.NOT_ACTIVATED);
 			} else {
 				throw new PersonManagerException(PersonManagerException.ErrorCause.WRONG_EMAIL_OR_PASSWORD);
+			}
 		} catch (PersonManagerException e) {
 			throw e;
 		} catch (Exception e) {
 			log.error("Error logging in", e);
             antonis.le
-            antonis.le
+		return null;
             antonis.le
-            antonis.le
+	@Override
-            panagiotis
+	public User activate(final String email, final String token) throws PersonManagerException {
             antonis.le
-            panagiotis
+		if (!userDAO.verifyToken(email, token))
-            antonis.le
+			throw new PersonManagerException(PersonManagerException.ErrorCause.NOT_EXISTS);
-            antonis.le
+		else {
-            panagiotis
+			User user = userDAO.getUserByEmail(email);
 			userDAO.activateUser(user.getEmail());
 			userDAO.deleteToken(user.getEmail(), token);
             antonis.le
-            antonis.le
+		return getByEmail(email);
             antonis.le
 	@Override
-            antonis.le
+	public void resetPassword(final String email) throws PersonManagerException {
 		SecureRandom random = new SecureRandom();
 		final String newPassword = new BigInteger(50, random).toString(32);
             antonis.le
-            panagiotis
+		if (!userDAO.updatePassword(newPassword, email)) {
-            antonis.le
+			throw new PersonManagerException(PersonManagerException.ErrorCause.NOT_EXISTS);
+		}
-            panagiotis
+		final User user = userDAO.getUserByEmail(email);
-            panagiotis
+		executorService.submit(new Runnable() {
-            antonis.le
+			@Override
 			public void run() {
-            panagiotis
+				try {
-            panagiotis
+					emailUtils.sendResetPasswordEmail(user, newPassword);
-            antonis.le
+				} catch (MessagingException e) {
 					e.printStackTrace();
             panagiotis
             antonis.le
-            panagiotis
+		});
             antonis.le
 	@Override
-            antonis.le
+	public List<Role> getRoles() {
-            panagiotis
+		return userDAO.getRoles();
             antonis.le
-            antonis.le
+	@Override
-            panagiotis
+	public List<User> getModerators() {
 		return userDAO.getModerators();
             antonis.le
             antonis.le
-            antonis.le
+	@Override
-            panagiotis
+	public List<User> getAccountingOfficers() {
 		return userDAO.getAccountingOfficers();
             antonis.le
             stefania.m
-            antonis.le
+	@Override
-            panagiotis
+	public void activateUser(String email) {
 		userDAO.activateUser(email);
             antonis.le
             antonis.le
-            antonis.le
+	@Override
-            panagiotis
+	public void activateUsers(List<String> emails) {
 		for (String email : emails) {
 			userDAO.activateUser(email);
             antonis.le
+	}
             antonis.le
-            antonis.le
+	@Override
-            panagiotis
+	public void deactivateUser(String email) {
 		userDAO.deactivateUser(email);
             antonis.le
             antonis.le
-            antonis.le
+	@Override
-            panagiotis
+	public void deactivateUsers(List<String> emails) {
 		for (String email : emails) {
 			userDAO.deactivateUser(email);
             antonis.le
+	}
             antonis.le
-            antonis.le
+	@Override
-            panagiotis
+	public void acceptUserRole(final String email, final String roleId) {
 		userDAO.acceptUserRole(email, roleId);
-            panagiotis
+		final User user = userDAO.getUserByEmail(email);
 		final Role role = userDAO.getRole(roleId);
 		final List<User> moderators = getModerators();
-            panagiotis
+		executorService.submit(new Runnable() {
-            antonis.le
+			@Override
 			public void run() {
 				try {
-            panagiotis
+					emailUtils.sendUserRoleAcceptedEmail(user, role);
 					for (User moderator : moderators)
 						emailUtils.sendModeratorRoleAcceptedEmail(moderator, user, role);
-            antonis.le
+				} catch (MessagingException e) {
 					e.printStackTrace();
             panagiotis
             antonis.le
-            panagiotis
+		});
             antonis.le
             antonis.le
-            antonis.le
+	@Override
-            panagiotis
+	public void rejectRole(final String email, final String roleId) {
 		userDAO.rejectUserRole(email, roleId);
             antonis.le
-            panagiotis
+		final User user = userDAO.getUserByEmail(email);
 		final Role role = getRole(roleId);
 		final List<User> moderators = getModerators();
-            panagiotis
+		executorService.submit(new Runnable() {
-            antonis.le
+			@Override
 			public void run() {
 				try {
-            panagiotis
+					emailUtils.sendUserRoleRejectedEmail(user, role);
 					for (User moderator : moderators)
 						emailUtils.sendModeratorRoleRejectedEmail(moderator, user, role);
-            antonis.le
+				} catch (MessagingException e) {
 					e.printStackTrace();
             panagiotis
             antonis.le
-            panagiotis
+		});
             antonis.le
             antonis.le
-            antonis.le
+	@Override
-            panagiotis
+	public List<User> getUsers() {
-            panagiotis
+		return userDAO.getUsers();
             antonis.le
             antonis.le
-            antonis.le
+	@Override
-            panagiotis
+	public String generateId(User user) {
-            antonis.le
+		StringBuilder sb = new StringBuilder();
             antonis.le
-            panagiotis
+		sb.append(user.getFirstname()).append(user.getLastname()).append(user.getEmail());
-            antonis.le
+		return "portal::" + DigestUtils.md5Hex(sb.toString());
+	}
-            antonis.le
+	public int getTokenTTL() {
 		return tokenTTL;
+	}
 	public void setTokenTTL(int tokenTTL) {
 		this.tokenTTL = tokenTTL;
+	}
             panagiotis
 	@Override
 	public Role getRole(String roleId){
 		return userDAO.getRole(roleId);
+	}
             panagiotis
 	@Override
 	public List<Role> getUserRoles(String email){
 		return userDAO.getUserRoles(email);
+	}
             antonis.le

Project

General

Profile

D-Net