#include #include #include #include #include "CAENHVWrapper.h" #include int main(void) { // VARIABLES DECLARATION char address[30], userName[20], passwd[30], name[64], ParName[8], channelname[30], directory_data[80], meteofile[80], meteofile2[80], header[200]; char directory_datashort[80], stringaexec[80], stringaexecdb[80], ongoingscan_sm[80]; int link, is, n, slot, NrOfCh=1, pw, status, station; float vmon, imon, hvset; time_t now; float dew, pressure=0,rainlast,rainday,rainmonth,rainyear,heat,temp1=0,temp2=0,rh1=0,rh2=0,wind,gust,dir; int day,month,year,hour,min; int pressurezero=990, stack,i; int channel_temp, slot_temp; float channel_offset; float *param = NULL; param = malloc(sizeof(float)); uint *param2 = NULL; param2 = malloc(sizeof(uint)); ushort *id_channel = NULL; id_channel = malloc(sizeof(ushort)); // CAEN SY1527 settings sprintf(userName,"%s","admin"); sprintf(passwd,"%s","admin"); // Reading time information for hv scan FILE *stream29; stream29=fopen("/srv/www/cgi-bin/ongoingscan_sm","r"); fscanf(stream29,"%s",ongoingscan_sm); fflush(stream29); fclose(stream29); // SETTING DATA DIRECTORY (it should exist!!) //strcpy (directory_data,"/home/user/re4data/HVSCAN/"); //time_t rawtime; //struct tm * timeinfo; //time ( &rawtime ); //timeinfo = localtime ( &rawtime ); //strftime ( directory_datashort, 16,"%Y%m%d%H%M%S", timeinfo ); //strftime ( directory_data, 100,"/home/user/re4data/HVSCAN_CHAMBERS/%Y%m%d_", timeinfo ); strcpy (directory_data,"/home/user/re4data/HVSCAN_SM/"); strcat (directory_data,ongoingscan_sm); // SETTING DATA DIRECTORY (it should exist!!) //strcpy (directory_data,"/home/user/re4data/"); strcpy (meteofile,"/home/user/meteolog3"); strcpy (meteofile2,"/home/user/meteolog4"); // Reading the Configuration file (it cointains the path file also) FILE *stream1; stream1=fopen("/srv/www/htdocs/conf_sm_qc41.txt","r"); fscanf(stream1,"%s\n",name); fscanf(stream1,"%s\n",address); /* // Useful informations printf("Configuration file correctly read\n"); printf("IP address: %s \n", address); printf("%s\n", ""); */ // Preparing connection to the mainframe CAENHVRESULT ret_init,ret; link = LINKTYPE_TCPIP; ret_init = CAENHVInitSystem(name, link, address, userName, passwd); //printf("\nCAENHVInitSystem: %s (num. %d)\n\n", CAENHVGetError(name), ret_init); // Reading latest values from the weather station FILE *stream3; stream3=fopen(meteofile,"r"); //fgets(header,sizeof(header),stream3); while (!feof(stream3)) { fscanf(stream3,"%d %d %d %d %d %f %f %f %f %f %f %f %f %f %f %f %f\n",&day,&month,&year,&hour,&min,&temp1,&rh1,&dew,&pressure,&wind,&gust,&dir,&rainlast,&rainday,&rainmonth,&rainyear,&heat); } fflush(stream3); fclose(stream3); // Reading latest values from the weather station (indoor values) FILE *stream5; stream5=fopen(meteofile2,"r"); //fgets(header,sizeof(header),stream3); while (!feof(stream5)) { fscanf(stream5,"%d %d %d %d %d %f %f\n",&day,&month,&year,&hour,&min,&temp1,&rh1); } fflush(stream5); fclose(stream5); /* // Reading stack number FILE *stream22; stream22=fopen("/srv/www/htdocs/stack.txt","r"); fscanf(stream22,"%s",stack); fflush(stream22); fclose(stream22); */ // OPENING FILE FOR THE DB) strcpy (stringaexecdb,directory_data); strcat (stringaexecdb,"_hvscan.csv"); FILE *stream34=fopen(stringaexecdb,"r"); if (!stream34) { FILE *stream38=fopen(stringaexecdb,"w"); fprintf(stream38,"%s\n","Serial_number,Layer,HV_eff,HV_app,i_mon,env_t,env_p,env_rh,gas_t,gas_rh"); fflush(stream38); fclose(stream38); } else { fflush(stream34); fclose(stream34); } FILE *stream35; stream35=fopen(stringaexecdb,"a"); // Reading values from the Mainframe if ( ret_init == CAENHV_OK ) { while (!feof(stream1)) { // READING THE CONFIGURATION FILE fscanf(stream1,"%s %d %d %d\n",channelname, &slot, &id_channel[0], &station); //printf("Slot: %d Channel in the slot = %d \n tdc_station = %d", slot,id_channel[0], station); time(&now); // READING THE HIGH VOLTAGE sprintf(ParName,"%s","VMon"); ret = CAENHVGetChParam(name, slot, ParName, NrOfCh, id_channel, param); if (ret==CAENHV_OK) { vmon = param[0]; } else { //printf("\nCAEN1527: %s (num. %d)\n Paramenter Name %s \n", CAENHVGetError(name), ret, ParName); } // READING THE CURRENTS sprintf(ParName,"%s","IMon"); ret = CAENHVGetChParam(name, slot, ParName, NrOfCh, id_channel, param); if (ret==CAENHV_OK) { imon = param[0]; } else { //printf("\nCAEN1527: %s (num. %d)\n Paramenter Name %s \n", CAENHVGetError(name), ret, ParName); } FILE *stream81; stream81=fopen("/home/user/workspace/rpcupgrade/CAEN1527_monitoring-1.00/CAEN1527_monitoring/qc41_offsets.ini","r"); while (!feof(stream81)) { fscanf(stream81,"%d %d %f\n", &slot_temp, &channel_temp, &channel_offset); if ( channel_temp == id_channel[0] && slot_temp == slot ) { imon = imon + channel_offset; } } fflush(stream81); fclose(stream81); // READING THE STATUS sprintf(ParName,"%s","Status"); ret = CAENHVGetChParam(name, slot, ParName, NrOfCh, id_channel, param2); if (ret==CAENHV_OK) { status = param2[0]; } else { //printf("\nCAEN1527: %s (num. %d)\n Paramenter Name %s \n", CAENHVGetError(name), ret, ParName); } // READING THE POWER ON/OFF sprintf(ParName,"%s","Pw"); ret = CAENHVGetChParam(name, slot, ParName, NrOfCh, id_channel, param2); if (ret==CAENHV_OK) { pw = param2[0]; } else { //printf("\nCAEN1527: %s (num. %d)\n Paramenter Name %s \n", CAENHVGetError(name), ret, ParName); } // DEBUGGING PRINTOUT OF THE VARIABLES //printf("%s %d %s %d %d %.2f %.5f %d %d\n",name, now, channelname, slot, id_channel[0], vmon ,imon ,status, pw); // OPENING FILE TO WRITE DATA (chamber by chamber) strcpy (stringaexec,directory_data); strcat (stringaexec,channelname); strcat (stringaexec,"_hvscan.dat"); FILE *stream2; stream2=fopen(stringaexec,"a"); fprintf(stream2,"%s %d %s %d %d %.2f %.5f %d %d %f %f %f\n",name, now, channelname, slot, id_channel[0], vmon ,imon ,status, pw, temp1, pressure, rh1); fflush(stream2); fclose(stream2); strcpy (stringaexec,directory_data); //strcat (stringaexec,"stack"); hvset = (vmon * pressurezero / pressure) / 100; hvset = hvset + 0.5; hvset = (int)hvset; hvset = hvset * 100; char * pch; char whichsm[80]; pch = strtok (channelname,"_"); i=0; while (pch != NULL) { i=i+1; if (i==1) strcpy(channelname, pch); if (i==2) strcpy(whichsm, pch); pch = strtok (NULL, "_"); } if (strcmp(whichsm,"t")==0) strcpy(whichsm,"TOP"); if (strcmp(whichsm,"b")==0) strcpy(whichsm,"BOTTOM"); fprintf(stream35,"%s,%s,%.0f,%.0f,%.2f,%4.1f,%3.0f,%4.1f,,,\n", channelname,whichsm,hvset,vmon, imon, temp1, pressure, rh1); // WRITING INFOS INTO THE ELOG //strcpy (stringaexec,"elog -h cms904cr1 -p 8080 -l 904lab -a Author=DAQ USER -a Type=""New configuration"" "); //strcat (stringaexec,"-a Subject=""Started Chamber HV SCAN"" "); //system(stringaexec); } ret_init = CAENHVDeinitSystem(name); //printf("\nDisconnecting from caen on %s \n",name); } else { //printf("Error connecting to the caen %s (num %d) \n",CAENHVGetError(name),ret_init); } // CLOSING FILES fflush(stream1); fclose(stream1); fflush(stream35); fclose(stream35); }