"""
Définit les outils généraux élémentaires.
-
- Ce module est destiné à être appelée par AssimilationStudy.
"""
__author__ = "Jean-Philippe ARGAUD"
__all__ = []
import numpy
from daCore import Persistence
from daCore import PlatformInfo
+from daCore import Interfaces
from daCore import Templates
+from daCore.Interfaces import ImportFromScript
# ==============================================================================
class CacheManager(object):
"Permet de lancer le calcul d'assimilation"
if FileName is None or not os.path.exists(FileName):
raise ValueError("a YACS file name has to be given for YACS execution.\n")
+ else:
+ __file = os.path.abspath(FileName)
+ logging.debug("The YACS file name is \"%s\"."%__file)
if not PlatformInfo.has_salome or \
not PlatformInfo.has_yacs or \
not PlatformInfo.has_adao:
xmlLoader = loader.YACSLoader()
xmlLoader.registerProcCataLoader()
try:
- catalogAd = r.loadCatalog("proc", os.path.abspath(FileName))
+ catalogAd = r.loadCatalog("proc", __file)
r.addCatalog(catalogAd)
except:
pass
try:
- p = xmlLoader.load(os.path.abspath(FileName))
+ p = xmlLoader.load(__file)
except IOError as ex:
print("The YACS XML schema file can not be loaded: %s"%(ex,))
#
return 1
+# ==============================================================================
+class RegulationAndParameters(object):
+ """
+ Classe générale d'interface d'action pour la régulation et ses paramètres
+ """
+ def __init__(self,
+ name = "GenericRegulation",
+ asAlgorithm = None,
+ asDict = None,
+ asScript = None,
+ ):
+ """
+ """
+ self.__name = str(name)
+ self.__P = {}
+ #
+ if asAlgorithm is None and asScript is not None:
+ __Algo = ImportFromScript(asScript).getvalue( "Algorithm" )
+ else:
+ __Algo = asAlgorithm
+ #
+ if asDict is None and asScript is not None:
+ __Dict = ImportFromScript(asScript).getvalue( self.__name, "Parameters" )
+ else:
+ __Dict = asDict
+ #
+ if __Dict is not None:
+ self.__P.update( dict(__Dict) )
+ #
+ if __Algo is not None:
+ self.__P.update( {"Algorithm":self.__A} )
+
+ def get(self, key = None):
+ "Vérifie l'existence d'une clé de variable ou de paramètres"
+ if key in self.__P:
+ return self.__P[key]
+ else:
+ return self.__P
+
# ==============================================================================
class DataObserver(object):
"""
self.__objname = str(__objname)
self.__logSerie = []
self.__switchoff = False
- self.__viewers = self.__loaders = {
- "TUI":_TUIViewer,
- "EPD":_EPDViewer,
- "DCT":_DCTViewer,
- "SCD":_SCDViewer,
- "YACS":_YACSViewer,
+ self.__viewers = {
+ "TUI" :Interfaces._TUIViewer,
+ "SCD" :Interfaces._SCDViewer,
+ "YACS":Interfaces._YACSViewer,
+ }
+ self.__loaders = {
+ "TUI" :Interfaces._TUIViewer,
+ "COM" :Interfaces._COMViewer,
}
if __addViewers is not None:
self.__viewers.update(dict(__addViewers))
self.__switchoff = False
def dump(self, __filename=None, __format="TUI", __upa=""):
- "Restitution normalisée des commandes (par les *GenericCaseViewer)"
+ "Restitution normalisée des commandes"
if __format in self.__viewers:
__formater = self.__viewers[__format](self.__name, self.__objname, self.__logSerie)
else:
raise ValueError("Loading as \"%s\" is not available"%__format)
return __formater.load(__filename, __content, __object)
-# ==============================================================================
-class GenericCaseViewer(object):
- """
- Gestion des commandes de creation d'une vue de cas
- """
- def __init__(self, __name="", __objname="case", __content=None, __object=None):
- "Initialisation et enregistrement de l'entete"
- self._name = str(__name)
- self._objname = str(__objname)
- self._lineSerie = []
- self._switchoff = False
- self._numobservers = 2
- self._content = __content
- self._object = __object
- self._missing = """raise ValueError("This case requires beforehand to import or define the variable named <%s>. When corrected, remove this command, correct and uncomment the following one.")\n# """
- def _append(self, *args):
- "Transformation de commande individuelle en enregistrement"
- raise NotImplementedError()
- def _extract(self, *args):
- "Transformation d'enregistrement en commande individuelle"
- raise NotImplementedError()
- def _finalize(self, __upa=None):
- "Enregistrement du final"
- if __upa is not None and len(__upa)>0:
- self._lineSerie.append("%s.execute()"%(self._objname,))
- self._lineSerie.append(__upa)
- def _addLine(self, line=""):
- "Ajoute un enregistrement individuel"
- self._lineSerie.append(line)
- def _get_objname(self):
- return self._objname
- def dump(self, __filename=None, __upa=None):
- "Restitution normalisée des commandes"
- self._finalize(__upa)
- __text = "\n".join(self._lineSerie)
- __text +="\n"
- if __filename is not None:
- __file = os.path.abspath(__filename)
- __fid = open(__file,"w")
- __fid.write(__text)
- __fid.close()
- return __text
- def load(self, __filename=None, __content=None, __object=None):
- "Chargement normalisé des commandes"
- if __filename is not None and os.path.exists(__filename):
- self._content = open(__filename, 'r').read()
- elif __content is not None and type(__content) is str:
- self._content = __content
- elif __object is not None and type(__object) is dict:
- self._object = copy.deepcopy(__object)
- else:
- pass # use "self._content" from initialization
- __commands = self._extract(self._content, self._object)
- return __commands
-
-class _TUIViewer(GenericCaseViewer):
- """
- Etablissement des commandes d'un cas ADAO TUI (Cas<->TUI)
- """
- def __init__(self, __name="", __objname="case", __content=None, __object=None):
- "Initialisation et enregistrement de l'entete"
- GenericCaseViewer.__init__(self, __name, __objname, __content, __object)
- self._addLine("# -*- coding: utf-8 -*-")
- self._addLine("#\n# Python script for ADAO TUI\n#")
- self._addLine("from numpy import array, matrix")
- self._addLine("import adaoBuilder")
- self._addLine("%s = adaoBuilder.New('%s')"%(self._objname, self._name))
- if self._content is not None:
- for command in self._content:
- self._append(*command)
- def _append(self, __command=None, __keys=None, __local=None, __pre=None, __switchoff=False):
- "Transformation d'une commande individuelle en un enregistrement"
- if __command is not None and __keys is not None and __local is not None:
- __text = ""
- if __pre is not None:
- __text += "%s = "%__pre
- __text += "%s.%s( "%(self._objname,str(__command))
- if "self" in __keys: __keys.remove("self")
- if __command not in ("set","get") and "Concept" in __keys: __keys.remove("Concept")
- for k in __keys:
- __v = __local[k]
- if __v is None: continue
- if k == "Checked" and not __v: continue
- if k == "Stored" and not __v: continue
- if k == "AvoidRC" and __v: continue
- if k == "noDetails": continue
- if isinstance(__v,Persistence.Persistence): __v = __v.values()
- if callable(__v): __text = self._missing%__v.__name__+__text
- if isinstance(__v,dict):
- for val in __v.values():
- if callable(val): __text = self._missing%val.__name__+__text
- numpy.set_printoptions(precision=15,threshold=1000000,linewidth=1000*15)
- __text += "%s=%s, "%(k,repr(__v))
- numpy.set_printoptions(precision=8,threshold=1000,linewidth=75)
- __text.rstrip(", ")
- __text += ")"
- self._addLine(__text)
- def _extract(self, __multilines="", __object=None):
- "Transformation un enregistrement en une commande individuelle"
- __is_case = False
- __commands = []
- __multilines = __multilines.replace("\r\n","\n")
- for line in __multilines.split("\n"):
- if "adaoBuilder.New" in line and "=" in line:
- self._objname = line.split("=")[0].strip()
- __is_case = True
- logging.debug("TUI Extracting commands of '%s' object..."%(self._objname,))
- if not __is_case:
- continue
- else:
- if self._objname+".set" in line:
- __commands.append( line.replace(self._objname+".","",1) )
- logging.debug("TUI Extracted command: %s"%(__commands[-1],))
- return __commands
-
-class _EPDViewer(GenericCaseViewer):
- """
- Etablissement des commandes d'un cas EPD (Eficas Python Dictionnary/Cas<-EPD)
- """
- def __init__(self, __name="", __objname="case", __content=None, __object=None):
- "Initialisation et enregistrement de l'entete"
- GenericCaseViewer.__init__(self, __name, __objname, __content, __object)
- self._observerIndex = 0
- self._addLine("# -*- coding: utf-8 -*-")
- self._addLine("#\n# Python script for ADAO EPD\n#")
- self._addLine("from numpy import array, matrix")
- self._addLine("#")
- self._addLine("%s = {}"%__objname)
- if self._content is not None:
- for command in self._content:
- self._append(*command)
- def _extract(self, __multilines=None, __object=None):
- "Transformation un enregistrement en une commande individuelle"
- if __multilines is not None:
- __multilines = __multilines.replace("\r\n","\n")
- exec(__multilines)
- self._objdata = None
- __getlocals = locals()
- for k in __getlocals:
- try:
- if type(__getlocals[k]) is dict:
- if 'ASSIMILATION_STUDY' in __getlocals[k]:
- self._objname = k
- self._objdata = __getlocals[k]['ASSIMILATION_STUDY']
- if 'CHECKING_STUDY' in __getlocals[k]:
- self._objname = k
- self._objdata = __getlocals[k]['CHECKING_STUDY']
- except:
- continue
- elif __multilines is None and __object is not None and type(__object) is dict:
- self._objname = "case"
- self._objdata = None
- if 'ASSIMILATION_STUDY' in __object:
- self._objdata = __object['ASSIMILATION_STUDY']
- if 'CHECKING_STUDY' in __object:
- self._objdata = __object['CHECKING_STUDY']
- else:
- self._objdata = None
- #
- if self._objdata is None or not(type(self._objdata) is dict) or not('AlgorithmParameters' in self._objdata):
- raise ValueError("Impossible to load given content as a ADAO EPD one (no dictionnary or no 'AlgorithmParameters' key found).")
- # ----------------------------------------------------------------------
- logging.debug("EPD Extracting commands of '%s' object..."%(self._objname,))
- __commands = []
- __UserPostAnalysis = ""
- for k,r in self._objdata.items():
- __command = k
- logging.debug("EPD Extracted command: %s:%s"%(k, r))
- if __command == "StudyName" and len(str(r))>0:
- __commands.append( "set( Concept='Name', String='%s')"%(str(r),) )
- elif __command == "StudyRepertory":
- __commands.append( "set( Concept='Directory', String='%s')"%(str(r),) )
- #
- elif __command == "UserPostAnalysis" and type(r) is dict:
- if 'STRING_DATA' in r:
- __UserPostAnalysis = r['STRING_DATA']['STRING']
- elif 'SCRIPT_DATA' in r and os.path.exists(r['SCRIPT_DATA']['SCRIPT_FILE']):
- __UserPostAnalysis = open(r['SCRIPT_DATA']['SCRIPT_FILE'],'r').read()
- elif 'TEMPLATE_DATA' in r:
- # AnalysisPrinter...
- __itempl = r['TEMPLATE_DATA']['Template']
- __UserPostAnalysis = r['TEMPLATE_DATA'][__itempl]['ValueTemplate']
- else:
- __UserPostAnalysis = ""
- __UserPostAnalysis = __UserPostAnalysis.replace("ADD",self._objname)
- #
- elif __command == "AlgorithmParameters" and type(r) is dict and 'Algorithm' in r:
- if 'Parameters%s'%(r['Algorithm'],) in r and r['Parameters'] == 'Defaults':
- __Dict = r['Parameters%s'%(r['Algorithm'],)]
- if 'SetSeed' in __Dict:__Dict['SetSeed'] = int(__Dict['SetSeed'])
- if 'BoxBounds' in __Dict and type(__Dict['BoxBounds']) is str:
- __Dict['BoxBounds'] = eval(__Dict['BoxBounds'])
- __parameters = ', Parameters=%s'%(repr(__Dict),)
- elif 'Dict' in r and r['Parameters'] == 'Dict':
- __from = r['Dict']['data']
- if 'STRING_DATA' in __from:
- __parameters = ", Parameters=%s"%(repr(eval(__from['STRING_DATA']['STRING'])),)
- elif 'SCRIPT_DATA' in __from and os.path.exists(__from['SCRIPT_DATA']['SCRIPT_FILE']):
- __parameters = ", Script='%s'"%(__from['SCRIPT_DATA']['SCRIPT_FILE'],)
- else:
- __parameters = ""
- __commands.append( "set( Concept='AlgorithmParameters', Algorithm='%s'%s )"%(r['Algorithm'],__parameters) )
- #
- elif __command == "Observers" and type(r) is dict and 'SELECTION' in r:
- if type(r['SELECTION']) is str:
- __selection = (r['SELECTION'],)
- else:
- __selection = tuple(r['SELECTION'])
- for sk in __selection:
- __idata = r[sk]['%s_data'%sk]
- if __idata['NodeType'] == 'Template' and 'Template' in __idata['ObserverTemplate']:
- __template =__idata['ObserverTemplate']['Template']
- __commands.append( "set( Concept='Observer', Variable='%s', Template='%s' )"%(sk,__template) )
- if __idata['NodeType'] == 'String' and 'Value' in __idata:
- __value =__idata['Value']
- __commands.append( "set( Concept='Observer', Variable='%s', String='%s' )"%(sk,__value) )
- #
- # Background, ObservationError, ObservationOperator...
- elif type(r) is dict:
- __argumentsList = []
- if 'Stored' in r and bool(r['Stored']):
- __argumentsList.append(['Stored',True])
- if 'INPUT_TYPE' in r and r['INPUT_TYPE'] in r:
- # Vector, Matrix, ScalarSparseMatrix, DiagonalSparseMatrix, Function
- __itype = r['INPUT_TYPE']
- __idata = r[__itype]['data']
- if 'FROM' in __idata and __idata['FROM'].upper()+'_DATA' in __idata:
- # String, Script, Template, ScriptWithOneFunction, ScriptWithFunctions
- __ifrom = __idata['FROM']
- if __ifrom == 'String' or __ifrom == 'Template':
- __argumentsList.append([__itype,__idata['STRING_DATA']['STRING']])
- if __ifrom == 'Script':
- __argumentsList.append([__itype,True])
- __argumentsList.append(['Script',__idata['SCRIPT_DATA']['SCRIPT_FILE']])
- if __ifrom == 'ScriptWithOneFunction':
- __argumentsList.append(['OneFunction',True])
- __argumentsList.append(['Script',__idata['SCRIPTWITHONEFUNCTION_DATA'].pop('SCRIPTWITHONEFUNCTION_FILE')])
- if len(__idata['SCRIPTWITHONEFUNCTION_DATA'])>0:
- __argumentsList.append(['Parameters',__idata['SCRIPTWITHONEFUNCTION_DATA']])
- if __ifrom == 'ScriptWithFunctions':
- __argumentsList.append(['ThreeFunctions',True])
- __argumentsList.append(['Script',__idata['SCRIPTWITHFUNCTIONS_DATA'].pop('SCRIPTWITHFUNCTIONS_FILE')])
- if len(__idata['SCRIPTWITHFUNCTIONS_DATA'])>0:
- __argumentsList.append(['Parameters',__idata['SCRIPTWITHFUNCTIONS_DATA']])
- __arguments = ["%s = %s"%(k,repr(v)) for k,v in __argumentsList]
- __commands.append( "set( Concept='%s', %s )"%(__command, ", ".join(__arguments)))
- #
- # ----------------------------------------------------------------------
- __commands.sort() # Pour commencer par 'AlgorithmParameters'
- __commands.append(__UserPostAnalysis)
- return __commands
-
-class _DCTViewer(GenericCaseViewer):
- """
- Etablissement des commandes d'un cas DCT (Cas<->DCT)
- """
- def __init__(self, __name="", __objname="case", __content=None, __object=None):
- "Initialisation et enregistrement de l'entete"
- GenericCaseViewer.__init__(self, __name, __objname, __content, __object)
- self._observerIndex = 0
- self._addLine("# -*- coding: utf-8 -*-")
- self._addLine("#\n# Python script for ADAO DCT\n#")
- self._addLine("from numpy import array, matrix")
- self._addLine("#")
- self._addLine("%s = {}"%__objname)
- if self._content is not None:
- for command in self._content:
- self._append(*command)
- def _append(self, __command=None, __keys=None, __local=None, __pre=None, __switchoff=False):
- "Transformation d'une commande individuelle en un enregistrement"
- if __command is not None and __keys is not None and __local is not None:
- __text = ""
- if "execute" in __command: return
- if "self" in __keys: __keys.remove("self")
- if __command in ("set","get") and "Concept" in __keys:
- __key = __local["Concept"]
- __keys.remove("Concept")
- else:
- __key = __command.replace("set","").replace("get","")
- if "Observer" in __key and 'Variable' in __keys:
- self._observerIndex += 1
- __key += "_%i"%self._observerIndex
- __text += "%s['%s'] = {"%(self._objname,str(__key))
- for k in __keys:
- __v = __local[k]
- if __v is None: continue
- if k == "Checked" and not __v: continue
- if k == "Stored" and not __v: continue
- if k == "AvoidRC" and __v: continue
- if k == "noDetails": continue
- if isinstance(__v,Persistence.Persistence): __v = __v.values()
- if callable(__v): __text = self._missing%__v.__name__+__text
- if isinstance(__v,dict):
- for val in __v.values():
- if callable(val): __text = self._missing%val.__name__+__text
- numpy.set_printoptions(precision=15,threshold=1000000,linewidth=1000*15)
- __text += "'%s':%s, "%(k,repr(__v))
- numpy.set_printoptions(precision=8,threshold=1000,linewidth=75)
- __text.rstrip(", ").rstrip()
- __text += "}"
- if __text[-2:] == "{}": return # Supprime les *Debug et les variables
- self._addLine(__text)
- def _extract(self, __multilines="", __object=None):
- "Transformation un enregistrement en une commande individuelle"
- __commands = []
- __multilines = __multilines.replace("\r\n","\n")
- exec(__multilines)
- self._objdata = None
- __getlocals = locals()
- for k in __getlocals:
- try:
- if 'AlgorithmParameters' in __getlocals[k] and type(__getlocals[k]) is dict:
- self._objname = k
- self._objdata = __getlocals[k]
- except:
- continue
- if self._objdata is None:
- raise ValueError("Impossible to load given content as a ADAO DCT one (no 'AlgorithmParameters' key found).")
- for k in self._objdata:
- if 'Observer_' in k:
- __command = k.split('_',1)[0]
- else:
- __command = k
- __arguments = ["%s = %s"%(k,repr(v)) for k,v in self._objdata[k].items()]
- __commands.append( "set( Concept='%s', %s )"%(__command, ", ".join(__arguments)))
- __commands.sort() # Pour commencer par 'AlgorithmParameters'
- return __commands
-
-class _SCDViewer(GenericCaseViewer):
- """
- Etablissement des commandes d'un cas SCD (Study Config Dictionary/Cas->SCD)
- """
- def __init__(self, __name="", __objname="case", __content=None, __object=None):
- "Initialisation et enregistrement de l'entete"
- GenericCaseViewer.__init__(self, __name, __objname, __content, __object)
- self._addLine("# -*- coding: utf-8 -*-")
- self._addLine("#\n# Input for ADAO converter to YACS\n#")
- self._addLine("from numpy import array, matrix")
- self._addLine("#")
- self._addLine("study_config = {}")
- self._addLine("study_config['StudyType'] = 'ASSIMILATION_STUDY'")
- self._addLine("study_config['Name'] = '%s'"%self._name)
- self._addLine("observers = {}")
- self._addLine("study_config['Observers'] = observers")
- self._addLine("#")
- self._addLine("inputvariables_config = {}")
- self._addLine("inputvariables_config['Order'] =['adao_default']")
- self._addLine("inputvariables_config['adao_default'] = -1")
- self._addLine("study_config['InputVariables'] = inputvariables_config")
- self._addLine("#")
- self._addLine("outputvariables_config = {}")
- self._addLine("outputvariables_config['Order'] = ['adao_default']")
- self._addLine("outputvariables_config['adao_default'] = -1")
- self._addLine("study_config['OutputVariables'] = outputvariables_config")
- if __content is not None:
- for command in __content:
- self._append(*command)
- def _append(self, __command=None, __keys=None, __local=None, __pre=None, __switchoff=False):
- "Transformation d'une commande individuelle en un enregistrement"
- if __command == "set": __command = __local["Concept"]
- else: __command = __command.replace("set", "", 1)
- #
- __text = None
- if __command in (None, 'execute', 'executePythonScheme', 'executeYACSScheme', 'get', 'Name'):
- return
- elif __command in ['Debug', 'setDebug']:
- __text = "#\nstudy_config['Debug'] = '1'"
- elif __command in ['NoDebug', 'setNoDebug']:
- __text = "#\nstudy_config['Debug'] = '0'"
- elif __command in ['Observer', 'setObserver']:
- __obs = __local['Variable']
- self._numobservers += 1
- __text = "#\n"
- __text += "observers['%s'] = {}\n"%__obs
- if __local['String'] is not None:
- __text += "observers['%s']['nodetype'] = '%s'\n"%(__obs, 'String')
- __text += "observers['%s']['String'] = \"\"\"%s\"\"\"\n"%(__obs, __local['String'])
- if __local['Script'] is not None:
- __text += "observers['%s']['nodetype'] = '%s'\n"%(__obs, 'Script')
- __text += "observers['%s']['Script'] = \"%s\"\n"%(__obs, __local['Script'])
- if __local['Template'] is not None and __local['Template'] in Templates.ObserverTemplates:
- __text += "observers['%s']['nodetype'] = '%s'\n"%(__obs, 'String')
- __text += "observers['%s']['String'] = \"\"\"%s\"\"\"\n"%(__obs, Templates.ObserverTemplates[__local['Template']])
- if __local['Info'] is not None:
- __text += "observers['%s']['info'] = \"\"\"%s\"\"\"\n"%(__obs, __local['Info'])
- else:
- __text += "observers['%s']['info'] = \"\"\"%s\"\"\"\n"%(__obs, __obs)
- __text += "observers['%s']['number'] = %s"%(__obs, self._numobservers)
- elif __local is not None: # __keys is not None and
- numpy.set_printoptions(precision=15,threshold=1000000,linewidth=1000*15)
- __text = "#\n"
- __text += "%s_config = {}\n"%__command
- if 'self' in __local: __local.pop('self')
- __to_be_removed = []
- for __k,__v in __local.items():
- if __v is None: __to_be_removed.append(__k)
- for __k in __to_be_removed:
- __local.pop(__k)
- for __k,__v in __local.items():
- if __k == "Concept": continue
- if __k in ['ScalarSparseMatrix','DiagonalSparseMatrix','Matrix','OneFunction','ThreeFunctions'] and 'Script' in __local: continue
- if __k == 'Algorithm':
- __text += "study_config['Algorithm'] = %s\n"%(repr(__v))
- elif __k == 'Script':
- __k = 'Vector'
- __f = 'Script'
- __v = "'"+repr(__v)+"'"
- for __lk in ['ScalarSparseMatrix','DiagonalSparseMatrix','Matrix']:
- if __lk in __local and __local[__lk]: __k = __lk
- if __command == "AlgorithmParameters": __k = "Dict"
- if 'OneFunction' in __local and __local['OneFunction']:
- __text += "%s_ScriptWithOneFunction = {}\n"%(__command,)
- __text += "%s_ScriptWithOneFunction['Function'] = ['Direct', 'Tangent', 'Adjoint']\n"%(__command,)
- __text += "%s_ScriptWithOneFunction['Script'] = {}\n"%(__command,)
- __text += "%s_ScriptWithOneFunction['Script']['Direct'] = %s\n"%(__command,__v)
- __text += "%s_ScriptWithOneFunction['Script']['Tangent'] = %s\n"%(__command,__v)
- __text += "%s_ScriptWithOneFunction['Script']['Adjoint'] = %s\n"%(__command,__v)
- __text += "%s_ScriptWithOneFunction['DifferentialIncrement'] = 1e-06\n"%(__command,)
- __text += "%s_ScriptWithOneFunction['CenteredFiniteDifference'] = 0\n"%(__command,)
- __k = 'Function'
- __f = 'ScriptWithOneFunction'
- __v = '%s_ScriptWithOneFunction'%(__command,)
- if 'ThreeFunctions' in __local and __local['ThreeFunctions']:
- __text += "%s_ScriptWithFunctions = {}\n"%(__command,)
- __text += "%s_ScriptWithFunctions['Function'] = ['Direct', 'Tangent', 'Adjoint']\n"%(__command,)
- __text += "%s_ScriptWithFunctions['Script'] = {}\n"%(__command,)
- __text += "%s_ScriptWithFunctions['Script']['Direct'] = %s\n"%(__command,__v)
- __text += "%s_ScriptWithFunctions['Script']['Tangent'] = %s\n"%(__command,__v)
- __text += "%s_ScriptWithFunctions['Script']['Adjoint'] = %s\n"%(__command,__v)
- __k = 'Function'
- __f = 'ScriptWithFunctions'
- __v = '%s_ScriptWithFunctions'%(__command,)
- __text += "%s_config['Type'] = '%s'\n"%(__command,__k)
- __text += "%s_config['From'] = '%s'\n"%(__command,__f)
- __text += "%s_config['Data'] = %s\n"%(__command,__v)
- __text = __text.replace("''","'")
- elif __k in ('Stored', 'Checked'):
- if bool(__v):
- __text += "%s_config['%s'] = '%s'\n"%(__command,__k,int(bool(__v)))
- elif __k in ('AvoidRC', 'noDetails'):
- if not bool(__v):
- __text += "%s_config['%s'] = '%s'\n"%(__command,__k,int(bool(__v)))
- else:
- if __k == 'Parameters': __k = "Dict"
- if isinstance(__v,Persistence.Persistence): __v = __v.values()
- if callable(__v): __text = self._missing%__v.__name__+__text
- if isinstance(__v,dict):
- for val in __v.values():
- if callable(val): __text = self._missing%val.__name__+__text
- __text += "%s_config['Type'] = '%s'\n"%(__command,__k)
- __text += "%s_config['From'] = '%s'\n"%(__command,'String')
- __text += "%s_config['Data'] = \"\"\"%s\"\"\"\n"%(__command,repr(__v))
- __text += "study_config['%s'] = %s_config"%(__command,__command)
- numpy.set_printoptions(precision=8,threshold=1000,linewidth=75)
- if __switchoff:
- self._switchoff = True
- if __text is not None: self._addLine(__text)
- if not __switchoff:
- self._switchoff = False
- def _finalize(self, *__args):
- self.__loadVariablesByScript()
- self._addLine("#")
- self._addLine("Analysis_config = {}")
- self._addLine("Analysis_config['From'] = 'String'")
- self._addLine("Analysis_config['Data'] = \"\"\"import numpy")
- self._addLine("xa=numpy.ravel(ADD.get('Analysis')[-1])")
- self._addLine("print 'Analysis:',xa\"\"\"")
- self._addLine("study_config['UserPostAnalysis'] = Analysis_config")
- def __loadVariablesByScript(self):
- __ExecVariables = {} # Necessaire pour recuperer la variable
- exec("\n".join(self._lineSerie), __ExecVariables)
- study_config = __ExecVariables['study_config']
- # Pour Python 3 : self.__hasAlgorithm = bool(study_config['Algorithm'])
- if 'Algorithm' in study_config:
- self.__hasAlgorithm = True
- else:
- self.__hasAlgorithm = False
- if not self.__hasAlgorithm and \
- "AlgorithmParameters" in study_config and \
- isinstance(study_config['AlgorithmParameters'], dict) and \
- "From" in study_config['AlgorithmParameters'] and \
- "Data" in study_config['AlgorithmParameters'] and \
- study_config['AlgorithmParameters']['From'] == 'Script':
- __asScript = study_config['AlgorithmParameters']['Data']
- __var = ImportFromScript(__asScript).getvalue( "Algorithm" )
- __text = "#\nstudy_config['Algorithm'] = '%s'"%(__var,)
- self._addLine(__text)
- if self.__hasAlgorithm and \
- "AlgorithmParameters" in study_config and \
- isinstance(study_config['AlgorithmParameters'], dict) and \
- "From" not in study_config['AlgorithmParameters'] and \
- "Data" not in study_config['AlgorithmParameters']:
- __text = "#\n"
- __text += "AlgorithmParameters_config['Type'] = 'Dict'\n"
- __text += "AlgorithmParameters_config['From'] = 'String'\n"
- __text += "AlgorithmParameters_config['Data'] = '{}'\n"
- self._addLine(__text)
- del study_config
-
-class _XMLViewer(GenericCaseViewer):
- """
- Etablissement des commandes d'un cas XML
- """
- def __init__(self, __name="", __objname="case", __content=None, __object=None):
- "Initialisation et enregistrement de l'entete"
- GenericCaseViewer.__init__(self, __name, __objname, __content, __object)
- raise NotImplementedError()
-
-class _YACSViewer(GenericCaseViewer):
- """
- Etablissement des commandes d'un cas YACS (Cas->SCD->YACS)
- """
- def __init__(self, __name="", __objname="case", __content=None, __object=None):
- "Initialisation et enregistrement de l'entete"
- GenericCaseViewer.__init__(self, __name, __objname, __content, __object)
- self.__internalSCD = _SCDViewer(__name, __objname, __content, __object)
- self._append = self.__internalSCD._append
- def dump(self, __filename=None, __convertSCDinMemory=True):
- "Restitution normalisée des commandes"
- self.__internalSCD._finalize()
- # -----
- if __filename is None:
- raise ValueError("A file name has to be given for YACS XML output.")
- # -----
- if not PlatformInfo.has_salome or \
- not PlatformInfo.has_adao:
- raise ImportError("\n\n"+\
- "Unable to get SALOME or ADAO environnement variables.\n"+\
- "Please load the right environnement before trying to use it.\n")
- elif __convertSCDinMemory:
- __file = os.path.abspath(__filename)
- __SCDdump = self.__internalSCD.dump()
- if os.path.isfile(__file) or os.path.islink(__file):
- os.remove(__file)
- from daYacsSchemaCreator.run import create_schema_from_content
- create_schema_from_content(__SCDdump, __file)
- else:
- __file = os.path.abspath(__filename)
- __SCDfile = __file[:__file.rfind(".")] + '_SCD.py'
- __SCDdump = self.__internalSCD.dump(__SCDfile)
- if os.path.isfile(__file) or os.path.islink(__file):
- os.remove(__file)
- __converterExe = os.path.join(os.environ["ADAO_ROOT_DIR"], "bin/salome", "AdaoYacsSchemaCreator.py")
- __args = ["python", __converterExe, __SCDfile, __file]
- import subprocess
- __p = subprocess.Popen(__args)
- (__stdoutdata, __stderrdata) = __p.communicate()
- __p.terminate()
- os.remove(__SCDfile)
- # -----
- if not os.path.exists(__file):
- __msg = "An error occured during the ADAO YACS Schema build for\n"
- __msg += "the target output file:\n"
- __msg += " %s\n"%__file
- __msg += "See errors details in your launching terminal log.\n"
- raise ValueError(__msg)
- # -----
- __fid = open(__file,"r")
- __text = __fid.read()
- __fid.close()
- return __text
-
-# ==============================================================================
-class ImportFromScript(object):
- """
- Obtention d'une variable nommee depuis un fichier script importe
- """
- def __init__(self, __filename=None):
- "Verifie l'existence et importe le script"
- if __filename is None:
- raise ValueError("The name of the file, containing the variable to be read, has to be specified.")
- if not os.path.isfile(__filename):
- raise ValueError("The file containing the variable to be imported doesn't seem to exist. Please check the file. The given file name is:\n \"%s\""%__filename)
- if os.path.dirname(__filename) != '':
- sys.path.insert(0, os.path.dirname(__filename))
- __basename = os.path.basename(__filename).rstrip(".py")
- else:
- __basename = __filename.rstrip(".py")
- self.__basename = __basename
- self.__scriptfile = __import__(__basename, globals(), locals(), [])
- self.__scriptstring = open(__filename,'r').read()
- def getvalue(self, __varname=None, __synonym=None ):
- "Renvoie la variable demandee"
- if __varname is None:
- raise ValueError("The name of the variable to be read has to be specified. Please check the content of the file and the syntax.")
- if not hasattr(self.__scriptfile, __varname):
- if __synonym is None:
- raise ValueError("The imported script file \"%s\" doesn't contain the mandatory variable \"%s\" to be read. Please check the content of the file and the syntax."%(str(self.__basename)+".py",__varname))
- elif not hasattr(self.__scriptfile, __synonym):
- raise ValueError("The imported script file \"%s\" doesn't contain the mandatory variable \"%s\" to be read. Please check the content of the file and the syntax."%(str(self.__basename)+".py",__synonym))
- else:
- return getattr(self.__scriptfile, __synonym)
- else:
- return getattr(self.__scriptfile, __varname)
- def getstring(self):
- "Renvoie le script complet"
- return self.__scriptstring
-
# ==============================================================================
def CostFunction3D(_x,
_Hm = None, # Pour simuler Hm(x) : HO["Direct"].appliedTo
