de.hybris.platform.importcockpit.services.cronjob.impl

Class DefaultImportCockpitCronJobService

java.lang.Object

de.hybris.platform.servicelayer.internal.service.AbstractService

de.hybris.platform.servicelayer.internal.service.AbstractBusinessService

de.hybris.platform.servicelayer.cronjob.impl.DefaultCronJobService

de.hybris.platform.importcockpit.services.cronjob.impl.DefaultImportCockpitCronJobService

All Implemented Interfaces:

ImportCockpitCronJobService, CronJobService, Serializable

public class DefaultImportCockpitCronJobService
extends DefaultCronJobService
implements ImportCockpitCronJobService

Provides service methods for the specific performing, logging and reporting of the import cockpit cron jobs.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class de.hybris.platform.servicelayer.internal.service.AbstractService

AbstractService.SerializableDTO

Field Summary

Fields inherited from class de.hybris.platform.servicelayer.cronjob.impl.DefaultCronJobService

DEFAULT_LOG_BUNCH

Fields inherited from class de.hybris.platform.servicelayer.internal.service.AbstractBusinessService

modelService, sessionService, txManager

Fields inherited from class de.hybris.platform.servicelayer.internal.service.AbstractService

tenant

Constructor Summary

Constructors

Constructor and Description
DefaultImportCockpitCronJobService()

Method Summary

Modifier and Type	Method and Description
void	createJobMedia(ImportCockpitCronJobModel cronJobModel) Starts the impex generation and sets the generated impex package as a jobMedia in the cron job.
protected ImpExMediaGenerationService	getImpExGenerationService()
protected ImportCockpitCronJobDao	getImportCockpitCronJobDao() Accessor for a ImportCockpitCronJobDao which might be helpful on higher levels of the class hierarchy.
ImportCockpitCronJobLogDao	getImportCockpitCronJobLogDao()
List<ImportCockpitCronJobModel>	getImportCockpitCronJobs() returns a list of all ImportCockpitCronJobs.
protected ImportCockpitMappingService	getImportCockpitMappingService()
String	getLogsAsText(CronJobModel cronJobModel) Returns text representation of top 500 CronJobModel.getLogs() entries for a given CronJobModel, as concatenated and decorated content of its JobLogModel.getMessage().
String	getLogsAsText(CronJobModel cronJobModel, int count) Returns text representation of top given count CronJobModel.getLogs() entries for a given CronJobModel, as concatenated and decorated content of its JobLogModel.getMessage().
protected MappingModelValidationService	getModelValidationService()
List<ImportCockpitCronJobModel>	getRecentlyModifiedCronJobs(int count) Gets a list of the most recently edited ImportCockpitCronJobs.
boolean	isPerformable(CronJobModel cronJob) Checks if the cronjob model is performable.
boolean	performImportCockpitCronJobSecure(ImportCockpitCronJobModel cronJobModel) Starts the import cockpit cron job if a valid mapping is attached to it.
void	resetCronJob(ImportCockpitCronJobModel cronJobModel) Resets following attribute values of the specified cronJob object: jobMedia, externalDataCollection, workMedia, valueCount, lastSuccessfulLine, enableCodeExecution, unzipMediasMedia, enableHmcSavedValues.
void	setImpexGenerationService(ImpExMediaGenerationService impexGenerationService)
void	setImportCockpitCronJobDao(ImportCockpitCronJobDao importCockpitCronJobDao)
void	setImportCockpitCronJobLogDao(ImportCockpitCronJobLogDao importCockpitCronJobLogDao)
void	setImportCockpitMappingService(ImportCockpitMappingService importCockpitMappingService)
void	setModelValidationService(MappingModelValidationService modelValidationService)

Methods inherited from class de.hybris.platform.servicelayer.cronjob.impl.DefaultCronJobService

canRunOnThisNode, getCronJob, getCronJobExpression, getCronJobFactory, getJob, getJobLogConverter, getPerformable, getRunningOrRestartedCronJobs, isAbortable, isError, isFinished, isPaused, isRunning, isSuccessful, performCronJob, performCronJob, requestAbortCronJob, setClusterService, setCronJobCodeGenerator, setCronJobDao, setJobDao, setJobLogConverter, setJobLogDao, setRunCronJobMessageBuilder, setTaskService, setTenantService, startOnDifferentNodeViaTask

Methods inherited from class de.hybris.platform.servicelayer.internal.service.AbstractBusinessService

getModelService, getSessionService, getTxManager, setModelService, setSessionService, setTxManager

Methods inherited from class de.hybris.platform.servicelayer.internal.service.AbstractService

afterPropertiesSet, getCurrentTenant, setBeanName, setCurrentTenant, setTenantScope, writeReplace

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.hybris.platform.servicelayer.cronjob.CronJobService

getCronJob, getCronJobFactory, getJob, getPerformable, getRunningOrRestartedCronJobs, isAbortable, isError, isFinished, isPaused, isRunning, isSuccessful, performCronJob, performCronJob, requestAbortCronJob

Constructor Detail

DefaultImportCockpitCronJobService

public DefaultImportCockpitCronJobService()

Method Detail

setImpexGenerationService

public void setImpexGenerationService(ImpExMediaGenerationService impexGenerationService)

getImpExGenerationService

protected ImpExMediaGenerationService getImpExGenerationService()

setModelValidationService

public void setModelValidationService(MappingModelValidationService modelValidationService)

getModelValidationService

protected MappingModelValidationService getModelValidationService()

resetCronJob

public void resetCronJob(ImportCockpitCronJobModel cronJobModel)

Description copied from interface: ImportCockpitCronJobService

Resets following attribute values of the specified cronJob object: jobMedia, externalDataCollection, workMedia, valueCount, lastSuccessfulLine, enableCodeExecution, unzipMediasMedia, enableHmcSavedValues. This is necessary in order to start a new clean import. That's why this method is called before the jobMedia is generated.

Specified by:

resetCronJob in interface ImportCockpitCronJobService

createJobMedia

public void createJobMedia(ImportCockpitCronJobModel cronJobModel)

Description copied from interface: ImportCockpitCronJobService

Starts the impex generation and sets the generated impex package as a jobMedia in the cron job.

Specified by:

createJobMedia in interface ImportCockpitCronJobService

isPerformable

public boolean isPerformable(CronJobModel cronJob)

Description copied from interface: CronJobService

Checks if the cronjob model is performable.

Specified by:

isPerformable in interface CronJobService

Overrides:

isPerformable in class DefaultCronJobService

Parameters:

cronJob - which will be used

performImportCockpitCronJobSecure

public boolean performImportCockpitCronJobSecure(ImportCockpitCronJobModel cronJobModel)

Description copied from interface: ImportCockpitCronJobService

Starts the import cockpit cron job if a valid mapping is attached to it.

Specified by:

performImportCockpitCronJobSecure in interface ImportCockpitCronJobService

Returns:

true if the cron job has been performed successfully with a valid mapping

getLogsAsText

public String getLogsAsText(CronJobModel cronJobModel)

Description copied from interface: CronJobService

Returns text representation of top 500 CronJobModel.getLogs() entries for a given CronJobModel, as concatenated and decorated content of its JobLogModel.getMessage().

Specified by:

getLogsAsText in interface CronJobService

Overrides:

getLogsAsText in class DefaultCronJobService

getLogsAsText

public String getLogsAsText(CronJobModel cronJobModel,
                            int count)

Description copied from interface: CronJobService

Returns text representation of top given count CronJobModel.getLogs() entries for a given CronJobModel, as concatenated and decorated content of its JobLogModel.getMessage().

Specified by:

getLogsAsText in interface CronJobService

Overrides:

getLogsAsText in class DefaultCronJobService

getRecentlyModifiedCronJobs

public List<ImportCockpitCronJobModel> getRecentlyModifiedCronJobs(int count)

Description copied from interface: ImportCockpitCronJobService

Gets a list of the most recently edited ImportCockpitCronJobs.

Specified by:

getRecentlyModifiedCronJobs in interface ImportCockpitCronJobService

Parameters:

count - : The number of recently edited ImportCockpitCronJobs to return.

Returns:

a list containing a specified number of the most recently edited ImportCockpitCronJobs.

getImportCockpitCronJobs

public List<ImportCockpitCronJobModel> getImportCockpitCronJobs()

Description copied from interface: ImportCockpitCronJobService

returns a list of all ImportCockpitCronJobs.

Specified by:

getImportCockpitCronJobs in interface ImportCockpitCronJobService

Returns:

list of all ImportCockpitCronJob.

getImportCockpitMappingService

protected ImportCockpitMappingService getImportCockpitMappingService()

setImportCockpitMappingService

public void setImportCockpitMappingService(ImportCockpitMappingService importCockpitMappingService)

getImportCockpitCronJobDao

protected ImportCockpitCronJobDao getImportCockpitCronJobDao()

Accessor for a ImportCockpitCronJobDao which might be helpful on higher levels of the class hierarchy.

Returns:

the icCronJobDao

setImportCockpitCronJobDao

public void setImportCockpitCronJobDao(ImportCockpitCronJobDao importCockpitCronJobDao)

getImportCockpitCronJobLogDao

public ImportCockpitCronJobLogDao getImportCockpitCronJobLogDao()

Returns:

the importCockpitCronJobLogDao

setImportCockpitCronJobLogDao

public void setImportCockpitCronJobLogDao(ImportCockpitCronJobLogDao importCockpitCronJobLogDao)

Parameters:

importCockpitCronJobLogDao - the importCockpitCronJobLogDao to set