MuonTrackResidualAnalyzer.cc

Go to the documentation of this file.

#include "Validation/RecoMuon/src/MuonTrackResidualAnalyzer.h"

// Collaborating Class Header
#include "FWCore/Framework/interface/ConsumesCollector.h"
#include "FWCore/Framework/interface/Frameworkfwd.h"
#include "FWCore/Framework/interface/Event.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"

#include "Geometry/CommonDetUnit/interface/GeomDet.h"

#include "TrackingTools/TransientTrack/interface/TransientTrack.h"
#include "TrackingTools/KalmanUpdators/interface/KFUpdator.h"
#include "TrackingTools/KalmanUpdators/interface/Chi2MeasurementEstimator.h"
#include "TrackingTools/TrackFitters/interface/KFTrajectoryFitter.h"
#include "TrackingTools/TrackFitters/interface/KFTrajectorySmoother.h"

#include "DataFormats/TrajectorySeed/interface/TrajectorySeedCollection.h"
#include "DataFormats/MuonDetId/interface/DTLayerId.h"
#include "DataFormats/MuonDetId/interface/MuonSubdetId.h"

#include "RecoMuon/TrackingTools/interface/MuonPatternRecoDumper.h"
#include "RecoMuon/TrackingTools/interface/MuonServiceProxy.h"
#include "Validation/RecoMuon/src/Histograms.h"
#include "RecoMuon/TransientTrackingRecHit/interface/MuonTransientTrackingRecHitBuilder.h"
#include "RecoMuon/TransientTrackingRecHit/interface/MuonTransientTrackingRecHit.h"

#include "TFile.h"
#include "TH1F.h"
#include "TH2F.h"
#include "TDirectory.h"

using namespace std;
using namespace edm;


MuonTrackResidualAnalyzer::MuonTrackResidualAnalyzer(const edm::ParameterSet &ps) {
  pset = ps;
  // service parameters
  ParameterSet serviceParameters = pset.getParameter<ParameterSet>("ServiceParameters");
  // the services
  theService = new MuonServiceProxy(serviceParameters, consumesCollector());

  theMuonTrackLabel = pset.getParameter<InputTag>("MuonTrack");
  theMuonTrackToken = consumes<reco::TrackCollection>(theMuonTrackLabel);

  cscSimHitLabel = pset.getParameter<InputTag>("CSCSimHit");
  dtSimHitLabel = pset.getParameter<InputTag>("DTSimHit");
  rpcSimHitLabel = pset.getParameter<InputTag>("RPCSimHit");
  theCSCSimHitToken = consumes<std::vector<PSimHit> >(cscSimHitLabel);
  theDTSimHitToken = consumes<std::vector<PSimHit> >(dtSimHitLabel);
  theRPCSimHitToken = consumes<std::vector<PSimHit> >(rpcSimHitLabel);

  dbe_ = edm::Service<DQMStore>().operator->();
  out = pset.getUntrackedParameter<string>("rootFileName");
  dirName_ = pset.getUntrackedParameter<std::string>("dirName");
  subsystemname_ = pset.getUntrackedParameter<std::string>("subSystemFolder", "YourSubsystem");

  // Sim or Real
  theDataType = pset.getParameter<InputTag>("DataType");
  if (theDataType.label() != "RealData" && theDataType.label() != "SimData")
    LogDebug("MuonTrackResidualAnalyzer") << "Error in Data Type!!";
  theDataTypeToken = consumes<edm::SimTrackContainer>(theDataType);

  theEtaRange = (EtaRange)pset.getParameter<int>("EtaRange");

  theUpdator = new KFUpdator();
  theEstimator = new Chi2MeasurementEstimator(100000.);

  theMuonSimHitNumberPerEvent = 0;
}

MuonTrackResidualAnalyzer::~MuonTrackResidualAnalyzer() {
  delete theUpdator;
  delete theEstimator;
  delete theService;
}

void MuonTrackResidualAnalyzer::bookHistograms(DQMStore::IBooker &ibooker,
                                               edm::Run const &iRun,
                                               edm::EventSetup const & /* iSetup */) {
  LogDebug("MuonTrackResidualAnalyzer") << "Begin Run";

  ibooker.cd();
  InputTag algo = theMuonTrackLabel;
  string dirName = dirName_;
  if (!algo.process().empty())
    dirName += algo.process() + "_";
  if (!algo.label().empty())
    dirName += algo.label() + "_";
  if (!algo.instance().empty())
    dirName += algo.instance() + "";
  if (dirName.find("Tracks") < dirName.length()) {
    dirName.replace(dirName.find("Tracks"), 6, "");
  }
  std::replace(dirName.begin(), dirName.end(), ':', '_');
  ibooker.setCurrentFolder(dirName);

  hDPtRef = ibooker.book1D("DeltaPtRef", "P^{in}_{t}-P^{in ref}", 10000, -20, 20);

  // Resolution wrt the 1D Rec Hits
  //  h1DRecHitRes = new HResolution1DRecHit("TotalRec");

  // Resolution wrt the 1d Sim Hits
  //  h1DSimHitRes = new HResolution1DRecHit("TotalSim");

  hSimHitsPerTrack = ibooker.book1D("SimHitsPerTrack", "Number of sim hits per track", 55, 0, 55);
  hSimHitsPerTrackVsEta =
      ibooker.book2D("SimHitsPerTrackVsEta", "Number of sim hits per track VS #eta", 120, -3., 3., 55, 0, 55);
  hDeltaPtVsEtaSim =
      ibooker.book2D("DeltaPtVsEtaSim", "#Delta P_{t} vs #eta gen, sim quantity", 120, -3., 3., 500, -250., 250.);
  hDeltaPtVsEtaSim2 =
      ibooker.book2D("DeltaPtVsEtaSim2", "#Delta P_{t} vs #eta gen, sim quantity", 120, -3., 3., 500, -250., 250.);
}

void MuonTrackResidualAnalyzer::dqmEndRun(edm::Run const &, edm::EventSetup const &) {
  if (!out.empty() && dbe_)
    dbe_->save(out);
}
void MuonTrackResidualAnalyzer::analyze(const edm::Event &event, const edm::EventSetup &eventSetup) {
  LogDebug("MuonTrackResidualAnalyzer") << "Analyze";

  // Update the services
  theService->update(eventSetup);
  MuonPatternRecoDumper debug;
  theMuonSimHitNumberPerEvent = 0;

  // Get the SimHit collection from the event
  Handle<PSimHitContainer> dtSimHits;
  event.getByToken(theDTSimHitToken, dtSimHits);

  Handle<PSimHitContainer> cscSimHits;
  event.getByToken(theCSCSimHitToken, cscSimHits);

  Handle<PSimHitContainer> rpcSimHits;
  event.getByToken(theRPCSimHitToken, rpcSimHits);

  Handle<SimTrackContainer> simTracks;

  // FIXME Add the tracker one??

  // Map simhits per DetId
  map<DetId, const PSimHit *> muonSimHitsPerId = mapMuSimHitsPerId(dtSimHits, cscSimHits, rpcSimHits);

  hSimHitsPerTrack->Fill(theMuonSimHitNumberPerEvent);

  double etaSim = 0;

  if (theDataType.label() == "SimData") {
    // Get the SimTrack collection from the event
    event.getByToken(theDataTypeToken, simTracks);

    // Loop over the Sim tracks
    SimTrackContainer::const_iterator simTrack;

    for (simTrack = simTracks->begin(); simTrack != simTracks->end(); ++simTrack)
      if (abs((*simTrack).type()) == 13) {
        hSimHitsPerTrackVsEta->Fill((*simTrack).momentum().eta(), theMuonSimHitNumberPerEvent);
        etaSim = (*simTrack).momentum().eta();
        theSimTkId = (*simTrack).trackId();
      }
  }

  // Get the RecTrack collection from the event
  Handle<reco::TrackCollection> muonTracks;
  event.getByToken(theMuonTrackToken, muonTracks);

  reco::TrackCollection::const_iterator muonTrack;

  // Loop over the Rec tracks
  for (muonTrack = muonTracks->begin(); muonTrack != muonTracks->end(); ++muonTrack) {
    reco::TransientTrack track(*muonTrack, &*theService->magneticField(), theService->trackingGeometry());

    TrajectoryStateOnSurface outerTSOS = track.outermostMeasurementState();
    TrajectoryStateOnSurface innerTSOS = track.innermostMeasurementState();

    TransientTrackingRecHit::ConstRecHitContainer result;

    // SimHit Energy loss analysis
    double momAtEntry = -150., momAtExit = -150.;

    if (theSimHitContainer.size() > 1) {
      const GeomDet *geomDetA = theService->trackingGeometry()->idToDet(DetId(theSimHitContainer.front()->detUnitId()));
      double distA = geomDetA->toGlobal(theSimHitContainer.front()->localPosition()).mag();

      const GeomDet *geomDetB = theService->trackingGeometry()->idToDet(DetId(theSimHitContainer.back()->detUnitId()));
      double distB = geomDetB->toGlobal(theSimHitContainer.back()->localPosition()).mag();

      LogTrace("MuonTrackResidualAnalyzer")
          << "Inner SimHit: " << theSimHitContainer.front()->particleType()
          << " Pt: " << theSimHitContainer.front()->momentumAtEntry().perp()
          << " E: " << theSimHitContainer.front()->momentumAtEntry().perp() << " R: " << distA << endl;
      LogTrace("MuonTrackResidualAnalyzer")
          << "Outer SimHit: " << theSimHitContainer.back()->particleType()
          << " Pt: " << theSimHitContainer.back()->momentumAtEntry().perp()
          << " E: " << theSimHitContainer.front()->momentumAtEntry().perp() << " R: " << distB << endl;

      momAtEntry = theSimHitContainer.front()->momentumAtEntry().perp();
      momAtExit = theSimHitContainer.back()->momentumAtEntry().perp();
    }

    trackingRecHit_iterator rhFirst = track.recHitsBegin();
    trackingRecHit_iterator rhLast = track.recHitsEnd() - 1;
    map<DetId, const PSimHit *>::const_iterator itFirst = muonSimHitsPerId.find((*rhFirst)->geographicalId());
    map<DetId, const PSimHit *>::const_iterator itLast = muonSimHitsPerId.find((*rhLast)->geographicalId());

    double momAtEntry2 = -150, momAtExit2 = -150.;
    if (itFirst != muonSimHitsPerId.end())
      momAtEntry2 = itFirst->second->momentumAtEntry().perp();
    else {
      LogDebug("MuonTrackResidualAnalyzer") << "No first sim hit found";
      ++rhFirst;
      itFirst = muonSimHitsPerId.find((*rhFirst)->geographicalId());
      if (itFirst != muonSimHitsPerId.end())
        momAtEntry2 = itFirst->second->momentumAtEntry().perp();
      else {
        LogDebug("MuonTrackResidualAnalyzer") << "No second sim hit found";
        // continue;
      }
    }

    if (itLast != muonSimHitsPerId.end())
      momAtExit2 = itLast->second->momentumAtEntry().perp();
    else {
      LogDebug("MuonTrackResidualAnalyzer") << "No last sim hit found";
      --rhLast;
      itLast = muonSimHitsPerId.find((*rhLast)->geographicalId());
      if (itLast != muonSimHitsPerId.end())
        momAtExit2 = itLast->second->momentumAtEntry().perp();
      else {
        LogDebug("MuonTrackResidualAnalyzer") << "No last but one sim hit found";
        // continue;
      }
    }

    if (etaSim) {
      if (momAtEntry >= 0 && momAtExit >= 0)
        hDeltaPtVsEtaSim->Fill(etaSim, momAtEntry - momAtExit);
      if (momAtEntry2 >= 0 && momAtExit2 >= 0)
        hDeltaPtVsEtaSim2->Fill(etaSim, momAtEntry2 - momAtExit2);
    } else
      LogDebug("MuonTrackResidualAnalyzer") << "NO SimTrack'eta";
    //

    // computeResolution(trajectoryBW,muonSimHitsPerId,h1DSimHitRes);
    // computeResolution(smoothed,muonSimHitsPerId,h1DSimHitRes);
  }
}

bool MuonTrackResidualAnalyzer::isInTheAcceptance(double eta) {
  switch (theEtaRange) {
    case all:
      return (abs(eta) <= 2.4) ? true : false;
    case barrel:
      return (abs(eta) < 1.1) ? true : false;
    case endcap:
      return (abs(eta) >= 1.1 && abs(eta) <= 2.4) ? true : false;
    default: {
      LogDebug("MuonTrackResidualAnalyzer") << "No correct Eta range selected!! ";
      return false;
    }
  }
}

// map the muon simhits by id
map<DetId, const PSimHit *> MuonTrackResidualAnalyzer::mapMuSimHitsPerId(Handle<PSimHitContainer> dtSimhits,
                                                                         Handle<PSimHitContainer> cscSimhits,
                                                                         Handle<PSimHitContainer> rpcSimhits) {
  MuonPatternRecoDumper debug;

  map<DetId, const PSimHit *> hitIdMap;
  theSimHitContainer.clear();

  mapMuSimHitsPerId(dtSimhits, hitIdMap);
  mapMuSimHitsPerId(cscSimhits, hitIdMap);
  mapMuSimHitsPerId(rpcSimhits, hitIdMap);

  if (theSimHitContainer.size() > 1)
    stable_sort(
        theSimHitContainer.begin(), theSimHitContainer.end(), RadiusComparatorInOut(theService->trackingGeometry()));

  LogDebug("MuonTrackResidualAnalyzer") << "Sim Hit list";
  int count = 1;
  for (vector<const PSimHit *>::const_iterator it = theSimHitContainer.begin(); it != theSimHitContainer.end(); ++it) {
    LogTrace("MuonTrackResidualAnalyzer")
        << count << " "
        << " Process Type: " << (*it)->processType() << " " << debug.dumpMuonId(DetId((*it)->detUnitId())) << endl;
  }

  return hitIdMap;
}

void MuonTrackResidualAnalyzer::mapMuSimHitsPerId(Handle<PSimHitContainer> simhits,
                                                  map<DetId, const PSimHit *> &hitIdMap) {
  for (PSimHitContainer::const_iterator simhit = simhits->begin(); simhit != simhits->end(); ++simhit) {
    if (abs(simhit->particleType()) != 13 && theSimTkId != simhit->trackId())
      continue;

    theSimHitContainer.push_back(&*simhit);
    DetId id = DetId(simhit->detUnitId());

    if (id.subdetId() == MuonSubdetId::DT) {
      DTLayerId lId(id.rawId());
      id = DetId(lId.rawId());
    }

    map<DetId, const PSimHit *>::const_iterator it = hitIdMap.find(id);

    if (it == hitIdMap.end())
      hitIdMap[id] = &*simhit;
    else
      LogDebug("MuonTrackResidualAnalyzer") << "TWO muons in the same sensible volume!!";

    ++theMuonSimHitNumberPerEvent;
  }
}

void MuonTrackResidualAnalyzer::computeResolution(Trajectory &trajectory,
                                                  map<DetId, const PSimHit *> &hitIdMap,
                                                  HResolution1DRecHit *histos) {
  Trajectory::DataContainer data = trajectory.measurements();

  for (Trajectory::DataContainer::const_iterator datum = data.begin(); datum != data.end(); ++datum) {
    GlobalPoint fitPoint = datum->updatedState().globalPosition();

    // FIXME!
    //     double errX = datum->updatedState().cartesianError().matrix()[0][0];
    //     double errY = datum->updatedState().cartesianError().matrix()[1][1];
    //     double errZ = datum->updatedState().cartesianError().matrix()[2][2];
    //
    double errX = datum->updatedState().localError().matrix()(3, 3);
    double errY = datum->updatedState().localError().matrix()(4, 4);
    double errZ = 1.;

    map<DetId, const PSimHit *>::const_iterator it = hitIdMap.find(datum->recHit()->geographicalId());

    if (it == hitIdMap.end())
      continue;  // FIXME! Put a counter

    const PSimHit *simhit = it->second;

    LocalPoint simHitPoint = simhit->localPosition();

    const GeomDet *geomDet = theService->trackingGeometry()->idToDet(DetId(simhit->detUnitId()));

    LocalPoint fitLocalPoint = geomDet->toLocal(fitPoint);

    LocalVector diff = fitLocalPoint - simHitPoint;

    cout << "SimHit position " << simHitPoint << endl;
    cout << "Fit position " << fitLocalPoint << endl;
    cout << "Fit position2 " << datum->updatedState().localPosition() << endl;
    cout << "Errors on the fit position: (" << errX << "," << errY << "," << errZ << ")" << endl;
    cout << "Resolution on x: " << diff.x() / abs(simHitPoint.x()) << endl;
    cout << "Resolution on y: " << diff.y() / abs(simHitPoint.y()) << endl;
    cout << "Resolution on z: " << diff.z() / abs(simHitPoint.z()) << endl;

    cout << "Eta direction: " << simhit->momentumAtEntry().eta() << " eta position: " << simHitPoint.eta() << endl;
    cout << "Phi direction: " << simhit->momentumAtEntry().phi() << " phi position: " << simHitPoint.phi() << endl;

    histos->Fill(simHitPoint.x(),
                 simHitPoint.y(),
                 simHitPoint.z(),
                 diff.x(),
                 diff.y(),
                 diff.z(),
                 errX,
                 errY,
                 errZ,
                 simhit->momentumAtEntry().eta(),
                 simhit->momentumAtEntry().phi());
    // simHitPoint.eta(), simHitPoint.phi() ); // FIXME!
  }
}