Merge branch 'sh/d1'

scan_orderv4_liedou.php

@@ -63,6 +63,7 @@ function readDataFromDb(){
 		}
         //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
 
+        $ptype = $orderDetail["ptype"];
 		$order_id=$orderDetail["trade_id"];
         $update_time=$orderDetail["update_time"];
         $order_create_at=$orderDetail["create_time"];
@@ -87,6 +88,8 @@ function readDataFromDb(){
         }
         elseif($statusDesc=="3"){
             $orderStatus=2;
+        } else {
+            continue; //其他状态：待付款，已付定金，不做处理；
         }
         if($typeDesc=="聚划算"){
             $type=0;
@@ -96,7 +99,10 @@ function readDataFromDb(){
         }
         elseif($typeDesc=="天猫"){
             $type=2;
-        }
+        } 
+        elseif($typeDesc=="京东"){
+            $type=3;
+        } 
 
         $adzone_id=$orderDetail["adzone_id"];
         $relation_id = $orderDetail["relation_id"];
@@ -108,7 +114,7 @@ function readDataFromDb(){
     	echo 'order_id:'.$order_id.'|| goods_id:'.$goods_id.'|| orderstatus:'.$orderStatus.'|| order_balance_at:'.$order_balance_at;
 		echo '|| predict_income:'.$predict_income.'|| adzone_id:'.$adzone_id.'|| special_id:'.$special_id.'|| relation_id:'.$relation_id."\n";
 
-        $resultone=UserInfo($special_id, $relation_id, $adzone_id);
+        $resultone=UserInfo($special_id, $relation_id, $adzone_id, $ptype);
 
 		if( DETAILDEBUG == 1){
 			echo 'userinfo:';
@@ -154,22 +160,27 @@ function readDataFromDb(){
 					echo 'rebateInfo'."\n";
 					var_dump($moneyInfo);
 				}
-            	$detail = TBK::tbkItemInfoGet( ['goods_id'=>$goods_id] );
-                if( !empty($detail) ){
-                    $goods_img=$detail->pict_url;
+
+                if($ptype == 2){
+                    $goods_img = $orderDetail["img"];
                 } else {
-                    echo json_encode($detail, 256)."\n";
-                    echo "淘宝客商品详情接口未获取到商品信息，开始调用淘宝客物料搜索接口"."\n";
-                    # 调用淘宝客【推广者-物料搜索】api
-                    $goodsKey = "https://uland.taobao.com/item/edetail?id=".$goods_id;
-                    $goodsList = TBK::search($goodsKey);
-                    if (!empty($goodsList['list'])) {
-                        $goodsDetail = $goodsList['list'][0];
-                        $goods_img = $goodsDetail->pict_url;
-                        echo "通过物料搜索接口获取到商品图"."\n";
+                	$detail = TBK::tbkItemInfoGet( ['goods_id'=>$goods_id] );
+                    if( !empty($detail) ){
+                        $goods_img=$detail->pict_url;
                     } else {
-                        echo "物料搜索接口仍未获取到商品图".json_encode($goodsList, 256)."\n";
-                        $goods_img="";
+                        echo json_encode($detail, 256)."\n";
+                        echo "淘宝客商品详情接口未获取到商品信息，开始调用淘宝客物料搜索接口"."\n";
+                        # 调用淘宝客【推广者-物料搜索】api
+                        $goodsKey = "https://uland.taobao.com/item/edetail?id=".$goods_id;
+                        $goodsList = TBK::search($goodsKey);
+                        if (!empty($goodsList['list'])) {
+                            $goodsDetail = $goodsList['list'][0];
+                            $goods_img = $goodsDetail->pict_url;
+                            echo "通过物料搜索接口获取到商品图"."\n"; 
+                        } else {
+                            echo "物料搜索接口仍未获取到商品图".json_encode($goodsList, 256)."\n";
+                            $goods_img="";
+                        }
                     }
                 }
 
@@ -194,7 +205,7 @@ function readDataFromDb(){
             			    if($v>0){
             				#order_rebate表插入父级佣金
             				$rebaseType=$TypeArr[$k];
-            				$res=generateSqlInsertRebateSelf($userLevel[$k],$order_balance_at,$order_create_at,$goods_img,$goods_name,$order_id,$userList[$k],$rebaseType,$moneyInfo[$k],$sum_price,$orderStatus,$goods_id,$predict_income);
+            				$res=generateSqlInsertRebateSelf($userLevel[$k],$order_balance_at,$order_create_at,$goods_img,$goods_name,$order_id,$userList[$k],$rebaseType,$moneyInfo[$k],$sum_price,$orderStatus,$goods_id,$predict_income, $ptype);
             							# 推送
                             $flag_time = time() - strtotime($order_create_at);
             				if($res && $flag_time<3600){
@@ -296,7 +307,7 @@ function readDataFromDb(){
                                                                 if($YysManageRabate < 1){
                                                                         $YysManageRabate = 1;
                                                                 }
-                                                                $res = YysManageInsertRebate(4,$order_balance_at,$order_create_at,$goods_img,$goods_name,$order_id,$YysManageInfo['user_id'],$rebaseType,$YysManageRabate,$sum_price,$orderStatus,$goods_id,$predict_income);
+                                                                $res = YysManageInsertRebate(4,$order_balance_at,$order_create_at,$goods_img,$goods_name,$order_id,$YysManageInfo['user_id'],$rebaseType,$YysManageRabate,$sum_price,$orderStatus,$goods_id,$predict_income,$ptype);
                                                                 echo 'rebateinsert_YysManage:'.$res;
                                                                 echo "\n";
                                                         }
@@ -374,24 +385,30 @@ function readDataFromDb(){
 	            $ordernoExists=orderMysql($order_id,$goods_id);            	            
             
 	            if( empty($ordernoExists) ){
-	                $detail = TBK::tbkItemInfoGet( ['goods_id'=>$goods_id] );                
-	                if( !empty($detail) ){
-	                	$goods_img=$detail->pict_url;
-	                } else {
-                        echo json_encode($detail, 256)."\n";
-	                    echo "淘宝客商品详情接口未获取到商品信息，开始调用淘宝客物料搜索接口"."\n";
-                        # 调用淘宝客【推广者-物料搜索】api
-                        $goodsKey = "https://uland.taobao.com/item/edetail?id=".$goods_id;
-                        $goodsList = TBK::search($goodsKey);
-                        if (!empty($goodsList['list'])) {
-                            $goodsDetail = $goodsList['list'][0];
-                            $goods_img = $goodsDetail->pict_url;
-                            echo "通过物料搜索接口获取到商品图"."\n";
-                        } else {
-                            echo "物料搜索接口仍未获取到商品图".json_encode($goodsList, 256)."\n";
-                            $goods_img="";
-                        }
-	                }
+
+                    if($ptype == 2){
+                        $goods_img = $orderDetail["img"];;
+                    } else {
+    	                $detail = TBK::tbkItemInfoGet( ['goods_id'=>$goods_id] );                
+    	                if( !empty($detail) ){
+    	                	$goods_img=$detail->pict_url;
+    	                } else {
+                            echo json_encode($detail, 256)."\n";
+    	                    echo "淘宝客商品详情接口未获取到商品信息，开始调用淘宝客物料搜索接口"."\n";
+                            # 调用淘宝客【推广者-物料搜索】api
+                            $goodsKey = "https://uland.taobao.com/item/edetail?id=".$goods_id;
+                            $goodsList = TBK::search($goodsKey);
+                            if (!empty($goodsList['list'])) {
+                                $goodsDetail = $goodsList['list'][0];
+                                $goods_img = $goodsDetail->pict_url;
+                                echo "通过物料搜索接口获取到商品图"."\n";
+                            } else {
+                                echo "物料搜索接口仍未获取到商品图".json_encode($goodsList, 256)."\n";
+                                $goods_img="";
+                            }
+    	                }
+
+                    }
 	                $res=generateSqlInsertOrderOther($goods_img,$goods_name,$order_id,$adzone_id,$goods_id,$num,$price,$sum_price,$predict_income,0,$orderStatus,$type,$order_create_at,$order_click_at,$order_balance_at);                        
 					if($res){
                         $res_count['nouserinsert_num']++;
@@ -522,7 +539,12 @@ function YysInfo( $user_id ){
         return ['user_id'=>48941,'level'=>4,'parent_user_id'=>'-1'];
 }
 
-function UserInfo($special_id, $relation_id, $adzone_id){
+function UserInfo($special_id, $relation_id, $adzone_id, $ptype=1){
+
+    if($ptype == 2){
+        return JdUserInfo($relation_id);
+    }
+
     $_PDO=DB_PDO::getInstance( conf::$DB_CONF );
     //新加逻辑 2020-7-8 封relation不分佣
     $sql = "SELECT value FROM global_variable WHERE variable_key ='relation_blacklist' ";
@@ -535,7 +557,6 @@ function UserInfo($special_id, $relation_id, $adzone_id){
         }
     }
 
-
     if(in_array($adzone_id,[123456])){
         return false;
     }
@@ -570,6 +591,30 @@ function UserInfo($special_id, $relation_id, $adzone_id){
     }
 }
 
+function JdUserInfo($relation_id){
+    if(!$relation_id){
+        return false;
+    }
+
+    $_PDO=DB_PDO::getInstance( conf::$DB_CONF );
+
+    $sql = "SELECT id FROM users WHERE invite_code = '{$relation_id}'";
+    $stmt = $_PDO->prepare($sql);  
+    $stmt->execute();    
+    $resultone = $stmt->fetch(PDO::FETCH_ASSOC);
+
+    if(!empty($resultone)){
+        $sql="SELECT * FROM user_level WHERE user_id = :user_id";
+        $stmt = $_PDO->prepare($sql);  
+        $stmt->execute(array(':user_id'=>$resultone['id']));    
+        $userResult = $stmt->fetch(PDO::FETCH_ASSOC);
+        return $userResult;
+    }
+    else{
+        return false;   
+    }
+}
+
 function userLevelInfo($user_id){	
     $sql="SELECT * FROM user_level WHERE user_id = :user_id ";
     $_PDO=DB_PDO::getInstance( conf::$DB_CONF );
@@ -736,18 +781,18 @@ function generateSqlInsertOrder($goods_img,$goods_name,$userId,$order_id,$adzone
     }
 }    
 #返利表订单插入脚本
-function generateSqlInsertRebateSelf($user_level,$order_balance_at,$order_create_at,$goods_img,$goods_name,$order_id,$userId,$rebaseType,$last_orderSelfRebaseRebase,$sum_price,$orderStatus,$goods_id,$pre_income){
+function generateSqlInsertRebateSelf($user_level,$order_balance_at,$order_create_at,$goods_img,$goods_name,$order_id,$userId,$rebaseType,$last_orderSelfRebaseRebase,$sum_price,$orderStatus,$goods_id,$pre_income,$ptype){
     $_PDO=DB_PDO::getInstance( conf::$DB_CONF );
     if( !empty($order_balance_at) ){
-        $sql="insert into order_rebate (user_level,order_balance_at,order_create_at,img,name,order_id,user_id,type,rebate,money,status,goods_id,pre_income) VALUES (:user_level,:order_balance_at,:order_create_at,:goods_img,:goods_name,:order_id,:userId,:rebaseType,:last_orderSelfRebaseRebase,:sum_price,:orderStatus,:goods_id,:pre_income)";
+        $sql="insert into order_rebate (user_level,order_balance_at,order_create_at,img,name,order_id,user_id,type,rebate,money,status,goods_id,pre_income,ptype) VALUES (:user_level,:order_balance_at,:order_create_at,:goods_img,:goods_name,:order_id,:userId,:rebaseType,:last_orderSelfRebaseRebase,:sum_price,:orderStatus,:goods_id,:pre_income,:ptype)";
         $stmt = $_PDO->prepare($sql);  
-		$stmt->execute(array(':user_level'=>$user_level,':order_balance_at'=>$order_balance_at,':order_create_at'=>$order_create_at,':goods_img'=>$goods_img,':goods_name'=>$goods_name,':order_id'=>$order_id,':userId'=>$userId,':rebaseType'=>$rebaseType,':last_orderSelfRebaseRebase'=>$last_orderSelfRebaseRebase,':sum_price'=>$sum_price,':orderStatus'=>$orderStatus,':goods_id'=>$goods_id,':pre_income'=>$pre_income));
+		$stmt->execute(array(':user_level'=>$user_level,':order_balance_at'=>$order_balance_at,':order_create_at'=>$order_create_at,':goods_img'=>$goods_img,':goods_name'=>$goods_name,':order_id'=>$order_id,':userId'=>$userId,':rebaseType'=>$rebaseType,':last_orderSelfRebaseRebase'=>$last_orderSelfRebaseRebase,':sum_price'=>$sum_price,':orderStatus'=>$orderStatus,':goods_id'=>$goods_id,':pre_income'=>$pre_income,':ptype'=>$ptype));
 		return $_PDO->lastinsertid();
     }
     else{
-        $sql="insert into order_rebate (user_level,order_create_at,img,name,order_id,user_id,type,rebate,money,status,goods_id,pre_income) VALUES (:user_level,:order_create_at,:goods_img,:goods_name,:order_id,:userId,:rebaseType,:last_orderSelfRebaseRebase,:sum_price,:orderStatus,:goods_id,:pre_income)";
+        $sql="insert into order_rebate (user_level,order_create_at,img,name,order_id,user_id,type,rebate,money,status,goods_id,pre_income,ptype) VALUES (:user_level,:order_create_at,:goods_img,:goods_name,:order_id,:userId,:rebaseType,:last_orderSelfRebaseRebase,:sum_price,:orderStatus,:goods_id,:pre_income,:ptype)";
         $stmt = $_PDO->prepare($sql);  
-		$stmt->execute(array(':user_level'=>$user_level,':order_create_at'=>$order_create_at,':goods_img'=>$goods_img,':goods_name'=>$goods_name,':order_id'=>$order_id,':userId'=>$userId,':rebaseType'=>$rebaseType,':last_orderSelfRebaseRebase'=>$last_orderSelfRebaseRebase,':sum_price'=>$sum_price,':orderStatus'=>$orderStatus,':goods_id'=>$goods_id,':pre_income'=>$pre_income));
+		$stmt->execute(array(':user_level'=>$user_level,':order_create_at'=>$order_create_at,':goods_img'=>$goods_img,':goods_name'=>$goods_name,':order_id'=>$order_id,':userId'=>$userId,':rebaseType'=>$rebaseType,':last_orderSelfRebaseRebase'=>$last_orderSelfRebaseRebase,':sum_price'=>$sum_price,':orderStatus'=>$orderStatus,':goods_id'=>$goods_id,':pre_income'=>$pre_income,':ptype'=>$ptype));
 		return $_PDO->lastinsertid();
     }
 }
@@ -771,18 +816,18 @@ function YysInsertRebate($user_level,$order_balance_at,$order_create_at,$goods_i
 
 
 #返利表订单插入运营商津贴信息
-function YysManageInsertRebate($user_level,$order_balance_at,$order_create_at,$goods_img,$goods_name,$order_id,$userId,$rebaseType,$last_orderSelfRebaseRebase,$sum_price,$orderStatus,$goods_id,$pre_income){
+function YysManageInsertRebate($user_level,$order_balance_at,$order_create_at,$goods_img,$goods_name,$order_id,$userId,$rebaseType,$last_orderSelfRebaseRebase,$sum_price,$orderStatus,$goods_id,$pre_income,$ptype=1){
     $_PDO=DB_PDO::getInstance( conf::$DB_CONF );
     if( !empty($order_balance_at) ){
-        $sql="insert into order_rebate_profit (user_level,order_balance_at,order_create_at,img,name,order_id,user_id,type,rebate,money,status,goods_id,pre_income) VALUES (:user_level,:order_balance_at,:order_create_at,:goods_img,:goods_name,:order_id,:userId,:rebaseType,:last_orderSelfRebaseRebase,:sum_price,:orderStatus,:goods_id,:pre_income)";
+        $sql="insert into order_rebate_profit (user_level,order_balance_at,order_create_at,img,name,order_id,user_id,type,rebate,money,status,goods_id,pre_income,ptype) VALUES (:user_level,:order_balance_at,:order_create_at,:goods_img,:goods_name,:order_id,:userId,:rebaseType,:last_orderSelfRebaseRebase,:sum_price,:orderStatus,:goods_id,:pre_income,:ptype)";
         $stmt = $_PDO->prepare($sql);  
-		$stmt->execute(array(':user_level'=>$user_level,':order_balance_at'=>$order_balance_at,':order_create_at'=>$order_create_at,':goods_img'=>$goods_img,':goods_name'=>$goods_name,':order_id'=>$order_id,':userId'=>$userId,':rebaseType'=>$rebaseType,':last_orderSelfRebaseRebase'=>$last_orderSelfRebaseRebase,':sum_price'=>$sum_price,':orderStatus'=>$orderStatus,':goods_id'=>$goods_id,':pre_income'=>$pre_income));
+		$stmt->execute(array(':user_level'=>$user_level,':order_balance_at'=>$order_balance_at,':order_create_at'=>$order_create_at,':goods_img'=>$goods_img,':goods_name'=>$goods_name,':order_id'=>$order_id,':userId'=>$userId,':rebaseType'=>$rebaseType,':last_orderSelfRebaseRebase'=>$last_orderSelfRebaseRebase,':sum_price'=>$sum_price,':orderStatus'=>$orderStatus,':goods_id'=>$goods_id,':pre_income'=>$pre_income,':ptype'=>$ptype));
 		return $_PDO->lastinsertid();
     }
     else{
-        $sql="insert into order_rebate_profit (user_level,order_create_at,img,name,order_id,user_id,type,rebate,money,status,goods_id,pre_income) VALUES (:user_level,:order_create_at,:goods_img,:goods_name,:order_id,:userId,:rebaseType,:last_orderSelfRebaseRebase,:sum_price,:orderStatus,:goods_id,:pre_income)";
+        $sql="insert into order_rebate_profit (user_level,order_create_at,img,name,order_id,user_id,type,rebate,money,status,goods_id,pre_income,ptype) VALUES (:user_level,:order_create_at,:goods_img,:goods_name,:order_id,:userId,:rebaseType,:last_orderSelfRebaseRebase,:sum_price,:orderStatus,:goods_id,:pre_income,:ptype)";
         $stmt = $_PDO->prepare($sql);  
-		$stmt->execute(array(':user_level'=>$user_level,':order_create_at'=>$order_create_at,':goods_img'=>$goods_img,':goods_name'=>$goods_name,':order_id'=>$order_id,':userId'=>$userId,':rebaseType'=>$rebaseType,':last_orderSelfRebaseRebase'=>$last_orderSelfRebaseRebase,':sum_price'=>$sum_price,':orderStatus'=>$orderStatus,':goods_id'=>$goods_id,':pre_income'=>$pre_income));
+		$stmt->execute(array(':user_level'=>$user_level,':order_create_at'=>$order_create_at,':goods_img'=>$goods_img,':goods_name'=>$goods_name,':order_id'=>$order_id,':userId'=>$userId,':rebaseType'=>$rebaseType,':last_orderSelfRebaseRebase'=>$last_orderSelfRebaseRebase,':sum_price'=>$sum_price,':orderStatus'=>$orderStatus,':goods_id'=>$goods_id,':pre_income'=>$pre_income,':ptype'=>$ptype));
 		return $_PDO->lastinsertid();
     }
 }