No OneTemporary
Actions

Size

18 KB

Subscribers

None

View Options

	diff --git a/app/PrepareGENIE.cxx b/app/PrepareGENIE.cxx
	index bf3355c..5eb2060 100644
	--- a/app/PrepareGENIE.cxx
	+++ b/app/PrepareGENIE.cxx
	@@ -1,565 +1,569 @@
	#include <stdio.h>
	#include <stdlib.h>
	#include "FitLogger.h"
	#include "PlotUtils.h"
	#include "TFile.h"
	#include "TH1D.h"
	#include "TTree.h"

	#ifdef __GENIE_ENABLED__
	#include "Conventions/Units.h"
	#include "GHEP/GHepParticle.h"
	#include "PDG/PDGUtils.h"
	#endif

	std::string gInputFiles = "";
	std::string gOutputFile = "";
	std::string gFluxFile = "";
	std::string gTarget = "";
	double MonoEnergy;
	bool IsMonoE = false;

	void PrintOptions();
	void ParseOptions(int argc, char* argv[]);
	void RunGENIEPrepareMono(std::string input, std::string target,
	std::string output);
	void RunGENIEPrepare(std::string input, std::string flux, std::string target,
	std::string output);

	int main(int argc, char* argv[]) {
	ParseOptions(argc, argv);
	if (IsMonoE) {
	RunGENIEPrepareMono(gInputFiles, gTarget, gOutputFile);
	} else {
	RunGENIEPrepare(gInputFiles, gFluxFile, gTarget, gOutputFile);
	}
	}

	void RunGENIEPrepareMono(std::string input, std::string target,
	std::string output) {
	// Setup TTree
	TChain* tn = new TChain("gtree");
	tn->AddFile(input.c_str());

	int nevt = tn->GetEntries();
	NtpMCEventRecord* genientpl = NULL;
	tn->SetBranchAddress("gmcrec", &genientpl);

	TH1D* fluxhist = new TH1D("flux", "flux", 1000, 0, 10);
	fluxhist->Fill(MonoEnergy);
	fluxhist->Scale(1, "width");

	// Make Event Hist
	TH1D* eventhist = (TH1D*)fluxhist->Clone();
	eventhist->Reset();

	TH1D* xsechist = (TH1D*)eventhist->Clone();

	// Create maps
	std::map<std::string, TH1D*> modexsec;
	std::map<std::string, TH1D*> modecount;
	std::vector<std::string> genieids;
	std::vector<std::string> targetids;
	std::vector<std::string> interids;

	// Loop over all events
	for (int i = 0; i < nevt; i++) {
	tn->GetEntry(i);

	StopTalking();
	EventRecord& event = *(genientpl->event);
	GHepParticle* neu = event.Probe();
	StartTalking();

	// Get XSec From Spline
	GHepRecord genie_record = static_cast<GHepRecord>(event);
	double xsec = (genie_record.XSec() / (1E-38 * genie::units::cm2));

	// Parse Interaction String
	std::string mode = genie_record.Summary()->AsString();
	std::vector<std::string> modevec = GeneralUtils::ParseToStr(mode, ";");
	std::string targ = (modevec[0] + ";" + modevec[1]);
	std::string inter = mode;

	// Fill lists of Unique IDS
	if (std::find(targetids.begin(), targetids.end(), targ) ==
	targetids.end()) {
	targetids.push_back(targ);
	}

	if (std::find(interids.begin(), interids.end(), inter) == interids.end()) {
	interids.push_back(inter);
	}

	// Create entries Mode Maps
	if (modexsec.find(mode) == modexsec.end()) {
	genieids.push_back(mode);

	modexsec[mode] = (TH1D*)xsechist->Clone();
	modecount[mode] = (TH1D*)xsechist->Clone();
	}

	// Fill XSec Histograms
	modexsec[mode]->Fill(neu->E(), xsec);
	modecount[mode]->Fill(neu->E());

	// Fill total event hist
	eventhist->Fill(neu->E());

	// Clear Event
	genientpl->Clear();

	if (i % (nevt / 20) == 0) {
	LOG(FIT) << "Processed " << i << "/" << nevt << " GENIE events."
	<< std::endl;
	}
	}
	LOG(FIT) << "Processed all events" << std::endl;

	TFile* outputfile = new TFile(input.c_str(), "UPDATE");
	outputfile->cd();

	LOG(FIT) << "Getting splines " << std::endl;

	// Save each of the reconstructed splines to file
	std::map<std::string, TH1D*> modeavg;

	TDirectory* inddir = (TDirectory*)outputfile->Get("IndividualGENIESplines");
	if (!inddir)
	inddir = (TDirectory*)outputfile->mkdir("IndividualGENIESplines");
	inddir->cd();

	// Loop over GENIE ID's and get MEC count
	int MECcount = 0;
	bool MECcorrect = FitPar::Config().GetParB("CorrectGENIEMECNorm");
	for (UInt_t i = 0; i < genieids.size(); i++) {
	if (genieids[i].find("MEC") != std::string::npos) {
	MECcount++;
	}
	}
	LOG(FIT) << "Found " << MECcount << " repeated MEC instances." << std::endl;

	for (UInt_t i = 0; i < genieids.size(); i++) {
	std::string mode = genieids[i];

	modexsec[mode]->Write((mode + "_summed_xsec").c_str(), TObject::kOverwrite);
	modecount[mode]->Write((mode + "_summed_evt").c_str(), TObject::kOverwrite);

	// Form extra avg xsec map -> Reconstructed spline
	modeavg[mode] = (TH1D*)modexsec[mode]->Clone();
	modeavg[mode]->Divide(modecount[mode]);

	if (MECcorrect && (mode.find("MEC") != std::string::npos)) {
	modeavg[mode]->Scale(1.0 / double(MECcount));
	}

	modeavg[mode]->Write((mode + "_rec_spline").c_str(), TObject::kOverwrite);
	}

	TDirectory* targdir = (TDirectory*)outputfile->Get("TargetGENIESplines");
	if (!targdir) targdir = (TDirectory*)outputfile->mkdir("TargetGENIESplines");
	targdir->cd();

	LOG(FIT) << "Getting Target Splines" << std::endl;
	// For each target save a total spline
	std::map<std::string, TH1D*> targetsplines;

	for (uint i = 0; i < targetids.size(); i++) {
	LOG(FIT) << "Getting target " << i << std::endl;
	std::string targ = targetids[i];
	targetsplines[targ] = (TH1D*)xsechist->Clone();
	LOG(FIT) << "Created target spline for " << targ << std::endl;

	for (uint j = 0; j < genieids.size(); j++) {
	std::string mode = genieids[j];

	if (mode.find(targ) != std::string::npos) {
	LOG(FIT) << "Mode " << mode << " contains " << targ << " target!"
	<< std::endl;
	targetsplines[targ]->Add(modeavg[mode]);
	LOG(FIT) << "Finished with Mode " << mode << " "
	<< modeavg[mode]->Integral() << std::endl;
	}
	}

	LOG(FIT) << "Saving target spline:" << targ << std::endl;
	targetsplines[targ]->Write(("Total" + targ).c_str(), TObject::kOverwrite);
	}

	LOG(FIT) << "Getting total splines" << std::endl;
	// Now we have each of the targets we need to create a total cross-section.
	int totalnucl = 0;
	std::vector<std::string> targprs = GeneralUtils::ParseToStr(target, ",");
	TH1D* totalxsec = (TH1D*)xsechist->Clone();

	for (uint i = 0; i < targprs.size(); i++) {
	std::string targpdg = targprs[i];

	for (std::map<std::string, TH1D*>::iterator iter = targetsplines.begin();
	iter != targetsplines.end(); iter++) {
	std::string targstr = iter->first;
	TH1D* xsec = iter->second;

	if (targstr.find(targpdg) != std::string::npos) {
	LOG(FIT) << "Adding target spline " << targstr
	<< " Integral = " << xsec->Integral("width") << std::endl;
	totalxsec->Add(xsec);

	int nucl = atoi(targpdg.c_str());
	totalnucl += int((nucl % 10000) / 10);
	}
	}
	}

	outputfile->cd();
	totalxsec->Write("nuisance_Xsec", TObject::kOverwrite);
	eventhist = (TH1D*)totalxsec->Clone();
	eventhist->Multiply(fluxhist);

	eventhist->Write("nuisance_events", TObject::kOverwrite);
	fluxhist->Write("nuisance_flux", TObject::kOverwrite);

	LOG(FIT) << "Inclusive XSec Per Nucleon = "
	<< eventhist->Integral("width") * 1E-38 / fluxhist->Integral("width")
	<< std::endl;
	std::cout << "XSec Hist Integral = " << xsechist->Integral("width")
	<< std::endl;

	return;
	}

	void RunGENIEPrepare(std::string input, std::string flux, std::string target,
	std::string output) {
	LOG(FIT) << "Running GENIE Prepare" << std::endl;

	// Get Flux Hist
	std::vector<std::string> fluxvect = GeneralUtils::ParseToStr(flux, ",");
	TH1D* fluxhist = NULL;
	if (fluxvect.size() == 3) {
	double from = GeneralUtils::StrToDbl(fluxvect[0]);
	double to = GeneralUtils::StrToDbl(fluxvect[1]);
	- int step = GeneralUtils::StrToInt(fluxvect[2]);
	+ double step = GeneralUtils::StrToDbl(fluxvect[2]);
	+
	+ int nstep = ceil((to - from) / step);
	+ to = from + step * nstep;

	QLOG(FIT, "Generating flat flux histogram from "
	<< from << " to " << to << " with bins " << step << " wide.");
	+
	fluxhist =
	new TH1D("spectrum", ";E_{#nu} (GeV);Count (A.U.)", step, from, to);
	fluxhist->SetDirectory(0);
	} else if (fluxvect.size() == 2) {
	TFile* fluxfile = new TFile(fluxvect[0].c_str(), "READ");
	if (!fluxfile->IsZombie()) {
	fluxhist = dynamic_cast<TH1D*>(fluxfile->Get(fluxvect[1].c_str()));
	if (!fluxhist) {
	ERR(FTL) << "Couldn't find histogram named: \"" << fluxvect[1]
	<< "\" in file: \"" << fluxvect[0] << std::endl;
	throw;
	}
	fluxhist->SetDirectory(0);
	}
	} else if (fluxvect.size() == 1) {
	MonoEnergy = GeneralUtils::StrToDbl(fluxvect[0]);
	RunGENIEPrepareMono(input, target, output);
	return;
	} else {
	LOG(FTL) << "Bad flux specification: \"" << flux << "\"." << std::endl;
	throw;
	}

	// Setup TTree
	TChain* tn = new TChain("gtree");
	tn->AddFile(input.c_str());

	int nevt = tn->GetEntries();
	NtpMCEventRecord* genientpl = NULL;
	tn->SetBranchAddress("gmcrec", &genientpl);

	// Make Event Hist
	TH1D* eventhist = (TH1D*)fluxhist->Clone();
	eventhist->Reset();

	TH1D* xsechist = (TH1D*)eventhist->Clone();

	// Create maps
	std::map<std::string, TH1D*> modexsec;
	std::map<std::string, TH1D*> modecount;
	std::vector<std::string> genieids;
	std::vector<std::string> targetids;
	std::vector<std::string> interids;

	// Loop over all events
	for (int i = 0; i < nevt; i++) {
	tn->GetEntry(i);

	StopTalking();
	EventRecord& event = *(genientpl->event);
	GHepParticle* neu = event.Probe();
	StartTalking();

	// Get XSec From Spline
	GHepRecord genie_record = static_cast<GHepRecord>(event);
	double xsec = (genie_record.XSec() / (1E-38 * genie::units::cm2));

	// Parse Interaction String
	std::string mode = genie_record.Summary()->AsString();
	std::vector<std::string> modevec = GeneralUtils::ParseToStr(mode, ";");
	std::string targ = (modevec[0] + ";" + modevec[1]);
	std::string inter = mode;

	// Fill lists of Unique IDS
	if (std::find(targetids.begin(), targetids.end(), targ) ==
	targetids.end()) {
	targetids.push_back(targ);
	}

	if (std::find(interids.begin(), interids.end(), inter) == interids.end()) {
	interids.push_back(inter);
	}

	// Create entries Mode Maps
	if (modexsec.find(mode) == modexsec.end()) {
	genieids.push_back(mode);

	modexsec[mode] = (TH1D*)xsechist->Clone();
	modecount[mode] = (TH1D*)xsechist->Clone();
	}

	// Fill XSec Histograms
	modexsec[mode]->Fill(neu->E(), xsec);
	modecount[mode]->Fill(neu->E());

	// Fill total event hist
	eventhist->Fill(neu->E());

	// Clear Event
	genientpl->Clear();

	if (i % (nevt / 20) == 0) {
	LOG(FIT) << "Processed " << i << "/" << nevt << " GENIE events."
	<< std::endl;
	}
	}
	LOG(FIT) << "Processed all events" << std::endl;

	// Once event loop is done we can start saving stuff into the file

	TFile* outputfile = new TFile(input.c_str(), "UPDATE");
	outputfile->cd();

	LOG(FIT) << "Getting splines " << std::endl;

	// Save each of the reconstructed splines to file
	std::map<std::string, TH1D*> modeavg;

	TDirectory* inddir = (TDirectory*)outputfile->Get("IndividualGENIESplines");
	if (!inddir)
	inddir = (TDirectory*)outputfile->mkdir("IndividualGENIESplines");
	inddir->cd();

	// Loop over GENIE ID's and get MEC count
	int MECcount = 0;
	bool MECcorrect = FitPar::Config().GetParB("CorrectGENIEMECNorm");
	for (UInt_t i = 0; i < genieids.size(); i++) {
	if (genieids[i].find("MEC") != std::string::npos) {
	MECcount++;
	}
	}
	LOG(FIT) << "Found " << MECcount << " repeated MEC instances." << std::endl;

	for (UInt_t i = 0; i < genieids.size(); i++) {
	std::string mode = genieids[i];

	modexsec[mode]->Write((mode + "_summed_xsec").c_str(), TObject::kOverwrite);
	modecount[mode]->Write((mode + "_summed_evt").c_str(), TObject::kOverwrite);

	// Form extra avg xsec map -> Reconstructed spline
	modeavg[mode] = (TH1D*)modexsec[mode]->Clone();
	modeavg[mode]->Divide(modecount[mode]);

	if (MECcorrect && (mode.find("MEC") != std::string::npos)) {
	modeavg[mode]->Scale(1.0 / double(MECcount));
	}

	modeavg[mode]->Write((mode + "_rec_spline").c_str(), TObject::kOverwrite);
	}

	TDirectory* targdir = (TDirectory*)outputfile->Get("TargetGENIESplines");
	if (!targdir) targdir = (TDirectory*)outputfile->mkdir("TargetGENIESplines");
	targdir->cd();

	LOG(FIT) << "Getting Target Splines" << std::endl;
	// For each target save a total spline
	std::map<std::string, TH1D*> targetsplines;

	for (uint i = 0; i < targetids.size(); i++) {
	LOG(FIT) << "Getting target " << i << std::endl;
	std::string targ = targetids[i];
	targetsplines[targ] = (TH1D*)xsechist->Clone();
	LOG(FIT) << "Created target spline for " << targ << std::endl;

	for (uint j = 0; j < genieids.size(); j++) {
	std::string mode = genieids[j];

	// Look at all matching modes/targets
	if (mode.find(targ) != std::string::npos) {
	LOG(FIT) << "Mode " << mode << " contains " << targ << " target!"
	<< std::endl;
	// modeavg[mode]->Write( (mode + "_cont_" + targ).c_str() ,
	// TObject::kOverwrite);
	targetsplines[targ]->Add(modeavg[mode]);
	LOG(FIT) << "Finished with Mode " << mode << " "
	<< modeavg[mode]->Integral() << std::endl;
	}
	}

	LOG(FIT) << "Saving target spline:" << targ << std::endl;
	targetsplines[targ]->Write(("Total" + targ).c_str(), TObject::kOverwrite);
	}

	LOG(FIT) << "Getting total splines" << std::endl;
	// Now we have each of the targets we need to create a total cross-section.
	int totalnucl = 0;
	std::vector<std::string> targprs = GeneralUtils::ParseToStr(target, ",");
	TH1D* totalxsec = (TH1D*)xsechist->Clone();

	for (uint i = 0; i < targprs.size(); i++) {
	std::string targpdg = targprs[i];

	for (std::map<std::string, TH1D*>::iterator iter = targetsplines.begin();
	iter != targetsplines.end(); iter++) {
	std::string targstr = iter->first;
	TH1D* xsec = iter->second;

	if (targstr.find(targpdg) != std::string::npos) {
	LOG(FIT) << "Adding target spline " << targstr
	<< " Integral = " << xsec->Integral("width") << std::endl;
	totalxsec->Add(xsec);

	int nucl = atoi(targpdg.c_str());
	totalnucl += int((nucl % 10000) / 10);
	}
	}
	}
	LOG(FIT) << "Total XSec Integral = " << totalxsec->Integral("width")
	<< std::endl;

	outputfile->cd();
	totalxsec->Write("nuisance_xsec", TObject::kOverwrite);
	eventhist = (TH1D*)fluxhist->Clone();
	eventhist->Multiply(totalxsec);

	LOG(FIT) << "Dividing by Total Nucl = " << totalnucl << std::endl;
	eventhist->Scale(1.0 / double(totalnucl));

	eventhist->Write("nuisance_events", TObject::kOverwrite);
	fluxhist->Write("nuisance_flux", TObject::kOverwrite);

	LOG(FIT) << "Inclusive XSec Per Nucleon = "
	<< eventhist->Integral("width") * 1E-38 / fluxhist->Integral("width")
	<< std::endl;
	std::cout << "XSec Hist Integral = " << xsechist->Integral("width")
	<< std::endl;

	return;
	};

	void PrintOptions() {
	std::cout << "PrepareGENIEEvents NUISANCE app. " << std::endl
	<< "Takes GHep Outputs and prepares events for NUISANCE."
	<< std::endl
	<< std::endl
	<< "PrepareGENIEEvents [-h,-help,--h,--help] [-i "
	"inputfile1.root,inputfile2.root,inputfile3.root,...] "
	<< "[-f flux_root_file.root,flux_hist_name] [-t "
	"target1[frac1],target2[frac2],...]"
	<< std::endl
	<< std::endl;

	std::cout << "Prepare Mode [Default] : Takes a single GHep file, "
	"reconstructs the original GENIE splines, "
	<< " and creates a duplicate file that also contains the flux, "
	"event rate, and xsec predictions that NUISANCE needs. "
	<< std::endl;
	std::cout << "Following options are required for Prepare Mode:" << std::endl;
	std::cout << " [ -i inputfile.root ] : Reads in a single GHep input file "
	"that needs the xsec calculation ran on it. "
	<< std::endl;
	std::cout << " [ -f flux_file.root,hist_name ] : Path to root file "
	"containing the flux histogram the GHep records were generated "
	"with."
	<< " A simple method is to point this to the flux histogram genie "
	"generatrs '-f /path/to/events/input-flux.root,spectrum'. "
	<< std::endl;
	std::cout << " [ -f elow,ehigh,estep ] : Energy range specification when no "
	"flux file was used."
	<< std::endl;
	std::cout << " [ -t target ] : Target that GHepRecords were generated with. "
	"Comma seperated list. E.g. for CH2 "
	"target=1000060120,1000010010,1000010010"
	<< std::endl;
	std::cout << " [ -o outputfile.root ] : File to write prepared input file to."
	<< std::endl;
	std::cout << " [ -m Mono_E_nu_GeV ] : Run in mono-energetic mode."
	<< std::endl;
	}

	void ParseOptions(int argc, char* argv[]) {
	bool flagopt = false;

	// If No Arguments print commands
	for (int i = 1; i < argc; ++i) {
	if (!std::strcmp(argv[i], "-h")) {
	flagopt = true;
	break;
	}
	if (i + 1 != argc) {
	// Cardfile
	if (!std::strcmp(argv[i], "-h")) {
	flagopt = true;
	break;
	} else if (!std::strcmp(argv[i], "-i")) {
	gInputFiles = argv[i + 1];
	++i;
	} else if (!std::strcmp(argv[i], "-o")) {
	gOutputFile = argv[i + 1];
	++i;
	} else if (!std::strcmp(argv[i], "-f")) {
	gFluxFile = argv[i + 1];
	++i;
	} else if (!std::strcmp(argv[i], "-t")) {
	gTarget = argv[i + 1];
	++i;
	} else if (!std::strcmp(argv[i], "-m")) {
	MonoEnergy = GeneralUtils::StrToDbl(argv[i + 1]);
	IsMonoE = true;
	++i;
	} else {
	ERR(FTL) << "ERROR: unknown command line option given! - '" << argv[i]
	<< " " << argv[i + 1] << "'" << std::endl;
	PrintOptions();
	break;
	}
	}
	}

	if (gInputFiles == "" && !flagopt) {
	ERR(FTL) << "No input file(s) specified!" << std::endl;
	flagopt = true;
	}

	if (gFluxFile == "" && !flagopt) {
	ERR(FTL) << "No flux input specified for Prepare Mode" << std::endl;
	flagopt = true;
	}

	if (gTarget == "" && !flagopt) {
	ERR(FTL) << "No target specified for Prepare Mode" << std::endl;
	flagopt = true;
	}

	if (argc < 1 \|\| flagopt) {
	PrintOptions();
	exit(-1);
	}

	return;
	}

File Metadata

Mime Type: text/x-diff
Expires: Tue, Nov 19, 8:02 PM (1 d, 5 h)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 3805959
Default Alt Text: (18 KB)

No OneTemporaryActions

View Options

File Metadata

Event Timeline

No OneTemporary
Actions