An error occurred while loading the file. Please try again.
-
sarojsingh2021 authored35128dae
package com.tarento.retail.service.impl;import java.io.File;import java.io.IOException;import java.nio.file.Files;import java.nio.file.Path;import java.nio.file.Paths;import java.util.ArrayList;import java.util.Arrays;import java.util.HashSet;import java.util.Iterator;import java.util.List;import java.util.Map;import java.util.Map.Entry;import java.util.Set;import java.util.concurrent.ConcurrentHashMap;import org.apache.commons.lang3.StringUtils;import org.apache.velocity.VelocityContext;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.security.core.authority.SimpleGrantedAuthority;import org.springframework.security.core.userdetails.UserDetails;import org.springframework.security.core.userdetails.UserDetailsService;import org.springframework.security.core.userdetails.UsernameNotFoundException;import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;import org.springframework.stereotype.Service;import org.springframework.web.multipart.MultipartFile;import com.tarento.retail.dao.RoleDao;import com.tarento.retail.dao.UserDao;import com.tarento.retail.dto.CountryDto;import com.tarento.retail.dto.MasterRoleDto;import com.tarento.retail.dto.UserCountryDto;import com.tarento.retail.dto.UserDto;import com.tarento.retail.dto.UserMasterRoleCountryOrgDto;import com.tarento.retail.dto.UserRoleDto;import com.tarento.retail.model.Action;import com.tarento.retail.model.Country;import com.tarento.retail.model.InstituteCourses;import com.tarento.retail.model.KeyValue;import com.tarento.retail.model.LoginAuthentication;import com.tarento.retail.model.Role;import com.tarento.retail.model.SearchRequest;import com.tarento.retail.model.User;import com.tarento.retail.model.UserAuthentication;import com.tarento.retail.model.UserDeviceToken;import com.tarento.retail.model.UserProfile;import com.tarento.retail.model.mapper.SqlDataMapper.UserProfileMapper;import com.tarento.retail.model.mapper.SqlDataMapper.UserRoleActionMapper;import com.tarento.retail.model.mapper.SqlDataMapper.UserRoleMapper;import com.tarento.retail.service.UserService;import com.tarento.retail.util.Cache;import com.tarento.retail.util.Constants;import com.tarento.retail.util.DateUtil;import com.tarento.retail.util.NotificationService;import com.tarento.retail.util.Util;@Service(value = Constants.USER_SERVICE)public class UserServiceImpl implements UserDetailsService, UserService { public static final Logger LOGGER = LoggerFactory.getLogger(UserServiceImpl.class); public static ConcurrentHashMap<String, UserDto> userRoleActionMap = new ConcurrentHashMap<>(); @Autowired private UserDao userDao; @Autowired RoleDao roleDao;7172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140
@Autowired
private BCryptPasswordEncoder bcryptEncoder;
public List<Action> findAllActionsByRoleID(List<Integer> roleID) {
List<Action> actions = new ArrayList<Action>();
List<Action> completeActions = new ArrayList<Action>();
for (int roleid : roleID) {
actions = userDao.findAllActionsByRoleID(roleid);
completeActions.addAll(actions);
}
return completeActions;
}
public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
User user = userDao.findOnlyUser(username);
if (user == null) {
throw new UsernameNotFoundException("Invalid username or password.");
}
return new org.springframework.security.core.userdetails.User(user.getUsername(), user.getPassword(),
getAuthority());
}
private List<SimpleGrantedAuthority> getAuthority() {
return Arrays.asList(new SimpleGrantedAuthority("ROLE_ADMIN"));
}
public List<UserProfile> findAll(Integer pageNumber, Integer numberOfRecords, Boolean active, String keyword,
List<Long> roles, String countryCode, Long orgId) {
List<UserProfile> profileList = new ArrayList<>();
Integer startIndex = 0;
if (pageNumber != null && pageNumber >= 0) {
startIndex = ((pageNumber == 0) ? (pageNumber) : (pageNumber - 1) * numberOfRecords);
}
UserProfileMapper mapper = userDao.findAll(active, keyword, roles, countryCode, orgId);
if (mapper != null) {
Iterator<Entry<Long, UserProfile>> userItr = mapper.userMap.entrySet().iterator();
while (userItr.hasNext()) {
Entry<Long, UserProfile> entry = userItr.next();
if (null != entry.getValue()) {
profileList.add(entry.getValue());
}
}
}
return applyPagignation(startIndex, numberOfRecords, profileList);
}
private List<UserProfile> applyPagignation(Integer startIndex, Integer numberOfRecords,
List<UserProfile> profileList) {
List<UserProfile> finalProfileList = new ArrayList<>();
if (numberOfRecords == null) {
numberOfRecords = profileList.size();
}
for (int i = startIndex; i < (startIndex + numberOfRecords) && i < profileList.size(); i++) {
finalProfileList.add(profileList.get(i));
}
return finalProfileList;
}
@Override
public User findOne(String username) {
return userDao.findByUsername(username);
}
@Override
public UserProfile findById(Long id, Long orgId) {
List<UserProfile> profileList = new ArrayList<>();
UserProfileMapper mapper = userDao.findOne(id, orgId);
if (mapper != null) {
141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210
Iterator<Entry<Long, UserProfile>> userItr = mapper.userMap.entrySet().iterator();
while (userItr.hasNext()) {
Entry<Long, UserProfile> entry = userItr.next();
if (null != entry.getValue()) {
profileList.add(entry.getValue());
}
}
for (UserProfile profile : profileList) {
List<Role> roleList = mapper.userRoleMap.get(profile.getId());
if (roleList != null) {
profile.setRoles(roleList);
}
}
}
return (profileList != null && !profileList.isEmpty()) ? profileList.get(0) : null;
}
@Override
public User save(User user) {
if (StringUtils.isBlank(user.getPassword())) {
user.setPassword("UP-SMF#User");
}
String encryptedPassword = bcryptEncoder.encode(user.getPassword());
user.setPassword(encryptedPassword);
return userDao.save(user);
}
@Override
public UserAuthentication save(UserAuthentication user) {
return userDao.save(user);
}
@Override
public User update(User user) {
return userDao.update(user);
}
@Override
public List<Role> findAllRolesByUser(Long userId, String orgId, String username) {
UserRoleMapper mapper = userDao.findAllRolesByUser(userId, orgId, username);
List<Role> roleList = new ArrayList<>();
Iterator<Entry<Long, Role>> itr = mapper.roleMap.entrySet().iterator();
while (itr.hasNext()) {
roleList.add(itr.next().getValue());
}
return roleList;
}
@Override
public Set<Action> findAllActionsByUser(Long userId, String orgId) {
Set<Action> actions = new HashSet<Action>();
UserRoleMapper mapper = userDao.findAllRolesByUser(userId, orgId, null);
List<Role> roleList = new ArrayList<>();
Iterator<Entry<Long, Role>> itr = mapper.roleMap.entrySet().iterator();
while (itr.hasNext()) {
roleList.add(itr.next().getValue());
}
for (Role role : roleList) {
actions.addAll(roleDao.findAllActionsByRole(role.getId()));
}
return actions;
}
@Override
public User findMobile(String phoneNo) {
return userDao.findMobile(phoneNo);
}
211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280
@Override
public Boolean mapUserToRole(UserRoleDto userRole) {
return userDao.mapUserToRole(userRole);
}
@Override
public UserProfile saveUserProfile(UserProfile profile) {
User newUser = new User();
newUser.setUsername(profile.getUsername());
newUser.setEmailId(profile.getEmailId());
newUser.setPassword(profile.getPassword());
newUser.setPhoneNo(profile.getPhoneNo());
newUser.setOrgId(profile.getOrgId());
newUser.setCountryCode(profile.getCountryCode());
newUser.setTimeZone(profile.getTimeZone());
newUser.setAvatarUrl(profile.getAvatarUrl());
if (profile.getId() != null) {
newUser.setIsActive(profile.getIsActive());
newUser.setIsDeleted(profile.getIsDeleted());
} else {
newUser.setIsActive(Boolean.TRUE);
newUser.setIsDeleted(Boolean.FALSE);
}
User savedUser = save(newUser);
if (savedUser != null) {
profile.setId(savedUser.getId());
profile = userDao.saveUserProfile(profile);
// update user role
if (profile != null && (profile.getRoleId() != null || profile.getRoles() != null)) {
UserRoleDto userRole = new UserRoleDto();
userRole.setUserId(profile.getId());
if (StringUtils.isNotBlank(profile.getOrgId())) {
userRole.setOrgId(Long.parseLong(profile.getOrgId()));
}
userRole.setRoleId(profile.getRoleId());
userRole.setRoles(profile.getRoles());
userDao.mapUserToRole(userRole);
}
return profile;
}
return null;
}
@Override
public UserProfile updateUserProfileImage(UserProfile profile) {
return userDao.updateUserProfileImage(profile);
}
@Override
public Long checkUserNameExists(String emailId, String phoneNo) {
return userDao.checkUserNameExists(emailId, phoneNo);
}
@Override
public Boolean uploadFile(MultipartFile file, long userId) {
try {
// Get the file and save it somewhere
if (!new File(Constants.UPLOADED_FOLDER).exists()) {
if (new File(Constants.UPLOADED_FOLDER).mkdir()) {
LOGGER.info("Directory is created!");
} else {
LOGGER.error("Failed to create directory!");
}
} else {
LOGGER.info("Folder exist");
}
UserProfile userProfile = new UserProfile();
281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350
byte[] bytes = file.getBytes();
Path path = Paths.get(Constants.UPLOADED_FOLDER + userId + "_" + file.getOriginalFilename());
LOGGER.info("Path before write: " + path);
Path path1 = Files.write(path, bytes);
LOGGER.info("Path after write : " + path1);
if (path1 != null) {
List<UserProfile> profileList = new ArrayList<>();
UserProfileMapper userProfileMapper = userDao.findOneUser(userId);
if (userProfileMapper != null) {
Iterator<Entry<Long, UserProfile>> userItr = userProfileMapper.userMap.entrySet().iterator();
while (userItr.hasNext()) {
Entry<Long, UserProfile> entry = userItr.next();
if (null != entry.getValue()) {
profileList.add(entry.getValue());
}
}
for (UserProfile profile : profileList) {
List<Role> roleList = userProfileMapper.userRoleMap.get(profile.getId());
if (roleList != null) {
profile.setRoles(roleList);
}
}
}
userProfile = (profileList != null && !profileList.isEmpty()) ? profileList.get(0) : null;
userProfile.setAvatarUrl(userId + "_" + file.getOriginalFilename());
UserProfile profile = this.updateUserProfileImage(userProfile);
if (profile.getAvatarUrl() == userProfile.getAvatarUrl())
return true;
else
return false;
} else
return false;
} catch (IOException e) {
LOGGER.error(String.format(Constants.EXCEPTION_METHOD, "uploadFile", e.getMessage()));
return false;
}
}
@Override
public List<UserProfile> findListOfUsers(List<Long> userIdList) {
List<UserProfile> profileList = new ArrayList<>();
UserProfileMapper mapper = userDao.findListOfUsers(userIdList);
if (mapper != null) {
Iterator<Entry<Long, UserProfile>> userItr = mapper.userMap.entrySet().iterator();
while (userItr.hasNext()) {
Entry<Long, UserProfile> entry = userItr.next();
if (null != entry.getValue()) {
profileList.add(entry.getValue());
}
}
for (UserProfile profile : profileList) {
List<Role> roleList = mapper.userRoleMap.get(profile.getId());
if (roleList != null) {
profile.setRoles(roleList);
}
}
}
return profileList;
}
@Override
public UserProfile updateUserProfile(UserProfile profile) {
User newUser = new User();
newUser.setId(profile.getId());
newUser.setUsername(profile.getUsername());
351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420
newUser.setEmailId(profile.getEmailId());
newUser.setPassword(profile.getPassword());
newUser.setPhoneNo(profile.getPhoneNo());
newUser.setIsActive(profile.getIsActive());
newUser.setIsDeleted(profile.getIsDeleted());
newUser.setTimeZone(profile.getTimeZone());
newUser.setAvatarUrl(profile.getAvatarUrl());
if (update(newUser) != null) {
userDao.updateUserProfile(profile);
// update user role
if (profile != null && (profile.getRoleId() != null || profile.getRoles() != null)) {
UserRoleDto userRole = new UserRoleDto();
userRole.setUserId(profile.getId());
if (StringUtils.isNotBlank(profile.getOrgId())) {
userRole.setOrgId(Long.parseLong(profile.getOrgId()));
}
userRole.setRoleId(profile.getRoleId());
userRole.setRoles(profile.getRoles());
userDao.mapUserToRole(userRole);
}
return profile;
}
return null;
}
@Override
public Long getNumberOfUsers(Long role, Boolean active) {
return userDao.getNumberOfUsers(role, active);
}
@Override
public Long getNumberOfRoles() {
return userDao.getNumberOfRoles();
}
@Override
public List<Country> getCountryList() {
return userDao.getCountryList();
}
@Override
public List<Country> getCountryListForUser(Long userId) {
return userDao.getCountryListForUser(userId);
}
@Override
public List<Country> getCountryListForOrg(Long orgId) {
return userDao.getCountryListForOrg(orgId);
}
@Override
public Boolean mapUserToCountry(UserCountryDto userCountry) {
return userDao.mapUserToCountry(userCountry);
}
@Override
public Boolean invalidateToken(String authToken) {
return userDao.invalidateToken(authToken);
}
@Override
public Boolean findUserByToken(String authToken) {
return userDao.findUserByToken(authToken);
}
@Override
public Boolean checkUserTokenExists(Long userId, String deviceToken) {
return userDao.checkUserTokenExists(userId, deviceToken);
}
421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490
@Override
public Boolean updateUserDeviceToken(Long userId, String deviceToken, String deviceId, Long authTokenRef) {
return userDao.insertUserDeviceToken(userId, deviceToken, deviceId, authTokenRef);
}
@Override
public List<UserDeviceToken> getDeviceTokenForUsers(List<Long> userIdList) {
return userDao.getDeviceTokenForUserList(userIdList);
}
@Override
public Long fetchAuthTokenReference(String authToken) {
return userDao.fetchAuthTokenReference(authToken);
}
@Override
public Boolean hasAccess(List<Role> roles) {
List<Long> roleIds = new ArrayList<>();
for (Role role : roles) {
roleIds.add(role.getId());
}
List<Action> userActions = userDao.findAllActionsByRoleIDs(roleIds);
return false;
}
@Override
public Boolean createCountry(CountryDto countryDto) {
return userDao.saveCountry(countryDto);
}
@Override
public Boolean updateCountry(CountryDto countryDto) {
return userDao.updateCountry(countryDto);
}
@Override
public Boolean checkCountryAlreadyExists(String code, Long orgId) {
return userDao.checkCountryExistsWithCode(code, orgId);
}
@Override
public Boolean deleteUserToRole(UserRoleDto userRole) {
return userDao.deleteUserToRole(userRole);
}
@Override
public Boolean deleteCountryForOrg(CountryDto countryDto) {
System.out.println("ID: " + countryDto.getId() + " OrgId " + countryDto.getOrgId());
return userDao.deleteCountryForOrg(countryDto);
}
@Override
public Boolean deleteUser(UserDto userDto) {
return userDao.deleteUser(userDto);
}
@Override
public Boolean softDeleteUser(UserDto userDto) {
return userDao.softDeleteUser(userDto);
}
@Override
public List<UserDto> getUsersByMasterRole(String roleCode, Long orgId) {
return userDao.getUsersByMasterRole(roleCode, orgId);
}
@Override
public Boolean mapUserMasterRoleCountryOrg(UserMasterRoleCountryOrgDto userMasterRoleCountryOrgDto) {
return userDao.mapUserMasterRoleCountryOrg(userMasterRoleCountryOrgDto);
}
491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560
@Override
public List<MasterRoleDto> getMasterRoleByOrgDomainId(Long orgDomainId) {
return userDao.getMasterRoleByOrgDomainId(orgDomainId);
}
@Override
public UserDto findUserRolesActions(String username) {
if (userRoleActionMap.contains(username)) {
return userRoleActionMap.get(username);
} else {
UserRoleActionMapper mapper = userDao.findUserRolesActions(username);
UserDto userDto = getUserFromMapper(mapper);
userRoleActionMap.put(userDto.getUserName(), userDto);
return userDto;
}
}
private UserDto getUserFromMapper(UserRoleActionMapper mapper) {
UserDto dto = new UserDto();
Iterator<Entry<Long, UserDto>> itr = mapper.userMap.entrySet().iterator();
List<Role> roleList = new ArrayList<>();
Set<Action> actionSet = new HashSet<Action>();
while (itr.hasNext()) {
Entry<Long, UserDto> userEntry = itr.next();
Long userId = userEntry.getKey();
dto = userEntry.getValue();
Map<Long, Role> roleMap = mapper.userRoleMap.get(userId);
if (roleMap != null) {
Iterator<Entry<Long, Role>> roleItr = roleMap.entrySet().iterator();
while (roleItr.hasNext()) {
Entry<Long, Role> roleEntry = roleItr.next();
Long roleId = roleEntry.getKey();
Role role = roleEntry.getValue();
roleList.add(role);
Map<Long, Action> roleActionMap = mapper.roleActionMap.get(roleId);
if (roleActionMap != null) {
Iterator<Entry<Long, Action>> actionItr = roleActionMap.entrySet().iterator();
while (actionItr.hasNext()) {
Entry<Long, Action> actionEntry = actionItr.next();
Action action = actionEntry.getValue();
actionSet.add(action);
}
}
}
}
}
dto.setRoles(roleList);
dto.setActions(actionSet);
return dto;
}
@Override
public UserProfile getUserProfile(String username) {
return userDao.getUserProfile(username);
}
@Override
public Boolean requestOTP(String email) {
try {
String otp = Util.generateOTP();
// send Email
String[] receipent = { email };
VelocityContext context = new VelocityContext();
context.put("otp", otp);
Boolean sendEmail = NotificationService.sendMail(receipent, Constants.OTP_EMAIL_SUBJECT, context,
Constants.EmailTemplate.OTP);
if (sendEmail) {
Cache.setUserOTPData(email, otp);
return Boolean.TRUE;
561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630
}
} catch (Exception e) {
LOGGER.error(String.format(Constants.EXCEPTION_METHOD, "requestOTP", e.getMessage()));
}
return Boolean.FALSE;
}
@Override
public Boolean validateUserOTP(String username, String otp) {
return Boolean.TRUE; //remove when commit the code
/*
try {
LoginAuthentication loginAuth = Cache.getUserAuthData(username);
if (loginAuth != null && loginAuth.getOtpExpiryDate() > DateUtil.getCurrentTimestamp()
&& loginAuth.getOtp().equals(otp)) {
return Boolean.TRUE;
}
} catch (Exception e) {
LOGGER.error(String.format(Constants.EXCEPTION_METHOD, "validateUserOTP", e.getMessage()));
}
return Boolean.FALSE;
*/
}
@Override
public List<UserProfile> findAll(SearchRequest searchRequest) {
List<UserProfile> profileList = new ArrayList<>();
UserProfileMapper mapper = userDao.findAll(searchRequest);
if (mapper != null) {
Iterator<Entry<Long, UserProfile>> userItr = mapper.userMap.entrySet().iterator();
while (userItr.hasNext()) {
Entry<Long, UserProfile> entry = userItr.next();
if (null != entry.getValue()) {
profileList.add(entry.getValue());
}
}
}
return profileList;
}
@Override
public List<KeyValue> getNumberOfUsersAndRoles() {
return userDao.getNumberOfUsersAndRoles();
}
@Override
public Boolean setUserPin(int pin, Long userId) {
String encryptedPin = bcryptEncoder.encode(String.valueOf(pin));
return userDao.setUserPin(encryptedPin, userId);
}
@Override
public Boolean validateUserPin(String username, int pin) {
return userDao.validateUserPin(pin, username);
}
@Override
public Boolean deleteDeviceToken(Long userId, String deviceId) {
return userDao.deleteDeviceToken(userId, deviceId);
}
@Override
public Boolean updateDeviceAuthRef(Long userId, String deviceToken, Long authId) {
return userDao.updateDeviceAuthRef(userId, deviceToken, authId);
}
@Override
public InstituteCourses getInstituteCourses(Long profileId, String course, String degree) {
return userDao.getInstituteCourses(profileId, course, degree);
631632633634635636637638639
}
@Override
public Boolean saveInstituteCourse(InstituteCourses instituteCourses) {
return userDao.saveInstituteCourse(instituteCourses);
}
}