From d74a01fa05579efd3a31de74d82b51e9e8ddca26 Mon Sep 17 00:00:00 2001
From: Goeran Heinemann <goeran@karsdorf.net>
Date: Fri, 13 Mar 2020 13:17:12 +0100
Subject: [PATCH] parse-csv

---
 parse-csv.php | 41 +++++++++++++++++++++++++++++++++++++++++
 parse.php     |  3 ++-
 2 files changed, 43 insertions(+), 1 deletion(-)
 create mode 100644 parse-csv.php

diff --git a/parse-csv.php b/parse-csv.php
new file mode 100644
index 0000000..5d56fe7
--- /dev/null
+++ b/parse-csv.php
@@ -0,0 +1,41 @@
+<?php
+include 'config.php';
+
+$sql = "SELECT * FROM scans where site=4";
+$stmt = $pdo->query($sql);
+$data = $stmt->fetchAll(PDO::FETCH_ASSOC);
+foreach ($data as $row){
+    $teile = explode("<!---break--->", $row['content']);
+    foreach ($teile as $teil){
+        $laender = str_getcsv($teil);
+        if (count($laender)>1){
+            if ($laender[0] != 'parent'){
+                $data = array();
+                $data['country'] = $laender[0];
+                $data['state'] = $laender[1];
+                $data['infected'] = $laender[5];
+                $data['cured'] = $laender[6];
+                $data['deaths'] = $laender[7];
+                $sql = "INSERT INTO `data`(`scan`, `place`, `amount`, `deaths`, `cured`) VALUES (?,?,?,?,?)";
+                $stmt =$pdo->prepare($sql);
+                $stmt->bindParam(1, $row['id']);
+                $place = $data['country'].'.'.$data['state'];
+                $stmt->bindParam(2, $place);
+                $stmt->bindParam(3, $data['infected']);
+                $stmt->bindParam(4, $data['deaths']);
+                $stmt->bindParam(5, $data['cured']);
+                if(!$stmt->execute()){
+                    if ($stmt->errorInfo()[0] != '23000'){
+                        var_dump($stmt->errorInfo());
+                    }
+                }
+            }
+        }
+    }
+    $sql = "UPDATE `scans` SET `parsed`=true WHERE id=?";
+    $stmt = $pdo->prepare($sql);
+    $stmt->bindParam(1, $row['id']);
+    if (!$stmt->execute()){
+        var_dump($stmt->errorInfo());
+    }
+}
\ No newline at end of file
diff --git a/parse.php b/parse.php
index e8d8e3c..41ce7ec 100755
--- a/parse.php
+++ b/parse.php
@@ -1,4 +1,5 @@
 #! /usr/bin/php
 <?php
 include 'parse-rki.php';
-include 'parse-worldometers.php';
\ No newline at end of file
+include 'parse-worldometers.php';
+include "parse-csv.php";
\ No newline at end of file