123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640264126422643264426452646264726482649265026512652265326542655265626572658265926602661266226632664266526662667266826692670267126722673267426752676267726782679268026812682268326842685268626872688268926902691269226932694269526962697269826992700270127022703270427052706270727082709271027112712271327142715271627172718271927202721272227232724272527262727272827292730273127322733273427352736273727382739274027412742274327442745274627472748274927502751275227532754275527562757275827592760276127622763276427652766276727682769277027712772277327742775277627772778277927802781278227832784278527862787278827892790279127922793279427952796279727982799280028012802280328042805280628072808280928102811 |
- """
- Temporal raster algebra base class
- (C) 2013 by the GRASS Development Team
- This program is free software under the GNU General Public
- License (>=v2). Read the file COPYING that comes with GRASS
- for details.
- :authors: Thomas Leppelt and Soeren Gebbert
- .. code-block:: python
- >>> p = TemporalRasterAlgebraLexer()
- >>> p.build()
- >>> p.debug = True
- >>> expression = 'R = A / B * 20 + C - 2.45'
- >>> p.test(expression)
- R = A / B * 20 + C - 2.45
- LexToken(NAME,'R',1,0)
- LexToken(EQUALS,'=',1,2)
- LexToken(NAME,'A',1,4)
- LexToken(DIV,'/',1,6)
- LexToken(NAME,'B',1,8)
- LexToken(MULT,'*',1,10)
- LexToken(INT,20,1,12)
- LexToken(ADD,'+',1,15)
- LexToken(NAME,'C',1,17)
- LexToken(SUB,'-',1,19)
- LexToken(FLOAT,2.45,1,21)
- >>> expression = 'R = A {equal,|/} B'
- >>> p.test(expression)
- R = A {equal,|/} B
- LexToken(NAME,'R',1,0)
- LexToken(EQUALS,'=',1,2)
- LexToken(NAME,'A',1,4)
- LexToken(T_ARITH1_OPERATOR,'{equal,|/}',1,6)
- LexToken(NAME,'B',1,17)
- >>> expression = 'R = A {equal,||} B'
- >>> p.test(expression)
- R = A {equal,||} B
- LexToken(NAME,'R',1,0)
- LexToken(EQUALS,'=',1,2)
- LexToken(NAME,'A',1,4)
- LexToken(T_COMP_OPERATOR,'{equal,||}',1,6)
- LexToken(NAME,'B',1,17)
- >>> expression = 'R = A {equal,&&} B'
- >>> p.test(expression)
- R = A {equal,&&} B
- LexToken(NAME,'R',1,0)
- LexToken(EQUALS,'=',1,2)
- LexToken(NAME,'A',1,4)
- LexToken(T_COMP_OPERATOR,'{equal,&&}',1,6)
- LexToken(NAME,'B',1,17)
- >>> expression = 'R = A {equal | during,+*} B'
- >>> p.test(expression)
- R = A {equal | during,+*} B
- LexToken(NAME,'R',1,0)
- LexToken(EQUALS,'=',1,2)
- LexToken(NAME,'A',1,4)
- LexToken(T_ARITH1_OPERATOR,'{equal | during,+*}',1,6)
- LexToken(NAME,'B',1,26)
- >>> expression = 'R = A {equal | during,+:} B'
- >>> p.test(expression)
- R = A {equal | during,+:} B
- LexToken(NAME,'R',1,0)
- LexToken(EQUALS,'=',1,2)
- LexToken(NAME,'A',1,4)
- LexToken(T_SELECT_OPERATOR,'{equal | during,+:}',1,6)
- LexToken(NAME,'B',1,26)
- >>> expression = 'R = abs(A) {equal,+:} exp(B) / sqrt(C) - log(D)'
- >>> p.test(expression)
- R = abs(A) {equal,+:} exp(B) / sqrt(C) - log(D)
- LexToken(NAME,'R',1,0)
- LexToken(EQUALS,'=',1,2)
- LexToken(ABS,'abs',1,4)
- LexToken(LPAREN,'(',1,7)
- LexToken(NAME,'A',1,8)
- LexToken(RPAREN,')',1,9)
- LexToken(T_SELECT_OPERATOR,'{equal,+:}',1,11)
- LexToken(EXP,'exp',1,22)
- LexToken(LPAREN,'(',1,25)
- LexToken(NAME,'B',1,26)
- LexToken(RPAREN,')',1,27)
- LexToken(DIV,'/',1,29)
- LexToken(SQRT,'sqrt',1,31)
- LexToken(LPAREN,'(',1,35)
- LexToken(NAME,'C',1,36)
- LexToken(RPAREN,')',1,37)
- LexToken(SUB,'-',1,39)
- LexToken(LOG,'log',1,41)
- LexToken(LPAREN,'(',1,44)
- LexToken(NAME,'D',1,45)
- LexToken(RPAREN,')',1,46)
- """
- import grass.pygrass.modules as pymod
- from temporal_raster_operator import *
- from temporal_algebra import *
- ##############################################################################
- class TemporalRasterAlgebraLexer(TemporalAlgebraLexer):
- """Lexical analyzer for the GRASS GIS temporal algebra"""
- def __init__(self):
- TemporalAlgebraLexer.__init__(self)
- # Supported r.mapcalc functions.
- mapcalc_functions = {
- 'exp': 'EXP',
- 'log': 'LOG',
- 'sqrt': 'SQRT',
- 'abs': 'ABS',
- 'cos': 'COS',
- 'acos': 'ACOS',
- 'sin': 'SIN',
- 'asin': 'ASIN',
- 'tan': 'TAN',
- 'double': 'DOUBLE',
- 'float': 'FLOATEXP',
- 'int': 'INTEXP',
- 'isnull': 'ISNULL',
- 'isntnull': 'ISNTNULL',
- 'null': 'NULL',
- 'exist': 'EXIST',
- }
- # This is the list of token names.
- raster_tokens = (
- 'MOD',
- 'DIV',
- 'MULT',
- 'ADD',
- 'SUB',
- 'T_ARITH1_OPERATOR',
- 'T_ARITH2_OPERATOR',
- 'L_SPAREN',
- 'R_SPAREN',
- )
- # Build the token list
- tokens = TemporalAlgebraLexer.tokens + raster_tokens \
- + tuple(mapcalc_functions.values())
- # Regular expression rules for simple tokens
- t_MOD = r'[\%]'
- t_DIV = r'[\/]'
- t_MULT = r'[\*]'
- t_ADD = r'[\+]'
- t_SUB = r'[-]'
- t_T_ARITH1_OPERATOR = r'\{([a-zA-Z\| ]+[,])?([\|&+=]?[\%\*\/])\}'
- t_T_ARITH2_OPERATOR = r'\{([a-zA-Z\| ]+[,])?([\|&+=]?[+-])\}'
- t_L_SPAREN = r'\['
- t_R_SPAREN = r'\]'
- # Parse symbols
- def temporal_symbol(self, t):
- # Check for reserved words
- if t.value in TemporalRasterAlgebraLexer.time_functions.keys():
- t.type = TemporalRasterAlgebraLexer.time_functions.get(t.value)
- elif t.value in TemporalRasterAlgebraLexer.datetime_functions.keys():
- t.type = TemporalRasterAlgebraLexer.datetime_functions.get(t.value)
- elif t.value in TemporalRasterAlgebraLexer.conditional_functions.keys():
- t.type = TemporalRasterAlgebraLexer.conditional_functions.get(t.value)
- elif t.value in TemporalRasterAlgebraLexer.mapcalc_functions.keys():
- t.type = TemporalRasterAlgebraLexer.mapcalc_functions.get(t.value)
- else:
- t.type = 'NAME'
- return t
- #########
- #####################################################################
- class TemporalRasterBaseAlgebraParser(TemporalAlgebraParser):
- """The temporal algebra class"""
- # Get the tokens from the lexer class
- tokens = TemporalRasterAlgebraLexer.tokens
- # Setting equal precedence level for select and hash operations.
- precedence = (
- ('left', 'T_SELECT_OPERATOR', 'T_SELECT', 'T_NOT_SELECT'), # 1
- ('left', 'ADD', 'SUB', 'T_ARITH2_OPERATOR'), #2
- ('left', 'AND', 'OR', 'T_COMP_OPERATOR', 'MOD', 'DIV', 'MULT',
- 'T_ARITH1_OPERATOR'))
- def __init__(self, pid=None, run=True, debug=False, spatial=False,
- nprocs=1, register_null=False):
- TemporalAlgebraParser.__init__(self, pid, run, debug, spatial)
- self.nprocs = nprocs
- self.empty_maps = {}
- self.register_null = register_null
- def check_null(self, t):
- try:
- int(t)
- return t
- except ValueError:
- return "null()"
- ######################### Temporal functions ##############################
- def eval_toperator(self, operator, comparison=False):
- """This function evaluates a string containing temporal operations.
- :param operator: String of temporal operations, e.g. {equal|during,=!:}.
- :return: List of temporal relations (equal, during), the given
- function (!:) and the interval/instances (=).
- .. code-block:: python
- >>> init(True)
- >>> p = TemporalRasterBaseAlgebraParser()
- >>> operator = "{equal,:}"
- >>> p.eval_toperator(operator)
- (['EQUAL'], '=', ':')
- >>> operator = "{equal|during,:}"
- >>> p.eval_toperator(operator)
- (['EQUAL', 'DURING'], '=', ':')
- >>> operator = "{equal,!:}"
- >>> p.eval_toperator(operator)
- (['EQUAL'], '=', '!:')
- >>> operator = "{equal|during,!:}"
- >>> p.eval_toperator(operator)
- (['EQUAL', 'DURING'], '=', '!:')
- >>> operator = "{equal|during,=!:}"
- >>> p.eval_toperator(operator)
- (['EQUAL', 'DURING'], '=', '!:')
- >>> operator = "{equal|during|starts,#}"
- >>> p.eval_toperator(operator)
- (['EQUAL', 'DURING', 'STARTS'], '=', '#')
- >>> operator = "{!:}"
- >>> p.eval_toperator(operator)
- (['EQUAL'], '=', '!:')
- >>> operator = "{=:}"
- >>> p.eval_toperator(operator)
- (['EQUAL'], '=', ':')
- >>> operator = "{#}"
- >>> p.eval_toperator(operator)
- (['EQUAL'], '=', '#')
- >>> operator = "{equal|during}"
- >>> p.eval_toperator(operator)
- (['EQUAL', 'DURING'], None, None)
- >>> operator = "{equal}"
- >>> p.eval_toperator(operator)
- (['EQUAL'], None, None)
- >>> operator = "{equal,||}"
- >>> p.eval_toperator(operator, True)
- (['EQUAL'], '=', '||')
- >>> operator = "{equal|during,&&}"
- >>> p.eval_toperator(operator, True)
- (['EQUAL', 'DURING'], '=', '&&')
- """
- p = TemporalRasterOperatorParser()
- p.parse(operator, comparison)
- p.relations = [rel.upper() for rel in p.relations]
- return(p.relations, p.temporal, p.function)
- ###########################################################################
- def p_statement_assign(self, t):
- # The expression should always return a list of maps.
- """
- statement : stds EQUALS expr
- """
- if self.run:
- # Create the process queue for parallel mapcalc processing
- process_queue = pymod.ParallelModuleQueue(int(self.nprocs))
- if isinstance(t[3], list):
- num = len(t[3])
- count = 0
- register_list = []
- for i in range(num):
- # Check if resultmap names exist in GRASS database.
- rastername = self.basename + "_" + str(i) + "@" + self.mapset
- rastermap = RasterDataset(rastername)
- if rastermap.map_exists() and self.overwrite is False:
- self.msgr.fatal("Error raster maps with basename %s "
- "exist. Use --o flag to overwrite "
- "existing file" % (rastername))
- map_test_list = []
- for map_i in t[3]:
- newident = self.basename + "_" + str(count)
- if "cmd_list" in dir(map_i):
- print(newident + ' = ' + map_i.cmd_list)
- # Build r.mapcalc module and execute expression.
- # Change map name to given basename.
- # Create deepcopy of r.mapcalc module.
- map_test = map_i.get_new_instance(newident + "@" + self.mapset)
- map_test.set_temporal_extent(map_i.get_temporal_extent())
- map_test.set_spatial_extent(map_i.get_spatial_extent())
- map_test_list.append(map_test)
- m = copy.deepcopy(self.m_mapcalc)
- m_expression = newident + "=" + map_i.cmd_list
- m.inputs["expression"].value = str(m_expression)
- m.flags["overwrite"].value = self.overwrite
- process_queue.put(m)
- else:
- map_i.set_id(newident + "@" + self.mapset)
- map_test_list.append(map_i)
- count += 1
- process_queue.wait()
- for map_i in map_test_list:
- if not map_test.map_exists():
- self.msgr.error(_("Error computing map <%s>" %
- (map_i.get_id())))
- else:
- register_list.append(map_i)
- # Open connection to temporal database.
- dbif, connect = init_dbif(self.dbif)
- # Create result space time dataset.
- resultstds = open_new_stds(t[1], self.stdstype, 'absolute',
- t[1], t[1], 'mean', self.dbif,
- overwrite=self.overwrite)
- for map_i in register_list:
- # Get meta data from grass database.
- map_i.load()
- # Do not register empty maps if not required
- # In case of a null map continue, do not register null maps
- if map_i.metadata.get_min() is None and \
- map_i.metadata.get_max() is None:
- if not self.register_null:
- self.empty_maps[map_i.get_name()] = map_i.get_name()
- continue
- if map_i.is_in_db(dbif) and self.overwrite:
- # Update map in temporal database.
- map_i.update_all(dbif)
- elif map_i.is_in_db(dbif) and self.overwrite is False:
- # Raise error if map exists and no overwrite flag is given.
- self.msgr.fatal("Error vector map %s exist in temporal"
- " database. Use overwrite flag. : "
- "\n%s" % (map_i.get_map_id(),
- cmd.popen.stderr))
- else:
- # Insert map into temporal database.
- map_i.insert(dbif)
- # Register map in result space time dataset.
- success = resultstds.register_map(map_i, dbif)
- resultstds.update_from_registered_maps(dbif)
- dbif.close()
- t[0] = register_list
- self.remove_empty_maps()
- def p_arith1_operation(self, t):
- """
- expr : stds MOD stds
- | expr MOD stds
- | stds MOD expr
- | expr MOD expr
- | stds DIV stds
- | expr DIV stds
- | stds DIV expr
- | expr DIV expr
- | stds MULT stds
- | expr MULT stds
- | stds MULT expr
- | expr MULT expr
- | stds MOD t_td_var
- | expr MOD t_td_var
- | stds DIV t_td_var
- | expr DIV t_td_var
- | stds MULT t_td_var
- | expr MULT t_td_var
- """
- # Check input stds.
- maplistA = self.check_stds(t[1])
- maplistB = self.check_stds(t[3])
- topolist = self.get_temporal_topo_list(maplistA, maplistB)
- if self.run:
- resultlist = []
- for map_i in topolist:
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i, bool_op='and',
- copy=True)
- # Set first input for overlay module.
- mapainput = map_i.get_id()
- # Loop over temporal related maps and create overlay modules.
- tbrelations = map_i.get_temporal_relations()
- count = 0
- for map_j in (tbrelations['EQUAL']):
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_j, 'and',
- temp_op='=')
- # Stop the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- break
- if count == 0:
- # Set map name.
- name = map_new.get_id()
- else:
- # Generate an intermediate map
- name = self.generate_map_name()
- if "map_value" in dir(map_j) and len(map_j.map_value) > 0 and map_j.map_value[0].get_type() == "timediff":
- mapbinput = map_j.map_value[0].get_type_value()[0]
- else:
- # Set first input for overlay module.
- mapbinput = map_j.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "(%s %s %s)" % (map_new.cmd_list, t[2],
- mapbinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "(%s %s %s)" % (mapainput, t[2],
- map_j.cmd_list)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "(%s %s %s)" % (map_new.cmd_list, t[2],
- map_j.cmd_list)
- else:
- cmdstring = "(%s %s %s)" % (mapainput, t[2], mapbinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Set new map name to temporary map name.
- mapainput = name
- count += 1
- # Append map to result map list.
- if returncode == 1:
- resultlist.append(map_new)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_arith1_operation_numeric1(self, t):
- """
- expr : stds MOD number
- | expr MOD number
- | stds DIV number
- | expr DIV number
- | stds MULT number
- | expr MULT number
- """
- # Check input stds.
- maplist = self.check_stds(t[1])
- if self.run:
- resultlist = []
- for map_i in maplist:
- mapinput = map_i.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_i):
- cmdstring = "(%s %s %s)" % (map_i.cmd_list, t[2], t[3])
- else:
- cmdstring = "(%s %s %s)" % (mapinput, t[2], t[3])
- # Conditional append of module command.
- map_i.cmd_list = cmdstring
- # Append map to result map list.
- resultlist.append(map_i)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_arith1_operation_numeric2(self, t):
- """
- expr : number MOD stds
- | number MOD expr
- | number DIV stds
- | number DIV expr
- | number MULT stds
- | number MULT expr
- """
- # Check input stds.
- maplist = self.check_stds(t[3])
- if self.run:
- resultlist = []
- for map_i in maplist:
- mapinput = map_i.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_i):
- cmdstring = "(%s %s %s)" % (t[1], t[2], map_i.cmd_list)
- else:
- cmdstring = "(%s %s %s)" % (t[1], t[2], mapinput)
- # Conditional append of module command.
- map_i.cmd_list = cmdstring
- # Append map to result map list.
- resultlist.append(map_i)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_arith2_operation(self, t):
- """
- expr : stds ADD stds
- | expr ADD stds
- | stds ADD expr
- | expr ADD expr
- | stds SUB stds
- | expr SUB stds
- | stds SUB expr
- | expr SUB expr
- | stds ADD t_td_var
- | expr ADD t_td_var
- | expr SUB t_td_var
- | stds SUB t_td_var
- """
- # Check input stds.
- maplistA = self.check_stds(t[1])
- maplistB = self.check_stds(t[3])
- topolist = self.get_temporal_topo_list(maplistA, maplistB)
- if self.run:
- resultlist = []
- for map_i in topolist:
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i, bool_op='and',
- copy=True)
- # Set first input for overlay module.
- mapainput = map_i.get_id()
- # Loop over temporal related maps and create overlay modules.
- tbrelations = map_i.get_temporal_relations()
- count = 0
- for map_j in (tbrelations['EQUAL']):
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_j, 'and',
- temp_op='=')
- # Stop the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- break
- if count == 0:
- # Set map name.
- name = map_new.get_id()
- else:
- # Generate an intermediate map
- name = self.generate_map_name()
- if "map_value" in dir(map_j) and len(map_j.map_value) > 0 and map_j.map_value[0].get_type() == "timediff":
- mapbinput = map_j.map_value[0].get_type_value()[0]
- else:
- # Set first input for overlay module.
- mapbinput = map_j.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "(%s %s %s)" % (map_new.cmd_list, t[2],
- mapbinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "(%s %s %s)" % (mapainput, t[2],
- map_j.cmd_list)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "(%s %s %s)" % (map_new.cmd_list, t[2],
- map_j.cmd_list)
- else:
- cmdstring = "(%s %s %s)" % (mapainput, t[2], mapbinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Set new map name to temporary map name.
- mapainput = name
- count += 1
- # Append map to result map list.
- if returncode == 1:
- resultlist.append(map_new)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_arith2_operation_numeric1(self, t):
- """
- expr : stds ADD number
- | expr ADD number
- | stds SUB number
- | expr SUB number
- """
- # Check input stds.
- maplist = self.check_stds(t[1])
- if self.run:
- resultlist = []
- for map_i in maplist:
- mapinput = map_i.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_i):
- cmdstring = "(%s %s %s)" % (map_i.cmd_list, t[2], t[3])
- else:
- cmdstring = "(%s %s %s)" % (mapinput, t[2], t[3])
- # Conditional append of module command.
- map_i.cmd_list = cmdstring
- # Append map to result map list.
- resultlist.append(map_i)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_arith2_operation_numeric2(self, t):
- """
- expr : number ADD stds
- | number ADD expr
- | number SUB stds
- | number SUB expr
- """
- # Check input stds.
- maplist = self.check_stds(t[3])
- if self.run:
- resultlist = []
- for map_i in maplist:
- mapinput = map_i.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_i):
- cmdstring = "(%s %s %s)" % (t[1], t[2], map_i.cmd_list)
- else:
- cmdstring = "(%s %s %s)" % (t[1], t[2], mapinput)
- # Conditional append of module command.
- map_i.cmd_list = cmdstring
- # Append map to result map list.
- resultlist.append(map_i)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_arith1_operation_relation(self, t):
- """
- expr : stds T_ARITH1_OPERATOR stds
- | expr T_ARITH1_OPERATOR stds
- | stds T_ARITH1_OPERATOR expr
- | expr T_ARITH1_OPERATOR expr
- | stds T_ARITH1_OPERATOR t_td_var
- | expr T_ARITH1_OPERATOR t_td_var
- """
- # Check input stds.
- maplistA = self.check_stds(t[1])
- maplistB = self.check_stds(t[3])
- relations, temporal, function = self.eval_toperator(t[2])
- topolist = self.get_temporal_topo_list(maplistA, maplistB,
- topolist=relations)
- if self.run:
- resultlist = []
- for map_i in topolist:
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i, bool_op='and',
- copy=True)
- # Set first input for overlay module.
- mapainput = map_i.get_id()
- # Loop over temporal related maps and create overlay modules.
- tbrelations = map_i.get_temporal_relations()
- count = 0
- for topo in relations:
- if topo in tbrelations.keys():
- for map_j in (tbrelations[topo]):
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new,
- map_j, 'and',
- temp_op=temporal)
- print(returncode)
- # Stop the loop if no temporal or spatial
- # relationship exist.
- if returncode == 0:
- break
- if count == 0:
- # Set map name.
- name = map_new.get_id()
- else:
- # Generate an intermediate map
- name = self.generate_map_name()
- map_new.set_id(name + "@" + mapset)
- # Set second input for overlay module.
- if "map_value" in dir(map_j) and len(map_j.map_value) > 0 and map_j.map_value[0].get_type() == "timediff":
- mapbinput = map_j.map_value[0].get_type_value()[0]
- else:
- # Set first input for overlay module.
- mapbinput = map_j.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_new):
- cmdstring = "(%s %s %s)" % (map_new.cmd_list,
- function,
- mapbinput)
- print('with cmd in a: ' + map_j.get_id())
- elif "cmd_list" in dir(map_j):
- cmdstring = "(%s %s %s)" % (mapainput,
- function,
- map_j.cmd_list)
- print('with cmd in b')
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "(%s %s %s)" % (map_new.cmd_list,
- function,
- map_j.cmd_list)
- print('with cmd in b')
- else:
- cmdstring = "(%s %s %s)" % (mapainput,
- function,
- mapbinput)
- print(cmdstring)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Set new map name to temporary map name.
- mapainput = name
- count += 1
- if returncode == 0:
- break
- # Append map to result map list.
- if returncode == 1:
- resultlist.append(map_new)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_arith2_operation_relation(self, t):
- """
- expr : stds T_ARITH2_OPERATOR stds
- | expr T_ARITH2_OPERATOR stds
- | stds T_ARITH2_OPERATOR expr
- | expr T_ARITH2_OPERATOR expr
- | stds T_ARITH2_OPERATOR t_td_var
- | expr T_ARITH2_OPERATOR t_td_var
- """
- # Check input stds.
- maplistA = self.check_stds(t[1])
- maplistB = self.check_stds(t[3])
- relations, temporal, function = self.eval_toperator(t[2])
- topolist = self.get_temporal_topo_list(maplistA, maplistB,
- topolist=relations)
- if self.run:
- resultlist = []
- for map_i in topolist:
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i, bool_op='and',
- copy=True)
- # Set first input for overlay module.
- mapainput = map_i.get_id()
- # Loop over temporal related maps and create overlay modules.
- tbrelations = map_i.get_temporal_relations()
- count = 0
- for topo in relations:
- if topo in tbrelations.keys():
- for map_j in (tbrelations[topo]):
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new,
- map_j, 'and',
- temp_op=temporal)
- # Stop the loop if no temporal or spatial
- # relationship exist.
- if returncode == 0:
- break
- if count == 0:
- # Set map name.
- name = map_new.get_id()
- else:
- # Generate an intermediate map
- name = self.generate_map_name()
- map_new.set_id(name + "@" + self.mapset)
- # Set second input for overlay module.
- if "map_value" in dir(map_j) and len(map_j.map_value) > 0 and map_j.map_value[0].get_type() == "timediff":
- mapbinput = map_j.map_value[0].get_type_value()[0]
- else:
- # Set first input for overlay module.
- mapbinput = map_j.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "(%s %s %s)" % (map_new.cmd_list,
- function,
- mapbinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "(%s %s %s)" % (mapainput,
- function,
- map_j.cmd_list)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "(%s %s %s)" % (map_new.cmd_list,
- function,
- map_j.cmd_list)
- else:
- cmdstring = "(%s %s %s)" % (mapainput,
- function,
- mapbinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Set new map name to temporary map name.
- mapainput = name
- count += 1
- if returncode == 0:
- break
- # Append map to result map list.
- if returncode == 1:
- resultlist.append(map_new)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_mapcalc_function(self, t):
- # Supported mapcalc functions.
- """
- mapcalc_arith : ABS
- | LOG
- | SQRT
- | EXP
- | COS
- | ACOS
- | SIN
- | ASIN
- | TAN
- | DOUBLE
- | FLOATEXP
- | INTEXP
- """
- t[0] = t[1]
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_mapcalc_operation(self, t):
- # Examples:
- # sin(A)
- # log(B)
- """
- expr : mapcalc_arith LPAREN stds RPAREN
- | mapcalc_arith LPAREN expr RPAREN
- """
- # Check input stds.
- maplist = self.check_stds(t[3])
- if self.run:
- resultlist = []
- for map_i in maplist:
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_i):
- cmdstring = "%s(%s)" % (t[1].lower(), map_i.cmd_list)
- else:
- cmdstring = "%s(%s)" % (t[1].lower(), map_i.get_id())
- # Set new command list for map.
- map_i.cmd_list = cmdstring
- # Append map with updated command list to result list.
- resultlist.append(map_i)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_s_var_expr(self, t):
- # Examples:
- # isnull(A)
- """
- s_var_expr : ISNULL LPAREN stds RPAREN
- | ISNULL LPAREN expr RPAREN
- """
- # Check input stds.
- maplist = self.check_stds(t[3])
- if self.run:
- resultlist = []
- for map_i in maplist:
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_i):
- cmdstring = "%s(%s)" % (t[1].lower(), map_i.cmd_list)
- else:
- cmdstring = "%s(%s)" % (t[1].lower(), map_i.get_id())
- # Set new command list for map.
- map_i.cmd_list = cmdstring
- # Append map with updated command list to result list.
- resultlist.append(map_i)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_s_var_expr_1(self, t):
- # Examples:
- # isntnull(A)
- """
- s_var_expr : ISNTNULL LPAREN stds RPAREN
- | ISNTNULL LPAREN expr RPAREN
- """
- # Check input stds.
- maplist = self.check_stds(t[3])
- if self.run:
- resultlist = []
- for map_i in maplist:
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_i):
- cmdstring = "!isnull(%s)" % (map_i.cmd_list)
- else:
- cmdstring = "!isnull(%s)" % (map_i.get_id())
- # Set new command list for map.
- map_i.cmd_list = cmdstring
- # Append map with updated command list to result list.
- resultlist.append(map_i)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_s_var_expr2(self, t):
- # Examples:
- # A <= 2
- """
- s_var_expr : stds comp_op number
- | expr comp_op number
- """
- # Check input stds.
- maplist = self.check_stds(t[1])
- if self.run:
- resultlist = []
- for map_i in maplist:
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_i):
- cmdstring = "%s %s %s" % (map_i.cmd_list, t[2], t[3])
- else:
- cmdstring = "%s %s %s" % (map_i.get_id(), t[2], t[3])
- # Set new command list for map.
- map_i.cmd_list = cmdstring
- # Append map with updated command list to result list.
- resultlist.append(map_i)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_s_var_expr3(self, t):
- # Examples:
- # A <= 2 || B == 10
- # A < 3 && A > 1
- """
- s_var_expr : s_var_expr AND AND s_var_expr
- | s_var_expr OR OR s_var_expr
- """
- # Check input stds.
- maplistA = self.check_stds(t[1])
- maplistB = self.check_stds(t[4])
- topolist = self.get_temporal_topo_list(maplistA, maplistB)
- if self.run:
- resultlist = []
- for map_i in topolist:
- # Loop over temporal related maps and create overlay modules.
- tbrelations = map_i.get_temporal_relations()
- count = 0
- for map_j in (tbrelations['EQUAL']):
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i,
- bool_op='and', copy=True)
- # Set first input for overlay module.
- mapainput = map_i.get_id()
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_j, 'and',
- temp_op='=')
- # Stop the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- break
- if count == 0:
- # Set map name.
- name = map_new.get_id()
- else:
- # Generate an intermediate map
- name = self.generate_map_name()
- # Set first input for overlay module.
- mapbinput = map_j.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "%s %s %s" % (map_new.cmd_list,
- t[2] + t[3], mapbinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "%s %s %s" % (mapainput, t[2] + t[3],
- map_j.cmd_list)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "%s %s %s" % (map_new.cmd_list,
- t[2] + t[3], map_j.cmd_list)
- else:
- cmdstring = "%s %s %s" % (mapainput, t[2] + t[3],
- mapbinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Set new map name to temporary map name.
- #mapainput = name
- count += 1
- # Append map to result map list.
- if returncode == 1:
- resultlist.append(map_new)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_s_var_expr4(self, t):
- # Examples:
- # exist(B)
- """
- s_var_expr : EXIST LPAREN stds RPAREN
- | EXIST LPAREN expr RPAREN
- """
- # Check input stds.
- maplist = self.check_stds(t[3])
- if self.run:
- resultlist = []
- for map_i in maplist:
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_i):
- cmdstring = "%s" % (map_i.cmd_list)
- else:
- cmdstring = "%s" % (map_i.get_id())
- # Set new command list for map.
- map_i.cmd_list = cmdstring
- # Append map with updated command list to result list.
- resultlist.append(map_i)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_s_expr_condition_if(self, t):
- # Examples:
- # if(s_var_expr, B)
- # if(A == 1, B)
- """
- expr : IF LPAREN s_var_expr COMMA stds RPAREN
- | IF LPAREN s_var_expr COMMA expr RPAREN
- """
- ifmaplist = self.check_stds(t[3])
- thenmaplist = self.check_stds(t[5])
- topolist = self.get_temporal_topo_list(ifmaplist, thenmaplist)
- resultlist = []
- for map_i in topolist:
- #print(map_i.get_id())
- # Loop over temporal related maps and create overlay modules.
- tbrelations = map_i.get_temporal_relations()
- count = 0
- for map_j in (tbrelations['EQUAL']):
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i, bool_op='and',
- copy=True)
- # Set first input for overlay module.
- mapainput = map_i.get_id()
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_j, 'and',
- temp_op='=')
- # Stop the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- break
- if count == 0:
- # Set map name.
- name = map_new.get_id()
- else:
- # Generate an intermediate map
- name = self.generate_map_name()
- # Set first input for overlay module.
- mapbinput = map_j.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "if(%s,%s)" % (map_new.cmd_list, mapbinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "if(%s,%s)" % (mapainput, map_j.cmd_list)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "if(%s,%s)" % (map_new.cmd_list,
- map_j.cmd_list)
- else:
- cmdstring = "if(%s,%s)" % (mapainput, mapbinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Set new map name to temporary map name.
- #mapainput = name
- count += 1
- # Append map to result map list.
- if returncode == 1:
- resultlist.append(map_new)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_s_numeric_condition_if(self, t):
- # Examples:
- # if(s_var_expr, 1)
- # if(A == 5, 10)
- """
- expr : IF LPAREN s_var_expr COMMA number RPAREN
- | IF LPAREN s_var_expr COMMA NULL LPAREN RPAREN RPAREN
- """
- ifmaplist = self.check_stds(t[3])
- resultlist = []
- # Select input for r.mapcalc expression based on length of PLY object.
- if len(t) == 7:
- numinput = t[5]
- elif len(t) == 9:
- numinput = self.check_null(t[5])
- # Iterate over condition map list.
- for map_i in ifmaplist:
- mapinput = map_i.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_i):
- cmdstring = "if(%s,%s)" % (map_i.cmd_list, numinput)
- else:
- cmdstring = "if(%s,%s)" % (mapinput, numinput)
- # Conditional append of module command.
- map_i.cmd_list = cmdstring
- # Append map to result map list.
- resultlist.append(map_i)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_s_expr_condition_if_relation(self, t):
- # Examples:
- # if({equal||during}, s_var_expr, A)
- """
- expr : IF LPAREN T_REL_OPERATOR COMMA s_var_expr COMMA stds RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA s_var_expr COMMA expr RPAREN
- """
- relations, temporal, function = self.eval_toperator(t[3])
- ifmaplist = self.check_stds(t[5])
- thenmaplist = self.check_stds(t[7])
- topolist = self.get_temporal_topo_list(ifmaplist, thenmaplist,
- topolist=relations)
- resultlist = []
- for map_i in topolist:
- #print(map_i.get_id())
- # Loop over temporal related maps.
- tbrelations = map_i.get_temporal_relations()
- count = 0
- for topo in relations:
- if topo in tbrelations.keys():
- for map_j in (tbrelations[topo]):
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i,
- bool_op='and',
- copy=True)
- # Set first input for overlay module.
- mapainput = map_i.get_id()
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_j,
- 'and',
- temp_op='=')
- # Stop the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- break
- if count == 0:
- # Set map name.
- name = map_new.get_id()
- else:
- # Generate an intermediate map
- name = self.generate_map_name()
- # Set first input for overlay module.
- mapbinput = map_j.get_id()
- #print(mapbinput)
- #mapbinput = mapbinput.split('@')[0]
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "if(%s,%s)" % (map_new.cmd_list,
- mapbinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "if(%s,%s)" % (mapainput,
- map_j.cmd_list)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "if(%s,%s)" % (map_new.cmd_list,
- map_j.cmd_list)
- else:
- cmdstring = "if(%s,%s)" % (mapainput, mapbinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Set new map name to temporary map name.
- #mapainput = name
- count += 1
- # Append map to result map list.
- if returncode == 1:
- resultlist.append(map_new)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_s_expr_condition_elif(self, t):
- # Examples:
- # if(s_var_expr, A, B)
- """
- expr : IF LPAREN s_var_expr COMMA stds COMMA stds RPAREN
- | IF LPAREN s_var_expr COMMA stds COMMA expr RPAREN
- | IF LPAREN s_var_expr COMMA expr COMMA stds RPAREN
- | IF LPAREN s_var_expr COMMA expr COMMA expr RPAREN
- """
- ifmaplist = self.check_stds(t[3])
- thenmaplist = self.check_stds(t[5])
- elsemaplist = self.check_stds(t[7])
- resultlist = []
- thendict = {}
- elsedict = {}
- # Get topologies for the appropriate conclusion term.
- thentopolist = self.get_temporal_topo_list(ifmaplist, thenmaplist)
- # Fill dictionaries with related maps for both conclusion terms.
- for map_i in thentopolist:
- thenrelations = map_i.get_temporal_relations()
- relationmaps = thenrelations['EQUAL']
- thendict[map_i.get_id()] = relationmaps
- # Get topologies for the alternative conclusion term.
- elsetopolist = self.get_temporal_topo_list(ifmaplist, elsemaplist)
- for map_i in elsetopolist:
- elserelations = map_i.get_temporal_relations()
- relationmaps = elserelations['EQUAL']
- elsedict[map_i.get_id()] = relationmaps
- # Loop through conditional map list.
- for map_i in ifmaplist:
- if map_i.get_id() in thendict.keys():
- thenlist = thendict[map_i.get_id()]
- else:
- thenlist = []
- if map_i.get_id() in elsedict.keys():
- elselist = elsedict[map_i.get_id()]
- else:
- elselist = []
- # Set iteration amount to maximal or minimum number of related
- # conclusion maps, depending on null map creation flag.
- if self.null:
- iternum = max(len(thenlist), len(elselist))
- else:
- iternum = min(len(thenlist), len(elselist))
- # Calculate difference in conclusion lengths.
- iterthen = iternum - len(thenlist)
- iterelse = iternum - len(elselist)
- # Extend null maps to the list to get conclusions with same length.
- if iterthen != 0:
- for i in range(iterthen):
- thenlist.extend(['null()'])
- if iterelse != 0:
- for i in range(iterelse):
- elselist.extend(['null()'])
- # Combine the conclusions in a paired list.
- conclusionlist = zip(thenlist, elselist)
- for i in range(iternum):
- conclusionmaps = conclusionlist[i]
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i, bool_op='and',
- copy=True)
- # Set first input for overlay module.
- mapifinput = map_i.get_id()
- # Get conclusion maps.
- map_then = conclusionmaps[0]
- map_else = conclusionmaps[1]
- # Check if conclusions are map objects.
- if map_then != 'null()':
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_then,
- 'and', temp_op='=')
- maptheninput = map_then.get_id()
- # Continue the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- continue
- else:
- maptheninput = 'null()'
- # Check if conclusions are map objects.
- if map_else != 'null()':
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_else,
- 'and', temp_op='=')
- mapelseinput = map_else.get_id()
- # Continue the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- continue
- else:
- mapelseinput = 'null()'
- #if map_then != 'null()' and map_else != 'null()':
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_then) \
- and "cmd_list" not in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (map_new.cmd_list,
- maptheninput,
- mapelseinput)
- elif "cmd_list" in dir(map_new) and "cmd_list" in dir(map_then) \
- and "cmd_list" not in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (map_new.cmd_list,
- map_then.cmd_list,
- mapelseinput)
- elif "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_then) \
- and "cmd_list" in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (map_new.cmd_list,
- maptheninput,
- map_else.cmd_list)
- elif "cmd_list" in dir(map_new) and "cmd_list" in dir(map_then) \
- and "cmd_list" in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (map_new.cmd_list,
- map_then.cmd_list,
- map_else.cmd_list)
- elif "cmd_list" not in dir(map_new) and "cmd_list" in dir(map_then) \
- and "cmd_list" not in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (mapifinput,
- map_then.cmd_list,
- mapelseinput)
- elif "cmd_list" not in dir(map_new) and "cmd_list" not in dir(map_then) \
- and "cmd_list" in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (mapifinput,
- maptheninput,
- map_else.cmd_list)
- elif "cmd_list" not in dir(map_new) and "cmd_list" in dir(map_then) \
- and "cmd_list" in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (mapifinput,
- map_then.cmd_list,
- map_else.cmd_list)
- else:
- cmdstring = "if(%s, %s, %s)" % (mapifinput,
- maptheninput,
- mapelseinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Append map to result map list.
- if returncode == 1:
- resultlist.append(map_new)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_s_numeric_condition_elif(self, t):
- # Examples:
- # if(s_var_expr, 1, 2)
- # if(A == 5, 10, 0)
- """
- expr : IF LPAREN s_var_expr COMMA number COMMA number RPAREN
- | IF LPAREN s_var_expr COMMA NULL LPAREN RPAREN COMMA number RPAREN
- | IF LPAREN s_var_expr COMMA number COMMA NULL LPAREN RPAREN RPAREN
- | IF LPAREN s_var_expr COMMA NULL LPAREN RPAREN COMMA NULL LPAREN RPAREN RPAREN
- """
- ifmaplist = self.check_stds(t[3])
- resultlist = []
- # Select input for r.mapcalc expression based on length of PLY object.
- if len(t) == 9:
- numthen = t[5]
- numelse = t[7]
- elif len(t) == 11 and t[6] == '(':
- numthen = t[5] + t[6] + t[7]
- numelse = t[9]
- elif len(t) == 11 and t[6] == ',':
- numthen = t[5]
- numelse = t[7] + t[8] + t[9]
- elif len(t) == 13:
- numthen = t[5] + t[6] + t[7]
- numelse = t[9] + t[10] + t[11]
- # Iterate over condition map list.
- for map_i in ifmaplist:
- mapinput = map_i.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_i):
- cmdstring = "if(%s, %s, %s)" % (map_i.cmd_list, numthen,
- numelse)
- else:
- cmdstring = "if(%s, %s, %s)" % (mapinput, numthen, numelse)
- # Conditional append of module command.
- map_i.cmd_list = cmdstring
- # Append map to result map list.
- resultlist.append(map_i)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_s_numeric_expr_condition_elif(self, t):
- # Examples:
- # if(s_var_expr, 1, A)
- # if(A == 5 && C > 5, A, null())
- """
- expr : IF LPAREN s_var_expr COMMA number COMMA stds RPAREN
- | IF LPAREN s_var_expr COMMA NULL LPAREN RPAREN COMMA stds RPAREN
- | IF LPAREN s_var_expr COMMA number COMMA expr RPAREN
- | IF LPAREN s_var_expr COMMA NULL LPAREN RPAREN COMMA expr RPAREN
- | IF LPAREN s_var_expr COMMA stds COMMA number RPAREN
- | IF LPAREN s_var_expr COMMA stds COMMA NULL LPAREN RPAREN RPAREN
- | IF LPAREN s_var_expr COMMA expr COMMA number RPAREN
- | IF LPAREN s_var_expr COMMA expr COMMA NULL LPAREN RPAREN RPAREN
- """
- ifmaplist = self.check_stds(t[3])
- resultlist = []
- thenmaplist = []
- numthen = ''
- elsemaplist = []
- numelse = ''
- # Select input for r.mapcalc expression based on length of PLY object.
- if len(t) == 9:
- try:
- thenmaplist = self.check_stds(t[5])
- except:
- numthen = self.check_null(t[5])
- try:
- elsemaplist = self.check_stds(t[7])
- except:
- numelse = self.check_null(t[7])
- elif len(t) == 11:
- try:
- thenmaplist = self.check_stds(t[5])
- except:
- numthen = self.check_null(t[5])
- try:
- elsemaplist = self.check_stds(t[9])
- except:
- numelse = self.check_null(t[7])
- if thenmaplist != []:
- topolist = self.get_temporal_topo_list(ifmaplist, thenmaplist)
- elif elsemaplist != []:
- topolist = self.get_temporal_topo_list(ifmaplist, elsemaplist)
- if numthen != '':
- numinput = numthen
- elif numelse != '':
- numinput = numelse
- # Iterate over condition map lists with temporal relations.
- for map_i in topolist:
- # Loop over temporal related maps and create overlay modules.
- tbrelations = map_i.get_temporal_relations()
- count = 0
- for map_j in (tbrelations['EQUAL']):
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i, bool_op='and',
- copy=True)
- # Set first input for overlay module.
- mapainput = map_i.get_id()
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_j, 'and',
- temp_op='=')
- # Stop the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- break
- if count == 0:
- # Set map name.
- name = map_new.get_id()
- else:
- # Generate an intermediate map
- name = self.generate_map_name()
- # Set first input for overlay module.
- mapbinput = map_j.get_id()
- # Create r.mapcalc expression string for the operation.
- if thenmaplist != []:
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "if(%s,%s,%s)" % (map_new.cmd_list,
- mapbinput,
- numinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "if(%s,%s,%s)" % (mapainput,
- map_j.cmd_list,
- numinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "if(%s,%s,%s)" % (map_new.cmd_list,
- map_j.cmd_list,
- numinput)
- else:
- cmdstring = "if(%s,%s,%s)" % (mapainput,
- mapbinput, numinput)
- if elsemaplist != []:
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "if(%s,%s,%s)" % (map_new.cmd_list,
- numinput,
- mapbinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "if(%s,%s,%s)" % (mapainput,
- numinput,
- map_j.cmd_list)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "if(%s,%s,%s)" % (map_new.cmd_list,
- numinput,
- map_j.cmd_list)
- else:
- cmdstring = "if(%s,%s,%s)" % (mapainput, numinput,
- mapbinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Set new map name to temporary map name.
- #mapainput = name
- count += 1
- # Append map to result map list.
- if returncode == 1:
- resultlist.append(map_new)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_s_numeric_expr_condition_elif_relation(self, t):
- # Examples:
- # if({during},s_var_expr, 1, A)
- # if({during}, A == 5, A, null())
- """
- expr : IF LPAREN T_REL_OPERATOR COMMA s_var_expr COMMA number COMMA stds RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA s_var_expr COMMA NULL LPAREN RPAREN COMMA stds RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA s_var_expr COMMA number COMMA expr RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA s_var_expr COMMA NULL LPAREN RPAREN COMMA expr RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA s_var_expr COMMA stds COMMA number RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA s_var_expr COMMA stds COMMA NULL LPAREN RPAREN RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA s_var_expr COMMA expr COMMA number RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA s_var_expr COMMA expr COMMA NULL LPAREN RPAREN RPAREN
- """
- relations, temporal, function = self.eval_toperator(t[3])
- ifmaplist = self.check_stds(t[5])
- resultlist = []
- thenmaplist = []
- numthen = ''
- elsemaplist = []
- numelse = ''
- # Select input for r.mapcalc expression based on length of PLY object.
- if len(t) == 11:
- try:
- thenmaplist = self.check_stds(t[7])
- except:
- numthen = self.check_null(t[7])
- try:
- elsemaplist = self.check_stds(t[9])
- except:
- numelse = self.check_null(t[9])
- elif len(t) == 13:
- try:
- thenmaplist = self.check_stds(t[7])
- except:
- numthen = self.check_null(t[7])
- try:
- elsemaplist = self.check_stds(t[11])
- except:
- numelse = self.check_null(t[9])
- if thenmaplist != []:
- topolist = self.get_temporal_topo_list(ifmaplist, thenmaplist,
- topolist=relations)
- elif elsemaplist != []:
- topolist = self.get_temporal_topo_list(ifmaplist, elsemaplist,
- topolist=relations)
- if numthen != '':
- numinput = numthen
- elif numelse != '':
- numinput = numelse
- # Iterate over condition map lists with temporal relations.
- for map_i in topolist:
- # Loop over temporal related maps and create overlay modules.
- tbrelations = map_i.get_temporal_relations()
- count = 0
- for topo in relations:
- if topo in tbrelations.keys():
- for map_j in (tbrelations[topo]):
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i,
- bool_op='and',
- copy=True)
- # Set first input for overlay module.
- mapainput = map_i.get_id()
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_j,
- 'and',
- temp_op='=')
- # Stop the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- break
- if count == 0:
- # Set map name.
- name = map_new.get_id()
- else:
- # Generate an intermediate map
- name = self.generate_map_name()
- # Set first input for overlay module.
- mapbinput = map_j.get_id()
- # Create r.mapcalc expression string for the operation.
- if thenmaplist != []:
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "if(%s,%s,%s)" % (map_new.cmd_list,
- mapbinput,
- numinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "if(%s,%s,%s)" % (mapainput,
- map_j.cmd_list,
- numinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "if(%s,%s,%s)" % (map_new.cmd_list,
- map_j.cmd_list,
- numinput)
- else:
- cmdstring = "if(%s,%s,%s)" % (mapainput,
- mapbinput,
- numinput)
- if elsemaplist != []:
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "if(%s,%s,%s)" % (map_new.cmd_list,
- numinput,
- mapbinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "if(%s,%s,%s)" % (mapainput,
- numinput,
- map_j.cmd_list)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "if(%s,%s,%s)" % (map_new.cmd_list,
- numinput,
- map_j.cmd_list)
- else:
- cmdstring = "if(%s,%s,%s)" % (mapainput,
- numinput,
- mapbinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Set new map name to temporary map name.
- #mapainput = name
- count += 1
- # Append map to result map list.
- if returncode == 1:
- resultlist.append(map_new)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_s_expr_condition_elif_relation(self, t):
- # Examples:
- # if({equal||during}, s_var_expr, A, B)
- """
- expr : IF LPAREN T_REL_OPERATOR COMMA s_var_expr COMMA stds COMMA stds RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA s_var_expr COMMA stds COMMA expr RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA s_var_expr COMMA expr COMMA stds RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA s_var_expr COMMA expr COMMA expr RPAREN
- """
- relations, temporal, function = self.eval_toperator(t[3])
- ifmaplist = self.check_stds(t[5])
- thenmaplist = self.check_stds(t[7])
- elsemaplist = self.check_stds(t[9])
- resultlist = []
- thendict = {}
- elsedict = {}
- # Get topologies for the appropriate conclusion term.
- thentopolist = self.get_temporal_topo_list(ifmaplist, thenmaplist,
- topolist=relations)
- # Fill dictionaries with related maps for both conclusion terms.
- for map_i in thentopolist:
- thenrelations = map_i.get_temporal_relations()
- relationmaps = []
- for topo in relations:
- if topo in thenrelations.keys():
- relationmaps = relationmaps + thenrelations[topo]
- thendict[map_i.get_id()] = relationmaps
- # Get topologies for the alternative conclusion term.
- elsetopolist = self.get_temporal_topo_list(ifmaplist, elsemaplist,
- topolist=relations)
- for map_i in elsetopolist:
- elserelations = map_i.get_temporal_relations()
- relationmaps = []
- for topo in relations:
- if topo in elserelations.keys():
- relationmaps = relationmaps + elserelations[topo]
- elsedict[map_i.get_id()] = relationmaps
- # Loop trough conditional map list.
- for map_i in ifmaplist:
- if map_i.get_id() in thendict.keys():
- thenlist = thendict[map_i.get_id()]
- else:
- thenlist = []
- if map_i.get_id() in elsedict.keys():
- elselist = elsedict[map_i.get_id()]
- else:
- elselist = []
- # Set iteration amount to maximal or minimum number of related
- # conclusion maps, depending on null map creation flag.
- if self.null:
- iternum = max(len(thenlist), len(elselist))
- else:
- iternum = min(len(thenlist), len(elselist))
- # Calculate difference in conclusion lengths.
- iterthen = iternum - len(thenlist)
- iterelse = iternum - len(elselist)
- # Extend null maps to the list to get conclusions with same length.
- if iterthen != 0:
- for i in range(iterthen):
- thenlist.extend(['null()'])
- if iterelse != 0:
- for i in range(iterelse):
- elselist.extend(['null()'])
- # Combine the conclusions in a paired list.
- conclusionlist = zip(thenlist, elselist)
- for i in range(iternum):
- conclusionmaps = conclusionlist[i]
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i, bool_op='and',
- copy=True)
- # Set first input for overlay module.
- mapifinput = map_i.get_id()
- # Get conclusion maps.
- map_then = conclusionmaps[0]
- map_else = conclusionmaps[1]
- # Check if conclusions are map objects.
- if map_then != 'null()':
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_then,
- 'and', temp_op='=')
- maptheninput = map_then.get_id()
- # Continue the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- continue
- else:
- maptheninput = 'null()'
- # Check if conclusions are map objects.
- if map_else != 'null()':
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_else,
- 'and', temp_op='=')
- mapelseinput = map_else.get_id()
- # Continue the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- continue
- else:
- mapelseinput = 'null()'
- #if map_then != 'null()' and map_else != 'null()':
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_then) \
- and "cmd_list" not in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (map_new.cmd_list,
- maptheninput,
- mapelseinput)
- elif "cmd_list" in dir(map_new) and "cmd_list" in dir(map_then) \
- and "cmd_list" not in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (map_new.cmd_list,
- map_then.cmd_list,
- mapelseinput)
- elif "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_then) \
- and "cmd_list" in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (map_new.cmd_list,
- maptheninput,
- map_else.cmd_list)
- elif "cmd_list" in dir(map_new) and "cmd_list" in dir(map_then) \
- and "cmd_list" in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (map_new.cmd_list,
- map_then.cmd_list,
- map_else.cmd_list)
- elif "cmd_list" not in dir(map_new) and "cmd_list" in dir(map_then) \
- and "cmd_list" not in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (mapifinput,
- map_then.cmd_list,
- mapelseinput)
- elif "cmd_list" not in dir(map_new) and "cmd_list" not in dir(map_then) \
- and "cmd_list" in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (mapifinput,
- maptheninput,
- map_else.cmd_list)
- elif "cmd_list" not in dir(map_new) and "cmd_list" in dir(map_then) \
- and "cmd_list" in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (mapifinput,
- map_then.cmd_list,
- map_else.cmd_list)
- else:
- cmdstring = "if(%s, %s, %s)" % (mapifinput,
- maptheninput,
- mapelseinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Append map to result map list.
- if returncode == 1:
- resultlist.append(map_new)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_ts_var_expr1(self, t):
- # Combination of spatial and temporal conditional expressions.
- # Examples:
- # A <= 2 || start_date <= 2013-01-01
- # end_date > 2013-01-15 && A > 10
- # IMPORTANT: Only the intersection of map lists in conditionals are
- # exported.
- """
- ts_var_expr : s_var_expr AND AND t_var_expr
- | t_var_expr AND AND s_var_expr
- | t_var_expr OR OR s_var_expr
- | s_var_expr OR OR t_var_expr
- | ts_var_expr AND AND s_var_expr
- | ts_var_expr AND AND t_var_expr
- | ts_var_expr OR OR s_var_expr
- | ts_var_expr OR OR t_var_expr
- | s_var_expr AND AND ts_var_expr
- | t_var_expr AND AND ts_var_expr
- | s_var_expr OR OR ts_var_expr
- | t_var_expr OR OR ts_var_expr
- """
- # Check whether inputs are map lists or global temporal variables and
- # store each in separate lists.
- ts_var_dict = {"temporal": [], "spatial": []}
- temporal_list = []
- spatial_list = []
- operator = t[2] + t[3]
- temporalop = GlobalTemporalVar()
- temporalop.relationop = operator
- temporalop.topology.append("EQUAL")
- if isinstance(t[1], dict) and "spatial" in t[1]:
- temporal_list = temporal_list + t[1]["temporal"]
- spatial_list.append(t[1]["spatial"])
- elif isinstance(t[1], list):
- if all([isinstance(i, ta.GlobalTemporalVar) for i in t[1]]):
- temporal_list = temporal_list + t[1]
- else:
- tsexprA = self.check_stds(t[1])
- spatial_list.append(tsexprA)
- elif isinstance(t[1], ta.GlobalTemporalVar):
- temporal_list.append(t[1])
- if temporal_list != [] and isinstance(t[4], ta.GlobalTemporalVar):
- temporal_list.append(temporalop)
- if temporal_list != [] and \
- isinstance(t[4], list) and \
- all([isinstance(i, ta.GlobalTemporalVar) for i in t[4]]):
- temporal_list.append(temporalop)
- if isinstance(t[4], dict) and "spatial" in t[4]:
- temporal_list = temporal_list + t[4]["temporal"]
- spatial_list.append(t[4]["spatial"])
- elif isinstance(t[4], list):
- if all([isinstance(i, ta.GlobalTemporalVar) for i in t[4]]):
- temporal_list = temporal_list + t[4]
- else:
- tsexprB = self.check_stds(t[4])
- spatial_list.append(tsexprB)
- elif isinstance(t[4], ta.GlobalTemporalVar):
- temporal_list.append(t[4])
- ts_var_dict["temporal"] = temporal_list
- # Condition for two map lists in spatio temporal expression.
- if len(spatial_list) == 2:
- # Build topology for both map lists in spatio temporal expression.
- topolist = self.get_temporal_topo_list(spatial_list[0],
- spatial_list[1])
- resultlist = []
- for map_i in topolist:
- # Loop over temporal related maps and create overlay modules.
- tbrelations = map_i.get_temporal_relations()
- count = 0
- for map_j in (tbrelations['EQUAL']):
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i,
- bool_op='and', copy=True)
- # Set first input for overlay module.
- mapainput = map_i.get_id()
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_j,
- 'and', temp_op='=')
- # Stop the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- break
- if count == 0:
- # Set map name.
- name = map_new.get_id()
- else:
- # Generate an intermediate map
- name = self.generate_map_name()
- # Set first input for overlay module.
- mapbinput = map_j.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "%s %s %s" % (map_new.cmd_list, operator,
- mapbinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "%s %s %s" % (mapainput, operator,
- map_j.cmd_list)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "%s %s %s" % (map_new.cmd_list, operator,
- map_j.cmd_list)
- else:
- cmdstring = "%s %s %s" % (mapainput, operator,
- mapbinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Set new map name to temporary map name.
- #mapainput = name
- count += 1
- # Append map to result map list.
- if returncode == 1:
- resultlist.append(map_new)
- # Return dictionary with spatial map list of temporal
- # intersected maps and temporal expression in list form.
- ts_var_dict["spatial"] = resultlist
- # Condition for only one map list in spatio temporal expression.
- elif len(spatial_list) == 1:
- ts_var_dict["spatial"] = spatial_list[0]
- t[0] = ts_var_dict
- def p_ts_expr_condition_if(self, t):
- # Examples:
- # if(ts_var_expr, A)
- # if(start_year == 2013 || B != 5, A)
- """
- expr : IF LPAREN ts_var_expr COMMA stds RPAREN
- | IF LPAREN ts_var_expr COMMA expr RPAREN
- """
- ts_var_dict = t[3]
- spatialcond = ts_var_dict["spatial"]
- # Extract spatial map list from condition.
- ifmaplist = self.check_stds(spatialcond)
- thenmaplist = self.check_stds(t[5])
- topolist = self.get_temporal_topo_list(ifmaplist, thenmaplist)
- resultlist = []
- resultspatial = []
- for map_i in topolist:
- #print(map_i.get_id())
- # Loop over temporal related maps and create overlay modules.
- tbrelations = map_i.get_temporal_relations()
- count = 0
- for map_j in (tbrelations['EQUAL']):
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i, bool_op='and',
- copy=True)
- # Set first input for overlay module.
- mapainput = map_i.get_id()
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_j, 'and',
- temp_op='=')
- # Stop the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- break
- if count == 0:
- # Set map name.
- name = map_new.get_id()
- else:
- # Generate an intermediate map
- name = self.generate_map_name()
- # Set first input for overlay module.
- mapbinput = map_j.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "if(%s,%s)" % (map_new.cmd_list, mapbinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "if(%s,%s)" % (mapainput, map_j.cmd_list)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "if(%s,%s)" % (map_new.cmd_list,
- map_j.cmd_list)
- else:
- cmdstring = "if(%s,%s)" % (mapainput, mapbinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Set new map name to temporary map name.
- #mapainput = name
- count += 1
- # Append map to result map list.
- if returncode == 1:
- resultspatial.append(map_new)
- # Evaluate temporal statements in spatio temporal condition.
- #if len(ts_var_dict["temporal"]) == 1:
- #temporalcond = ts_var_dict["temporal"][0]
- #else:
- temporalcond = ts_var_dict["temporal"]
- resultspatial = self.check_stds(resultspatial)
- thencond = self.build_condition_list(temporalcond, resultspatial)
- thenresult = self.eval_condition_list(thencond)
- # Clear the map list.
- resultlist = self.check_stds(thenresult, clear=True)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_ts_expr_condition_if_relation(self, t):
- # Examples:
- # if({equal||during}, ts_var_expr, A)
- # if({starts||during}, B > 2 || end_month() == 4, A)
- """
- expr : IF LPAREN T_REL_OPERATOR COMMA ts_var_expr COMMA stds RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA ts_var_expr COMMA expr RPAREN
- """
- relations, temporal, function = self.eval_toperator(t[3])
- ts_var_dict = t[5]
- spatialcond = ts_var_dict["spatial"]
- # Extract spatial map list from condition.
- ifmaplist = self.check_stds(spatialcond)
- thenmaplist = self.check_stds(t[7])
- topolist = self.get_temporal_topo_list(ifmaplist, thenmaplist,
- topolist=relations)
- resultspatial = []
- for map_i in topolist:
- #print(map_i.get_id())
- # Loop over temporal related maps and create overlay modules.
- tbrelations = map_i.get_temporal_relations()
- count = 0
- for topo in relations:
- if topo in tbrelations.keys():
- for map_j in (tbrelations[topo]):
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i,
- bool_op='and',
- copy=True)
- # Set first input for overlay module.
- mapainput = map_i.get_id()
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_j,
- 'and',
- temp_op='=')
- # Stop the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- break
- if count == 0:
- # Set map name.
- name = map_new.get_id()
- else:
- # Generate an intermediate map
- name = self.generate_map_name()
- # Set first input for overlay module.
- mapbinput = map_j.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "if(%s,%s)" % (map_new.cmd_list,
- mapbinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "if(%s,%s)" % (mapainput,
- map_j.cmd_list)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "if(%s,%s)" % (map_new.cmd_list,
- map_j.cmd_list)
- else:
- cmdstring = "if(%s,%s)" % (mapainput, mapbinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Set new map name to temporary map name.
- #mapainput = name
- count += 1
- # Append map to result map list.
- if returncode == 1:
- resultspatial.append(map_new)
- # Evaluate temporal statements in spatio temporal condition.
- #if len(ts_var_dict["temporal"]) == 1:
- #temporalcond = ts_var_dict["temporal"][0]
- #else:
- temporalcond = ts_var_dict["temporal"]
- resultspatial = self.check_stds(resultspatial)
- thencond = self.build_condition_list(temporalcond, resultspatial,
- relations)
- thenresult = self.eval_condition_list(thencond)
- # Clear the map list.
- resultlist = self.check_stds(thenresult, clear=True)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_ts_numeric_condition_if(self, t):
- # Examples:
- # if(ts_var_expr, 1)
- # if(A == 5 && start_day() > 5, 10)
- """
- expr : IF LPAREN ts_var_expr COMMA number RPAREN
- | IF LPAREN ts_var_expr COMMA NULL LPAREN RPAREN RPAREN
- """
- ts_var_dict = t[3]
- spatialcond = ts_var_dict["spatial"]
- ifmaplist = self.check_stds(spatialcond)
- resultspatial = []
- # Select input for r.mapcalc expression based on length of PLY object.
- if len(t) == 7:
- numinput = t[5]
- elif len(t) == 9:
- numinput = t[5] + t[6] + t[7]
- # Iterate over condition map list.
- for map_i in ifmaplist:
- mapinput = map_i.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_i):
- cmdstring = "if(%s,%s)" % (map_i.cmd_list, numinput)
- else:
- cmdstring = "if(%s,%s)" % (mapinput, numinput)
- # Conditional append of module command.
- map_i.cmd_list = cmdstring
- # Append map to result map list.
- resultspatial.append(map_i)
- temporalcond = ts_var_dict["temporal"]
- resultspatial = self.check_stds(resultspatial)
- thencond = self.build_condition_list(temporalcond, resultspatial)
- thenresult = self.eval_condition_list(thencond)
- # Clear the map list.
- resultlist = self.check_stds(thenresult, clear=True)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_ts_expr_condition_elif(self, t):
- # Examples:
- # if(s_var_expr, A, B)
- # if(start_day() < 20 && B > 2, A, B)
- """
- expr : IF LPAREN ts_var_expr COMMA stds COMMA stds RPAREN
- | IF LPAREN ts_var_expr COMMA stds COMMA expr RPAREN
- | IF LPAREN ts_var_expr COMMA expr COMMA stds RPAREN
- | IF LPAREN ts_var_expr COMMA expr COMMA expr RPAREN
- """
- ts_var_dict = t[3]
- spatialcond = ts_var_dict["spatial"]
- ifmaplist = self.check_stds(spatialcond)
- thenmaplist = self.check_stds(t[5])
- elsemaplist = self.check_stds(t[7])
- resultspatial = []
- thendict = {}
- elsedict = {}
- # Get topologies for the appropriate conclusion term.
- thentopolist = self.get_temporal_topo_list(ifmaplist, thenmaplist)
- # Fill dictionaries with related maps for both conclusion terms.
- for map_i in thentopolist:
- thenrelations = map_i.get_temporal_relations()
- relationmaps = thenrelations['EQUAL']
- thendict[map_i.get_id()] = relationmaps
- # Get topologies for the alternative conclusion term.
- elsetopolist = self.get_temporal_topo_list(ifmaplist, elsemaplist)
- for map_i in elsetopolist:
- elserelations = map_i.get_temporal_relations()
- relationmaps = elserelations['EQUAL']
- elsedict[map_i.get_id()] = relationmaps
- # Loop through conditional map list.
- for map_i in ifmaplist:
- if map_i.get_id() in thendict.keys():
- thenlist = thendict[map_i.get_id()]
- else:
- thenlist = []
- if map_i.get_id() in elsedict.keys():
- elselist = elsedict[map_i.get_id()]
- else:
- elselist = []
- # Set iteration amount to maximal or minimum number of related
- # conclusion maps, depending on null map creation flag.
- if self.null:
- iternum = max(len(thenlist), len(elselist))
- else:
- iternum = min(len(thenlist), len(elselist))
- # Calculate difference in conclusion lengths.
- iterthen = iternum - len(thenlist)
- iterelse = iternum - len(elselist)
- # Extend null maps to the list to get conclusions with same length.
- if iterthen != 0:
- for i in range(iterthen):
- thenlist.extend(['null()'])
- if iterelse != 0:
- for i in range(iterelse):
- elselist.extend(['null()'])
- # Combine the conclusions in a paired list.
- conclusionlist = zip(thenlist, elselist)
- for i in range(iternum):
- conclusionmaps = conclusionlist[i]
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i,
- bool_op='and', copy=True)
- # Set first input for overlay module.
- mapifinput = map_i.get_id()
- # Get conclusion maps.
- map_then = conclusionmaps[0]
- map_else = conclusionmaps[1]
- # Check if conclusions are map objects.
- if map_then != 'null()':
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_then,
- 'and', temp_op='=')
- maptheninput = map_then.get_id()
- # Continue the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- continue
- else:
- maptheninput = 'null()'
- # Check if conclusions are map objects.
- if map_else != 'null()':
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_else,
- 'and', temp_op='=')
- mapelseinput = map_else.get_id()
- # Continue the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- continue
- else:
- mapelseinput = 'null()'
- #if map_then != 'null()' and map_else != 'null()':
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_then) \
- and "cmd_list" not in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (map_new.cmd_list,
- maptheninput,
- mapelseinput)
- elif "cmd_list" in dir(map_new) and "cmd_list" in dir(map_then) \
- and "cmd_list" not in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (map_new.cmd_list,
- map_then.cmd_list,
- mapelseinput)
- elif "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_then) \
- and "cmd_list" in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (map_new.cmd_list,
- maptheninput,
- map_else.cmd_list)
- elif "cmd_list" in dir(map_new) and "cmd_list" in dir(map_then) \
- and "cmd_list" in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (map_new.cmd_list,
- map_then.cmd_list,
- map_else.cmd_list)
- elif "cmd_list" not in dir(map_new) and "cmd_list" in dir(map_then) \
- and "cmd_list" not in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (mapifinput,
- map_then.cmd_list,
- mapelseinput)
- elif "cmd_list" not in dir(map_new) and "cmd_list" not in dir(map_then) \
- and "cmd_list" in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (mapifinput,
- maptheninput,
- map_else.cmd_list)
- elif "cmd_list" not in dir(map_new) and "cmd_list" in dir(map_then) \
- and "cmd_list" in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (mapifinput,
- map_then.cmd_list,
- map_else.cmd_list)
- else:
- cmdstring = "if(%s, %s, %s)" % (mapifinput,
- maptheninput,
- mapelseinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Append map to result map list.
- if returncode == 1:
- resultspatial.append(map_new)
- temporalcond = ts_var_dict["temporal"]
- resultspatial = self.check_stds(resultspatial)
- thencond = self.build_condition_list(temporalcond, resultspatial)
- thenresult = self.eval_condition_list(thencond)
- #elseresult = self.eval_condition_list(thencond, inverse = True)
- # Combine and sort else and then statement to result map list.
- #combilist = thenresult + elseresult
- #resultlist = sorted(combilist, key = AbstractDatasetComparisonKeyStartTime)
- # Clear the map list.
- #resultlist = self.check_stds(resultlist, clear = True)
- resultlist = self.check_stds(thenresult, clear=True)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_ts_expr_condition_elif_relation(self, t):
- # Examples:
- # if({equal||during}, s_var_expr, A, B)
- # if({contains}, start_day() == 3 || C != 2, A, B)
- """
- expr : IF LPAREN T_REL_OPERATOR COMMA ts_var_expr COMMA stds COMMA stds RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA ts_var_expr COMMA stds COMMA expr RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA ts_var_expr COMMA expr COMMA stds RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA ts_var_expr COMMA expr COMMA expr RPAREN
- """
- relations, temporal, function = self.eval_toperator(t[3])
- ts_var_dict = t[5]
- spatialcond = ts_var_dict["spatial"]
- # Extract spatial map list from condition.
- ifmaplist = self.check_stds(spatialcond)
- thenmaplist = self.check_stds(t[7])
- elsemaplist = self.check_stds(t[9])
- resultspatial = []
- thendict = {}
- elsedict = {}
- # Get topologies for the appropriate conclusion term.
- thentopolist = self.get_temporal_topo_list(ifmaplist, thenmaplist,
- topolist=relations)
- # Fill dictionaries with related maps for both conclusion terms.
- for map_i in thentopolist:
- thenrelations = map_i.get_temporal_relations()
- relationmaps = []
- for topo in relations:
- if topo in thenrelations.keys():
- relationmaps = relationmaps + thenrelations[topo]
- thendict[map_i.get_id()] = relationmaps
- # Get topologies for the alternative conclusion term.
- elsetopolist = self.get_temporal_topo_list(ifmaplist, elsemaplist,
- topolist=relations)
- for map_i in elsetopolist:
- elserelations = map_i.get_temporal_relations()
- relationmaps = []
- for topo in relations:
- if topo in elserelations.keys():
- relationmaps = relationmaps + elserelations[topo]
- elsedict[map_i.get_id()] = relationmaps
- # Loop trough conditional map list.
- for map_i in ifmaplist:
- if map_i.get_id() in thendict.keys():
- thenlist = thendict[map_i.get_id()]
- else:
- thenlist = []
- if map_i.get_id() in elsedict.keys():
- elselist = elsedict[map_i.get_id()]
- else:
- elselist = []
- # Set iteration amount to maximal or minimum number of related
- # conclusion maps, depending on null map creation flag.
- if self.null:
- iternum = max(len(thenlist), len(elselist))
- else:
- iternum = min(len(thenlist), len(elselist))
- # Calculate difference in conclusion lengths.
- iterthen = iternum - len(thenlist)
- iterelse = iternum - len(elselist)
- # Extend null maps to the list to get conclusions with same length.
- if iterthen != 0:
- for i in range(iterthen):
- thenlist.extend(['null()'])
- if iterelse != 0:
- for i in range(iterelse):
- elselist.extend(['null()'])
- # Combine the conclusions in a paired list.
- conclusionlist = zip(thenlist, elselist)
- for i in range(iternum):
- conclusionmaps = conclusionlist[i]
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i, bool_op='and',
- copy=True)
- # Set first input for overlay module.
- mapifinput = map_i.get_id()
- # Get conclusion maps.
- map_then = conclusionmaps[0]
- map_else = conclusionmaps[1]
- # Check if conclusions are map objects.
- if map_then != 'null()':
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_then,
- 'and', temp_op='=')
- maptheninput = map_then.get_id()
- # Continue the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- continue
- else:
- maptheninput = 'null()'
- # Check if conclusions are map objects.
- if map_else != 'null()':
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_else,
- 'and', temp_op='=')
- mapelseinput = map_else.get_id()
- # Continue the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- continue
- else:
- mapelseinput = 'null()'
- #if map_then != 'null()' and map_else != 'null()':
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_then) \
- and "cmd_list" not in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (map_new.cmd_list,
- maptheninput,
- mapelseinput)
- elif "cmd_list" in dir(map_new) and "cmd_list" in dir(map_then) \
- and "cmd_list" not in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (map_new.cmd_list,
- map_then.cmd_list,
- mapelseinput)
- elif "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_then) \
- and "cmd_list" in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (map_new.cmd_list,
- maptheninput,
- map_else.cmd_list)
- elif "cmd_list" in dir(map_new) and "cmd_list" in dir(map_then) \
- and "cmd_list" in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (map_new.cmd_list,
- map_then.cmd_list,
- map_else.cmd_list)
- elif "cmd_list" not in dir(map_new) and "cmd_list" in dir(map_then) \
- and "cmd_list" not in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (mapifinput,
- map_then.cmd_list,
- mapelseinput)
- elif "cmd_list" not in dir(map_new) and "cmd_list" not in dir(map_then) \
- and "cmd_list" in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (mapifinput, maptheninput,
- map_else.cmd_list)
- elif "cmd_list" not in dir(map_new) and "cmd_list" in dir(map_then) \
- and "cmd_list" in dir(map_else):
- cmdstring = "if(%s, %s, %s)" % (mapifinput,
- map_then.cmd_list,
- map_else.cmd_list)
- else:
- cmdstring = "if(%s, %s, %s)" % (mapifinput, maptheninput,
- mapelseinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Append map to result map list.
- if returncode == 1:
- resultspatial.append(map_new)
- temporalcond = ts_var_dict["temporal"]
- resultspatial = self.check_stds(resultspatial)
- thencond = self.build_condition_list(temporalcond, resultspatial,
- relations)
- thenresult = self.eval_condition_list(thencond)
- #elseresult = self.eval_condition_list(thencond, inverse = True)
- # Combine and sort else and then statement to result map list.
- #combilist = thenresult + elseresult
- #resultlist = sorted(combilist, key = AbstractDatasetComparisonKeyStartTime)
- # Clear the map list.
- resultlist = self.check_stds(thenresult, clear=True)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_ts_numeric_condition_elif(self, t):
- # Examples:
- # if(ts_var_expr, 1, 2)
- # if(A == 1 || end_year == 2013, 10, null())
- """
- expr : IF LPAREN ts_var_expr COMMA number COMMA number RPAREN
- | IF LPAREN ts_var_expr COMMA NULL LPAREN RPAREN COMMA number RPAREN
- | IF LPAREN ts_var_expr COMMA number COMMA NULL LPAREN RPAREN RPAREN
- | IF LPAREN ts_var_expr COMMA NULL LPAREN RPAREN COMMA NULL LPAREN RPAREN RPAREN
- """
- ts_var_dict = t[3]
- spatialcond = ts_var_dict["spatial"]
- # Extract spatial map list from condition.
- ifmaplist = self.check_stds(spatialcond)
- resultspatial = []
- # Select input for r.mapcalc expression based on length of PLY object.
- if len(t) == 9:
- numthen = t[5]
- numelse = t[7]
- elif len(t) == 11:
- numthen = self.check_null(t[5])
- numelse = self.check_null(t[7])
- elif len(t) == 13:
- numthen = self.check_null(t[5])
- numelse = self.check_null(t[9])
- # Iterate over condition map list.
- for map_i in ifmaplist:
- mapinput = map_i.get_id()
- # Create r.mapcalc expression string for the operation.
- if "cmd_list" in dir(map_i):
- cmdstring = "if(%s, %s, %s)" % (map_i.cmd_list, numthen,
- numelse)
- else:
- cmdstring = "if(%s, %s, %s)" % (mapinput, numthen, numelse)
- # Conditional append of module command.
- map_i.cmd_list = cmdstring
- # Append map to result map list.
- resultspatial.append(map_i)
- temporalcond = ts_var_dict["temporal"]
- resultspatial = self.check_stds(resultspatial)
- thencond = self.build_condition_list(temporalcond, resultspatial)
- thenresult = self.eval_condition_list(thencond)
- #elseresult = self.eval_condition_list(thencond, inverse = True)
- # Combine and sort else and then statement to result map list.
- #combilist = thenresult + elseresult
- #resultlist = sorted(combilist, key = AbstractDatasetComparisonKeyStartTime)
- # Clear the map list.
- #resultlist = self.check_stds(resultlist, clear = True)
- resultlist = self.check_stds(thenresult, clear=True)
- t[0] = resultlist
- def p_ts_numeric_expr_condition_elif(self, t):
- # Examples:
- # if(ts_var_expr, 1, A)
- # if(A == 5 && start_day() > 5, A, null())
- """
- expr : IF LPAREN ts_var_expr COMMA number COMMA stds RPAREN
- | IF LPAREN ts_var_expr COMMA NULL LPAREN RPAREN COMMA stds RPAREN
- | IF LPAREN ts_var_expr COMMA number COMMA expr RPAREN
- | IF LPAREN ts_var_expr COMMA NULL LPAREN RPAREN COMMA expr RPAREN
- | IF LPAREN ts_var_expr COMMA stds COMMA number RPAREN
- | IF LPAREN ts_var_expr COMMA stds COMMA NULL LPAREN RPAREN RPAREN
- | IF LPAREN ts_var_expr COMMA expr COMMA number RPAREN
- | IF LPAREN ts_var_expr COMMA expr COMMA NULL LPAREN RPAREN RPAREN
- """
- ts_var_dict = t[3]
- spatialcond = ts_var_dict["spatial"]
- ifmaplist = self.check_stds(spatialcond)
- resultspatial = []
- thenmaplist = []
- numthen = ''
- elsemaplist = []
- numelse = ''
- # Select input for r.mapcalc expression based on length of PLY object.
- if len(t) == 9:
- try:
- thenmaplist = self.check_stds(t[5])
- except:
- numthen = t[5]
- try:
- elsemaplist = self.check_stds(t[7])
- except:
- numelse = t[7]
- elif len(t) == 11:
- try:
- thenmaplist = self.check_stds(t[5])
- except:
- numthen = t[5] + t[6] + t[7]
- try:
- elsemaplist = self.check_stds(t[9])
- except:
- numelse = t[7] + t[8] + t[9]
- if thenmaplist != []:
- topolist = self.get_temporal_topo_list(ifmaplist, thenmaplist)
- elif elsemaplist != []:
- topolist = self.get_temporal_topo_list(ifmaplist, elsemaplist)
- if numthen != '':
- numinput = numthen
- elif numelse != '':
- numinput = numelse
- # Iterate over condition map lists with temporal relations.
- for map_i in topolist:
- # Loop over temporal related maps and create overlay modules.
- tbrelations = map_i.get_temporal_relations()
- count = 0
- for map_j in (tbrelations['EQUAL']):
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i, bool_op='and',
- copy=True)
- # Set first input for overlay module.
- mapainput = map_i.get_id()
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_j, 'and',
- temp_op='=')
- # Stop the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- break
- if count == 0:
- # Set map name.
- name = map_new.get_id()
- else:
- # Generate an intermediate map
- name = self.generate_map_name()
- # Set first input for overlay module.
- mapbinput = map_j.get_id()
- # Create r.mapcalc expression string for the operation.
- if thenmaplist != []:
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "if(%s,%s,%s)" % (map_new.cmd_list,
- mapbinput,
- numinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "if(%s,%s,%s)" % (mapainput,
- map_j.cmd_list,
- numinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "if(%s,%s,%s)" % (map_new.cmd_list,
- map_j.cmd_list,
- numinput)
- else:
- cmdstring = "if(%s,%s,%s)" % (mapainput, mapbinput,
- numinput)
- if elsemaplist != []:
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "if(%s,%s,%s)" % (map_new.cmd_list,
- numinput,
- mapbinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "if(%s,%s,%s)" % (mapainput, numinput,
- map_j.cmd_list)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "if(%s,%s,%s)" % (map_new.cmd_list,
- numinput, map_j.cmd_list)
- else:
- cmdstring = "if(%s,%s,%s)" % (mapainput, numinput,
- mapbinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Set new map name to temporary map name.
- #mapainput = name
- count += 1
- # Append map to result map list.
- if returncode == 1:
- resultspatial.append(map_new)
- temporalcond = ts_var_dict["temporal"]
- resultspatial = self.check_stds(resultspatial)
- thencond = self.build_condition_list(temporalcond, resultspatial)
- thenresult = self.eval_condition_list(thencond)
- # Clear the map list.
- resultlist = self.check_stds(thenresult, clear=True)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- def p_ts_numeric_expr_condition_elif_relation(self, t):
- # Examples:
- # if({during},ts_var_expr, 1, A)
- # if({during}, A == 5 && start_day() > 5, A, null())
- """
- expr : IF LPAREN T_REL_OPERATOR COMMA ts_var_expr COMMA number COMMA stds RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA ts_var_expr COMMA NULL LPAREN RPAREN COMMA stds RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA ts_var_expr COMMA number COMMA expr RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA ts_var_expr COMMA NULL LPAREN RPAREN COMMA expr RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA ts_var_expr COMMA stds COMMA number RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA ts_var_expr COMMA stds COMMA NULL LPAREN RPAREN RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA ts_var_expr COMMA expr COMMA number RPAREN
- | IF LPAREN T_REL_OPERATOR COMMA ts_var_expr COMMA expr COMMA NULL LPAREN RPAREN RPAREN
- """
- relations, temporal, function = self.eval_toperator(t[3])
- ts_var_dict = t[5]
- spatialcond = ts_var_dict["spatial"]
- ifmaplist = self.check_stds(spatialcond)
- resultspatial = []
- thenmaplist = []
- numthen = ''
- elsemaplist = []
- numelse = ''
- # Select input for r.mapcalc expression based on length of PLY object.
- if len(t) == 11:
- try:
- thenmaplist = self.check_stds(t[7])
- except:
- numthen = t[7]
- try:
- elsemaplist = self.check_stds(t[9])
- except:
- numelse = t[9]
- elif len(t) == 13:
- try:
- thenmaplist = self.check_stds(t[7])
- except:
- numthen = t[9] + t[10] + t[11]
- try:
- elsemaplist = self.check_stds(t[11])
- except:
- numelse = t[9] + t[10] + t[11]
- if thenmaplist != []:
- topolist = self.get_temporal_topo_list(ifmaplist, thenmaplist,
- topolist=relations)
- elif elsemaplist != []:
- topolist = self.get_temporal_topo_list(ifmaplist, elsemaplist,
- topolist=relations)
- if numthen != '':
- numinput = numthen
- elif numelse != '':
- numinput = numelse
- # Iterate over condition map lists with temporal relations.
- for map_i in topolist:
- # Loop over temporal related maps and create overlay modules.
- tbrelations = map_i.get_temporal_relations()
- count = 0
- for topo in relations:
- if topo in tbrelations.keys():
- for map_j in (tbrelations[topo]):
- # Generate an intermediate map for the result map list.
- map_new = self.generate_new_map(base_map=map_i,
- bool_op='and',
- copy=True)
- # Set first input for overlay module.
- mapainput = map_i.get_id()
- # Create overlayed map extent.
- returncode = self.overlay_map_extent(map_new, map_j,
- 'and',
- temp_op='=')
- # Stop the loop if no temporal or spatial relationship exist.
- if returncode == 0:
- break
- if count == 0:
- # Set map name.
- name = map_new.get_id()
- else:
- # Generate an intermediate map
- name = self.generate_map_name()
- # Set first input for overlay module.
- mapbinput = map_j.get_id()
- # Create r.mapcalc expression string for the operation.
- if thenmaplist != []:
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "if(%s,%s,%s)" % (map_new.cmd_list,
- mapbinput,
- numinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "if(%s,%s,%s)" % (mapainput,
- map_j.cmd_list,
- numinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "if(%s,%s,%s)" % (map_new.cmd_list,
- map_j.cmd_list,
- numinput)
- else:
- cmdstring = "if(%s,%s,%s)" % (mapainput,
- mapbinput,
- numinput)
- if elsemaplist != []:
- if "cmd_list" in dir(map_new) and "cmd_list" not in dir(map_j):
- cmdstring = "if(%s,%s,%s)" % (map_new.cmd_list,
- numinput,
- mapbinput)
- elif "cmd_list" in dir(map_j) and "cmd_list" not in dir(map_new):
- cmdstring = "if(%s,%s,%s)" % (mapainput,
- numinput,
- map_j.cmd_list)
- elif "cmd_list" in dir(map_j) and "cmd_list" in dir(map_new):
- cmdstring = "if(%s,%s,%s)" % (map_new.cmd_list,
- numinput,
- map_j.cmd_list)
- else:
- cmdstring = "if(%s,%s,%s)" % (mapainput,
- numinput,
- mapbinput)
- # Conditional append of module command.
- map_new.cmd_list = cmdstring
- # Set new map name to temporary map name.
- #mapainput = name
- count += 1
- # Append map to result map list.
- if returncode == 1:
- resultspatial.append(map_new)
- temporalcond = ts_var_dict["temporal"]
- resultspatial = self.check_stds(resultspatial)
- thencond = self.build_condition_list(temporalcond, resultspatial)
- thenresult = self.eval_condition_list(thencond)
- # Clear the map list.
- resultlist = self.check_stds(thenresult, clear=True)
- t[0] = resultlist
- if self.debug:
- for map in resultlist:
- print map.cmd_list
- ###############################################################################
- if __name__ == "__main__":
- import doctest
- doctest.testmod()
|