a12_scale.php

<?php

/*
 * Кантар A12 - изпраща по един пакет на ред, без индикация за стабилност:
 *
 * wn0000.00kg
 * wn0000.00kg
 * wn0003.18kg
 * wn0006.37kg
 * wn0009.16kg
 * wn0010.79kg
 * wn0011.70kg
 * wn0012.01kg
 * wn0012.00kg
 *
 * Стабилно състояние се приема при 2 последователни еднакви показания.
 *
**/

$tmpl = "<?xml version='1.0' encoding='UTF-8' ?>" .
	"<monitor>" .
	"<Devices>" .
	"<item>" .
	"<Name>D19</Name>" .
	"<Entries>" .
	"<item>" .
		"<Unit>KG</Unit>" .
		"<ID>20</ID>" .
		"<Value>[#0.000#]</Value>" . // UNSTABLE, NO_CONNECTION, PORT_BUSSY
		"<Name>ElectronicScale1</Name>" .
		"</item>" .
	"</Entries>" .
	"</item>" .
        "</Devices>" .
	"</monitor>";

//define ('DEVICE', '/dev/ttyUSB0');
define ('DEVICE', '/dev/ttyUSB0');
define ('READ_TIMEOUT', 3); // секунди

/**
 * Разбира един ред от кантара и връща теглото в килограми.
 *
 * @param string $line редът, както е прочетен от порта
 *
 * @return float|null теглото в кг или null, ако редът не е валиден пакет
 */
function parseScaleLine($line)
{
	$line = trim($line);
	if ($line === '') {

		return null;
	}

	// знак + число + мерна единица в края на реда; "wn0012.00kg" дава "0012.00kg"
	if (!preg_match('/([+-])?\s*([0-9]+(?:[.,][0-9]+)?)\s*(kg|g)?\s*$/i', $line, $m)) {

		return null;
	}

	$weight = (float) str_replace(',', '.', $m[2]);
	if (isset($m[1]) && $m[1] === '-') {
		$weight = -$weight;
	}

	if (isset($m[3]) && strtolower($m[3]) === 'g') {
		$weight /= 1000;
	}

	return $weight;
}

clearstatcache();
$fp = @fopen(DEVICE, 'r');

$err = null;
$weight = null;
$gotData = false;
$rawBytes = 0;

if ($fp === false) {
	$err = 'PORT_BUSSY';
} else {
	// четенето е блокиращо (както в standard_scale.php) - при неблокиращ режим
	// PHP вдига EOF флага на първото празно четене и порта "занемява" завинаги.
	// Таймаутът се пази със stream_select, а не с неблокиращ fread.
	stream_set_blocking($fp, true);

	$prev = null;
	$startTime = microtime(true);

	while ($weight === null && (microtime(true) - $startTime) < READ_TIMEOUT) {
		$read = array($fp);
		$write = $except = null;

		// false = устройството не е select()-able; тогава четем направо, блокиращо
		$ready = @stream_select($read, $write, $except, 1);
		if ($ready === 0) {

			continue;
		}

		$line = fgets($fp);
		if ($line === false || $line === '') {
			usleep(20000); // 20 ms, за да не върти процесора на 100%

			continue;
		}

		$rawBytes += strlen($line);

		$value = parseScaleLine($line);
		if ($value === null) {

			continue;
		}

		$gotData = true;
		$value = number_format($value, 3, '.', '');

		// стабилно = 2 последователни еднакви показания
		if ($prev === $value) {
			$weight = $value;

			break;
		}

		$prev = $value;
	}

	fclose($fp);

	if ($weight === null) {
		if (!$rawBytes) {
			$err = 'NO_CONNECTION'; // портът се отвори, но не дойде нито един байт
		} elseif (!$gotData) {
			$err = 'BAD_FORMAT';   // има байтове, но не се разпознават като пакет
		} else {
			$err = 'UNSTABLE';     // има пакети, но теглото не се успокои
		}
	}
}

$tmpl = str_replace('[#0.000#]', $err === null ? $weight : $err, $tmpl);