campo-sirio/ve/ve5400.cpp

#include <applicat.h>
#include <mask.h>
#include <progind.h>
#include <relation.h>
#include <archives.h>
#include <utility.h>
#include "ve5400.h"
#include "velib.h"
#include <doc.h>

class TArchive_mask : public TMask
{
public:
  TArchive_mask() : TMask("ve5400") { }
  virtual ~TArchive_mask() { }
};


class TArchive_doc : public TSkeleton_application
{
  TArray _file;
  TIsamtempfile *_tdoc;                    //dichiaro un puntatore al file _tdoc (non posso dichiarare un file)
  TIsamtempfile *_trdoc;                   //                              _trdoc
  TFilename      _tmp_dir;
  TArchive       _arc; 
  TString        _desc;
  char           _unit;
  
protected:                                                                  // TSkeleton_application
  virtual void main_loop();
  void open_files(int logicnum, ...);
  virtual bool create();
  void create_tmp_files(bool create);
  void delete_tmp_files(bool remove);
  void archivia(const TMask& m);
  void ripristina(const TMask& m);

public:
  TArchive_doc() { }
  virtual ~TArchive_doc() { }
};

void TArchive_doc::open_files(int logicnum, ...)  
{  
  va_list marker;
  va_start(marker, logicnum);
  while (logicnum > 0)
  {
    CHECKD(_file.objptr(logicnum) == NULL, "File gia' aperto: ", logicnum);
    _file.add(new TLocalisamfile(logicnum), logicnum);
    logicnum = va_arg(marker, int);
  }
}

bool TArchive_doc::create()
{                 
  open_files(LF_TABCOM, LF_TAB, LF_CLIFO, LF_OCCAS, LF_INDSP, LF_CFVEN,
             LF_DOC, LF_RIGHEDOC, LF_ANAMAG, LF_MOVMAG, LF_RMOVMAG, LF_CONDV,
             LF_SVRIEP, LF_AGENTI, LF_PERCPROV, LF_CESS, 0);
  _tmp_dir.temp();
  _tmp_dir = _tmp_dir.path();
  _tmp_dir << "VE";
  if (!_tmp_dir.exist()) make_dir(_tmp_dir);
  _tmp_dir.insert("%");                                   // Add % sign
       
  _tdoc = _trdoc = NULL;     
       
  return TSkeleton_application::create();
}


void TArchive_doc::create_tmp_files(bool create)         //crea i files temporanei (nella directory temp) 
{
  TFilename tf(_tmp_dir);
  tf.add("f1");
  _tdoc   = new TIsamtempfile(LF_DOC,tf,create);         
  tf.rtrim(1); tf << "2";
  _trdoc   = new TIsamtempfile(LF_RIGHEDOC,tf,create);
}                     

void TArchive_doc::delete_tmp_files(bool remove)        //cancella i files temporanei al termine dell'archiviazione
{
  if (remove)                                           // Cosi' posso forzare la cancellazione in chiusura
  {
    _tdoc->set_autodel();
    _trdoc->set_autodel();
  }
  delete _tdoc;
  delete _trdoc;
  _tdoc = NULL;
  _trdoc = NULL;
}



void TArchive_doc::archivia(const TMask& m)
{ 
  TRelation rel(LF_DOC);                         //crea una relazione sul file identificato dal numero LF_DOC
  m.autosave(rel);                               //scrive, in base alla rel, i valori del campo con specifica LF_DOC
    
  TRectype recini(rel.curr());                   //crea recini di TRectype che costruisce il record corrente del file
  TRectype recfin(rel.curr());                   //crea recfin di TRectype che costruisce il record corrente del file
    
  recini.put(DOC_NDOC, m.get(F_NUMFR));     //setta il contenuto del campo DOC_NDOC con il numero che arriva da m.get (<28> il numero del primo record da leggere)
  recfin.put(DOC_NDOC, m.get(F_NUMTO));     //come sopra ma per l'ultimo record (questi due numeri gli servono nel cursore)
    
  _unit = m.get(F_DRIVE)[0];             //legge solo A o B e non :
  _desc = m.get(F_DESCRFILE);
    
  TString filter;                                 //crea l'ogetto filter da TString


  TCursor cur(&rel, filter, 1, &recini, &recfin); //crea un cursore (cur) basato sulla relazione rel, il filtro filter, da recini a recfin
  const long total = cur.items();                 //mette in total il numero totale di record
    
  if (total > 0)                                  //se c'<27> almeno un record...
  {
    TString msg = "Confermare l'invio di ";  //istanza della TString (compare una box con la richiesta di conferma)
    msg.add_plural(total, "documento");              //cerca il plurale della stringa "documento" se total <20>>1
    if (yesno_box(msg))                              //se si conferma l'archiviazione (OK nella box)...
    { 
                                                    //chiamo la funzione che crea i file temporanei in modo da creare un
      create_tmp_files(TRUE);                       //file di intestazione ed un file di righe temporanei (N.B. non devo
                                                    //creare alcun oggetto perch<63> la funzione <20> un metodo della TArchive_doc
                                                    //e quindi l'oggetto <20> gi<67> creato
                                                      
        
        
      TProgind pi(total, "Elaborazione in corso...", TRUE, TRUE);      //istanza pi di TProgind che fa comparire la finestra di elaborazione in corso
      TDocumento* doc = new TDocumento;                                //doc <20> un puntatore ad una istanza di TDocumento
      rel.lfile().set_curr(doc);                                       //applica set_curr al localisamfile che viene ritornato da rel.lfile()
                                                                       //set_curr sostituisce il record corrente del file doc
      int err = NOERR;
                                                                         
      for (cur = 0; cur.pos() < total && !pi.iscancelled() && err==NOERR; ++cur)     //for cur che va da 0 alla posizione corrente (che deve essere < del numero totale
                                                                                     //dei record (total) and non essere interrotto e non esserci errore
      { 
        err = _tdoc->write(doc->head());                                               //scrive l'intestazione sul file
        if (err != NOERR)                                                            //se invece c'<27> un errore..
        {
          error_box("Errore %d durante la copia dell'intestazione", err);
          break;
        }
        for (int r = 1; r <= doc->physical_rows() && err==NOERR; r++)                //scrive le righe sul file temp delle
        {                                                                            //righe;
          err = _trdoc->write((*doc)[r]);                                            //scrive le righe sul file
          if (err != NOERR)
          {
            error_box("Errore %d durante la copia delle righe", err);
          } 
        }
        pi.addstatus(1L);                                                           //mette la barra di work in progress
      }                                              
        
      delete_tmp_files(FALSE);                                //chiude i files temp in modo da risparmiare memoria
        
      const char * dir = &_tmp_dir[1];                        //fa puntare dir alla directory temp
      bool rt = _arc.backup(dir,_unit,_desc, TRUE);           //esegue la compressione ed il salvataggio sul device scelto
      create_tmp_files(FALSE);                                //apre i files temp, riallocandoli (NON li crea effettvam.)
      delete_tmp_files(TRUE);                                 //cancella fisicamente i files temp
    }
  }
}



void TArchive_doc::ripristina(const TMask& m)
{
  const char* dir =&_tmp_dir[1];                                                   // Cut out % sign
  _unit = m.get(F_DRIVE)[0];                                                       // Stabilisce quale <20> il device corretto
  if (_arc.restore(dir,_unit,FALSE,TRUE))
  {
    TIsamfile doc(LF_DOC);
    TLocalisamfile rdoc(LF_RIGHEDOC);
    doc.open();
    int err = doc.lock();
    if (err != NOERR)  
    {
      error_box("Il file documenti non puo' essere bloccato in modo esclusivo."
                " Nessun documento ricevuto. Errore %d.",err);
      return;
    }

    create_tmp_files(FALSE);                                                        // In realta' ci sono gia'
    const TRecnotype items = _tdoc->items() + _trdoc->items();
    TProgind pi(items, "Ricezione documenti inviati", FALSE, TRUE);

    for (_trdoc->first();_trdoc->good() && err==NOERR;_trdoc->next())
    {
      if ((err=rdoc.write(_trdoc->curr())) == _isreinsert)
        err=rdoc.rewrite(_trdoc->curr());
      pi.addstatus(1);
    }
    if (err != NOERR)
      error_box("Errore %d ricevendo il file RIGHE DOCUMENTI.",err);  
    else
    {           
      TDocumento* documento = new TDocumento;
      _tdoc->set_curr(documento);
      for (_tdoc->first();_tdoc->good() && err==NOERR;_tdoc->next())
      {
        pi.addstatus(1);
        err = documento->write(doc);
      }
      if (err != NOERR) 
        error_box("Errore %d ricevendo il file DOCUMENTI.",err);  
    }
    delete_tmp_files(TRUE);                                                            // Removes temp files!
    doc.close();                                                          
  } 
  else
    error_box("Errore nella ricezione dei file da dischetto. Nessun documento ricevuto.");
}



//////////////////////////////////////////////////////////
//////////  Main loop del programma            ///////////
//////////////////////////////////////////////////////////


void TArchive_doc::main_loop()
{
  TArchive_mask m;
  KEY key = K_ENTER;
                                 
    while (key != K_QUIT)
    {
       key=m.run();
       
       if (key == K_ENTER)
         archivia(m);
       if (key == K_DEL)
         ripristina(m);
    }       
 
}                                           

int ve5400(int argc, char* argv[])
{
  TArchive_doc a;
  a.run(argc, argv, "Invio/Ricezione");
  return 0;
}