CoGCalibration_utils.py

# !/usr/bin/env python
# -*- coding: utf-8 -*-
 
 
 
#
# evaluates the CoG corrections, create a localDB
# with the corrections and a root file to check
# the corrections
#
# usage: basf2 SVDCoGTimeCalibratinWithErrorImporter localDB filename
# localDB = name of the local DB folder
# filename = single root file, or file with the list of reconstructed files
#
# this script can be launched with launch_calibration_cog.sh in the
# B2SVD project, svd_CoGHitTime_calibration repository
#
 
 
import basf2 as b2
from ROOT import Belle2, TFile, TFitResultPtr, TH1F, TH2D, TH2F
from ROOT import TF1, gDirectory, gROOT
import math
from ROOT.Belle2 import SVDCoGCalibrationFunction
 
 
svd_recoDigits = "SVDRecoDigitsFromTracks"
cdc_Time0 = "EventT0"
svd_Clusters = "SVDClustersFromTracks"
 
gROOT.SetBatch(True)
 
# mode = True
 
 
class SVDCoGTimeCalibrationImporterModule(b2.Module):
    """
    Python class used for evaluating the CoG corrections, create a localDB,
    creating a localDB with the corrections and a root file to check the corrections
    """
 
    def notApplyCorrectForCDCLatency(self, mode):
        """
        Function that allows to set if apply the CDC latency correction
 
        parameters:
             mode (bool):
             - if True -> not apply correction
             - if False -> apply correction
        """
        
        self.notApplyCDCLatencyCorrectionnotApplyCDCLatencyCorrection = mode
        print("Not Correct for CDC latency: " + str(mode) + " " + str(self.notApplyCDCLatencyCorrectionnotApplyCDCLatencyCorrection))
 
    def fillLists(self, mode_byte_object, svdClusters_rel_RecoTracks_cl):
        """
        Function that fill the lists needed for the CoG corrections
 
        parameters:
             mode_byte_object (modeByte): modeByte that contains the information about the TB
             svdClusters_rel_RecoTracks_cl (SVDCluster): cluster related to tracks
        """
 
        timeCluster = svdClusters_rel_RecoTracks_cl.getClsTime()
        snrCluster = svdClusters_rel_RecoTracks_cl.getSNR()
        layerCluster = svdClusters_rel_RecoTracks_cl.getSensorID().getLayerNumber()
        layerIndex = layerCluster - 3
        sensorCluster = svdClusters_rel_RecoTracks_cl.getSensorID().getSensorNumber()
        sensorIndex = sensorCluster - 1
        ladderCluster = svdClusters_rel_RecoTracks_cl.getSensorID().getLadderNumber()
        ladderIndex = ladderCluster - 1
        sideCluster = svdClusters_rel_RecoTracks_cl.isUCluster()
        if sideCluster:
            sideIndex = 1
        else:
            sideIndex = 0
 
        hasTimezero = self.cdcEventT0cdcEventT0.hasEventT0()
        # print("Time: " + str(hasTimezero))
        if hasTimezero:
            TBClusters = mode_byte_object.getTriggerBin()
            TBIndex = ord(TBClusters)
            tZero = self.cdcEventT0cdcEventT0.getEventT0()
            # tZero_err = self.cdcEventT0.getEventT0Uncertainty()
            # tZero_err = 5.1
            tZeroSync = tZero - 4000./509 * (3 - TBIndex)
            et0 = self.EventT0HistEventT0Hist
            et0.Fill(tZeroSync)
            # print(str(tZero_err))
 
            resHist = self.resListresList[layerIndex][ladderIndex][sensorIndex][sideIndex][TBIndex]
            resHist.Fill(timeCluster - tZeroSync)
            spHist = self.spListspList[layerIndex][ladderIndex][sensorIndex][sideIndex][TBIndex]
            # spHist.Fill(timeCluster, 1.3*timeCluster - 50 + random.gauss(0,10))
            spHist.Fill(timeCluster, tZeroSync)
            cogHist = self.cogListcogList[layerIndex][ladderIndex][sensorIndex][sideIndex][TBIndex]
            cogHist.Fill(timeCluster)
            cdcHist = self.cdcListcdcList[layerIndex][ladderIndex][sensorIndex][sideIndex][TBIndex]
            cdcHist.Fill(tZeroSync)
            snrHist = self.snrListsnrList[layerIndex][ladderIndex][sensorIndex][sideIndex][TBIndex]
            snrHist.Fill(snrCluster)
 
            self.nListnList[layerIndex][ladderIndex][sensorIndex][sideIndex][TBIndex] += 1
            self.sumCOGListsumCOGList[layerIndex][ladderIndex][sensorIndex][sideIndex][TBIndex] += timeCluster
 
            
            self.NTOTNTOT = self.NTOTNTOT + 1
 
    def set_localdb(self, localDB):
        """
        Function that allows to set the localDB
 
        parameters:
             localDB (str): Name of the localDB used
        """
        
        self.localdblocaldb = localDB
 
    def initialize(self):
        """
        Initialize object (histograms, lists, ...) used by the class
        """
 
        
        self.outputFileNameoutputFileName = "CoGCorrectionMonitor_" + self.localdblocaldb + ".root"
 
        
        self.resListresList = []
        
        self.spListspList = []
        
        self.cogListcogList = []
        
        self.cdcListcdcList = []
        
        self.snrListsnrList = []
        
        self.nListnList = []
        
        self.sumCOGListsumCOGList = []
 
        geoCache = Belle2.VXD.GeoCache.getInstance()
 
        self.EvtEvt = 0
        for layer in geoCache.getLayers(Belle2.VXD.SensorInfoBase.SVD):
            layerList0 = []
            layerList1 = []
            layerList2 = []
            layerList3 = []
            layerList4 = []
            layerList5 = []
            layerList6 = []
            layerList7 = []
            layerList8 = []
            self.resListresList.append(layerList0)
            self.spListspList.append(layerList1)
            self.cogListcogList.append(layerList2)
            self.cdcListcdcList.append(layerList3)
            self.snrListsnrList.append(layerList4)
            self.nListnList.append(layerList8)
            self.sumCOGListsumCOGList.append(layerList7)
            # layerNumber = layer.getLayerNumber()
            for ladder in geoCache.getLadders(layer):
                ladderList0 = []
                ladderList1 = []
                ladderList2 = []
                ladderList3 = []
                ladderList4 = []
                ladderList5 = []
                ladderList6 = []
                ladderList7 = []
                ladderList8 = []
                layerList0.append(ladderList0)
                layerList1.append(ladderList1)
                layerList2.append(ladderList2)
                layerList3.append(ladderList3)
                layerList4.append(ladderList4)
                layerList5.append(ladderList5)
                layerList6.append(ladderList6)
                layerList7.append(ladderList7)
                layerList8.append(ladderList8)
                # ladderNumber = ladder.getLadderNumber()
                for sensor in geoCache.getSensors(ladder):
                    sensorList0 = []
                    sensorList1 = []
                    sensorList2 = []
                    sensorList3 = []
                    sensorList4 = []
                    sensorList5 = []
                    sensorList6 = []
                    sensorList7 = []
                    sensorList8 = []
                    ladderList0.append(sensorList0)
                    ladderList1.append(sensorList1)
                    ladderList2.append(sensorList2)
                    ladderList3.append(sensorList3)
                    ladderList4.append(sensorList4)
                    ladderList5.append(sensorList5)
                    ladderList6.append(sensorList6)
                    ladderList7.append(sensorList7)
                    ladderList8.append(sensorList8)
                    # sensorNumber = sensor.getSensorNumber()
                    for side in range(2):
                        sideList0 = []
                        sideList1 = []
                        sideList2 = []
                        sideList3 = []
                        sideList4 = []
                        sideList5 = []
                        sideList6 = []
                        sideList7 = []
                        sideList8 = []
                        sensorList0.append(sideList0)
                        sensorList1.append(sideList1)
                        sensorList2.append(sideList2)
                        sensorList3.append(sideList3)
                        sensorList4.append(sideList4)
                        sensorList5.append(sideList5)
                        sensorList6.append(sideList6)
                        sensorList7.append(sideList7)
                        sensorList8.append(sideList8)
 
        for i in geoCache.getLayers(Belle2.VXD.SensorInfoBase.SVD):
            layerN = i.getLayerNumber()
            li = layerN - 3
            for j in geoCache.getLadders(i):
                ladderN = j.getLadderNumber()
                ldi = ladderN - 1
                for k in geoCache.getSensors(j):
                    sensorN = k.getSensorNumber()
                    si = sensorN - 1
                    for s in range(2):
                        for t in range(4):
                            self.resListresList[li][ldi][si][s].append(
                                TH1F("res" + "_" + str(k) + "." + str(s) + "." + str(t), " ", 200, -100, 100))
                            self.spListspList[li][ldi][si][s].append(
                                TH2D("sp" + "_" + str(k) + "." + str(s) + "." + str(t), " ", 300, -150, 150, 300, -150, 150))
                            self.cogListcogList[li][ldi][si][s].append(
                                TH1F("cog" + "_" + str(k) + "." + str(s) + "." + str(t), " ", 200, -100, 100))
                            self.cdcListcdcList[li][ldi][si][s].append(
                                TH1F("cdc" + "_" + str(k) + "." + str(s) + "." + str(t), " ", 200, -100, 100))
                            self.snrListsnrList[li][ldi][si][s].append(
                                TH1F("snr" + "_" + str(k) + "." + str(s) + "." + str(t), " ", 100, 0, 100))
                            self.nListnList[li][ldi][si][s].append(0)
                            self.sumCOGListsumCOGList[li][ldi][si][s].append(0)
        
        self.EventT0HistEventT0Hist = TH1F("EventT0", " ", 200, -100, 100)
        
        self.AlphaUTBAlphaUTB = TH2F("alphaVsTB_U", " ", 400, 0.5, 2, 4, 0, 4)
        self.AlphaUTBAlphaUTB.GetXaxis().SetTitle("alpha")
        self.AlphaUTBAlphaUTB.GetYaxis().SetTitle("trigger bin")
        
        self.AlphaVTBAlphaVTB = TH2F("alphaVsTB_V", " ", 400, 0.5, 2, 4, 0, 4)
        self.AlphaVTBAlphaVTB.GetXaxis().SetTitle("alpha")
        self.AlphaVTBAlphaVTB.GetYaxis().SetTitle("trigger bin")
        
        self.BetaUTBBetaUTB = TH2F("betaVsTB_U", " ", 200, -100, 100, 4, 0, 4)
        self.BetaUTBBetaUTB.GetXaxis().SetTitle("beta (ns)")
        self.BetaUTBBetaUTB.GetYaxis().SetTitle("trigger bin")
        
        self.BetaVTBBetaVTB = TH2F("betaVsTB_V", " ", 200, -100, 100, 4, 0, 4)
        self.BetaVTBBetaVTB.GetXaxis().SetTitle("beta (ns)")
        self.BetaVTBBetaVTB.GetYaxis().SetTitle("trigger bin")
 
        
        self.MeanHistVTBMeanHistVTB = TH2F("meanHistVsTB_V", " ", 100, -10, 10, 4, 0, 4)
        self.MeanHistVTBMeanHistVTB.GetXaxis().SetTitle("distribution mean (ns)")
        self.MeanHistVTBMeanHistVTB.GetYaxis().SetTitle("trigger bin")
        
        self.MeanHistUTBMeanHistUTB = TH2F("meanHistVsTB_U", " ", 100, -10, 10, 4, 0, 4)
        self.MeanHistUTBMeanHistUTB.GetXaxis().SetTitle("distribution mean (ns)")
        self.MeanHistUTBMeanHistUTB.GetYaxis().SetTitle("trigger bin")
        
        self.RMSHistVTBRMSHistVTB = TH2F("rmsHistVsTB_V", " ", 100, 0, 10, 4, 0, 4)
        self.RMSHistVTBRMSHistVTB.GetXaxis().SetTitle("distribution RMS (ns)")
        self.RMSHistVTBRMSHistVTB.GetYaxis().SetTitle("trigger bin")
        
        self.RMSHistUTBRMSHistUTB = TH2F("rmsHistVsTB_U", " ", 100, 0, 10, 4, 0, 4)
        self.RMSHistUTBRMSHistUTB.GetXaxis().SetTitle("distribution RMS (ns)")
        self.RMSHistUTBRMSHistUTB.GetYaxis().SetTitle("trigger bin")
        
        self.MeanFitVTBMeanFitVTB = TH2F("meanFitVsTB_V", " ", 100, -10, 10, 4, 0, 4)
        self.MeanFitVTBMeanFitVTB.GetXaxis().SetTitle("fit mean (ns)")
        self.MeanFitVTBMeanFitVTB.GetYaxis().SetTitle("trigger bin")
        
        self.MeanFitUTBMeanFitUTB = TH2F("meanFitVsTB_U", " ", 100, -10, 10, 4, 0, 4)
        self.MeanFitUTBMeanFitUTB.GetXaxis().SetTitle("fit mean (ns)")
        self.MeanFitUTBMeanFitUTB.GetYaxis().SetTitle("trigger bin")
        
        self.RMSFitUTBRMSFitUTB = TH2F("rmsFitVsTB_U", " ", 100, 0, 10, 4, 0, 4)
        self.RMSFitUTBRMSFitUTB.GetXaxis().SetTitle("fit sigma (ns)")
        self.RMSFitUTBRMSFitUTB.GetYaxis().SetTitle("trigger bin")
        
        self.RMSFitVTBRMSFitVTB = TH2F("rmsFitVsTB_V", " ", 100, 0, 10, 4, 0, 4)
        self.RMSFitVTBRMSFitVTB.GetXaxis().SetTitle("fit sigma (ns)")
        self.RMSFitVTBRMSFitVTB.GetYaxis().SetTitle("trigger bin")
 
        
        self.gausgaus = TF1("gaus", 'gaus(0)', -150, 100)
 
        self.NTOTNTOT = 0
 
    def event(self):
        """
        Function that allows to cicle on the events
        """
        svd_evt_info = Belle2.PyStoreObj('SVDEventInfo')
        mode_byte = svd_evt_info.getModeByte()
        # timeClusterU = 0
        # timeClusterV = 0
        # sideIndex = 0
        # TBIndexU = 0
        # TBIndexV = 0
        
        self.EvtEvt = self.EvtEvt + 1
 
        
        self.cdcEventT0cdcEventT0 = Belle2.PyStoreObj(cdc_Time0)
        svdCluster_list = Belle2.PyStoreArray(svd_Clusters)
        # svdRecoDigit_list = Belle2.PyStoreArray(svd_recoDigits)
 
        for svdCluster in svdCluster_list:
            # svdRecoDigit = svdCluster.getRelatedTo(svd_recoDigits)
            self.fillListsfillLists(mode_byte, svdCluster)
 
    def terminate(self):
        """
        Terminates te class and produces the output rootfile
        """
 
        tfile = TFile(self.outputFileNameoutputFileName, 'recreate')
        iov = Belle2.IntervalOfValidity.always()
 
        payload = Belle2.SVDCoGTimeCalibrations.t_payload()
 
        timeCal = SVDCoGCalibrationFunction()
        # Bias and Scale
        tbBias = [-50, -50, -50, -50]
        tbScale = [1, 1, 1, 1]
        tbBias_err = [1, 1, 1, 1]
        tbScale_err = [1, 1, 1, 1]
        # tbCovScaleBias = [1, 1, 1, 1]
 
        TCOGMEAN = 0
        T0MEAN = 0
 
        '''
        geoCache = Belle2.VXD.GeoCache.getInstance()
        for layer in geoCache.getLayers(Belle2.VXD.SensorInfoBase.SVD):
            layerNumber = layer.getLayerNumber()
            li = layerNumber - 3
            for ladder in geoCache.getLadders(layer):
                ladderNumber = ladder.getLadderNumber()
                ldi = ladderNumber - 1
                for sensor in geoCache.getSensors(ladder):
                    sensorNumber = sensor.getSensorNumber()
                    si = sensorNumber - 1
                    for side in range(2):
                        for tb in range(4):
                            n = self.nList[li][ldi][si][side][tb]
                            NTOT += n
        '''
        geoCache = Belle2.VXD.GeoCache.getInstance()
        gDirectory.mkdir("plots")
        gDirectory.cd("plots")
        for layer in geoCache.getLayers(Belle2.VXD.SensorInfoBase.SVD):
            layerNumber = layer.getLayerNumber()
            li = layerNumber - 3
            gDirectory.mkdir("layer" + str(layer))
            gDirectory.cd("layer" + str(layer))
            for ladder in geoCache.getLadders(layer):
                ladderNumber = ladder.getLadderNumber()
                ldi = ladderNumber - 1
                for sensor in geoCache.getSensors(ladder):
                    sensorNumber = sensor.getSensorNumber()
                    si = sensorNumber - 1
                    for side in range(2):
                        for tb in range(4):
                            # Resolution distribution Histograms with Gaussian Fit
                            res = self.resListresList[li][ldi][si][side][tb]
                            fitResult = int(TFitResultPtr(res.Fit(self.gausgaus, "R")))
 
                            if res.GetEntries() > 5:
                                if side == 1:
                                    self.MeanHistUTBMeanHistUTB.Fill(res.GetMean(), tb)
                                    self.RMSHistUTBRMSHistUTB.Fill(res.GetRMS(), tb)
                                    if fitResult > -1:
                                        self.MeanFitUTBMeanFitUTB.Fill(self.gausgaus.GetParameter(1), tb)
                                        self.RMSFitUTBRMSFitUTB.Fill(self.gausgaus.GetParameter(2), tb)
                                else:
                                    self.MeanHistVTBMeanHistVTB.Fill(res.GetMean(), tb)
                                    self.RMSHistVTBRMSHistVTB.Fill(res.GetRMS(), tb)
                                    if fitResult > -1:
                                        self.MeanFitVTBMeanFitVTB.Fill(self.gausgaus.GetParameter(1), tb)
                                        self.RMSFitVTBRMSFitVTB.Fill(self.gausgaus.GetParameter(2), tb)
 
                            res.Write()
                            # COG Distribution Histograms
                            cog = self.cogListcogList[li][ldi][si][side][tb]
                            cog.Write()
                            # CDC EventT0 Distribution Histograms
                            cdc = self.cdcListcdcList[li][ldi][si][side][tb]
                            cdc.Write()
                            # SNR Distribution Histograms
                            snr = self.snrListsnrList[li][ldi][si][side][tb]
                            # snrMean = snr.GetMean()
                            snr.Write()
                            # ScatterPlot Histograms with Linear Fit
                            sp = self.spListspList[li][ldi][si][side][tb]
                            # covscalebias = sp.GetCovariance()
                            pfxsp = sp.ProfileX()
                            sp.Write()
                            pfxsp.Write()
 
                            if sp.GetRMS() != 0:
                                m = sp.GetCovariance() / pow(sp.GetRMS(1), 2)
                                # m = sp.GetCovariance()/cog.GetRMS()
                                m_err = 2 / pow(sp.GetRMS(), 3) * sp.GetRMSError() * sp.GetCovariance()
                                q = sp.GetMean(2) - m * sp.GetMean(1)
                                q_err = math.sqrt(pow(sp.GetMeanError(2), 2) +
                                                  pow(m * sp.GetMeanError(1), 2) + pow(m_err * sp.GetMean(1), 2))
                            else:
                                m = 1
                                m_err = 0
                                q = 0
                                q_err = 0
 
                            if side == 1:
                                self.AlphaUTBAlphaUTB.Fill(m, tb)
                                self.BetaUTBBetaUTB.Fill(q, tb)
                            else:
                                self.AlphaVTBAlphaVTB.Fill(m, tb)
                                self.BetaVTBBetaVTB.Fill(q, tb)
 
                            n = self.nListnList[li][ldi][si][side][tb]
 
                            tbBias[tb] = q
                            tbScale[tb] = m
                            tbBias_err[tb] = q_err
                            tbScale_err[tb] = m_err
                            TCOGMEAN += n * (m * self.sumCOGListsumCOGList[li][ldi][si][side][tb] / n + q) / self.NTOTNTOT
 
                        T0MEAN = self.EventT0HistEventT0Hist.GetMean()
                        '''
                        print(
                            "Mean of the CoG corrected distribution: " +
                            str(TCOGMEAN) +
                            " Mean of the T0 distribution: " +
                            str(T0MEAN))
                        '''
                        if not self.notApplyCDCLatencyCorrectionnotApplyCDCLatencyCorrection:
                            tbBias[0] = tbBias[0] - T0MEAN
                            tbBias[1] = tbBias[1] - T0MEAN
                            tbBias[2] = tbBias[2] - T0MEAN
                            tbBias[3] = tbBias[3] - T0MEAN
 
                        timeCal.set_bias(tbBias[0], tbBias[1], tbBias[2], tbBias[3])
                        timeCal.set_scale(tbScale[0], tbScale[1], tbScale[2], tbScale[3])
                        print("setting CoG calibration for " + str(layerNumber) + "." + str(ladderNumber) + "." + str(sensorNumber))
                        payload.set(layerNumber, ladderNumber, sensorNumber, bool(side), 1, timeCal)
            gDirectory.cd("../")
 
        gDirectory.cd("../")
        self.AlphaUTBAlphaUTB.Write()
        self.AlphaVTBAlphaVTB.Write()
        self.BetaUTBBetaUTB.Write()
        self.BetaVTBBetaVTB.Write()
        self.MeanFitUTBMeanFitUTB.Write()
        self.MeanFitVTBMeanFitVTB.Write()
        self.RMSFitUTBRMSFitUTB.Write()
        self.RMSFitVTBRMSFitVTB.Write()
        self.MeanHistUTBMeanHistUTB.Write()
        self.MeanHistVTBMeanHistVTB.Write()
        self.RMSHistUTBRMSHistUTB.Write()
        self.RMSHistVTBRMSHistVTB.Write()
        self.EventT0HistEventT0Hist.Write()
 
        Belle2.Database.Instance().storeData(Belle2.SVDCoGTimeCalibrations.name, payload, iov)
 
        tfile.Close()