| 1 | |
|
| 2 | |
|
| 3 | |
|
| 4 | |
|
| 5 | |
|
| 6 | |
|
| 7 | |
|
| 8 | |
|
| 9 | |
|
| 10 | |
|
| 11 | |
|
| 12 | |
|
| 13 | |
|
| 14 | |
|
| 15 | |
|
| 16 | |
package org.kuali.rice.kim.impl.role; |
| 17 | |
|
| 18 | |
import org.apache.commons.collections.CollectionUtils; |
| 19 | |
import org.apache.commons.lang.StringUtils; |
| 20 | |
import org.apache.ojb.broker.query.Criteria; |
| 21 | |
import org.apache.ojb.broker.query.Query; |
| 22 | |
import org.apache.ojb.broker.query.QueryFactory; |
| 23 | |
import org.apache.ojb.broker.query.ReportQueryByCriteria; |
| 24 | |
import org.joda.time.DateTime; |
| 25 | |
import org.kuali.rice.core.api.criteria.Predicate; |
| 26 | |
import org.kuali.rice.core.api.criteria.PredicateFactory; |
| 27 | |
import org.kuali.rice.core.api.criteria.QueryByCriteria; |
| 28 | |
import org.kuali.rice.core.api.membership.MemberType; |
| 29 | |
import org.kuali.rice.core.framework.persistence.ojb.dao.PlatformAwareDaoBaseOjb; |
| 30 | |
import org.kuali.rice.kim.api.KimConstants; |
| 31 | |
import org.kuali.rice.kim.api.group.GroupMember; |
| 32 | |
import org.kuali.rice.kim.api.identity.entity.EntityDefault; |
| 33 | |
import org.kuali.rice.kim.api.identity.principal.Principal; |
| 34 | |
import org.kuali.rice.kim.api.permission.Permission; |
| 35 | |
import org.kuali.rice.kim.api.responsibility.Responsibility; |
| 36 | |
import org.kuali.rice.kim.api.responsibility.ResponsibilityQueryResults; |
| 37 | |
import org.kuali.rice.kim.api.responsibility.ResponsibilityService; |
| 38 | |
import org.kuali.rice.kim.api.role.Role; |
| 39 | |
import org.kuali.rice.kim.api.role.RoleMember; |
| 40 | |
import org.kuali.rice.kim.api.role.RoleMembership; |
| 41 | |
import org.kuali.rice.kim.api.services.KimApiServiceLocator; |
| 42 | |
import org.kuali.rice.kim.impl.KIMPropertyConstants; |
| 43 | |
import org.kuali.rice.kim.impl.common.delegate.DelegateTypeBo; |
| 44 | |
import org.kuali.rice.kim.impl.common.delegate.DelegateMemberBo; |
| 45 | |
|
| 46 | |
import java.sql.Timestamp; |
| 47 | |
import java.util.ArrayList; |
| 48 | |
import java.util.Collection; |
| 49 | |
import java.util.HashMap; |
| 50 | |
import java.util.List; |
| 51 | |
import java.util.Map; |
| 52 | |
import java.util.Map.Entry; |
| 53 | |
|
| 54 | |
import static org.kuali.rice.core.api.criteria.PredicateFactory.*; |
| 55 | |
|
| 56 | 0 | public class RoleDaoOjb extends PlatformAwareDaoBaseOjb implements RoleDao { |
| 57 | |
|
| 58 | |
|
| 59 | |
|
| 60 | |
|
| 61 | |
|
| 62 | |
|
| 63 | |
private void addSubCriteriaBasedOnRoleQualification(Criteria c, Map<String, String> qualification) { |
| 64 | 0 | if (qualification != null && CollectionUtils.isNotEmpty(qualification.keySet())) { |
| 65 | 0 | for (Map.Entry<String, String> qualifier : qualification.entrySet()) { |
| 66 | 0 | Criteria subCrit = new Criteria(); |
| 67 | 0 | if (StringUtils.isNotEmpty(qualifier.getValue())) { |
| 68 | 0 | String value = (qualifier.getValue()).replace('*', '%'); |
| 69 | 0 | subCrit.addLike("attributeValue", value); |
| 70 | 0 | subCrit.addEqualTo("kimAttributeId", qualifier.getKey()); |
| 71 | 0 | subCrit.addEqualToField("roleMemberId", Criteria.PARENT_QUERY_PREFIX + "roleMemberId"); |
| 72 | 0 | ReportQueryByCriteria subQuery = QueryFactory.newReportQuery(RoleMemberAttributeDataBo.class, subCrit); |
| 73 | 0 | c.addExists(subQuery); |
| 74 | |
} |
| 75 | 0 | } |
| 76 | |
} |
| 77 | 0 | } |
| 78 | |
|
| 79 | |
@SuppressWarnings("unchecked") |
| 80 | |
public List<RoleMemberBo> getRolePrincipalsForPrincipalIdAndRoleIds(Collection<String> roleIds, String principalId, Map<String, String> qualification) { |
| 81 | |
|
| 82 | 0 | Criteria c = new Criteria(); |
| 83 | |
|
| 84 | 0 | if (roleIds != null) { |
| 85 | 0 | c.addIn(KIMPropertyConstants.RoleMember.ROLE_ID, roleIds); |
| 86 | |
} |
| 87 | 0 | if (principalId != null) { |
| 88 | 0 | c.addEqualTo(KIMPropertyConstants.RoleMember.MEMBER_ID, principalId); |
| 89 | |
} |
| 90 | 0 | c.addEqualTo(KIMPropertyConstants.RoleMember.MEMBER_TYPE_CODE, MemberType.PRINCIPAL.getCode()); |
| 91 | 0 | addSubCriteriaBasedOnRoleQualification(c, qualification); |
| 92 | |
|
| 93 | 0 | Query query = QueryFactory.newQuery(RoleMemberBo.class, c); |
| 94 | 0 | Collection<RoleMemberBo> coll = getPersistenceBrokerTemplate().getCollectionByQuery(query); |
| 95 | 0 | ArrayList<RoleMemberBo> results = new ArrayList<RoleMemberBo>(coll.size()); |
| 96 | 0 | for (RoleMemberBo rm : coll) { |
| 97 | 0 | if (rm.isActive(new Timestamp(System.currentTimeMillis()))) { |
| 98 | 0 | results.add(rm); |
| 99 | |
} |
| 100 | |
} |
| 101 | 0 | return results; |
| 102 | |
} |
| 103 | |
|
| 104 | |
public List<GroupMember> getGroupPrincipalsForPrincipalIdAndGroupIds(Collection<String> groupIds, String principalId) { |
| 105 | 0 | List<String> groupIdValues = new ArrayList<String>(); |
| 106 | 0 | List<GroupMember> groupPrincipals = new ArrayList<GroupMember>(); |
| 107 | 0 | if (groupIds != null |
| 108 | |
&& principalId == null) { |
| 109 | 0 | groupIdValues = new ArrayList<String>(groupIds); |
| 110 | 0 | } else if (principalId != null) { |
| 111 | 0 | groupIdValues = KimApiServiceLocator.getGroupService().getGroupIdsByPrincipalId(principalId); |
| 112 | |
} |
| 113 | 0 | if (groupIdValues != null |
| 114 | |
&& groupIdValues.size() > 0) { |
| 115 | 0 | Collection<GroupMember> groupMembers = KimApiServiceLocator.getGroupService().getMembers(groupIdValues); |
| 116 | 0 | for (GroupMember groupMembershipInfo : groupMembers) { |
| 117 | 0 | if (principalId != null) { |
| 118 | 0 | if (MemberType.PRINCIPAL.equals(groupMembershipInfo.getType()) |
| 119 | |
&& StringUtils.equals(principalId, groupMembershipInfo.getMemberId()) |
| 120 | |
&& groupMembershipInfo.isActive(new DateTime())) { |
| 121 | 0 | groupPrincipals.add(groupMembershipInfo); |
| 122 | |
} |
| 123 | |
} else { |
| 124 | 0 | groupPrincipals.add(groupMembershipInfo); |
| 125 | |
} |
| 126 | |
} |
| 127 | |
} |
| 128 | 0 | return groupPrincipals; |
| 129 | |
} |
| 130 | |
|
| 131 | |
public List<GroupMember> getGroupMembers(Collection<String> groupIds) { |
| 132 | 0 | List<GroupMember> groupMembers = new ArrayList<GroupMember>(); |
| 133 | 0 | if (groupIds != null) { |
| 134 | 0 | List<String> groupIdValues = new ArrayList<String>(groupIds); |
| 135 | |
|
| 136 | 0 | if (groupIdValues.size() > 0) { |
| 137 | |
|
| 138 | 0 | Collection<GroupMember> groupMemberships = KimApiServiceLocator.getGroupService().getMembers(groupIdValues); |
| 139 | |
|
| 140 | 0 | if (!CollectionUtils.isEmpty(groupMemberships)) { |
| 141 | 0 | for (GroupMember groupMembershipInfo : groupMemberships) { |
| 142 | 0 | if (MemberType.GROUP.equals(groupMembershipInfo.getType()) |
| 143 | |
&& groupMembershipInfo.isActive(new DateTime())) { |
| 144 | 0 | groupMembers.add(groupMembershipInfo); |
| 145 | |
} |
| 146 | |
} |
| 147 | |
} |
| 148 | |
} |
| 149 | |
} |
| 150 | 0 | return groupMembers; |
| 151 | |
} |
| 152 | |
|
| 153 | |
@SuppressWarnings("unchecked") |
| 154 | |
public List<RoleMemberBo> getRoleGroupsForGroupIdsAndRoleIds(Collection<String> roleIds, Collection<String> groupIds, Map<String, String> qualification) { |
| 155 | 0 | Criteria c = new Criteria(); |
| 156 | 0 | if (roleIds != null && !roleIds.isEmpty()) { |
| 157 | 0 | c.addIn(KIMPropertyConstants.RoleMember.ROLE_ID, roleIds); |
| 158 | |
} |
| 159 | 0 | if (groupIds != null && !groupIds.isEmpty()) { |
| 160 | 0 | c.addIn(KIMPropertyConstants.RoleMember.MEMBER_ID, groupIds); |
| 161 | |
} |
| 162 | 0 | c.addEqualTo(KIMPropertyConstants.RoleMember.MEMBER_TYPE_CODE, MemberType.GROUP.getCode()); |
| 163 | 0 | addSubCriteriaBasedOnRoleQualification(c, qualification); |
| 164 | |
|
| 165 | 0 | Query query = QueryFactory.newQuery(RoleMemberBo.class, c); |
| 166 | 0 | Collection<RoleMemberBo> coll = getPersistenceBrokerTemplate().getCollectionByQuery(query); |
| 167 | 0 | ArrayList<RoleMemberBo> results = new ArrayList<RoleMemberBo>(coll.size()); |
| 168 | 0 | for (RoleMemberBo rm : coll) { |
| 169 | 0 | if (rm.isActive(new Timestamp(System.currentTimeMillis()))) { |
| 170 | 0 | results.add(rm); |
| 171 | |
} |
| 172 | |
} |
| 173 | 0 | return results; |
| 174 | |
} |
| 175 | |
|
| 176 | |
@SuppressWarnings("unchecked") |
| 177 | |
public Map<String, DelegateTypeBo> getDelegationImplMapFromRoleIds(Collection<String> roleIds) { |
| 178 | 0 | Map<String, DelegateTypeBo> results = new HashMap<String, DelegateTypeBo>(); |
| 179 | 0 | if (CollectionUtils.isNotEmpty(roleIds)) { |
| 180 | 0 | Criteria c = new Criteria(); |
| 181 | 0 | c.addIn(KIMPropertyConstants.Delegation.ROLE_ID, roleIds); |
| 182 | 0 | c.addEqualTo(KIMPropertyConstants.Delegation.ACTIVE, Boolean.TRUE); |
| 183 | 0 | Query query = QueryFactory.newQuery(DelegateTypeBo.class, c); |
| 184 | 0 | Collection<DelegateTypeBo> coll = getPersistenceBrokerTemplate().getCollectionByQuery(query); |
| 185 | 0 | for (DelegateTypeBo delegateBo : coll) { |
| 186 | 0 | results.put(delegateBo.getDelegationId(), delegateBo); |
| 187 | |
} |
| 188 | |
} |
| 189 | 0 | return results; |
| 190 | |
} |
| 191 | |
|
| 192 | |
@SuppressWarnings("unchecked") |
| 193 | |
public List<DelegateTypeBo> getDelegationBosForRoleIds(Collection<String> roleIds) { |
| 194 | 0 | List<DelegateTypeBo> results = new ArrayList<DelegateTypeBo>(); |
| 195 | 0 | if (roleIds != null && !roleIds.isEmpty()) { |
| 196 | 0 | Criteria c = new Criteria(); |
| 197 | 0 | c.addIn(KIMPropertyConstants.Delegation.ROLE_ID, roleIds); |
| 198 | 0 | c.addEqualTo(KIMPropertyConstants.Delegation.ACTIVE, Boolean.TRUE); |
| 199 | 0 | Query query = QueryFactory.newQuery(DelegateTypeBo.class, c); |
| 200 | 0 | Collection<DelegateTypeBo> coll = getPersistenceBrokerTemplate().getCollectionByQuery(query); |
| 201 | 0 | for (DelegateTypeBo delegateBo : coll) { |
| 202 | 0 | results.add(delegateBo); |
| 203 | |
} |
| 204 | |
} |
| 205 | 0 | return results; |
| 206 | |
} |
| 207 | |
|
| 208 | |
@SuppressWarnings("unchecked") |
| 209 | |
public List<DelegateMemberBo> getDelegationPrincipalsForPrincipalIdAndDelegationIds( |
| 210 | |
Collection<String> delegationIds, String principalId) { |
| 211 | 0 | Criteria c = new Criteria(); |
| 212 | |
|
| 213 | 0 | if (principalId != null) { |
| 214 | 0 | c.addEqualTo(KIMPropertyConstants.DelegationMember.MEMBER_ID, principalId); |
| 215 | |
} |
| 216 | 0 | c.addEqualTo(KIMPropertyConstants.DelegationMember.MEMBER_TYPE_CODE, MemberType.PRINCIPAL.getCode()); |
| 217 | 0 | if (delegationIds != null && !delegationIds.isEmpty()) { |
| 218 | 0 | c.addIn(KIMPropertyConstants.DelegationMember.DELEGATION_ID, delegationIds); |
| 219 | |
} |
| 220 | 0 | Query query = QueryFactory.newQuery(DelegateMemberBo.class, c); |
| 221 | 0 | Collection<DelegateMemberBo> coll = getPersistenceBrokerTemplate().getCollectionByQuery(query); |
| 222 | 0 | ArrayList<DelegateMemberBo> results = new ArrayList<DelegateMemberBo>(coll.size()); |
| 223 | 0 | for (DelegateMemberBo rm : coll) { |
| 224 | 0 | if (rm.isActive(new Timestamp(System.currentTimeMillis()))) { |
| 225 | 0 | results.add(rm); |
| 226 | |
} |
| 227 | |
} |
| 228 | 0 | return results; |
| 229 | |
} |
| 230 | |
|
| 231 | |
@SuppressWarnings("unchecked") |
| 232 | |
public List<DelegateMemberBo> getDelegationGroupsForGroupIdsAndDelegationIds( |
| 233 | |
Collection<String> delegationIds, List<String> groupIds) { |
| 234 | 0 | Criteria c = new Criteria(); |
| 235 | 0 | if (delegationIds != null && !delegationIds.isEmpty()) { |
| 236 | 0 | c.addIn(KIMPropertyConstants.DelegationMember.DELEGATION_ID, delegationIds); |
| 237 | |
} |
| 238 | 0 | if (groupIds != null && !groupIds.isEmpty()) { |
| 239 | 0 | c.addIn(KIMPropertyConstants.DelegationMember.MEMBER_ID, groupIds); |
| 240 | |
} |
| 241 | 0 | c.addEqualTo(KIMPropertyConstants.DelegationMember.MEMBER_TYPE_CODE, MemberType.GROUP.getCode()); |
| 242 | 0 | Query query = QueryFactory.newQuery(DelegateMemberBo.class, c); |
| 243 | 0 | Collection<DelegateMemberBo> coll = getPersistenceBrokerTemplate().getCollectionByQuery(query); |
| 244 | 0 | ArrayList<DelegateMemberBo> results = new ArrayList<DelegateMemberBo>(coll.size()); |
| 245 | 0 | for (DelegateMemberBo rm : coll) { |
| 246 | 0 | if (rm.isActive(new Timestamp(System.currentTimeMillis()))) { |
| 247 | 0 | results.add(rm); |
| 248 | |
} |
| 249 | |
} |
| 250 | 0 | return results; |
| 251 | |
} |
| 252 | |
|
| 253 | |
@SuppressWarnings("unchecked") |
| 254 | |
public List<RoleMemberBo> getRoleMembersForRoleIds(Collection<String> roleIds, String memberTypeCode, Map<String, String> qualification) { |
| 255 | 0 | Criteria c = new Criteria(); |
| 256 | |
|
| 257 | 0 | if (roleIds != null && !roleIds.isEmpty()) { |
| 258 | 0 | c.addIn(KIMPropertyConstants.RoleMember.ROLE_ID, roleIds); |
| 259 | |
} |
| 260 | 0 | if (memberTypeCode != null) { |
| 261 | 0 | c.addEqualTo(KIMPropertyConstants.RoleMember.MEMBER_TYPE_CODE, memberTypeCode); |
| 262 | |
} |
| 263 | 0 | addSubCriteriaBasedOnRoleQualification(c, qualification); |
| 264 | |
|
| 265 | 0 | Query query = QueryFactory.newQuery(RoleMemberBo.class, c); |
| 266 | 0 | Collection<RoleMemberBo> coll = getPersistenceBrokerTemplate().getCollectionByQuery(query); |
| 267 | 0 | ArrayList<RoleMemberBo> results = new ArrayList<RoleMemberBo>(coll.size()); |
| 268 | 0 | for (RoleMemberBo rm : coll) { |
| 269 | 0 | if (rm.isActive(new Timestamp(System.currentTimeMillis()))) { |
| 270 | 0 | results.add(rm); |
| 271 | |
} |
| 272 | |
} |
| 273 | 0 | return results; |
| 274 | |
} |
| 275 | |
|
| 276 | |
@SuppressWarnings("unchecked") |
| 277 | |
public List<RoleMemberBo> getRoleMembershipsForRoleIdsAsMembers(Collection<String> roleIds, Map<String, String> qualification) { |
| 278 | 0 | Criteria c = new Criteria(); |
| 279 | |
|
| 280 | 0 | if (roleIds != null && !roleIds.isEmpty()) { |
| 281 | 0 | c.addIn(KIMPropertyConstants.RoleMember.MEMBER_ID, roleIds); |
| 282 | |
} |
| 283 | 0 | c.addEqualTo(KIMPropertyConstants.RoleMember.MEMBER_TYPE_CODE, MemberType.ROLE.getCode()); |
| 284 | 0 | addSubCriteriaBasedOnRoleQualification(c, qualification); |
| 285 | |
|
| 286 | 0 | Query query = QueryFactory.newQuery(RoleMemberBo.class, c); |
| 287 | 0 | Collection<RoleMemberBo> coll = getPersistenceBrokerTemplate().getCollectionByQuery(query); |
| 288 | 0 | ArrayList<RoleMemberBo> results = new ArrayList<RoleMemberBo>(coll.size()); |
| 289 | 0 | for (RoleMemberBo rm : coll) { |
| 290 | 0 | if (rm.isActive(new Timestamp(System.currentTimeMillis()))) { |
| 291 | 0 | results.add(rm); |
| 292 | |
} |
| 293 | |
} |
| 294 | 0 | return results; |
| 295 | |
} |
| 296 | |
|
| 297 | |
@SuppressWarnings("unchecked") |
| 298 | |
public List<RoleMemberBo> getRoleMembershipsForMemberId(String memberType, String memberId, Map<String, String> qualification) { |
| 299 | 0 | Criteria c = new Criteria(); |
| 300 | 0 | List<RoleMemberBo> parentRoleMembers = new ArrayList<RoleMemberBo>(); |
| 301 | |
|
| 302 | 0 | if (StringUtils.isEmpty(memberId) |
| 303 | |
|| StringUtils.isEmpty(memberType)) { |
| 304 | 0 | return parentRoleMembers; |
| 305 | |
} |
| 306 | |
|
| 307 | 0 | c.addEqualTo(KIMPropertyConstants.RoleMember.MEMBER_ID, memberId); |
| 308 | 0 | c.addEqualTo(KIMPropertyConstants.RoleMember.MEMBER_TYPE_CODE, memberType); |
| 309 | 0 | addSubCriteriaBasedOnRoleQualification(c, qualification); |
| 310 | |
|
| 311 | 0 | Query query = QueryFactory.newQuery(RoleMemberBo.class, c); |
| 312 | 0 | Collection<RoleMemberBo> coll = getPersistenceBrokerTemplate().getCollectionByQuery(query); |
| 313 | 0 | ArrayList<RoleMemberBo> results = new ArrayList<RoleMemberBo>(coll.size()); |
| 314 | 0 | for (RoleMemberBo rm : coll) { |
| 315 | 0 | if (rm.isActive(new Timestamp(System.currentTimeMillis()))) { |
| 316 | 0 | results.add(rm); |
| 317 | |
} |
| 318 | |
} |
| 319 | 0 | return results; |
| 320 | |
} |
| 321 | |
|
| 322 | |
@SuppressWarnings("unchecked") |
| 323 | |
public List<RoleMemberBo> getRoleMembersForRoleIdsWithFilters(Collection<String> roleIds, String principalId, Collection<String> groupIds, Map<String, String> qualification) { |
| 324 | 0 | Criteria c = new Criteria(); |
| 325 | |
|
| 326 | 0 | if (roleIds != null && !roleIds.isEmpty()) { |
| 327 | 0 | c.addIn(KIMPropertyConstants.RoleMember.ROLE_ID, roleIds); |
| 328 | |
} |
| 329 | 0 | Criteria orSet = new Criteria(); |
| 330 | 0 | orSet.addEqualTo(KIMPropertyConstants.RoleMember.MEMBER_TYPE_CODE, MemberType.ROLE.getCode()); |
| 331 | 0 | Criteria principalCheck = new Criteria(); |
| 332 | 0 | if (principalId != null) { |
| 333 | 0 | principalCheck.addEqualTo(KIMPropertyConstants.RoleMember.MEMBER_ID, principalId); |
| 334 | |
} |
| 335 | 0 | principalCheck.addEqualTo(KIMPropertyConstants.RoleMember.MEMBER_TYPE_CODE, MemberType.PRINCIPAL.getCode()); |
| 336 | 0 | orSet.addOrCriteria(principalCheck); |
| 337 | 0 | Criteria groupCheck = new Criteria(); |
| 338 | 0 | if (groupIds != null && !groupIds.isEmpty()) { |
| 339 | 0 | groupCheck.addIn(KIMPropertyConstants.RoleMember.MEMBER_ID, groupIds); |
| 340 | |
} |
| 341 | 0 | groupCheck.addEqualTo(KIMPropertyConstants.RoleMember.MEMBER_TYPE_CODE, MemberType.GROUP.getCode()); |
| 342 | 0 | orSet.addOrCriteria(groupCheck); |
| 343 | 0 | c.addAndCriteria(orSet); |
| 344 | 0 | addSubCriteriaBasedOnRoleQualification(c, qualification); |
| 345 | |
|
| 346 | 0 | Query query = QueryFactory.newQuery(RoleMemberBo.class, c); |
| 347 | 0 | Collection<RoleMemberBo> coll = getPersistenceBrokerTemplate().getCollectionByQuery(query); |
| 348 | 0 | ArrayList<RoleMemberBo> results = new ArrayList<RoleMemberBo>(coll.size()); |
| 349 | 0 | for (RoleMemberBo rm : coll) { |
| 350 | 0 | if (rm.isActive(new Timestamp(System.currentTimeMillis()))) { |
| 351 | 0 | results.add(rm); |
| 352 | |
} |
| 353 | |
} |
| 354 | 0 | return results; |
| 355 | |
} |
| 356 | |
|
| 357 | |
public List<RoleBo> getRoles(Map<String, String> fieldValues) { |
| 358 | 0 | Criteria criteria = new Criteria(); |
| 359 | 0 | Map<String, Map<String, String>> criteriaMap = setupCritMaps(fieldValues); |
| 360 | |
|
| 361 | |
|
| 362 | 0 | Map<String, String> lookupNames = criteriaMap.get("lookupNames"); |
| 363 | 0 | for (Map.Entry<String, String> entry : lookupNames.entrySet()) { |
| 364 | 0 | if (StringUtils.isNotBlank(entry.getValue())) { |
| 365 | 0 | if (!entry.getKey().equals(KIMPropertyConstants.Principal.PRINCIPAL_NAME)) { |
| 366 | 0 | addLikeToCriteria(criteria, entry.getKey(), entry.getValue()); |
| 367 | |
} else { |
| 368 | 0 | List<String> roleIds = getRoleIdsForPrincipalName(entry.getValue()); |
| 369 | 0 | if (roleIds != null && !roleIds.isEmpty()) { |
| 370 | 0 | criteria.addIn(KimConstants.PrimaryKeyConstants.ID, roleIds); |
| 371 | |
} else { |
| 372 | |
|
| 373 | 0 | roleIds.add("NOTFOUND"); |
| 374 | 0 | criteria.addIn(KimConstants.PrimaryKeyConstants.ID, roleIds); |
| 375 | |
} |
| 376 | 0 | } |
| 377 | |
} |
| 378 | |
} |
| 379 | 0 | if (!criteriaMap.get("attr").isEmpty()) { |
| 380 | 0 | String kimTypeId = null; |
| 381 | 0 | for (Map.Entry<String, String> entry : fieldValues.entrySet()) { |
| 382 | 0 | if (entry.getKey().equals("kimTypeId")) { |
| 383 | 0 | kimTypeId = entry.getValue(); |
| 384 | 0 | break; |
| 385 | |
} |
| 386 | |
} |
| 387 | 0 | setupAttrCriteria(criteria, criteriaMap.get("attr"), kimTypeId); |
| 388 | |
} |
| 389 | 0 | if (!criteriaMap.get("perm").isEmpty()) { |
| 390 | 0 | criteria.addExists(setupPermCriteria(criteriaMap.get("perm"))); |
| 391 | |
} |
| 392 | 0 | if (!criteriaMap.get("resp").isEmpty()) { |
| 393 | 0 | criteria.addExists(setupRespCriteria(criteriaMap.get("resp"))); |
| 394 | |
} |
| 395 | 0 | if (!criteriaMap.get("group").isEmpty()) { |
| 396 | 0 | criteria.addExists(setupGroupCriteria(criteriaMap.get("group"))); |
| 397 | |
} |
| 398 | |
|
| 399 | 0 | Query q = QueryFactory.newQuery(RoleBo.class, criteria); |
| 400 | |
|
| 401 | 0 | return (List) getPersistenceBrokerTemplate().getCollectionByQuery(q); |
| 402 | |
} |
| 403 | |
|
| 404 | |
|
| 405 | |
private List<String> getPrincipalIdsForPrincipalName(String principalName) { |
| 406 | 0 | QueryByCriteria.Builder qb = QueryByCriteria.Builder.create(); |
| 407 | 0 | qb.setPredicates(equal("principals.principalName", principalName)); |
| 408 | 0 | List<EntityDefault> entities = KimApiServiceLocator.getIdentityService().findEntityDefaults(qb.build()).getResults(); |
| 409 | |
|
| 410 | 0 | List<String> principalIds = new ArrayList<String>(); |
| 411 | 0 | for (EntityDefault entity : entities) { |
| 412 | 0 | for (Principal principal : entity.getPrincipals()) { |
| 413 | 0 | principalIds.add(principal.getPrincipalId()); |
| 414 | |
} |
| 415 | |
} |
| 416 | |
|
| 417 | 0 | return principalIds; |
| 418 | |
|
| 419 | |
} |
| 420 | |
|
| 421 | |
private List<String> getRoleIdsForPrincipalName(String value) { |
| 422 | 0 | String principalName = value.replace('*', '%'); |
| 423 | 0 | List<String> roleIds = new ArrayList<String>(); |
| 424 | 0 | Criteria memberSubCrit = new Criteria(); |
| 425 | 0 | QueryByCriteria.Builder qb = QueryByCriteria.Builder.create(); |
| 426 | 0 | qb.setPredicates(equal("principals.principalName", principalName)); |
| 427 | 0 | List<EntityDefault> entities = KimApiServiceLocator.getIdentityService().findEntityDefaults(qb.build()).getResults(); |
| 428 | 0 | if (entities == null |
| 429 | |
|| entities.size() == 0) { |
| 430 | 0 | return roleIds; |
| 431 | |
} |
| 432 | |
|
| 433 | 0 | List<String> principalIds = new ArrayList<String>(); |
| 434 | 0 | for (EntityDefault entity : entities) { |
| 435 | 0 | for (Principal principal : entity.getPrincipals()) { |
| 436 | 0 | principalIds.add(principal.getPrincipalId()); |
| 437 | |
} |
| 438 | |
} |
| 439 | 0 | if (principalIds != null && !principalIds.isEmpty()) { |
| 440 | 0 | memberSubCrit.addEqualTo(KIMPropertyConstants.RoleMember.MEMBER_TYPE_CODE, MemberType.PRINCIPAL.getCode()); |
| 441 | 0 | memberSubCrit.addIn(KIMPropertyConstants.RoleMember.MEMBER_ID, principalIds); |
| 442 | |
|
| 443 | 0 | ReportQueryByCriteria memberSubQuery = QueryFactory.newReportQuery(RoleMemberBo.class, memberSubCrit); |
| 444 | 0 | for (RoleMemberBo roleMbr : (List<RoleMemberBo>) getPersistenceBrokerTemplate().getCollectionByQuery(memberSubQuery)) { |
| 445 | 0 | if (roleMbr.isActive(new Timestamp(System.currentTimeMillis())) && !roleIds.contains(roleMbr.getRoleId())) { |
| 446 | 0 | roleIds.add(roleMbr.getRoleId()); |
| 447 | |
} |
| 448 | |
} |
| 449 | |
} |
| 450 | |
|
| 451 | 0 | List<String> groupIds = new ArrayList<String>(); |
| 452 | 0 | for (String principalId : principalIds) { |
| 453 | 0 | List<String> principalGroupIds = KimApiServiceLocator.getGroupService().getGroupIdsByPrincipalId( |
| 454 | |
principalId); |
| 455 | 0 | for (String groupId : principalGroupIds) { |
| 456 | 0 | if (!groupIds.contains(groupId)) { |
| 457 | 0 | groupIds.add(groupId); |
| 458 | |
} |
| 459 | |
} |
| 460 | 0 | } |
| 461 | |
|
| 462 | 0 | if (groupIds != null && !groupIds.isEmpty()) { |
| 463 | 0 | Criteria grpRoleCrit = new Criteria(); |
| 464 | 0 | grpRoleCrit.addEqualTo(KIMPropertyConstants.RoleMember.MEMBER_TYPE_CODE, MemberType.GROUP.getCode()); |
| 465 | 0 | grpRoleCrit.addIn(KIMPropertyConstants.RoleMember.MEMBER_ID, groupIds); |
| 466 | |
|
| 467 | 0 | ReportQueryByCriteria memberSubQuery = QueryFactory.newReportQuery(RoleMemberBo.class, grpRoleCrit); |
| 468 | |
|
| 469 | 0 | for (RoleMemberBo roleMbr : (List<RoleMemberBo>) getPersistenceBrokerTemplate().getCollectionByQuery(memberSubQuery)) { |
| 470 | 0 | if (roleMbr.isActive(new Timestamp(System.currentTimeMillis())) && !roleIds.contains(roleMbr.getRoleId())) { |
| 471 | 0 | roleIds.add(roleMbr.getRoleId()); |
| 472 | |
} |
| 473 | |
} |
| 474 | |
} |
| 475 | |
|
| 476 | 0 | return roleIds; |
| 477 | |
} |
| 478 | |
|
| 479 | |
private Map<String, Map<String, String>> setupCritMaps(Map<String, String> fieldValues) { |
| 480 | |
|
| 481 | 0 | Map<String, Map<String, String>> critMap = new HashMap<String, Map<String, String>>(); |
| 482 | 0 | List<String> permFieldName = new ArrayList<String>(); |
| 483 | 0 | permFieldName.add("permName"); |
| 484 | 0 | permFieldName.add("permNamespaceCode"); |
| 485 | 0 | permFieldName.add("permTmplName"); |
| 486 | 0 | permFieldName.add("permTmplNamespaceCode"); |
| 487 | 0 | List<String> respFieldName = new ArrayList<String>(); |
| 488 | 0 | respFieldName.add("respName"); |
| 489 | 0 | respFieldName.add("respNamespaceCode"); |
| 490 | 0 | respFieldName.add("respTmplName"); |
| 491 | 0 | respFieldName.add("respTmplNamespaceCode"); |
| 492 | 0 | Map<String, String> permFieldMap = new HashMap<String, String>(); |
| 493 | 0 | Map<String, String> respFieldMap = new HashMap<String, String>(); |
| 494 | 0 | Map<String, String> attrFieldMap = new HashMap<String, String>(); |
| 495 | 0 | Map<String, String> groupFieldMap = new HashMap<String, String>(); |
| 496 | 0 | Map<String, String> lookupNamesMap = new HashMap<String, String>(); |
| 497 | |
|
| 498 | 0 | for (Map.Entry<String, String> entry : fieldValues.entrySet()) { |
| 499 | 0 | if (StringUtils.isNotBlank(entry.getValue())) { |
| 500 | 0 | String nameValue = entry.getValue().replace('*', '%'); |
| 501 | 0 | if (permFieldName.contains(entry.getKey())) { |
| 502 | 0 | permFieldMap.put(entry.getKey(), nameValue); |
| 503 | 0 | } else if (respFieldName.contains(entry.getKey())) { |
| 504 | 0 | respFieldMap.put(entry.getKey(), nameValue); |
| 505 | 0 | } else if (entry.getKey().startsWith(KimConstants.AttributeConstants.GROUP_NAME)) { |
| 506 | 0 | groupFieldMap.put(entry.getKey(), nameValue); |
| 507 | 0 | } else if (entry.getKey().contains(".")) { |
| 508 | 0 | attrFieldMap.put(entry.getKey(), nameValue); |
| 509 | |
} else { |
| 510 | 0 | lookupNamesMap.put(entry.getKey(), nameValue); |
| 511 | |
} |
| 512 | 0 | } |
| 513 | |
} |
| 514 | |
|
| 515 | 0 | critMap.put("perm", permFieldMap); |
| 516 | 0 | critMap.put("resp", respFieldMap); |
| 517 | 0 | critMap.put("group", groupFieldMap); |
| 518 | 0 | critMap.put("attr", attrFieldMap); |
| 519 | 0 | critMap.put("lookupNames", lookupNamesMap); |
| 520 | 0 | return critMap; |
| 521 | |
} |
| 522 | |
|
| 523 | |
|
| 524 | |
private void setupAttrCriteria(Criteria crit, Map<String, String> attrCrit, String kimTypeId) { |
| 525 | 0 | for (Map.Entry<String, String> entry : attrCrit.entrySet()) { |
| 526 | 0 | Criteria subCrit = new Criteria(); |
| 527 | 0 | addLikeToCriteria(subCrit, "attributes.attributeValue", entry.getValue()); |
| 528 | 0 | addEqualToCriteria(subCrit, "attributes.kimAttributeId", entry.getKey().substring(entry.getKey().indexOf(".") + 1, entry.getKey().length())); |
| 529 | 0 | addEqualToCriteria(subCrit, "attributes.kimTypeId", kimTypeId); |
| 530 | 0 | subCrit.addEqualToField("roleId", Criteria.PARENT_QUERY_PREFIX + "roleId"); |
| 531 | 0 | crit.addExists(QueryFactory.newReportQuery(RoleMemberBo.class, subCrit)); |
| 532 | 0 | } |
| 533 | 0 | } |
| 534 | |
|
| 535 | |
private ReportQueryByCriteria setupPermCriteria(Map<String, String> permCrit) { |
| 536 | |
|
| 537 | 0 | List<Predicate> andConds = new ArrayList<Predicate>(); |
| 538 | |
|
| 539 | 0 | for (Map.Entry<String, String> entry : permCrit.entrySet()) { |
| 540 | 0 | if (entry.getKey().equals("permTmplName") || entry.getKey().equals("permTmplNamespaceCode")) { |
| 541 | 0 | if (entry.getKey().equals("permTmplName")) { |
| 542 | 0 | andConds.add(equal("template." + KimConstants.UniqueKeyConstants.PERMISSION_TEMPLATE_NAME, entry.getValue())); |
| 543 | |
|
| 544 | |
} else { |
| 545 | 0 | andConds.add(equal("template." + KimConstants.UniqueKeyConstants.NAMESPACE_CODE, entry.getValue())); |
| 546 | |
} |
| 547 | |
} |
| 548 | |
|
| 549 | 0 | if (entry.getKey().equals("permName") || entry.getKey().equals("permNamespaceCode")) { |
| 550 | 0 | if (entry.getKey().equals("permName")) { |
| 551 | 0 | andConds.add(equal(KimConstants.UniqueKeyConstants.PERMISSION_NAME, entry.getValue())); |
| 552 | |
} else { |
| 553 | 0 | andConds.add(equal(KimConstants.UniqueKeyConstants.NAMESPACE_CODE, entry.getValue())); |
| 554 | |
|
| 555 | |
} |
| 556 | |
} |
| 557 | |
} |
| 558 | |
|
| 559 | |
|
| 560 | 0 | List<Permission> permList = KimApiServiceLocator.getPermissionService().findPermissions(QueryByCriteria.Builder.fromPredicates(andConds.toArray(new Predicate[]{}))).getResults(); |
| 561 | 0 | List<String> roleIds = null; |
| 562 | |
|
| 563 | 0 | if (permList != null && !permList.isEmpty()) { |
| 564 | 0 | roleIds = getRoleIdsForPermissions(permList); |
| 565 | |
} |
| 566 | |
|
| 567 | 0 | if (roleIds == null || roleIds.isEmpty()) { |
| 568 | 0 | roleIds = new ArrayList<String>(); |
| 569 | 0 | roleIds.add("-1"); |
| 570 | |
} |
| 571 | |
|
| 572 | 0 | Criteria memberSubCrit = new Criteria(); |
| 573 | 0 | memberSubCrit.addIn("roleId", roleIds); |
| 574 | 0 | memberSubCrit.addEqualToField("roleId", Criteria.PARENT_QUERY_PREFIX + "roleId"); |
| 575 | 0 | return QueryFactory.newReportQuery(RoleBo.class, memberSubCrit); |
| 576 | |
|
| 577 | |
} |
| 578 | |
|
| 579 | |
private List<String> getRoleIdsForPermissions(Collection<Permission> permissions) { |
| 580 | 0 | if ( permissions.isEmpty() ) { |
| 581 | 0 | return new ArrayList<String>(0); |
| 582 | |
} |
| 583 | 0 | List<String> permissionIds = new ArrayList<String>( permissions.size() ); |
| 584 | 0 | for ( Permission permission : permissions ) { |
| 585 | 0 | permissionIds.add( permission.getId() ); |
| 586 | |
} |
| 587 | 0 | Criteria c = new Criteria(); |
| 588 | 0 | c.addIn( "permissionId", permissionIds ); |
| 589 | 0 | c.addEqualTo( "active", true ); |
| 590 | |
|
| 591 | 0 | Query query = QueryFactory.newQuery( RolePermissionBo.class, c, true ); |
| 592 | 0 | Collection<RolePermissionBo> coll = getPersistenceBrokerTemplate().getCollectionByQuery(query); |
| 593 | 0 | List<String> roleIds = new ArrayList<String>( coll.size() ); |
| 594 | 0 | for ( RolePermissionBo rp : coll ) { |
| 595 | 0 | roleIds.add( rp.getRoleId() ); |
| 596 | |
} |
| 597 | 0 | return roleIds; |
| 598 | |
} |
| 599 | |
|
| 600 | |
private ReportQueryByCriteria setupRespCriteria(Map<String, String> respCrit) { |
| 601 | 0 | QueryByCriteria.Builder queryByCriteriaBuilder = QueryByCriteria.Builder.create(); |
| 602 | 0 | List<Predicate> predicates = new ArrayList<Predicate>(); |
| 603 | 0 | for (Map.Entry<String, String> entry : respCrit.entrySet()) { |
| 604 | 0 | if (entry.getKey().equals("respTmplName") || entry.getKey().equals("respTmplNamespaceCode")) { |
| 605 | 0 | if (entry.getKey().equals("respTmplName")) { |
| 606 | 0 | predicates.add(PredicateFactory.equal("template" + KimConstants.UniqueKeyConstants.RESPONSIBILITY_TEMPLATE_NAME, entry.getValue())); |
| 607 | |
} else { |
| 608 | 0 | predicates.add(PredicateFactory.equal("template." + KimConstants.UniqueKeyConstants.NAMESPACE_CODE, entry.getValue())); |
| 609 | |
} |
| 610 | |
} |
| 611 | 0 | if (entry.getKey().equals("respName") || entry.getKey().equals("respNamespaceCode")) { |
| 612 | 0 | if (entry.getKey().equals("respName")) { |
| 613 | 0 | predicates.add(PredicateFactory.equal(KimConstants.UniqueKeyConstants.RESPONSIBILITY_NAME, entry.getValue())); |
| 614 | |
} else { |
| 615 | 0 | predicates.add(PredicateFactory.equal(KimConstants.UniqueKeyConstants.NAMESPACE_CODE, entry.getValue())); |
| 616 | |
} |
| 617 | |
} |
| 618 | |
} |
| 619 | 0 | queryByCriteriaBuilder.setPredicates(PredicateFactory.and(predicates.toArray(new Predicate[predicates.size()]))); |
| 620 | |
|
| 621 | 0 | ResponsibilityService responsibilityService = KimApiServiceLocator.getResponsibilityService(); |
| 622 | 0 | ResponsibilityQueryResults results = responsibilityService.findResponsibilities(queryByCriteriaBuilder.build()); |
| 623 | 0 | List<Responsibility> responsibilities = results.getResults(); |
| 624 | |
|
| 625 | |
|
| 626 | 0 | List<String> roleIds = new ArrayList<String>(); |
| 627 | 0 | for (Responsibility responsibility : responsibilities) { |
| 628 | 0 | roleIds.addAll(responsibilityService.getRoleIdsForResponsibility(responsibility.getId(), null)); |
| 629 | |
} |
| 630 | |
|
| 631 | 0 | if (roleIds.isEmpty()) { |
| 632 | 0 | roleIds.add("-1"); |
| 633 | |
} |
| 634 | |
|
| 635 | 0 | Criteria memberSubCrit = new Criteria(); |
| 636 | 0 | memberSubCrit.addIn("roleId", roleIds); |
| 637 | 0 | memberSubCrit.addEqualToField("roleId", Criteria.PARENT_QUERY_PREFIX + "roleId"); |
| 638 | 0 | return QueryFactory.newReportQuery(RoleBo.class, memberSubCrit); |
| 639 | |
|
| 640 | |
} |
| 641 | |
|
| 642 | |
private ReportQueryByCriteria setupGroupCriteria(Map<String,String> groupCrit) { |
| 643 | |
|
| 644 | |
|
| 645 | 0 | final QueryByCriteria.Builder searchCrit = QueryByCriteria.Builder.create(); |
| 646 | 0 | for (Entry<String, String> entry : groupCrit.entrySet()) { |
| 647 | 0 | if (entry.getKey().equals(KimConstants.AttributeConstants.GROUP_NAME)) { |
| 648 | |
|
| 649 | 0 | searchCrit.setPredicates(equal(entry.getKey(), entry.getValue())); |
| 650 | |
} else { |
| 651 | |
|
| 652 | 0 | searchCrit.setPredicates(equal(KimConstants.AttributeConstants.NAMESPACE_CODE, entry.getValue())); |
| 653 | |
|
| 654 | |
} |
| 655 | |
} |
| 656 | |
|
| 657 | 0 | Criteria crit = new Criteria(); |
| 658 | |
|
| 659 | 0 | List<String> groupIds = KimApiServiceLocator.getGroupService().findGroupIds(searchCrit.build()); |
| 660 | |
|
| 661 | 0 | if(groupIds == null || groupIds.isEmpty()){ |
| 662 | 0 | groupIds = new ArrayList<String>(); |
| 663 | 0 | groupIds.add("-1"); |
| 664 | |
} |
| 665 | 0 | crit.addIn("memberId", groupIds); |
| 666 | 0 | crit.addEqualToField("roleId", Criteria.PARENT_QUERY_PREFIX + "roleId"); |
| 667 | |
|
| 668 | 0 | return QueryFactory.newReportQuery(RoleMemberBo.class, crit); |
| 669 | |
|
| 670 | |
} |
| 671 | |
|
| 672 | |
private void addLikeToCriteria(Criteria criteria, String propertyName, String propertyValue) { |
| 673 | 0 | String[] keyValues = getCaseInsensitiveValues(propertyName, propertyValue); |
| 674 | 0 | criteria.addLike(keyValues[0], keyValues[1]); |
| 675 | 0 | } |
| 676 | |
|
| 677 | |
private void addEqualToCriteria(Criteria criteria, String propertyName, String propertyValue) { |
| 678 | 0 | String[] keyValues = getCaseInsensitiveValues(propertyName, propertyValue); |
| 679 | 0 | criteria.addEqualTo(keyValues[0], keyValues[1]); |
| 680 | 0 | } |
| 681 | |
|
| 682 | |
private String[] getCaseInsensitiveValues(String propertyName, String propertyValue) { |
| 683 | 0 | String[] keyValues = new String[2]; |
| 684 | 0 | keyValues[0] = propertyName == null ? "" : getDbPlatform().getUpperCaseFunction() + "(" + propertyName + ")"; |
| 685 | 0 | keyValues[1] = propertyValue == null ? "" : propertyValue.toUpperCase(); |
| 686 | 0 | return keyValues; |
| 687 | |
} |
| 688 | |
|
| 689 | |
private boolean hasCoreRoleMemberCriteria(Map<String, String> fieldValues) { |
| 690 | 0 | return StringUtils.isNotEmpty(fieldValues.get(KimConstants.PrimaryKeyConstants.ROLE_MEMBER_ID)) || |
| 691 | |
StringUtils.isNotEmpty(fieldValues.get(KimConstants.PrimaryKeyConstants.SUB_ROLE_ID)) || |
| 692 | |
StringUtils.isNotEmpty(fieldValues.get(KimConstants.PrimaryKeyConstants.MEMBER_ID)) || |
| 693 | |
StringUtils.isNotEmpty(fieldValues.get(KIMPropertyConstants.KimMember.MEMBER_TYPE_CODE)) || |
| 694 | |
StringUtils.isNotEmpty(fieldValues.get(KIMPropertyConstants.KimMember.ACTIVE_FROM_DATE)) || |
| 695 | |
StringUtils.isNotEmpty(fieldValues.get(KIMPropertyConstants.KimMember.ACTIVE_TO_DATE)); |
| 696 | |
} |
| 697 | |
|
| 698 | |
private boolean hasExtraRoleMemberCriteria(Map<String, String> fieldValues) { |
| 699 | 0 | return StringUtils.isNotEmpty(fieldValues.get(KimConstants.KimUIConstants.MEMBER_NAME)) || |
| 700 | |
StringUtils.isNotEmpty(fieldValues.get(KimConstants.KimUIConstants.MEMBER_NAMESPACE_CODE)); |
| 701 | |
} |
| 702 | |
|
| 703 | |
@SuppressWarnings("unchecked") |
| 704 | |
private List<RoleBo> getRoleMembersRoles(String memberNamespaceCode, String memberName) { |
| 705 | 0 | Criteria queryCriteria = new Criteria(); |
| 706 | 0 | addEqualToCriteria(queryCriteria, KimConstants.UniqueKeyConstants.NAMESPACE_CODE, memberNamespaceCode); |
| 707 | 0 | addEqualToCriteria(queryCriteria, KimConstants.UniqueKeyConstants.NAME, memberName); |
| 708 | 0 | Query q = QueryFactory.newQuery(RoleBo.class, queryCriteria); |
| 709 | 0 | return (List<RoleBo>) getPersistenceBrokerTemplate().getCollectionByQuery(q); |
| 710 | |
} |
| 711 | |
|
| 712 | |
private List<String> getRoleMembersGroupIds(String memberNamespaceCode, String memberName){ |
| 713 | 0 | QueryByCriteria.Builder builder = QueryByCriteria.Builder.create(); |
| 714 | 0 | builder.setPredicates(and( |
| 715 | |
like(KimConstants.AttributeConstants.GROUP_NAME, memberName), |
| 716 | |
like(KimConstants.AttributeConstants.NAMESPACE_CODE, memberNamespaceCode))); |
| 717 | 0 | return KimApiServiceLocator.getGroupService().findGroupIds(builder.build()); |
| 718 | |
} |
| 719 | |
} |