Changeset 7466 for trunk/Jav_CO/com/scenari/m/co/agent/sortie/HAgentSortie.java

Timestamp:

11/23/06 18:21:31 (6 years ago)

Author:

sys

Message:

api Data + AgentLinker

File:

• trunk/Jav_CO/com/scenari/m/co/agent/sortie/HAgentSortie.java (modified) (6 diffs)

trunk/Jav_CO/com/scenari/m/co/agent/sortie/HAgentSortie.java

@@ -52 +52 @@
 import com.scenari.m.co.donnee.IComputedData;
 import com.scenari.m.co.instance.IWInstFormation;
+import com.scenari.s.fw.log.HLogMgr;
 import com.scenari.s.fw.log.HTrace;
 import com.scenari.s.fw.log.HTraceMgr;
@@ -61 +62 @@
 
         /** Cache en mémoire du résultat. */
-        protected transient IComputedData fResultatCache = null;
+        protected transient IComputedData fDataCache = null;
 
         /** Trace. */
@@ -83 +84 @@
         public IComputedData computeAsData(IHDialog pDialog, Object pArguments) throws Exception {
 
-                if (fResultatCache != null) return fResultatCache;
+                if (fDataCache != null) return fDataCache;
 
                 IComputedData vResult = IComputedData.NULL;
@@ -102 +103 @@
 
                 String vCache = ((HComposantTypeSortie) fComposant.hGetComposantType()).hGetResultatCache();
-                if(vCache != null) {
+                if (vCache != null) {
                         if ("*".equals(vCache)) {
-                                fResultatCache = new DataVolatileString(vResult.getString(), vResult.getMime());
-                                return fResultatCache;
+                                fDataCache = new DataVolatileString(vResult.getString(), vResult.getMime());
+                                return fDataCache;
                         } else if ("node".equals(vCache)) {
-                                fResultatCache = new DataVolatileNode(vResult.getNode(), vResult.getMime());
-                                return fResultatCache;
+                                fDataCache = new DataVolatileNode(vResult.getNode(), vResult.getMime());
+                                return fDataCache;
                         }
                 }
@@ -115 +116 @@
 
         public Node computeAsNode(IHDialog pDialog, Object pArguments) throws Exception {
-                return computeAsData(pDialog, pArguments).getNode();
+
+                if (fDataCache != null) return fDataCache.getNode();
+                String vCache = ((HComposantTypeSortie) fComposant.hGetComposantType()).hGetResultatCache();
+                if (vCache != null) {
+                        xComputeCache(vCache, pDialog, pArguments);
+                        return fDataCache.getNode();
+                }
+
+                IData vSource = ((WComposantSortie) fComposant).hGetSource();
+
+                if (!hIsActif(pDialog)) {
+                        return IData.NULL_NODE;
+                } else if (vSource.getLevel() <= IData.LEVEL_STATIQUE) {
+                        return ((WComposantSortie) fComposant).hGetSource().getNode(pDialog, this, pArguments);
+                } else {
+                        if (((HComposantTypeSortie) fComposant.hGetComposantType()).hGetTransformsList() == null) {
+                                return vSource.getNode(pDialog, this, pArguments);
+                        } else {
+                                return new XDonneeResultatSortie(this, pDialog, pArguments).getNode();
+                        }
+                }
         }
 
@@ -122 +143 @@
          */
         public String computeAsString(IHDialog pDialog, Object pArguments) throws Exception {
-                return computeAsData(pDialog, pArguments).getString();
+
+                if (fDataCache != null) return fDataCache.getString();
+
+                String vCache = ((HComposantTypeSortie) fComposant.hGetComposantType()).hGetResultatCache();
+                if (vCache != null) {
+                        xComputeCache(vCache, pDialog, pArguments);
+                        return fDataCache.getString();
+                }
+
+                IData vSource = ((WComposantSortie) fComposant).hGetSource();
+
+                if (!hIsActif(pDialog)) {
+                        return IData.NULL_STRING;
+                } else if (vSource.getLevel() <= IData.LEVEL_STATIQUE) {
+                        return ((WComposantSortie) fComposant).hGetSource().getString(pDialog, this, pArguments);
+                } else {
+                        if (((HComposantTypeSortie) fComposant.hGetComposantType()).hGetTransformsList() == null) {
+                                return vSource.getString(pDialog, this, pArguments);
+                        } else {
+                                return new XDonneeResultatSortie(this, pDialog, pArguments).getString();
+                        }
+                }
+        }
+
+        protected void xComputeCache(String pCache, IHDialog pDialog, Object pArguments) throws Exception {
+                if (!hIsActif(pDialog)) {
+                        fDataCache = IComputedData.NULL;
+                }
+                IData vSource = ((WComposantSortie) fComposant).hGetSource();
+                if ("*".equals(pCache)) {
+                        if (vSource.getLevel() <= IData.LEVEL_STATIQUE) {
+                                fDataCache = new DataVolatileString(vSource.getString(pDialog, this, pArguments));
+                        } else {
+                                if (((HComposantTypeSortie) fComposant.hGetComposantType()).hGetTransformsList() == null) {
+                                        try {
+                                                pDialog.hExecStackPush(this);
+                                                fDataCache = new DataVolatileString(vSource.getString(pDialog, this, pArguments));
+                                        } finally {
+                                                pDialog.hExecStackPop();
+                                        }
+                                } else {
+                                        fDataCache = new DataVolatileString(new XDonneeResultatSortie(this, pDialog, pArguments).getString());
+                                }
+                        }
+                } else if ("node".equals(pCache)) {
+                        if (vSource.getLevel() <= IData.LEVEL_STATIQUE) {
+                                fDataCache = new DataVolatileNode(vSource.getNode(pDialog, this, pArguments));
+                        } else {
+                                if (((HComposantTypeSortie) fComposant.hGetComposantType()).hGetTransformsList() == null) {
+                                        try {
+                                                pDialog.hExecStackPush(this);
+                                                fDataCache = new DataVolatileNode(vSource.getNode(pDialog, this, pArguments));
+                                        } finally {
+                                                pDialog.hExecStackPop();
+                                        }
+                                } else {
+                                        fDataCache = new DataVolatileNode(new XDonneeResultatSortie(this, pDialog, pArguments).getNode());
+                                }
+                        }
+                } else {
+                        throw HLogMgr.hNewException("Valeur de cache inconnue '" + pCache + "' définie dans " + this);
+                }
         }