/* Функции и структуры для работы с последовательным портом в ОС Windows */
/* для pmkcom v0.17 */

HANDLE hPort=NULL; 	/* Дескриптор порта,
создается при открытии и используется для всех операций с портом */
DCB dcb;   /* Device Control Block - установки, управляющие работой порта */
COMMTIMEOUTS cto;  /* Структура, задающая тайм-ауты последовательного порта */

int openport;	/* номер уже открытого порта, 0 - нет открытых */

long mkspeed=9600; // Текущая скорость обмена (для конкретной команды)

long mkport_speed=9600; // Установленная скорость обмена
int mkport_rinter=40; /*cto.ReadIntervalTimeout=40;
Максимальное время между чтением байт, мс */
int mkport_rinter9=40; /*cto.ReadIntervalTimeout=40;
Максимальное время между чтением байт, мс */
int mkport_rtconst=300; /* cto.ReadTotalTimeoutConstant=300;
Время ожидания начала приема, мс */
int mkport_rtconst9=300; /* cto.ReadTotalTimeoutConstant=300;
Время ожидания начала приема, мс */
int mkport_rtmult=0; /* cto.ReadTotalTimeoutMultiplier=0;
Множитель для вычисления общего времени чтения */
int mkport_rtmult9=0; /* cto.ReadTotalTimeoutMultiplier=0;
Множитель для вычисления общего времени чтения */
int mkport_wtconst=100; /* cto.WriteTotalTimeoutConstant=100;
Время ожидания начала записи, мс */
int mkport_wtconst9=100; /* cto.WriteTotalTimeoutConstant=100;
Время ожидания начала записи, мс */
int mkport_wtmult=10; /* cto.WriteTotalTimeoutMultiplier=10;
Множитель для вычисления общего времени записи, мс */
int mkport_wtmult9=10; /* cto.WriteTotalTimeoutMultiplier=10;
Множитель для вычисления общего времени записи, мс */

int mkport_popros=500; // период опроса, мс
int mkport_pwrite=400; // период записи, мс
int mkport_pwrite9=400; // период записи для 9600, мс
int mkport_pread=300; // период чтения, мс
int mkport_pread9=300; // период чтения для 9600, мс
/*--------------------*/


/* ----------------------------------------------------------------- ПОРТ */

/*-------------------------------------------- PORT OPEN */
int port_open(int ncom)
{
/* В WIN порт открывается и закрывается при любой команде
(для совместимости с USB-COM) */

int re=0;
int i;

maxlbuf=256;	// Реально в ЭВМ команды не больше 256 байт

/* Инициализация буферов */
for (i=0; i<maxlbuf; i++) {rbuf[i]=0; kbuf[i]=0; dbuf[i]=0;}

openport=0;	

return(re);
}

/*------------------------------------------- PORT SPEED ------------*/
int port_speed(long s)
{
/* установить скорость обмена */
mkspeed=s;
return(0);
}

/*------------------------------------------- CLOSE -------------------*/
int port_close(void)
{
int re=0;
/* В WIN порт открывается и закрывается при любой команде
для совместимости с USB-COM */

return(re);
}
/*--------------------------------------------------------------------*/


int kom_mtest(int n, int k, int z, int r, long len)
{
/* Используемые при вызове переменные
n - сетевой номер - должен быть от 0 до 255
k - соответствует коду типа пакета "K" протокола
    Для команд запроса данных - 0x10.
z,r - соответствуют кодам группы параметров "Z" и коду параметра "R", см. протокол.
	Определяют формат и назначение передаваемых данных или запрашиваемой величины.
len - длина передаваемых данных D1...DN из буфера dbuf.
    Для команд запроса данных - нуль.
*/
int re=0;	
/* Код возврата из функции 0 - OK, 256-выход по тайм-ауту, 257-ошибочная контрольная сумма или формат команды, 258 - последовательный порт не открыт или не обнаружен.
   1-255 коды ошибок, см. протокол.
*/
int i; // Вспомогательные переменные

int l,l1; // Вспомогательные переменные

char strPort[64]="\\\\.\\COM"; // Строка, используемая при открытии порта

char temp[32];	// буфер для преобразования чисел

DWORD d;	// переменная для подсчета реально переданных и принятых байт

float* f;	// для разбора принятого числа в формате float

	f_dd=0;			// обнулить флаг наличия данных в dd
	f_str=0;		// обнулить флаг наличия строки в str

/* Начало формирования команды в буфере kbuf[],
формат команды здесь подробно не рассматривается. См. в протоколе
*/
	
	kbuf[0]=0;	// адрес группы, для отдельного прибора равен нулю
	kbuf[1]=n%256;	// адрес (сетевой номер)
	kbuf[2]=(len+4)%256;		// длина пакета, мл. байт
	kbuf[3]=((len+4)/256)%256;	// длина пакета, ст. байт
	kbuf[4]=k%256;				// код типа пакета
	kbuf[5]=z%256;				// код группы параметров
	kbuf[6]=r%256;				// код параметра

/* Перенос передаваемых данных (если есть) */

	if (len!=0)
        {
        for (l=0; l<len; l++) kbuf[l+7]=dbuf[l];
        l1=len+7;
        }
        else l1=7;

/* Подсчет контрольной суммы */

	kbuf[l1]=0;
	for (l=0; l<l1; l++) {kbuf[l1]+=kbuf[l];
			              kbuf[l1]%=256;
		                  }

	lenkbuf=l1+1;
/* Команда сформирована в буфере kbuf[] - далее открытие порта */
	itoa(com+1,temp,10); /* Преобразование номера последовательного порта в строку */
	//strPort+=temp;     /* Добавление номера к существующей строке */
	strcat(strPort,temp);

/* v0.19 - если наименование порта задано в командной строке - использовать его */
	if (fportname[0]!=0) strncpy(strPort,fportname,62);


/* Открытие коммуникационного порта  для ввода - вывода */

	hPort=::CreateFile(strPort, GENERIC_READ|GENERIC_WRITE,0,
		NULL,OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL,NULL);
/*
Здесь:
hPort - дескриптор;
strPort - строка с наименованием порта COM1...COMX
*/

	if((hPort==INVALID_HANDLE_VALUE)||(hPort==NULL))
	{
	/* Если порт не открывается - выход с кодом ошибки 258 */
		openport=0;
		re=258;
		goto end;
		
	}

	openport=com;	// порт com успешно открыт

/* Установка параметров обмена */

	memset(&dcb,0,sizeof(dcb)); /* Выделение места в памяти */

	dcb.DCBlength=sizeof(dcb);

	switch (mkspeed)
		{ //v1.18
		case 600: dcb.BaudRate=CBR_600; break;
		case 1200: dcb.BaudRate=CBR_1200; break;
		case 2400: dcb.BaudRate=CBR_2400; break;
		case 4800: dcb.BaudRate=CBR_4800; break;
		case 9600: dcb.BaudRate=CBR_9600; break;
		case 14400: dcb.BaudRate=CBR_14400; break;
		case 19200: dcb.BaudRate=CBR_19200; break;
		case 38400: dcb.BaudRate=CBR_38400; break;
		case 56000: dcb.BaudRate=CBR_56000; break;
		case 57600: dcb.BaudRate=CBR_57600; break;
		default: dcb.BaudRate=CBR_9600;
		}

	/* 8 бит, 1 стоп бит, без контроля четности */
	dcb.ByteSize=8;dcb.Parity=0;dcb.StopBits=ONESTOPBIT;
	

	dcb.fBinary=TRUE; /* Обмен двоичными числами */
	dcb.fOutxCtsFlow=FALSE; /* Сигнал CTS не отслеживать */
	dcb.fOutxDsrFlow=FALSE; /* Сигнал DSR не отслеживать */
	dcb.fDtrControl=DTR_CONTROL_DISABLE; /* Контроль с помощью сигнала DTR запретить */
	dcb.fDsrSensitivity=FALSE; /* Сигнал DSR на коммуникационный драйвер не влияет */

	dcb.fOutX=FALSE; /* Управление выходным потоком символами XON/XOFF отключить */
	dcb.fInX=FALSE; /* Управление входным потоком символами XON/XOFF отключить */

	dcb.fErrorChar=FALSE; /* Ошибочные байты не заменять */
	dcb.fNull=FALSE; /* Нулевые байты не отбрасывать */
	dcb.fRtsControl=RTS_CONTROL_DISABLE; /* Запретить RTS */
	dcb.fAbortOnError=FALSE; /* Не прекращать ввод-вывод при ошибках */
	dcb.wReserved=0; /* Зарезервировано - должен быть 0 */

	
	::SetCommState(hPort,&dcb); /* Установить параметры порта с дескриптором hPort из структуры dcb */

	if (mkspeed==9600)
		{
		cto.ReadIntervalTimeout=mkport_rinter9; /* Максимальное время между чтением байт, мс (4)*/
		cto.ReadTotalTimeoutMultiplier=mkport_rtmult9; /* Множитель для вычисления общего времени чтения (0) */
		cto.ReadTotalTimeoutConstant=mkport_rtconst9; /* Время ожидания начала приема, мс v1.05=300 v<1.04=200 (300) */
		cto.WriteTotalTimeoutMultiplier=mkport_wtmult9; /* Множитель для вычисления общего времени записи, мс (10) */
		cto.WriteTotalTimeoutConstant=mkport_wtconst9; /* Время ожидания начала записи, мс (100) */
		}
		else
		{
		cto.ReadIntervalTimeout=mkport_rinter; /* Максимальное время между чтением байт, мс (4)*/
		cto.ReadTotalTimeoutMultiplier=mkport_rtmult; /* Множитель для вычисления общего времени чтения (0) */
		cto.ReadTotalTimeoutConstant=mkport_rtconst; /* Время ожидания начала приема, мс v1.05=300 v<1.04=200 (300) */
		cto.WriteTotalTimeoutMultiplier=mkport_wtmult; /* Множитель для вычисления общего времени записи, мс (10) */
		cto.WriteTotalTimeoutConstant=mkport_wtconst; /* Время ожидания начала записи, мс (100) */
		}

	::SetCommTimeouts(hPort,&cto); /* Установить тайм-ауты из структуры cto */

	::SetupComm(hPort,maxlbuf+8,maxlbuf+8); /* Очистить внутренние буферы порта и установить их длину maxbuf+8 байт */


for (i=0; i<maxlbuf; i++) rbuf[i]=0; /* Очистить входной буфер */

lenrbuf=0;

if((hPort!=INVALID_HANDLE_VALUE)&&(hPort!=NULL))
			{
			/* Если порт успешно открыт */
			/* Передать lenkbuf байт из буфера kbuf[] */
			::WriteFile(hPort,(LPVOID)kbuf,lenkbuf,&d,NULL);
			/* Прочитать заголовок пакета (4 байта) в буфер rbuf[] */
			::ReadFile(hPort,(LPVOID)rbuf,4,&d,NULL);
			/* Определить длину пакета */
			lenrbuf=rbuf[2]+256*rbuf[3];
			if ((lenrbuf>0)&&(lenrbuf<maxlbuf))
				{
				/* Прочитать пакет в буфер rbuf[] начиная с rbuf[4] */
				::ReadFile(hPort,(LPVOID)(rbuf+4),lenrbuf,&d,NULL);	
				}
			
			/* Закрыть порт */
			CloseHandle(hPort);
			openport=0;	
			}


/* Проверка количества принятых байт */
if (lenrbuf<=0) {re=256; goto end;}
lenrbuf+=4;	/* прибавить длину заголовка */

/* Проверка контрольной суммы принятого ответа */
l=0;
for (i=0; i<lenrbuf-1; i++) {l+=rbuf[i]; if (l>=256) l-=256;}

if (rbuf[lenrbuf-1]!=(BYTE)l) {re=257; goto end;}

/* Проверка формата команды - наличие в ответе обязательных полей */

if ((rbuf[0]!=0)||(rbuf[1]!=n)) {re=257; goto end;}

if ((rbuf[5]!=z) || (rbuf[6]!=r)) {re=257; goto end;}

if (rbuf[4]==0x40) {re=rbuf[7]; goto end;} /* принят пакет с сообщением об ошибке */

if ((z>=0x10)&&(r!=0)&&(lenrbuf==13))	
		{
		/* если был запрос числовой величины и длина пакета соответствует
		типу float, выполнить соответствующее преобразование и перенести
		принятые данные в глобальную переменную dd
		*/
		for (i=7; i<lenrbuf-1; i++) temp[i-7]=rbuf[i];
		f=(float*)temp;
		dd=(double)*f;
		f_dd=1;
		}


if ((z<0x10)&&(r==0)&&(lenrbuf>7))
			{
			/* при запросе байтовых данных заполнить строку mstr */
			for (i=7; i<lenrbuf-1; i++)
				{
				/* заменить непечатаемые символы пробелом и переместить конец строки
				*/
				if (rbuf[i]>=32) mstr[i-7]=(char)rbuf[i]; else mstr[i-7]=' ';	
				mstr[i-6]=0;	
				}
			f_str=1;
			}


end: return(re);	
}