11 changed files with 350 additions and 36 deletions
@ -1 +1,3 @@ |
|||
* * * * * /usr/bin/php /var/www/html/queue/cron_monitor.php |
|||
* * * * * /usr/bin/php /var/www/html/queue/cron_monitor.php |
|||
|
|||
*/5 * * * * /usr/bin/php /var/www/html/queue/crontab/sync_push_data.php |
|||
@ -0,0 +1,279 @@ |
|||
<?php |
|||
|
|||
/** |
|||
* 同步推送数据 |
|||
*/ |
|||
include_once dirname(dirname(__FILE__)).'/base/dealBase.php'; |
|||
|
|||
class syncPushData { |
|||
private $table; |
|||
|
|||
protected $dbflag = 'pushdata'; |
|||
private static $db_w = null; |
|||
private static $db_r = null; |
|||
private static $link; |
|||
|
|||
private $ismaster = false; |
|||
|
|||
|
|||
public function __construct() { |
|||
$obj = new mOrder(); |
|||
$info = $obj->getSyncDataModifyTime(); |
|||
if ($info['pdp_modified'] == '0000-00-00 00:00:00') { |
|||
$sql = "select min(pdp_modified) as pdp_modified from `pdp_tb_trade`"; |
|||
$r = $this->execute($sql, false, true); |
|||
|
|||
$start = $r['pdp_modified']; |
|||
} else { |
|||
$start = $info['pdp_modified']; |
|||
} |
|||
|
|||
$end = date("Y-m-d H:i:s", strtotime($start)+300); |
|||
|
|||
$list = $this->selectAll('pdp_tb_trade', array('sql'=>'`pdp_modified` >=? and `pdp_modified` <= ?', 'vals'=>array($start, $end)), 'pdp_modified desc'); |
|||
|
|||
foreach ($list as $info) { |
|||
if (empty($info['pdp_response'])) continue; |
|||
|
|||
$order = json_decode($info['pdp_response'], true); |
|||
|
|||
/* |
|||
array(17) { |
|||
["order_sn"]=> |
|||
string(22) "220811-669893293090781" |
|||
["trade_type"]=> |
|||
int(0) |
|||
["order_status"]=> |
|||
int(2) |
|||
["group_status"]=> |
|||
int(1) |
|||
["confirm_status"]=> |
|||
int(1) |
|||
["refund_status"]=> |
|||
int(1) |
|||
["after_sales_status"]=> |
|||
int(0) |
|||
["risk_control_status"]=> |
|||
int(0) |
|||
["created_time"]=> |
|||
string(19) "2022-08-11 10:58:31" |
|||
["pay_time"]=> |
|||
string(19) "2022-08-11 10:58:40" |
|||
["confirm_time"]=> |
|||
string(19) "2022-08-11 10:58:40" |
|||
["last_ship_time"]=> |
|||
string(19) "2022-08-13 10:58:40" |
|||
["updated_at"]=> |
|||
string(19) "2022-08-11 11:01:12" |
|||
["pay_amount"]=> |
|||
float(10.3) |
|||
["item_list"]=> |
|||
array(1) { |
|||
[0]=> |
|||
array(6) { |
|||
["goods_id"]=> |
|||
int(329073140054) |
|||
["sku_id"]=> |
|||
int(1119777051922) |
|||
["goods_name"]=> |
|||
string(87) "万方查重万方数据官网本科硕士博士毕业论文查重论文检测系统2.0" |
|||
["goods_price"]=> |
|||
float(2.6) |
|||
["goods_spec"]=> |
|||
string(42) "万方通用版（期刊作业报告等）" |
|||
["goods_count"]=> |
|||
int(4) |
|||
} |
|||
} |
|||
["buyer_memo"]=> |
|||
string(0) "" |
|||
["urge_shipping_time"]=> |
|||
string(0) "" |
|||
} |
|||
|
|||
*/ |
|||
|
|||
$obj->order_sn = $order['order_sn']; |
|||
$obj->order_status = $order['order_status']; |
|||
$obj->refund_status = $order['refund_status']; |
|||
$obj->after_sales_status = $order['after_sales_status']; |
|||
$obj->pay_amount = $order['pay_amount']; |
|||
$obj->pay_time = $order['pay_time']; |
|||
$obj->goods_id = $order['item_list'][0]['goods_id']; |
|||
$obj->sku_id = $order['item_list'][0]['sku_id']; |
|||
$obj->goods_price = $order['item_list'][0]['goods_price']; |
|||
$obj->goods_count = $order['item_list'][0]['goods_count']; |
|||
$obj->urge_shipping_time = $order['urge_shipping_time']; |
|||
$obj->last_ship_time = $order['last_ship_time']; |
|||
$obj->buyer_memo = $order['buyer_memo']; |
|||
$obj->risk_control_status = $order['risk_control_status']; |
|||
|
|||
$sobj = new mShop(); |
|||
$shop = $sobj->getShopByOwnerid($info['mall_id']); |
|||
|
|||
$res = $obj->addOrder($shop['id'], $shop['uid']); |
|||
$obj->writeLog('pdd', 'sync_push_data.log', $start.'|'.$end.'|'.$order['order_sn'].'|'.$res); |
|||
} |
|||
|
|||
$obj->updateSyncDataModifyTime($info['id'], $end); |
|||
} |
|||
|
|||
/** |
|||
* 解析数据库配置信息 |
|||
* 获得数据库的相关连接信息 |
|||
* @param sting $dbflag 数据库标识 |
|||
* @param boolean $master 是否为主库 |
|||
*/ |
|||
private function parseDbCnf($dbflag,$master=false) { |
|||
$configs = parse_ini_file(_Storage_CNF_PATH, true); |
|||
$config = $configs[strtolower($dbflag)]; |
|||
|
|||
if($master) { |
|||
$host_port = $config['master']; |
|||
} else { |
|||
$host_port = $config['slave']; |
|||
} |
|||
$hps = explode(',', $host_port); |
|||
$random = rand(0, count($hps)-1); |
|||
$hp = $hps[$random]; |
|||
|
|||
list($host, $port) = explode(':', $hp); |
|||
|
|||
$cnf = array(); |
|||
$cnf['host'] = trim($host); |
|||
$cnf['port'] = trim($port); |
|||
$cnf['user'] = $master==false ? trim($config['user_r']) : trim($config['user']); |
|||
$cnf['pwd'] = $master==false ? trim($config['passwd_r']) : trim($config['passwd']); |
|||
$cnf['db'] = trim($config['db']); |
|||
return $cnf; |
|||
} |
|||
|
|||
private function getInstance() { |
|||
$dbpara = $this->ismaster==false ? 'db_r' : 'db_w'; |
|||
|
|||
if(!is_null(self::$$dbpara)) { |
|||
self::$link = self::$$dbpara; |
|||
|
|||
// 判断mysql是否gone away |
|||
$status = self::$link->getAttribute(PDO::ATTR_SERVER_INFO); |
|||
if($status == 'MySQL server has gone away') { |
|||
self::$link = self::$$dbpara = $this->toDb(); |
|||
} |
|||
} else { |
|||
self::$link = self::$$dbpara = $this->toDb(); |
|||
} |
|||
return self::$link; |
|||
} |
|||
|
|||
private function initDb($table, $ismaster=false) { |
|||
$this->table = $table; |
|||
$this->ismaster = $ismaster; |
|||
|
|||
return self::getInstance(); |
|||
} |
|||
|
|||
private function toDb() { |
|||
$type = strtolower($this->dbflag); |
|||
$cnf = $this->parseDbCnf($this->dbflag, $this->ismaster); |
|||
|
|||
if (count($cnf)<=0 && $cnf['host'] == '') { |
|||
return false; |
|||
} |
|||
try { |
|||
$conn[PDO::ATTR_TIMEOUT] = 3; |
|||
if($GLOBALS['pconnect_db']===true) $conn[PDO::ATTR_PERSISTENT] = true; |
|||
$conn[PDO::MYSQL_ATTR_INIT_COMMAND] = "SET NAMES UTF8;"; |
|||
$db = new PDO('mysql:host='.$cnf['host'].';port='.$cnf['port'].';dbname='.$cnf['db'],$cnf['user'],$cnf['pwd'], $conn); |
|||
} catch(PDOException $e) { |
|||
//error_log('['.date('Y-m-d H:i:s').'][first-fail]'.implode('|', $cnf).':'.$e->getMessage()."\n", 3, LOG_PATH_BASE.'/mysql/stat_todb_'.date('Y-m-d').'.log'); |
|||
|
|||
try { |
|||
$conn[PDO::ATTR_TIMEOUT] = 3; |
|||
if($GLOBALS['pconnect_db']===true) $conn[PDO::ATTR_PERSISTENT] = true; |
|||
$conn[PDO::MYSQL_ATTR_INIT_COMMAND] = "SET NAMES UTF8;"; |
|||
$db = new PDO('mysql:host='.$cnf['host'].';port='.$cnf['port'].';dbname='.$cnf['db'],$cnf['user'],$cnf['pwd'], $conn); |
|||
} catch(PDOException $e) { |
|||
//error_log('['.date('Y-m-d H:i:s').'][second-fail]'.implode('|', $cnf).':'.$e->getMessage()."\n", 3, LOG_PATH_BASE.'/mysql/stat_todb_'.date('Y-m-d').'.log'); |
|||
return false; |
|||
} |
|||
|
|||
//error_log('['.date('Y-m-d H:i:s').'][second-succ]'.implode('|', $cnf)."\n", 3, LOG_PATH_BASE.'/mysql/stat_todb_'.date('Y-m-d').'.log'); |
|||
return $db; |
|||
} |
|||
|
|||
//error_log('['.date('Y-m-d H:i:s').'][first-succ]'.implode('|', $cnf)."\n", 3, LOG_PATH_BASE.'/mysql/stat_todb_'.date('Y-m-d').'.log'); |
|||
return $db; |
|||
} |
|||
|
|||
/** |
|||
* 数据库Select多数据 |
|||
* 封装标准方法 |
|||
* @param string $table 表名 |
|||
* @param string $where where条件，比如：array('sql'=>'name1=? and name2=?', 'vals'=>array('name1', 'name2')) |
|||
* @param string $orderby 排序，比如："ctime desc, name asc" |
|||
* @param array $limit 读取数量 array(起始数, 数量) |
|||
*/ |
|||
public function selectAll($table, $where=array(), $orderby='', $limit=array()) { |
|||
$this->initDb($table); |
|||
|
|||
try { |
|||
$wheresql = ''; |
|||
if(!empty($where)) { |
|||
$wheresql = "WHERE {$where['sql']}"; |
|||
$vals = $where['vals']; |
|||
} |
|||
|
|||
$orderby = "ORDER BY {$orderby}"; |
|||
if($orderby === null) $orderby = ''; |
|||
|
|||
$limitstr = empty($limit) ? '' : "LIMIT {$limit[0]}, {$limit[1]}"; |
|||
$sql = "SELECT * FROM `{$this->table}` {$wheresql} {$orderby} {$limitstr}"; |
|||
$st = self::$link->prepare($sql); |
|||
$res = $st->execute($vals); |
|||
if(!$res) return false; |
|||
|
|||
return $st->fetchAll(PDO::FETCH_ASSOC); |
|||
|
|||
} catch(PDOException $e) { |
|||
return false; |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 执行SQL查询语句 |
|||
* |
|||
* 当SQL语句为查询语句时返回执行后的全部数据 |
|||
* @access public |
|||
* @param string $sql SQL语句 |
|||
* @param boolean $all_rows 是否显示全部数据开关，当为true时，显示全部数据，为false时，显示一行数据，默认为true |
|||
* @param boolean $is_select 是否为查询语句 |
|||
* @return array | void |
|||
*/ |
|||
public function execute($sql, $all_rows=true, $is_select=false) { |
|||
$sql = trim($sql); |
|||
if(!$sql) return false; |
|||
|
|||
$this->ismaster = $is_select==false ? true : false; |
|||
self::getInstance(); |
|||
try { |
|||
$st = self::$link->prepare($sql); |
|||
$res = $st->execute(); |
|||
if(!$res) { |
|||
error_log('['.date('Y-m-d H:i:s').']'.$sql.':'.json_encode($st->errorInfo())."\n", 3, LOG_PATH_BASE.'/mysql/execute_'.date('Y-m-d').'.log'); |
|||
return false; |
|||
} |
|||
|
|||
if(!$is_select) return $res; |
|||
if($all_rows==true) { |
|||
return $st->fetchAll(PDO::FETCH_ASSOC); |
|||
} else { |
|||
return $st->fetch(PDO::FETCH_ASSOC); |
|||
} |
|||
} catch(PDOException $e) { |
|||
return false; |
|||
} |
|||
} |
|||
|
|||
} |
|||
|
|||
new syncPushData(); |
|||
Loading…
Reference in new issue