На 5 странице этой ветки автор опубликовал реквизиты для помощи, я уже отметился, рекомендую всем морально и материально поддержать автораneiks писал(а):Хорошая идея, я даже готов материально немножко помочь.
urfaclient на php
Ага, кажется нашел багу в либе. Или в самом URFA. Но скорее в либе.
Выглядит оно следующим образом - вызываю функцию 3018, возвращается код 0. Затем вызываю функцию 3019, возвращается код 3018 - т.е. оно читает из сокета ответ на _предыдущий_ запрос.
Пока что пофиксил ТРЕМЯ последовательными вызовами функции - в третий раз оно проходит. Но вообще надо это посмотреть более внимательно
. Да - и хорошо бы сделать опцию отключения диагностических сообщений, типа noecho() и echoon(), которые включают-выключают сообщения о ошибках .
Выглядит оно следующим образом - вызываю функцию 3018, возвращается код 0. Затем вызываю функцию 3019, возвращается код 3018 - т.е. оно читает из сокета ответ на _предыдущий_ запрос.
Пока что пофиксил ТРЕМЯ последовательными вызовами функции - в третий раз оно проходит. Но вообще надо это посмотреть более внимательно
. Да - и хорошо бы сделать опцию отключения диагностических сообщений, типа noecho() и echoon(), которые включают-выключают сообщения о ошибках .
Последний раз редактировалось hcube Пт фев 13, 2009 11:05, всего редактировалось 1 раз.
Выложи код обоих функций, или мне на почту.hcube писал(а):Ага, кажется нашел багу в либе. Или в самом URFA. Но скорее в либе.
Выглядит оно следующим образом - вызываю функцию 3018, возвращается код 0. Затем вызываю функцию 3019, возвращается код 3018 - т.е. оно читает из сокета ответ на _прыдыдущий_ запрос.
Пока что пофиксил ТРЕМЯ последовательными вызовами функции - третий раз оно проходит, но вообще надо это посмотреть более внимательно
Код: Выделить всё
function urfa_call($code)
{
global $socket;
$packet = new Packet();
$packet->clean();
$packet->code=201;
$packet->AttrSetInt($code,3);
$packet->write($socket);
if (!feof($socket))
{
// for($i=0;$i<1000000;$i++); // задержка на чтение из сокета.
$packet->clean();
$packet->read($socket);
echo "read : ".$packet->code." -> [".dechex($packet->AttrGetInt(3))."] vs [".dechex($code)."]";
switch ($packet->code)
{
case 200:
if ($packet->AttrGetInt(3)==$code)
return TRUE;
else
return FALSE;
}
}
unset($packet);
}А вот что происходит при последовательных вызовах
Unlink tariff : 4
read : 200 -> [0] vs [3019]
Error calling function rpcf_unlink_user_tariff
Link tariff : 4
read : 200 -> [3019] vs [3018]
Error calling function rpcf_link_user_tariff
read : 200 -> [0] vs [3018]
Error calling function rpcf_link_user_tariff
read : 200 -> [3018] vs [3018]
У меня есть вот какая мысль - вместо однократного чтения, сделать чтение сокета _пока_ не будет прочитано нужное значение, либо не исчерпан счетчик чтений. У меня такое ощущение, что в PHP может дурить функция работы с сокетами - которая feof($socket)) - т.е. она может выдать, что сокет непуст, когда реально данные туда еще не положились. Особенно в случае 4-байтных значений.
Код: Выделить всё
function rpcf_link_user_tariff($user_id,$account_id=0,$tariff_current,$tariff_next=tariff_current,$discount_period_id,$tariff_link_id=0) { //0x3018
$ret=array();
if (!urfa_call(0x3018)) {
print "Error calling function ". __FUNCTION__ ."\n";
return FALSE;
}
$packet = new Packet();
$packet->DataSetInt($user_id);
$packet->DataSetInt($account_id);
$packet->DataSetInt($tariff_current);
$packet->DataSetInt($tariff_next);
$packet->DataSetInt($discount_period_id);
$packet->DataSetInt($tariff_link_id);
urfa_send_param($packet);
if ($x = urfa_get_data()) {
$ret['tariff_link_id']=$x->DataGetInt();
urfa_get_data();
}
return $ret;
}
function rpcf_unlink_user_tariff($user_id,$account_id=0,$tariff_link_id=0)
{ //0x3019
$ret=array();
if (!urfa_call(0x3019)) {
print "Error calling function ". __FUNCTION__ ."\n";
return FALSE;
}
$packet = new Packet();
$packet->DataSetInt($user_id);
$packet->DataSetInt($account_id);
$packet->DataSetInt($tariff_link_id);
urfa_send_param($packet);
return $ret;
}Я думаю, что лучше вместо feof() использовать вот этот конструкт, и сравнение производить только тогда, когда приняты _два_ байта и они реально есть в буфере.
array stream_get_meta_data ( resource $stream )
Проверил... не, не то. Оно проверяет байты уже в PHP буфере, и просто зависает, если сделать ожидание наличия двух байтов. Так что возвращаясь к плану А - можно сделать просто ожидание нужного значения.
Модифицировал функцию вот таким образом :
Со второго раза оно получает правильное значение и дальше вроде нормально пашет. А иногда - с первого раза получает. Но это конечно не дело
Код: Выделить всё
function urfa_call($code)
{
global $socket;
$packet = new Packet();
$packet->clean();
$packet->code=201;
$packet->AttrSetInt($code,3);
$packet->write($socket);
if (!feof($socket))
{
$packet->clean();
$packet->read($socket);
echo "\nread : ".$packet->code." -> [".dechex($packet->AttrGetInt(3))."] vs [".dechex($code)."]";
while($packet->AttrGetInt(3) != $code)
{
$packet->read($socket);
echo "\nread : ".$packet->code." -> [".dechex($packet->AttrGetInt(3))."] vs [".dechex($code)."]";
}
switch ($packet->code)
{
case 200:
if ($packet->AttrGetInt(3)==$code)
return TRUE;
else
return FALSE;
}
}
unset($packet);
}AttrGetInt здесь должен быть только один вызов, а то индекс сбивается. Попробуй так если хочешь посмотреть что за код возвращается через переменную $ca здесь.
Код: Выделить всё
function urfa_call($code)
{
global $socket;
$packet = new Packet();
$packet->clean();
$packet->code=201;
$packet->AttrSetInt($code,3);
$packet->write($socket);
if (!feof($socket))
{
// for($i=0;$i<1000000;$i++); // задержка на чтение из сокета.
$packet->clean();
$packet->read($socket);
$ca = $packet->AttrGetInt(3);
echo "read : ".$packet->code." -> [".dechex($ca)."] vs [".dechex($code)."]";
// echo "read : ".$packet->code." -> [".dechex($packet->AttrGetInt(3))."] vs [".dechex($code)."]";
switch ($packet->code)
{
case 200:
if ($ca==$code)
return TRUE;
else
return FALSE;
}
}
unset($packet);
}Добавил в http://wiki.flintnet.ru/ юзерские функции и все функции которые нашел в этой теме.
Не-а. В том-то и дело, что проходит только _второе_ чтение из сокета. По первому читается или ноль, или предыдущий результат, а вот по второму - корректный код, и именно это чтение как раз синхронизирует обмен с URFA по фазе. Не знаю, почему - по идее должен был бы код читаться сразу. Ан нет. Может быть дело в том, что URFA сервис на загруженном серваке чуть подтормаживает после посылки запроса - незаметно для глаза, но достаточно для PHP скрипта.
И - AttrGetInt получает данные из УЖЕ прочитанного пакета. Сам факт чтения происходит по операции $packet->read($socket), а после нее уже можно как угодно из этого пакета читать числа.
Операция unpack() работает с уже полученными данными, не с сокетом. Поэтому ее можно запросто вызывать повторно.
И - AttrGetInt получает данные из УЖЕ прочитанного пакета. Сам факт чтения происходит по операции $packet->read($socket), а после нее уже можно как угодно из этого пакета читать числа.
Код: Выделить всё
function AttrGetInt($code)
{
if (isset($this->attr[$code]['data']))
{
$x = unpack("N",$this->attr[$code]['data']);
return $x[1];
}
else
return FALSE;
}Это некорректно составлены функции.
Не работает потому что не хватает вызовов $packet->urfa_get_data()
Поэтому и переписал urfa_get_data() чтобы одним вызовом все из сокета забиралось.
Попробуй так:
Не работает потому что не хватает вызовов $packet->urfa_get_data()
Поэтому и переписал urfa_get_data() чтобы одним вызовом все из сокета забиралось.
Попробуй так:
Код: Выделить всё
function rpcf_link_user_tariff($user_id,$account_id=0,$tariff_current,$tariff_next=tariff_current,$discount_period_id,$tariff_link_id=0) { //0x3018
$ret=array();
if (!urfa_call(0x3018)) {
print "Error calling function ". __FUNCTION__ ."\n";
return FALSE;
}
$packet = new Packet();
$packet->DataSetInt($user_id);
$packet->DataSetInt($account_id);
$packet->DataSetInt($tariff_current);
$packet->DataSetInt($tariff_next);
$packet->DataSetInt($discount_period_id);
$packet->DataSetInt($tariff_link_id);
urfa_send_param($packet);
if ($x = urfa_get_data()) {
$ret['tariff_link_id']=$x->DataGetInt();
}
urfa_get_data(); // Для старой версии urfa_get_data
return $ret;
}
function rpcf_unlink_user_tariff($user_id,$account_id=0,$tariff_link_id=0)
{ //0x3019
$ret=array();
if (!urfa_call(0x3019)) {
print "Error calling function ". __FUNCTION__ ."\n";
return FALSE;
}
$packet = new Packet();
$packet->DataSetInt($user_id);
$packet->DataSetInt($account_id);
$packet->DataSetInt($tariff_link_id);
urfa_send_param($packet);
urfa_get_data(); // Для старой версии urfa_get_data
return $ret;
}Намучался с перехватом ексепшинов (не хотят они нормально работать, хоть ты тресни), сделал небольшую модификацию.
В URFAClient_Connection.php ввел переменную $error='' , сделал обработку ошибок коннекта и логина.
В URFAClient.php :
Теперь перехватывает ошибки коннекта и логина на 100% :
В силу своих ограниченных знаний php возможно криво, но главное работает как часы.
В URFAClient_Connection.php ввел переменную $error='' , сделал обработку ошибок коннекта и логина.
Код: Выделить всё
class URFAClient_Connection
{
private $socket = null;
public $error = ''; // Для возврата ошибки
function __construct($address, $port, $login, $pass, $ssl = true)
{
if ($address && $port && $login) {
if (!$this->open($address, $port)) {
$this->error = 'connect error';
return false;
}
if (!$this->login($login, $pass, $ssl)) {
$this->error = 'login error';
}
}
}
function open($address, $port)
{
$context = stream_context_create(array('ssl' => array('ciphers'=> "ADH-RC4-MD5",)));
$address = gethostbyname($address);
$this->socket = stream_socket_client("tcp://$address:$port", $errno, $errstr, 30, STREAM_CLIENT_CONNECT, $context);
return !empty($this->socket); // Для возврата ошибки
}
....
Код: Выделить всё
abstract class URFAClient
{
/**
* @var URFAClient_Connection
*/
protected $connection = null;
protected $address;
protected $port;
public function __construct($login, $pass, $address = "127.0.0.1", $port = "11758", $ssl = false)
{
$this->address = $address;
$this->port = $port;
$this->connection = new URFAClient_Connection($address, $port, $login, $pass, $ssl);
$this->error = $this->connection->error;
}
}
Код: Выделить всё
$urfa_user5 = new URFAClient_User5($login, $password, "127.0.0.1", "11758",false);
if ($urfa_user5->error<>'') {
exit($urfa_user5->error);
}
Код: Выделить всё
function rpcf_get_users_list($from,$to,$card_user=0) { //0x2001
$ret=array();
if (!$this->connection->urfa_call(0x2001)) {
print "Error calling function ". __FUNCTION__ ."\n";
return FALSE;
}
$packet = $this->connection->getPacket();
$packet->DataSetInt($from);
$packet->DataSetInt($to);
$packet->DataSetInt($card_user);
$this->connection->urfa_send_param($packet);
if($x = $this->connection->urfa_get_data()){
$count=$x->DataGetInt();
$ret['count']=$count;
for ($i=0;$i<$count;$i++) {
$users['user_id']=$x->DataGetInt();
$users['login']=$x->DataGetString();
$users['basic_account']=$x->DataGetInt();
$users['full_name']=$x->DataGetString();
$users['is_blocked']=$x->DataGetInt();
$users['balance']=$x->DataGetDouble();
$ip_adr_size=$x->DataGetInt();
$users['ip_adr_size']=$ip_adr_size;
$ipgroup=array();
for ($j=0;$j<$ip_adr_size;$j++) {
$group_size=$x->DataGetInt();
$ipgroup['group_size']=$group_size;
$ips=array();
for ($k=0;$k<$group_size;$k++) {
$ips['ip_address']=$x->DataGetIPAddress();
$ips['mask']=$x->DataGetIPAddress();
$ips['group_type']=$x->DataGetInt();
$ipgroup['ips'][]=$ips;
}
$users['ipgroup']=$ipgroup;
}
$users['user_int_status']=$x->DataGetInt();
$ret['users'][]=$users;
}
}
return $ret;
}Если есть ошибки - просьба сообщить.