IsolationCorrectionTool.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2021 CERN for the benefit of the ATLAS collaboration
*/
 
#include "IsolationCorrections/IsolationCorrectionTool.h"
#include "xAODEgamma/Egamma.h"
#include "xAODEgamma/Electron.h"
#include "xAODEgamma/Photon.h"
#include "xAODEventInfo/EventInfo.h"
#include "PATInterfaces/SystematicRegistry.h"
#include "PathResolver/PathResolver.h"
#include "xAODPrimitives/IsolationHelpers.h"
 
#ifndef ROOTCORE
#include "AthAnalysisBaseComps/AthAnalysisHelper.h"
#include "AthAnalysisBaseComps/AthAnalysisAlgorithm.h"
#endif //ROOTCORE
 
#include "TFile.h"
 
namespace CP {
 
  IsolationCorrectionTool::IsolationCorrectionTool( const std::string &name )
    : asg::AsgMetadataTool(name), m_systDDonoff("PH_Iso_DDonoff") {
    declareProperty("CorrFile",                    m_corr_file                      = "IsolationCorrections/v5/isolation_ptcorrections_rel20_2.root") ;
    declareProperty("CorrFile_ddshift",            m_corr_ddshift_file              = "IsolationCorrections/v3/isolation_ddcorrection_shift.root");
    declareProperty("CorrFile_ddsmearing",         m_corr_ddsmearing_file           = "IsolationCorrections/v1/isolation_ddcorrection_smearing.root", "a run I smearing for MC calo iso");
    declareProperty("ToolVer",                     m_tool_ver_str                   = "REL21");
    declareProperty("DataDrivenVer",               m_ddVersion                      = "2017");
    declareProperty("AFII_corr",                   m_AFII_corr                      = false);
    declareProperty("IsMC",                        m_is_mc                          = true);
    declareProperty("Correct_etcone",              m_correct_etcone                 = false);
    declareProperty("Trouble_categories",          m_trouble_categories             = true);
    declareProperty("LogLogFitForLeakage",         m_useLogLogFit                   = false);
    declareProperty("ForcePartType",               m_forcePartType                  = false);
    declareProperty("Apply_ddshifts",              m_apply_ddDefault                = false);
    declareProperty("Apply_SC_leakcorr",           m_apply_SC_leak_corr             = false);
    declareProperty("Apply_etaEDParPU_correction",     m_apply_etaEDParPU_corr      = false);
    declareProperty("Apply_etaEDPar_mc_correction",    m_apply_etaEDParPU_mc_corr   = false);
    declareProperty("CorrFile_etaEDParPU_correction",  m_corr_etaEDParPU_file       = "IsolationCorrections/v6/zetas.root");
    declareProperty("CorrFile_etaEDPar_mc_correction", m_corr_etaEDPar_mc_corr_file = "IsolationCorrections/v6/zetas_correction.root");
 
    m_isol_corr = new IsolationCorrection(name);
  }
 
  StatusCode IsolationCorrectionTool::initialize() {
    ATH_MSG_INFO( "in initialize of " << name() << "..." );
 
    //ReadHandles
    ATH_CHECK(m_eventInfoKey.initialize());
    ATH_CHECK(m_centralEventShapeKey.initialize(m_apply_etaEDParPU_corr));
    ATH_CHECK(m_forwardEventShapeKey.initialize(m_apply_etaEDParPU_corr));
 
    //
    m_isol_corr->msg().setLevel(this->msg().level());
    //
    // Resolve the paths to the input files
    std::vector < std::string > corrFileNameList;
    corrFileNameList.push_back(m_corr_file);
    corrFileNameList.push_back(m_corr_ddshift_file);
    corrFileNameList.push_back(m_corr_ddsmearing_file);
 
    for ( unsigned int i=0; i<corrFileNameList.size(); ++i ){
 
      //First try the PathResolver
      std::string filename = PathResolverFindCalibFile( corrFileNameList.at(i) );
      if (filename.empty()){
          ATH_MSG_ERROR ( "Could NOT resolve file name " << corrFileNameList.at(i) );
          return StatusCode::FAILURE ;
      } else{
          ATH_MSG_INFO(" Path found = "<<filename);
      }
      corrFileNameList.at(i) = filename;
    }
    //
 
    CP::IsolationCorrection::Version tool_ver;
 
    if      (m_tool_ver_str == "REL22")   tool_ver = CP::IsolationCorrection::REL22;
    else if (m_tool_ver_str == "REL21")   tool_ver = CP::IsolationCorrection::REL21;
    else if (m_tool_ver_str == "REL20_2") tool_ver = CP::IsolationCorrection::REL20_2;
    else if (m_tool_ver_str == "REL17_2") tool_ver = CP::IsolationCorrection::REL17_2;
    else {
      ATH_MSG_WARNING("Tool version not recognized: "<<m_tool_ver_str<<"\nAllowed versions: REL22, REL21, REL20_2, REL17_2");
      return StatusCode::FAILURE;
    }
 
    if(TString(corrFileNameList[0]).Contains("isolation_ptcorrections_rel17_2.root") && m_tool_ver_str != "REL17_2"){
      ATH_MSG_WARNING("The specified correction file is not for "<<m_tool_ver_str<<" please use proper correction file");
      return StatusCode::FAILURE;
    }
 
    if (TString(corrFileNameList[0]).Contains("isolation_ptcorrections_rel20_2.root") && !( m_tool_ver_str == "REL20_2" || m_tool_ver_str == "REL21" ) ){
      ATH_MSG_WARNING("The specified correction file is not for "<<m_tool_ver_str<<" please use proper correction file");
      return StatusCode::FAILURE;
    }
    if (TString(corrFileNameList[0]).Contains("isolation_ptcorrections_rel22_") &&  m_tool_ver_str != "REL22" ){
      ATH_MSG_WARNING("The specified correction file is not for "<<m_tool_ver_str<<" please use proper correction file");
      return StatusCode::FAILURE;
    }
 
    m_isol_corr->SetCorrectionFile(m_corr_file, m_corr_ddshift_file, m_corr_ddsmearing_file);
    m_isol_corr->SetToolVer(tool_ver);
    m_isol_corr->SetTroubleCategories(m_trouble_categories);
    m_isol_corr->FitType(m_useLogLogFit);
    m_isol_corr->ForcePartType(m_forcePartType);
 
    // Note that systematics in Rel 21 are NOT done with the DD-Corr ON/OFF method!
    if (m_apply_ddDefault) {
      if (m_ddVersion == "2015" || m_ddVersion == "2015_2016" || m_ddVersion == "2017") {
        //if not REL21, register ourselves with the systematic registry!
          if (m_tool_ver_str!="REL21") {
            CP::SystematicRegistry& registry = CP::SystematicRegistry::getInstance();
            if( registry.registerSystematics( *this ) != StatusCode::SUCCESS ) return StatusCode::FAILURE;
          }
          m_apply_dd = true;
      } else {
          ATH_MSG_WARNING("Unknown data driven correction");
          m_apply_dd = false;
      }
    } else{
      m_apply_dd = false;
    }
 
    // Don't use DD Corrections for AFII if not rel21 (I do not know what was done in rel20.7 !)
    if (m_tool_ver_str != "REL21" && m_AFII_corr) m_apply_dd = false;
 
    m_isol_corr->SetAFII(m_AFII_corr);
    m_isol_corr->SetDataMC(m_is_mc);
 
    if(m_apply_etaEDParPU_corr){
      std::string filename = PathResolverFindCalibFile( m_corr_etaEDParPU_file );
      if (filename.empty()){
        ATH_MSG_ERROR ( "Could NOT resolve file name " << m_corr_etaEDParPU_file );
        return StatusCode::FAILURE ;
      }
      ATH_MSG_INFO(" Path found = "<<filename);
      std::unique_ptr<TFile> f(TFile::Open(filename.c_str(), "READ"));
 
      m_map_isotype_zetaPU[xAOD::Iso::topoetcone20] = std::unique_ptr<TGraph>((TGraph*)f->Get("topoetcone20"));
      m_map_isotype_zetaPU[xAOD::Iso::topoetcone30] = std::unique_ptr<TGraph>((TGraph*)f->Get("topoetcone30"));
      m_map_isotype_zetaPU[xAOD::Iso::topoetcone40] = std::unique_ptr<TGraph>((TGraph*)f->Get("topoetcone40"));
      f->Close();
 
      if(m_apply_etaEDParPU_mc_corr){
        std::string filename = PathResolverFindCalibFile( m_corr_etaEDPar_mc_corr_file );
        if (filename.empty()){
          ATH_MSG_ERROR ( "Could NOT resolve file name " << m_corr_etaEDPar_mc_corr_file );
          return StatusCode::FAILURE ;
        }
        ATH_MSG_INFO(" Path found = "<<filename);
        std::unique_ptr<TFile> f_corr(TFile::Open(filename.c_str(), "READ"));
 
        m_map_isotype_zeta_mc_corr[xAOD::Iso::topoetcone20] = std::unique_ptr<TGraph>((TGraph*)f_corr->Get("topoetcone20"));
        m_map_isotype_zeta_mc_corr[xAOD::Iso::topoetcone30] = std::unique_ptr<TGraph>((TGraph*)f_corr->Get("topoetcone30"));
        m_map_isotype_zeta_mc_corr[xAOD::Iso::topoetcone40] = std::unique_ptr<TGraph>((TGraph*)f_corr->Get("topoetcone40"));
        f_corr->Close();
      }
    }
 
    return m_isol_corr->initialize();
  }
 
 
  // this will correct a corrected topoetcone : replace a (old) leakage by another (new) one
  // This is not for photon, as it does not consider DD
  CP::CorrectionCode IsolationCorrectionTool::CorrectLeakage(xAOD::Egamma & eg) {
 
    static const std::vector<xAOD::Iso::IsolationType> topoisolation_types = {xAOD::Iso::topoetcone20,
                                                                                          xAOD::Iso::topoetcone40};
 
    for (auto type : topoisolation_types) {
      float oldleak = 0.;
      if (eg.isolationCaloCorrection(oldleak, type, xAOD::Iso::ptCorrection)) {
          ATH_MSG_DEBUG("leakage correction not stored for isolation type " << xAOD::Iso::toCString(type) << ". Nothing done.");
          continue;
      }
      float newleak = this->GetPtCorrection(eg,type);
      float iso     = 0;
      if (!eg.isolationValue(iso,type)) {
          ATH_MSG_WARNING("Isolation variable " << xAOD::Iso::toCString(type) << " not stored. Nothing done.");
          continue;
      }
      iso += (oldleak-newleak);
      bool setIso = eg.setIsolationValue(iso,type);
      setIso = (setIso && eg.setIsolationCaloCorrection(newleak,type,xAOD::Iso::ptCorrection));
      if (!setIso) {
          ATH_MSG_WARNING("Can't correct leakage for " << xAOD::Iso::toCString(type));
          return CP::CorrectionCode::Error;
      }
    }
 
    if (m_correct_etcone){
      // this is supposed to correct an uncorrected etcone
      static const std::vector<xAOD::Iso::IsolationType> isolation_types = {xAOD::Iso::etcone20,
                                                                                      xAOD::Iso::etcone30,
                                                                                      xAOD::Iso::etcone40};
 
      ATH_MSG_VERBOSE( "Correcting etconeXX isolation..." );
      for(auto type : topoisolation_types){
        float Etcone_value_corr = m_isol_corr->GetPtCorrectedIsolation(eg,type);
        eg.setIsolationValue(Etcone_value_corr,type);
      }
    }
 
    return CP::CorrectionCode::Ok;
  }
 
  CP::CorrectionCode IsolationCorrectionTool::applyCorrection(xAOD::Egamma &eg) {
 
    static const SG::AuxElement::Accessor<float> decDDcor20("topoetcone20_DDcorr");
    static const SG::AuxElement::Accessor<float> decDDcor40("topoetcone40_DDcorr");
 
    float SCsub = 0;
    if(m_apply_SC_leak_corr){
      float topoetconecoreConeEnergyCorrection = 0;
      if(!eg.isolationCaloCorrection(topoetconecoreConeEnergyCorrection, xAOD::Iso::topoetcone, xAOD::Iso::coreCone, xAOD::Iso::coreEnergy)){
          ATH_MSG_WARNING("Could not find SC based core");
      }
      float core57cells = 0.;
      if(!eg.isolationCaloCorrection(core57cells, xAOD::Iso::topoetcone, xAOD::Iso::core57cells, xAOD::Iso::coreEnergy)){
          ATH_MSG_WARNING("Could not find core57cells to apply SC based core correction");
      }
      ATH_MSG_VERBOSE("Old core correction value: " << core57cells);
      ATH_MSG_VERBOSE("SC based core correction value: " << topoetconecoreConeEnergyCorrection);
      SCsub = - topoetconecoreConeEnergyCorrection + core57cells;
    }
 
    float centralDensity = 0.;
    float forwardDensity = 0.;
    if(m_apply_etaEDParPU_corr){
      SG::ReadHandle<xAOD::EventShape> shapeCentral (m_centralEventShapeKey);
      SG::ReadHandle<xAOD::EventShape> shapeForward (m_forwardEventShapeKey);
      const xAOD::EventShape* evtShapeCentral = shapeCentral.ptr();
      const xAOD::EventShape* evtShapeForward = shapeForward.ptr();
      centralDensity = evtShapeCentral->getDensity(xAOD::EventShape::Density);
      forwardDensity = evtShapeForward->getDensity(xAOD::EventShape::Density);
    }
 
    static const std::vector<xAOD::Iso::IsolationType> topoisolation_types = {xAOD::Iso::topoetcone20,
                                                                                                xAOD::Iso::topoetcone30,
                                                                                                xAOD::Iso::topoetcone40};
    for (auto type : topoisolation_types) {
      float oldleak = 0.;
      if (!eg.isolationCaloCorrection(oldleak, type, xAOD::Iso::ptCorrection)) {
          ATH_MSG_DEBUG("leakage correction not stored for isolation type " << xAOD::Iso::toCString(type) << ". Nothing done");
          continue;
      }
      float oldiso  = 0;
      bool gotIso   = eg.isolationValue(oldiso,type);
      if (!gotIso) continue;
 
      // Use the Random Run Number from the Event Info to check which year's DD-Corrections to use
      // If the RandomRunNo can't be obtained, then default to what is set by either the default choice or by the AuxData check
      unsigned int theRunNumber = 0 ;
      SG::ReadHandle<xAOD::EventInfo> evtInfo (m_eventInfoKey);
      const xAOD::EventInfo* eventInfo = evtInfo.ptr();
      if (eventInfo) {
          static const SG::AuxElement::Accessor<unsigned int> randomrunnumber("RandomRunNumber");
          if (randomrunnumber.isAvailable(*eventInfo)){
            theRunNumber = randomrunnumber(*(eventInfo)) ;
        }
      } else{
          ATH_MSG_WARNING("Could not retrieve EventInfo object");
      }
      if (theRunNumber >= 320000)
          m_ddVersion = "2017" ;      // RunNo found, and is in 2017 range
      else if (theRunNumber > 0)
          m_ddVersion = "2015_2016" ; // RunNo found, but less than 2017 range
      // otherwise, stick with default (m_ddVersion is already assigned)
 
      // Don't use DD Corrections for AFII if not rel21 ? (I do not know what was done for rel20.7 !!!)
      if (m_tool_ver_str != "REL21" && m_AFII_corr) m_apply_dd = false;
 
      float iso     = oldiso;
      float newleak = 0.;
      if(m_apply_SC_leak_corr){
        ATH_MSG_VERBOSE("Iso before SC correction: " << iso);
        iso += (SCsub + oldleak);
        ATH_MSG_VERBOSE("Iso after SC correction: " << iso);
      }
      else {
        newleak = this->GetPtCorrection(eg,type);
        iso += (oldleak - newleak);
      }
      float ddcorr  = 0;
 
      // this correction is derived purly from data, but can also be applied to mc
      if(m_apply_etaEDParPU_corr){
        float abseta = fabs(eg.caloCluster()->etaBE(2));
        float densityOldCorrection = 0.;
        if(abseta <= 1.5){
          densityOldCorrection = centralDensity;
        }
        else{
          densityOldCorrection = forwardDensity;
        }
        float dR = xAOD::Iso::coneSize(type);
        static const float a_core = 5*7*0.025*TMath::Pi()/128;
        float area = TMath::Pi()*dR*dR-a_core;
        float oldpu_corr = densityOldCorrection*area;
        float newpu_corr = m_map_isotype_zetaPU[type]->Eval(abseta)*centralDensity*area;
        float pu_mc_corr = 0.;
        if(m_apply_etaEDParPU_mc_corr && m_is_mc){
          pu_mc_corr += m_map_isotype_zeta_mc_corr[type]->Eval(abseta)*centralDensity*area;
        }
        iso = iso + oldpu_corr - newpu_corr + pu_mc_corr;
        ATH_MSG_VERBOSE("Applying parametrized pileup correction to " << eg.type() << " with |eta|="<< abseta);
        ATH_MSG_VERBOSE("Old parametrized pileup correction for "<<xAOD::Iso::toCString(type)<< ": "<<oldpu_corr);
        ATH_MSG_VERBOSE("New parametrized pileup correction for "<<xAOD::Iso::toCString(type)<< ": "<<newpu_corr);
        ATH_MSG_VERBOSE("Parametrized mc correction for "<<xAOD::Iso::toCString(type)<< ": "<<pu_mc_corr);
        ATH_MSG_VERBOSE("Isolation after new correction for "<<xAOD::Iso::toCString(type)<< ": "<<iso);
        ATH_MSG_VERBOSE("Isolation after old correction for "<<xAOD::Iso::toCString(type)<< ": "<<iso+newpu_corr-oldpu_corr-pu_mc_corr);
        eg.setIsolationCaloCorrection(newpu_corr, type, xAOD::Iso::pileupCorrection);
      }
 
      if (m_is_mc && m_apply_dd && type != xAOD::Iso::topoetcone30 && eg.type() == xAOD::Type::Photon) {
          ddcorr = this->GetDDCorrection(eg,type);
          if (type == xAOD::Iso::topoetcone20)
            decDDcor20(eg) = ddcorr;
          else if (type == xAOD::Iso::topoetcone40)
            decDDcor40(eg) = ddcorr;
          iso += ddcorr;
      }
      bool setIso = eg.setIsolationValue(iso,type);
      setIso = (setIso && eg.setIsolationCaloCorrection(newleak-ddcorr,type,xAOD::Iso::ptCorrection));
      ATH_MSG_VERBOSE("oldeak = " << oldleak << " ddcor = " << ddcorr << " leak param = " << newleak
              << " stored correction " << eg.isolationCaloCorrection(type,xAOD::Iso::ptCorrection));
 
      if (!setIso) {
        ATH_MSG_WARNING("Can't correct leakage for " << xAOD::Iso::toCString(type));
        return CP::CorrectionCode::Error;
      }
    }
    return CP::CorrectionCode::Ok;
  }
 
  float IsolationCorrectionTool::GetPtCorrectedIsolation(const xAOD::Egamma& input, xAOD::Iso::IsolationType isol){
    return m_isol_corr->GetPtCorrectedIsolation(input, isol);
  }
 
  float IsolationCorrectionTool::GetPtCorrection(const xAOD::Egamma& input, xAOD::Iso::IsolationType isol) const {
    return m_isol_corr->GetPtCorrection(input, isol);
  }
 
  float IsolationCorrectionTool::GetDDCorrection(const xAOD::Egamma& input, xAOD::Iso::IsolationType isol){
    return m_isol_corr->GetDDCorrection(input, isol, m_ddVersion);
  }
 
  CP::CorrectionCode IsolationCorrectionTool::correctedCopy( const xAOD::Egamma& input, xAOD::Egamma*& output) {
    // A sanity check:
    if( output ) ATH_MSG_WARNING( "Non-null pointer received. There's a possible memory leak!" );
 
    if ( input.type() == xAOD::Type::Electron ) {
      output = new xAOD::Electron();
      output->makePrivateStore( static_cast<const xAOD::Electron&>(input) );
      return applyCorrection( *output );
    }
    else if ( input.type() == xAOD::Type::Photon ) {
      output = new xAOD::Photon();
      output->makePrivateStore( static_cast<const xAOD::Photon&>(input) );
      return applyCorrection( *output );
    }
    else {
      ATH_MSG_WARNING("Didn't get an electron or photon");
      return CP::CorrectionCode::Error;
    }
 
  }
 
  //Systematics
  bool IsolationCorrectionTool::isAffectedBySystematic( const CP::SystematicVariation& systematic ) const {
    CP::SystematicSet sys = affectingSystematics();
    return sys.find( systematic ) != sys.end();
  }
 
  CP::SystematicSet IsolationCorrectionTool::affectingSystematics() const {
    CP::SystematicSet result;
    return result;
  }
 
  CP::SystematicSet IsolationCorrectionTool::recommendedSystematics() const {
    return affectingSystematics();
  }
 
  StatusCode IsolationCorrectionTool::applySystematicVariation( const CP::SystematicSet& ) {
    return StatusCode::SUCCESS;
  }
 
  IsolationCorrectionTool::~IsolationCorrectionTool() {
    delete m_isol_corr;
  }
 
}