更新采集

This commit is contained in:
mkm 2023-10-10 14:54:50 +08:00
parent 95af8ff8e2
commit 258eef0f1d

View File

@ -57,7 +57,7 @@ use app\common\service\TopClient;
use app\controller\api\Ceshi;
use taobao\request\TbkItemInfoGetRequest;
use app\common\repositories\store\product\ProductRepository;
use crmeb\services\UploadService;
use think\facade\App;
/**
* Class Auth
@ -69,33 +69,36 @@ class Auth extends BaseController
{
public function caiji()
{
$url=$this->request->host();
$parmas = $this->request->param();
$query = parse_url($parmas['url']);
$itemId = $this->convertUrlQuery($query['query']);
$query=parse_url($parmas['url']);
$itemId=$this->convertUrlQuery($query['query']);
$c = new TopClient;
$c->appkey = '34537213';
$c->secretKey = '4a35f3657156580c1f533750295c54c4';
$req = new TbkItemInfoGetRequest;
$req->setNumIids($itemId['itemId']);
$resp = $c->execute($req);
$res = $resp->results->n_tbk_item;
$arr = json_decode(json_encode($res), true);
$images = [];
$upload = UploadService::create();
$dir = 'def/' . date('Y-m-d');
$res=$resp->results->n_tbk_item;
$images=[];
$filename = basename($res->pict_url); // 获取文件名
$destination = public_path('uploads').'img/' . $filename; // 目标路径
$pict_url= $url.'/uploads/img/'.$filename;
file_put_contents($destination, file_get_contents($res->pict_url));
$oss = $upload->to($dir)->stream(file_get_contents($arr['pict_url']));
$pict_url = $oss->filePath;
foreach ($arr['small_images']['string'] as $k => $v) {
$oss = $upload->to($dir)->stream(file_get_contents($v));
$images[] = $oss->filePath;
if($resp && isset($resp->small_images) && isset($resp->small_images->string)){
foreach($resp->small_images->string as $k=>$v){
$filename = basename($v); // 获取文件名
$destination = public_path('uploads').'img/' . $filename; // 目标路径
file_put_contents($destination, file_get_contents($v));
$images[]=$url.'/uploads/img/'.$filename;
}
$data = [
}
$data=[
"image" => $pict_url,
"slider_image" => $images,
"store_name" => $arr['title'],
"store_info" => $arr['cat_leaf_name'],
"slider_image" =>$images,
"store_name" => json_decode(json_encode($res->title),true)[0],
"store_info" => json_decode(json_encode($res->cat_leaf_name),true)[0],
"keyword" => "",
"bar_code" => "",
"guarantee_template_id" => "",
@ -130,7 +133,7 @@ class Auth extends BaseController
"attrValue" => [
0 => [
"image" => $pict_url,
"price" => bcsub($arr['reserve_price'], ($arr['reserve_price'] * 0.05), 2),
"price" => bcsub($res->reserve_price,($res->reserve_price*0.05),2),
"cost" => 0,
"ot_price" => 0,
"svip_price" => null,
@ -150,7 +153,7 @@ class Auth extends BaseController
"mer_status" => 1,
"rate" => 3,
];
$a = app()->make(ProductRepository::class)->create($data, 0, 1);
$a= app()->make( ProductRepository::class)->create($data,0,1);
// 下载图片并保存到目标路径
return app('json')->success($a);
}
@ -385,11 +388,11 @@ class Auth extends BaseController
}
if ($merchant['margin'] == 0) {
$margin = Db::name('MerchantType')->where('mer_type_id', $merchant['type_id'])->value('margin');
$margin = bcsub($margin,$merchant['paid_margin'],2);
}else{
$margin=$merchant['margin'];
$margin = bcsub($margin, $merchant['paid_margin'], 2);
} else {
$margin = $merchant['margin'];
}
if($margin==0){
if ($margin == 0) {
return app('json')->fail('当前金额为0,不能进行充值');
}
$orderSn = "bzj" . date('YmdHis') . uniqid();