From e0ab588c60a0e1968cca8b699beb716c99ae8237 Mon Sep 17 00:00:00 2001 From: 13146336667 <33367671@qq.com> Date: Thu, 11 Aug 2022 18:25:51 +0800 Subject: [PATCH] sync push data add log --- queue/crontab/sync_push_data.php | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/queue/crontab/sync_push_data.php b/queue/crontab/sync_push_data.php index 63c9292..e11a0f2 100644 --- a/queue/crontab/sync_push_data.php +++ b/queue/crontab/sync_push_data.php @@ -3,7 +3,7 @@ /** * 同步推送数据 */ -include_once dirname(dirname(__FILE__)).'/base/dealBase.php'; +include_once(dirname(dirname(dirname(__FILE__)))."/library/publicBase.php"); class syncPushData { private $table; @@ -18,7 +18,10 @@ class syncPushData { public function __construct() { $obj = new mOrder(); +$obj->writeLog('pdd', 'sync_push_data.log', 'exec'); + $info = $obj->getSyncDataModifyTime(); +$obj->writeLog('pdd', 'sync_push_data.log', $info['pdp_modified']); 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); @@ -30,6 +33,8 @@ class syncPushData { $end = date("Y-m-d H:i:s", strtotime($start)+300); +$obj->writeLog('pdd', 'sync_push_data.log', $start."|".$end); + $list = $this->selectAll('pdp_tb_trade', array('sql'=>'`pdp_modified` >=? and `pdp_modified` <= ?', 'vals'=>array($start, $end)), 'pdp_modified desc'); foreach ($list as $info) { @@ -112,7 +117,7 @@ class syncPushData { $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->writeLog('pdd', 'sync_push_data.log', $order['order_sn'].'|'.$res); } $obj->updateSyncDataModifyTime($info['id'], $end);