@@ -1,109 +1,143 | |||||
1 | import os, sys |
|
1 | import os, sys | |
2 | from pytz import timezone |
|
2 | from pytz import timezone | |
3 | path = os.path.dirname(os.getcwd()) |
|
3 | path = os.path.dirname(os.getcwd()) | |
4 | path = os.path.dirname(path) |
|
4 | path = os.path.dirname(path) | |
5 |
|
5 | |||
6 | print path |
|
6 | print path | |
7 | sys.path.insert(0, path) # Para usar las librerias del eclipse. |
|
7 | sys.path.insert(0, path) # Para usar las librerias del eclipse. | |
8 |
|
8 | |||
9 | from schainpy.controller import Project |
|
9 | from schainpy.controller import Project | |
10 |
|
10 | |||
11 | # from __main__ import time |
|
11 | # from __main__ import time | |
12 | #path = os.path.split(os.getcwd())[0] |
|
12 | #path = os.path.split(os.getcwd())[0] | |
13 | #sys.path.append(path) |
|
13 | #sys.path.append(path) | |
14 | # import scipy.io as sio |
|
14 | # import scipy.io as sio | |
15 | # import pprint |
|
15 | # import pprint | |
16 | # import numpy |
|
16 | # import numpy | |
17 | # import time |
|
17 | # import time | |
18 | # import os |
|
18 | # import os | |
19 | # import h5py |
|
19 | # import h5py | |
20 | # import re |
|
20 | # import re | |
21 | # import tables |
|
21 | # import tables | |
22 | # |
|
22 | # | |
23 | # from model.data.jrodata import * |
|
23 | # from model.data.jrodata import * | |
24 | # from model.proc.jroproc_base import ProcessingUnit, Operation |
|
24 | # from model.proc.jroproc_base import ProcessingUnit, Operation | |
25 | # from model.io.jroIO_base import * |
|
25 | # from model.io.jroIO_base import * | |
26 |
|
26 | |||
27 |
|
27 | |||
28 | # controllerObj = Project() |
|
28 | # controllerObj = Project() | |
29 |
|
29 | |||
30 | # controllerObj.setup(id = '191', name='test01', description=desc) |
|
30 | # controllerObj.setup(id = '191', name='test01', description=desc) | |
31 |
|
31 | |||
32 |
|
32 | |||
33 | #from controller import * |
|
33 | #from controller import * | |
34 |
|
34 | |||
35 | desc = "DBS Experiment Test" |
|
35 | desc = "DBS Experiment Test" | |
36 | filename = "DBStest.xml" |
|
36 | filename = "DBStest.xml" | |
37 |
|
37 | |||
38 | controllerObj = Project() |
|
38 | controllerObj = Project() | |
39 |
|
39 | |||
40 | controllerObj.setup(id = '191', name='test01', description=desc) |
|
40 | controllerObj.setup(id = '191', name='test01', description=desc) | |
41 |
|
41 | |||
42 | #path = 'F:\CIRI Data\processed' |
|
42 | #path = 'F:\CIRI Data\processed' | |
43 | path='/media/4B514E8903EBC487/CIRI Data/processed' |
|
43 | #path='/media/4B514E8903EBC487/CIRI Data/processed' | |
44 |
#path='/home/ |
|
44 | #path='/home/ciri/ciri_online' | |
|
45 | #offline program | |||
|
46 | #path='/home/ciri/.gvfs/SFTP for radar on 192.168.1.161/media/dataswap/huancayo/20150701/processed' | |||
|
47 | #online program | |||
|
48 | path='/home/ciri/.gvfs/SFTP for radar on 192.168.1.161/media/dataswap/huancayo/processed' | |||
45 | #pathFigure = 'C:\Users\jdk5273\Documents\LiClipseWorkspace' |
|
49 | #pathFigure = 'C:\Users\jdk5273\Documents\LiClipseWorkspace' | |
46 |
pathFigure='/home/ |
|
50 | pathFigure='/home/ciri/Pictures/ciri' | |
47 |
xmin = ' |
|
51 | xmin = '0' | |
48 |
xmax = ' |
|
52 | xmax = '24' | |
49 |
startTime = ' |
|
53 | startTime = '00:00:00' | |
|
54 | remotefolder = "/home/wmaster/graficos" | |||
50 |
|
55 | |||
51 | readUnitConfObj = controllerObj.addReadUnit(datatype='matoffReader', |
|
56 | readUnitConfObj = controllerObj.addReadUnit(datatype='matoffReader', | |
52 | path=path, |
|
57 | path=path, | |
53 |
startDate='2015/05/ |
|
58 | startDate='2015/05/30', | |
54 |
endDate='2015/05/ |
|
59 | endDate='2015/05/30', | |
55 | startTime=startTime, |
|
60 | startTime=startTime, | |
56 |
endTime=' |
|
61 | endTime='23:59:59', | |
57 |
online= |
|
62 | online=1, | |
58 | delay=5, |
|
63 | delay=5, | |
59 | walk=0) |
|
64 | walk=0) | |
60 |
|
65 | |||
61 | procUnitConfObj1 = controllerObj.addProcUnit(datatype='SpectraProc', inputId=readUnitConfObj.getId()) |
|
66 | procUnitConfObj1 = controllerObj.addProcUnit(datatype='SpectraProc', inputId=readUnitConfObj.getId()) | |
62 |
|
67 | |||
63 | # opObj14 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other') |
|
68 | # opObj14 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other') | |
64 | # opObj14.addParameter(name='id', value='1', format='int') |
|
69 | # opObj14.addParameter(name='id', value='1', format='int') | |
65 | # opObj14.addParameter(name='wintitle', value='Con interf', format='str') |
|
70 | # opObj14.addParameter(name='wintitle', value='Con interf', format='str') | |
66 | # opObj14.addParameter(name='save', value='0', format='bool') |
|
71 | # opObj14.addParameter(name='save', value='0', format='bool') | |
67 | # opObj14.addParameter(name='figpath', value=pathFigure, format='str') |
|
72 | # opObj14.addParameter(name='figpath', value=pathFigure, format='str') | |
68 |
|
73 | |||
69 | opObj11 = procUnitConfObj1.addOperation(name='IncohInt', optype='other') |
|
74 | opObj11 = procUnitConfObj1.addOperation(name='IncohInt', optype='other') | |
70 |
opObj11.addParameter(name='n', value=' |
|
75 | opObj11.addParameter(name='n', value='60', format='int') | |
71 |
|
76 | |||
72 | opObj14 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other') |
|
77 | opObj14 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other') | |
73 | opObj14.addParameter(name='id', value='2', format='int') |
|
78 | opObj14.addParameter(name='id', value='2', format='int') | |
74 | opObj14.addParameter(name='wintitle', value='Con interf', format='str') |
|
79 | opObj14.addParameter(name='wintitle', value='Con interf', format='str') | |
75 |
opObj14.addParameter(name='save', value=' |
|
80 | opObj14.addParameter(name='save', value='1', format='bool') | |
76 | opObj14.addParameter(name='figpath', value=pathFigure, format='str') |
|
81 | opObj14.addParameter(name='figpath', value=pathFigure, format='str') | |
77 |
|
|
82 | opObj14.addParameter(name='zmin', value='-30', format='int') | |
78 |
|
|
83 | opObj14.addParameter(name='zmax', value='0', format='int') | |
|
84 | opObj14.addParameter(name='exp_code', value='29', format='int') | |||
|
85 | opObj14.addParameter(name='wr_period', value='1', format='int') | |||
|
86 | opObj14.addParameter(name='save', value='1', format='int') | |||
|
87 | ||||
|
88 | opObj14.addParameter(name='ftp', value='1', format='int') | |||
79 |
|
89 | |||
80 | opObj14 = procUnitConfObj1.addOperation(name='CrossSpectraPlot', optype='other') |
|
90 | opObj14 = procUnitConfObj1.addOperation(name='CrossSpectraPlot', optype='other') | |
81 | opObj14.addParameter(name='id', value='4', format='int') |
|
91 | opObj14.addParameter(name='id', value='4', format='int') | |
82 | opObj14.addParameter(name='wintitle', value='Con interf', format='str') |
|
92 | opObj14.addParameter(name='wintitle', value='Con interf', format='str') | |
83 | opObj14.addParameter(name='phase_cmap', value='jet', format='str') |
|
93 | opObj14.addParameter(name='phase_cmap', value='jet', format='str') | |
84 |
opObj14.addParameter(name='save', value=' |
|
94 | opObj14.addParameter(name='save', value='1', format='bool') | |
85 | opObj14.addParameter(name='figpath', value=pathFigure, format='str') |
|
95 | opObj14.addParameter(name='figpath', value=pathFigure, format='str') | |
86 |
|
|
96 | opObj14.addParameter(name='zmin', value='-30', format='int') | |
87 |
|
|
97 | opObj14.addParameter(name='zmax', value='0', format='int') | |
|
98 | opObj14.addParameter(name='exp_code', value='29', format='int') | |||
|
99 | opObj14.addParameter(name='wr_period', value='1', format='int') | |||
|
100 | opObj14.addParameter(name='save', value='1', format='int') | |||
|
101 | ||||
|
102 | opObj14.addParameter(name='ftp', value='1', format='int') | |||
88 |
|
103 | |||
89 | opObj12 = procUnitConfObj1.addOperation(name='RTIPlot', optype='other') |
|
104 | opObj12 = procUnitConfObj1.addOperation(name='RTIPlot', optype='other') | |
90 | opObj12.addParameter(name='id', value='3', format='int') |
|
105 | opObj12.addParameter(name='id', value='3', format='int') | |
91 | opObj12.addParameter(name='wintitle', value='RTI Plot', format='str') |
|
106 | opObj12.addParameter(name='wintitle', value='RTI Plot', format='str') | |
92 | opObj12.addParameter(name='save', value='1', format='bool') |
|
107 | opObj12.addParameter(name='save', value='1', format='bool') | |
93 | opObj12.addParameter(name='figpath', value = pathFigure, format='str') |
|
108 | opObj12.addParameter(name='figpath', value = pathFigure, format='str') | |
94 | opObj12.addParameter(name='xmin', value=xmin, format='float') |
|
109 | opObj12.addParameter(name='xmin', value=xmin, format='float') | |
95 | opObj12.addParameter(name='xmax', value=xmax, format='float') |
|
110 | opObj12.addParameter(name='xmax', value=xmax, format='float') | |
96 |
|
|
111 | opObj12.addParameter(name='zmin', value='-30', format='int') | |
97 |
|
|
112 | opObj12.addParameter(name='zmax', value='0', format='int') | |
|
113 | opObj12.addParameter(name='exp_code', value='29', format='int') | |||
|
114 | opObj12.addParameter(name='wr_period', value='1', format='int') | |||
|
115 | opObj12.addParameter(name='save', value='1', format='int') | |||
|
116 | ||||
|
117 | opObj12.addParameter(name='ftp', value='1', format='int') | |||
|
118 | ||||
|
119 | # | |||
|
120 | procUnitConfObj2 = controllerObj.addProcUnit(name='SendToServer') | |||
|
121 | procUnitConfObj2.addParameter(name='server', value='jro-app.igp.gob.pe', format='str') | |||
|
122 | procUnitConfObj2.addParameter(name='username', value='wmaster', format='str') | |||
|
123 | procUnitConfObj2.addParameter(name='password', value='mst2010vhf', format='str') | |||
|
124 | procUnitConfObj2.addParameter(name='localfolder', value=pathFigure, format='str') | |||
|
125 | procUnitConfObj2.addParameter(name='remotefolder', value=remotefolder, format='str') | |||
|
126 | procUnitConfObj2.addParameter(name='ext', value='.png', format='str') | |||
|
127 | procUnitConfObj2.addParameter(name='period', value=5, format='int') | |||
|
128 | procUnitConfObj2.addParameter(name='protocol', value='ftp', format='str') | |||
|
129 | ||||
|
130 | ||||
|
131 | ||||
98 |
|
132 | |||
99 | #-------------------------------------------------------------------------------------------------- |
|
133 | #-------------------------------------------------------------------------------------------------- | |
100 | print "Escribiendo el archivo XML" |
|
134 | print "Escribiendo el archivo XML" | |
101 | controllerObj.writeXml(filename) |
|
135 | controllerObj.writeXml(filename) | |
102 | print "Leyendo el archivo XML" |
|
136 | print "Leyendo el archivo XML" | |
103 | controllerObj.readXml(filename) |
|
137 | controllerObj.readXml(filename) | |
104 |
|
138 | |||
105 | controllerObj.createObjects() |
|
139 | controllerObj.createObjects() | |
106 | controllerObj.connectObjects() |
|
140 | controllerObj.connectObjects() | |
107 | controllerObj.run() |
|
141 | controllerObj.run() | |
108 |
|
142 | |||
109 |
|
143 |
General Comments 0
You need to be logged in to leave comments.
Login now