1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
package org.openecomp.portalsdk.core.service;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.SortedSet;
import org.openecomp.portalsdk.core.domain.Role;
import org.openecomp.portalsdk.core.domain.User;
import org.openecomp.portalsdk.core.domain.support.CollaborateList;
import org.openecomp.portalsdk.core.logging.logic.EELFLoggerDelegate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import com.fasterxml.jackson.core.JsonParseException;
import com.fasterxml.jackson.databind.JsonMappingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.type.TypeFactory;
@Transactional
public class UserProfileServiceCentalizedImpl implements UserProfileService {
private EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(UserProfileServiceCentalizedImpl.class);
@Autowired
AppService appService;
@Autowired
RestApiRequestBuilder restApiRequestBuilder;
@Autowired
private DataAccessService dataAccessService;
public DataAccessService getDataAccessService() {
return dataAccessService;
}
public void setDataAccessService(DataAccessService dataAccessService) {
this.dataAccessService = dataAccessService;
}
@Override
public List<User> findAll() {
List<User> roles = new ArrayList<>();
ObjectMapper mapper = new ObjectMapper();
String user = restApiRequestBuilder.getViaREST("/findAll", true,null);
try {
roles = mapper.readValue(user,
TypeFactory.defaultInstance().constructCollectionType(List.class, User.class));
} catch (JsonParseException e) {
logger.error(EELFLoggerDelegate.errorLogger, "Json parsing failed", e);
} catch (JsonMappingException e) {
logger.error(EELFLoggerDelegate.errorLogger, "Json mapping failed", e);
} catch (IOException e) {
logger.error(EELFLoggerDelegate.errorLogger, "IO exception", e);
}
return roles;
}
@Override
public User getUser(String id) {
ObjectMapper mapper = new ObjectMapper();
User user = new User();
String responseString = restApiRequestBuilder.getViaREST("/getUser/" + id, true,id);
try {
user = mapper.readValue(responseString, User.class);
} catch (JsonParseException e) {
logger.error(EELFLoggerDelegate.errorLogger, "Json parsing failed", e);
} catch (JsonMappingException e) {
logger.error(EELFLoggerDelegate.errorLogger, "Json mapping failed", e);
} catch (IOException e) {
logger.error(EELFLoggerDelegate.errorLogger, "IO exception", e);
}
return user;
}
@Override
public User getUserByLoginId(String loginId) {
return getUser(loginId);
}
@Override
public void saveUser(User user) {
try {
getDataAccessService().saveDomainObject(user, null);
} catch (Exception e) {
logger.error(EELFLoggerDelegate.errorLogger, "saveUser Failed", e);
}
}
@Override
public List<User> findAllUserWithOnOffline(String originOrgUserId) {
HashSet<String> onlineUser = CollaborateList.getInstance().getAllUserName();
List<User> users = findAll();
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;
}
@Override
public List<User> findAllActive() {
List<User> users = findAll();
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;
}
}
|
