data_import_ajo.php

<?php

// Kutsutaanko CLI:stä
$php_cli = FALSE;

if (php_sapi_name() == 'cli') {
  $php_cli = TRUE;
}

date_default_timezone_set('Europe/Helsinki');

/* DATA IMPORT CRON LOOP */
/* Ajetaan cronista ja tämä sisäänlukee luedata-tiedostot datain hakemistosta */

// Kutsutaanko CLI:stä
if (!$php_cli) {
  die ("Tätä scriptiä voi ajaa vain komentoriviltä!");
}

// Laitetaan unlimited max time
ini_set("max_execution_time", 0);

$pupe_root_polku = dirname(__FILE__);
require "{$pupe_root_polku}/inc/connect.inc";
require "{$pupe_root_polku}/inc/functions.inc";

// Logitetaan ajo
cron_log();

$lock_params = array(
  "locktime" => 900,
);

// Sallitaan vain yksi instanssi tästä skriptistä kerrallaan
pupesoft_flock($lock_params);

function data_import() {
  global $pupe_root_polku;

  $faileja_kasitelty = FALSE;

  // Loopataan DATAIN -hakemisto läpi
  if ($files = scandir($pupe_root_polku."/datain")) {
    foreach ($files as $file) {

      // Etsitään "lue-data#" -alkuisia filejä, jotka loppuu ".DATAIMPORT"
      if (mb_substr($file, 0, 9) == "lue-data#" and mb_substr($file, -11) == ".DATAIMPORT") {

        // Filename on muotoa: lue-data#username#yhtio#taulu#randombit#jarjestys.DATAIMPORT
        // Filename on muotoa: lue-data#username#yhtio#taulu#randombit#alkuperainen_filename#jarjestys.DATAIMPORT
        $filen_tiedot = explode("#", $file);

        // Ei käsitellä jos filename ei ole oikeaa muotoa
        if (count($filen_tiedot) == 7) {

          $kuka     = $filen_tiedot[1];
          $yhtio     = $filen_tiedot[2];
          $taulu     = $filen_tiedot[3];
          $random   = $filen_tiedot[4];
          $orig_file   = $filen_tiedot[5];
          $jarjestys   = $filen_tiedot[6];

          // Logfile on muotoa: lue-data#username#yhtio#taulu#randombit#jarjestys.LOG
          $logfile = "lue-data#{$kuka}#{$yhtio}#{$taulu}#{$random}#{$orig_file}#{$jarjestys}.LOG";

          // Errorfile on muotoa: lue-data#username#yhtio#taulu#randombit#jarjestys.ERR
          $errfile = "lue-data#{$kuka}#{$yhtio}#{$taulu}#{$random}#{$orig_file}#{$jarjestys}.ERR";

          // Ajetaan lue_data tälle tiedostolle
          passthru("/usr/bin/php $pupe_root_polku/lue_data.php ".escapeshellarg($yhtio)." ".escapeshellarg($taulu)." ".escapeshellarg($pupe_root_polku."/datain/".$file)." ".escapeshellarg($pupe_root_polku."/datain/".$logfile)." ".escapeshellarg($pupe_root_polku."/datain/".$errfile));

          // Siirretään file käsitellyksi
          rename($pupe_root_polku."/datain/".$file, $pupe_root_polku."/datain/".$file.".DONE");

          $faileja_kasitelty = TRUE;
        }
      }
    }
  }

  // Katsotaan oisko tullut lisää käsiteltäviä
  if ($faileja_kasitelty) {
    data_import();
  }
}

// Aloitetaan sisäänluku
data_import();