Package overit.geocallapp.wfm.core.bl.criticalactivity.detectprocess.task

Class BTDetectCriticalActivities<I>

java.lang.Object

overit.geocall.bl.BusinessTask<I>

overit.geocallapp.utilities.core.bl.common.validexecution.ValidExecutionBusinessTask<I>

overit.geocallapp.wfm.core.bl.criticalactivity.detectprocess.task.BTCriticalActivity<I>

overit.geocallapp.wfm.core.bl.criticalactivity.detectprocess.task.BTDetectCriticalActivities<I>

All Implemented Interfaces:

Serializable, Tool, ValidExecution

Direct Known Subclasses:

BTAutomaticDetectCriticalActivities, BTForcedDetectCriticalActivities

public abstract class BTDetectCriticalActivities<I>
extends BTCriticalActivity<I>

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected CriticalActivityEntitiesCache	cache
protected Map<Long,CriticalActivityCriterion>	criteria
protected overit.geocallapp.wfm.util.wfmtasklog.WfmTaskLog	logger
protected Date	processEndDate
protected Date	processStartDate
protected Long	processType
protected String	processUUID
protected Set<Long>	woOperationsToSkip

Constructor Summary

Constructors

Constructor	Description
BTDetectCriticalActivities()

Method Summary

Modifier and Type	Method	Description
protected void	analyzeWoOperations(Set<Long> woOperationIds, CriticalActivityRule rule, CriticalActivityCriterion criterion, PoolKit poolKit)
protected void	closeLog()
protected BOCriticalActivity	createCriticalActivity(Long ruleId, Long woOperationId)
protected abstract List<BOCriticalActivityDetectProcess>	createDetectProcessData()
protected void	deleteOutdatedCriticalActivities(PoolKit poolKit)
protected void	deletePreviousCriticalActivities(Set<Long> woOperations, PoolKit poolKit)
protected void	deletePreviousCriticalActivities(PoolKit poolKit)
protected void	finalizeDetectProcessData()
protected CriticalActivityCriterion	getCriterion(BOCriticalActivityRuleCriterion criterion)
protected abstract CriticalActivityDetectProcessType	getProcessType()
protected void	init(I event, PoolKit poolKit)
protected void	initDetectProcessData()
protected abstract void	initLogger()
protected void	insertCriticalActivity(Long ruleId, Long woOperationId, PoolKit poolKit)
protected void	insertDetectProcessData()
protected abstract boolean	isImmediateCommit()
protected void	launchCommittableEvent(BusinessEvent event, PoolKit poolKit)
protected CriticalActivityRule	loadCriticalActivityRule(Long ruleId, PoolKit poolKit)
protected List<BOCriticalActivityDetectProcess>	loadRunningForcedProcesses(PoolKit poolKit)
protected List<BOCriticalActivityDetectProcess>	loadSubsequentForcedProcesses(PoolKit poolKit)
protected Set<Long>	loadWoOperations(CriticalActivityRule rule, CriticalActivityCriterion criterion, Set<Long> woOperationsToInclude, PoolKit poolKit)
protected Set<Long>	loadWoOperations(CriticalActivityRule rule, CriticalActivityCriterion criterion, PoolKit poolKit)
protected void	logLoadWoOperationsInput(CriticalActivityWorkOrderOperationSearchInput input)
protected void	openLog()
protected void	openLog(Set<Long> woOperations)
protected void	updateDetectProcessData()
protected void	updateWoOperationsToSkip(List<BOCriticalActivityDetectProcess> detectProcesses)

Methods inherited from class overit.geocallapp.wfm.core.bl.criticalactivity.detectprocess.task.BTCriticalActivity

getException, isValidExecution, throwExceptionIfInvalid

Methods inherited from class overit.geocallapp.utilities.core.bl.common.validexecution.ValidExecutionBusinessTask

body, checkValidExecution, execute, getEvent

Methods inherited from class overit.geocall.bl.BusinessTask

start, start, startAlone, startInBackground

Methods inherited from class java.lang.Object

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

Field Details

logger

protected overit.geocallapp.wfm.util.wfmtasklog.WfmTaskLog logger

cache

protected CriticalActivityEntitiesCache cache

criteria

protected Map<Long,CriticalActivityCriterion> criteria

woOperationsToSkip

protected Set<Long> woOperationsToSkip

processUUID

protected String processUUID

processType

protected Long processType

processStartDate

protected Date processStartDate

processEndDate

protected Date processEndDate

Constructor Details

BTDetectCriticalActivities

public BTDetectCriticalActivities()

Method Details

getProcessType

protected abstract CriticalActivityDetectProcessType getProcessType()

isImmediateCommit

protected abstract boolean isImmediateCommit()

initLogger

protected abstract void initLogger()

createDetectProcessData

protected abstract List<BOCriticalActivityDetectProcess> createDetectProcessData()

init

protected void init(I event,
 PoolKit poolKit)

initDetectProcessData

protected void initDetectProcessData()
                              throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

finalizeDetectProcessData

protected void finalizeDetectProcessData()
                                  throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

openLog

protected void openLog()
                throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

openLog

protected void openLog(Set<Long> woOperations)
                throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

closeLog

protected void closeLog()
                 throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

updateWoOperationsToSkip

protected void updateWoOperationsToSkip(List<BOCriticalActivityDetectProcess> detectProcesses)
                                 throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

loadRunningForcedProcesses

protected List<BOCriticalActivityDetectProcess> loadRunningForcedProcesses(PoolKit poolKit)
                                                                    throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

loadSubsequentForcedProcesses

protected List<BOCriticalActivityDetectProcess> loadSubsequentForcedProcesses(PoolKit poolKit)
                                                                       throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

deletePreviousCriticalActivities

protected void deletePreviousCriticalActivities(PoolKit poolKit)
                                         throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

deletePreviousCriticalActivities

protected void deletePreviousCriticalActivities(Set<Long> woOperations,
 PoolKit poolKit)
                                         throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

deleteOutdatedCriticalActivities

protected void deleteOutdatedCriticalActivities(PoolKit poolKit)
                                         throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

loadCriticalActivityRule

protected CriticalActivityRule loadCriticalActivityRule(Long ruleId,
 PoolKit poolKit)
                                                 throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

getCriterion

protected CriticalActivityCriterion getCriterion(BOCriticalActivityRuleCriterion criterion)

loadWoOperations

protected Set<Long> loadWoOperations(CriticalActivityRule rule,
 CriticalActivityCriterion criterion,
 PoolKit poolKit)
                              throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

loadWoOperations

protected Set<Long> loadWoOperations(CriticalActivityRule rule,
 CriticalActivityCriterion criterion,
 Set<Long> woOperationsToInclude,
 PoolKit poolKit)
                              throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

logLoadWoOperationsInput

protected void logLoadWoOperationsInput(CriticalActivityWorkOrderOperationSearchInput input)
                                 throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

analyzeWoOperations

protected void analyzeWoOperations(Set<Long> woOperationIds,
 CriticalActivityRule rule,
 CriticalActivityCriterion criterion,
 PoolKit poolKit)
                            throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

createCriticalActivity

protected BOCriticalActivity createCriticalActivity(Long ruleId,
 Long woOperationId)

insertCriticalActivity

protected void insertCriticalActivity(Long ruleId,
 Long woOperationId,
 PoolKit poolKit)
                               throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

insertDetectProcessData

protected void insertDetectProcessData()
                                throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

updateDetectProcessData

protected void updateDetectProcessData()
                                throws DAException,
DAValidateException

Throws:

DAException

DAValidateException

launchCommittableEvent

protected void launchCommittableEvent(BusinessEvent event,
 PoolKit poolKit)
                               throws DAException,
DAValidateException

Throws:

DAException

DAValidateException