SpectraProcessor.py
553 lines
| 17.6 KiB
| text/x-python
|
PythonLexer
Miguel Valdez
|
r10 | ''' | ||
| Created on Feb 7, 2012 | ||||
Daniel Valdez
|
r16 | @author $Author$ | ||
| @version $Id$ | ||||
|
Miguel Valdez
|
r10 | ''' | ||
|
Daniel Valdez
|
r72 | import os, sys | ||
| import numpy | ||||
| path = os.path.split(os.getcwd())[0] | ||||
| sys.path.append(path) | ||||
| from Model.Spectra import Spectra | ||||
| from IO.SpectraIO import SpectraWriter | ||||
| from Graphics.SpectraPlot import Spectrum | ||||
|
Miguel Valdez
|
r10 | |||
| class SpectraProcessor: | ||||
| ''' | ||||
| classdocs | ||||
| ''' | ||||
|
Daniel Valdez
|
r72 | |||
|
Miguel Valdez
|
r99 | dataInObj = None | ||
| dataOutObj = None | ||||
| integratorObjIndex = None | ||||
| decoderObjIndex = None | ||||
| writerObjIndex = None | ||||
| plotterObjIndex = None | ||||
| integratorObjList = [] | ||||
| decoderObjList = [] | ||||
| writerObjList = [] | ||||
| plotterObjList = [] | ||||
| buffer = None | ||||
| ptsId = 0 | ||||
| nFFTPoints = None | ||||
| pairList = None | ||||
| m_Spectra= Spectra() | ||||
| m_Voltage= Voltage() | ||||
| m_IncoherentIntegration= IncoherentIntegration() | ||||
Victor Sarmiento
|
r85 | def __init__(self, dataInObj, dataOutObj=None): | ||
|
Miguel Valdez
|
r10 | ''' | ||
| Constructor | ||||
| ''' | ||||
|
Victor Sarmiento
|
r85 | self.dataInObj = dataInObj | ||
|
Daniel Valdez
|
r72 | |||
|
Victor Sarmiento
|
r85 | if dataOutObj == None: | ||
| self.dataOutObj = Spectra() | ||||
|
Daniel Valdez
|
r72 | else: | ||
|
Victor Sarmiento
|
r85 | self.dataOutObj = dataOutObj | ||
|
Daniel Valdez
|
r72 | |||
|
Miguel Valdez
|
r99 | self.integratorObjIndex = None | ||
| self.decoderObjIndex = None | ||||
| self.writerObjIndex = None | ||||
| self.plotterObjIndex = None | ||||
|
Daniel Valdez
|
r72 | |||
|
Miguel Valdez
|
r99 | self.integratorObjList = [] | ||
| self.decoderObjList = [] | ||||
| self.writerObjList = [] | ||||
| self.plotterObjList = [] | ||||
|
Daniel Valdez
|
r72 | |||
| self.buffer = None | ||||
| self.ptsId = 0 | ||||
|
Victor Sarmiento
|
r85 | def init(self, nFFTPoints, pairList=None): | ||
|
Miguel Valdez
|
r99 | self.integratorObjIndex = 0 | ||
| self.decoderObjIndex = 0 | ||||
| self.writerObjIndex = 0 | ||||
| self.plotterObjIndex = 0 | ||||
|
Daniel Valdez
|
r72 | |||
|
Victor Sarmiento
|
r85 | if nFFTPoints == None: | ||
|
Miguel Valdez
|
r89 | nFFTPoints = self.dataOutObj.nFFTPoints | ||
|
Victor Sarmiento
|
r85 | |||
| self.nFFTPoints = nFFTPoints | ||||
| self.pairList = pairList | ||||
| if not( isinstance(self.dataInObj, Spectra) ): | ||||
| self.__getFft() | ||||
|
Daniel Valdez
|
r72 | else: | ||
|
Victor Sarmiento
|
r85 | self.dataOutObj.copy(self.dataInObj) | ||
|
Daniel Valdez
|
r72 | |||
|
Victor Sarmiento
|
r85 | def __getFft(self): | ||
| """ | ||||
| Convierte valores de Voltaje a Spectra | ||||
| Affected: | ||||
| self.dataOutObj.data_spc | ||||
| self.dataOutObj.data_cspc | ||||
| self.dataOutObj.data_dc | ||||
| self.dataOutObj.heightList | ||||
| self.dataOutObj.m_BasicHeader | ||||
| self.dataOutObj.m_ProcessingHeader | ||||
| self.dataOutObj.m_RadarControllerHeader | ||||
| self.dataOutObj.m_SystemHeader | ||||
| self.ptsId | ||||
| self.buffer | ||||
| self.dataOutObj.flagNoData | ||||
| self.dataOutObj.dataType | ||||
| self.dataOutObj.nPairs | ||||
| self.dataOutObj.nChannels | ||||
| self.dataOutObj.nProfiles | ||||
| self.dataOutObj.m_SystemHeader.numChannels | ||||
| self.dataOutObj.m_ProcessingHeader.totalSpectra | ||||
| self.dataOutObj.m_ProcessingHeader.profilesPerBlock | ||||
| self.dataOutObj.m_ProcessingHeader.numHeights | ||||
| self.dataOutObj.m_ProcessingHeader.spectraComb | ||||
| self.dataOutObj.m_ProcessingHeader.shif_fft | ||||
| """ | ||||
| blocksize = 0 | ||||
|
Miguel Valdez
|
r89 | nFFTPoints = self.nFFTPoints | ||
| nChannels, nheis = self.dataInObj.data.shape | ||||
|
Daniel Valdez
|
r72 | |||
| if self.buffer == None: | ||||
|
Miguel Valdez
|
r89 | self.buffer = numpy.zeros((nChannels, nFFTPoints, nheis), dtype='complex') | ||
|
Daniel Valdez
|
r73 | |||
|
Victor Sarmiento
|
r85 | self.buffer[:,self.ptsId,:] = self.dataInObj.data | ||
|
Daniel Valdez
|
r72 | self.ptsId += 1 | ||
|
Miguel Valdez
|
r89 | if self.ptsId < self.dataOutObj.nFFTPoints: | ||
|
Victor Sarmiento
|
r85 | self.dataOutObj.flagNoData = True | ||
| return | ||||
|
Daniel Valdez
|
r72 | |||
|
Victor Sarmiento
|
r85 | fft_volt = numpy.fft.fft(self.buffer,axis=1) | ||
| dc = fft_volt[:,0,:] | ||||
| #calculo de self-spectra | ||||
| fft_volt = numpy.fft.fftshift(fft_volt,axes=(1,)) | ||||
| spc = numpy.abs(fft_volt * numpy.conjugate(fft_volt)) | ||||
| blocksize += dc.size | ||||
| blocksize += spc.size | ||||
| cspc = None | ||||
|
Miguel Valdez
|
r89 | nPair = 0 | ||
|
Victor Sarmiento
|
r85 | if self.pairList != None: | ||
|
Daniel Valdez
|
r72 | #calculo de cross-spectra | ||
|
Miguel Valdez
|
r89 | nPairs = len(self.pairList) | ||
| cspc = numpy.zeros((nPairs, nFFTPoints, nheis), dtype='complex') | ||||
|
Victor Sarmiento
|
r85 | for pair in self.pairList: | ||
|
Miguel Valdez
|
r89 | cspc[nPair,:,:] = numpy.abs(fft_volt[pair[0],:,:] * numpy.conjugate(fft_volt[pair[1],:,:])) | ||
| nPair += 1 | ||||
|
Victor Sarmiento
|
r85 | blocksize += cspc.size | ||
| self.dataOutObj.data_spc = spc | ||||
| self.dataOutObj.data_cspc = cspc | ||||
| self.dataOutObj.data_dc = dc | ||||
| self.ptsId = 0 | ||||
| self.buffer = None | ||||
| self.dataOutObj.flagNoData = False | ||||
| self.dataOutObj.heightList = self.dataInObj.heightList | ||||
| self.dataOutObj.channelList = self.dataInObj.channelList | ||||
| self.dataOutObj.m_BasicHeader = self.dataInObj.m_BasicHeader.copy() | ||||
| self.dataOutObj.m_ProcessingHeader = self.dataInObj.m_ProcessingHeader.copy() | ||||
| self.dataOutObj.m_RadarControllerHeader = self.dataInObj.m_RadarControllerHeader.copy() | ||||
| self.dataOutObj.m_SystemHeader = self.dataInObj.m_SystemHeader.copy() | ||||
| self.dataOutObj.dataType = self.dataInObj.dataType | ||||
|
Miguel Valdez
|
r89 | self.dataOutObj.nPairs = nPair | ||
| self.dataOutObj.nChannels = nChannels | ||||
| self.dataOutObj.nProfiles = nFFTPoints | ||||
|
Victor Sarmiento
|
r85 | self.dataOutObj.nHeights = nheis | ||
|
Miguel Valdez
|
r89 | self.dataOutObj.nFFTPoints = nFFTPoints | ||
|
Victor Sarmiento
|
r85 | #self.dataOutObj.data = None | ||
|
Miguel Valdez
|
r89 | self.dataOutObj.m_SystemHeader.numChannels = nChannels | ||
| self.dataOutObj.m_SystemHeader.nProfiles = nFFTPoints | ||||
|
Victor Sarmiento
|
r85 | |||
| self.dataOutObj.m_ProcessingHeader.blockSize = blocksize | ||||
|
Miguel Valdez
|
r89 | self.dataOutObj.m_ProcessingHeader.totalSpectra = nChannels + nPair | ||
| self.dataOutObj.m_ProcessingHeader.profilesPerBlock = nFFTPoints | ||||
|
Victor Sarmiento
|
r85 | self.dataOutObj.m_ProcessingHeader.numHeights = nheis | ||
| self.dataOutObj.m_ProcessingHeader.shif_fft = True | ||||
|
Miguel Valdez
|
r89 | spectraComb = numpy.zeros( (nChannels+nPair)*2,numpy.dtype('u1')) | ||
|
Victor Sarmiento
|
r85 | k = 0 | ||
|
Miguel Valdez
|
r89 | for i in range( 0,nChannels*2,2 ): | ||
|
Victor Sarmiento
|
r85 | spectraComb[i] = k | ||
| spectraComb[i+1] = k | ||||
| k += 1 | ||||
| k *= 2 | ||||
| if self.pairList != None: | ||||
|
Daniel Valdez
|
r72 | |||
|
Victor Sarmiento
|
r85 | for pair in self.pairList: | ||
| spectraComb[k] = pair[0] | ||||
| spectraComb[k+1] = pair[1] | ||||
| k += 2 | ||||
|
Daniel Valdez
|
r72 | |||
|
Victor Sarmiento
|
r85 | self.dataOutObj.m_ProcessingHeader.spectraComb = spectraComb | ||
|
Daniel Valdez
|
r73 | |||
|
Daniel Valdez
|
r72 | def addWriter(self,wrpath): | ||
|
Victor Sarmiento
|
r85 | objWriter = SpectraWriter(self.dataOutObj) | ||
|
Daniel Valdez
|
r72 | objWriter.setup(wrpath) | ||
|
Miguel Valdez
|
r99 | self.writerObjList.append(objWriter) | ||
|
Daniel Valdez
|
r72 | |||
|
Daniel Valdez
|
r73 | def addPlotter(self, index=None): | ||
| if index==None: | ||||
|
Miguel Valdez
|
r99 | index = self.plotterObjIndex | ||
|
Daniel Valdez
|
r72 | |||
|
Victor Sarmiento
|
r85 | plotObj = Spectrum(self.dataOutObj, index) | ||
|
Miguel Valdez
|
r99 | self.plotterObjList.append(plotObj) | ||
|
Daniel Valdez
|
r72 | |||
| def addIntegrator(self,N): | ||||
| objIncohInt = IncoherentIntegration(N) | ||||
|
Miguel Valdez
|
r99 | self.integratorObjList.append(objIncohInt) | ||
|
Daniel Valdez
|
r72 | |||
|
Victor Sarmiento
|
r85 | def writeData(self, wrpath): | ||
| if self.dataOutObj.flagNoData: | ||||
|
Daniel Valdez
|
r72 | return 0 | ||
|
Miguel Valdez
|
r99 | if len(self.writerObjList) <= self.writerObjIndex: | ||
|
Daniel Valdez
|
r72 | self.addWriter(wrpath) | ||
|
Miguel Valdez
|
r99 | self.writerObjList[self.writerObjIndex].putData() | ||
|
Daniel Valdez
|
r72 | |||
|
Miguel Valdez
|
r99 | self.writerObjIndex += 1 | ||
|
Daniel Valdez
|
r72 | |||
|
Daniel Valdez
|
r73 | def plotData(self,xmin=None, xmax=None, ymin=None, ymax=None, winTitle='', index=None): | ||
|
Victor Sarmiento
|
r85 | if self.dataOutObj.flagNoData: | ||
|
Daniel Valdez
|
r72 | return 0 | ||
|
Miguel Valdez
|
r99 | if len(self.plotterObjList) <= self.plotterObjIndex: | ||
|
Daniel Valdez
|
r73 | self.addPlotter(index) | ||
|
Daniel Valdez
|
r72 | |||
|
Miguel Valdez
|
r99 | self.plotterObjList[self.plotterObjIndex].plotData(xmin=xmin, xmax=xmax, ymin=ymin, ymax=ymax,winTitle=winTitle) | ||
|
Daniel Valdez
|
r72 | |||
|
Miguel Valdez
|
r99 | self.plotterObjIndex += 1 | ||
|
Daniel Valdez
|
r72 | |||
| def integrator(self, N): | ||||
|
Victor Sarmiento
|
r85 | if self.dataOutObj.flagNoData: | ||
|
Daniel Valdez
|
r72 | return 0 | ||
|
Miguel Valdez
|
r99 | if len(self.integratorObjList) <= self.integratorObjIndex: | ||
|
Daniel Valdez
|
r72 | self.addIntegrator(N) | ||
|
Miguel Valdez
|
r99 | myCohIntObj = self.integratorObjList[self.integratorObjIndex] | ||
|
Victor Sarmiento
|
r85 | myCohIntObj.exe(self.dataOutObj.data_spc) | ||
|
Daniel Valdez
|
r72 | |||
| if myCohIntObj.flag: | ||||
|
Victor Sarmiento
|
r85 | self.dataOutObj.data_spc = myCohIntObj.data | ||
| self.dataOutObj.m_ProcessingHeader.incoherentInt *= N | ||||
| self.dataOutObj.flagNoData = False | ||||
|
Daniel Valdez
|
r72 | |||
| else: | ||||
|
Victor Sarmiento
|
r85 | self.dataOutObj.flagNoData = True | ||
|
Daniel Valdez
|
r72 | |||
|
Miguel Valdez
|
r99 | self.integratorObjIndex += 1 | ||
|
Victor Sarmiento
|
r85 | |||
| def removeDC(self, type): | ||||
| if self.dataOutObj.flagNoData: | ||||
| return 0 | ||||
| pass | ||||
| def removeInterference(self): | ||||
| if self.dataOutObj.flagNoData: | ||||
| return 0 | ||||
| pass | ||||
| def removeSatellites(self): | ||||
| if self.dataOutObj.flagNoData: | ||||
| return 0 | ||||
| pass | ||||
| def selectChannels(self, channelList, pairList=None): | ||||
| """ | ||||
| Selecciona un bloque de datos en base a canales y pares segun el channelList y el pairList | ||||
| Input: | ||||
| channelList : lista sencilla de canales a seleccionar por ej. (2,3,7) | ||||
| pairList : tupla de pares que se desea selecionar por ej. ( (0,1), (0,2) ) | ||||
| Affected: | ||||
| self.dataOutObj.data_spc | ||||
| self.dataOutObj.data_cspc | ||||
| self.dataOutObj.data_dc | ||||
| self.dataOutObj.nChannels | ||||
| self.dataOutObj.nPairs | ||||
| self.dataOutObj.m_ProcessingHeader.spectraComb | ||||
| self.dataOutObj.m_SystemHeader.numChannels | ||||
| Return: | ||||
| None | ||||
| """ | ||||
| if self.dataOutObj.flagNoData: | ||||
| return 0 | ||||
|
Victor Sarmiento
|
r96 | channelIndexList = [] | ||
| for channel in channelList: | ||||
| if channel in self.dataOutObj.channelList: | ||||
| index = self.dataOutObj.channelList.index(channel) | ||||
| channelIndexList.append(index) | ||||
| continue | ||||
| raise ValueError, "The value %d in channelList is not valid" %channel | ||||
|
Miguel Valdez
|
r89 | nProfiles = self.dataOutObj.nProfiles | ||
|
Victor Sarmiento
|
r96 | #dataType = self.dataOutObj.dataType | ||
| nHeights = self.dataOutObj.nHeights #m_ProcessingHeader.numHeights | ||||
|
Victor Sarmiento
|
r85 | blocksize = 0 | ||
| #self spectra | ||||
|
Victor Sarmiento
|
r96 | nChannels = len(channelIndexList) | ||
| spc = numpy.zeros( (nChannels,nProfiles,nHeights), dtype='float' ) #dataType[0] ) | ||||
|
Daniel Valdez
|
r72 | |||
|
Victor Sarmiento
|
r96 | for index, channel in enumerate(channelIndexList): | ||
| spc[index,:,:] = self.dataOutObj.data_spc[index,:,:] | ||||
|
Victor Sarmiento
|
r85 | |||
| #DC channel | ||||
|
Miguel Valdez
|
r89 | dc = numpy.zeros( (nChannels,nHeights), dtype='complex' ) | ||
|
Victor Sarmiento
|
r96 | for index, channel in enumerate(channelIndexList): | ||
|
Victor Sarmiento
|
r85 | dc[index,:] = self.dataOutObj.data_dc[channel,:] | ||
| blocksize += dc.size | ||||
| blocksize += spc.size | ||||
|
Miguel Valdez
|
r89 | nPairs = 0 | ||
|
Victor Sarmiento
|
r85 | cspc = None | ||
| if pairList == None: | ||||
| pairList = self.pairList | ||||
|
Victor Sarmiento
|
r96 | if (pairList != None) and (self.dataOutObj.data_cspc != None): | ||
|
Victor Sarmiento
|
r85 | #cross spectra | ||
|
Miguel Valdez
|
r89 | nPairs = len(pairList) | ||
| cspc = numpy.zeros( (nPairs,nProfiles,nHeights), dtype='complex' ) | ||||
|
Victor Sarmiento
|
r85 | |||
| spectraComb = self.dataOutObj.m_ProcessingHeader.spectraComb | ||||
| totalSpectra = len(spectraComb) | ||||
| nchan = self.dataOutObj.nChannels | ||||
|
Victor Sarmiento
|
r96 | pairIndexList = [] | ||
|
Victor Sarmiento
|
r85 | |||
| for pair in pairList: #busco el par en la lista de pares del Spectra Combinations | ||||
| for index in range(0,totalSpectra,2): | ||||
| if pair[0] == spectraComb[index] and pair[1] == spectraComb[index+1]: | ||||
|
Victor Sarmiento
|
r96 | pairIndexList.append( index/2 - nchan ) | ||
|
Victor Sarmiento
|
r85 | |||
|
Victor Sarmiento
|
r96 | for index, pair in enumerate(pairIndexList): | ||
|
Victor Sarmiento
|
r85 | cspc[index,:,:] = self.dataOutObj.data_cspc[pair,:,:] | ||
| blocksize += cspc.size | ||||
| else: | ||||
| pairList = self.pairList | ||||
| cspc = self.dataOutObj.data_cspc | ||||
| if cspc != None: | ||||
| blocksize += cspc.size | ||||
|
Miguel Valdez
|
r89 | spectraComb = numpy.zeros( (nChannels+nPairs)*2,numpy.dtype('u1')) | ||
|
Victor Sarmiento
|
r85 | i = 0 | ||
| for val in channelList: | ||||
| spectraComb[i] = val | ||||
| spectraComb[i+1] = val | ||||
| i += 2 | ||||
| if pairList != None: | ||||
| for pair in pairList: | ||||
| spectraComb[i] = pair[0] | ||||
| spectraComb[i+1] = pair[1] | ||||
| i += 2 | ||||
| self.dataOutObj.data_spc = spc | ||||
| self.dataOutObj.data_cspc = cspc | ||||
| self.dataOutObj.data_dc = dc | ||||
|
Miguel Valdez
|
r89 | self.dataOutObj.nChannels = nChannels | ||
| self.dataOutObj.nPairs = nPairs | ||||
|
Victor Sarmiento
|
r85 | |||
| self.dataOutObj.channelList = channelList | ||||
| self.dataOutObj.m_ProcessingHeader.spectraComb = spectraComb | ||||
|
Miguel Valdez
|
r89 | self.dataOutObj.m_ProcessingHeader.totalSpectra = nChannels + nPairs | ||
| self.dataOutObj.m_SystemHeader.numChannels = nChannels | ||||
| self.dataOutObj.nChannels = nChannels | ||||
|
Victor Sarmiento
|
r85 | self.dataOutObj.m_ProcessingHeader.blockSize = blocksize | ||
| def selectHeightsByValue(self, minHei, maxHei): | ||||
| """ | ||||
| Selecciona un bloque de datos en base a un grupo de valores de alturas segun el rango | ||||
| minHei <= height <= maxHei | ||||
| Input: | ||||
| minHei : valor minimo de altura a considerar | ||||
| maxHei : valor maximo de altura a considerar | ||||
| Affected: | ||||
| Indirectamente son cambiados varios valores a travez del metodo selectHeightsByIndex | ||||
| Return: | ||||
| None | ||||
| """ | ||||
| if self.dataOutObj.flagNoData: | ||||
| return 0 | ||||
|
Victor Sarmiento
|
r96 | if (minHei < self.dataOutObj.heightList[0]) or (minHei > maxHei): | ||
| raise ValueError, "some value in (%d,%d) is not valid" % (minHei, maxHei) | ||||
| if (maxHei > self.dataOutObj.heightList[-1]): | ||||
| raise ValueError, "some value in (%d,%d) is not valid" % (minHei, maxHei) | ||||
|
Victor Sarmiento
|
r85 | minIndex = 0 | ||
| maxIndex = 0 | ||||
| data = self.dataOutObj.heightList | ||||
| for i,val in enumerate(data): | ||||
| if val < minHei: | ||||
| continue | ||||
| else: | ||||
| minIndex = i; | ||||
| break | ||||
| for i,val in enumerate(data): | ||||
| if val <= maxHei: | ||||
| maxIndex = i; | ||||
| else: | ||||
| break | ||||
| self.selectHeightsByIndex(minIndex, maxIndex) | ||||
| def selectHeightsByIndex(self, minIndex, maxIndex): | ||||
| """ | ||||
| Selecciona un bloque de datos en base a un grupo indices de alturas segun el rango | ||||
| minIndex <= index <= maxIndex | ||||
| Input: | ||||
| minIndex : valor minimo de altura a considerar | ||||
| maxIndex : valor maximo de altura a considerar | ||||
| Affected: | ||||
| self.dataOutObj.data_spc | ||||
| self.dataOutObj.data_cspc | ||||
| self.dataOutObj.data_dc | ||||
| self.dataOutObj.heightList | ||||
| self.dataOutObj.nHeights | ||||
| self.dataOutObj.m_ProcessingHeader.numHeights | ||||
| self.dataOutObj.m_ProcessingHeader.blockSize | ||||
| self.dataOutObj.m_ProcessingHeader.firstHeight | ||||
| self.dataOutObj.m_RadarControllerHeader.numHeights | ||||
| Return: | ||||
| None | ||||
| """ | ||||
| if self.dataOutObj.flagNoData: | ||||
| return 0 | ||||
|
Victor Sarmiento
|
r96 | if (minIndex < 0) or (minIndex > maxIndex): | ||
| raise ValueError, "some value in (%d,%d) is not valid" % (minIndex, maxIndex) | ||||
| if (maxIndex >= self.dataOutObj.nHeights): | ||||
| raise ValueError, "some value in (%d,%d) is not valid" % (minIndex, maxIndex) | ||||
|
Miguel Valdez
|
r89 | nChannels = self.dataOutObj.nChannels | ||
| nPairs = self.dataOutObj.nPairs | ||||
| nProfiles = self.dataOutObj.nProfiles | ||||
|
Victor Sarmiento
|
r85 | dataType = self.dataOutObj.dataType | ||
|
Victor Sarmiento
|
r96 | nHeights = maxIndex - minIndex + 1 | ||
|
Victor Sarmiento
|
r85 | blockSize = 0 | ||
| #self spectra | ||||
|
Victor Sarmiento
|
r96 | spc = self.dataOutObj.data_spc[:,:,minIndex:maxIndex+1] | ||
| blockSize += spc.size | ||||
|
Victor Sarmiento
|
r85 | |||
| #cross spectra | ||||
|
Victor Sarmiento
|
r96 | cspc = None | ||
| if self.dataOutObj.data_cspc != None: | ||||
| cspc = self.dataOutObj.data_cspc[:,:,minIndex:maxIndex+1] | ||||
| blockSize += cspc.size | ||||
|
Victor Sarmiento
|
r85 | |||
| #DC channel | ||||
|
Victor Sarmiento
|
r96 | dc = self.dataOutObj.data_dc[:,minIndex:maxIndex+1] | ||
| blockSize += dc.size | ||||
|
Victor Sarmiento
|
r85 | |||
| self.dataOutObj.data_spc = spc | ||||
|
Victor Sarmiento
|
r96 | if cspc != None: | ||
| self.dataOutObj.data_cspc = cspc | ||||
|
Victor Sarmiento
|
r85 | self.dataOutObj.data_dc = dc | ||
| firstHeight = self.dataOutObj.heightList[minIndex] | ||||
|
Victor Sarmiento
|
r96 | self.dataOutObj.nHeights = nHeights | ||
| self.dataOutObj.m_ProcessingHeader.blockSize = blockSize | ||||
| self.dataOutObj.m_ProcessingHeader.numHeights = nHeights | ||||
|
Victor Sarmiento
|
r85 | self.dataOutObj.m_ProcessingHeader.firstHeight = firstHeight | ||
|
Victor Sarmiento
|
r96 | self.dataOutObj.m_RadarControllerHeader.numHeights = nHeights | ||
|
Victor Sarmiento
|
r85 | |||
|
Victor Sarmiento
|
r96 | self.dataOutObj.heightList = self.dataOutObj.heightList[minIndex:maxIndex+1] | ||
|
Victor Sarmiento
|
r85 | |||
|
Daniel Valdez
|
r72 | class IncoherentIntegration: | ||
|
Miguel Valdez
|
r99 | |||
| profCounter = 1 | ||||
| data = None | ||||
| buffer = None | ||||
| flag = False | ||||
| nIncohInt = None | ||||
|
Daniel Valdez
|
r72 | def __init__(self, N): | ||
|
Miguel Valdez
|
r99 | |||
|
Daniel Valdez
|
r72 | self.profCounter = 1 | ||
| self.data = None | ||||
| self.buffer = None | ||||
| self.flag = False | ||||
| self.nIncohInt = N | ||||
| def exe(self,data): | ||||
| if self.buffer == None: | ||||
| self.buffer = data | ||||
| else: | ||||
| self.buffer = self.buffer + data | ||||
| if self.profCounter == self.nIncohInt: | ||||
| self.data = self.buffer | ||||
| self.buffer = None | ||||
| self.profCounter = 0 | ||||
| self.flag = True | ||||
| else: | ||||
| self.flag = False | ||||
| self.profCounter += 1 | ||||