244 lines
9.5 KiB
C++
244 lines
9.5 KiB
C++
|
#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;
|
|||
|
|
}
|