Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import java.time.LocalDateTime;

import java.util.List;

import javax.servlet.http.HttpServletRequest;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

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

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

import org.springframework.stereotype.Controller;

import org.springframework.ui.Model;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.PostMapping;

import org.springframework.web.bind.annotation.RequestParam;

import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;

import com.spice.profitmandi.common.model.ProfitMandiConstants;

import com.spice.profitmandi.dao.entity.auth.AuthUser;

import com.spice.profitmandi.dao.entity.dtr.Role;

import com.spice.profitmandi.dao.entity.dtr.User;

import com.spice.profitmandi.dao.entity.dtr.UserRole;

import com.spice.profitmandi.dao.repository.auth.AuthRepository;

import com.spice.profitmandi.dao.repository.dtr.RoleRepository;

import com.spice.profitmandi.dao.repository.dtr.UserRepository;

import com.spice.profitmandi.dao.repository.dtr.UserRoleRepository;

import com.spice.profitmandi.service.AuthService;

import com.spice.profitmandi.web.model.LoginDetails;

import com.spice.profitmandi.web.util.CookiesProcessor;

@Controller

public class AuthUserController {

	private static final Logger LOGGER = LogManager.getLogger(AuthUserController.class);

	@Autowired

	private AuthService authService;

	@Autowired

	private AuthRepository authRepository;

	@Autowired

	private UserRepository userRepository;

	@Autowired

	private RoleRepository roleRepository;

	@Autowired

	private UserRoleRepository userRoleRepository;

	@Autowired

	private CookiesProcessor cookiesProcessor;

	@Autowired

	@Qualifier("userUserRepository")

	private com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;

	@GetMapping(value = "/createAuthUser")

	public String getcreateAuthUser(HttpServletRequest request,

			@RequestParam(name = "offset", defaultValue = "0") int offset,

			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)

			throws ProfitMandiBusinessException {

		List<AuthUser> authUsers = authRepository.selectAll(offset, limit);

		long size = authRepository.selectCountAuthUser();

		model.addAttribute("authUsers", authUsers);

		model.addAttribute("start", offset + 1);

		model.addAttribute("size", size);

		if (authUsers.size() < limit) {

			model.addAttribute("end", offset + authUsers.size());

		} else {

			model.addAttribute("end", offset + limit);

		}

		return "create-auth-user";

	}

	@PostMapping(value = "/createAuthUser")

	public String createAuthUser(HttpServletRequest request,

			@RequestParam(name = ProfitMandiConstants.FIRST_NAME, defaultValue = "") String firstName,

			@RequestParam(name = ProfitMandiConstants.LAST_NAME, defaultValue = "") String lastName,

			@RequestParam(name = ProfitMandiConstants.EMAIL_ID, defaultValue = "") String emailId,

			@RequestParam(name = ProfitMandiConstants.MOBILE_NUMBER, defaultValue = "") String mobileNumber,

			@RequestParam(name = "offset", defaultValue = "0") int offset,

			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)

			throws ProfitMandiBusinessException {

		AuthUser authUser = null;

		User user = null;

		List<Role> roles = roleRepository.selectAll();

		try {

			user = userRepository.selectByEmailId(emailId);

			userRoleRepository.deleteByUserId(user.getId());

			for (Role role : roles) {

				UserRole userRole = new UserRole();

				userRole.setRoleId(role.getId());

				userRole.setUserId(user.getId());

				userRoleRepository.persist(userRole);

			}

		} catch (Exception ex) {

			user = new User();

			user.setFirstName(firstName);

			user.setLastName(lastName);

			user.setUsername(emailId);

			user.setEmailId(emailId);

			user.setPassword("");

			user.setMobileNumber(mobileNumber);

			user.setCity("Noida");

			user.setPinCode(201301);

			user.setActivated(true);

			user.setMobile_verified(true);

			user.setReferral_url("");

			user.setUpdateTimestamp(LocalDateTime.now());

			user.setStatus(0);

			user.setCreateTimestamp(LocalDateTime.now());

			userRepository.persist(user);

			LOGGER.info("User created successfully");

			for (Role role : roles) {

				UserRole userRole = new UserRole();

				userRole.setRoleId(role.getId());

				userRole.setUserId(user.getId());

				userRoleRepository.persist(userRole);

			}

		}

		authUser = new AuthUser();

		authUser.setEmailId(emailId);

		authUser.setFirstName(firstName);

		authUser.setLastName(lastName);

		authUser.setMobileNumber(mobileNumber);

		authUser.setCreatedTimestamp(LocalDateTime.now());

		authService.addAuthUser(authUser);

		List<AuthUser> authUsers = authRepository.selectAll(offset, limit);

		long size = authRepository.selectCountAuthUser();

		model.addAttribute("authUsers", authUsers);

		model.addAttribute("start", offset + 1);

		model.addAttribute("size", size);

		if (authUsers.size() < limit) {

			model.addAttribute("end", offset + authUsers.size());

		} else {

			model.addAttribute("end", offset + limit);

		}

		return "create-auth-user";

	}

	@GetMapping(value = "/changePassword")

	public String getChangePassword(HttpServletRequest request, Model model) {

		return "change-auth-user-password";

	}

	@PostMapping(value = "/changePassword")

	public String changePassword(HttpServletRequest request,

			@RequestParam(name = "oldPassword", defaultValue = "") String oldPassword,

			@RequestParam(name = "newPassword", defaultValue = "") String newPassword, Model model)

			throws ProfitMandiBusinessException {

		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

		authService.changePassword(loginDetails.getEmailId(), oldPassword, newPassword);

		return "change-auth-user-password";

	}

	@GetMapping(value = "/getPaginatedAuthUser")

	public String getPaginatedAuthUser(HttpServletRequest request,

			@RequestParam(name = "offset", defaultValue = "0") int offset,

			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model) {

		List<AuthUser> authUsers = authRepository.selectAll(offset, limit);

		model.addAttribute("authUsers", authUsers);

		return "auth-users-paginated";

	}

}