Package com.avoka.fc.core.dao

Class JobDao

java.lang.Object

com.avoka.core.dao.BaseDao

com.avoka.fc.core.dao.AbstractDao

com.avoka.fc.core.dao.JobDao

public class JobDao
extends AbstractDao

Provides a DAO for the Collaboration Job entity.

Since:

4.0.0

See Also:

• Job

Field Summary

Fields inherited from class com.avoka.core.dao.BaseDao

FETCH_LIMIT, STATEMENT_MAX_NO_PARAMETERS

Constructor Summary

Constructors

Constructor	Description
JobDao()

Method Summary

Modifier and Type	Method	Description
int	getFinishedJobCount()	Return the number of finished collaboration jobs
Job	getJobForKey(String jobKey)	Return the Job object for the given job key or null if not found.
Job	getJobForPK(Object id)	Return the Job object for the given primary key or null if not found.
Job	getJobForReferenceNumber(String referenceNumber)	Return the first Job object for the given reference number or null if not found.
List<Job>	getJobList(String clientId, String searchString, String status, String serviceId, Date startDate, Date endDate)	Return the list of jobs matching the specified search criteria.
List<Job>	getJobList(String keyword, String jobStatus, Date fromDate, Portal portal)	Deprecated.
List<Job>	getJobList(String keyword, String jobStatus, Date fromDate, Portal portal, String loginName)	Deprecated.
List<Job>	getJobListForKeywordOrProperty(String clientId, String jobKeyword, String jobStatus, Date startDate, Date endDate, String propertyName, String propertyValue)	Return the list of jobs which match the specified search criteria.
org.apache.cayenne.ResultIterator<Job>	getJobsForLicensing()	Return up to 100,000 collaboration jobs that have not yet been published for licensing
List<Job>	getJobsReadyToProcess()	Return the list of jobs ready to process.
int	getNumberOfJobsCreated(Date startDate, Date endDate, Client client)	Return the number of jobs created within a certain date range and optionally matching a specific client.
List<Job>	getPurgeJobDataJobList(int fetchLimit, Date cutoffDate)	Return the list of Job of which job data can be purged
List<Long>	getPurgeJobIdList(int fetchLimit)	Return the list of Job ID to purge.
void	recalcJobAbandonTime(Long clientId, int maxAgeInDays, boolean calcOnTimeCreated)	Recalculate job abandon times if the global Abandon policy has changed.
void	recalcJobDataPurgeTime(Long clientId, int maxAgeInDays)	Recalc job data purge time
void	recalcJobPurgeTime(int maxAgeInDays)	Recalculate job purge times if the global purge policy has changed.
void	updateJobAbandonTime(Job job)	Updates the job Abandon time based on the job status and deployment setting (i.e.
void	updateJobDataPurgeTime(Job job)	Set the job data purge time based on the job status.
void	updateJobPurgeTime(Job job)	Updates the job purge time based on the job status.

Methods inherited from class com.avoka.fc.core.dao.AbstractDao

andFilterClientExcludeNull, andFilterClientIncludeNull, andFilterClientOnly, isClientAccessAllowed, performQueryConfigCached

Methods inherited from class com.avoka.core.dao.BaseDao

addOrdering, addOrderingCaseInsensitive, addOrderingCaseSensitive, andQueryBetween, andQueryInExp, andQueryInExp, andQueryLikeIgnoreCaseExp, andQueryMatchDbExp, andQueryMatchExp, andQueryMatchIsNotNull, andQueryMatchIsNull, andQueryNoMatchExp, andQueryNotTrue, deleteObject, deleteObjects, findObject, getDataContext, getFetchLimit, getLogger, getObjectForPK, newObject, orQueryLikeIgnoreCaseExp, orQueryMatchExp, performNamedQuery, performNamedQuery, performNamedQuery, performNamedQuery, performNonSelectingQuery, performNonSelectingQuery, performNonSelectingQuery, performNonSelectingQuery, performQuery, performQuery, performQuery, registerNewObject, setCacheStrategy, setFetchLimit, setLocalCacheStrategy, setLocalCacheStrategy, setSharedCacheStrategy, toMap, toMap

Methods inherited from class java.lang.Object

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

Constructor Details

JobDao

public JobDao()

Method Details

getJobForPK

public Job getJobForPK(Object id)

Return the Job object for the given primary key or null if not found.

Parameters:

id - the Job ID

Returns:

the Job object for the given primary key or null if not found

getJobForKey

public Job getJobForKey(String jobKey)

Return the Job object for the given job key or null if not found.

Parameters:

jobKey - the Job Key

Returns:

the Job object for the given job key or null if not found

getJobForReferenceNumber

public Job getJobForReferenceNumber(String referenceNumber)

Return the first Job object for the given reference number or null if not found.

Parameters:

referenceNumber - the Job Key

Returns:

the first Job object for the given reference number or null if not found

Since:

4.2.1

getJobsReadyToProcess

public List<Job> getJobsReadyToProcess()

Return the list of jobs ready to process. To ensure the job processing is fairly balanced across all jobs needing processing this method will return a result list ordered by unprocessed job, then jobs last processed time.

Returns:

the list of jobs ready to process

getJobList

public List<Job> getJobList(String clientId,
 String searchString,
 String status,
 String serviceId,
 Date startDate,
 Date endDate)

Return the list of jobs matching the specified search criteria. The list of results will be sorted by creation time in descending order.

Parameters:

clientId - the client ID to filter on (optional; if not set, user-specific client filtering will be applied)

searchString - the search string entered by the user (optional)

status - the status (optional)

serviceId - the controller Service Definition ID

startDate - the lower bound on the creation time

endDate - the upper bound on the creation time

Returns:

the list of matching jobs

getJobListForKeywordOrProperty

public List<Job> getJobListForKeywordOrProperty(String clientId,
 String jobKeyword,
 String jobStatus,
 Date startDate,
 Date endDate,
 String propertyName,
 String propertyValue)

Return the list of jobs which match the specified search criteria. If the jobKeyword is specified this will be used to search for the job name using a like match expression, or the job reference number using an exact match expression, or the job key if the keyword is a 32 character alphanumeric expression.

If the propertyName and propertyValue criteria is specified then the search will filter on job with job properties which have the specified property name (exact match) and job property value (like match).

Parameters:

clientId - the client ID (optional)

jobKeyword - the job keyword (optional)

jobStatus - the job status (optional)

startDate - the job creation start date (optional)

endDate - the job creation end date (optional)

propertyName - the job property name (optional)

propertyValue - the job property value (optional)

Returns:

the list of jobs which match the specified search criteria

Since:

4.3.4

getJobList

public List<Job> getJobList(String keyword,
 String jobStatus,
 Date fromDate,
 Portal portal)

Deprecated.

Return the list of Jobs for the given search criteria.

Parameters:

keyword - the search keyword

jobStatus - the job status

fromDate - the start date

portal - the portals client associations

Returns:

the list Jobs for the given search criteria.

getJobList

public List<Job> getJobList(String keyword,
 String jobStatus,
 Date fromDate,
 Portal portal,
 String loginName)

Deprecated.

Return the list of Jobs for the given search criteria.

Parameters:

keyword - the search keyword

jobStatus - the job status

fromDate - the start date

portal - the portals client associations

loginName - the login name to filter on (optional)

Returns:

the list of jobs for the given search criteria

Since:

4.3.1

getNumberOfJobsCreated

public int getNumberOfJobsCreated(Date startDate,
 Date endDate,
 Client client)

Return the number of jobs created within a certain date range and optionally matching a specific client. Other attributes such as current job status are not considered.

Parameters:

startDate - the start date (required, inclusive)

endDate - the end date (required, exclusive)

client - the organization to match (optional)

Returns:

the number of jobs created during the specified period

Since:

4.2.0

getPurgeJobDataJobList

public List<Job> getPurgeJobDataJobList(int fetchLimit,
 Date cutoffDate)

Return the list of Job of which job data can be purged

Parameters:

fetchLimit - the query fetch limit

cutoffDate - the query cut off date

Returns:

the list of Job to purge job data

Since:

24.4.0

getPurgeJobIdList

public List<Long> getPurgeJobIdList(int fetchLimit)

Return the list of Job ID to purge.

Parameters:

fetchLimit - the query fetch limit

Returns:

the list of Job ID to purge

Since:

4.3.3

recalcJobPurgeTime

public void recalcJobPurgeTime(int maxAgeInDays)

Recalculate job purge times if the global purge policy has changed.

Parameters:

maxAgeInDays - the new maximum age of a collaboration job

Since:

4.3.3

updateJobDataPurgeTime

public void updateJobDataPurgeTime(Job job)

Set the job data purge time based on the job status. Set job data purge time if the job is finished (Completed, Cancelled, Expired)

Parameters:

job - the job (required)

Since:

24.4.0

updateJobPurgeTime

public void updateJobPurgeTime(Job job)

Updates the job purge time based on the job status. Note that if the job is finished (completed, cancelled, expired), the finished time should be set for purge time calculation.

Parameters:

job - the job (required)

Since:

4.3.3

recalcJobAbandonTime

public void recalcJobAbandonTime(Long clientId,
 int maxAgeInDays,
 boolean calcOnTimeCreated)

Recalculate job abandon times if the global Abandon policy has changed.

Parameters:

clientId - the client id (optional; if clientId is not set, it is assumed that the system policy has changed)

maxAgeInDays - the new maximum age of a collaboration job

calcOnTimeCreated - value based on which the abandon time is calculated from time created or last processed

Since:

22.4.0

recalcJobDataPurgeTime

public void recalcJobDataPurgeTime(Long clientId,
 int maxAgeInDays)

Recalc job data purge time

Parameters:

clientId - the client id

maxAgeInDays - the new maximum age of a collaboration job data

Since:

24.4.0

updateJobAbandonTime

public void updateJobAbandonTime(Job job)

Updates the job Abandon time based on the job status and deployment setting (i.e. based on time created or time last processed). Note that if the job is not cancelled, completed, Error, expired, based on the deployment setting Abandon time is calculated from time created or time last processed.

Parameters:

job - the job (required)

Since:

22.4.0

getFinishedJobCount

public int getFinishedJobCount()

Return the number of finished collaboration jobs

Returns:

the number of finished collaboration jobs

Since:

4.3.3

getJobsForLicensing

public org.apache.cayenne.ResultIterator<Job> getJobsForLicensing()

Return up to 100,000 collaboration jobs that have not yet been published for licensing

Returns:

a result iterator for matching jobs

Since:

4.3.4