229 lines
9.0 KiB
PHP
229 lines
9.0 KiB
PHP
<?php
|
|
/* $Revision: 58 $ */
|
|
|
|
error_reporting(-1);
|
|
ini_set('display_errors', 'On');
|
|
|
|
$db = new SQLite3('/var/lib/sqlite/shoppinglist.db');
|
|
try {
|
|
$db->busyTimeout(300000); // 5 min. is a lot but who knows how busy we are; apart from that people don't notice as things run in background :)
|
|
} catch (Exception $ex) {
|
|
// if not supported then can't set it but it's not a break of the leg ;)
|
|
}
|
|
$ShoppingListKey = null;
|
|
$BrowserId = null;
|
|
|
|
function readGlobalVars() {
|
|
global $db, $ShoppingListKey, $BrowserId;
|
|
$BrowserId=$_POST['BrowserId'];
|
|
$ShoppingListName=$_POST['ShoppingListName'];
|
|
$ShoppingListKey = $db->querySingle("SELECT key FROM shoppinglist where name='" . SQLite3::escapeString($ShoppingListName) . "'");
|
|
return($ShoppingListKey);
|
|
}
|
|
|
|
function BrandBrowser() {
|
|
global $db, $ShoppingListKey, $BrowserId;
|
|
|
|
$ShoppingListName=$_POST['ShoppingListName'];
|
|
|
|
$res=true;
|
|
$ShoppingListKey = readGlobalVars();
|
|
if (null == $ShoppingListKey ) {
|
|
$res=$db->exec("insert into shoppinglist (name) values ('" . SQLite3::escapeString($ShoppingListName) . "')");
|
|
$ShoppingListKey = $db->lastInsertRowID();
|
|
}
|
|
echo "{ \"Result\":\"" . ($res==true?"True":"False") . "\", \"TransferQKey\":\"" . $_POST['TransferQKey'] . "\" }";
|
|
|
|
}
|
|
|
|
function DeleteShop(){
|
|
global $db, $ShoppingListKey, $BrowserId;
|
|
|
|
$shopGlobalId = $_POST['GlobalId'];
|
|
|
|
$sql="update entry set BrowserId = '" . SQLite3::escapeString($BrowserId) . "', status='d' where shoppingListKey=$ShoppingListKey and shopKey in (select key from Shop where globalId='" . SQLite3::escapeString($shopGlobalId) . "') ";
|
|
$res=$db->exec($sql);
|
|
|
|
if ($res == true) {
|
|
$res=$db->exec("update shop set BrowserId = '" . SQLite3::escapeString($BrowserId) . "', status='d' where shoppingListKey=" . $ShoppingListKey . " and globalId='" . SQLite3::escapeString($shopGlobalId) . "' ");
|
|
}
|
|
|
|
echo "{ \"Result\":\"" . ($res==true?"True":"False") . "\", \"TransferQKey\":\"" . $_POST['TransferQKey'] . "\" }";
|
|
}
|
|
|
|
function ReceiveShop() {
|
|
global $db, $ShoppingListKey, $BrowserId;
|
|
$description = $_POST['Description'];
|
|
$shopGlobalId = $_POST['GlobalId'];
|
|
$status = isset($_POST['value']) ? $_POST['value'] : "a";
|
|
|
|
if ($status != "d") {
|
|
$status = "a";
|
|
}
|
|
|
|
$res=true;
|
|
$shopKey = $db->querySingle("Select key from shop where globalId='" . SQLite3::escapeString($shopGlobalId) . "'");
|
|
if (null == $shopKey) {
|
|
$res=$db->exec("insert into Shop (status,shoppinglistKey,BrowserId,globalId,Description) values ('a'," . $ShoppingListKey . ", '" . $BrowserId . "','" . SQLite3::escapeString($shopGlobalId) . "','" . SQLite3::escapeString($description) . "')");
|
|
$shopKey = $db->lastInsertRowID();
|
|
} else {
|
|
$res=$db->exec("update Shop set status='" . SQLite3::escapeString($status) . "', BrowserId='" . $BrowserId . "', Description = '" . SQLite3::escapeString($description) . "' where key=" . $shopKey);
|
|
}
|
|
|
|
echo "{ \"Result\":\"" . ($res==true?"True":"False") . "\", \"TransferQKey\":\"" . $_POST['TransferQKey'] . "\", \"ShopKey\":\"$shopKey\" }";
|
|
}
|
|
|
|
function ReceiveEntry() {
|
|
global $db, $ShoppingListKey, $BrowserId;
|
|
$description = $_POST['Description'];
|
|
$shopGlobalId = $_POST['shopGlobalId'];
|
|
|
|
$res = true;
|
|
$shopKey = $db->querySingle("Select key from shop where shoppinglistkey=" . $ShoppingListKey . " and globalId='" . SQLite3::escapeString($shopGlobalId) . "'");
|
|
if (null == $shopKey) {
|
|
// normally the shop should arrive first, but it's not guaranteed.... if it doesn't the create a dummy shop...
|
|
$res=$db->exec("insert into Shop (status,shoppinglistkey,BrowserId,globalId,Description) values ('a'," . $ShoppingListKey . ", '" . SQLite3::escapeString($BrowserId) . "','" . SQLite3::escapeString($shopGlobalId) . "','Default')");
|
|
$shopKey = $db->lastInsertRowID();
|
|
}
|
|
|
|
if ($res==true) {
|
|
$EntryKey = $db->querySingle("SELECT key FROM Entry where Description='" . SQLite3::escapeString($description) . "' and ShoppingListKey=" . $ShoppingListKey . " and shopKey=" . $shopKey);
|
|
if (null == $EntryKey) {
|
|
$res=$db->exec("insert into Entry (Status,ShoppingListKey,BrowserId,shopKey,Description) values ('a'," . $ShoppingListKey . ",'" . SQLite3::escapeString($BrowserId) . "'," . $shopKey . ",'" . SQLite3::escapeString($description) . "')");
|
|
$EntryKey = $db->lastInsertRowID();
|
|
} else {
|
|
$res=$db->exec("update Entry set status='a', BrowserId='" . $BrowserId . "', Description = '" . SQLite3::escapeString($description) . "' where key=" . $EntryKey);
|
|
}
|
|
}
|
|
|
|
echo "{ \"Result\":\"" . ($res==true?"True":"False") . "\", \"TransferQKey\":\"" . $_POST['TransferQKey'] . "\", \"EntryKey\":\"$EntryKey\" }";
|
|
}
|
|
|
|
function SendChangedData() {
|
|
global $db, $ShoppingListKey, $BrowserId;
|
|
|
|
$maxModified = $_POST['maxModified'];
|
|
|
|
$sleepTimer=5; // sleep 5 seconds per Iteration
|
|
$numIterations=0;
|
|
|
|
$Data=null;
|
|
|
|
while ($Data == null && ($numIterations++ * $sleepTimer)<100){ // do a roundtrip all 100 seconds.
|
|
|
|
$Data=getModifiedShopData($maxModified["Shop"]);
|
|
if ($Data==null) { $Data=getModifiedEntryData($maxModified["Entry"] ); }
|
|
|
|
if ($Data != null) {
|
|
echo $Data;
|
|
} else {
|
|
sleep($sleepTimer);
|
|
}
|
|
}
|
|
|
|
if (null == $Data) {
|
|
echo "{ \"ChangeType\":\"None\", \"Result\":\"True\" }";
|
|
}
|
|
}
|
|
|
|
function getModifiedShopData($maxModified) {
|
|
global $db, $ShoppingListKey, $BrowserId;
|
|
|
|
$sAddCond="";
|
|
|
|
// For initial downloads do not send deleted records.
|
|
if ($maxModified == 0) {
|
|
$sAddCond=" and Shop.status != 'd' ";
|
|
}
|
|
|
|
$allShops = null;
|
|
$retVal = null;
|
|
$ojShops=null;
|
|
|
|
$sql="SELECT shop.status, shop.modified, shop.key, shop.globalId, shop.Description FROM shop where shop.shoppinglistKey=" . $ShoppingListKey . " and shop.browserId != '" . SQLite3::escapeString($BrowserId) . "' and shop.modified>" . SQLite3::escapeString($maxModified) . "" . $sAddCond . " Order by shop.modified";
|
|
|
|
$allShops = $db->query($sql);
|
|
|
|
while ($theShop = $allShops->fetchArray()) {
|
|
|
|
if (null==$ojShops) { $ojShops=", \"Shops\":["; }
|
|
$ojShops .= "{ \"ShopKey\":\"" . $theShop["key"] . "\", \"Modified\":\"" . $theShop["modified"] . "\", \"Status\":\"" . $theShop["status"] . "\", \"GlobalId\":" . json_encode($theShop["globalId"]) . ", \"Description\":" . json_encode($theShop["Description"]) . " },";
|
|
}
|
|
if (null!=$ojShops) { $ojShops = rtrim($ojShops,",") . "]"; } else { $ojShops=""; }
|
|
|
|
if ($ojShops!=null) {
|
|
$retVal= "{ \"ChangeType\":\"Shop\", \"Result\":\"" . ($allShops==true?"True":"False") . "\" " . $ojShops . " }";
|
|
}
|
|
|
|
return($retVal);
|
|
}
|
|
|
|
|
|
function getModifiedEntryData($maxModified) {
|
|
global $db, $ShoppingListKey, $BrowserId;
|
|
|
|
$sAddCond="";
|
|
|
|
// For initial downloads do not send deleted records.
|
|
if ($maxModified == 0) {
|
|
$sAddCond=" and Entry.status != 'd' ";
|
|
}
|
|
|
|
$allEntries = null;
|
|
$retVal = null;
|
|
$ojEntries=null;
|
|
|
|
$allEntries = $db->query("SELECT entry.status, entry.modified, entry.key, entry.Description, shop.globalId FROM entry,shop where entry.shoppingListKey=" . $ShoppingListKey . " and shop.key=entry.shopKey and entry.BrowserId != '" . SQLite3::escapeString($BrowserId) . "' and entry.modified>" . SQLite3::escapeString($maxModified) . "" . $sAddCond . " Order by entry.modified");
|
|
|
|
while ($theEntry = $allEntries->fetchArray()) {
|
|
|
|
if (null==$ojEntries) { $ojEntries=", \"Entries\":["; }
|
|
$ojEntries .= "{ \"EntryKey\":\"" . $theEntry["key"] . "\", \"Modified\":\"" . $theEntry["modified"] . "\", \"Status\":\"" . $theEntry["status"] . "\", \"Description\":" . json_encode($theEntry["Description"]) . ", \"shopGlobalId\":" . json_encode($theEntry["globalId"]) . " },";
|
|
}
|
|
if (null!=$ojEntries) { $ojEntries = rtrim($ojEntries,",") . "]"; } else { $ojEntries=""; }
|
|
|
|
if ($ojEntries!=null) {
|
|
$retVal= "{ \"ChangeType\":\"Entry\", \"Result\":\"" . ($allEntries==true?"True":"False") . "\" " . $ojEntries . " }";
|
|
}
|
|
|
|
return($retVal);
|
|
}
|
|
|
|
function DeleteEntry(){
|
|
global $db, $ShoppingListKey, $BrowserId;
|
|
|
|
$Description = $_POST['Description'];
|
|
$shopGlobalId = null;
|
|
if (!empty($_POST['shopGlobalId'])) {
|
|
$shopGlobalId = $_POST['shopGlobalId'];
|
|
}
|
|
|
|
$res = true;
|
|
|
|
if ($res==true) {
|
|
$sql="update entry set BrowserId = '" . SQLite3::escapeString($BrowserId) . "', status='d' where shoppingListKey=$ShoppingListKey and Description='" . SQLite3::escapeString($Description) . "'";
|
|
if (null != $shopGlobalId) { $sql = $sql . " and shopKey = (select key from shop where globalId='" . SQLite3::escapeString($shopGlobalId) . "')"; }
|
|
|
|
$res=$db->exec($sql);
|
|
}
|
|
|
|
echo "{ \"Result\":\"" . ($res==true?"True":"False") . "\", \"TransferQKey\":\"" . $_POST['TransferQKey'] . "\" }";
|
|
}
|
|
|
|
readGlobalVars();
|
|
|
|
if(isset($_POST['action']) && !empty($_POST['action'])) {
|
|
$action = $_POST['action'];
|
|
switch($action) {
|
|
case 'BrandBrowser' : BrandBrowser() ; break;
|
|
case 'ReceiveEntry' : ReceiveEntry() ; break;
|
|
case 'ReceiveShop' : ReceiveShop() ; break;
|
|
case 'SendChangedData' : SendChangedData() ; break;
|
|
case 'DeleteEntry' : DeleteEntry() ; break;
|
|
case 'DeleteShop' : DeleteShop() ; break;
|
|
}
|
|
}
|
|
|
|
$db->close();
|
|
?>
|