<?php
function historyPZM($last_id = 0)
{
if ($last_id) {
$url = 'http://localhost:8888/history?fromid=' . $last_id;
} else {
$url = 'http://localhost:8888/history';
}
$page = '';
$result = get_web_page($url);
if (($result['errno'] != 0) || ($result['http_code'] != 200)) {
$error = $result['errmsg'];
} else {
$page = $result['content'];
}
$array_new = array();
$xcmorewrite = explode("\n", str_replace("\r", '', $page));
foreach ($xcmorewrite as $value) {
if ($value) {
$array_new[] = explode(";", $value);
}
}
return $array_new;
}
?>
<?php
function get_web_page($url)
{
$uagent = "Opera/9.80 (Windows NT 6.1; WOW64) Presto/2.12.388 Version/12.14";
$ch = curl_init($url);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); // recupera a página da web
curl_setopt($ch, CURLOPT_HEADER, 0); // não recupera cabeçalhos
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1); // siga redirecionamentos
curl_setopt($ch, CURLOPT_ENCODING, ""); // lida com todas as codificações
curl_setopt($ch, CURLOPT_USERAGENT, $uagent); // agente de usuário
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 20);// tempo limite da conexão
curl_setopt($ch, CURLOPT_TIMEOUT, 20); // tempo limite da resposta
curl_setopt($ch, CURLOPT_MAXREDIRS, 2); // para após o 10o redirecionamento
$content = curl_exec($ch);
$err = curl_errno($ch);
$errmsg = curl_error($ch);
$header = curl_getinfo($ch);
curl_close($ch);
$header['errno'] = $err;
$header['errmsg'] = $errmsg;
$header['content'] = $content;
return $header;
}
?>
Você pode testá-lo através do console, por exemplo: curl http://localhost:8888/history
O exemplo do Cron-task script manipulador para receber novas transações e a estrutura da tabela
CREATE TABLE `pzm_history` (
`id` bigint(20) NOT NULL,
`tarif_id` int(1) NOT NULL,
`tr_id` varchar(255) NOT NULL,
`tr_date` varchar(255) NOT NULL,
`tr_timestamp` int(11) NOT NULL,
`pzm` varchar(50) NOT NULL,
`summa` decimal(16,2) NOT NULL,
`mess` varchar(255) NOT NULL,
`status` int(1) NOT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
* Todas as chaves necessárias e incremento automático de ID devem ser adicionados à tabela
Manipuladora:
<?php
$nomer = getLastPrmHistory();
$historys = historyPZM($nomer);
foreach ($historys as $item) {
if ($item['0'] != "No transactions!") {
// esta linha adiciona dados ao ‘pzm_history’ tabela usando INSERT IGNORE
PzmHistory::find()->insertIgnore([
'tr_id' => $item['0'],
'tr_date' => $item['1'],
'tr_timestamp' => $item['2'],
'pzm' => $item['3'],
'summa' => $item['4'],
'mess' => $item['5'],
'status' => 0
]);
}
}
function getLastPrmHistory()
{
// isso procura a última linha da tabela para obter o último ID das transações que estão na tabela
if (!empty($pzmHistory = PzmHistory::find()->orderBy('id', "DESC")->first())) {
return $pzmHistory->tr_id;
};
return 0;
}
?>
<?php
function destinationPZM($pzm)
{
$url = 'http://localhost:8888/publickey?destination=' . $pzm;
$page = '';
$result = get_web_page($url);
if (($result['errno'] != 0) || ($result['http_code'] != 200)) {
$error = $result['errmsg'];
return '';
} else {
$page = $result['content'];
$haystack = "Public key absent";
$haystack2 = "Send error!";
$pos = strripos($page, $haystack);
$pos2 = strripos($page, $haystack2);
if ($pos === false AND $pos2 === false) {
$xcmorewrite = explode(' ', $page);
$page = trim($xcmorewrite[0]);
return $page;
} else {
return '';
}
}
return $page;
}
?>
<?php
function getBalancePZM($pzm)
{
$ip = '*******'; // um exemplo 192.168.1.1:9976 com port
$url = 'http://'.$ip.'/prizm?requestType=getAccount&account=' . $pzm;
$page = '';
$result = get_web_page($url);
//print_r($result); die;
if (($result['errno'] != 0) || ($result['http_code'] != 200)) {
$error = $result['errmsg'];
return '';
} else {
$page = $result['content'];
$page = json_decode($page, true);
if ( isset($page['balanceNQT']) ) {
return $page['balanceNQT'] / 100;
} else {
return 0;
}
}
}
?>
<?php
public function payPZM($summa, $pzm, $public_key, $text)
{
$p2 = SENDKEY; // esta é a senha que você especificou durante a instalação
$return = false;
$url = 'http://localhost:8888/send?sendkey=' . $p2 . '&amount=' . $summa . '&comment=' . urlencode($text) . '&destination=' . $pzm . '&publickey=' . $public_key;
$page = '';
$result = get_web_page($url);
if (($result['errno'] != 0) || ($result['http_code'] != 200)) {
$error = $result['errmsg'];
} else {
$page = $result['content'];
}
if (preg_match('/^\+?\d+$/', $page)) {
$return = true;
} else {
$return = false;
}
return $return;
}
?>