更新助手类
This commit is contained in:
Li Jianxuan
parent
e4ef7119fb
commit
87f2aaa67d
|
|
@ -0,0 +1,145 @@
|
|||
<?php
|
||||
namespace Helpers;
|
||||
|
||||
class Curl
|
||||
{
|
||||
private $options;
|
||||
|
||||
public function __construct($options = array())
|
||||
{
|
||||
$this->options = array_merge(array(
|
||||
'debug' => false,
|
||||
'http_port' => '80',
|
||||
'user_agent' => 'Westdc DataService',
|
||||
'timeout' => 20,
|
||||
'curlopts' => null,
|
||||
'verifyssl' => true,
|
||||
), $options);
|
||||
}
|
||||
|
||||
/**
|
||||
* Send a request to the server, receive a response
|
||||
*
|
||||
* @param string $apiPath Request API path
|
||||
* @param array $parameters Parameters
|
||||
* @param string $httpMethod HTTP method to use
|
||||
*
|
||||
* @return string HTTP response
|
||||
*/
|
||||
public function request($url, array $parameters = array(), $httpMethod = 'GET', array $options = array())
|
||||
{
|
||||
$options = array_merge($this->options, $options);
|
||||
|
||||
$curlOptions = array();
|
||||
$headers = array();
|
||||
|
||||
if ('POST' === $httpMethod) {
|
||||
$curlOptions += array(
|
||||
CURLOPT_POST => true,
|
||||
);
|
||||
}
|
||||
elseif ('PUT' === $httpMethod) {
|
||||
$curlOptions += array(
|
||||
CURLOPT_POST => true, // This is so cURL doesn't strip CURLOPT_POSTFIELDS
|
||||
CURLOPT_CUSTOMREQUEST => 'PUT',
|
||||
);
|
||||
}
|
||||
elseif ('DELETE' === $httpMethod) {
|
||||
$curlOptions += array(
|
||||
CURLOPT_CUSTOMREQUEST => 'DELETE',
|
||||
);
|
||||
}
|
||||
|
||||
if (!empty($parameters))
|
||||
{
|
||||
if('GET' === $httpMethod)
|
||||
{
|
||||
$queryString = utf8_encode($this->buildQuery($parameters));
|
||||
$url .= '?' . $queryString;
|
||||
} elseif ('POST' === $httpMethod) {
|
||||
$curlOptions += array(
|
||||
CURLOPT_POSTFIELDS => is_array($parameters) ? http_build_query($parameters) : $parameters,
|
||||
);
|
||||
} else {
|
||||
$curlOptions += array(
|
||||
CURLOPT_POSTFIELDS => json_encode($parameters)
|
||||
);
|
||||
$headers[] = 'Content-Type: application/json';
|
||||
}
|
||||
} else {
|
||||
$headers[] = 'Content-Length: 0';
|
||||
}
|
||||
|
||||
$this->debug('send '.$httpMethod.' request: '.$url);
|
||||
|
||||
$curlOptions += array(
|
||||
CURLOPT_URL => $url,
|
||||
CURLOPT_PORT => $options['http_port'],
|
||||
CURLOPT_USERAGENT => $options['user_agent'],
|
||||
CURLOPT_RETURNTRANSFER => true,
|
||||
CURLOPT_TIMEOUT => $options['timeout'],
|
||||
CURLOPT_HTTPHEADER => $headers,
|
||||
CURLOPT_SSL_VERIFYPEER => $options['verifyssl'],
|
||||
);
|
||||
|
||||
if (ini_get('open_basedir') == '' && ini_get('safe_mode') != 'On') {
|
||||
$curlOptions[CURLOPT_FOLLOWLOCATION] = true;
|
||||
}
|
||||
|
||||
if (is_array($options['curlopts'])) {
|
||||
$curlOptions += $options['curlopts'];
|
||||
}
|
||||
|
||||
if (isset($options['proxy'])) {
|
||||
$curlOptions[CURLOPT_PROXY] = $options['proxy'];
|
||||
}
|
||||
|
||||
$response = $this->doCurlCall($curlOptions);
|
||||
|
||||
return $response;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get a JSON response and transform it to a PHP array
|
||||
*
|
||||
* @return array the response
|
||||
*/
|
||||
protected function decodeResponse($response)
|
||||
{
|
||||
// "false" means a failed curl request
|
||||
if (false === $response['response']) {
|
||||
$this->debug(print_r($response, true));
|
||||
return false;
|
||||
}
|
||||
return parent::decodeResponse($response);
|
||||
}
|
||||
|
||||
protected function doCurlCall(array $curlOptions)
|
||||
{
|
||||
$curl = curl_init();
|
||||
|
||||
curl_setopt_array($curl, $curlOptions);
|
||||
|
||||
$response = curl_exec($curl);
|
||||
$headers = curl_getinfo($curl);
|
||||
$errorNumber = curl_errno($curl);
|
||||
$errorMessage = curl_error($curl);
|
||||
|
||||
curl_close($curl);
|
||||
|
||||
return compact('response', 'headers', 'errorNumber', 'errorMessage');
|
||||
}
|
||||
|
||||
protected function buildQuery($parameters)
|
||||
{
|
||||
return http_build_query($parameters, '', '&');
|
||||
}
|
||||
|
||||
protected function debug($message)
|
||||
{
|
||||
if($this->options['debug'])
|
||||
{
|
||||
print $message."\n";
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -1,5 +1,5 @@
|
|||
<?php
|
||||
namespace Helper;
|
||||
namespace Helpers;
|
||||
|
||||
class View extends \Zend_Controller_Plugin_Abstract
|
||||
{
|
||||
|
|
@ -85,8 +85,9 @@ class View extends \Zend_Controller_Plugin_Abstract
|
|||
}
|
||||
|
||||
static function Dump($data,$exit = true){
|
||||
echo "<pre>";
|
||||
echo "<pre>"."\r\n";
|
||||
var_dump($data);
|
||||
echo "\r\n";
|
||||
echo "</pre>";
|
||||
if($exit)
|
||||
{
|
||||
|
|
|
|||
|
|
@ -0,0 +1,139 @@
|
|||
<?php
|
||||
namespace Helpers;
|
||||
|
||||
class dbh
|
||||
{
|
||||
private $db; //传入PDO对象.
|
||||
private $product = 0; //产品环境
|
||||
|
||||
function __construct($db)
|
||||
{
|
||||
$this->db = $db;
|
||||
}
|
||||
|
||||
function insert($table,$data,$return=false)
|
||||
{
|
||||
$fields = array();
|
||||
$datas = array();
|
||||
|
||||
foreach($data as $k=>$v)
|
||||
{
|
||||
$fields[] = '"'.$k.'"';
|
||||
if(is_int($v) || is_float($v) || is_bool($v))
|
||||
{
|
||||
$datas[] = $v;
|
||||
}else{
|
||||
if(preg_match("/\'/",$v))
|
||||
{
|
||||
$v = preg_replace("/\'/","''",$v);
|
||||
}
|
||||
$datas[] = "'".$v."'";
|
||||
}
|
||||
}
|
||||
|
||||
$fields = join(",",$fields);
|
||||
$datas = join(",",$datas);
|
||||
|
||||
if($return == false){
|
||||
$sql = "INSERT INTO \"".$table."\" ($fields) VALUES ($datas)";
|
||||
try{
|
||||
return $this->db->exec($sql);
|
||||
}catch (Exception $e) {
|
||||
if($this->product)
|
||||
{
|
||||
return false;
|
||||
}else{
|
||||
echo 'Caught exception: '. $e->getMessage(). "\n";
|
||||
}
|
||||
}
|
||||
}else{
|
||||
$sql = "INSERT INTO \"".$table."\" ($fields) VALUES ($datas) RETURNING id";
|
||||
try{
|
||||
$sth = $this->db->prepare($sql);
|
||||
if($sth->execute())
|
||||
{
|
||||
$temp = $sth->fetch(PDO::FETCH_ASSOC);
|
||||
return $temp['id'];
|
||||
}else{
|
||||
return false;
|
||||
}
|
||||
}catch (Exception $e) {
|
||||
if($this->product)
|
||||
{
|
||||
return false;
|
||||
}else{
|
||||
echo 'Caught exception: '. $e->getMessage(). "\n";
|
||||
}
|
||||
}
|
||||
}
|
||||
}//insert
|
||||
|
||||
function update($table,$data,$condition="",$return=false)
|
||||
{
|
||||
$ups = array();
|
||||
|
||||
foreach($data as $k=>$v)
|
||||
{
|
||||
if(is_int($v) || is_float($v) || is_bool($v))
|
||||
{
|
||||
$ups[] = '"'.$k.'"='.$v;
|
||||
}else{
|
||||
if(preg_match("/\'/",$v))
|
||||
{
|
||||
$v = preg_replace("/\'/","''",$v);
|
||||
}
|
||||
if(preg_match("/\"/",$v))
|
||||
{
|
||||
$v = preg_replace("/\"/","''",$v);
|
||||
}
|
||||
$ups[] = '"'.$k.'"=\''.$v."'";
|
||||
}
|
||||
}
|
||||
|
||||
$fields = join(",",$ups);
|
||||
|
||||
if(!empty($condition))
|
||||
{
|
||||
$wheresql = " WHERE ".$condition;
|
||||
}else{
|
||||
$wheresql = "";
|
||||
}
|
||||
|
||||
if($return == false){
|
||||
|
||||
try{
|
||||
$sql = "UPDATE \"".$table."\" SET $fields $wheresql";
|
||||
if($this->db->exec($sql))
|
||||
{
|
||||
return true;
|
||||
}else{
|
||||
return false;
|
||||
}
|
||||
}catch (Exception $e) {
|
||||
if($this->product)
|
||||
{
|
||||
return false;
|
||||
}else{
|
||||
echo 'Caught exception: '. $e->getMessage(). "\n";
|
||||
}
|
||||
}
|
||||
}else{
|
||||
try{
|
||||
$sql = "UPDATE \"".$table."\" SET $fields $wheresql";
|
||||
return $this->db->exec($sql);
|
||||
}catch (Exception $e) {
|
||||
if($this->product)
|
||||
{
|
||||
return false;
|
||||
}else{
|
||||
echo "<pre>";
|
||||
echo $sql."\r\n";
|
||||
echo 'Caught exception: '. $e->getMessage(). "\r\n";
|
||||
echo "</pre>";
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
}//update
|
||||
|
||||
}
|
||||
Loading…
Reference in New Issue