malhuda/developer
1
0
Fork 0
mirror of https://github.com/easy-wi/developer.git synced 2025-02-20 11:23:28 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Optimiert, und Bedingungen eingefügt

Browse Source
This commit is contained in:
Ulrich Block 2013-08-20 23:02:35 +02:00
parent 538137906e
commit 8e6d228a9f
1 changed files with 106 additions and 82 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

188
external/api_users.php vendored
View File

@ -2,58 +2,56 @@
/**
* File: api_users.php.
* Author: Ulrich Block
* Copyright 2010-2012
* Copyright 2010-2013
* Contact: support@easy-wi.com
* Page: easy-wi.com
*/
// Configuring the API. Should be placed in another file and included
// The database access
$config['dbHost']='localhost';
$config['dbName']='database';
$config['dbUser']='databaseUser';
$config['dbPwd']='securePassword';
$config['sourceSystem']='securePassword';
// Access to the file
$config['passwordToken']='myPasswordToken';
$config['allowedIPs']=array('1.1.1.1','1.1.1.2');
// include config file
require_once ('api_config.php');
// Type of System allowed are:
// webspell,teklab
$config['sourceType']='teklab';
// Initial parameters
$error=array();
// There is no need to check every user every time
// Start looking only for new IDs
if (isset($_GET['lastID']) and is_numeric($_GET['lastID'])) {
$lastID=(int)$_GET['lastID'];
} else {
$lastID=0;
}
$lastID=(isset($_GET['lastID']) and is_numeric($_GET['lastID'])) ? (int)$_GET['lastID'] : 0;
// this requieres that a column exists which is updated every time the account gets an update:
// ALTER TABLE `yourUserTable` ADD COLUMN `updatetime` TIMESTAMP ON UPDATE CURRENT_TIMESTAMP
// This might lead to false posivives if data like the logintime is stored in that table.
// The more accurate way would be to fill/update the column only in wanted cases
if (isset($_GET['updateTime']) and @strtotime($_GET['updateTime'])) {
// convert to string and back to date so proper format is ensured
$updateTime=date('Y-m-d H:i:s',strtotime($_GET['updateTime']));
} else {
$updateTime='0000-00-00 00:00:00';
}
// Processing all users at once can lead to memory issues if system is small or userbase large.
if (isset($_GET['chunkSize']) and is_numeric($_GET['chunkSize'])) {
$chunkSize=(int)$_GET['chunkSize'];
} else {
$chunkSize=10;
}
// convert to string and back to date so proper format is ensured
$updateTime=date('Y-m-d H:i:s',strtotime((isset($_GET['updateTime']) and @strtotime($_GET['updateTime'])) ? $_GET['updateTime'] : '0000-00-00 00:00:00'));
// Processing all users at once can lead to memory issues if system has small recources or large database large.
$chunkSize=(isset($_GET['chunkSize']) and is_numeric($_GET['chunkSize'])) ? (int)$_GET['chunkSize'] : 10;
// To be able to properly get data in chunks the starting point needs to be defined.
if (isset($_GET['start']) and is_numeric($_GET['start'])) {
$start=(int)$_GET['start'];
} else {
$start=0;
}
$start=(isset($_GET['start']) and is_numeric($_GET['start'])) ? (int)$_GET['start'] : 0;
// Check if the IP is whitelisted
if(isset($_SERVER['REMOTE_ADDR']) and in_array($_SERVER['REMOTE_ADDR'],$config['allowedIPs'])) {
$config['externalIP']=$_SERVER['REMOTE_ADDR'];
$config['externalIP']=(string)$_SERVER['REMOTE_ADDR'];
} else {
$error[]='Scipt called locally or IP is not whitelisted.';
}
// Check if access token was send and is correct
if (!isset($_GET['passwordToken'])) {
$error[]='No password token has been send.';
@ -61,77 +59,103 @@ if (!isset($_GET['passwordToken'])) {
$error[]='Bad password token has been send.';
}
$list=(in_array($_GET['list'],array('user','substitutes','gameserver','voicemaster','voiceserver','dedicated','virtual','hostnode'))) ? (string)$_GET['list'] : 'user';
// Send header data
header("Content-type: application/json; charset=UTF-8");
// If there was an error send error and stop script
if (count($error)>0) {
echo json_encode(array('error'=>$error));
// Else check for new users
} else {
// Establish database connection
try {
$connection=new PDO("mysql:host=".$config['dbHost'].";dbname=".$config['dbName'],$config['dbUser'],$config['dbPwd'],array(PDO::MYSQL_ATTR_INIT_COMMAND=>"SET NAMES utf8"));
$connection->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
$pdo=new PDO("mysql:host=".$config['dbHost'].";dbname=".$config['dbName'],$config['dbUser'],$config['dbPwd'],array(PDO::MYSQL_ATTR_INIT_COMMAND=>"SET NAMES utf8"));
$pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
// Get amount of users that are new or received an update
// The Query needs to be altered to your database. This is just an example!
$sql="SELECT COUNT(`userID`) AS `amount` FROM `ws_C4J_user`
WHERE (`userID`>? OR `updatetime`>?) AND `activated`=1 AND `banned` IS NULL";
$query=$connection->prepare($sql);
$query=$pdo->prepare($sql);
$query->execute(array($lastID,$updateTime));
$total=$query->fetchColumn();
// JSON array
$json=array();
// This query fetches the actual data.
// The Query needs to be altered to your database. This is just an example!
// specify the needed columns to reduce database load.
$sql="SELECT `userID`,`email`,`username`,`firstname`,`lastname`,`birthday`,`country`,`tel`,`fax`,`mobile`,`town`,`postcode`,`street`,`streetnr`,`updatetime`
FROM `usertable`
WHERE (`userID`>? OR `updatetime`>?) AND `activated`=1 AND (`banned` IS NULL OR `banned`='')
ORDER BY `userID`
LIMIT $start,$chunkSize";
$query=$connection->prepare($sql);
$query->execute(array($lastID,$updateTime));
foreach ($query->fetchAll(PDO::FETCH_ASSOC) as $row) {
// Easy-Wi stores the salutation with numbers
if (isset($row['salutation']) and $row['salutation']=='mr') {
$salutation=1;
} else if (isset($row['salutation']) and $row['salutation']=='ms') {
$salutation=2;
} else {
$salutation='';
// User export
if ($list=='user') {
// This query fetches the actual data.
// The Query needs to be altered to your database. This is just an example!
// specify the needed columns to reduce database load.
// webspell
if ($config['sourceType']=='webspell') {
$sql="SELECT * FROM `usertable`
WHERE (`userID`>? OR `updatetime`>?) AND `activated`=1 AND (`banned` IS NULL OR `banned`='')
LIMIT $start,$chunkSize";
$query=$pdo->prepare($sql);
$query->execute(array($lastID,$updateTime));
foreach ($query->fetchAll(PDO::FETCH_ASSOC) as $row) {
// Easy-Wi stores the salutation with numbers
if (isset($row['salutation']) and $row['salutation']=='mr') {
$salutation=1;
} else if (isset($row['salutation']) and $row['salutation']=='ms') {
$salutation=2;
} else {
$salutation=null;
}
// the keys needs to be adjusted to your table layout and query!
$json[]=array(
'externalID'=>$row['userID'],
'salutation'=>$salutation,
'email'=>$row['email'],
'loginName'=>$row['username'],
'firstName'=>$row['firstname'],
'lastName'=>$row['lastname'],
'birthday'=>$row['birthday'],
'country'=>$row['country'],
'phone'=>$row['tel'],
'fax'=>$row['fax'],
'handy'=>$row['mobile'],
'city'=>$row['town'],
'cityn'=>$row['postcode'],
'street'=>$row['street'],
'streetn'=>$row['streetnr'],
'updatetime'=>$row['updatetime'],
'usertype'=>'u',
'password'=>$row['password']
);
}
} else if ($config['sourceType']=='teklab') {
}
// the keys need to be adjusted to your table layout and query!
$json[]=array(
'externalID'=>$row['userID'],
'salutation'=>$salutation,
'email'=>$row['email'],
'loginName'=>$row['username'],
'firstName'=>$row['firstname'],
'lastName'=>$row['lastname'],
'birthday'=>$row['birthday'],
'country'=>$row['country'],
'phone'=>$row['tel'],
'fax'=>$row['fax'],
'handy'=>$row['mobile'],
'city'=>$row['town'],
'cityn'=>$row['postcode'],
'street'=>$row['street'],
'streetn'=>$row['streetnr'],
'updatetime'=>$row['updatetime']
);
}
} else if ($list=='substitutes' and $config['sourceType']=='teklab') {
} else if ($list=='dedicated' and $config['sourceType']=='teklab') {
} else if ($list=='gameserver' and $config['sourceType']=='teklab') {
} else if ($list=='voice' and $config['sourceType']=='teklab') {
} else if ($list=='node' and $config['sourceType']=='teklab') {
} else if ($list=='virt' and $config['sourceType']=='teklab') {
}
// Echo the JSON reply with
echo json_encode(array('total'=>$total,'users'=>$json));
echo json_encode(array('total'=>$total,'entries'=>$json));
}
// Catch database error and display
catch(PDOException $error) {
echo json_encode(array('error'=>$error->getMessage()));