#include <fcntl.h>
#ifndef WIN32
#include <termios.h>
#endif
#include <stdlib.h>
#include <stdio.h>
#ifndef WIN32
#include <unistd.h>
#endif
#include <ctype.h>
#include <string.h>
#include <errno.h>

// Pretpostavlja se da je komunikacija 9600bps
#define BAUDRATE B9600

// Interne varijable programa
  struct SInit
  {
  char port[255];
  char portdelay[255];
  char output[255];
  char debug[5];
  char silent[5];
  char verify[5];
  char speed[20];
  char status[255];
  } Init;

// Paket odgovora printera

  struct ReplyPacket
  {
  char preamble;
  char len;
  char seq;
  char cmd;
  char rdata[255];
  char sep;
  unsigned char stat[6];
  char postamble;
  char bcc[4];
  char term;
  } rpacket;

/*     GLOBALS     */
struct SInit Initialize;

/*Rutina za generisanje komande printeru*/
void SendForm(int fd, char seq, char cmd, char *message)
{
char outstring[256];		//buffer za paket
unsigned int cpos;		//
unsigned long int checksum;	//checksum paketa
char oc;			//pozicija u paketu
int fh,status;

oc=0;
outstring[oc]=toascii(0x01);	//1. bajt - uvek 01
oc++;
outstring[oc]=toascii(0x20+3+strlen(message)+1);  //2. bajt - projektovana duzina paketa
oc++;
if (seq>0x80) seq=seq-0x7f;	//3. bajt - sekvenca, ne moze biti veci od 7fh
outstring[oc]=toascii(seq);
oc++;
outstring[oc]=toascii(cmd);	//4. bajt - komanda 20h-70h
oc++;

for (cpos=0;cpos<strlen(message);cpos++) //5. bajt - x. bajt - podaci komande
outstring[oc+cpos]=message[cpos];
oc=oc+strlen(message);
outstring[oc]=toascii(0x05);		//postamble
oc++;
checksum=0;
for (cpos=1;cpos<oc;cpos++)
{
checksum=checksum+outstring[cpos];
}
outstring[oc]=toascii(0x30+((checksum/256)/16));	//4 bajta za checksum
oc++;
outstring[oc]=toascii(0x30+((checksum/256)-((checksum/256)/16)*0x10));
oc++;
outstring[oc]=toascii(0x30+((checksum-((checksum/256)*256))/16));
oc++;
outstring[oc]=toascii(0x30+(checksum-(checksum/0x10)*0x10));
oc++;
outstring[oc]=toascii(0x3);	//terminator
oc++;
outstring[oc]=toascii(13);	//"enter", nepotrebno?

status=write(fd,&outstring,oc+1);
if (status<1) {puts("Error in sending form");exit(0);}
}

int OpenSerial(char *port)
{
  int fd;

#ifndef WIN32
  struct termios options;
  fd = open(port, O_RDWR | O_NOCTTY | O_NONBLOCK );  
  if (fd<0) puts("Error in accessing serial device");
#endif

return fd;
}

char* ReadFromPort(fd,ss,l)
char *ss;
int fd,l;
{
int r;
r=read(fd,ss,l);
//fcntl(fd, F_SETFL, FNDELAY);
}

void SendToPort(fd,ss)
char *ss;
int fd;
{
write(fd,ss,sizeof(ss));
}

void CloseSerial(fd)
{
close(fd);
}

char* GetInit(char *buffer, char *sstring)
{
char rstring[255];
int stresult,pos;
char *fn;

fn=strstr(buffer,sstring);
stresult=fn-buffer+1;
stresult=stresult+strlen(sstring)-1;
pos=0;
while ((buffer[stresult]!=toascii(0x0A)) && (buffer[stresult]!=toascii(0x0D)))
{
rstring[pos]=buffer[stresult];
pos++;
stresult++;
}
rstring[pos]=toascii(0);
return rstring;
}

// Otvaranje serijskog porta i citanje lokalnih varijabli
void initialization(void)
{
 char buffer[16384];
 char rstring[255];
 int stresult,sresult;
 char *fn;
 FILE *init;
  char *setting;

  if((init  = fopen( "init", "r" )) == NULL ) {printf( "The file 'init' was not opened\n" );exit(0);}

fread(&buffer,1,10000,init);

setting=GetInit(buffer,"port=");
strcpy(Initialize.port,setting);

setting=GetInit(buffer,"speed=");
strcpy(Initialize.speed,setting);

setting=GetInit(buffer,"verify=");
strcpy(Initialize.verify,setting);

setting=GetInit(buffer,"debug=");
strcpy(Initialize.debug,setting);

setting=GetInit(buffer,"silent=");
strcpy(Initialize.debug,setting);

setting=GetInit(buffer,"status=");
strcpy(Initialize.status,setting);

setting=GetInit(buffer,"portdelay=");
strcpy(Initialize.portdelay,setting);

setting=GetInit(buffer,"output=");
strcpy(Initialize.output,setting);

if(fclose(init)) {printf( "The file 'data' was not closed\n" );exit(0);}
}

// Uzimanje odgovora od printera
// 
void GetForm(int fd)
{
int i;

#ifndef WIN32
int flags = fcntl(fd, F_GETFL, 0);
int retval = fcntl(fd, F_SETFL, flags & ~O_NDELAY); 
#endif

while (read(fd,&rpacket.preamble,1)<1) rpacket.preamble=0;
if (rpacket.preamble==21) puts("Checksum of input file is bad");
while (rpacket.preamble==22) while (read(fd,&rpacket.preamble,1)<1) rpacket.preamble=22;
if (rpacket.preamble==21) puts("Checksum of input file is bad");
if (rpacket.preamble!=1) puts("Preamble bad.");
if (Initialize.debug[0]=='1') printf("Preamble: %i\n",rpacket.preamble);
while (read(fd,&rpacket.len,1)<1) rpacket.len=0;
if (Initialize.debug[0]=='1') printf("Len: %i\n",rpacket.len);
while (read(fd,&rpacket.seq,1)<1) rpacket.seq=0;
if (Initialize.debug[0]=='1') printf("Seq: %i\n",rpacket.seq);
while (read(fd,&rpacket.cmd,1)<1) rpacket.cmd=0;
if (Initialize.debug[0]=='1') printf("Cmd: %i\n",rpacket.cmd);

if ((rpacket.len-11-0x20)<0) puts("Serious error - packet length not possible.");
for (i=1;i<=rpacket.len-11-0x20;i++)
{
while (read(fd,&rpacket.rdata[i-1],1)<1) rpacket.rdata[i]=' ';
}
rpacket.rdata[i]=0;
if (Initialize.debug[0]=='1') puts("Packet returned:");
if (Initialize.debug[0]=='1') puts(rpacket.rdata);

while (read(fd,&rpacket.sep,1)<1) rpacket.sep=0;
if (rpacket.sep!=4) puts("Divider bad.");
while (read(fd,&rpacket.stat[0],1)<1) rpacket.stat[0]=0;
while (read(fd,&rpacket.stat[1],1)<1) rpacket.stat[1]=0;
while (read(fd,&rpacket.stat[2],1)<1) rpacket.stat[2]=0;
while (read(fd,&rpacket.stat[3],1)<1) rpacket.stat[3]=0;
while (read(fd,&rpacket.stat[4],1)<1) rpacket.stat[4]=0;
while (read(fd,&rpacket.stat[5],1)<1) rpacket.stat[5]=0;
while (read(fd,&rpacket.postamble,1)<1) rpacket.postamble=0;
while (read(fd,&rpacket.bcc[0],1)<1) rpacket.bcc[1]=0;
while (read(fd,&rpacket.bcc[1],1)<1) rpacket.bcc[2]=0;
while (read(fd,&rpacket.bcc[2],1)<1) rpacket.bcc[3]=0;
while (read(fd,&rpacket.bcc[3],1)<1) rpacket.bcc[4]=0;
while (read(fd,&rpacket.term,1)<1) rpacket.term=0;

if (rpacket.postamble!=5) puts("Postamble bad.");
if (rpacket.term!=3) puts("Terminator bad.");
}

// Reuturn results to output file.
void AddToOutput(char *infile)
{
FILE *fh;
char s[255];

strcpy(s,infile);
strcat(s,Initialize.output);
fh  = fopen( s, "a" );
if (fh == NULL ) printf( "The file 'output' was not opened\n" );
fseek(fh,0,SEEK_END);
fputs(rpacket.rdata,fh);
fputc(toascii(0X0A),fh);
fclose(fh);

strcpy(s,infile);
strcat(s,Initialize.status);
fh  = fopen( s, "w" );
if (fh == NULL ) printf( "The file 'status' was not opened\n" );

fputs("[General purpose]",fh);
fputc(toascii(0X0A),fh);
fputs("Syntax Error=",fh);
if ((rpacket.stat[0] & 1)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Invalid Code=",fh);
if ((rpacket.stat[0] & 2)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Date&Time not set=",fh);
if ((rpacket.stat[0] & 4)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Display unconnected=",fh);
if ((rpacket.stat[0] & 8)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Mechanism defected=",fh);
if ((rpacket.stat[0] & 16)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("General Error=",fh);
if ((rpacket.stat[0] & 32)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Reserved=",fh);
if ((rpacket.stat[0] & 64)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Reserved=",fh);
if ((rpacket.stat[0] & 128)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputc(toascii(0X0A),fh);

fputs("[General purpose]",fh);
fputc(toascii(0X0A),fh);
fputs("Sum Overflow=",fh);
if ((rpacket.stat[1] & 1)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Command not permitted=",fh);
if ((rpacket.stat[1] & 2)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("RAM Clearing=",fh);
if ((rpacket.stat[1] & 4)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Not used=",fh);
if ((rpacket.stat[1] & 8)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("RAM Destroyed=",fh);
if ((rpacket.stat[1] & 16)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Printer opened=",fh);
if ((rpacket.stat[1] & 32)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Reserved=",fh);
if ((rpacket.stat[1] & 64)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Reserved=",fh);
if ((rpacket.stat[1] & 128)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputc(toascii(0X0A),fh);

fputs("[General purpose]",fh);
fputc(toascii(0X0A),fh);
fputs("No paper on both=",fh);
if ((rpacket.stat[2] & 1)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Paper near end on both=",fh);
if ((rpacket.stat[2] & 2)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("No journal paper=",fh);
if ((rpacket.stat[2] & 4)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Open fiscal receipt=",fh);
if ((rpacket.stat[2] & 8)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Journal paper near end=",fh);
if ((rpacket.stat[2] & 16)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Non-fiscal receipt opened=",fh);
if ((rpacket.stat[2] & 32)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Reserved=",fh);
if ((rpacket.stat[2] & 64)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Reserved=",fh);
if ((rpacket.stat[2] & 128)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputc(toascii(0X0A),fh);

fputs("[State of the keys]",fh);
fputc(toascii(0X0A),fh);
fputs("AutoCut selected=",fh);
if ((rpacket.stat[3] & 1)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Not in use=",fh);
if ((rpacket.stat[3] & 2)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Transparent display=",fh);
if ((rpacket.stat[3] & 4)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Baud rate is set=",fh);
if ((rpacket.stat[3] & 8)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Not in use=",fh);
if ((rpacket.stat[3] & 16)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Not in use=",fh);
if ((rpacket.stat[3] & 32)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Reserved=",fh);
if ((rpacket.stat[3] & 64)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Reserved=",fh);
if ((rpacket.stat[3] & 128)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputc(toascii(0X0A),fh);

fputs("[For the fiscal memory]",fh);
fputc(toascii(0X0A),fh);
fputs("Error in fiscal memory=",fh);
if ((rpacket.stat[4] & 1)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Not in use=",fh);
if ((rpacket.stat[4] & 2)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("No fiscal module=",fh);
if ((rpacket.stat[4] & 4)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Less then 50 closure left=",fh);
if ((rpacket.stat[4] & 8)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Fiscal mem full=",fh);
if ((rpacket.stat[4] & 16)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("General fiscal error=",fh);
if ((rpacket.stat[4] & 32)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Reserved=",fh);
if ((rpacket.stat[4] & 64)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Reserved=",fh);
if ((rpacket.stat[4] & 128)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputc(toascii(0X0A),fh);

fputs("[For the fiscal memory]",fh);
fputc(toascii(0X0A),fh);
fputs("Fiscal memory read-only=",fh);
if ((rpacket.stat[5] & 1)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Fiscal memory formatted=",fh);
if ((rpacket.stat[5] & 2)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Not in use=",fh);
if ((rpacket.stat[5] & 4)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Device fiscalized=",fh);
if ((rpacket.stat[5] & 8)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("More than 0 tax rated programmed=",fh);
if ((rpacket.stat[5] & 16)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Serial and fiscal programmed=",fh);
if ((rpacket.stat[5] & 32)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Reserved=",fh);
if ((rpacket.stat[5] & 64)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputs("Reserved=",fh);
if ((rpacket.stat[5] & 128)!=0) fputc('1',fh); else fputc('0',fh);
fputc(toascii(0X0A),fh);
fputc(toascii(0X0A),fh);

fputs("Bytes:",fh);
fputc(rpacket.stat[0],fh);
fputc(rpacket.stat[1],fh);
fputc(rpacket.stat[2],fh);
fputc(rpacket.stat[3],fh);
fputc(rpacket.stat[4],fh);
fputc(rpacket.stat[5],fh);
fclose(fh);
}

void TranslateInput (int fd, char *infile)
{
FILE *fh;
int l,i;
char buffer[65535];
char procline[255];
char params[255];
char s[255];
unsigned char seq=2;

strcpy(s,infile);
strcat(s,Initialize.output);
remove(s);
strcpy(s,infile);
strcat(s,Initialize.status);
remove(s);

if (Initialize.debug[0]='1') puts("Opening input file...");
if ((fh  = fopen( infile, "r" )) == NULL ) {printf( "The file 'input' was not opened\n" ); exit(0);}
while (fgets(procline,255,fh)!=NULL)
{
if (Initialize.debug[0]='1') puts("Process commands...");
if (strlen(procline)<2) puts("Command too short");
l=strlen(procline)-3;
for (i=2;i<strlen(procline)-1;i++) params[i-2]=procline[i]; params[i-2]=0;

if (strncmp(procline,"GT",2)==0) //Get time
{
if (Initialize.debug[0]='1') puts("Get Time");
SendForm(fd,seq,62,params);
GetForm(fd);
AddToOutput(infile);
seq++;
}

if (strncmp(procline,"NP",2)==0) //NonFiscal Print
{
if (Initialize.debug[0]='1') puts("Nonfiscal receipt");
SendForm(fd,seq,38,"");
GetForm(fd);
AddToOutput(infile);
SendForm(fd,seq,42,params);
GetForm(fd);
SendForm(fd,seq,39,"");
GetForm(fd);
seq++;
}

if (strncmp(procline,"DA",2)==0) //Define article
{
if (Initialize.debug[0]='1') puts("Define Article");
strcpy(s,"P");
if (params[0]='1') params[0]=0xC0;
if (params[0]='2') params[0]=0xC3;
if (params[0]='3') params[0]=0xC4;
if (params[0]='4') params[0]=0x80;
if (params[0]='5') params[0]=0xC5;
if (params[0]='6') params[0]=0xC6;
if (params[0]='7') params[0]=0xC8;
if (params[0]='8') params[0]=0xa3;
if (params[0]='9') params[0]=0xCA;

strcat(s,params);

//if (params[0]='1') strcat(s,toascii(0xC0));
//if (params[0]='2') strcat(s,toascii(0xC3));
//if (params[0]='3') strcat(s,toascii(0xC4));
//if (params[0]='4') strcat(s,toascii(0x80));
//if (params[0]='5') strcat(s,toascii(0xC5));
//if (params[0]='6') strcat(s,toascii(0xC6));
//if (params[0]='7') strcat(s,toascii(0xC8));
//if (params[0]='8') strcat(s,toascii(0xA3));
//if (params[0]='9') strcat(s,toascii(0xCA));

//strcpy(s,"PĀ1,100,Test");

SendForm(fd,seq,107,s);
GetForm(fd);
AddToOutput(infile);
seq++;
}

if (strncmp(procline,"DI",2)==0) //Diagnostic Info (Print)
{
if (Initialize.debug[0]='1') puts("Diagnostic Info");
SendForm(fd,seq,71,"");
GetForm(fd);
AddToOutput(infile);
seq++;
}

if (strncmp(procline,"GS",2)==0) //Get Statistics
{
if (Initialize.debug[0]='1') puts("Get Statistics");
SendForm(fd,seq,67,"");
GetForm(fd);
AddToOutput(infile);
seq++;
}

if (strncmp(procline,"PY",2)==0) //Payement
{
if (Initialize.debug[0]='1') puts("Payement");
SendForm(fd,seq,53,params);
GetForm(fd);
AddToOutput(infile);
seq++;

SendForm(fd,seq,56,"");
GetForm(fd);
seq++;
}

if (strncmp(procline,"SA",2)==0) //Sell Article
{
if (Initialize.debug[0]='1') puts("Sell Article");
SendForm(fd,seq,48,"1;1,1");
GetForm(fd);
AddToOutput(infile);
seq++;

strcpy(s,"S+");
strcat(s,params);
strcpy(params,s);
SendForm(fd,seq,52,params);
GetForm(fd);
seq++;

}

if (strncmp(procline,"DU",2)==0) //Display Upper
{
if (Initialize.debug[0]='1') puts("Display Upper");
SendForm(fd,seq,47,params);
GetForm(fd);
AddToOutput(infile);
seq++;
}

if (strncmp(procline,"DL",2)==0) //Display Lower
{
if (Initialize.debug[0]='1') puts("Display Lower");
SendForm(fd,seq,35,params);
GetForm(fd);
AddToOutput(infile);
seq++;
}

if (strncmp(procline,"DD",2)==0) //Display Date & Time
{
if (Initialize.debug[0]='1') puts("Display Date & Time");
SendForm(fd,seq,63,"");
GetForm(fd);
AddToOutput(infile);
seq++;
}

if (strncmp(procline,"DC",2)==0) //Display Clear
{
if (Initialize.debug[0]='1') puts("Display Clear");
SendForm(fd,seq,33,params);
GetForm(fd);
AddToOutput(infile);
seq++;
}

if (strncmp(procline,"SH",2)==0) //Set Header and Footer
{
if (Initialize.debug[0]='1') puts("Set Header and Footer");
SendForm(fd,seq,43,params);
GetForm(fd);
AddToOutput(infile);
seq++;
}

if (strncmp(procline,"PF",2)==0) //Paper Feed
{
if (Initialize.debug[0]='1') puts("Paper Feed");
SendForm(fd,seq,44,params);
GetForm(fd);
AddToOutput(infile);
seq++;
}

} //end of read

fclose(fh);
} //end of translate

void main(int argc, char *argv[])
{
  int fd,c, n;
  char *str;

  puts("Unix Fiscal Print v1.0b, Galeb Group 2003.");
  
/* GLOBAL SETTINGS */

  puts("Init...");
  initialization();

// read the user input

  if (argc<2) {puts("No parameters");exit(0);}
  if (strlen(argv[1])==0) {puts("You must specify input file");exit(0);}
  if (Initialize.debug[0]='1') puts(argv[1]);

  /* COMMUNICATION */

  if (Initialize.debug[0]='1') puts("Opening port...");
  if (Initialize.debug[0]='1') puts(Initialize.port);
  fd=OpenSerial(Initialize.port);
  if (fd<0) {puts("Error in accessing serial device");exit(0);}
  if (Initialize.debug[0]='1') puts("Translate input");
  TranslateInput(fd,argv[1]);
  CloseSerial(fd);
}