php_script/liedou_order.../sync_liedou_...

<?php
define( "ROOT_PATH", dirname(dirname(__FILE__)) );
require_once ROOT_PATH.'/DB_PDO.class.php';
require_once ROOT_PATH.'/TBK_v2.class.php';
require_once ROOT_PATH.'/confv2.class.php';
require_once ROOT_PATH.'/RedisClass.php';

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

date_default_timezone_set('PRC');
 
sync_refund();

/**
 * 同步失效订单
 */
function sync_refund(){
	//同步订单脚本
	# 1.10分钟一次，同步2天内失效订单
	 
	$now = date('Y-m-d H:i:s');
	echo "\n\n脚本Start_time:".$now;
	$time = date("Y-m-d H:i:s", strtotime('-15 day'));
	echo "\nCreate_time:".$time;

	$etime = '';
	$orderResult = array();
	$time_type = 2;//按付款时间查
	$tk_status = 13;//查询失效状态订单

	for($x=1;$x<1081;$x++){
		$position_index = '';//查下一页必要参数
		$stime = !empty($etime) ? $etime : $time;
		$dstr = $time.' '.($x*20).' minutes';
		$etime = date("Y-m-d H:i:s",strtotime($dstr));	
		//渠道
		for($i=1;$i<100;$i++){
			$res = TBK::syncOrderNew($i,$stime, $etime, $time_type ,$tk_status,2,$position_index);
			if(empty($res)){
				break;
			}else{
				$orderData = $res['data'];
				$position_index = $res['position_index'];
			}
			$orderResult = array_merge($orderResult, $orderData);
		}

		$position_index = '';
		//会员
		for($i=1;$i<100;$i++){
			$res = TBK::syncOrderNew($i,$stime, $etime, $time_type ,$tk_status,3,$position_index);
			if(empty($res)){
				break;
			}else{
				$orderData = $res['data'];
				$position_index = $res['position_index'];
			}
			$orderResult = array_merge($orderResult, $orderData);
		}

	}	

	# 统计
	$res_count = array(
		'total_num' => 0,
		'insert_num' => 0,
		'update_num' => 0,
		'fail_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";			
	    	echo 'order_id:'.$orderDetail['trade_id'].'|| goods_id:'.$orderDetail['item_id'].'|| orderstatus:'.$orderDetail['tk_status'].'|| order_balance_at: || update_time:'.$now;
			if( DETAILDEBUG == 1){
				echo 'orderDetail:';
				var_dump($orderDetail);
			}

			# 花生联盟活跃relation逻辑 //退款逻辑跳过
			if($orderDetail['adzone_id'] == '102465800487'){
				echo "\n花生订单跳过\n";
				continue;
			}

			$sql = "select id,tk_status from liedou_taoke_orders where trade_id = '".$orderDetail['trade_id']."' and num_iid = '".$orderDetail['item_id']."' limit 1";
			$stmt = $_PDO->prepare($sql);
	        	$stmt->execute();
	        	$result = $stmt->fetch(PDO::FETCH_ASSOC);
			if(!empty($result)){
				if($orderDetail['tk_status'] != $result['tk_status']){
					//更新操作
					$sql = "update liedou_taoke_orders set tk_status={$orderDetail['tk_status']} WHERE trade_id = '".$orderDetail['trade_id']."' and num_iid = '".$orderDetail['item_id']."'";
					$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{
				if(!isset($orderDetail['tk_earning_time'])) $orderDetail['tk_earning_time'] = '2000-00-00 00:00:00';
			if(!isset($orderDetail['click_time'])) $orderDetail['click_time'] = $orderDetail['tk_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['pub_share_fee'])) $orderDetail['pub_share_fee'] = 0;
		        if(!isset($orderDetail['subsidy_type'])) $orderDetail['subsidy_type'] = 0;
		        if(!isset($orderDetail['flow_source'])) $orderDetail['flow_source'] = '--';
		        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;
			
				//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\n\n";
	}

	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']);
    if(!isset($orderDetail['special_id'])) $orderDetail['special_id'] = null;
    if(!isset($orderDetail['relation_id'])) $orderDetail['relation_id'] = null;
	$sql = "insert into liedou_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['tk_create_time']."', '". $orderDetail['click_time']."', '". $orderDetail['item_title']."', '". $orderDetail['item_id']."', '". $orderDetail['seller_nick']."', '". $orderDetail['seller_shop_title']."', '". $orderDetail['item_num']."', '". $orderDetail['item_price']."', '". $orderDetail['tk_status']."', '". $orderDetail['order_type']."', '". $orderDetail['income_rate']."', '". $orderDetail['pub_share_rate']."', '". $orderDetail['pay_price']."', '". $orderDetail['pub_share_pre_fee']."', '". $orderDetail['alipay_total_price']."', '". $orderDetail['pub_share_fee']."', '". $orderDetail['tk_earning_time']."', '". $orderDetail['total_commission_rate']."', '". $orderDetail['total_commission_fee']."', '". $orderDetail['subsidy_rate']."', '". $orderDetail['subsidy_fee']."', '". $orderDetail['subsidy_type']."', '". $orderDetail['terminal_type']."', '". $orderDetail['flow_source']."', '". $orderDetail['trade_parent_id']."', '". $orderDetail['trade_id']."', '". $orderDetail['item_category_name']."', '". $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;
}