de.hybris.platform.droolsruleengineservices.impl

Class DefaultCommerceRuleEngineService

java.lang.Object

de.hybris.platform.droolsruleengineservices.impl.DefaultCommerceRuleEngineService

All Implemented Interfaces:

RuleEngineService

public class DefaultCommerceRuleEngineService
extends Object
implements RuleEngineService

Default implementation of Commerce Rule Engine Service.

Constructor Summary

Constructors

Constructor and Description
DefaultCommerceRuleEngineService()

Method Summary

Modifier and Type	Method and Description
protected Collection<Object>	addRuleConfigurationFacts(Collection<DroolsRuleModel> rules) returns a set of rule configuration facts for the given rules (used in evaluate(RuleEvaluationContext) method) by using the configured getRuleConfigurationProvider().
protected RuleEngineResultRAO	addRuleEngineResultRAO(RuleEvaluationContext context) Adds a RuleEngineResultRAO to the facts of this context if it doesn't exist already.
protected Collection<Object>	addRuleGroupExecutionFacts(Collection<DroolsRuleModel> rules) Returns a collection of (unique) rule group execution facts for the given rules (used in evaluate(RuleEvaluationContext) method) using the configured getRuleGroupExecutionProvider().
RuleEngineActionResult	archiveRule(AbstractRuleEngineRuleModel ruleEngineRule) Archives the given rule if it already exists.
RuleEngineActionResult	archiveRule(AbstractRuleEngineRuleModel ruleEngineRule, AbstractRulesModuleModel rulesModule) Archives the given rule if it already exists.
protected MessageLevel	convertLevel(Level level) converts a drools message Level code to a MessageLevel
RuleEvaluationResult	evaluate(RuleEvaluationContext context) Executes rule evaluation for given RuleEvaluationContext.
protected AgendaEventListenerFactory	getAgendaEventListenerFactory()
protected AgendaFilterFactory	getAgendaFilterFactory()
protected ConfigurationService	getConfigurationService()
protected EngineRuleDao	getEngineRuleDao()
protected FactContextFactory	getFactContextFactory()
protected Map<String,Object>	getGlobals(Collection<DroolsRuleModel> rules) retrieves the globals defined in the given set of rules.
protected RuleEngineService	getPlatformRuleEngineService()
protected ProcessEventListenerFactory	getProcessEventListenerFactory()
protected RAOProvider	getRuleConfigurationProvider()
AbstractRuleEngineRuleModel	getRuleForCode(String code) Finds AbstractRuleEngineRuleModel for given code.
AbstractRuleEngineRuleModel	getRuleForUuid(String uuid) Finds AbstractRuleEngineRuleModel for given uuid.
protected RAOProvider	getRuleGroupExecutionProvider()
AbstractRulesModuleModel	getRuleModuleForRule(AbstractRuleEngineRuleModel rule) Finds AbstractRulesModuleModel by corresponding AbstractRuleEngineRuleModel.
protected RuleRuntimeEventListenerFactory	getRuleRuntimeEventListenerFactory()
RuleEngineActionResult	initialize(AbstractRulesModuleModel abstractModule) Initializes the given rules module and propagates a RuleEngineInitializedEvent to other nodes.
RuleEngineActionResult	initialize(AbstractRulesModuleModel abstractModule, boolean propagateToOtherNodes) Initializes the given rules module (and if propagateToOtherNodes is set to true propagates a RuleEngineInitializedEvent to other nodes).
List<RuleEngineActionResult>	initializeAllRulesModules() Initializes all AbstractRulesModuleModels that are marked as active (in case of cluster mode - on all the nodes).
List<RuleEngineActionResult>	initializeAllRulesModules(boolean propagateToOtherNodes) Initializes all AbstractRulesModuleModels that are marked as active.
protected Set<Object>	provideRAOs(FactContext factContext)
void	setAgendaEventListenerFactory(AgendaEventListenerFactory agendaEventListenerFactory)
void	setAgendaFilterFactory(AgendaFilterFactory agendaFilterFactory)
void	setConfigurationService(ConfigurationService configurationService)
void	setEngineRuleDao(EngineRuleDao engineRuleDao)
void	setFactContextFactory(FactContextFactory factContextFactory)
void	setPlatformRuleEngineService(RuleEngineService ruleEngineService)
void	setProcessEventListenerFactory(ProcessEventListenerFactory processEventListenerFactory)
void	setRuleConfigurationProvider(RAOProvider ruleConfigurationProvider)
void	setRuleGroupExecutionProvider(RAOProvider ruleGroupExecutionProvider)
void	setRuleRuntimeEventListenerFactory(RuleRuntimeEventListenerFactory ruleRuntimeEventListenerFactory)
RuleEngineActionResult	updateEngineRule(AbstractRuleEngineRuleModel ruleEngineRule) Updates the given rule if it already exists and returns true if update was successful.
RuleEngineActionResult	updateEngineRule(AbstractRuleEngineRuleModel ruleEngineRule, AbstractRulesModuleModel rulesModule) Updates the given rule if it already exists.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultCommerceRuleEngineService

public DefaultCommerceRuleEngineService()

Method Detail

initialize

public RuleEngineActionResult initialize(AbstractRulesModuleModel abstractModule,
                                         boolean propagateToOtherNodes)

Description copied from interface: RuleEngineService

Initializes the given rules module (and if propagateToOtherNodes is set to true propagates a RuleEngineInitializedEvent to other nodes).

Specified by:

initialize in interface RuleEngineService

Parameters:

abstractModule - the module to be initialized

propagateToOtherNodes - if true propagates a RuleEngineInitializedEvent to other nodes.

Returns:

the result of the initialize action (use RuleEngineActionResult.isActionFailed() to check if the action succeeded)

initialize

public RuleEngineActionResult initialize(AbstractRulesModuleModel abstractModule)

Description copied from interface: RuleEngineService

Initializes the given rules module and propagates a RuleEngineInitializedEvent to other nodes.

Specified by:

initialize in interface RuleEngineService

Parameters:

abstractModule - the module to be initialized

Returns:

the result of the initialize action (use RuleEngineActionResult.isActionFailed() to check if the action succeeded)

convertLevel

protected MessageLevel convertLevel(Level level)

converts a drools message Level code to a MessageLevel

evaluate

public RuleEvaluationResult evaluate(RuleEvaluationContext context)

Description copied from interface: RuleEngineService

Executes rule evaluation for given RuleEvaluationContext. Executes all rules contained within the context

Specified by:

evaluate in interface RuleEngineService

Parameters:

context - the rule engine context containing data about rule engine execution

Returns:

results of rule engine execution

addRuleEngineResultRAO

protected RuleEngineResultRAO addRuleEngineResultRAO(RuleEvaluationContext context)

Adds a RuleEngineResultRAO to the facts of this context if it doesn't exist already.

Parameters:

context - the rule engine context

Returns:

the result rao (already added to the context.facts)

addRuleGroupExecutionFacts

protected Collection<Object> addRuleGroupExecutionFacts(Collection<DroolsRuleModel> rules)

Returns a collection of (unique) rule group execution facts for the given rules (used in evaluate(RuleEvaluationContext) method) using the configured getRuleGroupExecutionProvider().

Parameters:

rules - the rules for which to add the rule group execution facts

addRuleConfigurationFacts

protected Collection<Object> addRuleConfigurationFacts(Collection<DroolsRuleModel> rules)

returns a set of rule configuration facts for the given rules (used in evaluate(RuleEvaluationContext) method) by using the configured getRuleConfigurationProvider().

Parameters:

rules - the rules for which to add the configuration facts

provideRAOs

protected Set<Object> provideRAOs(FactContext factContext)

getGlobals

protected Map<String,Object> getGlobals(Collection<DroolsRuleModel> rules)

retrieves the globals defined in the given set of rules.

Parameters:

rules - the rules

Returns:

a map with key key global name and value spring bean to be set as the global

initializeAllRulesModules

public List<RuleEngineActionResult> initializeAllRulesModules()

Description copied from interface: RuleEngineService

Initializes all AbstractRulesModuleModels that are marked as active (in case of cluster mode - on all the nodes).

Specified by:

initializeAllRulesModules in interface RuleEngineService

Returns:

the results of the initialize action (use RuleEngineActionResult.isActionFailed() to check if the action succeeded)

initializeAllRulesModules

public List<RuleEngineActionResult> initializeAllRulesModules(boolean propagateToOtherNodes)

Description copied from interface: RuleEngineService

Initializes all AbstractRulesModuleModels that are marked as active.

Specified by:

initializeAllRulesModules in interface RuleEngineService

Parameters:

propagateToOtherNodes - if true on all the nodes of cluster

Returns:

the activation results

updateEngineRule

public RuleEngineActionResult updateEngineRule(AbstractRuleEngineRuleModel ruleEngineRule)

Description copied from interface: RuleEngineService

Updates the given rule if it already exists and returns true if update was successful.

Specified by:

updateEngineRule in interface RuleEngineService

Parameters:

ruleEngineRule - Rule to be updated

Returns:

the result of the update action (use RuleEngineActionResult.isActionFailed() to check if the action succeeded)

updateEngineRule

public RuleEngineActionResult updateEngineRule(AbstractRuleEngineRuleModel ruleEngineRule,
                                               AbstractRulesModuleModel rulesModule)

Description copied from interface: RuleEngineService

Updates the given rule if it already exists.

Specified by:

updateEngineRule in interface RuleEngineService

Parameters:

ruleEngineRule - Rule to be updated

rulesModule - AbstractRulesModuleModel where the Rule be updated

Returns:

the result of the update action (use RuleEngineActionResult.isActionFailed() to check if the action succeeded)

archiveRule

public RuleEngineActionResult archiveRule(AbstractRuleEngineRuleModel ruleEngineRule)

Description copied from interface: RuleEngineService

Archives the given rule if it already exists.

Specified by:

archiveRule in interface RuleEngineService

Parameters:

ruleEngineRule - Rule to be archived

Returns:

the result of the archive action (use RuleEngineActionResult.isActionFailed() to check if the action succeeded)

archiveRule

public RuleEngineActionResult archiveRule(AbstractRuleEngineRuleModel ruleEngineRule,
                                          AbstractRulesModuleModel rulesModule)

Description copied from interface: RuleEngineService

Archives the given rule if it already exists.

Specified by:

archiveRule in interface RuleEngineService

Parameters:

ruleEngineRule - Rule to be archived

rulesModule - AbstractRulesModuleModel where the Rule is archived

Returns:

the result of the archive action (use RuleEngineActionResult.isActionFailed() to check if the action succeeded)

getRuleForCode

public AbstractRuleEngineRuleModel getRuleForCode(String code)

Description copied from interface: RuleEngineService

Finds AbstractRuleEngineRuleModel for given code.

Specified by:

getRuleForCode in interface RuleEngineService

Parameters:

code - the rule code

Returns:

AbstractRuleEngineRuleModel for given code.

getRuleForUuid

public AbstractRuleEngineRuleModel getRuleForUuid(String uuid)

Description copied from interface: RuleEngineService

Finds AbstractRuleEngineRuleModel for given uuid.

Specified by:

getRuleForUuid in interface RuleEngineService

Parameters:

uuid - the rule uuid

Returns:

AbstractRuleEngineRuleModel for given uuid.

getRuleModuleForRule

public AbstractRulesModuleModel getRuleModuleForRule(AbstractRuleEngineRuleModel rule)

Description copied from interface: RuleEngineService

Finds AbstractRulesModuleModel by corresponding AbstractRuleEngineRuleModel.

Specified by:

getRuleModuleForRule in interface RuleEngineService

Parameters:

rule - the AbstractRuleEngineRuleModel

Returns:

AbstractRulesModuleModel by corresponding AbstractRuleEngineRuleModel

getAgendaFilterFactory

protected AgendaFilterFactory getAgendaFilterFactory()

setAgendaFilterFactory

public void setAgendaFilterFactory(AgendaFilterFactory agendaFilterFactory)

getAgendaEventListenerFactory

protected AgendaEventListenerFactory getAgendaEventListenerFactory()

setAgendaEventListenerFactory

public void setAgendaEventListenerFactory(AgendaEventListenerFactory agendaEventListenerFactory)

getProcessEventListenerFactory

protected ProcessEventListenerFactory getProcessEventListenerFactory()

setProcessEventListenerFactory

public void setProcessEventListenerFactory(ProcessEventListenerFactory processEventListenerFactory)

getRuleRuntimeEventListenerFactory

protected RuleRuntimeEventListenerFactory getRuleRuntimeEventListenerFactory()

setRuleRuntimeEventListenerFactory

public void setRuleRuntimeEventListenerFactory(RuleRuntimeEventListenerFactory ruleRuntimeEventListenerFactory)

getRuleConfigurationProvider

protected RAOProvider getRuleConfigurationProvider()

setRuleConfigurationProvider

public void setRuleConfigurationProvider(RAOProvider ruleConfigurationProvider)

getRuleGroupExecutionProvider

protected RAOProvider getRuleGroupExecutionProvider()

setRuleGroupExecutionProvider

public void setRuleGroupExecutionProvider(RAOProvider ruleGroupExecutionProvider)

getPlatformRuleEngineService

protected RuleEngineService getPlatformRuleEngineService()

getEngineRuleDao

protected EngineRuleDao getEngineRuleDao()

setEngineRuleDao

public void setEngineRuleDao(EngineRuleDao engineRuleDao)

setPlatformRuleEngineService

public void setPlatformRuleEngineService(RuleEngineService ruleEngineService)

getConfigurationService

protected ConfigurationService getConfigurationService()

setConfigurationService

public void setConfigurationService(ConfigurationService configurationService)

getFactContextFactory

protected FactContextFactory getFactContextFactory()

setFactContextFactory

public void setFactContextFactory(FactContextFactory factContextFactory)