Package org.ametys.plugins.userdirectory.synchronize

Class SQLSynchronizableUDOrgunitCollection

java.lang.Object

org.ametys.plugins.contentio.synchronize.AbstractStaticSynchronizableContentsCollection

org.ametys.plugins.contentio.synchronize.AbstractSynchronizableContentsCollection

org.ametys.plugins.contentio.synchronize.AbstractSimpleSynchronizableContentsCollection

org.ametys.plugins.contentio.synchronize.impl.AbstractDataSourceSynchronizableContentsCollection

org.ametys.plugins.contentio.synchronize.impl.SQLSynchronizableContentsCollection

org.ametys.plugins.userdirectory.synchronize.SQLSynchronizableUDOrgunitCollection

All Implemented Interfaces:

SynchronizableContentsCollection, Component, Configurable, Serviceable

public class SQLSynchronizableUDOrgunitCollection
extends SQLSynchronizableContentsCollection

Synchronizable collection for UD Orgunits

Field Summary

Fields

Modifier and Type	Field	Description
protected DeleteOrgUnitComponent	_deleteOrgUnitComponent	The delete orgUnit component
protected Integer	_nbSynchronizedOrgUnit	Number of updated contents for parent-child org unit relation
protected OrganisationChartPageHandler	_orgChartPageHandler	The organisation chart page handler
protected Map<String,String>	_orgUnitParents	The map which link orgunit with this parent
protected Map<String,String>	_orgUnitRemoteIds	The map which link orgunit with sql remote ids
protected OutgoingReferencesExtractor	_outgoingReferencesExtractor	The OutgoingReferences extractor
protected SQLUserSearchDAO	_sqlUserDAO	The sql user search DAO
protected CurrentUserProvider	_userProvider	The current user provider
protected Map<String,Map<String,String>>	_usersByOrgUnitId	The map which link users (userId and role) to their orgunits
static final String	ORGUNIT_REMOTE_ID_INTERNAL_DATA	The internal data name for orgUnit remote sql id
static final String	RESULT_NB_SYNCHRONIZED_ORGUNITS_RELATIONS	The result map key for number of deleted contents

Fields inherited from class org.ametys.plugins.contentio.synchronize.impl.SQLSynchronizableContentsCollection

_sqlCollectionDAO

Fields inherited from class org.ametys.plugins.contentio.synchronize.impl.AbstractDataSourceSynchronizableContentsCollection

__PARAM_DATASOURCE_ID, __PARAM_FIELD_ID, __PARAM_MAPPING, __PARAM_MAPPING_ATTRIBUTE, __PARAM_MAPPING_METADATA_REF, __PARAM_MAPPING_SYNCHRO, _columnsAndCriteria, _jsonUtils, _mapping, _syncFields

Fields inherited from class org.ametys.plugins.contentio.synchronize.AbstractSimpleSynchronizableContentsCollection

_contentHelper, _synchronizingContentOperatorEP

Fields inherited from class org.ametys.plugins.contentio.synchronize.AbstractSynchronizableContentsCollection

_contentWorkflowHelper, _currentUserProvider, _hasGlobalError, _i18nUtils, _nbCreatedContents, _nbDeletedContents, _nbError, _nbNotChangedContents, _nbSynchronizedContents, _observationManager, SCC_UNIQUE_ID

Fields inherited from class org.ametys.plugins.contentio.synchronize.AbstractStaticSynchronizableContentsCollection

_contentDAO, _contentPrefix, _contentType, _contentTypeEP, _id, _ignoreRestrictions, _initialActionId, _label, _languages, _modelId, _modelParamValues, _removalSync, _reportMails, _resolver, _restrictedField, _sccHelper, _searchModelConfiguration, _synchronizeActionId, _synchronizeExistingContentsOnly, _synchronizingContentOperator, _validateActionId, _validateAfterImport, _workflowName

Fields inherited from interface org.ametys.plugins.contentio.synchronize.SynchronizableContentsCollection

COLLECTION_ID_DATA_NAME, LAST_SYNCHRONIZATION_DATA_NAME, LAST_SYNCHRONIZATION_USER_DATA_NAME, RESULT_NB_CREATED_CONTENTS, RESULT_NB_DELETED_CONTENTS, RESULT_NB_NOT_CHANGED_CONTENTS, RESULT_NB_SYNCHRONIZED_CONTENTS

Constructor Summary

Constructors

Constructor	Description
SQLSynchronizableUDOrgunitCollection()

Method Summary

Modifier and Type	Method	Description
protected int	_deleteContents(List<Content> contentsToRemove, Logger logger)	Delete contents.
protected Content	_getOrgUnitContentFromRemoteId(String remoteId, String lang, Logger logger)	Get orgunit content from the remote Id
protected List<Map<String,Object>>	_getOrgUnitUsers(String orgUnitId, String lang)	Retrieves the users of the given orgunit
protected Map<String,Object>	_getSearchParameters(Map<String,Object> parameters, int offset, int limit, List<Object> sort, List<String> columns)	Get the parameters map for mybatis search
protected Map<String,Object>	_getSearchUserParameters(String orgUnitColumnKey, Logger logger)	Get the parameters map for user mybatis search
protected Optional<Triple<String,String,String>>	_getUserByOrgUnit(String orgUnitKey, String loginColumnName, String roleColumnName, Map<String,Object> normalizedUser, Logger logger)	Retrieves a Triple containing the orgunit id, and the user's login and role for the given normalized user
protected Content	_getUserContent(String loginValue, String lang)	Get user content from login value
protected Map<String,Map<String,String>>	_getUsersByOrgUnit(Logger logger)	Retrieves the user attributes for all org units
protected boolean	_hasSomethingChanged()	Checks if some content have changed during the synchronization
protected Optional<ModifiableContent>	_importOrSynchronizeContent(String idValue, String lang, Map<String,List<Object>> remoteValues, boolean forceImport, Logger logger)	Imports or synchronizes a content for a given language
protected List<ModifiableContent>	_internalPopulate(Logger logger, ContainerProgressionTracker progressionTracker)	Internal implementation of AbstractSynchronizableContentsCollection.populate(Logger, ContainerProgressionTracker)
protected void	_logSynchronizationResult(Logger logger)	Logs the result of the synchronization, containing The number of created contents The number of synchronized contents The number of unchanged contents The number of deleted contents
protected void	_setContentsRelationWithParentOrgunit(List<ModifiableContent> orgUnitContents, Logger logger)	Set all orgunit parents relation for each synchronized content
ContentSynchronizationResult	additionalCommonOperations(ModifiableContent content, Map<String,Object> additionalParameters, Logger logger)	Add specific fields to the content during import or synchronization.
protected Map<String,Object>	getAdditionalAttributeValues(String idValue, Content content, Map<String,Object> additionalParameters, boolean create, Logger logger)	Retrieves additional values to synchronize for a content
String	getLoginUserAttributeName()	Get the login user attribute name
String	getLoginUserColumnName()	Get the login user column name
String	getOrgunitJoinColumnNameForUser()	Get the name of the orgunit join column name of the user table
String	getOrgUnitRemoteIdColumnName()	Get the orgunit remote id column name
String	getRoleUserColumnName()	Get the role user column name
Map<String,Integer>	getSynchronizationResult()	Retrieves the result of the synchronization as a map of key / content count containing The number of created contents The number of synchronized contents The number of unchanged contents The number of deleted contents
String	getUserSortColumnName()	Get the user sort column name
String	getUserTableName()	Get the name of user SQL table
boolean	handleRightAssignmentContext()	Return true if a RightAssignmentContext should be automatically generated for the contents of this SCC
protected Map<String,Map<String,Object>>	internalSearch(Map<String,Object> searchParameters, int offset, int limit, List<Object> sort, Logger logger)	Search values and return the result without any treatment.
boolean	isUserSortPrevail()	True if the SQL sort for users prevail
void	service(ServiceManager smanager)

Methods inherited from class org.ametys.plugins.contentio.synchronize.impl.SQLSynchronizableContentsCollection

_checkIdObjectValue, _getNormalizedSearchResult, _getTotalCounParameters, _normalizeSearchResult, getTableName, getTotalCount

Methods inherited from class org.ametys.plugins.contentio.synchronize.impl.AbstractDataSourceSynchronizableContentsCollection

configureDataSource, configureSearchModel, getDataSourceId, getIdField, getLocalAndExternalFields, getMapping, getRemoteValues, putIdParameter

Methods inherited from class org.ametys.plugins.contentio.synchronize.AbstractSimpleSynchronizableContentsCollection

_addEditInputsForSCC, _editContent, _fillContent, _getContentsToRemove, _getEditInputs, _getEditInputsContextParameters, _handleContent, _importContent, _importOrSynchronizeContent, _importOrSynchronizeContents, _importOrSynchronizeContents, _isHandled, _synchronizeContent, _transformRemoteValues, configure, createContentAction, getContent, getNotSynchronizedRelatedContentIds, getTransformedRemoteValues, importContent, populate, search, synchronizeContent, updateSyncInformations, validateContent

Methods inherited from class org.ametys.plugins.contentio.synchronize.AbstractSynchronizableContentsCollection

_getAdditionalInputsForContentCreation, _getContentPathQuery, _getExpressionsList, _internalPopulate, _isParamNotEmpty, _removeEmptyParameters, createContentAction, deleteUnexistingContents, empty, sendErrorMail, validateContent

Methods inherited from class org.ametys.plugins.contentio.synchronize.AbstractStaticSynchronizableContentsCollection

_parseLanguages, _parseParameters, _transformRemoteValuesCardinality, configureStaticParams, getContentPrefix, getContentType, getId, getInitialActionId, getLabel, getLanguages, getParameterValues, getReportMails, getRestrictedField, getSearchModelConfiguration, getSynchronizeActionId, getSynchronizeCollectionModelId, getSynchronizingContentOperator, getValidateActionId, getWorkflowName, ignoreRestrictions, removalSync, synchronizeExistingContentsOnly, validateAfterImport

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.ametys.plugins.contentio.synchronize.SynchronizableContentsCollection

additionalImportOperations, additionalSynchronizeOperations

Field Details

ORGUNIT_REMOTE_ID_INTERNAL_DATA

public static final String ORGUNIT_REMOTE_ID_INTERNAL_DATA

The internal data name for orgUnit remote sql id

See Also:

• Constant Field Values

RESULT_NB_SYNCHRONIZED_ORGUNITS_RELATIONS

public static final String RESULT_NB_SYNCHRONIZED_ORGUNITS_RELATIONS

The result map key for number of deleted contents

See Also:

• Constant Field Values

_orgUnitParents

protected Map<String,String> _orgUnitParents

The map which link orgunit with this parent

_usersByOrgUnitId

protected Map<String,Map<String,String>> _usersByOrgUnitId

The map which link users (userId and role) to their orgunits

_orgUnitRemoteIds

protected Map<String,String> _orgUnitRemoteIds

The map which link orgunit with sql remote ids

_nbSynchronizedOrgUnit

protected Integer _nbSynchronizedOrgUnit

Number of updated contents for parent-child org unit relation

_sqlUserDAO

protected SQLUserSearchDAO _sqlUserDAO

The sql user search DAO

_orgChartPageHandler

protected OrganisationChartPageHandler _orgChartPageHandler

The organisation chart page handler

_userProvider

protected CurrentUserProvider _userProvider

The current user provider

_outgoingReferencesExtractor

protected OutgoingReferencesExtractor _outgoingReferencesExtractor

The OutgoingReferences extractor

_deleteOrgUnitComponent

protected DeleteOrgUnitComponent _deleteOrgUnitComponent

The delete orgUnit component

Constructor Details

SQLSynchronizableUDOrgunitCollection

public SQLSynchronizableUDOrgunitCollection()

Method Details

service

public void service(ServiceManager smanager)
             throws ServiceException

Specified by:

service in interface Serviceable

Overrides:

service in class SQLSynchronizableContentsCollection

Throws:

ServiceException

handleRightAssignmentContext

public boolean handleRightAssignmentContext()

Description copied from interface: SynchronizableContentsCollection

Return true if a RightAssignmentContext should be automatically generated for the contents of this SCC

Returns:

true to automatically generate a RightAssignmentContext. Return false if the rights of contents of this SCC are handle by its own RightAssignmentContext

getUserTableName

public String getUserTableName()

Get the name of user SQL table

Returns:

The user SQL table name

getOrgunitJoinColumnNameForUser

public String getOrgunitJoinColumnNameForUser()

Get the name of the orgunit join column name of the user table

Returns:

The name of the orgunit join column name

getLoginUserAttributeName

public String getLoginUserAttributeName()

Get the login user attribute name

Returns:

The login user attribute name

getLoginUserColumnName

public String getLoginUserColumnName()

Get the login user column name

Returns:

The login user column name

getRoleUserColumnName

public String getRoleUserColumnName()

Get the role user column name

Returns:

The role user column name

getUserSortColumnName

public String getUserSortColumnName()

Get the user sort column name

Returns:

The user sort column name

getOrgUnitRemoteIdColumnName

public String getOrgUnitRemoteIdColumnName()

Get the orgunit remote id column name

Returns:

The orgunit remote id column name

isUserSortPrevail

public boolean isUserSortPrevail()

True if the SQL sort for users prevail

Returns:

true if the SQL sort for users prevail

_getSearchParameters

protected Map<String,Object> _getSearchParameters(Map<String,Object> parameters,
 int offset,
 int limit,
 List<Object> sort,
 List<String> columns)

Description copied from class: SQLSynchronizableContentsCollection

Get the parameters map for mybatis search

Overrides:

_getSearchParameters in class SQLSynchronizableContentsCollection

Parameters:

parameters - the filter parameter

offset - the offset

limit - the limit

sort - the sort map

columns - the list of columns

Returns:

the parameter map

internalSearch

protected Map<String,Map<String,Object>> internalSearch(Map<String,Object> searchParameters,
 int offset,
 int limit,
 List<Object> sort,
 Logger logger)

Description copied from class: AbstractSimpleSynchronizableContentsCollection

Search values and return the result without any treatment.

Overrides:

internalSearch in class SQLSynchronizableContentsCollection

Parameters:

searchParameters - Search parameters to restrict the search

offset - Begin of the search

limit - Number of results

sort - Sort of results (ignored for LDAP results)

logger - The logger

Returns:

Map of results without any treatment.

_logSynchronizationResult

protected void _logSynchronizationResult(Logger logger)

Description copied from class: AbstractSynchronizableContentsCollection

Logs the result of the synchronization, containing

• The number of created contents
• The number of synchronized contents
• The number of unchanged contents
• The number of deleted contents

Overrides:

_logSynchronizationResult in class AbstractSynchronizableContentsCollection

Parameters:

logger - the logger

_hasSomethingChanged

protected boolean _hasSomethingChanged()

Description copied from class: AbstractSynchronizableContentsCollection

Checks if some content have changed during the synchronization

Overrides:

_hasSomethingChanged in class AbstractSynchronizableContentsCollection

Returns:

true if some contents have changed, false otherwise

_internalPopulate

protected List<ModifiableContent> _internalPopulate(Logger logger,
 ContainerProgressionTracker progressionTracker)

Description copied from class: AbstractSynchronizableContentsCollection

Internal implementation of AbstractSynchronizableContentsCollection.populate(Logger, ContainerProgressionTracker)

Overrides:

_internalPopulate in class AbstractSimpleSynchronizableContentsCollection

Parameters:

logger - The logger

progressionTracker - The progression tracker

Returns:

The list of created/synchronized contents

_getUsersByOrgUnit

protected Map<String,Map<String,String>> _getUsersByOrgUnit(Logger logger)

Retrieves the user attributes for all org units

Parameters:

logger - The logger

Returns:

the org units' users

_getUserByOrgUnit

protected Optional<Triple<String,String,String>> _getUserByOrgUnit(String orgUnitKey,
 String loginColumnName,
 String roleColumnName,
 Map<String,Object> normalizedUser,
 Logger logger)

Retrieves a Triple containing the orgunit id, and the user's login and role for the given normalized user

Parameters:

orgUnitKey - the orgUnit key

loginColumnName - the login column name

roleColumnName - the role column name

normalizedUser - the normalized user

logger - the logger

Returns:

the user info as a Triple

_importOrSynchronizeContent

protected Optional<ModifiableContent> _importOrSynchronizeContent(String idValue,
 String lang,
 Map<String,List<Object>> remoteValues,
 boolean forceImport,
 Logger logger)

Description copied from class: AbstractSimpleSynchronizableContentsCollection

Imports or synchronizes a content for a given language

Overrides:

_importOrSynchronizeContent in class AbstractSimpleSynchronizableContentsCollection

Parameters:

idValue - The unique identifier of the content

lang - The language of content to import or synchronize

remoteValues - The remote values

forceImport - To force import and ignoring the synchronize existing contents only option

logger - The logger

Returns:

The imported or synchronized content

additionalCommonOperations

public ContentSynchronizationResult additionalCommonOperations(ModifiableContent content,
 Map<String,Object> additionalParameters,
 Logger logger)

Description copied from interface: SynchronizableContentsCollection

Add specific fields to the content during import or synchronization.

Parameters:

content - Content to update

additionalParameters - Additional parameters

logger - The logger

Returns:

The synchronization result of the additional operations

getAdditionalAttributeValues

protected Map<String,Object> getAdditionalAttributeValues(String idValue,
 Content content,
 Map<String,Object> additionalParameters,
 boolean create,
 Logger logger)

Description copied from class: AbstractSimpleSynchronizableContentsCollection

Retrieves additional values to synchronize for a content

Overrides:

getAdditionalAttributeValues in class AbstractSimpleSynchronizableContentsCollection

Parameters:

idValue - id value of the content

content - The content

additionalParameters - Additional parameters

create - true if the content has been newly created, false otherwise

logger - The logger

Returns:

the values to add

_getOrgUnitUsers

protected List<Map<String,Object>> _getOrgUnitUsers(String orgUnitId,
 String lang)

Retrieves the users of the given orgunit

Parameters:

orgUnitId - the orgunit identifier

lang - the language of the orgunit

Returns:

the users linked to the given orgunit

_setContentsRelationWithParentOrgunit

protected void _setContentsRelationWithParentOrgunit(List<ModifiableContent> orgUnitContents,
 Logger logger)

Set all orgunit parents relation for each synchronized content

Parameters:

orgUnitContents - the synchronized content

logger - the logger

_getUserContent

protected Content _getUserContent(String loginValue,
 String lang)

Get user content from login value

Parameters:

loginValue - the login value

lang - the language

Returns:

the user content

_getOrgUnitContentFromRemoteId

protected Content _getOrgUnitContentFromRemoteId(String remoteId,
 String lang,
 Logger logger)

Get orgunit content from the remote Id

Parameters:

remoteId - the remote Id

lang - the language

logger - the logger

Returns:

the orgunit content

_getSearchUserParameters

protected Map<String,Object> _getSearchUserParameters(String orgUnitColumnKey,
 Logger logger)

Get the parameters map for user mybatis search

Parameters:

orgUnitColumnKey - the column name of the orgunit key

logger - the logger

Returns:

the parameter map

_deleteContents

protected int _deleteContents(List<Content> contentsToRemove,
 Logger logger)

Description copied from class: AbstractSynchronizableContentsCollection

Delete contents.

Overrides:

_deleteContents in class AbstractSynchronizableContentsCollection

Parameters:

contentsToRemove - List of contents to remove

logger - The logger

Returns:

the number of deleted contents

getSynchronizationResult

public Map<String,Integer> getSynchronizationResult()

Description copied from interface: SynchronizableContentsCollection

Retrieves the result of the synchronization as a map of key / content count containing

• The number of created contents
• The number of synchronized contents
• The number of unchanged contents
• The number of deleted contents

Specified by:

getSynchronizationResult in interface SynchronizableContentsCollection

Overrides:

getSynchronizationResult in class AbstractSynchronizableContentsCollection

Returns:

the result of the synchronization