com.hybris.backoffice.sync.facades

Class DefaultSynchronizationFacade

java.lang.Object

com.hybris.backoffice.sync.facades.DefaultSynchronizationFacade

All Implemented Interfaces:

SynchronizationFacade

public class DefaultSynchronizationFacade
extends java.lang.Object
implements SynchronizationFacade

Default implementation using the CatalogSynchronizationService. The synchronizations are done asynchronously using a background process (cron job).

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	BACKOFFICE_SYNC_CONFIG_ABORT_ON_COLLIDING
protected static java.lang.String	SYNC_CONFIG_CREATE_SAVED_VALUES
protected static java.lang.String	SYNC_CONFIG_ERROR_MODE
protected static java.lang.String	SYNC_CONFIG_FORCE_UPDATE
protected static java.lang.String	SYNC_CONFIG_KEEP_CRON_JOB
protected static java.lang.String	SYNC_CONFIG_LOG_LEVEL_DATABASE
protected static java.lang.String	SYNC_CONFIG_LOG_LEVEL_FILE
protected static java.lang.String	SYNC_CONFIG_LOG_TO_DATABASE
protected static java.lang.String	SYNC_CONFIG_LOG_TO_FILE
protected static java.lang.String	SYNC_CONFIG_SYNCHRONOUS

Constructor Summary

Constructors

Constructor and Description
DefaultSynchronizationFacade()

Method Summary

Modifier and Type	Method and Description
boolean	canSync(SyncItemJobModel sync) Tells whether current user can perform given sync.
protected java.util.List<ItemModel>	collectRelatedItems(java.util.List<ItemModel> items, java.util.Map<java.lang.String,java.lang.Object> ctxMap)
protected void	copyCronJobData(CatalogVersionSyncCronJobModel newCronJob, CatalogVersionSyncCronJobModel cronJobForRerun)
protected CatalogVersionSyncCronJobModel	copyCronJobSafely(java.util.function.Supplier<CatalogVersionSyncCronJobModel> copySupplier)
protected void	copyScheduledMedia(CatalogVersionSyncCronJobModel newCronJob, CatalogVersionSyncCronJobModel cronJobForRerun)
protected CatalogVersionSyncCronJobModel	createCronJobForRerun(CatalogVersionSyncCronJobModel cronJobForRerun)
protected SyncConfig	createSyncConfigWithDefaults(SyncItemJobModel syncJob) Creates sync config based on project properties and syncJob settings.
protected <T> T	executeInTransaction(java.util.function.Supplier<T> toExecute)
protected java.util.Optional<java.lang.String>	executeSync(SyncTask syncTask, java.util.function.BiFunction<SyncItemJobModel,SyncConfig,SyncResult> syncRunner)
protected <T> T	executeWithoutTypeInterceptors(java.util.function.Supplier<T> toExecute)
java.util.Optional<ItemModel>	findSyncCounterpart(ItemModel item, SyncItemJobModel syncItemJob) Finds a counterpart of given item in respective catalog version defined by the syncItemJob.
protected java.lang.Boolean	getBooleanFromSystemConfig(java.lang.String property, java.lang.Boolean defaultValue)
CatalogSynchronizationService	getCatalogSynchronizationService()
CatalogTypeService	getCatalogTypeService()
java.util.List<ItemModel>	getCatalogVersionAwareItems(java.util.List<? extends ItemModel> items) Extract catalog version aware items CatalogTypeService.isCatalogVersionAwareModel(ItemModel)
CatalogVersionService	getCatalogVersionService()
protected java.lang.String	getConfigValue(java.lang.String property, java.lang.String defaultValue)
CronJobService	getCronJobService()
protected java.util.Map<java.lang.String,java.lang.Object>	getCtxWithMaxRecursionDepth(java.util.Map<java.lang.String,java.lang.Object> ctx)
protected <T extends java.lang.Enum> T	getEnumValueFromSystemConfig(java.lang.Class<T> enumType, java.lang.String property, T defaultValue)
java.util.List<SyncItemJobModel>	getInboundSynchronizations(CatalogVersionModel catalogVersion) Gets inbound sync jobs for given catalog version.
java.util.List<CatalogVersionModel>	getItemsCatalogVersions(java.util.List<? extends ItemModel> items) Extracts from given list items which are CatalogVersion
MediaService	getMediaService()
ModelService	getModelService()
java.util.List<SyncItemJobModel>	getOutboundSynchronizations(CatalogVersionModel catalogVersion) Gets outbound sync jobs for given catalog version.
java.util.Optional<PartialSyncInfo>	getPartialSyncStatusInfo(ItemModel itemModel, SyncItemStatus status, java.util.Map<java.lang.String,java.lang.Object> ctxMap) Checks ItemModel's status in all available synchronizations.
RelatedItemsCollector	getRelatedItemsCollector()
SessionService	getSessionService()
java.util.Optional<CatalogVersionModel>	getSyncCatalogVersion(java.util.Collection<ItemModel> items) Returns catalog version for given items if they are from the same catalog version or are CatalogVersion itself.
protected java.util.List<SyncItemJobModel>	getSynchronizations(CatalogVersionModel syncCatalogVersion)
SynchronizationStatusService	getSynchronizationStatusService()
UserService	getUserService()
java.util.Optional<java.lang.Boolean>	isInSync(ItemModel itemModel, java.util.Map<java.lang.String,java.lang.Object> ctxMap) Checks ItemModel's status in all available synchronizations.
java.util.Optional<java.lang.Boolean>	isInSync(java.util.List<ItemModel> itemModels, SyncItemJobModel jobModel, java.util.Map<java.lang.String,java.lang.Object> ctxMap) Checks if all ItemModels are sync according to source and target from SyncItemJobModel.
boolean	isSyncInProgress(ItemModel item) Tells if given item is being synchronized.
protected java.util.Optional<java.lang.String>	performCatalogSync(SyncTask syncTask)
java.util.Optional<java.lang.String>	performSynchronization(SyncTask syncTask) Performs synchronization based on given sync task.
protected java.util.Optional<java.lang.String>	preformItemsSync(SyncTask syncTask)
protected SyncConfig	prepareSyncConfig(SyncConfig syncConfig, SyncItemJobModel syncJob) Prepares sync config.
void	reRunCronJob(CatalogVersionSyncCronJobModel cronJob) Runs given sync cron job again omitting items already processed in the previous run.
void	setCatalogSynchronizationService(CatalogSynchronizationService catalogSynchronizationService)
void	setCatalogTypeService(CatalogTypeService catalogTypeService)
void	setCatalogVersionService(CatalogVersionService catalogVersionService)
void	setCronJobService(CronJobService cronJobService)
void	setMediaService(MediaService mediaService)
void	setModelService(ModelService modelService)
void	setRelatedItemsCollector(RelatedItemsCollector relatedItemsCollector)
void	setSessionService(SessionService sessionService)
void	setSynchronizationStatusService(SynchronizationStatusService synchronizationStatusService)
void	setUserService(UserService userService)

Methods inherited from class java.lang.Object

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

Field Detail

SYNC_CONFIG_CREATE_SAVED_VALUES

protected static final java.lang.String SYNC_CONFIG_CREATE_SAVED_VALUES

See Also:

Constant Field Values

SYNC_CONFIG_FORCE_UPDATE

protected static final java.lang.String SYNC_CONFIG_FORCE_UPDATE

See Also:

Constant Field Values

SYNC_CONFIG_SYNCHRONOUS

protected static final java.lang.String SYNC_CONFIG_SYNCHRONOUS

See Also:

Constant Field Values

SYNC_CONFIG_LOG_TO_FILE

protected static final java.lang.String SYNC_CONFIG_LOG_TO_FILE

See Also:

Constant Field Values

SYNC_CONFIG_LOG_TO_DATABASE

protected static final java.lang.String SYNC_CONFIG_LOG_TO_DATABASE

See Also:

Constant Field Values

SYNC_CONFIG_KEEP_CRON_JOB

protected static final java.lang.String SYNC_CONFIG_KEEP_CRON_JOB

See Also:

Constant Field Values

SYNC_CONFIG_LOG_LEVEL_DATABASE

protected static final java.lang.String SYNC_CONFIG_LOG_LEVEL_DATABASE

See Also:

Constant Field Values

SYNC_CONFIG_LOG_LEVEL_FILE

protected static final java.lang.String SYNC_CONFIG_LOG_LEVEL_FILE

See Also:

Constant Field Values

SYNC_CONFIG_ERROR_MODE

protected static final java.lang.String SYNC_CONFIG_ERROR_MODE

See Also:

Constant Field Values

BACKOFFICE_SYNC_CONFIG_ABORT_ON_COLLIDING

protected static final java.lang.String BACKOFFICE_SYNC_CONFIG_ABORT_ON_COLLIDING

See Also:

Constant Field Values

Constructor Detail

DefaultSynchronizationFacade

public DefaultSynchronizationFacade()

Method Detail

performSynchronization

public java.util.Optional<java.lang.String> performSynchronization(SyncTask syncTask)

Description copied from interface: SynchronizationFacade

Performs synchronization based on given sync task.

Specified by:

performSynchronization in interface SynchronizationFacade

Parameters:

syncTask - - defines sync jobs and items to sync.

Returns:

executed sync cron job code CronJobModel.getCode() if sync has been started.

performCatalogSync

protected java.util.Optional<java.lang.String> performCatalogSync(SyncTask syncTask)

preformItemsSync

protected java.util.Optional<java.lang.String> preformItemsSync(SyncTask syncTask)

executeSync

protected java.util.Optional<java.lang.String> executeSync(SyncTask syncTask,
                                                           java.util.function.BiFunction<SyncItemJobModel,SyncConfig,SyncResult> syncRunner)

getItemsCatalogVersions

public java.util.List<CatalogVersionModel> getItemsCatalogVersions(java.util.List<? extends ItemModel> items)

Description copied from interface: SynchronizationFacade

Extracts from given list items which are CatalogVersion

Specified by:

getItemsCatalogVersions in interface SynchronizationFacade

Parameters:

items - list of items

Returns:

list of catalog version items

getCatalogVersionAwareItems

public java.util.List<ItemModel> getCatalogVersionAwareItems(java.util.List<? extends ItemModel> items)

Description copied from interface: SynchronizationFacade

Extract catalog version aware items CatalogTypeService.isCatalogVersionAwareModel(ItemModel)

Specified by:

getCatalogVersionAwareItems in interface SynchronizationFacade

Parameters:

items - list of items

Returns:

list of catalog version aware items

getSynchronizations

protected java.util.List<SyncItemJobModel> getSynchronizations(CatalogVersionModel syncCatalogVersion)

getInboundSynchronizations

public java.util.List<SyncItemJobModel> getInboundSynchronizations(CatalogVersionModel catalogVersion)

Description copied from interface: SynchronizationFacade

Gets inbound sync jobs for given catalog version.

Specified by:

getInboundSynchronizations in interface SynchronizationFacade

Parameters:

catalogVersion - - catalog version for which outbound synchronizations will be returned. To obtain catalog version please use SynchronizationFacade.getSyncCatalogVersion(Collection)

Returns:

list of sync jobs

getOutboundSynchronizations

public java.util.List<SyncItemJobModel> getOutboundSynchronizations(CatalogVersionModel catalogVersion)

Description copied from interface: SynchronizationFacade

Gets outbound sync jobs for given catalog version.

Specified by:

getOutboundSynchronizations in interface SynchronizationFacade

Parameters:

catalogVersion - - catalog version for which outbound synchronizations will be returned. To obtain catalog version please use SynchronizationFacade.getSyncCatalogVersion(Collection)

Returns:

list of sync jobs

getSyncCatalogVersion

public java.util.Optional<CatalogVersionModel> getSyncCatalogVersion(java.util.Collection<ItemModel> items)

Description copied from interface: SynchronizationFacade

Returns catalog version for given items if they are from the same catalog version or are CatalogVersion itself.

Specified by:

getSyncCatalogVersion in interface SynchronizationFacade

Parameters:

items - items for which catalog version will be extracted.

Returns:

catalog version for given items.

isInSync

public java.util.Optional<java.lang.Boolean> isInSync(java.util.List<ItemModel> itemModels,
                                                      SyncItemJobModel jobModel,
                                                      java.util.Map<java.lang.String,java.lang.Object> ctxMap)

Description copied from interface: SynchronizationFacade

Checks if all ItemModels are sync according to source and target from SyncItemJobModel.

Specified by:

isInSync in interface SynchronizationFacade

Parameters:

itemModels - defines items for which sync status is checked

jobModel - defines sync item job model from which source and target is taken to perform status check

ctxMap - defines additional context

Returns:

true if all itemModels are in sync

isInSync

public java.util.Optional<java.lang.Boolean> isInSync(ItemModel itemModel,
                                                      java.util.Map<java.lang.String,java.lang.Object> ctxMap)

Description copied from interface: SynchronizationFacade

Checks ItemModel's status in all available synchronizations.

Specified by:

isInSync in interface SynchronizationFacade

Parameters:

itemModel - defines item for which sync status is checked

ctxMap - defines additional context

Returns:

true if all itemModel are in sync, Optional.empty if sync status is not available e.g. item is not catalog version aware

isSyncInProgress

public boolean isSyncInProgress(ItemModel item)

Description copied from interface: SynchronizationFacade

Tells if given item is being synchronized.

Specified by:

isSyncInProgress in interface SynchronizationFacade

Parameters:

item - item to check

Returns:

true if item is being synchronized.

reRunCronJob

public void reRunCronJob(CatalogVersionSyncCronJobModel cronJob)

Description copied from interface: SynchronizationFacade

Runs given sync cron job again omitting items already processed in the previous run.

Specified by:

reRunCronJob in interface SynchronizationFacade

Parameters:

cronJob - sync cron job to rerun.

copyCronJobSafely

protected CatalogVersionSyncCronJobModel copyCronJobSafely(java.util.function.Supplier<CatalogVersionSyncCronJobModel> copySupplier)

executeInTransaction

protected <T> T executeInTransaction(java.util.function.Supplier<T> toExecute)

executeWithoutTypeInterceptors

protected <T> T executeWithoutTypeInterceptors(java.util.function.Supplier<T> toExecute)

createCronJobForRerun

protected CatalogVersionSyncCronJobModel createCronJobForRerun(CatalogVersionSyncCronJobModel cronJobForRerun)

copyCronJobData

protected void copyCronJobData(CatalogVersionSyncCronJobModel newCronJob,
                               CatalogVersionSyncCronJobModel cronJobForRerun)

copyScheduledMedia

protected void copyScheduledMedia(CatalogVersionSyncCronJobModel newCronJob,
                                  CatalogVersionSyncCronJobModel cronJobForRerun)

getPartialSyncStatusInfo

public java.util.Optional<PartialSyncInfo> getPartialSyncStatusInfo(ItemModel itemModel,
                                                                    SyncItemStatus status,
                                                                    java.util.Map<java.lang.String,java.lang.Object> ctxMap)

Description copied from interface: SynchronizationFacade

Checks ItemModel's status in all available synchronizations.

Specified by:

getPartialSyncStatusInfo in interface SynchronizationFacade

Parameters:

itemModel - defines item for which sync status is checked

status - defines target status for partial sync info PartialSyncInfo

ctxMap - defines additional context

Returns:

partial sync information if item is catalog version aware.

findSyncCounterpart

public java.util.Optional<ItemModel> findSyncCounterpart(ItemModel item,
                                                         SyncItemJobModel syncItemJob)

Description copied from interface: SynchronizationFacade

Finds a counterpart of given item in respective catalog version defined by the syncItemJob.

Specified by:

findSyncCounterpart in interface SynchronizationFacade

Parameters:

item - item of which counterpart will be found.

syncItemJob - synchronization job which defines source and target catalog version.

Returns:

counterpart item if found.

collectRelatedItems

protected java.util.List<ItemModel> collectRelatedItems(java.util.List<ItemModel> items,
                                                        java.util.Map<java.lang.String,java.lang.Object> ctxMap)

canSync

public boolean canSync(SyncItemJobModel sync)

Description copied from interface: SynchronizationFacade

Tells whether current user can perform given sync.

Specified by:

canSync in interface SynchronizationFacade

Parameters:

sync - synchronization job.

Returns:

true if user can synchronize.

getCtxWithMaxRecursionDepth

protected java.util.Map<java.lang.String,java.lang.Object> getCtxWithMaxRecursionDepth(java.util.Map<java.lang.String,java.lang.Object> ctx)

prepareSyncConfig

protected SyncConfig prepareSyncConfig(SyncConfig syncConfig,
                                       SyncItemJobModel syncJob)

Prepares sync config. If given sync config is null then then it will be created using createSyncConfigWithDefaults(SyncItemJobModel)

Parameters:

syncConfig - sync config from sync task SyncTask.getSyncConfig();

syncJob - sync job to be executed.

Returns:

sync config

createSyncConfigWithDefaults

protected SyncConfig createSyncConfigWithDefaults(SyncItemJobModel syncJob)

Creates sync config based on project properties and syncJob settings. If one of the settings is not defined in project properties then default from given syncJob is taken

Parameters:

syncJob - sync job to be executed.

Returns:

sync config with default values

getBooleanFromSystemConfig

protected java.lang.Boolean getBooleanFromSystemConfig(java.lang.String property,
                                                       java.lang.Boolean defaultValue)

getEnumValueFromSystemConfig

protected <T extends java.lang.Enum> T getEnumValueFromSystemConfig(java.lang.Class<T> enumType,
                                                                    java.lang.String property,
                                                                    T defaultValue)

getConfigValue

protected java.lang.String getConfigValue(java.lang.String property,
                                          java.lang.String defaultValue)

getCatalogSynchronizationService

public CatalogSynchronizationService getCatalogSynchronizationService()

setCatalogSynchronizationService

public void setCatalogSynchronizationService(CatalogSynchronizationService catalogSynchronizationService)

getSynchronizationStatusService

public SynchronizationStatusService getSynchronizationStatusService()

setSynchronizationStatusService

public void setSynchronizationStatusService(SynchronizationStatusService synchronizationStatusService)

getCatalogTypeService

public CatalogTypeService getCatalogTypeService()

setCatalogTypeService

public void setCatalogTypeService(CatalogTypeService catalogTypeService)

getRelatedItemsCollector

public RelatedItemsCollector getRelatedItemsCollector()

setRelatedItemsCollector

public void setRelatedItemsCollector(RelatedItemsCollector relatedItemsCollector)

getCronJobService

public CronJobService getCronJobService()

setCronJobService

public void setCronJobService(CronJobService cronJobService)

getModelService

public ModelService getModelService()

setModelService

public void setModelService(ModelService modelService)

getMediaService

public MediaService getMediaService()

setMediaService

public void setMediaService(MediaService mediaService)

getSessionService

public SessionService getSessionService()

setSessionService

public void setSessionService(SessionService sessionService)

getCatalogVersionService

public CatalogVersionService getCatalogVersionService()

setCatalogVersionService

public void setCatalogVersionService(CatalogVersionService catalogVersionService)

getUserService

public UserService getUserService()

setUserService

public void setUserService(UserService userService)