Changeset 550 for trunk/Modules/FinanceBankAPI/FioAPI.php

Timestamp:

Jul 7, 2013, 7:37:48 PM (11 years ago)

Author:

chronos

Message:

• Upraveno: Přepracována třída pro import plateb přes Fio API. Nyní se načítají položky přes CSV formát.
• Přidáno: Import z Fio do tabulky FinanceBankImport a odsud pak pokud je nalezen variabilní symbol tak do FinanceOperation.

File:

• trunk/Modules/FinanceBankAPI/FioAPI.php (modified) (3 diffs)

trunk/Modules/FinanceBankAPI/FioAPI.php

@@ -4 +4 @@
 
 include('GPC.php');
+
+function RemoveComma($Text)
+{
+  if((mb_strlen($Text) >= 2) and ($Text[0] == '"') and (mb_substr($Text, -1, 1) == '"')) return(mb_substr($Text, 1, -1));
+    else return($Text);
+}
  
 class FioAPI
@@ -9 +15 @@
   var $Token;
   var $Encoding;
+  var $Format;
   
   function __construct()
   {
     $this->Encoding = 'utf-8';
+    $this->Format = 'csv';
   }
  
@@ -20 +28 @@
  
     // URL format: https://www.fio.cz/ib_api/rest/periods/{token}/{datum od}/{datum do}/transactions.{format}
-    echo('1');
-    $fp = fsockopen('ssl://www.fio.cz', 443, $errno, $errstr, 30);
-    echo('2');
-    if(!$fp) 
+    // Send request
+    $RequestURL = '/ib_api/rest/periods/'.$this->Token.'/'.
+      date('Y-m-d', $TimeFrom).'/'.date('Y-m-d', $TimeTo).'/transactions.'.$this->Format;
+    echo($RequestURL);
+    $Response = file_get_contents('https://www.fio.cz'.$RequestURL);
+    if($Response == FALSE) 
     {
-      throw new Exception('Connection error: '.$errstr);
+      throw new Exception('Connection error');
     } else 
     {
-      // Send request
-      $RequestURL = '/ib_api/rest/periods/'.$this->Token.'/'.
-        date('Y-m-d', $TimeFrom).'/'.date('Y-m-d', $TimeTo).'/transactions.gpc';
-      $Request = "GET ".$RequestURL." HTTP/1.1\r\n";
-      $Request .= "Host: www.fio.cz\r\n";
-      $Request .= "User-Agent: PHP Script\r\n";
-      $Request .= "Content-Type: text/html\r\n";
-      $Request .= "Connection: Close\r\n\r\n";
-      fwrite($fp, $Request);
- 
-      // Read response
-      echo('3');
-      $Response = array();
-      while(!feof($fp)) 
-        $Response .= trim(fgets($fp, 1024))."\n";
-      fclose($fp);      
-      echo('4');
-      $Response = iconv('windows-1250', $this->Encoding, $Response);
+      echo($Response);
+      if($this->Format == 'gpc') $Response = iconv('windows-1250', $this->Encoding, $Response);
       $Response = explode("\n", $Response);
- 
-      // Strip HTTP header
-      while($Response[0] != '') array_shift($Response);
-      array_shift($Response); // Remove empty line
-      //echo(implode("\n", $Response));
- 
-      // Parse all GPC lines
-      $GPC = new GPC();
-      $Result = array();
-      foreach($Response as $Index => $Line)
+      
+      if($this->Format == 'gpc')
+      {       
+        // Parse all GPC lines
+        $GPC = new GPC();
+        $Result = array();
+        foreach($Response as $Index => $Line)
+        {
+          if(($Index == 0) and (substr($Line, 0, strlen(GPC_TYPE_REPORT)) != GPC_TYPE_REPORT)) $this->NoValidDataError($Response);
+          $GPCLine = $GPC->ParseLine($Line);
+          if($GPCLine != NULL) $Result[] = $GPCLine;
+        }
+      } else
+      if($this->Format == 'csv')
       {
-        if(($Index == 0) and (substr($Line, 0, strlen(GPC_TYPE_REPORT)) != GPC_TYPE_REPORT)) $this->NoValidDataError($Response);
-        $GPCLine = $GPC->ParseLine($Line);
-        if($GPCLine != NULL) $Result[] = $GPCLine;
+        $Result = array(
+          'Items' => array(),
+        );
+        
+        // CVS header
+        while($Response[0] != '') 
+        {
+          $Line = explode(';', $Response[0]);
+          if($Line[0] == 'accountId') $Result['AccountNumber'] = $Line[0];
+          else if($Line[0] == 'bankId') $Result['BankId'] = $Line[0]; 
+          else if($Line[0] == 'currency') $Result['Currency'] = $Line[0];
+          else if($Line[0] == 'iban') $Result['IBAN'] = $Line[0];
+          else if($Line[0] == 'bic') $Result['BIC'] = $Line[0];
+          else if($Line[0] == 'openingBalance') $Result['OpeningBalance'] = $Line[0];
+          else if($Line[0] == 'closingBalance') $Result['ClosingBalance'] = $Line[0];
+          else if($Line[0] == 'dateStart') $Result['DateStart'] = $Line[0];
+          else if($Line[0] == 'dateEnd') $Result['DateEnd'] = $Line[0];
+          else if($Line[0] == 'idFrom') $Result['IdFrom'] = $Line[0];
+          else if($Line[0] == 'idTo') $Result['IdTo'] = $Line[0];            
+          array_shift($Response);
+        }
+        array_shift($Response); // Remove empty line
+
+        if($Response[0] != 'ID pohybu;Datum;Objem;Měna;Protiúčet;Název protiúčtu;Kód banky;Název banky;KS;VS;SS;Uživatelská identifikace;Zpráva pro příjemce;Typ;Provedl;Upřesnění;Komentář;BIC;ID pokynu'
+          ) throw new Exception('Unsupported CSV header');
+        array_shift($Response);
+        array_pop($Response);
+        foreach($Response as $Index => $Line)
+        {
+          $Line = explode(';', $Line);
+          $Date = explode('.', $Line[1]);
+          $Date = mktime(0, 0, 0, $Date[1], $Date[0], $Date[2]);
+          $NewRecord = array('ID' => $Line[0], 'Date' => $Date, 'Value' => $Line[2], 'CurrencyCode' => $Line[3], 
+            'OffsetAccount' => $Line[4], 'OffsetAccountName' => $Line[5], 'BankCode' => $Line[6], 'BankName' => RemoveComma($Line[7]),
+            'ConstantSymbol' => $Line[8], 'VariableSymbol' => $Line[9], 'SpecificSymbol' => $Line[10],
+            'UserIdent' => RemoveComma($Line[11]), 'Message' => RemoveComma($Line[12]), 'Type' => RemoveComma($Line[13]), 
+            'User' => RemoveComma($Line[14]), 'Details' => RemoveComma($Line[15]), 'Comment' => RemoveComma($Line[16]), 
+            'BIC' => $Line[17], 'OrderID' => $Line[18]);
+          $Result['Items'][] = $NewRecord;          
+        }
       }
       return($Result);