D-Net

package eu.dnetlib.goldoa.service;

import eu.dnetlib.goldoa.domain.Affiliation;

import eu.dnetlib.goldoa.domain.PersonManagerException;

import eu.dnetlib.goldoa.domain.Role;

import eu.dnetlib.goldoa.domain.User;

import eu.dnetlib.goldoa.domain.UserRole;

//import eu.dnetlib.goldoa.service.dao.OrganizationDAO;

import eu.dnetlib.goldoa.service.dao.UserDAO;

//import eu.dnetlib.goldoa.service.dao.ProjectDAO;

//import eu.dnetlib.goldoa.service.utils.EmailUtils;

import org.apache.commons.codec.digest.DigestUtils;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.dao.EmptyResultDataAccessException;

import org.springframework.stereotype.Repository;

import org.springframework.transaction.annotation.Transactional;

//import javax.mail.MessagingException;

import java.math.BigInteger;

import java.security.SecureRandom;

import java.util.ArrayList;

import java.util.List;

import java.util.UUID;

import java.util.concurrent.ExecutorService;

/**

 * Created by antleb on 3/4/15.

 */

public class UserManagerImpl implements UserManager {

	@Autowired

	private UserDAO userDAO;

	/*@Autowired

	private ProjectDAO projectDAO;

	@Autowired

	private OrganizationDAO organizationDAO;

	@Autowired

	private PublisherManager publisherManager;

	@Autowired

	private OrganizationManager organizationManager;

	@Autowired

	private EmailUtils emailUtils;*/

	@Autowired

	ExecutorService executorService;

	private int tokenTTL = 30;

	public static int generateId(Affiliation affiliation) {

		StringBuilder sb = new StringBuilder();

		if (affiliation.getPerson() != null)

			sb.append(affiliation.getPerson().getId());

		if (affiliation.getOrganization() != null)

			sb.append(affiliation.getOrganization().getId());

		return DigestUtils.md5Hex(sb.toString()).hashCode();

	}

	@Override

	public User getById(String personId) throws PersonManagerException {

		return userDAO.getUserById(personId);

	}

	@Override

	public User getByEmail(final String email) throws PersonManagerException {

		return userDAO.getUserByEmail(email);

	}

	@Override

	public User saveUser(final User user) throws PersonManagerException {

		final List<UserRole> previousRoles;

		if (user.getId() == null) {

			user.setId(generateId(user));

			user.setSource("portal");

			previousRoles = new ArrayList<UserRole>();

		} else {

			previousRoles = userDAO.getUserById(user.getId()).getRoles();

		}

		userDAO.saveUser(user);

//		deletePersonRelations(user);

//		savePersonRelations(user);

//

//		loadPersonRelations(user);

//		executorService.submit(new Runnable() {

//			@Override

//			public void run() {

//				try {

//					List<Role> roles = new ArrayList<Role>();

//

//					for (UserRole pRole : user.getRoles()) {

//						if (!previousRoles.contains(pRole) && !pRole.isApproved())

//							roles.add(pRole.getRole());

//					}

//

//					if (roles.size() > 0) {

//						List<User> moderators = getModerators();

//

//						emailUtils.sendUserRoleRequestedEmail(user, roles);

//

//						for (User moderator : moderators)

//							emailUtils.sendModeratorRoleRequestedEmail(moderator, user, roles);

//					}

//				} catch (MessagingException e) {

//					e.printStackTrace();

//				}

//			}

//		});

		return user;

	}

	@Override

	public void register(final User user) throws PersonManagerException {

		final String token = UUID.randomUUID().toString();

		/*try {

			User u = userDAO.getUserByEmail(user.getEmail());

			if (u != null)

				throw new PersonManagerException(PersonManagerException.ErrorCause.ALREADY_EXISTS);

		} catch (EmptyResultDataAccessException e) {

		} catch (PersonManagerException e) {

			throw e;

		} catch (RuntimeException e) {

			e.printStackTrace();

			throw e;

		}

		*/

		this.saveUser(user);

		userDAO.saveToken(user.getEmail(), token, tokenTTL);

		executorService.submit(new Runnable() {

			@Override

			public void run() {

//				try {

//					emailUtils.sendActivationEmail(user, token);

//				} catch (MessagingException e) {

//					e.printStackTrace();

//				}

			}

		});

	}

	@Override

	public User login(String email, String password) throws PersonManagerException {

		if (userDAO.verifyLogin(email, password)) {

			User user = getByEmail(email);

			if (user.isActive())

				return user;

			else

				throw new PersonManagerException(PersonManagerException.ErrorCause.NOT_ACTIVATED);

		} else {

			throw new PersonManagerException(PersonManagerException.ErrorCause.WRONG_EMAIL_OR_PASSWORD);

		}

	}

	@Override

	public User activate(final String email, final String token) throws PersonManagerException {

		if (!userDAO.verifyToken(email, token))

			throw new PersonManagerException(PersonManagerException.ErrorCause.NOT_EXISTS);

		else {

			User user = userDAO.getUserByEmail(email);

			userDAO.activateUser(user.getEmail());

			userDAO.deleteToken(user.getEmail(), token);

		}

		return getByEmail(email);

	}

	@Override

	public void resetPassword(final String email) throws PersonManagerException {

		SecureRandom random = new SecureRandom();

		final String newPassword = new BigInteger(50, random).toString(32);

		if (!userDAO.updatePassword(newPassword, email)) {

			throw new PersonManagerException(PersonManagerException.ErrorCause.NOT_EXISTS);

		}

	/*	executorService.submit(new Runnable() {

			@Override

			public void run() {

				User user = userDAO.getUserByEmail(email);

				try {

					emailUtils.sendResetPasswordEmail(user, newPassword);

				} catch (MessagingException e) {

					e.printStackTrace();

				}

			}

		});*/

	}

	@Override

	public List<Role> getRoles() {

		return userDAO.getRoles();

	}

	@Override

	public List<User> getModerators() {

		return userDAO.getModerators();

	}

	@Override

	public List<User> getAccountingOfficers() {

		return userDAO.getAccountingOfficers();

	}

	@Override

	public void activateUser(String userId) {

		userDAO.activateUser(userId);

	}

	@Override

	public void activateUsers(List<String> userIds) {

		for (String userId : userIds) {

			userDAO.activateUser(userId);

		}

	}

	@Override

	public void deactivateUser(String email) {

		userDAO.deactivateUser(email);

	}

	@Override

	public void deactivateUsers(List<String> emails) {

		for (String email : emails) {

			userDAO.deactivateUser(email);

		}

	}

	@Override

	public void acceptUserRole(final String email, final String roleId) {

		userDAO.acceptUserRole(email, roleId);

		/*executorService.submit(new Runnable() {

			@Override

			public void run() {

				User user = userDAO.getUserByEmail(email);

				Role role = userDAO.getRole(roleId);

				List<User> moderators = getModerators();

				try {

					emailUtils.sendUserRoleAcceptedEmail(user, role);

					for (User moderator : moderators)

						emailUtils.sendModeratorRoleAcceptedEmail(moderator, user, role);

				} catch (MessagingException e) {

					e.printStackTrace();

				}

			}

		});*/

	}

	@Override

	public void rejectRole(final String email, final String roleId) {

		userDAO.rejectUserRole(email, roleId);

		/*executorService.submit(new Runnable() {

			@Override

			public void run() {

				User user = userDAO.getUserByEmail(email);

				Role role = userDAO.getRole(roleId);

				List<User> moderators = getModerators();

				try {

					emailUtils.sendUserRoleRejectedEmail(user, role);

					for (User moderator : moderators)

						emailUtils.sendModeratorRoleRejectedEmail(moderator, user, role);

				} catch (MessagingException e) {

					e.printStackTrace();

				}

			}

		});*/

	}

	@Override

	public List<User> getUsers() {

		List<User> users = userDAO.getUsers();

		for (User user : users) {

			loadPersonRelations(user);

		}

		return users;

	}

	@Override

	public String generateId(User user) {

		StringBuilder sb = new StringBuilder();

		sb.append(user.getFirstname()).append(user.getLastname()).append(user.getEmail());

		return "portal::" + DigestUtils.md5Hex(sb.toString());

	}

	private void deletePersonRelations(final User user) {

		userDAO.deleteAffiliations(user.getEmail());

		userDAO.deletePersonRoles(user.getEmail());

		userDAO.removeProjectCoordinators(user.getEmail());

	}

	private void savePersonRelations(final User user) throws PersonManagerException {

//		List<String> projectIds = new ArrayList<String>();

//		if (user.getProjectCoordinators() != null)

//			for (Project project : user.getProjectCoordinators())

//				projectIds.add(project.getId());

//		if (user.getPublisher() != null && user.getPublisher().getId() == null)

//			publisherManager.savePublisher(user.getPublisher());

//

//		for (Affiliation affiliation : user.getAffiliations()) {

//			if (affiliation.getOrganization() != null && affiliation.getOrganization().getId() == null)

//				try {

//					organizationManager.saveOrganization(affiliation.getOrganization());

//				} catch (OrganizationManagerException e) {

//					e.printStackTrace();

//				}

//		}

//		userDAO.saveProjectCoordinators(user.getEmail(), user.getProjectCoordinators());

//		userDAO.saveUserRoles(user.getEmail(), user.getRoles());

//		userDAO.saveAffiliations(user, user.getAffiliations());

		//savePerson(user);

	}

	private void loadPersonRelations(User user) {

//

//		if (user.getPublisher() != null && user.getPublisher().getId() != null) {

//			user.setPublisher(publisherManager.getPublisher(user.getPublisher().getId()));

//		} else {

//			user.setPublisher(null);

//		}

//		user.setCoordinatedProjects(projectDAO.getProjectsCoordinatedBy(user.getId()));

//		if (user.getAffiliations() != null) {

//			for (Affiliation affiliation : user.getAffiliations()) {

//				if (affiliation.getOrganization() != null)

//					affiliation.setOrganization(organizationDAO.getOrganization(affiliation.getOrganization().getId()));

//			}

//		}

//

//		if (user.getRoles() != null)

//			for (int i = 0; i < user.getRoles().size(); i++) {

//				user.getRoles().get(i).setRole(userDAO.getRole(user.getRoles().get(i).getRole().getId()));

//			}

	}

	public int getTokenTTL() {

		return tokenTTL;

	}

	public void setTokenTTL(int tokenTTL) {

		this.tokenTTL = tokenTTL;

	}

}