导数据方法

<?php
// 写如sql语句
//	查询所有商品的信息及店铺信息
echo '<meta charset="utf-8">';
include './mysql.php';

/**
* 执行简单的插入
* @access public
* @parameter goal 目标表
* @parameter rest 来源表
* @parameter goal 来源字段
* import_insert('33hao_goods_class(gc_id,gc_name,gc_parent_id,gc_sort,level)','br_gcategory','cate_id,cate_name,parent_id,sort_order,level');
* @return array
*/
function  import_insert($goal,$rest,$resc,$where=''){
$model = new mysql("localhost","root","root","aumall");
$sql = "INSERT INTO {$goal} SELECT {$resc} FROM {$rest} {$where}";
$result = $model ->query($sql);

}

//	先插入商品goods_common  后续在插入goods

//goods_common没有 spec_name spec_value brand_id brand_name type_id goods_image goods_body goods_attr goods_specname goods_marketprice goods_costprice goods_discount goods_serial goods_storage_alarm transport_id areaid_1
// areaid_2 goods_stcids plateid_top plateid_bottom,
$str1 ="33hao_goods_common(goods_name,gc_id,gc_id_1,gc_id_2,gc_id_3,gc_name,store_id,store_name,goods_state,goods_verify,goods_addtime,goods_price,goods_marketprice,goods_body)";
$str11 ="33hao_goods(goods_commonid,goods_name,gc_id,gc_id_1,gc_id_2,gc_id_3,store_id,store_name,goods_state,goods_verify,goods_addtime,goods_price,goods_marketprice,goods_storage)";
$str2 ="goods_name,cate_id,cate_id_1,cate_id_2,cate_id_3,cate_name,store_id,121,1,10,".time().",price,description";
$str22 ="goods_name,cate_id,cate_id_1,cate_id_2,cate_id_3,store_id,121,1,10,".time().",price,100";
$where ="where if_trade =1 and if_show=1 and g.store_id >0 and  goods_id>240000";// <=30000    >50000<200000 >=200000
// echo $str2;
// import_insert('33hao_brand(brand_id,brand_name,brand_recommend,brand_pic)','br_brand','brand_id,brand_name,recommended,brand_logo','where if_show=1');
// import_insert($str1,'br_goods',$str2,$where);

//	查询出所有的goods信息
set_time_limit(0);
$sql_goods = "select g.*,br_store.store_name from br_goods g JOIN br_store ON br_store.store_id=g.store_id {$where}";
$model = new mysql("localhost","root","root","aumall");
$result = $model ->query($sql_goods,1);
if($result){
foreach ($result as $key => $value) {
if(empty($value)){echo '导入结束！';return '121';}
//	定义市场价格
$goods_marketprice =$value['price']+100;
//	先插入goods_common表
$sql_gcom = "value('{$value['goods_name']}','{$value['cate_id']}','{$value['cate_id_1']}','{$value['cate_id_2']}','{$value['cate_id_3']}','{$value['cate_name']}','{$value['store_id']}','{$value['store_name']}',1,10,".time().",'{$value['price']}','{$goods_marketprice}','{$value['description']}')";
// 插入goods_common
$sql_do = "INSERT INTO {$str1} {$sql_gcom}";
$result = $model ->query($sql_do);
if(is_int($result) && !empty($result)){
echo $value['goods_name'].':<font color="green">导入商品公共表成功   -- </font>';
$sql_g= "value({$result},'{$value['goods_name']}','{$value['cate_id']}','{$value['cate_id_1']}','{$value['cate_id_2']}','{$value['cate_id_3']}','{$value['store_id']}','{$value['store_name']}',1,10,".time().",'{$value['price']}','{$goods_marketprice}',100)";
$sql_do_g = "INSERT INTO {$str11} {$sql_g}";
$result1 = $model ->query($sql_do_g);
if($result1){
echo $value['goods_name'].':<font color="green">导入商品表成功 </font><br>';
file_put_contents('./seccess.txt', $value['goods_id']);
}else{
echo $value['goods_name'].':<font color="red">导入商品表失败  </font><br>';
$handle = fopen('./log.txt','a+');
fwrite($handle,'失败--id:'.$value['goods_id'].'<br />');
fclose($handle);
}
}else{
$handle = fopen('./log_C.txt','a+');
fwrite($handle,'失败--id:'.$value['goods_id'].'<br />');
fclose($handle);
}
}
}

?>