StEEmcPool/StEEmcPointMaker/StEEmcPointMaker.cxx

#include "StEEmcPointMaker.h" 
#include "StEEmcPool/StEEmcA2EMaker/StEEmcA2EMaker.h"
#include "StEEmcPool/StEEmcClusterMaker/StEEmcClusterMaker.h"

#include "StEEmcUtil/EEmcGeom/EEmcGeomDefs.h"
#include "StEEmcUtil/EEmcGeom/EEmcGeomSimple.h"
#include "StEEmcUtil/StEEmcSmd/EEmcSmdGeom.h" 

#include <iostream> 
#include <algorithm>
#include <map>

#include "eeTowerFunction.h"

/* StEvent stuff */
#include "StEvent/StEvent.h"
#include "StEvent/StEmcCollection.h"
#include "StEvent/StEmcPoint.h"

/* Root's linear algebra package */
#include "TMatrixF.h"

//#define DEBUG_buildPoints

ClassImp(StEEmcPointMaker);

// ----------------------------------------------------------------------------
StEEmcPointMaker::StEEmcPointMaker(const Char_t *name):StMaker(name)
{
    std::cout << "StEEmcPointMaker("<<name<<")" << std::endl << std::flush; 

    mEEtow=new EEmcGeomSimple();
    mEEsmd=EEmcSmdGeom::instance();
    mEEmap=EEmcSmdMap::instance(); 

    mTowerThreshold=0.;
    mFillStEvent=false;
    mEnergyMode=1;
    mLimit=10;
    mSmdMatch = 0.;

}

// ----------------------------------------------------------------------------
Int_t StEEmcPointMaker::Init()
{
    mEEanalysis=(StEEmcA2EMaker*)GetMaker(mNameAnalysis);
    mEEclusters=(StEEmcClusterMaker*)GetMaker(mNameClusters);
    assert(mEEanalysis);
    assert(mEEclusters);
    return StMaker::Init();
}

// ----------------------------------------------------------------------------
Int_t StEEmcPointMaker::Make()
{
 
  
  // Loop over all 12 EEMC sectors
  for ( Int_t sector=0; sector<12; sector++ )
    {

      StEEmcSmdClusterVec_t uclusters=mEEclusters->smdclusters(sector,0);
      StEEmcSmdClusterVec_t vclusters=mEEclusters->smdclusters(sector,1);

      std::sort( uclusters.begin(), uclusters.end(), inner );
      std::sort( vclusters.begin(), vclusters.end(), inner );

      findPoints( sector, uclusters, vclusters, mPoints );
      
    }


  for ( UInt_t i=0;i<mPoints.size();i++ )
    {
      mPoints[i].energy( (Float_t)(mPoints[i].energy()/0.007/2.) );
    }




  StEEmcPointVec_t orgpoints=mPoints;

  //  shareEnergy(); //  <<<<<<< leads to negative point energies... rethink

  if ( mEnergyMode == 1 )
    shareEnergySimple();
  else
    shareEnergySmd();


  countRelatives();
  

  if ( mFillStEvent )
    {
      fillStEvent();
      verifyStEvent();
    }

  /*
  for ( UInt_t i=0;i<mPoints.size();i++ )
    {
      mPoints[i].print();
    }
  for ( Int_t i=0;i<10;i++ ) std::cout << std::endl;
*/
    
  return kStOK;
}

// ----------------------------------------------------------------------------

StEEmcPointVec_t StEEmcPointMaker::buildSmdPoints( Int_t sector, 
                                                   StEEmcSmdClusterVec_t &u, 
                                                   StEEmcSmdClusterVec_t &v )
{

  StEEmcPointVec_t points;

  for ( UInt_t i=0; i<u.size(); i++ ) 
    {

      StEEmcSmdCluster uc=u[i];
      Float_t xu=uc.mean();

      for ( UInt_t j=0;j<v.size(); j++ ) 
        {


          StEEmcSmdCluster vc=v[j];
          Float_t xv=vc.mean();

          TVector3 direct = mEEsmd->getIntersection( sector, xu, xv );
          
          Int_t sec,sub,eta;
          if ( !mEEtow->getTower(direct,sec,sub,eta) )
            {
              continue; 
            }
          else
            {
            }

          if ( sector != sec )
            continue;



          Bool_t good = false;
          if ( mEEanalysis->tower(sec,sub,eta).energy() > mTowerThreshold ) 
            good=true;
          else if ( mEEanalysis->tower(sec,sub,eta).fail() ) 
            {
              for ( Int_t layer=1;layer<=3;layer++ ) 
                {
                  if ( mEEanalysis->tower(sec,sub,eta,layer).energy() > 0. )
                    good=true;          
                }
            }

          /*
          Float_t uvdiff = TMath::Abs( uc.energy() - vc.energy() );
          Float_t uvavg  = 0.5 * ( uc.energy() + vc.energy() );
          if ( uvdiff > mSmdMatch * uvavg ) good = false;
          */
          Float_t Eu=uc.energy();
          Float_t Ev=vc.energy();
          if ( Eu < mSmdMatch * Ev || Ev < mSmdMatch * Eu ) good=false;
          
          if ( good ) {

            StEEmcPoint p;
            p.cluster( uc, 0 );
            p.cluster( vc, 1 );
            p.energy( uc.energy() + vc.energy() );
            p.tower( mEEanalysis->tower(sec,sub,eta) );
            TVector3 position=mEEsmd->getIntersection(sector,uc.mean(),vc.mean());
            p.position(position);
            points.push_back(p);

            mSmdPoints.push_back(p);

          }
                        
        }

    }
  
  return points;

}

















// ----------------------------------------------------------------------------
Bool_t StEEmcPointMaker::findPoints( Int_t sector, 
                                     StEEmcSmdClusterVec_t uclusters, 
                                     StEEmcSmdClusterVec_t vclusters,
                                     StEEmcPointVec_t &points )
{


  StEEmcPointVec_t mypoints;

  std::sort( uclusters.begin(), uclusters.end(), inner );
  std::sort( vclusters.begin(), vclusters.end(), inner );

  StEEmcPointVec_t smdpoints = buildSmdPoints( sector, uclusters, vclusters );

  
  if ( smdpoints.size() < 1 ) return false;
  
  std::sort( smdpoints.begin(), smdpoints.end(), chiSquare );
  

  std::map< Int_t, std::vector<Int_t> > u2p, v2p;            
  for ( UInt_t i=0; i<smdpoints.size(); i++ ) 
    {
      u2p[ smdpoints[i].cluster(0).key() ].push_back( i );
      v2p[ smdpoints[i].cluster(1).key() ].push_back( i );        
    }

  Bool_t go = false;
  StEEmcSmdClusterVec_t::iterator uiter=uclusters.begin();
  StEEmcSmdClusterVec_t::iterator viter=vclusters.begin();


  
  //    ----------<<<<<<<<< stage one >>>>>>>>>-------------



  while ( uiter<uclusters.end() || viter<vclusters.end() )
    {

      StEEmcSmdCluster ucl;ucl.key(-1);
      StEEmcSmdCluster vcl;vcl.key(-1);
      if ( uiter<uclusters.end() ) ucl=(*uiter);
      if ( viter<vclusters.end() ) vcl=(*viter);
      Int_t iUV=-1;
      if ( ucl.key()<0 )
        iUV=1;
      else if ( vcl.key()<0 )
        iUV=0;
      else if ( (*uiter).mean() < (*viter).mean() )
        iUV=0;
      else
        iUV=1;

      StEEmcSmdCluster &cluster=(iUV==0)?ucl:vcl;

      std::vector<Int_t> matched=(iUV==0)?
        u2p[cluster.key()]:
        v2p[cluster.key()];


      if (  matched.size()==0 || matched.size() >1 )
        {
          if ( iUV==0 ) uiter++;
          if ( iUV==1 ) viter++;
          continue;
        }

      go=true;
        
      StEEmcPoint p=smdpoints[matched.back()];
      
      mypoints.push_back(p);

      if ( iUV==0 ) uiter++;
      if ( iUV==1 ) viter++;
          
    }


  Float_t chisq=9.0E9;
  Int_t  imin=-1;
  for ( UInt_t i=0; i<mypoints.size(); i++ )
    {
      Float_t eu=mypoints[i].cluster(0).energy();
      Float_t ev=mypoints[i].cluster(1).energy();
      Float_t x2=(eu-ev)*(eu-ev);
      if ( x2 < chisq ) {
        imin=(Int_t)i;
        chisq=x2;
      }
    }


  if ( imin >= 0 ) {

    StEEmcPoint p=mypoints[imin];
    removeCluster( uclusters, p.cluster(0).key() );
    removeCluster( vclusters, p.cluster(1).key() );
    points.push_back(p);
    findPoints(sector, uclusters, vclusters, points );
    return true;

  }







  uiter=uclusters.begin();
  viter=vclusters.begin();
  while ( uiter!=uclusters.end() || viter!=vclusters.end() )
    {

      StEEmcSmdCluster ucl;ucl.key(-1);
      StEEmcSmdCluster vcl;vcl.key(-1);
      if ( uiter!=uclusters.end() ) ucl=(*uiter);
      if ( viter!=vclusters.end() ) vcl=(*viter);
      Int_t iUV=-1;
      if ( ucl.key()<0 )
        iUV=1;
      else if ( vcl.key()<0 )
        iUV=0;
      else if ( (*uiter).mean() < (*viter).mean() )
        iUV=0;
      else
        iUV=1;

      StEEmcSmdCluster &cluster=(iUV==0)?ucl:vcl;

      std::vector<Int_t> matched=(iUV==0)?
        u2p[cluster.key()]:
        v2p[cluster.key()];

      if ( matched.size()==0 || matched.size()==1 )
        {
          if ( iUV==0 ) uiter++;
          if ( iUV==1 ) viter++;
          continue;
        }
      
      StEEmcPoint p=smdpoints[matched.front()];
      
      mypoints.push_back(p);
    
      if ( iUV==0 ) uiter++;
      if ( iUV==1 ) viter++;

    }


  chisq=9.0E9;
  imin=-1;
  for ( UInt_t i=0; i<mypoints.size(); i++ )
    {
      Float_t eu=mypoints[i].cluster(0).energy();
      Float_t ev=mypoints[i].cluster(1).energy();
      Float_t x2=(eu-ev)*(eu-ev);
      if ( x2 < chisq ) {
        imin=(Int_t)i;
        chisq=x2;
      }
    }



  if ( imin >= 0 ) {

    StEEmcPoint p=mypoints[imin];
    removeCluster( uclusters, p.cluster(0).key() );
    removeCluster( vclusters, p.cluster(1).key() );
    points.push_back(p);
    findPoints(sector, uclusters, vclusters, points );
    return true;

  }
 

  return true;

}



// ----------------------------------------------------------------------------
void  StEEmcPointMaker::Clear( Option_t *opts )
{

  mEseen=0.;
  mPoints.clear(); 
  mSmdPoints.clear(); 

}

// ----------------------------------------------------------------------------
void StEEmcPointMaker::removeCluster( StEEmcSmdClusterVec_t &clusters, Int_t k )
{
  StEEmcSmdClusterVec_t::iterator iter=clusters.begin();
  while ( iter != clusters.end() )
    {
      if ( (*iter).key() == k ) {
        clusters.erase(iter);
        return;
      }
      iter++;
    }
}

// ----------------------------------------------------------------------------
void StEEmcPointMaker::shareEnergy()
{




  Int_t nrow=(Int_t)mPoints.size();
  Int_t ncol=(Int_t)mPoints.size();
  if ( nrow < 1 ) return; 

  std::vector<Float_t> Ef(nrow,0.);

  TMatrixF fractions(nrow,ncol);

  for ( Int_t k=0; k<mEEanalysis->numberOfHitTowers(0); k++ ) 
    {

      StEEmcTower tower=mEEanalysis->hittower(k,0);

      for ( UInt_t i=0; i< mPoints.size(); i++ ) 
        {

          Float_t fi=fracp2t( mPoints[i], tower );
          if ( fi<=0. ) continue;

          Ef[i] += fi * tower.energy();

          for ( UInt_t j=0; j<mPoints.size(); j++ )
            {

              Float_t fj=fracp2t( mPoints[j], tower );
              if (fi*fj<=0.) continue;

              fractions[i][j] += fi*fj;
              
            }
          
        }

    }

  fractions.Print();

  Double_t det = 0.;
  TMatrixF invert= fractions;
  invert.Invert(&det);

  invert.Print();

  TMatrixF test= fractions * invert;

  test.Print();


  
  std::vector<Float_t> epoints(nrow,0.);

  for ( Int_t i=0; i<nrow; i++ ) 
    { 
      for ( Int_t j=0; j<ncol; j++ )
        {
          epoints[i] += invert[i][j] * Ef[j];
        }      


    }

 

  


}


// ----------------------------------------------------------------------------
Float_t StEEmcPointMaker::fracp2t( StEEmcPoint &p, StEEmcTower &t )
{



  if ( !t.isNeighbor( p.tower(0) ) ) return 0.;
  //if ( !(t.index()==p.tower(0).index()) ) return 0.;


  Float_t xeta=(Float_t)t.etabin();
  Float_t xphi=(Float_t)t.phibin();
  Double_t X[]={xphi,xeta}; 

  Float_t xeta0=(Float_t)p.tower(0).etabin();
  Float_t xphi0=(Float_t)p.tower(0).phibin();

  Int_t sec,sub,eta;
  Float_t dphi,deta;
  if ( !mEEtow->getTower(p.position(), sec,sub,eta, dphi,deta ) ) return 0.;
  dphi/=2.0;
  deta/=2.0;

  Float_t xetap=xeta0+deta;
  Float_t xphip=xphi0+dphi;
  Double_t P[]={xphip,xetap,1.0};

  return eeTowerFunction( X, P );

}


// ----------------------------------------------------------------------------
void StEEmcPointMaker::shareEnergySimple()
{

  Int_t limit=mLimit; // algo quickly converges on energy
  Int_t count=0;

  while ( count++ < limit ) 
    {

      Float_t sumw[720]; 
      for (Int_t i=0;i<720;i++) sumw[i]=0.;

      for ( UInt_t i=0;i<mPoints.size();i++ )
        {

          StEEmcPoint point=mPoints[i];
          StEEmcTower tower=point.tower(0);

          sumw[ tower.index() ] += point.energy() * fracp2t( point, tower );

          for ( Int_t i=0; i<tower.numberOfNeighbors(); i++ )
            {
              StEEmcTower neighbor=tower.neighbor(i);
              sumw[ neighbor.index() ] += point.energy() * fracp2t( point, neighbor );
            }

        }


      
      for ( UInt_t i=0;i<mPoints.size();i++ )
        {

          StEEmcPoint &point=mPoints[i]; // note the reference
          StEEmcTower tower=point.tower(0);
          Float_t epoint=0.;

          Float_t frac=0.;
          if ( !tower.fail() && !tower.stat() && sumw[tower.index()]>0. )
          frac = point.energy() * fracp2t(point,tower) / sumw[ tower.index() ];

          epoint += tower.energy() * frac;
          
          for ( Int_t i=0; i<tower.numberOfNeighbors(); i++ )
            {
              StEEmcTower neighbor=tower.neighbor(i);
              if ( neighbor.stat() || neighbor.fail() || sumw[neighbor.index()]<=0. ) continue;
              frac = point.energy() * fracp2t(point,neighbor) / sumw[ neighbor.index() ];
              epoint += frac * neighbor.energy();
            }
          
          
          point.energy( epoint );

        }

    }




  std::vector<Bool_t> seen(720,false);
  for ( UInt_t i=0;i<mPoints.size();i++ )
    {

      StEEmcTower tow=mPoints[i].tower(0);
      if ( !seen[ tow.index() ] ) mEseen+=tow.energy();
      seen[ tow.index() ] = true;

      for ( Int_t j=0;j<tow.numberOfNeighbors();j++ )
        {
          StEEmcTower nei=tow.neighbor(j);
          if ( !seen[ nei.index() ] ) mEseen += nei.energy();
          seen[ nei.index() ] = true;
        }

    }
  





}





// ----------------------------------------------------------------------------
void StEEmcPointMaker::fillStEvent()
{


  StEvent *stevent=(StEvent*)GetInputDS("StEvent");
  if ( !stevent ) {
    Warning("fillStEvent","called, but no StEvent to be found");
    return;
  }


  for ( UInt_t i=0; i<mPoints.size(); i++ )
    {

      StEmcPoint *point=mPoints[i].stemc();
      stevent->emcCollection()->addEndcapPoint( point );

      mEtoEE[ point ] = mPoints[i];


    }

}



// ----------------------------------------------------------------------------
void StEEmcPointMaker::verifyStEvent()
{

  Float_t emc_sum_points = 0.;
  Float_t eemc_sum_points = 0.;

  StEvent *stevent=(StEvent*)GetInputDS("StEvent");
  if ( !stevent ) {
    Warning("verifyStEvent","called, but no StEvent to be found");
    return;
  }

  StSPtrVecEmcPoint& emcpts = stevent->emcCollection()->endcapPoints();
  for ( UInt_t i=0;i<emcpts.size();i++ )
    {

      StEmcPoint *p=emcpts[i];
      assert(p);
      emc_sum_points += p->energy();

    }

  for ( UInt_t i=0;i<mPoints.size();i++ )
    {

      StEEmcPoint p=mPoints[i];
      eemc_sum_points += p.energy();

    }

  std::cout << "StEEmcPointMaker point checksum: ";
  if ( emc_sum_points == eemc_sum_points )
    {
      std::cout << "passed";
    }
  else
    std::cout << "FAILED";
  std::cout << std::endl;
    

}


// ----------------------------------------------------------------------------
void StEEmcPointMaker::countRelatives()
{

  Int_t npoints[720];
  for ( Int_t i=0;i<720;i++ ) npoints[i]=0;

  for ( UInt_t i=0;i<mPoints.size();i++ )    
      npoints[ mPoints[i].tower(0).index() ]++;

  for ( UInt_t i=0;i<mPoints.size();i++ )
    {

      StEEmcTower tower=mPoints[i].tower(0);
      Int_t nn=tower.numberOfNeighbors();

      Int_t nrel=npoints[ tower.index() ] - 1; // don't count self
      assert(nrel>=0); // pbck

      for ( Int_t j=0;j<nn;j++ )
        {
          StEEmcTower t2=tower.neighbor(j);
          nrel+=npoints[ t2.index() ];
        }

      mPoints[i].numberOfRelatives(nrel);

    }
    

}




// ----------------------------------------------------------------------------
void StEEmcPointMaker::shareEnergySmd()
{

  Float_t sumw[720];for ( Int_t i=0;i<720;i++ )sumw[i]=0.;
  Float_t sumw1[720];for ( Int_t i=0;i<720;i++ )sumw1[i]=0.;

  for ( UInt_t ipoint=0;ipoint<mPoints.size();ipoint++ )
    {


      StEEmcPoint point=mPoints[ipoint];
      StEEmcTower tower=point.tower(0);
      sumw[tower.index()]+=point.energy();
      sumw1[tower.index()]+=point.energy(); 

      for ( Int_t itow=0;itow<tower.numberOfNeighbors();itow++ )
        {
          StEEmcTower t=tower.neighbor(itow);
          Int_t index=t.index();
          sumw[index]+=point.energy();
        }
     
    }


  for ( UInt_t ipoint=0;ipoint<mPoints.size();ipoint++ )
    {
      
      StEEmcPoint point=mPoints[ipoint]; // note reference
      StEEmcTower tower = point.tower(0);
      StEEmcTower pre1  = mEEanalysis->tower(tower.index(),1); 
      StEEmcTower pre2  = mEEanalysis->tower(tower.index(),2); 
      StEEmcTower post  = mEEanalysis->tower(tower.index(),3); 

      Float_t epoint = 0.;
      Float_t epre1  = 0.; 
      Float_t epre2  = 0.; 
      Float_t epost  = 0.;  

      Int_t index = tower.index();
      epoint += tower.energy() * point.energy() / sumw[index];
      epre1  += pre1.energy()  * point.energy() / sumw1[index]; 
      epre2  += pre2.energy()  * point.energy() / sumw1[index]; 
      epost  += post.energy()  * point.energy() / sumw[index]; 

      for ( Int_t itow=0;itow<tower.numberOfNeighbors();itow++ )
        {
          StEEmcTower t=tower.neighbor(itow);
//        StEEmcTower p=pre1.neighbor(itow);
//        StEEmcTower q=pre2.neighbor(itow);
          StEEmcTower r=post.neighbor(itow); 

          index = t.index();
          epoint += t.energy() * point.energy() / sumw[index];
//        epre1  += p.energy() * point.energy() / sumw[index];
//        epre2  += q.energy() * point.energy() / sumw[index];
          epost  += r.energy() * point.energy() / sumw[index];
        }

      //      point.energy( epoint );
      mPoints[ipoint].energy(epoint);
      mPoints[ipoint].energy(epre1,1);
      mPoints[ipoint].energy(epre2,2);
      mPoints[ipoint].energy(epost,3); 

    }


}

---