freenetis-github/application/libraries/importers/Txt_Tatra_Banka_Statement_File_Importer.php @ 93fe8f1c
139add4b | jeffraska | <?php defined('SYSPATH') or die('No direct script access.');
|
|
/*
|
|||
* This file is part of open source system FreenetIS
|
|||
* and it is released under GPLv3 licence.
|
|||
*
|
|||
* More info about licence can be found:
|
|||
* http://www.gnu.org/licenses/gpl-3.0.html
|
|||
*
|
|||
* More info about project can be found:
|
|||
* http://www.freenetis.org/
|
|||
*
|
|||
*/
|
|||
require dirname(__FILE__) . '/Tatra_Banka_Statement_File_Importer.php';
|
|||
/**
|
|||
* Parser for Tatra banka E-mail statements
|
|||
*
|
|||
* @author David Raška
|
|||
*/
|
|||
class Txt_Tatra_Banka_Statement_File_Importer extends Tatra_Banka_Statement_File_Importer
|
|||
{
|
|||
3a27a556 | jeffraska | // Date, accout, amount
|
|
const REGEX_DATA = "@(\d{1,2}\.\d{1,2}\.\d{4} \d{1,2}:\d{2}).+(\w{2}\d{2}(\d{4})(\d{16})).* (\d+,\d{2}) (.+)\.@";
|
|||
// Counter account
|
|||
const REGEX_CA = "@ (\d{4})/([\d-]+)@";
|
|||
// Variable, specific, constant symbol
|
|||
const REGEX_SYMBOLS = "@/VS(\d*)/SS(\d*)/KS(\d*)@";
|
|||
// Current balance
|
|||
const REGEX_BALANCE = "@aktualny zostatok: (\d+,\d{2}) (.+)@";
|
|||
139add4b | jeffraska | protected function check_file_data_format()
|
|
{
|
|||
$emails = implode('', $this->get_file_data());
|
|||
// Date, account, amount
|
|||
3a27a556 | jeffraska | $match_data = preg_match_all(self::REGEX_DATA,
|
|
139add4b | jeffraska | $emails,
|
|
$m1);
|
|||
// Counter account
|
|||
3a27a556 | jeffraska | $match_counter = preg_match_all(self::REGEX_CA,
|
|
139add4b | jeffraska | $emails,
|
|
$m2);
|
|||
// Variable, specific, constant symbol
|
|||
3a27a556 | jeffraska | $match_symbols = preg_match_all(self::REGEX_SYMBOLS,
|
|
139add4b | jeffraska | $emails,
|
|
$m3);
|
|||
$accounts = array();
|
|||
foreach ($m1[2] as $e)
|
|||
{
|
|||
$accounts[] = $e;
|
|||
}
|
|||
2a3378d9 | jeffraska | if (count(array_unique($accounts)) > 1)
|
|
{
|
|||
$this->add_error(__('E-mails contains more than one destination account: %s', implode(', ', array_unique($accounts))), FALSE);
|
|||
}
|
|||
return ($match_data == $match_symbols) && ($match_symbols == $match_counter) && count(array_unique($accounts)) <= 1;
|
|||
139add4b | jeffraska | }
|
|
protected function get_header_data()
|
|||
{
|
|||
$emails = $this->get_file_data();
|
|||
2a3378d9 | jeffraska | unset ($emails[self::LAST_DOWNLOAD_SETTINGS_KEY]);
|
|
if (count($emails) == 0)
|
|||
{
|
|||
return NULL;
|
|||
}
|
|||
139add4b | jeffraska | // Newest e-mail
|
|
3a27a556 | jeffraska | preg_match(self::REGEX_DATA,
|
|
139add4b | jeffraska | $emails[0],
|
|
$mN);
|
|||
// Current balance
|
|||
3a27a556 | jeffraska | preg_match(self::REGEX_BALANCE,
|
|
139add4b | jeffraska | $emails[0],
|
|
$mC);
|
|||
// Oldest e-mail
|
|||
3a27a556 | jeffraska | preg_match(self::REGEX_DATA,
|
|
139add4b | jeffraska | $emails[count($emails) - 1],
|
|
$mO);
|
|||
$hd = new Header_Data(
|
|||
$mN[4], //account ID
|
|||
$mN[3] //bank ID
|
|||
);
|
|||
$hd->from = DateTime::createFromFormat('j.n.Y G:i', $mO[1])->format('Y-m-d H:i:s');
|
|||
$hd->to = DateTime::createFromFormat('j.n.Y G:i', $mN[1])->format('Y-m-d H:i:s');
|
|||
$hd->closingBalance = floatval(str_replace(',', '.', $mC[1]));
|
|||
return $hd;
|
|||
}
|
|||
protected function parse_file_data()
|
|||
{
|
|||
$emails = $this->get_file_data();
|
|||
2a3378d9 | jeffraska | $this->last_download_datetime = $emails[self::LAST_DOWNLOAD_SETTINGS_KEY];
|
|
139add4b | jeffraska | foreach ($emails as $email)
|
|
{
|
|||
3a27a556 | jeffraska | $match_data = preg_match(self::REGEX_DATA,
|
|
139add4b | jeffraska | $email,
|
|
$m1);
|
|||
3a27a556 | jeffraska | $match_counter = preg_match(self::REGEX_CA,
|
|
139add4b | jeffraska | $email,
|
|
$m2);
|
|||
3a27a556 | jeffraska | $match_symbols = preg_match(self::REGEX_SYMBOLS,
|
|
139add4b | jeffraska | $email,
|
|
$m3);
|
|||
if (!$match_data || !$match_symbols || !$match_counter)
|
|||
{
|
|||
continue;
|
|||
}
|
|||
$this->data[] = array(
|
|||
'datetime' => DateTime::createFromFormat('j.n.Y G:i', $m1[1])->format('Y-m-d H:i:s'),
|
|||
'iban' => $m1[2],
|
|||
'bank' => $m1[3],
|
|||
'account' => $m1[4],
|
|||
'amount' => floatval(str_replace(',', '.', $m1[5])),
|
|||
'counter_account'=> $m2[2],
|
|||
'counter_bank' => $m2[1],
|
|||
'currency' => $m1[6],
|
|||
'vs' => $m3[1],
|
|||
'ss' => $m3[2],
|
|||
'ks' => $m3[3]
|
|||
);
|
|||
}
|
|||
return TRUE;
|
|||
}
|
|||
protected function do_download(Bank_account_Model $bank_account,
|
|||
Bank_Account_Settings $settings, $url)
|
|||
{
|
|||
93fe8f1c | jeffraska | $key = self::LAST_DOWNLOAD_SETTINGS_KEY;
|
|
$last_download = $settings->$key;
|
|||
2a3378d9 | jeffraska | ||
if (empty($last_download))
|
|||
{
|
|||
$last_download = 0;
|
|||
}
|
|||
139add4b | jeffraska | $hostname = $settings->get_download_statement_url();
|
|
$inbox = @imap_open($hostname, $settings->imap_name, $settings->imap_password, OP_READONLY);
|
|||
$all_mails = array();
|
|||
if ($inbox === FALSE)
|
|||
{
|
|||
$m = __('Cannot connect to IMAP server');
|
|||
throw new Exception($m . ' (' . implode(" > ", imap_errors()) . ')');
|
|||
}
|
|||
a80ef9ce | jeffraska | if ($last_download > 0)
|
|
{
|
|||
$last_download_prev = $last_download - (60 * 60 * 24); // - 1 day
|
|||
$emails = imap_search($inbox, 'SINCE "'.date('j F Y', $last_download_prev).'"');
|
|||
}
|
|||
else
|
|||
{
|
|||
$emails = imap_search($inbox, 'ALL');
|
|||
}
|
|||
139add4b | jeffraska | ||
2a3378d9 | jeffraska | $first = TRUE;
|
|
$all_mails[self::LAST_DOWNLOAD_SETTINGS_KEY] = 0;
|
|||
139add4b | jeffraska | if ($emails)
|
|
{
|
|||
2a3378d9 | jeffraska | // Sort from newest mail
|
|
139add4b | jeffraska | rsort($emails);
|
|
foreach ($emails as $email_number)
|
|||
{
|
|||
$struct = imap_fetchstructure($inbox, $email_number);
|
|||
2a3378d9 | jeffraska | $header = imap_headerinfo($inbox, $email_number);
|
|
if ($first)
|
|||
{
|
|||
$all_mails[self::LAST_DOWNLOAD_SETTINGS_KEY] = $header->udate;
|
|||
$first = FALSE;
|
|||
}
|
|||
a80ef9ce | jeffraska | if (intval($header->udate) <= intval($last_download))
|
|
2a3378d9 | jeffraska | {
|
|
a80ef9ce | jeffraska | break;
|
|
2a3378d9 | jeffraska | }
|
|
139add4b | jeffraska | ||
$body = imap_fetchbody($inbox,$email_number, 1);
|
|||
$body = $this->decode_body($body, $struct);
|
|||
if ($body === FALSE)
|
|||
{
|
|||
continue;
|
|||
}
|
|||
3a27a556 | jeffraska | preg_match(self::REGEX_DATA,
|
|
139add4b | jeffraska | $body,
|
|
$m1);
|
|||
3a27a556 | jeffraska | preg_match(self::REGEX_CA,
|
|
139add4b | jeffraska | $body,
|
|
$m2);
|
|||
3a27a556 | jeffraska | preg_match(self::REGEX_SYMBOLS,
|
|
139add4b | jeffraska | $body,
|
|
$m3);
|
|||
if (!$m1 || !$m2 || !$m3)
|
|||
{
|
|||
continue;
|
|||
}
|
|||
a80ef9ce | jeffraska | array_unshift($all_mails, $body);
|
|
139add4b | jeffraska | }
|
|
}
|
|||
imap_close($inbox);
|
|||
return $all_mails;
|
|||
}
|
|||
protected function decode_body($body, $struct)
|
|||
{
|
|||
if ($struct->type == TYPETEXT) // text body
|
|||
{
|
|||
// Decode text
|
|||
switch ($struct->encoding)
|
|||
{
|
|||
case ENC7BIT:
|
|||
break;
|
|||
case ENC8BIT:
|
|||
break;
|
|||
case ENCBINARY:
|
|||
throw new Exception("Unsupported IMAP encoding: ENCBINARY");
|
|||
break;
|
|||
case ENCBASE64:
|
|||
$body = base64_decode($body);
|
|||
break;
|
|||
case ENCQUOTEDPRINTABLE:
|
|||
$body = quoted_printable_decode($body);
|
|||
break;
|
|||
case ENCOTHER:
|
|||
break;
|
|||
}
|
|||
// Convert text to UTF-8
|
|||
if (isset($struct->parameters))
|
|||
{
|
|||
foreach ($struct->parameters as $p)
|
|||
{
|
|||
if ($p->attribute == "charset")
|
|||
{
|
|||
$body = iconv($p->value, "UTF-8", $body);
|
|||
break;
|
|||
}
|
|||
}
|
|||
}
|
|||
}
|
|||
else if ($struct->type == TYPEMULTIPART) // multipart body
|
|||
{
|
|||
foreach ($struct->parts as $p)
|
|||
{
|
|||
if ($p->type == TYPETEXT)
|
|||
{
|
|||
$body = $this->decode_body($body, $p);
|
|||
break;
|
|||
}
|
|||
}
|
|||
}
|
|||
else
|
|||
{
|
|||
return FALSE;
|
|||
}
|
|||
return $body;
|
|||
}
|
|||
}
|