通过天猫精品库API采集商品函数

goods.services.php 文件添加采集函数，利用天猫精品库API采集商品

    
    //add by wangtongphp QQ1006440989 通过天猫精品库API采集商品
    public function infinityCollect($q,$cat,$start,$sort,$brand,$post_fee,$start_price,$end_price,$aution_tag)
    {
        setTimeLimit(3600);
        global $_FANWE;
        include_once FANWE_ROOT.\'sdks/taobao/TopClient.php\';
        include_once FANWE_ROOT.\'sdks/taobao/request/TmallItemsDiscountSearchRequest.php\';
        Cache::getInstance()->loadCache(\'business\');
        
        $client = new TopClient;
        $client->appkey = trim($_FANWE[\'cache\'][\'business\'][\'taobao\'][\'app_key\']);
        $client->secretKey = trim($_FANWE[\'cache\'][\'business\'][\'taobao\'][\'app_secret\']);
        
        
        $req = new TmallItemsDiscountSearchRequest;
        $req->setQ("%E8%80%90%E5%85%8B");
        $req->setCat("2");
        $req->setStart(0);
        $req->setSort("sort=s");    
        $req->setBrand(20531);
        $req->setPostFee(-1);
        $req->setStartPrice("100");
        $req->setEndPrice("500");
        $req->setAuctionTag(3458);
        $resp = $client->execute($req);
        
        $result = array(\'status\'=>0,\'count\'=>0,\'max_page\'=>0);
        
        var_dump($resp);
        if(isset($resp->taobaoke_items) && isset($resp->taobaoke_items->taobaoke_item))
        {
            $max_page = ceil(((int)$resp->total_results) / 40);
            $list = (array)$resp->taobaoke_items;
            $list = $list[\'taobaoke_item\'];
            foreach($list as $item)
            {
                usleep(10);
                $item = (array)$item;
                $item[\'num_iid\'] = (float)$item[\'num_iid\'];
                $item[\'keyid\'] = \'taobao_\'.$item[\'num_iid\'];
                
                $bln = (int)FDB::resultFirst(\'SELECT COUNT(id) FROM \'.FDB::table(\'goods\')." WHERE keyid=\'".$item[\'keyid\']."\'");
                if($bln)
                    continue;
                    
                $bln = (int)FDB::resultFirst(\'SELECT COUNT(id) FROM \'.FDB::table(\'goods_disable\')." WHERE keyid=\'".$item[\'keyid\']."\'");
                if($bln)
                    continue;
                
                $item[\'nick\'] = addslashes($item[\'nick\']);
                //add by wangtongphp  如果不是天猫店铺，过滤掉；旗舰店、专卖店、专营店留下；
                if(!(mb_stripos($item[\'nick\'],\'旗舰店\')))
                {
                    continue;
                }
                
                
                $item[\'title\'] = addslashes(strip_tags($item[\'title\']));
                //add by wangtongphp  如果是男的，过滤；
                if(mb_stripos($item[\'title\'],\'男\'))
                {
                    continue;
                }
                
                $item[\'price\'] = (float)$item[\'price\'];
                $item[\'click_url\'] = addslashes($item[\'click_url\']);
                $item[\'shop_click_url\'] = addslashes($item[\'shop_click_url\']);
                $item[\'pic_url\'] = addslashes($item[\'pic_url\']);
                $item[\'item_location\'] = addslashes($item[\'item_location\']);
                $item[\'volume\'] = (int)$item[\'volume\'];
                $item[\'commission_rate\'] = (float)$item[\'commission_rate\'] / 100;
                $item[\'commission\'] = (float)$item[\'commission\'];
                $item[\'commission_num\'] = (int)$item[\'commission_num\'];
                $item[\'commission_volume\'] = (float)$item[\'commission_volume\'];
                FDB::insert(\'taobao_collect\',$item,false,true);
            }
            
            $result[\'status\'] = 1;
            $result[\'count\'] = count($list);
            $result[\'max_page\'] = $max_page;
        }
        return $result;
    }