1#@!#!123s

: / var / www / ipwdn / json_mysql /
Filename : json_import_all.php
back
<?php

$servername = "localhost";
$username = "root";
$password = "HbM#78Kp";
$dbname = "ipwdn";

// Database connection
$conn = new mysqli($servername, $username, $password, $dbname);


$path = "../json_export";
// sortowanie po nazwie pliku
// $files = scandir('data', SCANDIR_SORT_DESCENDING);
// $filename = $path.$files[0];

// wvczytanie wszystkich plków
foreach(new DirectoryIterator($path) as $item) {
    if ($item->isFile() && $item->getExtension() === 'json' && $item->getSize() > 0) {
        $file = clone $item;

        if ($file) {
            echo $file;
            echo '<br>';
            echo date('Y-m-d H:i:s', $item->getMTime());
            echo '<br>';

            $jsoncontent = file_get_contents($file->getPathname());
            $json_decode = json_decode($jsoncontent, true);
            // $timestamp = $json_decode['timestamp'];
            // $jsondata = json_encode($json_decode['data']);
            echo count($json_decode['data']);
            echo '<br>';

            foreach ($json_decode['data'] as $device => $data) {
                if (isset($data['dtimestamp']) && isset($data['timestamp'])) {
                    $time = $data['dtimestamp'];
                } else if (isset($data['timestamp'])) {
                    $time = strtotime($data['timestamp']);
                } else {
                    $time = null;
                }

                if ($time) {
                    $id = $time.'_'.$device;
                    $data['device'] = $device;
                    $jsondata = json_encode($data);
                    //Insert data Query
                    $sql = "INSERT INTO ipwdn_meteo_data (id, timestamp, device, data) VALUES ('$id', FROM_UNIXTIME('$time'), '$device', '$jsondata')";
                    if ($conn->query($sql) === TRUE) {
                        echo '<p style="color: blue;">Insert your JSON record successfully</p>';
                    } else {
                        echo '<p style="color: red;">Insert your JSON record failed (Record exists)</p>';
                    }
                } else {
                    echo '<p style="color: red;">No data!!!</p>';
                }
            }

            // $timestamp = date('Y-m-d H:i:s', strtotime($timestamp));

            // Insert data Query
            // if (count($json_decode['data']) > 1) {
            //     $sql = "INSERT INTO import_data_new (timestamp, data)
            //     VALUES ('$timestamp', '$jsondata')";

            //     if ($conn->query($sql) === TRUE) {
            //         echo '<p style="color: blue;">Insert your JSON record successfully</p>';
            //     } else {
            //         echo '<p style="color: red;">Insert your JSON record failed (Record exists)</p>';
            //     }
            // } else {
            //     echo '<p style="color: red;">Only one device!!!</p>';
            // }
        }
    } else {
        echo "<p>No valid file</p>";
    }
}

?>