Mercurial > bms / file diff

--- a/www/crontasks.php	Wed Oct 18 13:03:10 2023 +0200
+++ b/www/crontasks.php	Wed Dec 06 20:26:00 2023 +0100
@@ -79,34 +79,37 @@
 $query = "SELECT record,code,name,log_brew,log_fermentation,log_ispindel,log_co2pressure 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))
+	$query1 = "SELECT code FROM log_fermenter WHERE code='"  . $row['code'] . "';";
+	$result1 = mysqli_query($connect, $query1);
+	if (mysqli_num_rows($result1) > 0)
 		$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);
+		syslog(LOG_NOTICE, $row['code'] . ": " . $query);
 		$result1 = mysqli_query($connect, $query);
 	}
-	$logfile = "log/ispindel/" . $row['code'] . " " . $row['name'] . ".log";
-	if (file_exists($logfile))
+	$query1 = "SELECT code FROM log_ispindel WHERE code='"  . $row['code'] . "';";
+        $result1 = mysqli_query($connect, $query1);
+        if (mysqli_num_rows($result1) > 0)
                 $ok = 1;
         else
                 $ok = 0;
         if ($ok != $row['log_ispindel']) {
                 $query = "UPDATE products SET log_ispindel='" . $ok . "' WHERE record='" . $row['record'] . "';";
-                syslog(LOG_NOTICE, $query);
+                syslog(LOG_NOTICE, $row['code'] . ": " . $query);
                 $result1 = mysqli_query($connect, $query);
-        }
-	$logfile = "log/co2pressure/" . $row['code'] . " " . $row['name'] . ".log";
-        if (file_exists($logfile))
+	}
+	$query1 = "SELECT code FROM log_co2pressure WHERE code='"  . $row['code'] . "';";
+        $result1 = mysqli_query($connect, $query1);
+        if (mysqli_num_rows($result1) > 0)
                 $ok = 1;
         else
                 $ok = 0;
         if ($ok != $row['log_co2pressure']) {
                 $query = "UPDATE products SET log_co2pressure='" . $ok . "' WHERE record='" . $row['record'] . "';";
-                syslog(LOG_NOTICE, $query);
+                syslog(LOG_NOTICE, $row['code'] . ": " . $query);
                 $result1 = mysqli_query($connect, $query);
         }
 }