source: ether_eccad/trunk/ECCAD_INSERT/src/Grille.cpp @ 68

#include "Grille.h"

#include <stdio.h>
#include <string>
#include <dirent.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <iterator>
#include <time.h>
#include <iostream>
#include <sstream>
#include <cstring>
#include <stdlib.h>
#include "libpq/libpq-fs.h"
#include <math.h>
#include <sys/times.h>
//#include <eccad/eccad.h>

Grille::Grille()
{
        height = 360;
        width = 720;
}

Grille::Grille(int h, int w)
{
        height = h;
        width = w;
}

Grille::~Grille()
{
}

void Grille::writeDb(Logger* alogger, PGconn* conn)
{
        logger = alogger;
        
        float minParam, maxParam;
        
        //recupération des min max parametre
        
        
        string sqlParam = "select min_param, max_param from parametre where id_param = "+idParam+";";
        //cout<<sqlParam<<endl;
        
        PGresult* res = PQexec(conn, sqlParam.c_str());
        minParam = atof(PQgetvalue(res, 0, 0));
        maxParam = atof(PQgetvalue(res, 0, 1));
        ////cout<<"height "<<height<<" width "<<width<< " minParam "<<minParam<<" maxParam "<< maxParam<<endl;
        for (int i=0; i<height; i++)
        {
                for (int j=0; j<width; j++)
                {
                        this->valGriShort[i][j] = v2int(this->valGri[i][j], minParam, maxParam);
                }
        }
        
        //cout<<"ok"<<endl;
        
        PQexec(conn,("BEGIN")); 
        
        Oid objId = lo_creat(conn,INV_READ | INV_WRITE);
        
        int objIdWrite =  lo_open(conn, (int)objId, INV_WRITE);
        
        lo_write(conn, objIdWrite , (char*)valGriShort, height*width*sizeof(unsigned int));
        lo_close(conn, objIdWrite);
        
         PQexec(conn,("END")); 
        
        ////cout<<       objId           <<endl;
        stringstream sql;
                sql << "INSERT INTO grille ( id_produit, id_codification, id_param, valeurs_grille, date_grille, deltadate_grille, ncol_grille, nlign_grille, level_grille) VALUES(";
                sql << idProduit;
                sql << ",";
                sql << idCodif;
                sql << ",";
                sql << idParam;
                sql << ",";
                sql <<  objId;
                sql << ",'";    
                sql << dateGrille;
                sql << "','";
                sql << deltaDateGrille;
                sql <<"',"<<width<<","<<height<<",1);"; 
                ////cout << sql.str()<< endl;
                
                res = PQexec(conn, sql.str().c_str());
                if ( PQresultStatus(res) != PGRES_COMMAND_OK)  logger->traitementBaseMessages(" INSERT GRILLE N° : "+getId(conn)+ "+1", res);
                char *rep = PQcmdTuples(res);
                
                //printf("............ %s grille insérée pour la date %s \n", rep, dateGrille.c_str());
}



void Grille::updateGrille(Logger* alogger, string idGrille, PGconn* conn)
{
        logger = alogger;
        
        stringstream sql;
        PGresult* res;
        char* rep;
        sql << "select valeurs_grille from grille where id_grille = ";
        sql << idGrille;
        sql << ";";
        ////cout << sql.str()<< endl;
        res = PQexec(conn, sql.str().c_str());
        if ( PQresultStatus(res) != PGRES_TUPLES_OK)  logger->traitementBaseMessages(" SELECT OID N° : "+idGrille, res);
        rep = PQcmdTuples(res);
        char* id = PQgetvalue(res, 0, 0);
        
        int i = lo_unlink(conn, atoi(id));
        ////cout <<"id object :  "<< i<<endl;
        
        
        logger = alogger;
        PQexec(conn,("BEGIN")); 
        
        Oid objId = lo_creat(conn,INV_READ | INV_WRITE);
        
        int objIdWrite =  lo_open(conn, (int)objId, INV_WRITE);
        
        lo_write(conn, objIdWrite , (char*)valGri, height*width*sizeof(float));
        lo_close(conn, objIdWrite);
        
        PQexec(conn,("END")); 
                
        sql <<"UPDATE grille SET valeurs_grille = ";
        sql << objId;
        sql<< ";";      
        
        res = PQexec(conn, sql.str().c_str());
        if ( PQresultStatus(res) != PGRES_COMMAND_OK)  logger->traitementBaseMessages(" INSERT GRILLE N° : "+getId(conn)+ "+1", res);
        rep = PQcmdTuples(res);
                                
        //printf("............ %s update grille pour la date \n", rep);
        
}


void Grille::initialiseValGri(float val)
{
        for (int i=0; i<height; i++)
        {
                for (int j=0; j<width; j++)
                {
                        valGri[i][j] = val;
                }
        }
}

void Grille::initialiseInfosGri(string date, string deltaDate, string idPr, string idCod, string idPar)
{
        dateGrille = date;
        deltaDateGrille = deltaDate;    
        idProduit = idPr;
        idCodif = idCod;
        idParam = idPar;
        
}

void Grille::insertCode(string idCod, string legende, Logger* alogger, PGconn* conn)
{
        logger = alogger;
        string sql = "insert into code (id_codification, num_code, legend_code) values ("+idCod+","+getId(conn)+",'"+legende+"');";
        ////cout<< sql <<"*****************"<< endl;
        PGresult* res = PQexec(conn, sql.c_str());
        if ( PQresultStatus(res) != PGRES_COMMAND_OK)  logger->traitementBaseMessages(" INSERT CODE -- GRILLE N° : "+getId(conn), res);
                
        char *rep = PQcmdTuples(res);
        //printf("............ %s code inséré pour la date %s --- legende : %s \n", rep, dateGrille.c_str(), legende.c_str());
}


void Grille::insertCodeClasse(string idCod, string legende,int numClasse, Logger* alogger, PGconn* conn)
{
        logger = alogger;
        string sql = "insert into code (id_codification, num_code, legend_code, number_code) values ("+idCod+","+getId(conn)+",'"+legende+"',"+itoa(numClasse)+");";
        //cout<< sql <<"*****************"<< endl;
        PGresult* res = PQexec(conn, sql.c_str());
        if ( PQresultStatus(res) != PGRES_COMMAND_OK)  logger->traitementBaseMessages(" INSERT CODE -- GRILLE N° : "+getId(conn), res);
                
        char *rep = PQcmdTuples(res);
        printf("............ %s code inséré pour la date %s --- legende : %s \n", rep, dateGrille.c_str(), legende.c_str());
}


void Grille::insertCoded(string idCod, string legende, string code, Logger* alogger, PGconn* conn)
{
        logger = alogger;
        string sql = "insert into code (id_codification, num_code, legend_code) values ("+idCod+","+code+",'"+legende+"');";
        ////cout<< sql <<"*****************"<< endl;
        PGresult* res = PQexec(conn, sql.c_str());
        if ( PQresultStatus(res) != PGRES_COMMAND_OK)  logger->traitementBaseMessages(" INSERT CODE -- GRILLE N° : "+getId(conn), res);
                
        char *rep = PQcmdTuples(res);
        //printf("............ %s code inséré pour la date %s --- legende : %s \n", rep, dateGrille.c_str(), legende.c_str());
}




string Grille::getId(PGconn* conn)
{
        string sql ="select currval('grille_id_grille_seq');";
        PGresult* res = PQexec(conn, sql.c_str());
        
        return PQgetvalue(res, 0, 0);
}

float Grille::calculeMin()
{
        
        float min = valGri[0][0];
        for (int i=0; i<height; i++)
        {
                for (int j=0; j<width; j++)
                {
                        if ( valGri[i][j] < min )  min = valGri[i][j];
                }
        }
        return min;     
}

float Grille::calculeMax()
{
        float max = valGri[0][0];
        
        for (int i=0; i<height; i++)
        {
                for (int j=0; j<width; j++)
                {
                        if ( valGri[i][j] > max )  max = valGri[i][j];
                }
        }
        return max;     
}