326 lines
10 KiB
PHP
326 lines
10 KiB
PHP
<?php
|
|
|
|
require_once 'php/dbutils.php';
|
|
require_once 'php/config.php';
|
|
defined('DB') || define ( 'DB','mysql' );
|
|
|
|
|
|
class Sync {
|
|
public static function insertSystemData($pdo,$systemdata) {
|
|
try {
|
|
DbUtils::log("insertSystemData started");
|
|
if (!isset($systemdata["guestcode"])) {
|
|
return array("status" => "ERROR","msg" => "No Access code transmitted!");
|
|
}
|
|
|
|
$transmittedGuestcode = $systemdata["guestcode"];
|
|
if ($transmittedGuestcode != CODE) {
|
|
return array("status" => "ERROR","msg" => "Wrong Access code!");
|
|
}
|
|
|
|
self::insertIntoSystemTable($pdo, $systemdata, 'timezone');
|
|
self::insertIntoSystemTable($pdo, $systemdata, 'dailycode');
|
|
self::insertIntoSystemTable($pdo, $systemdata, 'resttables');
|
|
self::insertIntoSystemTable($pdo, $systemdata, 'types');
|
|
self::insertIntoSystemTable($pdo, $systemdata, 'products');
|
|
self::insertIntoSystemTable($pdo, $systemdata, 'currency');
|
|
self::insertIntoSystemTable($pdo, $systemdata, 'decpoint');
|
|
|
|
self::insertIntoSystemTable($pdo, $systemdata, 'askdaycode');
|
|
self::insertIntoSystemTable($pdo, $systemdata, 'asktablecode');
|
|
self::insertIntoSystemTable($pdo, $systemdata, 'guesttimeout');
|
|
|
|
if (isset($systemdata["timezone"])) {
|
|
self::updateOsAccessStatus($pdo, $systemdata["timezone"]);
|
|
}
|
|
$logo = '';
|
|
if (isset($systemdata["logo"]) && ($systemdata["logo"] != '')) {
|
|
$logo = $systemdata["logo"];
|
|
}
|
|
self::insertOrUpdateOrDeleteImage($pdo, 'logo', $logo, DbUtils::$TYPE_LOGO, null);
|
|
|
|
if (isset($systemdata["prodimages"])) {
|
|
DbUtils::log("prodimages are transmitted -> update now");
|
|
self::insertOrUpdateProdImages($pdo, $systemdata["prodimages"]);
|
|
}
|
|
return array("status" => "OK");
|
|
} catch (Exception $ex) {
|
|
return array("status" => "ERROR","msg" => $ex->getMessage());
|
|
}
|
|
}
|
|
|
|
|
|
private static function deleteImage_not_used($pdo,$imageName,$productid) {
|
|
if (DB == "mysql") {
|
|
if (is_null($productid)) {
|
|
$sql = "DELETE FROM %images% WHERE imagename=?";
|
|
DbUtils::execSql($pdo, $sql, array($imageName));
|
|
} else {
|
|
$sql = "DELETE FROM %images% WHERE productid=?";
|
|
DbUtils::execSql($pdo, $sql, array($productid));
|
|
}
|
|
} else {
|
|
|
|
}
|
|
}
|
|
|
|
private static function insertOrUpdateOrDeleteImage($pdo,$imageName,$content,$contenttype,$productid) {
|
|
$contentMd5 = null;
|
|
if ($content == '-') {
|
|
$content = '';
|
|
}
|
|
if (!is_null($content)) {
|
|
$contentMd5 = md5($content);
|
|
}
|
|
if (DB == "mysql") {
|
|
|
|
if (is_null($productid)) {
|
|
$sql = "SELECT id,content FROM %images% WHERE imagename=?";
|
|
$result = DbUtils::fetchSqlAll($pdo, $sql, array($imageName));
|
|
} else {
|
|
$sql = "SELECT id,content FROM %images% WHERE productid=?";
|
|
$result = DbUtils::fetchSqlAll($pdo, $sql, array($productid));
|
|
}
|
|
|
|
$delete = false;
|
|
if (!is_null($productid) && ($content == '')) {
|
|
$delete = true;
|
|
} else if (is_null($productid) && ($content == '')) {
|
|
$delete = true;
|
|
}
|
|
if ($delete) {
|
|
if (count($result) > 0) {
|
|
$id = $result[0]["id"];
|
|
$sql = "DELETE FROM %images% WHERE id=?";
|
|
DbUtils::execSql($pdo, $sql, array($id));
|
|
if (!is_null($productid)) {
|
|
DbUtils::log("Product image with id $productid deleted from mysql");
|
|
} else {
|
|
DbUtils::log("Product image with name $imageName deleted from mysql");
|
|
}
|
|
}
|
|
return;
|
|
}
|
|
|
|
|
|
if (count($result) == 0) {
|
|
$sql = "INSERT INTO %images% (imagename,content,contenttype,productid) VALUES(?,?,?,?)";
|
|
DbUtils::execSql($pdo, $sql, array($imageName,$content,$contenttype,$productid));
|
|
DbUtils::log("Image with name '" . $imageName . "' and product id=" . (is_null($productid) ? "null":$productid) . " inserted into mysql");
|
|
} else {
|
|
$origContentMd5 = md5($result[0]["content"]);
|
|
if ($contentMd5 != $origContentMd5) {
|
|
$rowId = $result[0]["id"];
|
|
$sql = "UPDATE %images% SET imagename=?,content=?,contenttype=?,productid=? WHERE id=?";
|
|
DbUtils::execSql($pdo, $sql, array($imageName,$content,$contenttype,$productid,$rowId));
|
|
DbUtils::log("Image updated with imagename='$imageName' and productid=" . (is_null($productid) ? "null":$productid) . " in mysql");
|
|
}
|
|
}
|
|
} else {
|
|
try {
|
|
$filename = "db/" . IMAGES_FILE;
|
|
$images = array();
|
|
if (file_exists($filename)) {
|
|
$imagesContent = file_get_contents($filename);
|
|
$images = json_decode($imagesContent,true);
|
|
}
|
|
|
|
$imgesWereChanged = false;
|
|
$foundImageAtKey = null;
|
|
|
|
$keys = array_keys($images);
|
|
foreach($keys as $aKey) {
|
|
$img = $images[$aKey];
|
|
if (is_null($productid)) {
|
|
if ($img["imagename"] == $imageName) {
|
|
$foundImageAtKey = $aKey;
|
|
break;
|
|
}
|
|
} else {
|
|
if ($img["productid"] == $productid) {
|
|
$foundImageAtKey = $aKey;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
$delete = false;
|
|
if ($imageName == 'logo') {
|
|
DbUtils::log("Logo content: " . $content);
|
|
}
|
|
if (!is_null($productid) && ($content == '')) {
|
|
$delete = true;
|
|
} else if (is_null($productid) && ($content == '')) {
|
|
$delete = true;
|
|
}
|
|
|
|
if ($delete) {
|
|
if (!is_null($foundImageAtKey)) {
|
|
unset ($images[$foundImageAtKey]);
|
|
file_put_contents($filename, json_encode($images));
|
|
if (!is_null($productid)) {
|
|
DbUtils::log("Product image with id $productid deleted from file");
|
|
} else {
|
|
DbUtils::log("Product image with name $imageName deleted from file");
|
|
}
|
|
}
|
|
return;
|
|
}
|
|
|
|
$img = array("imagename" => $imageName,"content" => $content, "contenttype" => $contenttype, "productid" => $productid);
|
|
if (is_null($foundImageAtKey)) {
|
|
$images[] = $img;
|
|
$imgesWereChanged = true;
|
|
DbUtils::log("Image with name '" . $imageName . "' and product id=" . (is_null($productid) ? "null":$productid) . " inserted into file db");
|
|
} else {
|
|
$origContentMd5 = md5($images[$foundImageAtKey]["content"]);
|
|
if ($contentMd5 != $origContentMd5) {
|
|
$images[$foundImageAtKey] = $img;
|
|
$imgesWereChanged = true;
|
|
DbUtils::log("Image updated with imagename='$imageName' and productid=" . (is_null($productid) ? "null":$productid) . " in file db");
|
|
}
|
|
}
|
|
|
|
if ($imgesWereChanged) {
|
|
file_put_contents($filename, json_encode($images));
|
|
}
|
|
} catch(Exception $ex) { }
|
|
}
|
|
}
|
|
|
|
private static function insertOrUpdateProdImages($pdo,$imagedata) {
|
|
foreach ($imagedata as $img) {
|
|
$productid = $img['prodid'];
|
|
$imgl = $img['imagedata'];
|
|
self::insertOrUpdateOrDeleteImage($pdo, '', $imgl, DbUtils::$TYPE_PRODIMG, $productid);
|
|
}
|
|
}
|
|
|
|
private static function insertIntoSystemTable($pdo,$data,$item) {
|
|
if (isset($data[$item])) {
|
|
$value = $data[$item];
|
|
$valuemd5 = md5($value);
|
|
if (DB == "mysql") {
|
|
$sql = "SELECT value FROM %ossystem% WHERE item=?";
|
|
$origvalSql = DbUtils::fetchSqlAll($pdo, $sql, array($item));
|
|
if (count($origvalSql) == 0) {
|
|
$sql = "INSERT INTO %ossystem% (item,value) VALUES(?,?)";
|
|
DbUtils::execSql($pdo, $sql, array($item,$value));
|
|
} else {
|
|
// to avoid unnecessary write operations check if update is needed
|
|
$origvalmd5 = md5($origvalSql[0]["value"]);
|
|
if ($valuemd5 != $origvalmd5) {
|
|
$sql = "UPDATE %ossystem% SET value=? WHERE item=?";
|
|
DbUtils::execSql($pdo, $sql, array($value,$item));
|
|
}
|
|
}
|
|
} else {
|
|
$filename = "db/" . OSSYSTEM_FILE;
|
|
try {
|
|
if (file_exists($filename)) {
|
|
$allOssystemvalues = file_get_contents($filename);
|
|
$dataItems = json_decode($allOssystemvalues, true);
|
|
if (isset($dataItems[$item])) {
|
|
$origvalmd5 = md5($dataItems[$item]);
|
|
if ($valuemd5 != $origvalmd5) {
|
|
$dataItems[$item] = $value;
|
|
file_put_contents($filename, json_encode($dataItems));
|
|
DbUtils::log("In $filename update item $item with value $value");
|
|
}
|
|
} else {
|
|
$dataItems[$item] = $value;
|
|
file_put_contents($filename, json_encode($dataItems));
|
|
DbUtils::log("In $filename insert item $item with value $value");
|
|
}
|
|
} else {
|
|
$dataItems = [];
|
|
$dataItems[$item] = $value;
|
|
file_put_contents($filename, json_encode($dataItems));
|
|
DbUtils::log("Create $filename and insert item $item with value $value");
|
|
}
|
|
} catch (Exception $ex) { }
|
|
}
|
|
}
|
|
}
|
|
|
|
private static function updateOsAccessStatus($pdo,$timezone) {
|
|
date_default_timezone_set($timezone);
|
|
$date = new DateTime();
|
|
$currentTimeStamp = $date->getTimestamp();
|
|
|
|
if (DB == "mysql") {
|
|
$sql = "SELECT id FROM %gueststatus% WHERE item=?";
|
|
$result = DbUtils::fetchSqlAll($pdo, $sql, array('lastosaccess'));
|
|
if (count($result) == 0) {
|
|
$sql = "INSERT INTO %gueststatus% (date,item) VALUES(?,?)";
|
|
} else {
|
|
$sql = "UPDATE %gueststatus% SET date=? WHERE item=?";
|
|
}
|
|
DbUtils::execSql($pdo, $sql, array($currentTimeStamp,'lastosaccess'));
|
|
} else {
|
|
$filename = "db/" . STATUS_FILE;
|
|
try {
|
|
if (file_exists($filename)) {
|
|
$lastaccess = file_get_contents($filename);
|
|
if ($currentTimeStamp != $lastaccess) {
|
|
file_put_contents($filename, $currentTimeStamp);
|
|
}
|
|
} else {
|
|
file_put_contents($filename, $currentTimeStamp);
|
|
}
|
|
} catch (Exception $ex) { }
|
|
}
|
|
}
|
|
|
|
public static function fetchQueueData($pdo) {
|
|
if (DB == "mysql") {
|
|
$pdo->beginTransaction();
|
|
$sql = "SELECT id,date,tableid,prodid,tablecode,dailycode FROM %queue%";
|
|
$result = DbUtils::fetchSqlAll($pdo, $sql, null);
|
|
DbUtils::log("Transmit " . count($result) . " items to core system from mysql queue table");
|
|
$sql = "DELETE FROM %queue%";
|
|
DbUtils::execSql($pdo, $sql, null);
|
|
$pdo->commit();
|
|
|
|
return $result;
|
|
} else {
|
|
$filename = "db/" . QUEUE_FILE;
|
|
if (file_exists($filename)) {
|
|
$queueItemsInFile = file_get_contents($filename);
|
|
$queueItems = json_decode($queueItemsInFile,true);
|
|
DbUtils::log("Transmit " . count($queueItems) . " items to core system from file queue");
|
|
|
|
$emptyContent = json_encode(array());
|
|
file_put_contents($filename, $emptyContent);
|
|
|
|
return $queueItems;
|
|
} else {
|
|
return array();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if (isset($_POST["data"])) {
|
|
$pdo = null;
|
|
if (DB == "mysql") {
|
|
$pdo = DbUtils::openDbAndReturnPdoStatic();
|
|
}
|
|
|
|
$data = $_POST["data"];
|
|
|
|
$utfdata = base64_decode($data);
|
|
$objFormat = json_decode($utfdata, true);
|
|
|
|
$ret = Sync::insertSystemData($pdo,$objFormat);
|
|
|
|
if ($ret["status"] != "OK") {
|
|
echo json_encode($ret);
|
|
} else {
|
|
$queuedData = Sync::fetchQueueData($pdo);
|
|
$ret = array("status" => "OK","msg" => $queuedData);
|
|
echo json_encode($ret);
|
|
}
|
|
} else {
|
|
echo "No data transmitted!";
|
|
} |