1 files changed, 116 insertions, 0 deletions
diff --git a/ecomp-sdk/epsdk-core/src/main/java/org/openecomp/portalsdk/core/service/UserProfileServiceImpl.java b/ecomp-sdk/epsdk-core/src/main/java/org/openecomp/portalsdk/core/service/UserProfileServiceImpl.java
new file mode 100644
index 00000000..2d134725
--- /dev/null
+++ b/ecomp-sdk/epsdk-core/src/main/java/org/openecomp/portalsdk/core/service/UserProfileServiceImpl.java
@@ -0,0 +1,116 @@
+/*-
+ * ================================================================================
+ * eCOMP Portal SDK
+ * ================================================================================
+ * Copyright (C) 2017 AT&T Intellectual Property
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ================================================================================
+ */
+package org.openecomp.portalsdk.core.service;
+
+import java.util.ArrayList;
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.List;
+import java.util.SortedSet;
+
+import org.hibernate.criterion.Criterion;
+import org.hibernate.criterion.Restrictions;
+import org.openecomp.portalsdk.core.domain.Role;
+import org.openecomp.portalsdk.core.domain.User;
+import org.openecomp.portalsdk.core.domain.support.CollaborateList;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service("userProfileService")
+@Transactional
+public class UserProfileServiceImpl implements UserProfileService{
+
+	
+	@Autowired
+	private DataAccessService  dataAccessService;
+	
+	public List<User> findAll() {
+		return getDataAccessService().getList(User.class, null);
+	}
+	
+	public User getUser(String userId){
+		return (User) getDataAccessService().getDomainObject(User.class, Long.parseLong(userId), null);
+	}
+	
+	@SuppressWarnings("unchecked")
+	public User getUserByLoginId(String loginId){
+		User user=null;
+		List<Criterion> restrictionsList = new ArrayList<Criterion>();
+		Criterion criterion1= Restrictions.eq("loginId",loginId);
+		restrictionsList.add(criterion1);
+		List<User> users = (List<User>) getDataAccessService().getList(User.class,null, restrictionsList, null);
+		if(users!=null && users.size()==1)
+			user = users.get(0);
+		return user;
+	}
+	
+	public void saveUser(User user){
+		
+		getDataAccessService().saveDomainObject(user, null);
+	}
+	
+	public DataAccessService getDataAccessService() {
+		return dataAccessService;
+	}
+
+
+	public void setDataAccessService(DataAccessService dataAccessService) {
+		this.dataAccessService = dataAccessService;
+	}
+	
+	@SuppressWarnings("unchecked")
+	public List<User> findAllUserWithOnOffline(String originOrgUserId) {
+		HashSet<String> onlineUser = CollaborateList.getInstance().getAllUserName();
+		List<User> users =  getDataAccessService().getList(User.class, null);
+		for(User u:users){
+			if(onlineUser.contains(u.getOrgUserId()))
+				u.setOnline(true);
+			if(u.getOrgUserId()!=null){
+				if(originOrgUserId.compareTo(u.getOrgUserId()) > 0) {
+					u.setChatId(originOrgUserId + "-" + u.getOrgUserId());
+				} else u.setChatId(u.getOrgUserId() + "-" + originOrgUserId  );
+			}
+		}
+		return users;
+		
+	}
+	
+	public List<User> findAllActive() {
+		List<User> users =  getDataAccessService().getList(User.class, null);
+		Iterator<User> itr = users.iterator();
+		while(itr.hasNext()){
+			User u = (User) itr.next();
+			if(!u.getActive())
+				itr.remove();//if not active remove user from list
+			else {
+				SortedSet<Role> roles = u.getRoles();
+				Iterator<Role> itrRoles = roles.iterator();
+				while(itrRoles.hasNext()){
+					Role role = (Role) itrRoles.next();
+					if(!role.getActive())
+						u.removeRole(role.getId());//if not active remove role from list
+				}
+			}
+		}
+		return users;
+	}
+
+}