<?
ini_set('memory_limit', '256M');
require_once('phplib/phplib.php');
require_once('common.php');

//
// functions to read udmz file
//

$db = mdb2_open($dsn);

$herinfo = get_better_herinfo($db, $_GET);

$period_id = $herinfo['period_id'];

if (isset($_GET['period_id'])) {
        $tail = "?period_id=$period_id";
} else $tail = '';

function fix_charset_whitespace($string) {
        return iconv('ISO-8859-1', 'UTF-8', trim($string));
}

function custom_explode($line) {
        return array_map('fix_charset_whitespace', explode("\t", trim($line)));
}

// the first element of the legenda is the uuid, we don't
// care about it's column title
function get_legenda($line) {
        return array_slice(custom_explode($line), 1);
}

function arrayarray(&$dest, $exploded, $val) {
        $next = &$dest[array_shift($exploded)];
        if ($exploded) arrayarray($next, $exploded, $val);
        else $next = $val;
}

function known_section($line, $preambule) {
        if (isset($preambule[trim($line)])) return true;
        else return false;
}

function add_record(&$curr, $legenda, $line) {
        $fields = custom_explode($line);
        $id = array_shift($fields);
        $deficit = count($legenda) - count($fields);
        if ($deficit < 0) error_system('deficit in udmz add_record cant be negative, but is?!?!');
        while ($deficit--) $fields[] = NULL;
        $curr[$id] = array_combine($legenda, $fields);
}

function read_udmz_lines($lines) {
        $out = array();
        $title = 'PREAMBULE';
        $curr = array();
        $legenda = get_legenda($lines[0]);

        for ($i = 1; $i < count($lines); $i++) {
                if (trim($lines[$i]) == '########') {
                        if (isset($curr)) {
                                arrayarray($out, explode('.', $title), $curr);
                                unset($curr);
                        }
                        if (known_section($lines[$i + 1], $out['PREAMBULE'])) {
                                $title = trim($lines[$i + 1]);
                                $curr = array();
                                $legenda = get_legenda($lines[$i+2]);
                        }
                        $i += 2;
                } else if (isset($curr)) add_record($curr, $legenda, $lines[$i]);
        }

        return $out;
}

// deze functie maakte voorheen gebruik van gzfile(), gzfile() kan
// echter niet werken met regels die langer zijn dan 8192 tekens, dus
// dat gaat mis, nu splitsen we de file 'met de hand'
function read_udmz_file($file) {
        $lines = array();
        $fp = gzopen($file, 'rb');
        if (!$fp) error_system("unable to open $file");
        while (!feof($fp)) {
                $line = fgets($fp);
                if (!$line) error_system("unable to read from $file");
                $lines[] = $line;
        }
        return read_udmz_lines($lines);
}

check_admin();

header('Content-type: text/plain');

print_r($_FILES);

switch ($_FILES['uploadedfile']['error']) {
        case UPLOAD_ERR_INI_SIZE:
                error_system('ge-uploade file te groot volgens php.ini');
        case UPLOAD_ERR_FORM_SIZE:
                error_system('ge-uploade file te groot volgens policy van php op deze server');
        case UPLOAD_ERR_PARTIAL:
                error_system('upload mislukt, file slechts gedeeltelijk aangekomen');
        case UPLOAD_ERR_NO_FILE:
                error_system('er is geen file geupload, omdat er geen geselecteerd was');
        case UPLOAD_ERR_NO_TMP_DIR:
                error_system('kan de file nergens kwijt, neem contact op met de beheerder');
        case UPLOAD_ERR_CANT_WRITE:
                error_system('schijf vol?, vraag de beheerder om meer ruimte');
        case UPLOAD_ERR_OK:
                break;
        default:
                error_system('onmogelijke error');
}

if ($_FILES['uploadedfile']['size'] == 0) error_system('file with no content uploaded, impossible!');


function calc_md5($file) {
        if (!($md5 = md5_file($file)))
                error_system('unable to calc md5sum of file '.$file);
        return $md5;
}

$md5 = calc_md5($_FILES['uploadedfile']['tmp_name']);

$filename = $_FILES['uploadedfile']['name'];

function merge_survs($survs) {
	$out = array();
	if (count($survs) == 0) return $out;

	$start = $survs[0]['start'];
	$end = $survs[0]['end'];
	$time = $survs[0]['time'];
	$surv = $survs[0]['surv'];

	for ($i = 1; $i < count($survs); $i++) {
		if ($surv != $survs[$i]['surv']) {
			$out[] = array(
				'start' => $start,
				'end' => $end,
				'time' => $time,
				'surv' => $surv
			);
			$start = $survs[$i]['start'];
			$end = $survs[$i]['end'];
			$time = $survs[$i]['time'];
			$surv = $survs[$i]['surv'];
		} else { // merge
			$end = $survs[$i]['end'];
			$time .= ','.$survs[$i]['time'];
		}
	}
	$out[] = array(
		'start' => $start,
		'end' => $end,
		'time' => $time,
		'surv' => $surv
	);
	return $out;
}

function collapse_survs($survs) {
	if (count($survs) == 0) return '';
	else if (count($survs) == 1) return $survs[0]['surv'];
	$survs = array_filter($survs, function ($elt) {
		if (!$elt['surv']) return false;
		else return true;
	});
	return implode(';', array_map(function ($elt) {
			return $elt['time'].':'.$elt['surv'];
		}, $survs));
}

function insert($db, $rooster_id, $activiteit, $date, $start, $end,
		$grp_id, $pta_id, $lok, $survs, $surv) {

	echo("insert: $activiteit $date $start-$end $lok $surv (grp_id=$grp_id,pta_id=$pta_id)\n");

	mdb2_exec($db, <<<EOQ
INSERT INTO roosterdetail ( rooster_id, activiteit, date,
	time_start, time_end, pta_id, grp_id, lok, surv )
VALUES ( $rooster_id, '%q', '%q', '%q', '%q', %i, %i, '%q', '%q' )
EOQ
	, $activiteit, $date, $start, $end, $pta_id, $grp_id, $lok, $surv);
	$roosterdetail_id = mdb2_single_val($db, 'SELECT LAST_INSERT_ID()');
	foreach ($survs as $info) {
		foreach (explode(',', $info['surv']) as $srv) {
			mdb2_exec($db, <<<EOQ
INSERT INTO survinfos ( roosterdetail_id, surv, start, end ) VALUES ( $roosterdetail_id, '%q', '%q', '%q' )
EOQ
			, $srv, $info['start'], $info['end']);
		}
	}
}

function write_to_db($db, $rooster_id, $toets_info) {
	if (!$toets_info) return;
	$survs = merge_survs($toets_info['survs']);
	$surv = collapse_survs($survs);
	if ($toets_info['grp'] == '') { // reserve of gangwacht
		insert($db, $rooster_id, strtolower(rtrim($toets_info['formula'], '_')),
			$toets_info['date'], $toets_info['start'], $toets_info['end'],
			0, 0, $toets_info['lok'], $survs, $surv);
	} else foreach (explode(',', $toets_info['grp']) as $grp) {
		if (preg_match("/_(\d+)_(\d+)(_(\d+))?\$/", $grp, $matches)) {
			$grp_id = $matches[1];
			$pta_id = $matches[2];
			insert($db, $rooster_id, mdb2_single_val($db, "SELECT PTA($pta_id)"),
				$toets_info['date'], $toets_info['start'], $toets_info['end'],
			       	$grp_id, $pta_id, $toets_info['lok'], $survs, $surv);

		} else echo("ERROR groep \"$grp\" niet ingelezen want format niet herkend\n");
	}
}

function parse_udmz($filename, $rooster_id) {
	global $db;
	$udmz = read_udmz_file($filename);
	echo('filename='.$filename.' rooster_id='.$rooster_id."\n");
	$toets_info = NULL;
	$current_id_number = -1;
	foreach ($udmz['Toets'] as $id => $toets) {
		/* decipher ID to see which toetsen are 'the same' */
		if (!preg_match('/^(\d+)(.*)$/', $id, $matches)) {
			WARNING("id $id is not of the structure NUMBER-SOMETHING_ELSE (123a)");
			continue;
		}
		$id_number = $matches[1];
		$id_letter = $matches[2];

		/* decipher TIMESET, complain if something weird happens */
		if (!preg_match('/\[(\d{8}):(\d{2}):(\d{2}):(\d{2})-'.
				'(\d{8}):(\d{2}):(\d{2}):(\d{2})>/',
				$toets['TIMESET'], $matches))
			error_system('ongeldige waarde van TIMESET');
		if ($matches[1] != $matches[5]) error_system('datum van begin en eind niet hetzelfde');
		$date = $matches[1];
		$start = "{$matches[2]}:{$matches[3]}";
		$end = "{$matches[6]}:{$matches[7]}";
		$surv = $toets['Doc'];
		$lok = $toets['Lok'];
		$grp = $toets['Grp'];
		$formula = $toets['FORMULA'];

		if ($start == $end) {
			echo("WARNING: deze toets heeft een duur van 0 minuten");
			continue;
		}
		if ($current_id_number != $id_number) {
			write_to_db($db, $rooster_id, $toets_info);
			$current_id_number = $id_number; 
			$toets_info = array(
				'date' => $date,
				'formula' => $formula,
				'start' => $start,
				'end' => $end,
				'survs' => array(),
				'lok' => $lok,
				'grp' => $grp
			);
			echo("found $id_number$id_letter: {$toets_info['formula']} {$toets_info['date']} {$toets_info['start']}-{$toets_info['end']} {$toets_info['lok']} $surv\n");
		} else {
			echo("attempt $id_number$id_letter with $id_number\n");
			if ($toets_info['end'] != $start) {
				error_system('zelfde toets sluit niet aan in tijd..?!?');
			}
			if ($toets_info['formula'] != $formula) {
				error_system('zelfde toets heeft niet zelfde formula');
			}
			if ($toets_info['date'] != $date) {
				error_system('zelfde toets heeft niet zelfde datum');
			}
			if ($toets_info['lok'] != $lok) {
				error_system('zelfde toets heeft niet zelfde lokaal');
			}
			if ($toets_info['grp'] != $grp) {
				error_system('zelfde toets heeft niet zelfde grp');
			}
			echo("update end from {$toets_info['end']} to $end with $surv\n");
			$toets_info['end'] = $end;
		}
		$toets_info['survs'][] =  array(
			'start' => $start,
			'end' => $end,
			'time' => timespan2lesuur($start.'-'.$end),
			'surv' => $surv
		);
	}

	/* don't forget to write the last one */
	write_to_db($db, $rooster_id, $toets_info);

	return true;
}

$exists = mdb2_single_val($db, "SELECT COUNT(*) FROM files WHERE file_md5 = '%q'", $md5);
if (!$exists) {
	if (!move_uploaded_file($_FILES['uploadedfile']['tmp_name'], $data.$md5)) {
		error_system('unable to store uploaded file');
	}
}

mdb2_exec($db, "INSERT INTO files ( file_md5, file_name, file_ok ) VALUES ( '%q', '%q', 0 )", $md5, $filename);
$file_id = mdb2_single_val($db, 'SELECT LAST_INSERT_ID()');
echo("file_id=$file_id\n");

mdb2_exec($db, "INSERT INTO rooster_ids ( period_id, rooster_version ) SELECT  $period_id, IFNULL(MAX(rooster_version), 0) + 1 FROM rooster_ids WHERE period_id = $period_id");
$rooster_id = mdb2_single_val($db, "SELECT LAST_INSERT_ID()");
$info = mdb2_single_assoc($db, "SELECT * FROM rooster_ids WHERE rooster_id = $rooster_id");
print_r($info);

if (parse_udmz($data.$md5, $rooster_id)) {
	echo("succes\n");
	mdb2_exec($db, "UPDATE files SET file_ok = 1 WHERE file_id = $file_id");
	mdb2_exec($db, "UPDATE rooster_ids SET rooster_visible = 1 WHERE rooster_id = $rooster_id");

	$_SESSION['notice'][] = 'Success';
	$_SESSION['notice'][] = "Rooster is gepubliceerd als versie {$info['rooster_version']}, het gepubliceerde rooster is zichtbaar op de envelopfrontjes, op de pagina voor de insgeschreven leerlingen en in het overzicht voor docenten (klik op 'home' en dan op 'herkansingsrooster')";

	header("Location: roostervriend.php$tail");
	exit;

} else {
	echo("fail!\n");
}

?>