--- rawreader/src/sort.cpp	2006/09/01 10:56:23	1.1
+++ rawreader/src/sort.cpp	2006/12/10 12:52:52	1.3
@@ -1,12 +1,18 @@
 ///////////////PAMELA PACKETS SORT///////////////////////////////////
 #include "descript.h"
+#include "flag.h"
+
 void  RunHeaderReader(char *buf);
 extern long int OBTtimesync;
 extern long int Timesync;
+extern char MYSQL[80];
+extern char database[80];
+extern int print_flag;
+
 struct Names
 {
- char a[80];                     /*Full name for mmm_nnnnn_counter_xx.bin*/
- char a_short[80];               /*Short name for mmm_nnnnn_counter_xx.bin*/
+ char a[80];                     /*Full name for nnnnn_mmm_xxx_AA.bin*/
+ char a_short[80];               /*Short name for nnnnn_mmm_xxx_AA.bin*/
  FILE *fo_a;
 };
 
@@ -21,6 +27,9 @@
  char ql[80];
  char tmp[80], tmp1[80], numer[10];
  char arina[80];
+ char connection[80];
+ char query[500];
+ long int orbit, route, count;
 // char buffer[10];
  char *packet=new char[Nmax];
  unsigned int type=0;           /*PAMELA packet type*/
@@ -34,6 +43,8 @@
  long int first[NumberPack+1];  /*First byte for PAMELA packets of given type*/
  long int last[NumberPack+1];   /*Last byte for PAMELA packets of given type*/
  long int temp=0;
+ long int time_differ=0;
+ int flag_time=0;
  int Hex_first[4];
  int Hex_last[4];
  int i=0, j=0, stop=0;
@@ -47,11 +58,17 @@
   first[i]=0;
   last[i]=0;}
 
- Length=(int)(strlen(file_init)); 
+ Length=(int)(strlen(file_init));
  strncat(strcpy(tmp,"\0"),file_init,Length-8);
  strcat(strcpy(tmp1,path),"tmp.dat");
  f_temp=fopen(tmp1,"wb+");
 
+ stringstream oss;
+
+ strcpy(connection,MYSQL);
+ strcat(connection,database);
+ TSQLServer *sqlServer = TSQLServer::Connect(connection, "pamelaprod", "rawprod");
+
  for (i=0;i<NumberPack+1;i++)
  {
   if (i==0) {fprintf(f_temp,"%02i",i);}
@@ -59,23 +76,17 @@
   fseek(f_temp,0,0);
   fgets(numer,10,f_temp);
   fseek(f_temp,0,0);
-/*************Open files /home/pamelaprod/rawreader/level0/nnnnn/mmm_counter/packets/mmm_nnnnn_counter_xx.bin*******/
+/*************Open files /home/pamelaprod/rawreader/level0/nnnnn/xxx_mmm/packets/nnnnn_mmm_xxx_AA.bin*******/
   strncat(strcpy(data[i].a,path3),file_init,Length-8);
-  strcat(data[i].a,numer);
+  strcat(data[i].a,numer); 
   strcat(data[i].a,".bin");
-  //form the 'mmm_'
-  for (j=0;j<4;j++) tmp[j]=data[i].a[strlen(data[i].a)-(20-j)];
-  //form the 'mmm_nnnnn_'
-  for (j=0;j<6;j++) tmp[j+4]=data[i].a[strlen(data[i].a)-(12-j)];
-  //form the 'mmm_nnnnn_ccc_'
-  for (j=0;j<4;j++) tmp[j+10]=data[i].a[strlen(data[i].a)-(16-j)];
-  //form the 'mmm_nnnnn_ccc_XX.bin'
-  for (j=0;j<6;j++) tmp[j+14]=data[i].a[strlen(data[i].a)-(6-j)]; tmp[20]='\0';
-/*********************Create names mmm_nnnnn_counter_xx.bin********************/  
+  //form the 'nnnnn_mmm_xxx_AA.bin'
+  for (j=0;j<20;j++) tmp[j]=data[i].a[strlen(data[i].a)-(20-j)];
+/*********************Create names nnnnn_mmm_xxx_AA.bin********************/  
   for (j=0;j<20;j++) 
   {data[i].a_short[j]=tmp[j]; data[i].a_short[20]='\0';
    data[i].a[strlen(data[i].a)-(20-j)]=tmp[j];
-  }
+  } 
  
   data[i].fo_a=fopen(data[i].a,"wb"); 
   if(data[i].fo_a==NULL)
@@ -87,34 +98,35 @@
 /**********************OPEN NECESSARY FILES************************/
 /******************************************************************/
  ifstream fo_pam;
- fo_pam.open(pam,ios::binary);      //open input file "mmm_counter_nnnnn_cln2.pam"
+ fo_pam.open(pam,ios::binary);      //open input file "nnnnn_mmm_xxx_cln2.pam"
  if(fo_pam.good()==0) {cerr<<"can not open pam file"; exit(1);} 
 
  ofstream fo_arina;
  strcpy(arina,"/home/arina/orientation/");
- strcat(arina,data[28].a_short); cout<<arina<<"\n";
+ strcat(arina,data[28].a_short); 
+ if (print_flag>0) cout<<arina<<"\n";
  fo_arina.open(arina,ios::binary);
  if(fo_arina.good()==0) {cerr<<"can not open arina file"; exit(1);} 
  
- fo_log=fopen(log, "rb");      //open input file "mmm_counter_nnnnn_cln2.log"
+ fo_log=fopen(log, "rb");      //open input file "nnnnn_mmm_xxx_cln2.log"
  if(fo_log==NULL) {cerr<<"can not open log file"; exit(1);}
 
  strcpy(fno2,path3);
  strncat(fno2,file_init,strlen(file_init)-8); 
- fo_work2=fopen(strcat(fno2,"work2.dat"), "wb");
- fo_work2=fopen(fno2, "wb");   //open output help file "work_cln2.dat"
+ strcat(fno2,"work2.dat");
+ fo_work2=fopen(fno2, "wb");   //open output help file "nnnnn_mmm_xxx_work2.dat"
  if(fo_work2==NULL) {cerr<<"can not open outputfile"; exit(1);}
 
  strncat(strcpy(ql,path3),file_init,Length-8);
  strcat(ql,"ql.log");
- fo_ql=fopen(ql, "wb");        //open output file "mmm_counter_nnnnn_ql.log"
+ fo_ql=fopen(ql, "wb");        //open output file "nnnnn_mmm_xxx_ql.log"
  if(fo_ql==NULL) {cerr<<"can not open ql file"; exit(1);}
 
 /******************************************************************/
 /******************************************************************/
  while(feof(fo_log)==0) 
  {
-//read PAMELA packet information from Route_cln2.log
+//read PAMELA packet information from nnnnn_mmm_xxx_cln2.log
   fscanf(fo_log,"%1c",&type);
   if (feof(fo_log)!=0) break;
   fscanf(fo_log,"%4c",&adr1);
@@ -124,22 +136,20 @@
   fscanf(fo_log,"%1c",&error);
   if (feof(fo_log)!=0) break;
   
-//  cout<<bitset<8>(error)<<"\n";
-//  cout<<bitset<8>(error).test(0)<<"\n";
   if ( ( (bitset<8>(error).test(7))||(error==0)||
 	 ((bitset<8>(error).test(0))&&(!bitset<8>(error).test(1))&&(!bitset<8>(error).test(2))&&
 	  (!bitset<8>(error).test(3))&&(!bitset<8>(error).test(4))&&(!bitset<8>(error).test(5))&&
 	    (!bitset<8>(error).test(6))) )&&
 	   (type>0)&&(type<NumberPack+1) )
   {
-/*Place file pointer in Route_cln2.pam on packet begin*/
+/*Place file pointer in nnnnn_mmm_xxx_cln2.pam on packet begin*/
    fo_pam.seekg(adr1-1,ios::beg);
-//read PAMELA packet from Route_cln2.pam
+//read PAMELA packet from nnnnn_mmm_xxx_cln2.pam
    fo_pam.read(packet,adr2-adr1+1);
   
    /*OBT of Pamela*/
    time=(long int)(unsigned char)(packet[11])+
-   	          256*(long int)(unsigned char)(packet[10])+
+   	      256*(long int)(unsigned char)(packet[10])+
           256*256*(long int)(unsigned char)(packet[9])+
       256*256*256*(long int)(unsigned char)(packet[8]);
       
@@ -147,20 +157,23 @@
     
    moscowtime=time-(OBTtimesync-Timesync);
       
-   if(type == 11)  cout<<"time ="<<time<<" moscowtime ="<<moscowtime<<"\n";
    /*temp is packet number*/
    temp=(long int)(unsigned char)(packet[7])+
    	          256*(long int)(unsigned char)(packet[6])+
           256*256*(long int)(unsigned char)(packet[5]);
-   if ((fmod((float)(temp),(float)(10000.))==0.)&&(temp!=0)) cout<<"sorting "<<temp<<"\n";
+   if ((print_flag>0)&&(fmod((float)(temp),(float)(10000.))==0.)&&(temp!=0)) cout<<"sorting "<<temp<<"\n";
+
    /*unpacking several packets....   mikhailov
-   unpackingPamelaPacket(packet,type)*/
-   
- // if (type == 10) RunHeaderReader(packet);  
-   if( type == 11){RunHeaderReader(packet);}
+   unpackingPamelaPacket(packet,type)*/  
+   if( type == 11)
+   {
+    RunHeaderReader(packet);
+    if (flag_time==0) time_differ=Timesync-OBTtimesync;
+    flag_time=1;
+   }
 /*******************Packet with type "type"***********************/
    counter[type]+=1;
-   //write PAMELA packet in mmm_nnnnn_counter_xx.bin	   
+   //write PAMELA packet in nnnnn_mmm_xxx_AA.bin	   
    if (type!=4) fwrite(packet,adr2-adr1+1,1,data[type].fo_a);
    //write for ARINA
    if (type==28) fo_arina.write(packet,adr2-adr1+1);
@@ -181,7 +194,7 @@
      temp=temp-(long int)pow(256.,3-i)*
      (int)(temp/(long int)(pow(256.,3-i)));}
    }
-   //write information about PAMELA packet in mmm_counter_nnnnn_ql.log
+   //write information about PAMELA packet in nnnnn_mmm_xxx_ql.log
    if (type!=4)
    {
     fprintf(fo_ql,"%1c",char(type));
@@ -202,16 +215,16 @@
   {
 /*******************Packets with errors***************************/
    char *er_pack=new char [adr2-adr1+1];
-   /*Place file pointer in mmm_counter_nnnnn_cln2.pam on error packet begin*/
+   /*Place file pointer in nnnnn_mmm_xxx_cln2.pam on error packet begin*/
    fo_pam.seekg(adr1-1,ios::beg);
-   //read PAMELA error packet from mmm_counter_nnnnn_cln2.pam
+   //read PAMELA error packet from nnnnn_mmm_xxx_cln2.pam
    fo_pam.read(er_pack,adr2-adr1+1);
    time=(long int)(unsigned char)(er_pack[11])+
    	          256*(long int)(unsigned char)(er_pack[10])+
           256*256*(long int)(unsigned char)(er_pack[9])+
       256*256*256*(long int)(unsigned char)(er_pack[8]);
    counter[0]+=1;
-   //write PAMELA packet in mmm_nnnnn_conter_00.bin	   
+   //write PAMELA packet in nnnnn_mmm_xxx_00.bin	   
    fwrite(er_pack,adr2-adr1+1,1,data[0].fo_a);
    first[0]=last[0]+1;
    last[0]+=adr2-adr1+1;
@@ -232,7 +245,7 @@
      (int)(temp/(long int)(pow(256.,3-i)));}
    }
    if (type!=4)
-   {//write information about PAMELA packet in mmm_counter_nnnnn_ql.log
+   {//write information about PAMELA packet in nnnnn_mmm_xxx_ql.log
     fprintf(fo_ql,"%1c",(char)(type));
     for (i=0;i<4;i++) fprintf(fo_ql,"%1c",char(Hex_first[i]));   
     //  for (i=0;i<4;i++) fprintf(fo_ql,"%1c",char(Hex_last[i]));  //temporary
@@ -252,6 +265,41 @@
  for (i=0;i<NumberPack+1;i++)
  fprintf(fo_work2,"Number of packets in %s file = %i\n",data[i].a_short,counter[i]);
 
+ for(i=0;i<5;i++) {tmp1[i]=file_init[i];} tmp1[5]=' ';
+ sscanf(tmp1,"%5d",&orbit); 
+ 
+ for(i=6;i<9;i++) {tmp1[i-6]=file_init[i];} tmp1[3]=' ';
+ sscanf(tmp1,"%3d",&route);
+ 
+ for(i=10;i<13;i++) {tmp1[i-10]=file_init[i];} tmp1[3]=' ';
+ sscanf(tmp1,"%3d",&count);
+ 
+ oss.str("");
+ oss << "UPDATE FILES1 set time_dif="<<time_differ<<" where cirquit_n="<<orbit<<" and route_n="<<route<<
+        " and counter="<<count;
+ if (print_flag>0) cout<<oss.str().c_str()<<" table FILES1\n";
+ TSQLResult *res=sqlServer->Query(oss.str().c_str());
+
+// Form the query string to write PAMELA packets number in Packets
+ query[0]='\0';
+ for(i=0;i<NumberPack;i++)
+ {
+  sprintf(tmp,"%i",counter[i]);
+  strcat(tmp,"','");
+  strcat(query,tmp);
+ }
+ sprintf(tmp,"%i",counter[i]);
+ strcat(tmp,"')"); 
+ strcat(query,tmp);
+ 
+ oss.str("");  
+ oss << "INSERT INTO PACKETS (cirquit_n, route_n, counter, P00, P07, P08, P09, P10, P11, P12, P13, P16, P17, P18, P19, P1A,"
+     << " P1B, P1C, P1D, P20, P21, P22, P23, P24, P25, P30, P50, P51, P52, P53, P54, P55, P60, P70, P71, P72, P73, P74,"
+     << " P75, P76, P77, P81, P82, P83, P84, P85, P86, P88, P89, P8A, PA1, PAB, PF0, PF1, PF2, PF3, PF4)"
+     << " VALUES ('"<< orbit << "','"<< route << "','"<<count<<"','"<<query;
+ if (print_flag>0) cout<<oss.str().c_str()<<" table PACKETS\n";      
+ TSQLResult *res1=sqlServer->Query(oss.str().c_str());
+
  fo_pam.close();
  fo_arina.close();
  fclose(fo_log);