INT FUNCTION StartSerial(STRING sPort)    
	INT    hPort;    
	hPort = ComOpen(sPort, 0);
    IF hPort < 0 THEN
		Prompt("Nu s-a deschis portul: " + sPort);
		RETURN -1;    
	END
Prompt("Portul: " + sPort+ " a fost deschis.");	    
hPrt=hPort;
!TaskNew("SerialRead", hPrt, 0);
!TaskNew("SerialWrite", hPrt, 0);
!ComClose(hPort);
buf="A0"
sem=0;    
RETURN 1;
END

INT FUNCTION SerialClose(INT hPort)
	ComClose(hPort);
	Prompt("Portul a fost inchis."); 
	RETURN 0;
END 

INT FUNCTION SerialWrite(INT hPort, STRING buffer)    
    INT SerialWriteError;    
    INT length; 
     !WHILE 1 DO     
       	length=StrLength(buffer);     
		SerialWriteError = ComWrite(hPort, buffer, length, 2);        
		IF SerialWriteError THEN            
    		Prompt("Error Writing port");            
    		ComReset(hPort);
    		RETURN -1;        
    	END
    !END	      
	RETURN 0;
END 

INT FUNCTION SerialRead(INT hPort)
	STRING buffer      
	INT    length;    
	INT    total;    
	INT    SerialReadError;    
	total = 0;
	  !WHILE 1 DO
	  	length=20;              
		SerialReadError = ComRead(hPort, buffer, length, 0);
		IF SerialReadError THEN            
			Prompt("Eroare la citirea P S " + SerialReadError : ####);            
			ComReset(hPort);
			RETURN -1;         
		ELSE 
		    !Prompt(length : #### + " caractere citite de la P S " );           
			IF StrLength(buffer)>0 THEN
			  buf_r=buffer;
			  nr_r=StrLength(buffer);
			    Val_a0=StrToInt(StrTrim(StrMid( buffer,3,StrLength(buffer)-3)));
			END
		END
	!END	       
RETURN 0;
END

INT FUNCTION Achiz
IF k1=1 THEN
   IF sem = 1 THEN
     sem=0;
	 SerialRead(hPrt);
   	 SerialWrite(hPrt,"A0");
   ELSE
    sem=1;
    SerialRead(hPrt);
   END 
END
RETURN 0
END

FUNCTION connect_mysql()
	hSQL = SQLConnect("DSN=MySQL_citect");
	IF hSQL > -1 THEN
		mes="Conexiunea MySQL_citect realizata";
	ELSE
		mes="Eroare de conectoare MySQL_citect";
	END
END 

FUNCTION connect_mysql()
	hSQL = SQLConnect("DLG=1");
	IF hSQL > -1 THEN
		mes="Conexiunea MySQL_citect realizata";
	ELSE
		mes="Eroare de conectoare MySQL_citect";
	END
END 

FUNCTION  citesc_mysql()
	err1=SQLExec (hSQL, "SELECT * FROM ap_electr ");
	err2=SQLNext(hSQL);
	dn_ap = SQLGetField(hSQL, "den_ap");
	u_n = SQLGetField(hSQL, "tens_n");
END

FUNCTION next_mysql()
err3=SQLNext(hSQL);
	IF err_sel<>0 THEN
		mes="Nu exista inregistrare";
		u_n="0";
	ELSE
		mes = SQLGetField(hSQL, "den_ap");
		u_n = SQLGetField(hSQL, "tens_n");
	END
END