|
|
@ -36,6 +36,17 @@ $obj->writeLog('pdd', 'sync_push_data.log', $info['pdp_modified']); |
|
|
|
$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'); |
|
|
|
|
|
|
|
$this->adddata($list); |
|
|
|
|
|
|
|
$modified = strtotime($end) <= time() ? $end : date("Y-m-d H:i:s"); |
|
|
|
|
|
|
|
$obj->updateSyncDataModifyTime($info['id'], $modified); |
|
|
|
} |
|
|
|
|
|
|
|
private function adddata($list) { |
|
|
|
$obj = new mOrder(); |
|
|
|
|
|
|
|
if (empty($list)) { |
|
|
|
$obj->writeLog('pdd', 'sync_push_data.log', 'empty list'); |
|
|
|
return true; |
|
|
@ -124,7 +135,7 @@ $obj->writeLog('pdd', 'sync_push_data.log', 'empty list'); |
|
|
|
$obj->writeLog('pdd', 'sync_push_data.log', $order['order_sn'].'|'.$res); |
|
|
|
} |
|
|
|
|
|
|
|
$obj->updateSyncDataModifyTime($info['id'], $end); |
|
|
|
return true; |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|