test4NewSignalChain.py
102 lines
| 3.4 KiB
| text/x-python
|
PythonLexer
/ schainpy / test4NewSignalChain.py
Daniel Valdez
|
r189 | """ | |
| $Author$ | |||
| $Id$ | |||
| """ | |||
| import datetime | |||
| from controller import * | |||
| from model import * | |||
| class Test(): | |||
| def __init__(self): | |||
| self.createObjects() | |||
| self.run() | |||
| def createObjects(self): | |||
| self.upConfig = controller.UPConf(id=1, name="voltageproc", type="voltage") | |||
| opConf = self.upConfig.addOperation(name="init", priority=0) | |||
| opConf1 = self.upConfig.addOperation(name="CohInt", priority=1, type="other") | |||
|
Daniel Valdez
|
r190 | opConf1.addParameter(name="nCohInt", value=100) | |
|
Daniel Valdez
|
r189 | ||
|
Daniel Valdez
|
r190 | opConf2 = self.upConfig.addOperation(name="Scope", priority=2, type="other") | |
| opConf2.addParameter(name="idfigure", value=1) | |||
|
Daniel Valdez
|
r189 | ||
|
Daniel Valdez
|
r192 | ||
| self.upConfigSpc = controller.UPConf(id=2, name="spectraproc", type="spectra") | |||
| opConf = self.upConfigSpc.addOperation(name="init", priority=0) | |||
| opConf.addParameter(name="nFFTPoints", value=8) | |||
| opConf3 = self.upConfigSpc.addOperation(name="SpectraPlot", priority=1, type="other") | |||
| opConf3.addParameter(name="idfigure", value=2) | |||
|
Daniel Valdez
|
r190 | # opConf = self.upConfig.addOperation(name="selectChannels", priority=3) | |
| # opConf.addParameter(name="channelList", value=[0,1]) | |||
|
Daniel Valdez
|
r189 | ||
| ######################################### | |||
| self.objR = jrodataIO.VoltageReader() | |||
| self.objP = jroprocessing.VoltageProc() | |||
|
Daniel Valdez
|
r192 | self.objSpc = jroprocessing.SpectraProc() | |
|
Daniel Valdez
|
r189 | ||
| self.objInt = jroprocessing.CohInt() | |||
|
Daniel Valdez
|
r190 | ||
|
Daniel Valdez
|
r189 | self.objP.addOperation(self.objInt, opConf1.id) | |
|
Daniel Valdez
|
r190 | self.objScope = jroplot.Scope() | |
| self.objP.addOperation(self.objScope, opConf2.id) | |||
|
Daniel Valdez
|
r192 | self.objSpcPlot = jroplot.SpectraPlot() | |
| self.objSpc.addOperation(self.objSpcPlot, opConf3.id) | |||
|
Daniel Valdez
|
r189 | self.connect(self.objR, self.objP) | |
|
Daniel Valdez
|
r192 | self.connect(self.objP, self.objSpc) | |
|
Daniel Valdez
|
r189 | def connect(self, obj1, obj2): | |
|
Daniel Valdez
|
r192 | obj2.setInput(obj1.getOutput()) | |
|
Daniel Valdez
|
r189 | ||
| def run(self): | |||
| while(True): | |||
| self.objR.run(path="/Users/dsuarez/Remote/Meteors", | |||
| startDate=datetime.date(2012,1,1), | |||
| endDate=datetime.date(2012,12,30), | |||
| startTime=datetime.time(0,0,0), | |||
| endTime=datetime.time(23,59,59), | |||
| set=0, | |||
| expLabel = "", | |||
| ext = None, | |||
| online = False) | |||
| for opConf in self.upConfig.getOperationObjList(): | |||
| kwargs={} | |||
| for parm in opConf.getParameterObjList(): | |||
| kwargs[parm.name]=parm.value | |||
| self.objP.call(opConf,**kwargs) | |||
|
Daniel Valdez
|
r192 | ||
| ############################ | |||
| for opConfSpc in self.upConfigSpc.getOperationObjList(): | |||
| kwargs={} | |||
| for parm in opConfSpc.getParameterObjList(): | |||
| kwargs[parm.name]=parm.value | |||
| self.objSpc.call(opConfSpc,**kwargs) | |||
|
Daniel Valdez
|
r189 | ||
| if self.objR.flagNoMoreFiles: | |||
| break | |||
| if self.objR.flagIsNewBlock: | |||
| print 'Block No %04d, Time: %s' %(self.objR.nTotalBlocks, | |||
| datetime.datetime.fromtimestamp(self.objR.basicHeaderObj.utc + self.objR.basicHeaderObj.miliSecond/1000.0),) | |||
| if __name__ == "__main__": | |||
| Test() |