X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.core%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fcore%2Fexecution%2FMapExecutionContext.java;h=97f4d91c2c0307ea7cbfc431e3e1cffee96400ee;hb=31a8055cac622a55afd2668e77f00aba1d031f91;hp=564acab2219b26357558150013456cfb0fffb019;hpb=08aa02f96eb32a6e1f0cc001113df9311a618eb9;p=gpl%2Fargeo-slc.git diff --git a/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/MapExecutionContext.java b/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/MapExecutionContext.java index 564acab22..97f4d91c2 100644 --- a/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/MapExecutionContext.java +++ b/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/execution/MapExecutionContext.java @@ -6,15 +6,23 @@ import java.util.HashMap; import java.util.Map; import java.util.UUID; +import org.argeo.slc.SlcException; import org.argeo.slc.execution.ExecutionContext; +import org.springframework.beans.BeanWrapper; +import org.springframework.beans.BeanWrapperImpl; +import org.springframework.beans.BeansException; +import org.springframework.context.ApplicationContext; +import org.springframework.context.ApplicationContextAware; -public class MapExecutionContext implements - ExecutionContext { +public class MapExecutionContext implements ExecutionContext, + ApplicationContextAware { private final Map variables = Collections .synchronizedMap(new HashMap()); private final String uuid; + private ApplicationContext applicationContext; + public MapExecutionContext() { uuid = UUID.randomUUID().toString(); variables.put(VAR_EXECUTION_CONTEXT_ID, uuid); @@ -22,14 +30,63 @@ public class MapExecutionContext implements } public void setVariable(String key, Object value) { + // check if we do not refer to a bean + int lastInd = key.lastIndexOf('.'); + if (applicationContext != null && lastInd > 0) { + String beanName = key.substring(0, lastInd); + String propertyName = key.substring(lastInd + 1); + if (applicationContext.containsBean(beanName)) { + BeanWrapper beanWrapper = new BeanWrapperImpl( + applicationContext.getBean(beanName)); + if (!beanWrapper.isWritableProperty(propertyName)) + throw new SlcException("No writable property " + + propertyName + " in bean " + beanName); + beanWrapper.setPropertyValue(propertyName, value); + } + } + variables.put(key, value); } public Object getVariable(String key) { + // check if we do not refer to a bean + int lastInd = key.lastIndexOf('.'); + if (applicationContext != null && lastInd > 0) { + String beanName = key.substring(0, lastInd); + String propertyName = key.substring(lastInd + 1); + if (applicationContext.containsBean(beanName)) { + BeanWrapper beanWrapper = new BeanWrapperImpl( + applicationContext.getBean(beanName)); + if (!beanWrapper.isReadableProperty(propertyName)) + throw new SlcException("No readable property " + + propertyName + " in bean " + beanName); + Object obj = beanWrapper.getPropertyValue(propertyName); + return obj; + } + } + return variables.get(key); } public String getUuid() { return uuid; } + + @Override + public boolean equals(Object obj) { + if (obj instanceof ExecutionContext) + return uuid.equals(((ExecutionContext) obj).getUuid()); + return false; + } + + @Override + public String toString() { + return getClass().getSimpleName() + "#" + uuid; + } + + public void setApplicationContext(ApplicationContext applicationContext) + throws BeansException { + this.applicationContext = applicationContext; + } + }