@@ -1,248 +1,257 | |||
|
1 | 1 | #!python |
|
2 | 2 | ''' |
|
3 | 3 | ''' |
|
4 | 4 | |
|
5 | 5 | import os, sys |
|
6 | 6 | import datetime |
|
7 | 7 | import time |
|
8 | 8 | |
|
9 | 9 | #path = os.path.dirname(os.getcwd()) |
|
10 | 10 | #path = os.path.dirname(path) |
|
11 | 11 | #sys.path.insert(0, path) |
|
12 | 12 | |
|
13 | 13 | from schainpy.controller import Project |
|
14 | 14 | |
|
15 | 15 | desc = "USRP_test" |
|
16 | 16 | filename = "USRP_processing.xml" |
|
17 | 17 | controllerObj = Project() |
|
18 | 18 | controllerObj.setup(id = '191', name='Test_USRP', description=desc) |
|
19 | 19 | |
|
20 | 20 | ############## USED TO PLOT IQ VOLTAGE, POWER AND SPECTRA ############# |
|
21 | 21 | |
|
22 | 22 | ####################################################################### |
|
23 | 23 | ######PATH DE LECTURA, ESCRITURA, GRAFICOS Y ENVIO WEB################# |
|
24 | 24 | ####################################################################### |
|
25 | 25 | #path = '/media/data/data/vientos/57.2063km/echoes/NCO_Woodman' |
|
26 | 26 | #path = '/DATA_RM/TEST_INTEGRACION' |
|
27 | path = '/DATA_RM/TEST_ONLINE' | |
|
28 | figpath = '/home/soporte/Pictures/TEST_INTEGRACION_IMG' | |
|
27 | #path = '/DATA_RM/TEST_ONLINE' | |
|
28 | #path ="/DATA_RM/TEST_LU_21_10M/NOISE_LNA_ON_TX_OFF" | |
|
29 | #path ="/DATA_RM/TEST_LU_21_10M/NOISE_LNA_OFF_TX_OFF" | |
|
30 | path = "/DATA_RM/TEST_LU_21_10M/SIGNAL_LNA_ON_TX_ON" | |
|
31 | figpath = '/home/soporte/Pictures/TEST_LU_VI_10M_SIGNAL_LNA_ON_TX_ON_ZOOM' | |
|
29 | 32 | #remotefolder = "/home/wmaster/graficos" |
|
30 | 33 | ####################################################################### |
|
31 | 34 | ################# RANGO DE PLOTEO###################################### |
|
32 | 35 | ####################################################################### |
|
33 |
dBmin = ' |
|
|
34 |
dBmax = ' |
|
|
36 | dBmin = '20' | |
|
37 | dBmax = '60' | |
|
35 | 38 | xmin = '0' |
|
36 | 39 | xmax ='24' |
|
37 | 40 | ymin = '0' |
|
38 | 41 | ymax = '600' |
|
39 | 42 | ####################################################################### |
|
40 | 43 | ########################FECHA########################################## |
|
41 | 44 | ####################################################################### |
|
42 | 45 | str = datetime.date.today() |
|
43 | 46 | today = str.strftime("%Y/%m/%d") |
|
44 | 47 | str2 = str - datetime.timedelta(days=1) |
|
45 | 48 | yesterday = str2.strftime("%Y/%m/%d") |
|
46 | 49 | ####################################################################### |
|
47 | 50 | ######################## UNIDAD DE LECTURA############################# |
|
48 | 51 | ####################################################################### |
|
49 | 52 | readUnitConfObj = controllerObj.addReadUnit(datatype='DigitalRFReader', |
|
50 | 53 | path=path, |
|
51 |
startDate="202 |
|
|
52 |
endDate="202 |
|
|
54 | startDate="2022/03/21",#today, | |
|
55 | endDate="2022/03/21",#today, | |
|
53 | 56 | startTime='00:00:00', |
|
54 | 57 | endTime='23:59:59', |
|
55 | 58 | delay=0, |
|
56 | 59 | #set=0, |
|
57 | 60 | online=0, |
|
58 | 61 | walk=1, |
|
59 | 62 | ippKm = 60) |
|
60 | 63 | |
|
61 | 64 | opObj11 = readUnitConfObj.addOperation(name='printInfo') |
|
62 | 65 | #opObj11 = readUnitConfObj.addOperation(name='printNumberOfBlock') |
|
63 | 66 | ####################################################################### |
|
64 | 67 | ################ OPERACIONES DOMINIO DEL TIEMPO######################## |
|
65 | 68 | ####################################################################### |
|
66 | 69 | |
|
67 | 70 | procUnitConfObjA = controllerObj.addProcUnit(datatype='VoltageProc', inputId=readUnitConfObj.getId()) |
|
68 | 71 | # |
|
69 | 72 | # codigo64='1,1,1,0,1,1,0,1,1,1,1,0,0,0,1,0,1,1,1,0,1,1,0,1,0,0,0,1,1,1,0,1,1,1,1,0,1,1,0,1,1,1,1,0,0,0,1,0,0,0,0,1,0,0,1,0,1,1,1,0,0,0,1,0,'+\ |
|
70 | 73 | # '1,1,1,0,1,1,0,1,1,1,1,0,0,0,1,0,1,1,1,0,1,1,0,1,0,0,0,1,1,1,0,1,0,0,0,1,0,0,1,0,0,0,0,1,1,1,0,1,1,1,1,0,1,1,0,1,0,0,0,1,1,1,0,1' |
|
71 | 74 | |
|
72 | 75 | #opObj11 = procUnitConfObjA.addOperation(name='setRadarFrequency') |
|
73 | 76 | #opObj11.addParameter(name='frequency', value='70312500') |
|
77 | opObj11 = procUnitConfObjA.addOperation(name='selectHeights') | |
|
78 | opObj11.addParameter(name='minIndex', value='1', format='int') | |
|
79 | # opObj11.addParameter(name='maxIndex', value='10000', format='int') | |
|
80 | opObj11.addParameter(name='maxIndex', value='1000', format='int') | |
|
81 | ||
|
82 | ||
|
74 | 83 | |
|
75 | 84 | ''' |
|
76 | 85 | opObj11 = procUnitConfObjA.addOperation(name='PulsePair', optype='other') |
|
77 | 86 | opObj11.addParameter(name='n', value='625', format='int')#10 |
|
78 | 87 | opObj11.addParameter(name='removeDC', value=1, format='int') |
|
79 | 88 | ''' |
|
80 | 89 | |
|
81 | 90 | # Ploteo TEST |
|
82 | 91 | ''' |
|
83 | 92 | opObj11 = procUnitConfObjA.addOperation(name='PulsepairPowerPlot', optype='other') |
|
84 | 93 | opObj11 = procUnitConfObjA.addOperation(name='PulsepairSignalPlot', optype='other') |
|
85 | 94 | opObj11 = procUnitConfObjA.addOperation(name='PulsepairVelocityPlot', optype='other') |
|
86 | 95 | #opObj11.addParameter(name='xmax', value=8) |
|
87 | 96 | opObj11 = procUnitConfObjA.addOperation(name='PulsepairSpecwidthPlot', optype='other') |
|
88 | 97 | ''' |
|
89 | 98 | # OJO SCOPE |
|
90 | 99 | #opObj10 = procUnitConfObjA.addOperation(name='ScopePlot', optype='external') |
|
91 | 100 | #opObj10.addParameter(name='id', value='10', format='int') |
|
92 | 101 | ##opObj10.addParameter(name='xmin', value='0', format='int') |
|
93 | 102 | ##opObj10.addParameter(name='xmax', value='50', format='int') |
|
94 | 103 | #opObj10.addParameter(name='type', value='iq') |
|
95 | 104 | ##opObj10.addParameter(name='ymin', value='-5000', format='int') |
|
96 | 105 | ##opObj10.addParameter(name='ymax', value='8500', format='int') |
|
97 | 106 | #opObj11.addParameter(name='save', value=figpath, format='str') |
|
98 | 107 | #opObj11.addParameter(name='save_period', value=10, format='int') |
|
99 | 108 | |
|
100 | 109 | #opObj10 = procUnitConfObjA.addOperation(name='setH0') |
|
101 | 110 | #opObj10.addParameter(name='h0', value='-5000', format='float') |
|
102 | 111 | |
|
103 | 112 | #opObj11 = procUnitConfObjA.addOperation(name='filterByHeights') |
|
104 | 113 | #opObj11.addParameter(name='window', value='1', format='int') |
|
105 | 114 | |
|
106 | 115 | #codigo='1,1,-1,1,1,-1,1,-1,-1,1,-1,-1,-1,1,-1,-1,-1,1,-1,-1,-1,1,1,1,1,-1,-1,-1' |
|
107 | 116 | #opObj11 = procUnitConfObjSousy.addOperation(name='Decoder', optype='other') |
|
108 | 117 | #opObj11.addParameter(name='code', value=codigo, format='floatlist') |
|
109 | 118 | #opObj11.addParameter(name='nCode', value='1', format='int') |
|
110 | 119 | #opObj11.addParameter(name='nBaud', value='28', format='int') |
|
111 | 120 | |
|
112 | 121 | #opObj11 = procUnitConfObjA.addOperation(name='CohInt', optype='other') |
|
113 | 122 | #opObj11.addParameter(name='n', value='100', format='int') |
|
114 | 123 | |
|
115 | 124 | ####################################################################### |
|
116 | 125 | ########## OPERACIONES ParametersProc######################## |
|
117 | 126 | ####################################################################### |
|
118 | 127 | ###procUnitConfObjB= controllerObj.addProcUnit(datatype='ParametersProc',inputId=procUnitConfObjA.getId()) |
|
119 | 128 | ''' |
|
120 | 129 | |
|
121 | 130 | opObj11 = procUnitConfObjA.addOperation(name='PedestalInformation') |
|
122 | 131 | opObj11.addParameter(name='path_ped', value=path_ped) |
|
123 | 132 | opObj11.addParameter(name='path_adq', value=path_adq) |
|
124 | 133 | opObj11.addParameter(name='t_Interval_p', value='0.01', format='float') |
|
125 | 134 | opObj11.addParameter(name='n_Muestras_p', value='100', format='float') |
|
126 | 135 | opObj11.addParameter(name='blocksPerfile', value='100', format='int') |
|
127 | 136 | opObj11.addParameter(name='f_a_p', value='25', format='int') |
|
128 | 137 | opObj11.addParameter(name='online', value='0', format='int') |
|
129 | 138 | |
|
130 | 139 | opObj11 = procUnitConfObjA.addOperation(name='Block360') |
|
131 | 140 | opObj11.addParameter(name='n', value='40', format='int') |
|
132 | 141 | |
|
133 | 142 | opObj11= procUnitConfObjA.addOperation(name='WeatherPlot',optype='other') |
|
134 | 143 | opObj11.addParameter(name='save', value=figpath) |
|
135 | 144 | opObj11.addParameter(name='save_period', value=1) |
|
136 | 145 | |
|
137 | 146 | |
|
138 | 147 | ''' |
|
139 | 148 | |
|
140 | 149 | ####################################################################### |
|
141 | 150 | ########## OPERACIONES DOMINIO DE LA FRECUENCIA######################## |
|
142 | 151 | ####################################################################### |
|
143 | 152 | |
|
144 | 153 | procUnitConfObjB = controllerObj.addProcUnit(datatype='SpectraProc', inputId=procUnitConfObjA.getId()) |
|
145 | 154 | procUnitConfObjB.addParameter(name='nFFTPoints', value='32', format='int') |
|
146 | 155 | procUnitConfObjB.addParameter(name='nProfiles', value='32', format='int') |
|
147 | 156 | |
|
148 | procUnitConfObjC = controllerObj.addProcUnit(datatype='SpectraHeisProc', inputId=procUnitConfObjA.getId()) | |
|
157 | #procUnitConfObjC = controllerObj.addProcUnit(datatype='SpectraHeisProc', inputId=procUnitConfObjA.getId()) | |
|
149 | 158 | #procUnitConfObjB.addParameter(name='nFFTPoints', value='64', format='int') |
|
150 | 159 | #procUnitConfObjB.addParameter(name='nProfiles', value='64', format='int') |
|
151 | opObj11 = procUnitConfObjC.addOperation(name='IncohInt4SpectraHeis', optype='other') | |
|
152 | opObj11.addParameter(name='timeInterval', value='8', format='int') | |
|
160 | #opObj11 = procUnitConfObjC.addOperation(name='IncohInt4SpectraHeis', optype='other') | |
|
161 | #opObj11.addParameter(name='timeInterval', value='8', format='int') | |
|
153 | 162 | |
|
154 | 163 | |
|
155 | 164 | #procUnitConfObjB.addParameter(name='pairsList', value='(0,0),(1,1),(0,1)', format='pairsList') |
|
156 | 165 | |
|
157 | 166 | #opObj13 = procUnitConfObjB.addOperation(name='removeDC') |
|
158 | 167 | #opObj13.addParameter(name='mode', value='2', format='int') |
|
159 | 168 | |
|
160 | opObj11 = procUnitConfObjB.addOperation(name='IncohInt', optype='other') | |
|
161 | opObj11.addParameter(name='n', value='8', format='float') | |
|
169 | #opObj11 = procUnitConfObjB.addOperation(name='IncohInt', optype='other') | |
|
170 | #opObj11.addParameter(name='n', value='8', format='float') | |
|
162 | 171 | ####################################################################### |
|
163 | 172 | ########## PLOTEO DOMINIO DE LA FRECUENCIA############################# |
|
164 | 173 | ####################################################################### |
|
165 | 174 | #---- |
|
166 | ||
|
175 | """ | |
|
167 | 176 | opObj11 = procUnitConfObjC.addOperation(name='SpectraHeisPlot') |
|
168 | 177 | opObj11.addParameter(name='id', value='10', format='int') |
|
169 | 178 | opObj11.addParameter(name='wintitle', value='Spectra_Alturas', format='str') |
|
170 | 179 |
|
|
171 | 180 |
|
|
172 | 181 |
|
|
173 | 182 |
|
|
174 | 183 | opObj11.addParameter(name='ymin', value=-20, format='int') |
|
175 | 184 | opObj11.addParameter(name='ymax', value=50, format='int') |
|
176 | 185 | opObj11.addParameter(name='showprofile', value='1', format='int') |
|
177 | 186 | opObj11.addParameter(name='save', value=figpath, format='str') |
|
178 | 187 | opObj11.addParameter(name='save_period', value=10, format='int') |
|
179 | ||
|
188 | """ | |
|
180 | 189 | |
|
181 | 190 | #SpectraPlot |
|
182 | 191 | |
|
183 | 192 | opObj11 = procUnitConfObjB.addOperation(name='SpectraPlot', optype='external') |
|
184 | 193 | opObj11.addParameter(name='id', value='1', format='int') |
|
185 | 194 | opObj11.addParameter(name='wintitle', value='Spectra', format='str') |
|
186 | 195 | #opObj11.addParameter(name='xmin', value=-0.01, format='float') |
|
187 | 196 | #opObj11.addParameter(name='xmax', value=0.01, format='float') |
|
188 | 197 | opObj11.addParameter(name='zmin', value=dBmin, format='int') |
|
189 | 198 | opObj11.addParameter(name='zmax', value=dBmax, format='int') |
|
190 | 199 | #opObj11.addParameter(name='ymin', value=ymin, format='int') |
|
191 | 200 | #opObj11.addParameter(name='ymax', value=ymax, format='int') |
|
192 | 201 | opObj11.addParameter(name='showprofile', value='1', format='int') |
|
193 | 202 | opObj11.addParameter(name='save', value=figpath, format='str') |
|
194 | 203 | opObj11.addParameter(name='save_period', value=10, format='int') |
|
195 | 204 | |
|
196 | 205 | #RTIPLOT |
|
197 | 206 | |
|
198 | 207 | opObj11 = procUnitConfObjB.addOperation(name='RTIPlot', optype='external') |
|
199 | 208 | opObj11.addParameter(name='id', value='2', format='int') |
|
200 | 209 | opObj11.addParameter(name='wintitle', value='RTIPlot', format='str') |
|
201 | 210 | opObj11.addParameter(name='zmin', value=dBmin, format='int') |
|
202 | 211 | opObj11.addParameter(name='zmax', value=dBmax, format='int') |
|
203 | 212 | #opObj11.addParameter(name='ymin', value=ymin, format='int') |
|
204 | 213 | #opObj11.addParameter(name='ymax', value=ymax, format='int') |
|
205 | 214 | #opObj11.addParameter(name='xmin', value=15, format='int') |
|
206 | 215 | #opObj11.addParameter(name='xmax', value=16, format='int') |
|
207 | 216 | |
|
208 | 217 | opObj11.addParameter(name='showprofile', value='1', format='int') |
|
209 | 218 | opObj11.addParameter(name='save', value=figpath, format='str') |
|
210 | 219 | opObj11.addParameter(name='save_period', value=10, format='int') |
|
211 | 220 | |
|
212 | 221 | |
|
213 | 222 | # opObj11 = procUnitConfObjB.addOperation(name='CrossSpectraPlot', optype='other') |
|
214 | 223 | # opObj11.addParameter(name='id', value='3', format='int') |
|
215 | 224 | # opObj11.addParameter(name='wintitle', value='CrossSpectraPlot', format='str') |
|
216 | 225 | # opObj11.addParameter(name='ymin', value=ymin, format='int') |
|
217 | 226 | # opObj11.addParameter(name='ymax', value=ymax, format='int') |
|
218 | 227 | # opObj11.addParameter(name='phase_cmap', value='jet', format='str') |
|
219 | 228 | # opObj11.addParameter(name='zmin', value=dBmin, format='int') |
|
220 | 229 | # opObj11.addParameter(name='zmax', value=dBmax, format='int') |
|
221 | 230 | # opObj11.addParameter(name='figpath', value=figures_path, format='str') |
|
222 | 231 | # opObj11.addParameter(name='save', value=0, format='bool') |
|
223 | 232 | # opObj11.addParameter(name='pairsList', value='(0,1)', format='pairsList') |
|
224 | 233 | # # |
|
225 | 234 | # opObj11 = procUnitConfObjB.addOperation(name='CoherenceMap', optype='other') |
|
226 | 235 | # opObj11.addParameter(name='id', value='4', format='int') |
|
227 | 236 | # opObj11.addParameter(name='wintitle', value='Coherence', format='str') |
|
228 | 237 | # opObj11.addParameter(name='phase_cmap', value='jet', format='str') |
|
229 | 238 | # opObj11.addParameter(name='xmin', value=xmin, format='float') |
|
230 | 239 | # opObj11.addParameter(name='xmax', value=xmax, format='float') |
|
231 | 240 | # opObj11.addParameter(name='figpath', value=figures_path, format='str') |
|
232 | 241 | # opObj11.addParameter(name='save', value=0, format='bool') |
|
233 | 242 | # opObj11.addParameter(name='pairsList', value='(0,1)', format='pairsList') |
|
234 | 243 | # |
|
235 | 244 | |
|
236 | 245 | ''' |
|
237 | 246 | ####################################################################### |
|
238 | 247 | ############### UNIDAD DE ESCRITURA ################################### |
|
239 | 248 | ####################################################################### |
|
240 | 249 | #opObj11 = procUnitConfObjB.addOperation(name='SpectraWriter', optype='other') |
|
241 | 250 | #opObj11.addParameter(name='path', value=wr_path) |
|
242 | 251 | #opObj11.addParameter(name='blocksPerFile', value='50', format='int') |
|
243 | 252 | print ("Escribiendo el archivo XML") |
|
244 | 253 | print ("Leyendo el archivo XML") |
|
245 | 254 | ''' |
|
246 | 255 | |
|
247 | 256 | |
|
248 | 257 | controllerObj.start() |
General Comments 0
You need to be logged in to leave comments.
Login now