Mercurial > bms / file diff

--- a/www/crontasks.php	Mon Feb 25 17:29:35 2019 +0100
+++ b/www/crontasks.php	Mon Feb 25 22:49:22 2019 +0100
@@ -2,13 +2,50 @@
 
 require_once('config.php');
 
-$mysqli = new mysqli(DBASE_HOST,DBASE_USER,DBASE_PASS,DBASE_NAME);
+$escapers = array("\\", "/", "\"", "\n", "\r", "\t", "\x08", "\x0c");
+$replacements = array("\\\\", "\\/", "\\\"", "\\n", "\\r", "\\t", "\\f", "\\b");
+
+$connect = mysqli_connect(DBASE_HOST, DBASE_USER, DBASE_PASS, DBASE_NAME);
+if (! $connect) {
+	die('Connect Error (' . mysqli_connect_errno() . ') ' . mysqli_connect_error());
+}
+mysqli_set_charset($connect, "utf8" );
+syslog(LOG_NOTICE, "crontasks.php started");
+
 $query = "UPDATE products SET stage=7 WHERE stage = 6 AND DATEDIFF(CURDATE(), package_date) > 0";
-$result = $mysqli->query($query);
+$result = mysqli_query($connect, $query);
+$changed = mysqli_affected_rows($connect);
+if ($changed > 0) {
+	syslog(LOG_NOTICE, "Updated ".$changed." products to stage 7");
+}
 
 $query = "UPDATE products SET stage=8 WHERE stage = 7 AND DATEDIFF(CURDATE(), package_date) > 13";
-$result = $mysqli->query($query);
+$result = mysqli_query($connect, $query);
+$changed = mysqli_affected_rows($connect);
+if ($changed > 0) {
+	syslog(LOG_NOTICE, "Updated ".$changed." products to stage 8");
+}
 
 $query = "UPDATE products SET stage=9 WHERE stage = 8 AND DATEDIFF(CURDATE(), package_date) > 41";
-$result = $mysqli->query($query);
+$result = mysqli_query($connect, $query);
+$changed = mysqli_affected_rows($connect);
+if ($changed > 0) {
+	syslog(LOG_NOTICE, "Updated ".$changed." products to stage 9");
+}
+
 
+$query = "SELECT record,code,name,log_brew,log_fermentation FROM products;";
+$result = mysqli_query($connect, $query);
+while ($row = mysqli_fetch_array($result, MYSQLI_ASSOC)) {
+	$logfile = "log/fermentation/" . $row['code'] . " " . $row['name'] . ".log";
+	if (file_exists($logfile))
+		$ok = 1;
+	else
+		$ok = 0;
+	if ($ok != $row['log_fermentation']) {
+		$query = "UPDATE products SET log_fermentation='" . $ok . "' WHERE record='" . $row['record'] . "';";
+		syslog(LOG_NOTICE, $query);
+		$result1 = mysqli_query($connect, $query);
+	}
+}
+