#include #include #include #include #include #include #include "ve5400.h" #include "velib.h" #include 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 (é 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'é 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 é>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é la funzione é un metodo della TArchive_doc //e quindi l'oggetto é giá 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 é 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'é 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 é 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; }