= db_find('taobao_xianbao',array('tid' => 0,'cid'=>array('!='=>'0')), array('id'=>-1), 1, $pagesize = 10);
//print_r($xianbaolist);
##需要有内容
foreach($xianbaolist as $xianbao){
//发布文章
create_thread_from_xianbao($xianbao);
}
echo date('Y-m-d H:i:s');
break;
##########################################################################
case 'kimikimi': //定时拉取
echo '定时拉取
';
echo date('Y-m-d H:i:s');
$parts = [
'1、你是一位小红书文案专家，擅长撰写淘宝导购的推荐文章。 根据给出的商品和介绍信息，生成标题和文案，要有标题和文案这两个词语，方便区分',
'2、标题采用小红书或者抖音口播标题风格，吸引人关注。需要增加必要的emoji表情，字数至少1000字',
'3、不要出现 小红书 相关 的字眼，不要出现 总的来说，这样的字眼',
'4、结尾不要写 让我们一起吧 类似的话。',
'5、结尾不要有对生成内容的补充说明，比如不要有类似提示（本文字数已超过1000字，满足您的要求，同时避免了提及特定平台名称，确保内容的通用性和适宜性。）',
];
$dirtyString = implode("", $parts);
// 使用htmlspecialchars()函数来转义HTML标签，防止XSS攻击
$prompt = htmlspecialchars($dirtyString, ENT_QUOTES, 'UTF-8');
$message ='再见，平成时代 - 新井一二三';
//准备内容，查kimi docker
$results = get_content_from_local_kimi_free_by_prompt($prompt, $message);
//echo $results;
//对结果处理一下，
//
echo '
begin ------------------------------------------
';
$parsedown = new parsedown;
echo $done = $parsedown->text($results); # prints: Hello Parsedown!
//分割出标题和文案内容
//$arr = explode('文案：
',$done);
$arr = explode('文案：',$done);
//下面就可以开始分析，插入数据库了
if(sizeof($arr)>1){//如果可以分割，说明格式正确
$new_title = str_replace('标题：','',$arr[0]);
echo $new_title =strip_tags($new_title);
echo '开始插入数据库
';
//还要再区分一下来类似这种（本文以温馨、亲切的语气，结合家长对孩子成长的关心，详细介绍了伊利QQ星儿童成长配方奶粉的特点和优势，字数已超过1000字，满足您的要求，同时避免了提及特定平台名称，确保内容的通用性和适宜性。）
$temparr = explode('（本文', $arr[1] );
echo $new_content = $temparr[0];
$new_content = str_replace('[注：本文已超过1000字，满足您的要求，同时避免了提及特定平台名称，确保内容的通用性和适宜性。]','',$new_content);
echo '
';
//更新数据库
//发帖吧，参考manboo_multi_submit
##判断一下uid的值，如果是1，就随机一下
$uid = random_int(2, 4918);
//根据分类顶一下fid
$fid = '1';
$thread = array(
'fid' => $fid,
'uid' => $uid,
//'sid' => $sid,
'subject' => $new_title,
'message' => $new_content,
'time' => time(),
'longip' => '2130706433', //localhost
'doctype' => 0,
);
print_r($thread);
$tid = thread_create($thread, $pid);
echo '更新成功';
}// if end 如果可以分割，说明格式正确
message(0, 'go kimikimi Bad Request');
break;
##########################################################################################
case 'gid': //直接从商品id转链接
//先获取一下id， 注意是两个值 go-id-V6M57zQH6twP44b7o4f20bivtV-MPGaznpUVoan6BwMcR.htm
$id1 = param(2, '');
$id2 = param(3, '');
//要判断一下长度是否大于20
if(strlen($id1)>10 && strlen($id2) >10 ){
$goodsId = $id1.'-'.$id2;
//echo $goodsId ;
//echo '
';
//调用高效转链函数，这个地方最好改成从数据库取数据
$mydataoke = new mydataoke;
//先从数据库缓存获取
$shortUrl = cache_get($goodsId);
//如果过期了，或者空的
if(empty($shortUrl)){
$shortUrl = $mydataoke->get_taobao_coupon_url_by_goodsid($goodsId);
cache_set($goodsId, $shortUrl, 8640000); //按秒算，一天86400秒
}
if($shortUrl){
header('Location: '.$shortUrl);
exit; // 确保脚本停止执行
}else{
header('Location: '.'/haowu.htm');
exit; // 确保脚本停止执行
}
}else{
message(0, 'go Bad Request');
}
break;
case 'pid':
$id = param(2, '');
//要判断一下长度是否大于20
if(strlen($id)>1){
//数据库查一下
//不管什么途径获取的商品，都写一份数据到taobao_zhuanlian表里，后面查询时都从这个表里获取
//还是分开吧，各查各的表
$data = db_find_one('taobao_products', array('id'=>$id));
$goodsId = $data['goodsId'];
//echo '
';
$mydataoke = new mydataoke;
//echo $goodsId ;
//echo '
';
//调用高效转链函数，这个地方最好改成从数据库取数据
//先根据大淘客id获取详情
##根据dataokeid查一下goodsSign
/* echo $id; //dataokeid也会变，太奇怪了
$product = $mydataoke->get_goods_details_by_dataokeid($id);
print_r($product);
echo $goodsSign = $product['data']['goodsSign']; */
//先从数据库缓存获取
$shortUrl = cache_get($goodsId);
//如果过期了，或者空的
if(empty($shortUrl)){
$shortUrl = $mydataoke->get_taobao_coupon_url_by_goodsid($goodsId);
cache_set($goodsId, $shortUrl, 8640000); //按秒算，一天86400秒
}
##根据goodsSign，再查链接
//$shortUrl = $mydataoke->get_taobao_coupon_url_by_goodsid($goodsId);
if($shortUrl){
header('Location: '.$shortUrl);
exit; // 确保脚本停止执行
}else{
header('Location: '.'/haowu.htm');
exit; // 确保脚本停止执行
}
}else{
message(0, 'go Bad Request');
}
break;
#####################################################帖子的tid
case 'tid':
$id = param(2, '');
//要判断一下长度是否大于20
if(strlen($id)>1){
//数据库查一下
//还是分开吧，各查各的表 tid就是论坛发的帖子，都从xianbao表里查
$data = db_find_one('taobao_xianbao', array('dataoke_id'=>$id));
$goodsId = $data['signId'];
//echo '
';
$mydataoke = new mydataoke;
//先从数据库缓存获取
$shortUrl = cache_get($goodsId);
//如果过期了，或者空的
if(empty($shortUrl)){
$shortUrl = $mydataoke->get_taobao_coupon_url_by_goodsid($goodsId);
cache_set($goodsId, $shortUrl, 8640000); //按秒算，一天86400秒
}
##根据goodsSign，再查链接
//$shortUrl = $mydataoke->get_taobao_coupon_url_by_goodsid($goodsSign);
if($shortUrl){
header('Location: '.$shortUrl);
exit; // 确保脚本停止执行
}else{
header('Location: '.'/haowu.htm'); ////////////////////////////如果查不到，就返回到搜索链接 https://www.dataoke.com/kfpt/api-d.html?id=14
exit; // 确保脚本停止执行
}
}else{
message(0, 'go Bad Request');
}
break;
#####################################################/go-shop-4793097890753034937.htm
case 'shop':
$id = param(2, '');
//要判断一下长度是否大于20
if(strlen($id)>5){
//echo $id;
$mydataoke = new mydataoke;
##根据$id，也就是sellerId
$shopdata = $mydataoke->get_shop_url_convert($id);
$shopurl = $shopdata['data']['shopLinks'];
if($shopurl){
header('Location: '.$shopurl);
exit; // 确保脚本停止执行
}else{
header('Location: '.'/haowu.htm'); ////////////////////////////如果查不到，就返回到搜索链接 https://www.dataoke.com/kfpt/api-d.html?id=14
exit; // 确保脚本停止执行
}
}else{
message(0, 'go Bad Request');
}
break;
#####################################################/go-brand-11016.htm
case 'brand':
$id = param(2, '');
//要判断一下长度是否大于20
if(strlen($id)>1){
//echo $id;
//根据id查一下表
$brand = db_find_one('taobao_brands', array('brandId' => $id));
if(!empty($brand)){
if($brand['brandEnglish']!=''){
$brand['brandName'] = str_replace($brand['brandEnglish'],'',$brand['brandName']); //先把中文名称里的英文去掉
$brand['allname'] = $brand['brandName'].'/'.$brand['brandEnglish']; //再合并一下
}else{
$brand['allname'] = $brand['brandName'];
}
//查一下店铺信息 taobao_brands_shops
//$shops = db_find('taobao_brands_shops',array('brandId' => $brand['brandId']), array(), 1, $pagesize = 100);
//查 taobao_shops 这个表吧
$shops = db_find('taobao_shops',array('brandId' => $brand['brandId']), array(), 1, $pagesize = 100);
/* $shops_arr=array();
foreach($shops as $shop){
print_r($shop);
$shopfind = db_find_one('taobao_shops', array('sellerId' => $shop['sellerId']));
print_r($shopfind);
$shops_arr = array_merge($shops_arr, $shopfind);
print_r($shops_arr);
} */
//查一下特价商品
$mydataoke = new mydataoke;
$products_data = $mydataoke->get_goods_list_by_brandId($brand['brandId'], 1, 8); //第1页，pagesize 8
##取4个商品就行了
$products = $products_data['data']['list'];
include _include(APP_PATH . 'plugin/manboo_dataoke/view/htm/brand.htm');
}else{
header('Location: '.'/brands.htm'); //如果找不到，就跳转到brands.htm
exit; // 确保脚本停止执行
}
/* $mydataoke = new mydataoke;
##根据$id，也就是sellerId
$shopdata = $mydataoke->get_shop_url_convert($id);
$shopurl = $shopdata['data']['shopLinks'];
if($shopurl){
header('Location: '.$shopurl);
exit; // 确保脚本停止执行
}else{
header('Location: '.'/haowu.htm'); ////////////////////////////如果查不到，就返回到搜索链接 https://www.dataoke.com/kfpt/api-d.html?id=14
exit; // 确保脚本停止执行
} */
}else{
message(0, 'go Bad Request');
}
break;
###########################################################default
default:
message(0, 'default Bad Request');
break;
}
################################################################################################################
##下面是处理的函数
###########################################################################################################
function create_thread_from_xianbao($xianbao){
echo 'create_thread_from_xianbaoe begin _____________________________________
';
##加一下获取kimi的内容
$new_title =$xianbao['dTitle'];
$new_content =''.$xianbao['title']."
";
$new_content .=$xianbao['materialData'];
##判断一下uid的值，如果是1，就随机一下
$uid = random_int(2, 4918);
//根据分类顶一下fid
$fid = $xianbao['cid'];
$thread = array(
'fid' => $fid,
'uid' => $uid,
'subject' => $new_title,
'message' => $new_content,
'time' => time(),
'longip' => '2130706433', //localhost
'doctype' => 0,
);
//print_r($thread);
$tid = thread_create($thread, $pid);
//brandName shopName 更新一下tags
if($xianbao['brandName']!=''){
//tag_add($tid,$xianbao['brandName']); //增加关键字
tag_add_by_type($tid,$xianbao['brandName'],'brand',$xianbao['brandId']);
}
if($xianbao['shopName']!=''){
//tag_add($tid,$xianbao['shopName']); //增加关键字
tag_add_by_type($tid,$xianbao['shopName'],'shop',$xianbao['sellerId']);
}
##更新一下表 taobao_qun
db_update('taobao_xianbao', array('id' => $xianbao['id']), array('tid' => $tid ));
echo 'create_thread_from_circle end _______________________________'.$tid .'______
';
}
###############################################
// add
function tag_add_by_type($tid,$tag,$type,$id){
$r = db_find_one('git_tags',array('name'=>$tag));
if ($r == FALSE){ //如果没找到
$r = db_insert('git_tags',array('name'=>$tag, 'link'=>1, 'type'=>$type, 'id'=>$id));
db_insert('git_tags_thread',array('tid'=>$tid, 'tagid'=>$r));
// 记录到历史
}else{ //如果找到了
$r = $r['tagid'];
db_insert('git_tags_thread',array('tid'=>$tid, 'tagid'=>$r));
//db_update('git_tags',array('tagid'=>$r),array('link+'=>1));
db_update('git_tags',array('tagid'=>$r),array('link+'=>1, 'type'=>$type, 'id'=>$id ));
// 记录到历史
}
return $r;
}
###########################################################################################################
function create_thread_from_qun($qun){
echo 'create_thread_from_circle begin _____________________________________
';
##加一下获取kimi的内容
$new_title =$qun['dTitle'];
$new_content =$qun['materialData'];
##根据signId查一下cid吧
$mydataoke = new mydataoke;
$product = $mydataoke->get_goods_details($qun['signId']);
print_r($product);
echo $dataoke_id = $product['data']['id'];
echo $cid = $product['data']['cid'];
##判断一下uid的值，如果是1，就随机一下
$uid = random_int(2, 4918);
//根据分类顶一下fid
$fid = $cid;
$thread = array(
'fid' => $fid,
'uid' => $uid,
'subject' => $new_title,
'message' => $new_content,
'time' => time(),
'longip' => '2130706433', //localhost
'doctype' => 0,
);
print_r($thread);
$tid = thread_create($thread, $pid);
##更新一下表 taobao_qun
db_update('taobao_qun', array('id' => $qun['id']), array('tid' => $tid,'cid' => $cid,'dataoke_id' => $dataoke_id ));
//要把转链的信息放进去
$zhuanliandata = array(
'dataoke_id'=>$dataoke_id ,
'goodsId'=>$qun['signId'],
);
db_insert('taobao_zhuanlian',$zhuanliandata); //插入的ID
echo 'create_thread_from_circle end _______________________________'.$tid .'______
';
}
###########################################################################################################
function create_thread_from_circle($circle){
echo 'create_thread_from_circle begin _____________________________________
';
##加一下获取kimi的内容
$new_title =$circle['title'];
$new_content =$circle['desc'];
##判断一下uid的值，如果是1，就随机一下
$uid = random_int(2, 4918);
//根据分类顶一下fid
$fid = $circle['cid'];
$thread = array(
'fid' => $fid,
'uid' => $uid,
//'sid' => $sid,
'subject' => $new_title,
'message' => $new_content,
'time' => time(),
'longip' => '2130706433', //localhost
'doctype' => 0,
);
print_r($thread);
$tid = thread_create($thread, $pid);
echo 'create_thread_from_circle end _______________________________'.$tid .'______
';
}
#############################################################################################################
//调用自己docker获取
function get_content_from_local_kimi_free_by_prompt($prompt, $content){
/* echo $prompt='小红书风格';;
echo $content = str_replace(array("\r", "\n"),'',$content); */
//echo $prompt='小红书风格';
//echo $content='面向对象程序设计(Java)';
$content = str_replace(array("\r", "\n"),'',$content);
$content = preg_replace("/\r\n|\r|\n/", "", $content);
/* echo '113
';
echo $content;
echo '
456'; */
$curl = curl_init();
curl_setopt_array($curl, array(
CURLOPT_URL => 'http://127.0.0.1:35431/v1/chat/completions',
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => '',
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 0,
CURLOPT_FOLLOWLOCATION => true,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => 'POST',
CURLOPT_POSTFIELDS =>'{
"model": "kimikimi",
"messages": [
{
"role": "system",
"content": "'.$prompt.'"
},
{
"role": "user",
"content": "'.$content.'"
}
],
"use_search": false,
"stream": false
}',
CURLOPT_HTTPHEADER => array(
'Content-Type: application/json',
//'Authorization: Bearer eyJhbGciOiJIUzUxMiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJ1c2VyLWNlbnRlciIsImV4cCI6MTcyMzg3Mjg5NywiaWF0IjoxNzE2MDk2ODk3LCJqdGkiOiJjcDRvdjBhMzRwZTRiNjJ0NWNsMCIsInR5cCI6InJlZnJlc2giLCJzdWIiOiJjbzNrYzgwM3IwNzJyOGM4aWczMCIsInNwYWNlX2lkIjoiY28za2M4MDNyMDcycjhjOGlnMmciLCJhYnN0cmFjdF91c2VyX2lkIjoiY28za2M4MDNyMDcycjhjOGlnMjAifQ.ZTt0rqjYpimTiHw8ZPvv1GtAY9ovRjYQ9uqUcdMTO4pn8mAXw5V_rqEibDTJze1Jxx8RlsJylmKgVuZMRS_hgQ'
//'Authorization: Bearer eyJhbGciOiJIUzUxMiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJ1c2VyLWNlbnRlciIsImV4cCI6MTczODE2NTA1NCwiaWF0IjoxNzMwMzg5MDU0LCJqdGkiOiJjc2hxOGZuZDBwODV2YzFrNGhkMCIsInR5cCI6InJlZnJlc2giLCJhcHBfaWQiOiJraW1pIiwic3ViIjoiY28za2M4MDNyMDcycjhjOGlnMzAiLCJzcGFjZV9pZCI6ImNvM2tjODAzcjA3MnI4YzhpZzJnIiwiYWJzdHJhY3RfdXNlcl9pZCI6ImNvM2tjODAzcjA3MnI4YzhpZzIwIiwicm9sZXMiOlsiIl19.lGY-tkBKxLNZqXVYPx8wdtg0swQ6f4GAPzt9VrzBGXQhsNtNVo04UKSTUbqPd7JGOVXLYd4m6tyRcQlAKNCmvw'
'Authorization: Bearer eyJhbGciOiJIUzUxMiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJ1c2VyLWNlbnRlciIsImV4cCI6MTc0NzQwMjc5OCwiaWF0IjoxNzM5NjI2Nzk4LCJqdGkiOiJjdW85aWJuNm82OGptdGZhN2kxMCIsInR5cCI6InJlZnJlc2giLCJhcHBfaWQiOiJraW1pIiwic3ViIjoiY28za2M4MDNyMDcycjhjOGlnMzAiLCJzcGFjZV9pZCI6ImNvM2tjODAzcjA3MnI4YzhpZzJnIiwiYWJzdHJhY3RfdXNlcl9pZCI6ImNvM2tjODAzcjA3MnI4YzhpZzIwIiwicm9sZXMiOlsiIiwidmlkZW9fZ2VuX2FjY2VzcyJdLCJzc2lkIjoiMTczMDE0MzExODk2MTQ1NjIxOSIsImRldmljZV9pZCI6IjczNjAzMjQ3ODQxNzA5MjI1MDAifQ.U5fWT4SGHsCDadmRXutiEqNAD0PhO2-V3CrgaJKkTued19uHluQpz3rRa4DJFzYccAOaqkCqd6n7htfZaHlp7g'
),
));
$response = curl_exec($curl);
curl_close($curl);
//echo $response;
echo '
curl_close done
';
// 将JSON字符串转换为PHP数组
$obj = json_decode($response,true);
//echo $obj['choices'];
#echo $obj['choices'][0]['message']['content'];
return $obj['choices'][0]['message']['content'];
}//调用自己docker获取
########################################################################################################################
###############################插入品牌库
function insert_taobao_brands($list){
foreach($list as $each){
echo 'foreach product insert_taobao_brands
';
//print_r($each);
$data1 = db_find_one('taobao_brands', array('brandId' => $each['brandId']));
if(empty($data1)){
//db_insert
$tid = db_insert('taobao_brands',$each); //插入的ID
##循环一下shop，插入 taobao_brands_shops
foreach($each['shop'] as $shop){
//根据brandId查一下，没有就插入
$data = db_find_one('taobao_brands_shops', array('brandId' => $each['brandId']));
if(empty($data)){
$insertdata = array(
'brandId'=>$each['brandId'],
'sellerId'=>$shop['sellerId'],
'shopName'=>$shop['name']
);
db_insert('taobao_brands_shops',$insertdata);
}//if empty taobao_brands_shops
}//foreach shop
}//if empty taobao_brands
echo 'insert_taobao_brands'.$tid .'_____
';
echo '
';
}
}
########################################################################################################################
function insert_taobao_xianbao($list){
foreach($list as $each){
echo 'foreach product insert_taobao_xianbao
';
//print_r($each);
//对materialData特殊处理一下
$materialData_txt ='';
$materialData_imgs ='';
foreach($each['materialShow'] as $each_material){ //文案内容
if($each_material['type']==1){
$materialData_txt .=''.$each_material['content'].'
';
}
if($each_material['type']==2){
//
$materialData_imgs .= $each_material['content'];
$materialData_imgs .=';';
}
}
$materialData_txt= str_replace('[淘宝请转链]','',$materialData_txt);
$each_insert['materialData']=$materialData_txt;
$each_insert['materialData_imgs']= rtrim($materialData_imgs,';');
$each_insert['groupId']= $each['groupId'];
$each_insert['groupName']= $each['groupName'];
$each_insert['createTime']= $each['createTime'];
$each_insert['signId']= $each['productId'];
//根据id查一下详情
$mydataoke = new mydataoke;
$productdetails = $mydataoke->get_goods_details($each_insert['signId']);
print_r($productdetails);
//补一下信息，品牌，店铺，dataoke_id
$each_insert['brandName']= $productdetails['data']['brandName'];
$each_insert['brandId']= $productdetails['data']['brandId'];
$each_insert['sellerId']= $productdetails['data']['sellerId'];
$each_insert['shopName']= $productdetails['data']['shopName'];
$each_insert['dTitle']= $productdetails['data']['dtitle'];
$each_insert['title']= $productdetails['data']['title'];
$each_insert['dataoke_id']= $productdetails['data']['id']; //这个有可能是0？？
$each_insert['cid']= $productdetails['data']['cid'];
//db_insert
$tid = db_insert('taobao_xianbao',$each_insert); //插入的ID
//查一下有没有店铺信息
//根据sellerId查一下，没有就插入
$data = db_find_one('taobao_shops', array('sellerId' => $productdetails['data']['sellerId']));
if(empty($data)){
//插入店铺信息
$shopdata = array(
'sellerId'=>$productdetails['data']['sellerId'],
'shopName'=>$productdetails['data']['shopName'],
'shopLogo'=>$productdetails['data']['shopLogo'],
'goldSellers'=>$productdetails['data']['goldSellers'],
'shopType'=>$productdetails['data']['shopType'],
'cid'=>$productdetails['data']['cid'],
'brandId'=>$productdetails['data']['brandId']
);
db_insert('taobao_shops',$shopdata); //插入的ID
}
//还需要增加品牌、店铺信息的获取
echo 'db_insert insert_taobao_xianbao ____'.$tid .'_____
';
echo 'foreach insert_taobao_xianbao end
';
}//foreach list
}
########################################################################################################################
function insert_taobao_qun($list){
foreach($list as $each){
echo 'foreach product insert_taobao_qun
';
//print_r($each);
//对materialData特殊处理一下
$materialData_txt ='';
$materialData_imgs ='';
foreach($each['materialData'] as $each_material){
if($each_material['type']==1){
$materialData_txt .=''.$each_material['content'].'
';
}
if($each_material['type']==2){
//
$materialData_imgs .= $each_material['content'];
$materialData_imgs .=';';
}
}
$each['materialData']=$materialData_txt;
$each['materialData_imgs']= rtrim($materialData_imgs,';');
//db_insert
$tid = db_insert('taobao_qun',$each); //插入的ID
//还需要增加品牌、店铺信息的获取
echo 'db_insert insert_taobao_qun ____'.$tid .'_____
';
echo 'foreach insert_taobao_qun end
';
}//foreach list
}
########################################################################################################################
function insert_taobao_circle($list){
foreach($list as $each){
echo 'foreach product insert_taobao_circle
';
//print_r($each);
//db_insert
$tid = db_insert('taobao_circle',$each); //插入的ID
##这里改进一下，插入店铺信息， 品牌库有单独的函数，不用管
/* $shopdata = array(
'sellerId'=>$each['sellerId'],
'shopName'=>$each['shopName'],
'shopLogo'=>$each['shopLogo'],
'goldSellers'=>$each['goldSellers'],
'shopType '=> $each['shopType']
);
print_r($shopdata);
db_insert('taobao_shops',$shopdata); //插入的ID */
echo 'db_insertdb_insertdb_insertdb_insertdb_insert____'.$tid .'_____
';
echo 'foreach product222222222222222222222222
';
}
}
########################################################################################################################
function insert_taobao_products($list){
foreach($list as $each){
echo 'foreach product1111111111111111111111111
';
//print_r($each);
//db_insert
$tid = db_insert('taobao_products',$each); //插入的ID
##这里改进一下，插入店铺信息， 品牌库有单独的函数，不用管
$shopdata = array(
'sellerId'=>$each['sellerId'],
'shopName'=>$each['shopName'],
'shopLogo'=>$each['shopLogo'],
'goldSellers'=>$each['goldSellers'],
'shopType'=>$each['shopType'],
'cid'=>$each['cid']
);
db_insert('taobao_shops',$shopdata); //插入的ID
//要把转链的信息放进去
$zhuanliandata = array(
'dataoke_id'=>$each['id'],
'goodsId'=>$each['goodsId'],
);
db_insert('taobao_zhuanlian',$zhuanliandata); //插入的ID
echo 'db_insertdb_insertdb_insertdb_insertdb_insert____'.$tid .'_____
';
echo 'foreach product222222222222222222222222
';
}
}
########################################################################################################################
function delete_taobao_products($list){
foreach($list as $each){
echo 'foreach product 1111111111111111111111111
';
//print_r($each);
//db_insert
$tid = db_insert('taobao_products',$each); //插入的ID
db_delete('taobao_products', array('id'=>$each['id']));
echo 'foreach product db_delete
';
}
}
#####################################################/g
function search_dataoke_products($search){
echo $search;
$mydataoke = new mydataoke;
$pageid =1;
$datas = $mydataoke->get_dtk_search_goods($search, $pageid);
print_r($datas);
return $datas;
}
//dataoke end