Importowanie billingu z AMS

SE/se-lib/Route/UrlAction/VoIPAmsImport.php

@@ -0,0 +1,193 @@
+<?php
+
+Lib::loadClass('RouteBase');
+Lib::loadClass('ProcesHelper');
+
+class Route_UrlAction_VoIPAmsImport extends RouteBase {
+
+	private $fields = [
+		"Data początkowa" => [
+			"name" => "date",
+			"regex" => "/^[[:digit:]]{4}(-[[:digit:]]{2}){2} [[:digit:]]{2}(:[[:digit:]]{2}){2}$/",
+			"sqlType" => "datetime",
+		],
+		"Numer abonenta" => [
+			"name" => "number",
+			"regex" => "/^[[:digit:]]{11}$/",
+			"sqlType" => "varchar(11)",
+		],
+		"Koszt netto" => [
+			"name" => "cost",
+			"regex" => "/^[[:digit:]]+,[[:digit:]]{2}$/",
+			"sqlType" => "decimal(10,2)",
+			"replace" => [
+				"from" => ",",
+				"to" => ".",
+			],
+		],
+	];
+
+	public function handleAuth() {
+		if (!User::logged()) {
+			throw new HttpException('Unauthorized', 401);
+		}
+	}
+
+	private function parseCsv($file) {
+		if (!file_exists($file)) Throw new Exception("CSV file error #1 - File not found.");
+		$csv = array_map(function ($line) {
+			return str_getcsv(trim($line), ";");
+		}, file($file));
+
+		array_walk($csv, function(&$a) use ($csv) {
+			if (count($csv[0]) != count($a)) throw new Exception("CSV file error #2 - Wrong fields count.");
+			$a = array_combine($csv[0], $a);
+		});
+		array_shift($csv);
+
+		$csv = array_filter($csv, function($a) {
+			if ($a['TG wych.'] != '27') return false;
+			if ($a['Koszt netto'] == '0,00') return false;
+			return true;
+		});
+
+		array_walk($csv, function(&$a) {
+			$result = [];
+			foreach ($this->fields as $k => $v) {
+				if (!isset($a[$k])) throw new Exception("CSV file error #3 - Field \"{$k}\" not found.");
+				if (!preg_match($v["regex"], $a[$k])) throw new Exception("CSV file error #4 - Bad value of \"{$k}\" ({$a[$k]}).");
+				if (isset($v["replace"])) $result[$v["name"]] = str_replace($v["replace"]["from"], $v["replace"]["to"], $a[$k]);
+				else $result[$v["name"]] = $a[$k];
+			}
+			$a = $result;
+		});
+
+		return array_values($csv);
+	}
+
+	private function importCsv() {
+		if (!isset($_FILES['csv'])) throw new Exception("Błąd formularza");
+		if ($_FILES['csv']['type'] != "text/csv") throw new Exception("Błędny plik CSV");
+		$csv = $this->parseCsv($_FILES['csv']['tmp_name']);
+		$csvPost = base64_encode(gzcompress(json_encode($csv)));
+		$_SESSION['VoIPAmsImportReady'] = true;
+?>
+<div class="container" style="margin-top:20px">
+  <form class="form-horizontal" method="post" enctype="multipart/form-data">
+    <legend>
+      Znalezione rekordy billingowe do zafakurowania
+    </legend>
+    <div class="col-sm-offset-2 col-sm-8">
+       <div style="text-align:center;">
+         <input type="hidden" name="csv" value="<?=$csvPost?>"/>
+         <button type="submit" class="btn btn-primary" name="action" value="doImportCsv">Importuj</button>
+       </div>
+       <hr/>
+       <table class="table table-bordered table-hover table-striped">
+         <thead>
+            <tr style="text-align:center; background-color:lightgray"><td width="19%">Lp.</td><td>Data połączenia</td><td>Numer klienta</td><td>Koszt netto połączenia</td></tr>
+         </thead>
+         <tbody>
+<?php
+		foreach ($csv as $i => $v) {
+			echo "<tr><td>" . ($i + 1) . "</td>";
+			foreach ($this->fields as $field) echo "<td> " . $v[$field["name"]] . "</td>";
+			echo "</tr>\n";
+		}
+?>
+        </tbody>
+      </table>
+    </div>
+  </form>
+</div>
+<?php
+	}
+
+	private function doQuery($query) {
+		try {
+			return DB::getPDO()->query($query);
+		} catch (Exception $e) {
+			throw new Exception("Wystąpił problem z zapytaniem SQL: {$query}<br/>{$e->getMessage()}");
+		}
+	}
+
+	private function doImportCsv() {
+		if (!isset($_SESSION['VoIPAmsImportReady'])) throw new Exception("Błąd formularza");
+		unset($_SESSION['VoIPAmsImportReady']);
+
+		$csv = json_decode(gzuncompress(base64_decode(V::get('csv','',$_POST))), true);
+		if (!$csv) throw new Exception("Błąd formularza");
+
+		$createColumns = []; $keys = []; $columns = [];
+		foreach ($this->fields as $field) {
+			$createColumns[] = "`{$field['name']}` {$field['sqlType']} NOT NULL";
+			$keys[] = "KEY `{$field['name']}` (`{$field['name']}`)";
+			$columns[] = $field['name'];
+		}
+
+		$queries = [];
+		$queries[] = "create temporary table `tmp_VoIPAmsImport` (" . implode(", ", array_merge($createColumns, $keys)) . ")";
+		foreach ($csv as $v) {
+			$values = [];
+			foreach ($this->fields as $field) $values["`{$field['name']}`"] = "'{$v[$field['name']]}'";
+			$queries[] = "insert into `tmp_VoIPAmsImport` (" . implode(", ", array_keys($values)) . ") values (" . implode(", ", $values) . ")";
+		}
+		$queries[] = <<<EOT
+create temporary table `tmp_VoIPAmsImport2`
+select sesa.ID_SERVICES, sesa.ID_BILLING_USERS, '16' as TYPE, DATE_FORMAT(tmp.`date`,'%Y-%m') as VALUE1, sum(round(tmp.`cost`,2)) as VALUE2,
+	'1' as NODE_ID, NULL as EXTERNAL_ID,'0' as TAB_UPDATE_STAT, 'ZAIMPORTOWANO PRZEZ VoIPAmsImport' as TAB_UPDATE_INFO
+from `tmp_VoIPAmsImport` tmp left join SES_VOIP_A sesa on sesa.S_ALIAS=tmp.number
+where sesa.ID_SERVICES IS NOT NULL
+group by sesa.ID_SERVICES, VALUE1
+having VALUE2>0
+EOT;
+
+		foreach ($queries as $query) $this->doQuery($query);
+		$result = DB::getPDO()->fetchFirst("select count(*) as `count`, sum(VALUE2) as `sum` from `tmp_VoIPAmsImport2`");
+
+		$query = <<<EOT
+insert into SES_VOIP_C (ID_SERVICES, ID_BILLING_USERS, TYPE, VALUE1, VALUE2, NODE_ID, EXTERNAL_ID, TAB_UPDATE_STAT, TAB_UPDATE_INFO)
+select * from `tmp_VoIPAmsImport2`
+EOT;
+		$this->doQuery($query);
+
+		SE_Layout::alert('success', "Z powodzeniem zaimportowano " . count($csv) . " rekordów billingowych ({$result['count']} pozycji do faktur na łączną kwotę {$result['sum']} zł netto)");
+		$this->form();
+	}
+
+	private function form() {
+?>
+<div class="container" style="margin-top:20px">
+  <form class="form-horizontal" method="post" enctype="multipart/form-data">
+    <legend>
+      Importowanie danych billingowych połączeń telefonicznych z platformy AMS
+    </legend>
+      <label class="col-sm-2 control-label">Wgraj plik</label>
+      <div class="col-sm-10" style="margin-top:3px;">
+        <input type="hidden" name="action" value="importCsv"/>
+        <input type="file" name="csv" onchange="javascript:this.form.submit();"/>
+      </div>
+    </div>
+  </form>
+</div>
+<?php
+	}
+
+	public function defaultAction() {
+		SE_Layout::gora();
+		SE_Layout::menu();
+		try {
+			$action = V::get('action','',$_POST);
+			$actions = [
+				"importCsv",
+				"doImportCsv"
+			];
+			if (in_array($action, $actions)) $this->$action();
+			else $this->form();
+		} catch (Exception $e) {
+			SE_Layout::alert('danger',$e->getMessage());
+			$this->form();
+		}
+		SE_Layout::dol();
+	}
+}