mint/app/sync/function.php

<?php
require_once "../public/function.php";
require_once '../redis/function.php';

function do_sync($param)
{
	$output=array();
	$output["error"]=0;
	$output["message"]="";
	$output["data"]=array();

	$redis=redis_connect();
	if($redis){
		$key = $redis->hget("sync://key",$_POST["userid"]);
		if($key===FALSE){
			$output["error"]=1;
			$output["message"]="无法提取key userid:".$_POST["userid"];
			return $output;	
		}
		else{
			if($key!=$_POST["key"]){
				$output["error"]=1;
				$output["message"]="key验证失败 {$key}- {$_POST["key"]} ";
				return $output;	
			}
		}
	}
	else{
		$output["error"]=1;
		$output["message"]="redis初始化失败";
		return $output;	
	}

    if (isset($_GET["op"])) {
        $op = $_GET["op"];
    } else if (isset($_POST["op"])) {
        $op = $_POST["op"];
    } else {
		$output["error"]=1;
		$output["message"]="无操作码";
		return $output;	
    }

    $PDO = new PDO($param->database, "", "", array(PDO::ATTR_PERSISTENT => true));
    $PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);

    switch ($op) {
        case "sync":
            {
				if(isset($_POST["size"])){
					$size=intval($_POST["size"]);
				}
				else{
					$size=0;
				}
				if($size>2000){
					$size=2000;
				}
				if(isset($_POST["time"])){
					$time = $_POST["time"];
					$query = "SELECT  {$param->receive_time} as receive_time from {$param->table}  where {$param->receive_time} > ? {$param->where} order by {$param->receive_time}  limit 0,".$size;
					$stmt = $PDO->prepare($query);
					$stmt->execute(array($time));
					$Fetch = $stmt->fetchAll(PDO::FETCH_ASSOC);
					#防止同一个时间有两条数据
					if(count($Fetch)>0){
						$newTime = $Fetch[count($Fetch)-1]["receive_time"];
						$syncId = implode(",",$param->sync_id);
						$query = "SELECT {$param->uuid} as guid, $syncId , {$param->modify_time} as modify_time from {$param->table}  where {$param->receive_time} > ? and {$param->receive_time} <= ? {$param->where}  order by {$param->receive_time} ";
						$stmt = $PDO->prepare($query);
						$stmt->execute(array($time,$newTime));
						$Fetch = $stmt->fetchAll(PDO::FETCH_ASSOC);
						foreach ($Fetch as $key => $value) {
							# code...
							
							$arrSyncId = array();
							foreach ($param->sync_id as $field) {
								# code...
								$arrSyncId[]=$value[$field];
							}
							$Fetch[$key]["sync_id"] = implode("#",$arrSyncId);
						}
					}
					$output["data"]=$Fetch;
					return $output;
			
				}
				else if(isset($_POST["id"])){
					/*
					$params = json_decode($_POST["id"],true);
					$count =count($params);
					#  创建一个填充了和params相同数量占位符的字符串 
					$place_holders = implode(',', array_fill(0, count($params), '?'));
					$query = "SELECT {$param->uuid} as guid, {$param->modify_time} as modify_time from {$param->table}  where {$param->uuid} in ($place_holders) order by {$param->receive_time} ASC  limit 0,".$size;
					$stmt = $PDO->prepare($query);
					$stmt->execute($params);
					$Fetch = $stmt->fetchAll(PDO::FETCH_ASSOC);
					$iFetch = count($Fetch);
					$output["data"]=$Fetch;
					return $output;
					*/
					$syncId = implode(",",$param->sync_id);
					$arrId = json_decode($_POST["id"],true);
					$query = "SELECT {$param->uuid} as guid, {$syncId} , {$param->modify_time} as modify_time from {$param->table}  where ";
					foreach ($param->sync_id as $field) {
						$query .= " $field = ? and";
					}
					$query .= " 1  limit 0,1";
					$stmt = $PDO->prepare($query);
					$data = array();
					foreach ($arrId as $id) {
						# code...
						$stmt->execute(explode("#",$id));
						$Fetch = $stmt->fetch(PDO::FETCH_ASSOC);
						if($Fetch){
							$Fetch["sync_id"] = $id;
							$data[]=$Fetch;
						}
					}
					$output["data"]=$data;
					return $output;
				}

                break;
            }
        case "get":
            {
                if (isset($_GET["id"])) {
                    $id = $_GET["id"];
                } else if (isset($_POST["id"])) {
                    $id = $_POST["id"];
                } else {
                    return (false);
                }
                $arrId = json_decode($id,true);
				/*  创建一个填充了和params相同数量占位符的字符串 */
				$place_holders = implode(',', array_fill(0, count($arrId), '?'));
                $query = "SELECT * FROM {$param->table} WHERE {$param->uuid} in ($place_holders)";
				$stmt = $PDO->prepare($query);
				$stmt->execute($arrId);
                $Fetch = $stmt->fetchAll(PDO::FETCH_ASSOC);
				$output["message"]="提取数据".count($Fetch);
				$output["data"]=$Fetch;
				return $output;
                break;
            }
        case "insert":
            {
                if (isset($_POST["data"])) {
                    $data = $_POST["data"];
                } else {
					$output["error"]=1;
					$output["message"]="没有提交数据";
					return $output;
                }

                // 开始一个事务，关闭自动提交
                $PDO->beginTransaction();
                $query = "INSERT INTO {$param->table} (";
                foreach ($param->insert as $row) {
                    $query .= "'" . $row . "',";
                }
				$query = mb_substr($query,0,-1,"UTF-8");
                $query .= ") VALUES ( ";
                for ($i = 0; $i < count($param->insert); $i++) {
                    $query .= " ?,";
                }
				$query = mb_substr($query,0,-1,"UTF-8");
                $query .= "  )";

                $arrData = json_decode($data, true);
                $stmt = $PDO->prepare($query);
                foreach ($arrData as $oneParam) {
                    $newRow = array();
                    foreach ($param->insert as $row) {
                        $newRow[] = $oneParam["{$row}"];
                    }

                    $stmt->execute($newRow);
                }
                // 提交更改
                $PDO->commit();
                if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
                    $error = $PDO->errorInfo();
					$output["error"]=1;
					$output["message"]="error - $error[2]";
					return $output;

                } else {
                    $count = count($arrData);
					$output["error"]=0;
					$output["message"]="INSERT $count recorders.";
					return $output;						
                }
                break;
            }
        case "update":
            {
                if (isset($_POST["data"])) {
                    $data = $_POST["data"];
                } else {
					$output["error"]=1;
					$output["message"]="没有输入数据";
					return $output;	
                }
                $arrData = json_decode($data, true);
                $query = "UPDATE {$param->table} SET ";
                foreach ($param->update as $row) {
                    $query .= "{$row} = ? ,";
                }
				$query = mb_substr($query,0,-1,"UTF-8");
                $query .= "  where {$param->uuid} = ? ";
                $stmt = $PDO->prepare($query);
                // 开始一个事务，关闭自动提交
                try {
                    $PDO->beginTransaction();
                    foreach ($arrData as $one) {
                        $newRow = array();
                        foreach ($param->update as $row) {
                            $newRow[] = $one["{$row}"];
                        }
                        $newRow[] = $one["{$param->uuid}"];
                        $stmt->execute($newRow);
                    }
                    // 提交更改
                    $PDO->commit();
                    if (!$stmt || ($stmt && $stmt->errorCode() != 0)) {
                        $error = $PDO->errorInfo();
						$output["error"]=1;
						$output["message"]="error - $error[2]";
						return $output;

                    } else {
                        $count = count($arrData);
						$output["error"]=0;
						$output["message"]="Update $count recorders.";
						return $output;
                    }
                } catch (Exception $e) {
                    $PDO->rollback();
					$output["error"]=1;
					$output["message"]="Failed:" . $e->getMessage();
					return $output;						
                }
                break;
            }
        default:
            break;
    }

}