examples/JDynamics/JConvertEvt.cc

Go to the documentation of this file.

 
#include <string>
#include <iostream>
#include <iomanip>
#include <algorithm>
#include <memory>
 
#include "TROOT.h"
#include "TFile.h"
 
#include "km3net-dataformat/offline/Head.hh"
#include "km3net-dataformat/offline/Evt.hh"
#include "km3net-dataformat/offline/io_online.hh"
 
#include "JDetector/JDetector.hh"
#include "JDetector/JDetectorToolkit.hh"
#include "JDetector/JPMTRouter.hh"
#include "JDetector/JModuleRouter.hh"
#include "JDetector/JPMTParametersMap.hh"
#include "JDetector/JPMTAnalogueSignalProcessor.hh"
 
#include "JDynamics/JDynamics.hh"
 
#include "JCompass/JSupport.hh"
 
#include "JAcoustics/JSupport.hh"
 
#include "JTrigger/JHit.hh"
#include "JTrigger/JHitToolkit.hh"
 
#include "JAAnet/JHead.hh"
#include "JAAnet/JHeadToolkit.hh"
#include "JAAnet/JAAnetToolkit.hh"
 
#include "JDAQ/JDAQEventIO.hh"
#include "JDAQ/JDAQSummarysliceIO.hh"
 
#include "JSupport/JSingleFileScanner.hh"
#include "JSupport/JTreeScanner.hh"
#include "JSupport/JFileRecorder.hh"
#include "JSupport/JMonteCarloFileSupportkit.hh"
#include "JSupport/JSupportToolkit.hh"
#include "JSupport/JSupport.hh"
#include "JSupport/JMeta.hh"
 
#include "Jeep/JeepToolkit.hh"
#include "Jeep/JParser.hh"
#include "Jeep/JMessage.hh"
 
 
/**
 * \file
 * Auxiliary program to convert trigger files to Evt format.
 *
 * \author mdejong, jseneca
 */
int main(int argc, char **argv)
{
  using namespace std;
  using namespace JPP;
  using namespace KM3NETDAQ;
 
  typedef JMultipleFileScanner<calibration_types>                  JCalibration_t;
 
  JMultipleFileScanner<> inputFile;
  JFileRecorder<JTYPELIST<Head, Evt, JDAQSummaryslice, JMeta>::typelist> outputFile;
  JLimit_t&              numberOfEvents = inputFile.getLimit();
  string                 detectorFile;
  JCalibration_t         calibrationFile;
  double                 Tmax_s;
  JPMTParametersMap      pmtParameters;
  int                    debug;
 
  try {
 
    JParser<> zap("Auxiliary program to convert fit results to Evt format.\
                  \nThe option -L corresponds to the name of a shared library \
                  \nand function so to rearrange the order of fit results.");
 
    zap['f'] = make_field(inputFile);
    zap['o'] = make_field(outputFile)          = "aanet.root";
    zap['n'] = make_field(numberOfEvents)      = JLimit::max();
    zap['a'] = make_field(detectorFile)        = "";
    zap['+'] = make_field(calibrationFile)     = JPARSER::initialised();
    zap['T'] = make_field(Tmax_s)              = 100.0;
    zap['P'] = make_field(pmtParameters,       "PMT simulation data (or corresponding file name)")                 = JPARSER::initialised();
    zap['d'] = make_field(debug)               = 2;
 
    zap(argc, argv);
  }
  catch(const exception& error) {
    FATAL(error.what() << endl);
  }
 
 
  typedef JSingleFileScanner< JDAQEvent >                             JSingleFileScanner_t;
  typedef JSingleFileScanner_t::pointer_type                          pointer_type;
 
 
  JDetector detector;
 
  if (detectorFile != "") {
    try {
      load(detectorFile, detector);
    }
    catch(const JException& error) {
      FATAL(error);
    }
  }
 
  unique_ptr<JDynamics> dynamics;
 
  try {
 
    dynamics.reset(new JDynamics(detector, Tmax_s));
 
    dynamics->load(calibrationFile);
  }
  catch(const exception& error) {
    if (!calibrationFile.empty()) {
      FATAL(error.what());
    }
  }
 
 
  const JPMTRouter    pmt_router(dynamics ? dynamics->getDetector() : detector);
  const JModuleRouter mod_router(dynamics ? dynamics->getDetector() : detector);
 
 
  outputFile.open();
 
  Head header;
 
  try {
    header = getHeader(inputFile);
  } catch(const exception& error) {}
  {
    JAANET::JHead buffer(header);
 
    buffer.DAQ.livetime_s = getLivetime(inputFile.begin(), inputFile.end());
    buffer.push(&JAANET::JHead::DAQ);
    
    copy(buffer, header);
  }
  
  outputFile.put(header);
 
 
  outputFile.put(JMeta(argc, argv));
 
 
  counter_type number_of_events = 0;
 
  for (JMultipleFileScanner<>::const_iterator i = inputFile.begin(); i != inputFile.end(); ++i) {
    
    STATUS("Processing: " << *i << endl);
    
    JSingleFileScanner_t in(*i);
    JTreeScanner<Evt>      mc(*i);
 
    in.setLimit(inputFile.getLimit());
    
    Vec offset(0,0,0);
 
    int mc_run_id = 0;
    
    try {
 
      const JAANET::JHead head(getHeader(*i));
    
      offset    = getOffset(head);
      mc_run_id = head.start_run.run_id;
      
    } catch(const exception& error) {}
 
 
    while (in.hasNext()) {
 
      STATUS("event: " << setw(10) << in.getCounter() << '\r'); DEBUG(endl);
 
      pointer_type ps = in.next();
 
      JDAQEvent*  tev   = ps;
 
      if (dynamics) {
        dynamics->update(*tev);                                                      // update detector
      }
      
      Evt out;                                                                       // output event
 
      if (mc.getEntries() != 0) {
 
        Evt* event = mc.getEntry(tev->getCounter());
 
        if (event != NULL) {
 
          out = *event;                                                              // import Monte Carlo true data
 
          if (out.mc_run_id == 0) {
            out.mc_run_id = mc_run_id;
          }
 
          for (vector<Trk>::iterator i = out.mc_trks.begin(); i != out.mc_trks.end(); ++i) {
            i->pos += offset;                                                        // offset true positions
          }
        }
      }
      
      read(out, *tev);                                                               // import DAQ data
 
      if (!pmt_router->empty()) {                                                    // import calibration data
 
        for (vector<Hit>::iterator i = out.mc_hits.begin(); i != out.mc_hits.end(); ++i) {
 
          if (pmt_router.hasPMT(i->pmt_id)) {
 
            const JPMTAddress    address = pmt_router.getAddress(i->pmt_id);
            const JPMTIdentifier id      = pmt_router.getIdentifier(address);
            const JPMT&          pmt     = pmt_router.getPMT(address);
 
            i->dom_id     = id.getID();
            i->channel_id = id.getPMTAddress();
            i->pos        = getPosition (pmt);
            i->dir        = getDirection(pmt);
 
          } else {
 
            FATAL("Missing PMT" << i->pmt_id << endl);
          }
        }
      }
 
      if (!mod_router->empty()) {                                                    // import calibration data
 
        for (vector<Hit>::iterator i = out.hits.begin(); i != out.hits.end(); ++i) {
 
          if (mod_router.hasModule(i->dom_id)) {
 
            const JPMTIdentifier id(i->dom_id, i->channel_id);
 
            const JPMTParameters&             parameters = pmtParameters.getPMTParameters(id);
            const JPMTAnalogueSignalProcessor cpu(parameters);
 
            const JPMT& pmt = mod_router.getPMT(id);
 
            JTRIGGER::JHit::setSlewing(parameters.slewing);
            
            const JTRIGGER::JHit hit(getTime(i->tdc, pmt.getCalibration()), i->tot);
            
            i->pmt_id = pmt.getID();
            i->pos    = getPosition (pmt);
            i->dir    = getDirection(pmt);
            i->t      = hit.getT();
            i->tot    = hit.getToT();
            i->a      = cpu.getNPE(i->tot);
 
          } else {
 
            FATAL("Missing module " << i->dom_id << endl);
          }
        }
      }
 
      out.id = ++number_of_events;
 
      outputFile.put(out);
    }
  }
 
  STATUS(endl);
 
  JMultipleFileScanner<JTYPELIST<JDAQSummaryslice, JMeta>::typelist> io(inputFile);
 
  io >> outputFile;
 
  outputFile.close();
}