609 lines
14 KiB
C++
Executable File
609 lines
14 KiB
C++
Executable File
// Ricezione dati da sistema
|
|
|
|
#include <config.h>
|
|
#include <mask.h>
|
|
#include <prefix.h>
|
|
#include <printapp.h>
|
|
#include <tabutil.h>
|
|
#include <urldefid.h>
|
|
#include <utility.h>
|
|
|
|
#include <nditte.h>
|
|
|
|
#include "cglib04.h"
|
|
|
|
//#include "ba7.h"
|
|
#include "cg2400.h"
|
|
|
|
class TRic_sistema : public TApplication
|
|
{
|
|
TTable* _tab_tra;
|
|
TTransfer_file* _tras_file;
|
|
TLocalisamfile* _mov;
|
|
TLocalisamfile* _rmov;
|
|
TLocalisamfile* _rmoviva;
|
|
|
|
TString80 TEMP;
|
|
|
|
int _numtotdisk,_progdisk,_numdisk,_numinv,_numinvp,_nultras;
|
|
int _stato_ripartenza,_nultras_tab;
|
|
bool _sequenza,_disketto;
|
|
bool _prima_volta,_baipassa;
|
|
TString _nomeid,_nomeidp,_marker,_trasf,_trasfer,_pathname,_ragsoc_dittar;
|
|
long _dittainv,_dittainvp,_dittaric,_totrectras,_totrectrasp;
|
|
TDate _datatras,_datatrasp,_dataultras_tab,_dataultras;
|
|
TString _sigle_file,_nrec_file;
|
|
char _agg_cau,_agg_pcon,_agg_cls,_agg_clifo,_agg_fatatt,_agg_fatpas;
|
|
|
|
public:
|
|
virtual bool create();
|
|
virtual bool destroy();
|
|
virtual bool menu(MENU_TAG m);
|
|
bool main_loop();
|
|
bool leggi_marker();
|
|
void leggi_trasfer();
|
|
void ripristina_trasfer();
|
|
long leggi_tabella_tras();
|
|
void componi_path(TMask&);
|
|
bool video_ripartenza();
|
|
void ditta_ricevente();
|
|
bool ripartenza();
|
|
bool set_flag();
|
|
void aggiorna_tabella();
|
|
|
|
const char* converti (const TString& data_AS400);
|
|
|
|
static bool baipassa(TMask& m,KEY k);
|
|
|
|
TRic_sistema() {};
|
|
};
|
|
|
|
HIDDEN TRic_sistema& app() { return (TRic_sistema &) main_app(); }
|
|
|
|
bool TRic_sistema::create()
|
|
{
|
|
TApplication::create();
|
|
|
|
_tab_tra = new TTable ("%TRA");
|
|
_tras_file = new TTransfer_file();
|
|
|
|
_mov = new TLocalisamfile (LF_MOV);
|
|
_rmov = new TLocalisamfile (LF_RMOV);
|
|
_rmoviva = new TLocalisamfile (LF_RMOVIVA);
|
|
|
|
_numdisk = 1;
|
|
_prima_volta = TRUE;
|
|
_nultras = 0;
|
|
_nultras_tab = 0;
|
|
_baipassa = FALSE;
|
|
|
|
dispatch_e_menu (BAR_ITEM(1));
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
bool TRic_sistema::destroy()
|
|
{
|
|
delete _tab_tra;
|
|
delete _tras_file;
|
|
|
|
delete _mov;
|
|
delete _rmov;
|
|
delete _rmoviva;
|
|
|
|
return TApplication::destroy();
|
|
}
|
|
|
|
void TRic_sistema::componi_path(TMask& msk)
|
|
{
|
|
TString path,drive;
|
|
int pos;
|
|
|
|
path = msk.get(F_PATHNAME);
|
|
drive = msk.get(F_DRIVE);
|
|
pos = path.find(':');
|
|
|
|
if (drive == "A:" || drive == "B:" || drive == "D:" || drive == "E:")
|
|
_disketto = TRUE;
|
|
else
|
|
_disketto = FALSE;
|
|
|
|
if (pos)
|
|
path = path.mid(pos+1);
|
|
|
|
if (path != "")
|
|
{
|
|
_marker << drive << "\\" << path << "\\marker";
|
|
_trasfer << drive << "\\" << path << "\\trasfer";
|
|
if (!_disketto)
|
|
_pathname << drive << "\\" << path;
|
|
}
|
|
else
|
|
{
|
|
_marker << drive << "\\marker";
|
|
_trasfer << drive << "\\trasfer";
|
|
if (!_disketto)
|
|
_pathname << drive << "\\";
|
|
}
|
|
}
|
|
|
|
const char* TRic_sistema::converti (const TString& data_AS400)
|
|
{
|
|
TEMP = data_AS400.mid(4,2);
|
|
TEMP << "-" << data_AS400.mid(2,2);
|
|
TEMP << "-" << data_AS400.mid(0,2);
|
|
return TEMP;
|
|
}
|
|
|
|
bool TRic_sistema::leggi_marker()
|
|
{
|
|
TString16 tmp;
|
|
|
|
if (!fexist(_marker))
|
|
{
|
|
if (_disketto)
|
|
return error_box("File marker non presente sul dischetto %d: impossibile proseguire", _numdisk);
|
|
else
|
|
return error_box("File marker non presente in %s: impossibile proseguire", (const char*)_pathname);
|
|
}
|
|
|
|
FILE* i;
|
|
|
|
const word size = 64;
|
|
TString buffer(size);
|
|
|
|
if ( (i = fopen(_marker,"r+t")) != NULL)
|
|
{
|
|
const word letti = fread((char*)(const char*)buffer,sizeof(char),size,i);
|
|
|
|
_progdisk = atoi(buffer.sub(31,33));
|
|
_numtotdisk = atoi(buffer.sub(29,31));
|
|
|
|
if (_progdisk != _numdisk)
|
|
{
|
|
message_box("Il dischetto inserito non rispecchia la giusta sequenza");
|
|
_sequenza = FALSE;
|
|
fclose(i);
|
|
return TRUE;
|
|
}
|
|
else
|
|
_sequenza = TRUE;
|
|
|
|
if (letti == 0)
|
|
return error_box("Rilevati ERRORI nel file MARKER: impossibile proseguire");
|
|
|
|
_nomeid = buffer.sub(0,10);
|
|
_dittainv = atol(buffer.sub(10,14));
|
|
_totrectras = atol(buffer.sub(23,29));
|
|
_numinv = atoi(buffer.sub(14,17));
|
|
tmp = buffer.sub(17,23);
|
|
_datatras = converti(tmp);
|
|
|
|
if (_numdisk > 1) //Va fatto solo dal disco 2 in poi
|
|
if (_nomeid != _nomeidp || _dittainv != _dittainvp || _totrectras != _totrectrasp
|
|
|| _numinv != _numinvp || _datatras != _datatrasp)
|
|
return error_box("I dati del marker del disco %d, non corrispondono ai dati del marker del disco 1", _numdisk);
|
|
|
|
_nomeidp = _nomeid;
|
|
_dittainvp = _dittainv;
|
|
_totrectrasp = _totrectras;
|
|
_numinvp = _numinv;
|
|
_datatrasp = _datatras;
|
|
|
|
fclose(i);
|
|
|
|
if (_numdisk == 1) // Va fatto solo per il primo disco
|
|
{
|
|
_dittaric = leggi_tabella_tras();
|
|
|
|
if (_dittaric != 0)
|
|
{
|
|
if (!prefix().exist(_dittaric))
|
|
return error_box("Libreria archivi ditta non presente su disco");
|
|
}
|
|
else
|
|
return error_box("Codici NON PRESENTI in tabella ricezione: caricarli e riprovare");
|
|
}
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
return FALSE;
|
|
}
|
|
|
|
bool TRic_sistema::main_loop()
|
|
{
|
|
TMask msk ("cg2400b");
|
|
KEY tasto;
|
|
|
|
tasto = msk.run();
|
|
|
|
if (tasto == K_ENTER)
|
|
{
|
|
componi_path(msk);
|
|
|
|
do
|
|
{
|
|
if (_disketto)
|
|
{
|
|
char drive = msk.get(F_DRIVE)[0];
|
|
if (yesno_box("Inserire il dischetto %d nell' unita' %c", _numdisk,drive))
|
|
{
|
|
if (!leggi_marker())
|
|
return FALSE;
|
|
|
|
if (_sequenza)
|
|
{
|
|
if (video_ripartenza())
|
|
ripristina_trasfer();
|
|
else
|
|
return FALSE;
|
|
|
|
set_flag();
|
|
aggiorna_tabella();
|
|
_tras_file->close(); // Chiude il trasfer letto dalla directory della ditta
|
|
|
|
_numdisk++;
|
|
}
|
|
}
|
|
else
|
|
return FALSE;
|
|
}
|
|
else
|
|
{
|
|
if (!leggi_marker())
|
|
return FALSE;
|
|
|
|
if (_sequenza)
|
|
{
|
|
if (video_ripartenza())
|
|
ripristina_trasfer();
|
|
else
|
|
return FALSE;
|
|
|
|
_tras_file->close(); // Chiude il trasfer letto da disco
|
|
|
|
set_flag();
|
|
aggiorna_tabella();
|
|
_tras_file->close(); // Chiude il trasfer letto dalla directory della ditta
|
|
_numdisk++;
|
|
}
|
|
else
|
|
return FALSE;
|
|
}
|
|
}
|
|
while (_numdisk <= _numtotdisk);
|
|
}
|
|
return FALSE;
|
|
}
|
|
|
|
void TRic_sistema::leggi_trasfer()
|
|
{
|
|
_nultras = 0;
|
|
|
|
_trasf = _tras_file->path(_dittaric);
|
|
_trasf << "\\trasfer";
|
|
|
|
_tras_file->open(_trasf);
|
|
|
|
if (_tras_file->exist())
|
|
{
|
|
if (_tras_file->read_control_rec())
|
|
{
|
|
_nultras = _tras_file->nultras();
|
|
_dataultras = _tras_file->dataultras();
|
|
//_sigle_file = _tras_file->sigle_file();
|
|
//_nrec_file = _tras_file->nrec_file();
|
|
}
|
|
}
|
|
}
|
|
|
|
bool TRic_sistema::ripartenza()
|
|
{
|
|
if (_stato_ripartenza == 1)
|
|
return error_box("Rilevato stato di RIPARTENZA CON DATI CONTRADDITORI: procedura interrotta");
|
|
|
|
if (_stato_ripartenza == 2)
|
|
return error_box("Trasferimento precedente NON COMPLETATO: completarlo prima di questo");
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
bool TRic_sistema::video_ripartenza()
|
|
{
|
|
TDate dataultras;
|
|
|
|
if (_prima_volta)
|
|
{
|
|
leggi_trasfer();
|
|
|
|
_prima_volta = FALSE;
|
|
TMask msk ("cg2400a");
|
|
KEY tasto;
|
|
|
|
ditta_ricevente();
|
|
_stato_ripartenza = _tras_file->controllo_ripartenza();
|
|
|
|
msk.set(F_NOMEID, _nomeid);
|
|
msk.set(F_CODDITTAINV, _dittainv);
|
|
msk.set(F_CODDITTARIC, _dittaric);
|
|
msk.set(F_RAGSOC, _ragsoc_dittar);
|
|
msk.set(F_NULTRASDSK, _numinv);
|
|
TString data1 = _datatras.string();
|
|
msk.set(F_DATAULTRASDSK, data1);
|
|
|
|
if (_nultras != 0)
|
|
{
|
|
msk.set(F_NULTRASTAB, _nultras);
|
|
TString data2 = _dataultras.string();
|
|
msk.set(F_DATAULTRASTAB, data2);
|
|
}
|
|
else
|
|
{
|
|
msk.set(F_NULTRASTAB, _nultras_tab);
|
|
TString data2 = _dataultras_tab.string();
|
|
msk.set(F_DATAULTRASTAB, data2);
|
|
}
|
|
|
|
if (_stato_ripartenza == 1 || _stato_ripartenza == 2 )
|
|
msk.set(F_STATO, "NON COMPLETA");
|
|
else
|
|
if (_stato_ripartenza == 0)
|
|
msk.set(F_STATO, "COMPLETA");
|
|
|
|
if (_numdisk == 1) // Va fatto solo per il primo disco
|
|
{
|
|
do
|
|
{
|
|
msk.set_handler(baipassa);
|
|
|
|
tasto = msk.run();
|
|
|
|
if (tasto != K_ENTER)
|
|
return FALSE;
|
|
|
|
if (_baipassa)
|
|
return TRUE;
|
|
|
|
if (!ripartenza())
|
|
return FALSE;
|
|
|
|
if (_numinv > (_nultras_tab + 1))
|
|
warning_box("Trasferimento FUORI SEQUENZA: manca un trasferimento intermedio");
|
|
else
|
|
if (_numinv < (_nultras_tab +1))
|
|
warning_box("I dischetti risultano GIA' TRASFERITI");
|
|
else
|
|
return TRUE;
|
|
}
|
|
while (tasto == K_ENTER);
|
|
}
|
|
}
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
bool TRic_sistema::baipassa(TMask& m,KEY k)
|
|
{
|
|
if ( (k == K_SHIFT+K_F7) && (app()._stato_ripartenza == 0) )
|
|
app()._baipassa = TRUE;
|
|
else
|
|
app()._baipassa = FALSE;
|
|
|
|
return FALSE;
|
|
}
|
|
|
|
void TRic_sistema::ripristina_trasfer()
|
|
{
|
|
TString ditta,app;
|
|
|
|
if (_numdisk == 1)
|
|
set_firm(_dittaric);
|
|
|
|
// app.format("%05da", _dittaric);
|
|
|
|
// ditta << "C:\\prassi\\" << app << "\\trasfer";
|
|
// fcopy(_trasfer,/*ditta*/_trasf,TRUE);
|
|
|
|
_tras_file->fcopytemp(_trasfer, _trasf, TRUE);
|
|
}
|
|
|
|
void TRic_sistema::ditta_ricevente()
|
|
{
|
|
TLocalisamfile nditte (LF_NDITTE);
|
|
|
|
nditte.setkey(1);
|
|
nditte.zero();
|
|
nditte.put(NDT_CODDITTA, _dittaric);
|
|
if (nditte.read() == NOERR)
|
|
_ragsoc_dittar = nditte.get(NDT_RAGSOC);
|
|
}
|
|
|
|
long TRic_sistema::leggi_tabella_tras()
|
|
{
|
|
TString dep;
|
|
long ditta = 0;
|
|
bool agg_fatatt,agg_fatpas;
|
|
|
|
_tab_tra->zero();
|
|
dep = format("%10s%05d", (const char*) _nomeid, _dittainv);
|
|
_tab_tra->put("CODTAB", (const char*) dep);
|
|
if (_tab_tra->read() == NOERR)
|
|
{
|
|
ditta = _tab_tra->get_long("I0");
|
|
_nultras_tab = _tab_tra->get_int ("I1");
|
|
_dataultras_tab = _tab_tra->get_date("D0");
|
|
_agg_cau = _tab_tra->get_char("S0");
|
|
_agg_clifo = _tab_tra->get_char("S1");
|
|
_agg_pcon = _tab_tra->get_char("S2");
|
|
_agg_cls = _tab_tra->get_char("S3");
|
|
agg_fatatt = _tab_tra->get_bool("B0");
|
|
if (agg_fatatt)
|
|
_agg_fatatt = 'X';
|
|
else
|
|
_agg_fatatt = ' ';
|
|
|
|
agg_fatpas = _tab_tra->get_bool("B1");
|
|
if (agg_fatpas)
|
|
_agg_fatpas = 'X';
|
|
else
|
|
_agg_fatpas = ' ';
|
|
}
|
|
|
|
return ditta;
|
|
}
|
|
|
|
bool TRic_sistema::set_flag()
|
|
{
|
|
TString sigla;
|
|
long nrec;
|
|
int j;
|
|
int k = 0;
|
|
TString flag;
|
|
TString record;
|
|
TString ana_com,pcon_cau;
|
|
TString uselab;
|
|
bool fatto = TRUE;
|
|
|
|
TConfig conf(CONFIG_DITTA);
|
|
|
|
ana_com = conf.get("AnCfCm","cg");
|
|
pcon_cau = conf.get("PcTcCm","cg");
|
|
|
|
_tras_file->open(_trasf);
|
|
|
|
if (_tras_file->exist())
|
|
{
|
|
if (_tras_file->read_control_rec())
|
|
{
|
|
_nultras = _tras_file->nultras();
|
|
_dataultras = _tras_file->dataultras();
|
|
_sigle_file = _tras_file->sigle_file();
|
|
_nrec_file = _tras_file->nrec_file();
|
|
record = _tras_file->record();
|
|
// La fill_index e' richiamata dentro a read_control_rec
|
|
// _tras_file->fill_index(_sigle_file,_nrec_file);
|
|
}
|
|
|
|
for (j = 0; j < _sigle_file.len(); j++)
|
|
{
|
|
sigla = _sigle_file.mid(j,1);
|
|
nrec = atol(_nrec_file.mid(k,6));
|
|
|
|
if (fatto)
|
|
{
|
|
if (sigla == "W" || sigla == "P")
|
|
{
|
|
if (nrec > 0 && pcon_cau == "")
|
|
{
|
|
flag = "T";
|
|
fatto = FALSE;
|
|
}
|
|
}
|
|
else
|
|
if (sigla == "A")
|
|
{
|
|
if (nrec > 0 && ana_com == "")
|
|
{
|
|
flag = "T";
|
|
fatto = FALSE;
|
|
}
|
|
}
|
|
else
|
|
if (sigla == "Z" || sigla == "U" || sigla == "B")
|
|
{
|
|
if (nrec > 0)
|
|
{
|
|
flag = "C";
|
|
fatto = FALSE;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
flag = "*";
|
|
fatto = FALSE;
|
|
}
|
|
|
|
if (flag == "T")
|
|
uselab = sigla;
|
|
else
|
|
uselab = "";
|
|
}
|
|
|
|
if (sigla == "W" || sigla == "P")
|
|
{
|
|
if (pcon_cau == "X")
|
|
{
|
|
_sigle_file.overwrite(" ",j);
|
|
_nrec_file.overwrite("000000",k);
|
|
}
|
|
}
|
|
|
|
if (sigla == "A")
|
|
{
|
|
if (ana_com == "X")
|
|
{
|
|
_sigle_file.overwrite(" ",j);
|
|
_nrec_file.overwrite("000000",k);
|
|
}
|
|
}
|
|
k += 6;
|
|
}
|
|
|
|
record.overwrite(_sigle_file,38);
|
|
record.overwrite(_nrec_file,47);
|
|
|
|
TString agg(7);
|
|
|
|
agg[0] = _agg_cls;
|
|
agg[1] = _agg_cau;
|
|
agg[2] = _agg_clifo;
|
|
agg[3] = _agg_pcon;
|
|
agg[4] = _agg_fatatt;
|
|
agg[5] = _agg_fatpas;
|
|
agg[6] = '\0';
|
|
|
|
record.overwrite(agg,234);
|
|
record.overwrite(uselab,240);
|
|
record.overwrite(" ",241);
|
|
|
|
const int size = 256;
|
|
|
|
if (!_tras_file->write_control_rec(record, size))
|
|
return FALSE;
|
|
}
|
|
|
|
conf.set("FlStTra", flag);
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
void TRic_sistema::aggiorna_tabella()
|
|
{
|
|
TString dep;
|
|
|
|
_tab_tra->zero();
|
|
dep = format("%10s%05d", (const char*) _nomeid, _dittainv);
|
|
_tab_tra->put("CODTAB", (const char*) dep);
|
|
if (_tab_tra->read() == NOERR)
|
|
{
|
|
_tab_tra->put("I1", (long)_nultras);
|
|
_tab_tra->put("D0", _dataultras);
|
|
_tab_tra->rewrite();
|
|
}
|
|
}
|
|
|
|
bool TRic_sistema::menu(MENU_TAG m)
|
|
{
|
|
if (m == BAR_ITEM(1))
|
|
return main_loop();
|
|
return FALSE;
|
|
}
|
|
|
|
int cg2400 (int argc, char* argv[])
|
|
{
|
|
TRic_sistema a;
|
|
a.run(argc, argv,"Ricezione archivi");
|
|
return TRUE;
|
|
}
|