--- chewbacca/PamOffLineSW/PacketUser.cpp	2008/12/18 12:58:37	1.3
+++ chewbacca/PamOffLineSW/PacketUser.cpp	2009/07/24 13:53:38	1.7
@@ -1,5 +1,5 @@
 //============================================================================
-// $Id: PacketUser.cpp,v 1.69 2008-10-27 10:41:27 messineo Exp $ 
+// $Id: PacketUser.cpp,v 1.6 2008/12/23 20:43:08 mocchiut Exp $ 
 // Description : 
 //============================================================================
 #include "PacketUser.h"
@@ -87,7 +87,7 @@
 	boot_number_prevvalue=0;
 
 	//(tassa)
-        id_to_recover[1000];
+	//        id_to_recover[1000]; // Emiliano: che si vuole fare con questa riga? cosi` non fa nulla...
         id_to_recover_index=0;   
 }
 
@@ -243,7 +243,7 @@
 //starts a new root file
 void PacketUser::StartGroup()
 {	
-	pRun = new PamelaRun(rootfilename, outDir, multiFile, compression);
+        pRun = new PamelaRun(rootfilename, gSystem->ExpandPathName(outDir), multiFile, compression); // EMI
 	strcat(rootfilename,".root");
 	reader->Init(pRun);			
 	stringstream oss;
@@ -325,7 +325,8 @@
 
 	stringstream oss;
 	oss.str()="";
-	oss<<"In download: "<<download<<" timeOffset: "<<timeOffset<<" obt_time_sync: "<<obt_time_sync<<" last_time_sync_info: "<<last_time_sync_info<<" using Packet Type: "<<type->GetName().c_str();
+	oss<<"In download: "<<download<<" timeOffset: "<<timeOffset<<" obt_time_sync: "<<obt_time_sync<<" last_time_sync_info: "<<last_time_sync_info<<" using Packet Type: "<<type->GetName();
+	//	oss<<"In download: "<<download<<" timeOffset: "<<timeOffset<<" obt_time_sync: "<<obt_time_sync<<" last_time_sync_info: "<<last_time_sync_info<<" using Packet Type: "<<type->GetName().c_str();
 	string msg = oss.str();
 	mainLogUtil->logAll(msg);
 }
@@ -351,7 +352,8 @@
 */		
 		stringstream oss;
 		oss.str()="";
-		oss<<"In download: "<<download<<" boot_number: "<<boot_number<<" using Packet Type: "<<type->GetName().c_str();
+		//		oss<<"In download: "<<download<<" boot_number: "<<boot_number<<" using Packet Type: "<<type->GetName().c_str();
+		oss<<"In download: "<<download<<" boot_number: "<<boot_number<<" using Packet Type: "<<type->GetName();
 		string msg = oss.str();
 		mainLogUtil->logAll(msg);
 		return;
@@ -429,7 +431,7 @@
 
     	oss.str("");
         oss << "SELECT YEAR(OFFSET_DATE),MONTH(OFFSET_DATE),DAY(OFFSET_DATE),HOUR(OFFSET_DATE),MINUTE(OFFSET_DATE),SECOND(OFFSET_DATE),ID FROM "<<	table <<" WHERE FROM_ORBIT < " 
-    	<< orbit_number << " order by FROM_ORBIT desc limit 1;";
+    	<< orbit_number << " AND SPECIAL_FILE='' order by FROM_ORBIT desc limit 1;";
     	
 		string msg2 = oss.str();
 		mainLogUtil->logAll(msg2);
@@ -524,7 +526,7 @@
 		if((!real_time_init)&&(!real_time_last))
 		{ 
 			//saved in another table for future study
-			if(saveROOT_DB(Table_ROOT_Bad, outDir,
+			if(saveROOT_DB(Table_ROOT_Bad, outDir,// here outDir is good, no expand EMI
 								filename, 
 							   pkt_number_init, pkt_number_last,
 							   obt_init, obt_last,
@@ -559,7 +561,7 @@
 		if(boot_number==0)
 		  boot_number=boot_number_prevvalue;
 
- 		if(saveROOT_DB(Table_ROOT_Good, outDir,
+ 		if(saveROOT_DB(Table_ROOT_Good, outDir, // here outDir is good, no expand EMI
 					filename, 
 				   pkt_number_init, pkt_number_last,
 				   obt_init, obt_last,
@@ -614,7 +616,7 @@
     << bad_pkt <<"','" << bad_pkt_read <<"','"<< bad_pkt_CalRead <<"','"<< num_PKT_Saved<<"','"
     << nome_input <<"',"
     <<"NULL,"<<_time_is_estimated<<   
-    ")";   	    
+    ");";   	    
 	string msg = oss.str();
 	mainLogUtil->logAll(msg);	
 	
@@ -664,7 +666,8 @@
     return;
    
   for (int i = 0; i<id_to_recover_index;i++){
-    oss << "UPDATE "<<  Table_ROOT_Good << " SET BOOT_NUMBER=" << boot_number << " WHERE ID_N=" << id_to_recover[i];  
+    oss.str("");
+    oss << "UPDATE "<<  Table_ROOT_Good << " SET BOOT_NUMBER=" << boot_number << " WHERE ID_N=" << id_to_recover[i] << ";";  
    query = oss.str();
    res= sqlServer->Query(query.c_str());
    if(!res)
@@ -676,12 +679,13 @@
    }
   }
 
-for (int i = 0; i<id_to_recover_index;i++){
-  oss << "UPDATE " <<  Table_ROOT_Merging << " SET BOOT_NUMBER=" <<  boot_number << " WHERE ROOT_ID_N=" << id_to_recover[i];  
-  query=oss.str();
-   res= sqlServer->Query(query.c_str());
-   if(!res)
-   {	
+  for (int i = 0; i<id_to_recover_index;i++){
+    oss.str("");
+    oss << "UPDATE " <<  Table_ROOT_Merging << " SET BOOT_NUMBER=" <<  boot_number << " WHERE ROOT_ID_N=" << id_to_recover[i] << ";";  
+    query=oss.str();
+    res= sqlServer->Query(query.c_str());
+    if(!res)
+      {	
 	   oss1<<"DBError UNABLE to: "<<query.c_str()<<endl;   
 	   msg1=oss1.str();
 	   mainLogUtil->logError(msg1);   
@@ -935,7 +939,8 @@
  	}
 	else if(type_rel == BIGGER){
 	//marco_new: ok anche se coincidenti etc
-	  oss << "DELETE FROM "<< table_name <<" WHERE ID_N ="<< ID_record<<";";
+	  //	  oss << "DELETE FROM "<< table_name <<" WHERE ID_N ="<< ID_record<<";"; // EMILIANO
+	  oss << "UPDATE "<< table_name <<" SET GOOD=0 WHERE ID_N ="<< ID_record<<";"; // EMILIANO DO NOT DELETE FROM ROOT_TABLE_MERGING JUST SET GOOD FLAG TO ZERO
 	  mainLogUtil->logInfo("Record deleted from merging table");	
  	}
 	else 
@@ -972,13 +977,13 @@
 	query.str("");
 
 	if(type_rel == AFTER)
-	  query<<"select * from "<<table_name<<" where REAL_TIME_LAST > "<< mtime_init <<" and REAL_TIME_LAST <= "<< mtime_last <<" and REAL_TIME_INIT < "<< mtime_init;
+	  query<<"select * from "<<table_name<<" where GOOD=1 and REAL_TIME_LAST > "<< mtime_init <<" and REAL_TIME_LAST <= "<< mtime_last <<" and REAL_TIME_INIT < "<< mtime_init; // EMI
 	else if(type_rel == BEFORE)
-	  query<<"select * from "<<table_name<<" where REAL_TIME_INIT >= "<< mtime_init <<" and REAL_TIME_INIT < "<< mtime_last <<" and REAL_TIME_LAST > "<< mtime_last;
+	  query<<"select * from "<<table_name<<" where GOOD=1 and REAL_TIME_INIT >= "<< mtime_init <<" and REAL_TIME_INIT < "<< mtime_last <<" and REAL_TIME_LAST > "<< mtime_last; // EMI
 	else if(type_rel == SMALLER) 
-	  query<<"select * from "<<table_name<<" where REAL_TIME_INIT < "<< mtime_init <<" and REAL_TIME_LAST > "<< mtime_last;
+	  query<<"select * from "<<table_name<<" where GOOD=1 and REAL_TIME_INIT < "<< mtime_init <<" and REAL_TIME_LAST > "<< mtime_last; // EMI
 	else if(type_rel == BIGGER) 
-		query<<"select * from "<<table_name<<" where REAL_TIME_INIT >= "<< mtime_init <<" and REAL_TIME_LAST <= "<< mtime_last;
+	  query<<"select * from "<<table_name<<" where GOOD=1 and REAL_TIME_INIT >= "<< mtime_init <<" and REAL_TIME_LAST <= "<< mtime_last; // EMI
 	else 
 		return 0;
 	
@@ -1232,7 +1237,7 @@
 {
 	char fno[80]="";
 	ofstream fout;
-	sprintf(fno,"%s/pkt%d_of_%s.pkt", outDir, numPKTSaved, nomefile);
+	sprintf(fno,"%s/pkt%d_of_%s.pkt", gSystem->ExpandPathName(outDir), numPKTSaved, nomefile); // EMI
 
 	if(append==true)
 		fout.open(fno, ios::binary | ios::app);
@@ -1252,11 +1257,11 @@
 	ofstream fout;
 	if(append==true)
 	{		
-		sprintf(fno,"%s/packets.pkt", outDir);
+   	        sprintf(fno,"%s/packets.pkt", gSystem->ExpandPathName(outDir)); // EMI
 		fout.open(fno, ios::binary | ios::app);
 	}
 	else{
-		sprintf(fno,"%s/packet%d.pkt", outDir, numPKT );
+  	        sprintf(fno,"%s/packet%d.pkt", gSystem->ExpandPathName(outDir), numPKT ); // EMI
 		fout.open(fno, ios::binary);			
 	}