#include <stdlib.h>
#include <ctype.h>

#include <applicat.h>
#include <isam.h>
#include <mask.h>
#include <prefix.h>
#include <progind.h>
#include <urldefid.h>
#include <utility.h>
#include <validate.h>
#include <progind.h>

#include "ba1.h"
#include "ba1100.h"

#if XVT_OS==XVT_OS_SCOUNIX
#define DIRSIZ   14
struct direct
{
  unsigned short d_ino;
  char           d_name[DIRSIZ];
};  
#else
#include <errno.h>
#include <dos.h>
#endif

class TManutenzione_app : public TApplication
{
  TDir_sheet * _browse;
  TMask  * _mask; 
  long    _firm;
  TRec_sheet*     _rec;

protected:
  virtual bool menu (MENU_TAG);
  virtual bool create () ;
  virtual bool destroy();
  void insert_riga(long, TToken_string&);
  void edit_riga(long, TToken_string&);
  void delete_riga();
  virtual bool extended_firm() const { return TRUE; }
  void update();
  void update_dir();
  void convert_dir();
  virtual void print();
  virtual void do_print(TPrinter & p, TRec_sheet & r);
  const char* dumpfilename(const FileDes& dep) const;

public:
  TManutenzione_app() : _browse(NULL), _rec(NULL), _mask(NULL) {}

};

HIDDEN void build_filelist(const char *path, TArray & list)

{
#if XVT_OS==XVT_OS_SCOUNIX
  struct directx
  {
    ino_t       d_ino;
    char        d_name[DIRSIZ + 1];
  } dlink;
  int   fd;

  if ((fd = open(path, 0)) == -1)
    return;
  dlink.d_name[DIRSIZ] = '\0';
  while(read(fd, &dlink, sizeof(struct direct)) ==
        sizeof(struct direct))
  {
    if (dlink.d_ino > 0)
    {
      TFixed_string dname(dlink.d_name);

      if (dname.find(".des") > 0 && dname[0] == 'd' && !isdigit(dname[1]))
        list.add(dname.mid(1,3));
    }
  }
  close(fd);  
#else     
  _find_t f;
  
  if (_dos_findfirst("recdesc/d???.des", _A_NORMAL, &f) == 0)
  { 
    bool one_to_add = TRUE;
    while (one_to_add)
    {                  
      TString80 dname(f.name);
      
      list.add(dname.mid(1,3));
      one_to_add = _dos_findnext(&f) == 0;
    }
  }
#endif
}

void TManutenzione_app::do_print(TPrinter & p, TRec_sheet & r)

{
  const char* table[] =  {"", "Alfanumerico", "Intero", "Intero Lungo",
                          "Reale", "Data", "Intero", "Carattere",
                          "Booleano", "Intero Zerofilled", 
                          "Intero Lungo Zerofilled"};
  TPrintrow row;
  TToken_string s;
  TParagraph_string d("", 25);
  TConfig * descr = NULL;
  TTrec & rec = *r.rec();
  TDir & dir = *r.dir();
  const char * descfname = r.descfname();
  TString16 tab(r.tab());
  const bool istab = tab.not_empty();
  
  tab.upper();
  if (fexist(descfname))
    descr = new TConfig(descfname, DESCPAR);

  const bool hasdescr = descr != NULL;

  row.reset();
  if (istab)
    row.put(format("Lista tabella %s ", (const char *) tab), 2);
  else
    row.put(format("Lista tracciato %s (%s)", dir.des(), dir.name()), 2);
  row.put("Pag. @#", 69);
  p.setheaderline(2, row);
  row.reset();
  row.put("Nome", 7);
  row.put("Tipo", 18);
  row.put("Lun.", 38);
  row.put(" Dec.", 43);
  row.put("Pos.", 48);
  row.put("Descrizione", 53);
  p.setheaderline(4, row);
  p.setbackground("l[1,6,78,6]");
  for (int i = 0; i < rec.fields(); i ++)
  {
    row.reset();
    s = rec.fielddef(i);
    TString16 name = s.get();
    row.put(format("%3d", i + 1), 2);
    row.put(name, 7);
    row.put(table[s.get_int()], 18);
    row.put(format("%4d", s.get_int()), 38);
    row.put(format("%4d", s.get_int()), 43);
    row.put(format("%4d", rec.rec()->Fd[i].RecOff), 48);
    const char *wd = NULL;

    d = "";
    if (hasdescr)
      d = descr->get(name);
    if (!istab || d.not_empty())
    {
      if (hasdescr)
      {
        wd = d.get(); 
        if (wd != NULL)
          row.put(wd, 53);
      }
      p.print(row);
      wd = d.get();
      while(wd != NULL)
      {
        row.reset();
        row.put(wd, 53);
        p.print(row);
        wd = d.get();
      }
    }
  }  
  p.formfeed();
  row.reset();
  row.put("Espressione chiave", 7);
  row.put("Duplicabile", 68);
  p.setheaderline(4, row);
  for (i = 0; i < rec.keys(); i ++)
  {
    row.reset();
    s = rec.keydef(i);
    row.put(format("%3d", i + 1), 2);
    row.put(s.get(), 7);
    row.put(*s.get() == 'X' ? "Si" : "No", 68);
    p.print(row);
  }
  p.formfeed();
  if (hasdescr)
    delete descr;
}

void TManutenzione_app::print()

{
  TPrinter & p = printer();

  p.open();
  p.headerlen(6);
  p.footerlen(4);
  if (_rec == NULL)
  { 
    TDir d;
    
    d.get(LF_DIR); 
    int items = (int)d.eod();
    TProgind *pi;
    pi = new TProgind(items,"Stampa tracciati record archivi", TRUE, TRUE, 63);

    pi->setstatus(2);

    for (int i = 2 ; !pi->iscancelled() && i <= items; i++)
    {
      TRec_sheet r(i, "");
      pi->addstatus(1);
      do_print(p, r);
    }

    delete pi;
    TArray list;

    build_filelist(DESCDIR, list);
    items = list.items();
    
    pi = new TProgind(items,"Stampa descrizione tabelle", TRUE, TRUE, 63);

    for (i = 0; !pi->iscancelled() && i < items; i++)
    {
      TString & tab = (TString &) list[i];
      TRec_sheet r(4, tab);

      pi->addstatus(1);
      do_print(p, r);
    }
    delete pi;
  }
  else do_print(p, *_rec);
  p.close();
}

bool TManutenzione_app::create() // initvar e arrmask

{
  TApplication::create();

  _firm = get_firm();
  
  if (argc() > 2)
  {
    update();
    return FALSE;
  }
  else
  {
    _mask = new TMask ("ba1100a");
    set_firm();
    _browse = new TDir_sheet ("Manutenzione file di sistema") ;  
    _browse->add_button(DLG_INSFILE, "Inserisce", K_F6);
    _browse->add_button(DLG_CONVERT, "Converte", K_F7);
    _browse->add_button(DLG_ADDFILE, "Aggiunge", K_F8);
    dispatch_e_menu(BAR_ITEM(1));
  }  
  enable_menu_item(M_FILE_PRINT);
  return TRUE ;
}

bool TManutenzione_app::destroy() // releasev e arrmask

{
  if (_firm) set_firm(_firm);
  if (_browse != NULL) delete  _browse;
  if (_mask != NULL) delete  _mask;
  return TApplication::destroy() ;
}


void TManutenzione_app::insert_riga (long riga_sel, TToken_string& riga)
{
  const int logicnum = int(riga_sel) + 1;
  const int num_files = (int)_browse->items();
  
  _mask->disable(DLG_PACK);
  _mask->disable(DLG_RECORD);
  _mask->disable(DLG_LOAD);
  _mask->disable(DLG_DUMP);
  _mask->show(F_TAB, logicnum >= LF_TABGEN && logicnum <= LF_TAB);
  _mask->hide(FLD_EXTEND);
  _mask->hide(FLD_EOX);
  _mask->set (FLD_NUM, riga.get(0));
  _mask->reset (F_TAB);
  
  if (_mask->run() == K_ENTER)
  {
    /* shift di uno in avanti degli elementi del direttorio partendo dall'ultimo */
    for (int i=num_files; i>=logicnum; i--)
    {
      _browse->dir()->get (i, _nolock, _nordir, _sysdirop);
      _browse->dir()->put (i + 1, _nordir, _sysdirop);
      _browse->rec()->get (i);
      _browse->rec()->put (i + 1);
    }
    _browse->dir()->set(_mask->get(FLD_NOME), _mask->get_long(FLD_EOD),
                        _mask->get_long(FLD_FLAG), _mask->get (FLD_DESC),
                        _mask->get (FLD_FORMULA));
    _browse->dir()->put(logicnum, _nordir, _sysdirop);
    _browse->rec()->zero();
    _browse->rec()->put(logicnum);
    _browse->dir()->get(LF_DIR);
    _browse->dir()->eod()++;
    _browse->set_items(_browse->dir()->eod());
    _browse->dir()->put(LF_DIR);
  }
}

const char* TManutenzione_app::dumpfilename(const FileDes& dep) const
{
  TFilename n; n.tempdir();
#if XVT_OS == XVT_OS_SCOUNIX  
  n << '/';
#else  
  n << '\\';
#endif  
  n << dep.SysName;
  n.strip("$%");
  n.ext("txt");
  n.lower();
  
  strcpy(__tmp_string, n);
  return __tmp_string;
}

void TManutenzione_app::edit_riga (long riga_sel, TToken_string& riga)

{
  KEY  tasto;
  FileDes  dep;
  TDir d;
  const int logicnum = int(riga_sel) + 1;

  _mask->enable(DLG_PACK);
  _mask->enable(DLG_RECORD);
  _mask->enable(DLG_LOAD);
  _mask->enable(DLG_DUMP);
  _mask->show(F_TAB, logicnum >= LF_TABGEN && logicnum <= LF_TAB);
  _mask->set (FLD_NUM, riga.get(0));
  _mask->set (FLD_NOME, riga.get());
  _mask->set (FLD_EOD, riga.get());
  _mask->set (FLD_EOX, riga.get());
  _mask->set (F_LEN, riga.get());
  _mask->set (FLD_DESC, riga.get());
  _mask->set (FLD_FORMULA, riga.get());
  _mask->set (FLD_FLAG, riga.get());
  _mask->reset (FLD_EXTEND);
  _mask->reset (F_TAB);

  const TRecnotype oldeox = atol(_mask->get(FLD_EOX));
  const bool com = prefix().is_com() || !*prefix().name();
  const char* name = _mask->get(FLD_NOME);
  const bool enable_extend = (com ? *name != '$' : *name == '$') && (riga_sel > 0);

  _mask->show(FLD_EXTEND, enable_extend);
  _mask->show(FLD_EOX, enable_extend);
  tasto = _mask->run();

  switch (tasto)
  {
  case K_F4:
  {
    const TFilename filename(_mask->get(FLD_NOME));

    if (logicnum > 1) 
    {
      TEdit_file ef;
      ef.browse(logicnum, filename);
    }
  }    
  break;
 case K_F5:
 case K_F6:
 case K_F7:
 case K_F8:
 case K_ENTER:
{
  strcpy (dep.SysName,_mask->get (FLD_NOME));
  dep.EOD = atol(_mask->get (FLD_EOD));
  dep.Flags = atol(_mask->get (FLD_FLAG));
  strcpy (dep.Des,_mask->get (FLD_DESC));
  strcpy (dep.FCalc,_mask->get (FLD_FORMULA));
  const TRecnotype eox = atol(_mask->get(FLD_EOX));

  _browse->dir()->get(logicnum, _lock, _nordir, _sysdirop);
  _browse->dir()->set(dep.SysName, dep.EOD, dep.Flags,
                      dep.Des, dep.FCalc);
  _browse->dir()->put(logicnum, _nordir, _sysdirop);

{
  TSystemisamfile f(logicnum);

  if (eox != oldeox)
  {
    d.get(logicnum);
    if (!fexist(d.name())) f.build(eox);
    else f.extend(eox);
    _browse->dir()->get(logicnum, _nolock, _nordir, _sysdirop);
  }
  if (tasto == K_F5)
  {
    f.packfile();
    f.packindex();
  }
  else
    if (tasto == K_F6)
    {
      _rec = new TRec_sheet(logicnum, _mask->get(F_TAB));
      _rec->edit();
      delete _rec;
      _rec = NULL;
    }
    else
      if (tasto == K_F7)
      {
        TMask m("ba1100b");
        
        TFilename nout(dumpfilename(dep));
        m.set(FLD_OUTFILE, nout);

        if (m.run() == K_ENTER)
        {
          nout = m.get(FLD_OUTFILE);
          if (nout.not_empty())
          {
            const char fs = *esc(m.get(FLD_FS));
            const char fd = *esc(m.get(FLD_FD));
            const char rs = *esc(m.get(FLD_RS));
            const bool withdel = m.get_bool(FLD_WITHDEL);
            const int keyno = m.get_int(FLD_KEYNO);
            f.dump(nout, keyno, fs, fd, rs, withdel);
          }  
        }
      }
      else
        if (tasto == K_F8)
        {
          TMask m("ba1100c");
          TFilename ninp(dumpfilename(dep));
          m.set(FLD_INFILE, ninp);
          if (m.run() == K_ENTER)
          {
            char fs = *esc(m.get(FLD_FS));
            char fd = *esc(m.get(FLD_FD));
            char rs = *esc(m.get(FLD_RS));
            ninp = m.get(FLD_INFILE);
            f.load(ninp, fs, fd, rs);
          }
        }
}
}
break;
default:
break;
}
}

void TManutenzione_app::delete_riga ()

{
  _browse->dir()->get(LF_DIR);
  if (_browse->dir()->eod() == 0) return;

  int logicnum = (int)_browse->items();

  _browse->dir()->get(logicnum);
  if (yesnocancel_box("Confermare l'eliminzione dell'archivio %s", _browse->dir()->name()) != K_YES) return;
  _browse->dir()->get(LF_DIR);
  _browse->dir()->eod()--;
  _browse->set_items(_browse->dir()->eod());
  _browse->dir()->put(LF_DIR);

}

void TManutenzione_app::update_dir()

{
  const TString pref(prefix().name());
  const bool is_com = prefix().is_com();

  prefix().set(""); 
  
  TDir d;
  d.get(LF_DIR);                 
  const int orig_items = (int)d.eod();
  
  prefix().set(pref); 

  d.get(LF_DIR);                 
  const int items = (int)d.eod();
  TString80 s("Aggiornamento direttorio ");

  if (is_com) s << "comune";
  else s << " della ditta " << atol (pref);
  
  TProgind p(items ? items : 1, s, TRUE, TRUE, 70);

  p.setstatus(1);
  for (int i = 2; i <= items; i++)
  { 
    p.addstatus(1);
    prefix().set(""); 
    d.get(i, _nolock, _nordir, _sysdirop);                 
    TString desc(d.des());
    TString s(d.name());
    bool towrite = FALSE;

    long flags = d.flags();
    word len = d.len();
    prefix().set(pref);
    d.get(i, _nolock, _nordir, _sysdirop); 
    bool to_create = (is_com ? d.is_com() : d.is_firm());
    
    if (flags < 0 && len != d.len() && s != d.name())
    {
      d.set(s, d.eox(), 0L, desc, d.expr()); 
      towrite = TRUE;
    }
    else
    {
      towrite = (desc != d.des());
      if (towrite)
        strcpy((char *) d.des(), desc);
    }
    if (towrite)
      d.put(i, _nordir, _sysdirop);                 
    d.get(i);
    TFilename datafile(d.name());

    if (to_create && !fexist(datafile))
    {
      TSystemisamfile f(i);
      f.build(10L);
    }
  }
  prefix().set(pref);

  if (items >= orig_items) return;
  
  for (i = items + 1; i <= orig_items; i++)
  {
    prefix().set(""); 
    d.get(i, _nolock, _nordir, _sysdirop);                 
    prefix().set(pref);
    d.set_len(0); 
    d.flags() = 0L; 
    d.put(i, _nordir, _sysdirop);                 
  }
  prefix().set(pref);
  d.get(LF_DIR, _nolock, _nordir, _sysdirop);                 
  d.eod() = orig_items; 
  d.put(LF_DIR, _nordir, _sysdirop);                 
} 

void TManutenzione_app::convert_dir()

{         
  const TString pref(prefix().name());
  TDir d;
  TTrec r;
  
  d.get(LF_DIR);                 
  const int items = (int)d.eod();
  TString80 s("Aggiornamento archivi ");

  if (prefix().is_com()) s << "comuni";
  else s << " della ditta " << atol (pref);
  
  TProgind p(items ? items : 1, s, TRUE, TRUE, 70);

  p.setstatus(1);
  
  for (int i = 2; i <= items; i++)
  {  
    p.addstatus(1);
    prefix().set(""); 
    r.get(i);                 
    prefix().set(pref); 
    TSystemisamfile f(i);
    f.update(r);         
  }
  prefix().set(""); 
  const long level = prefix().filelevel();
  prefix().set(pref);
  d.get(LF_DIR, _nolock, _nordir, _sysdirop);                 
  d.flags() = level; 
  d.put(LF_DIR, _nordir, _sysdirop);                 
}

void TManutenzione_app::update()

{ 
  long firm = get_firm();             
  TString pref;
  if (firm == 0) pref = prefix().name();
  
  do_events();
  
  begin_wait();
  prefix().set("com");
  update_dir();
  convert_dir();
  
  TSystemisamfile ditte(LF_NDITTE);
  ditte.open();
  
  for (ditte.first(); !ditte.eof(); ditte.next())
  {
    const long codditta = ditte.get_long("CODDITTA");
    const TRecnotype rec = ditte.recno();
    
    if (prefix().exist(codditta))
    {
      ditte.close();
      set_firm(codditta);
      update_dir();
      convert_dir();
      ditte.open();
    }
    ditte.readat(rec);
  }
  ditte.close();
  
  if (firm > 0) set_firm(firm);
  else prefix().set(pref);
  
  end_wait();
}

bool TManutenzione_app::menu(MENU_TAG m)
{
  TToken_string riga;
  long  riga_selezionata;
  bool  done = FALSE;

  _browse->rebuild();

  while (!done)
  {

    disable_menu_item(M_FILE_NEW);

    switch (_browse->run())
    {
    case K_F6: 
      riga_selezionata = _browse->selected();
      riga = _browse->row();
      insert_riga (riga_selezionata, riga);
      break;
      
    case K_ENTER: 
      riga_selezionata = _browse->selected();
      riga = _browse->row();
      edit_riga (riga_selezionata, riga);
      break;

    case K_DEL: delete_riga(); break;

    case K_ESC: done = TRUE; break;         

    case K_F7: update(); break;
      
    case K_F8:
      _browse->add();
      riga_selezionata = _browse->items() - 1;
      riga = _browse->row(riga_selezionata);
      edit_riga (riga_selezionata, riga);
      break;
      
    default: break;
    } 
    
    enable_menu_item(M_FILE_NEW);
  }
  
  return xvt_test_menu_tag(BAR_ITEM(2));
}

int ba1100(int argc, char** argv)
{
  TManutenzione_app a;
  a.run(argc, argv, "Gestione files");
  return 0;
}