php_script/onlive/sync_order_u...

<?php
require_once 'DB_PDO.class.php';
require_once 'TBK.class.php';
require_once 'conf.class.php';

define("DETAILDEBUG", 0);//打印流程详细信息，如有需要，设为1
define("LIMIT_NUM", 0);//限制导入条数,0不限制,方便测试,上线设为0

date_default_timezone_set('PRC');
# 同步一天内的订单 3小时执行一次
$_time = 1200; 
$now = time();
sync_orders($_time, $now);
/**
 * 同步新订单
 */
function sync_orders($_time, $now){
	//同步订单脚本
	# 1.同步N分钟内所有订单
	//$now = strtotime('2019-01-21 16:54:00');
	//$time = date("Y-m-d H:i:s", strtotime('-27 hour'));
	$time = "2019-07-05 00:00:00";
	echo "\n\nCreate_time:".$time;
	$orderResult = array();
	for($x=0;$x<288;$x++){
		$dstr = $time.' '.($x*20).' minutes';
		$stime = date("Y-m-d H:i:s",strtotime($dstr));	
		//二方
		for($i=1;$i<100;$i++){
			$res1 = TBK::syncOrder($i,$stime,$_time,1,'create_time',1,1);  //$page,$stime,$time,$tk_status,$time_type,$order_count_type,$order_scene
			if(empty($res1)){
				break;
			}
			$orderResult = array_merge($orderResult, $res1);
		}
		
		//三方
		for($i=1;$i<100;$i++){
			$res3 = TBK::syncOrder($i,$stime,$_time,1,'create_time',2,1);  //$page,$stime,$time,$tk_status,$time_type,$order_count_type,$order_scene
			if(empty($res3)){
				break;
			}
			$orderResult = array_merge($orderResult, $res3);
		}	
	}

	# 统计
	$res_count = array(
		'total_num' => 0,
		'insert_num' => 0,
		'fail_num' => 0,
		'update_num' => 0,
		'nshoud_update_num' =>0 ,	
	);

	#初始化pdo
	$_PDO=DB_PDO::getInstance( conf::$DB_CONF );

	foreach($orderResult as $k=>$orderDetail){
		$res_count['total_num']++;
			echo "/ ************************ order{$res_count['total_num']}-Start ************************* / \n";
			if(!isset($orderDetail['earning_time'])) $orderDetail['earning_time'] = '2000-00-00 00:00:00';
		if(!isset($orderDetail['click_time'])) $orderDetail['click_time'] = $orderDetail['create_time'];
	        if(!isset($orderDetail['special_id'])) $orderDetail['special_id'] = 0;
	        if(!isset($orderDetail['relation_id'])) $orderDetail['relation_id'] = 0;
	        if(!isset($orderDetail['total_commission_fee'])) $orderDetail['total_commission_fee'] = 0;
	        if(!isset($orderDetail['subsidy_fee'])) $orderDetail['subsidy_fee'] = 0;
	        if(!isset($orderDetail['pay_price'])) $orderDetail['pay_price'] = 0;
	        if(!isset($orderDetail['commission'])) $orderDetail['commission'] = 0;
	        if(!isset($orderDetail['subsidy_type'])) $orderDetail['subsidy_type'] = 0;
	        if(!isset($orderDetail['tk3rd_type'])) $orderDetail['tk3rd_type'] = '--';
	        if(!isset($orderDetail['site_name'])) $orderDetail['site_name'] = '';
	        if(!isset($orderDetail['adzone_name'])) $orderDetail['adzone_name'] = '';
	        if(!isset($orderDetail['pub_share_pre_fee'])) $orderDetail['pub_share_pre_fee'] = 0;
		    if(!isset($orderDetail['alipay_total_price'])) $orderDetail['alipay_total_price'] = 0;

	    	echo 'order_id:'.$orderDetail['trade_id'].'|| goods_id:'.$orderDetail['num_iid'].'|| orderstatus:'.$orderDetail['tk_status'].'|| order_balance_at:'.$orderDetail['earning_time'].'|| order_create_time:'.$orderDetail['create_time'];
			if( DETAILDEBUG == 1){
				echo 'orderDetail:';
				var_dump($orderDetail);
			}

			$sql = "select id,tk_status from zbds_taoke_orders where trade_id = '".$orderDetail['trade_id']."' and num_iid = '".$orderDetail['num_iid']."' limit 1";
			$stmt = $_PDO->prepare($sql);
	        	$stmt->execute();
	        	$result = $stmt->fetch(PDO::FETCH_ASSOC);
			if(!empty($result)){
				echo "\n 该订单已存在，更新操作";
				if($orderDetail['tk_status'] != $result['tk_status']){
					//更新操作
					$sql = "update zbds_taoke_orders set tk_status={$orderDetail['tk_status']},earning_time='".$orderDetail['earning_time']."' WHERE trade_id = '".$orderDetail['trade_id']."' and num_iid = '".$orderDetail['num_iid']."'";
					$stmt = $_PDO->prepare($sql);  
					$stmt->execute();
					$res = $stmt->rowCount();

					if($res){
						echo "\n 更新成功 +1";
						$res_count['update_num']++;
					}else{
						echo "\n 更新失败 +1";
			            $res_count['fail_num']++;
					}
				}else{
					echo "\n 状态未变，不做处理 +1";
					$res_count['nshoud_update_num']++;
				}
		
			}else{
			
				//create_time,click_time,item_title,num_iid,seller_nick,seller_shop_title,item_num,price,tk_status,order_type,income_rate,commission_rate,pay_price,pub_share_pre_fee,alipay_total_price,commission,earning_time,total_commission_rate,total_commission_fee,subsidy_rate,subsidy_fee,subsidy_type,terminal_type,tk3rd_type,trade_parent_id,trade_id,auction_category,site_id,site_name,adzone_id,adzone_name,relation_id,special_id
				$res = insertOrder($orderDetail,$res_count);				
			}
		echo "\n/ ** order{$res_count['total_num']}-End ** /";
	}
	echo "\n同步订单：";
	var_dump($res_count);
}

function insertOrder($orderDetail, &$res_count){
	
	$orderDetail['item_title'] = addslashes($orderDetail['item_title']);
    $orderDetail['seller_nick'] = addslashes($orderDetail['seller_nick']);
    $orderDetail['seller_shop_title'] = addslashes($orderDetail['seller_shop_title']);

	$sql = "insert into zbds_taoke_orders(create_time,click_time,item_title,num_iid,seller_nick,seller_shop_title,item_num,price,tk_status,order_type,income_rate,commission_rate,pay_price,pub_share_pre_fee,alipay_total_price,commission,earning_time,total_commission_rate,total_commission_fee,subsidy_rate,subsidy_fee,subsidy_type,terminal_type,tk3rd_type,trade_parent_id,trade_id,auction_category,site_id,site_name,adzone_id,adzone_name,relation_id,special_id) values('".$orderDetail['create_time']."', '". $orderDetail['click_time']."', '". $orderDetail['item_title']."', '". $orderDetail['num_iid']."', '". $orderDetail['seller_nick']."', '". $orderDetail['seller_shop_title']."', '". $orderDetail['item_num']."', '". $orderDetail['price']."', '". $orderDetail['tk_status']."', '". $orderDetail['order_type']."', '". $orderDetail['income_rate']."', '". $orderDetail['commission_rate']."', '". $orderDetail['pay_price']."', '". $orderDetail['pub_share_pre_fee']."', '". $orderDetail['alipay_total_price']."', '". $orderDetail['commission']."', '". $orderDetail['earning_time']."', '". $orderDetail['total_commission_rate']."', '". $orderDetail['total_commission_fee']."', '". $orderDetail['subsidy_rate']."', '". $orderDetail['subsidy_fee']."', '". $orderDetail['subsidy_type']."', '". $orderDetail['terminal_type']."', '". $orderDetail['tk3rd_type']."', '". $orderDetail['trade_parent_id']."', '". $orderDetail['trade_id']."', '". $orderDetail['auction_category']."', '". $orderDetail['site_id']."', '". $orderDetail['site_name']."', '". $orderDetail['adzone_id']."', '". $orderDetail['adzone_name']."', '". $orderDetail['relation_id']."', '". $orderDetail['special_id']."')";

	$_PDO=DB_PDO::getInstance( conf::$DB_CONF );
	$stmt = $_PDO->prepare($sql);
            $stmt->execute();
	$res = $_PDO->lastinsertid();
	if($res){
		echo "\n 插入成功 +1";
		$res_count['insert_num']++;
	}else{
		echo "\n 插入失败 +1";
        $res_count['fail_num']++;
	}
	return $res;
}