From: Jean-Philippe ARGAUD Date: Sun, 11 Feb 2018 20:56:25 +0000 (+0100) Subject: Updating case interfaces utilities X-Git-Tag: V8_5_0rc1~14 X-Git-Url: http://git.salome-platform.org/gitweb/?a=commitdiff_plain;h=fd108dc05d4e654b7ab313526be991610d5388b0;p=modules%2Fadao.git Updating case interfaces utilities --- diff --git a/src/daComposant/daCore/BasicObjects.py b/src/daComposant/daCore/BasicObjects.py index 07c17da..41c5f10 100644 --- a/src/daComposant/daCore/BasicObjects.py +++ b/src/daComposant/daCore/BasicObjects.py @@ -35,7 +35,9 @@ import copy 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): @@ -1592,12 +1594,16 @@ class CaseLogger(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, + "DCT":Interfaces._DCTViewer, + "SCD":Interfaces._SCDViewer, + "YACS":Interfaces._YACSViewer, + } + self.__loaders = { + "TUI":Interfaces._TUIViewer, + "EPD":Interfaces._EPDViewer, + "DCT":Interfaces._DCTViewer, } if __addViewers is not None: self.__viewers.update(dict(__addViewers)) @@ -1615,7 +1621,7 @@ class CaseLogger(object): 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: @@ -1630,604 +1636,6 @@ class CaseLogger(object): 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 diff --git a/src/daComposant/daCore/Interfaces.py b/src/daComposant/daCore/Interfaces.py new file mode 100644 index 0000000..71a8c74 --- /dev/null +++ b/src/daComposant/daCore/Interfaces.py @@ -0,0 +1,637 @@ +# -*- coding: utf-8 -*- +# +# Copyright (C) 2008-2018 EDF R&D +# +# This library is free software; you can redistribute it and/or +# modify it under the terms of the GNU Lesser General Public +# License as published by the Free Software Foundation; either +# version 2.1 of the License. +# +# This library is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU +# Lesser General Public License for more details. +# +# You should have received a copy of the GNU Lesser General Public +# License along with this library; if not, write to the Free Software +# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA +# +# See http://www.salome-platform.org/ or email : webmaster.salome@opencascade.com +# +# Author: Jean-Philippe Argaud, jean-philippe.argaud@edf.fr, EDF R&D + +""" + Définit les outils d'interfaces normalisées de cas. +""" +__author__ = "Jean-Philippe ARGAUD" +__all__ = [] + +import os +import sys +import logging +import copy +import numpy +from daCore import Persistence +from daCore import PlatformInfo +from daCore import Templates + +# ============================================================================== +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 + +# ============================================================================== +if __name__ == "__main__": + print('\n AUTODIAGNOSTIC \n')