|
...
|
...
|
@@ -37,7 +37,7 @@ class LyhImportTest extends Command |
|
|
|
*/
|
|
|
|
protected $description = '导入数据';
|
|
|
|
|
|
|
|
public $data = '';
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @remark :统一更新路由
|
|
...
|
...
|
@@ -49,9 +49,7 @@ class LyhImportTest extends Command |
|
|
|
public function handle(){
|
|
|
|
ProjectServer::useProject(3283);
|
|
|
|
echo date('Y-m-d H:i:s') . 'start' . PHP_EOL;
|
|
|
|
// $this->importCustomModule($this->data);
|
|
|
|
// $this->importProductCategory($this->data,3283);
|
|
|
|
$this->handleCatePid();
|
|
|
|
$this->importProduct('https://ecdn6.globalso.com/upload/p/1/file/2025-03/zy_boss_price_copy1.csv',3283);
|
|
|
|
DB::disconnect('custom_mysql');
|
|
|
|
echo date('Y-m-d H:i:s') . 'end' . PHP_EOL;
|
|
|
|
}
|
|
...
|
...
|
@@ -63,25 +61,24 @@ class LyhImportTest extends Command |
|
|
|
* @method :post
|
|
|
|
* @time :2025/3/3 15:59
|
|
|
|
*/
|
|
|
|
public function importProductCategory($text,$project_id){
|
|
|
|
//设置对应管理数组
|
|
|
|
$key_val = [];
|
|
|
|
$arr = explode("\n", $text);
|
|
|
|
foreach ($arr as $val){
|
|
|
|
$cate_arr = explode(",", $val);
|
|
|
|
$key_val[$cate_arr[1]] = $cate_arr[1];
|
|
|
|
$saveData = [
|
|
|
|
'project_id'=>$project_id,
|
|
|
|
'title'=>$cate_arr[1],
|
|
|
|
'seo_title'=>$cate_arr[0],
|
|
|
|
'seo_des'=>$cate_arr[2]
|
|
|
|
];
|
|
|
|
$cateModel = new Category();
|
|
|
|
$id = $cateModel->addReturnId($saveData);
|
|
|
|
$route = RouteMap::setRoute($cate_arr[1],RouteMap::SOURCE_PRODUCT_CATE,$id,$project_id);
|
|
|
|
$cateModel->edit(['route'=>$route],['id'=>$id]);
|
|
|
|
public function importProduct($url,$project_id){
|
|
|
|
$line_of_text = [];
|
|
|
|
$opts = [
|
|
|
|
'http' => [
|
|
|
|
'method' => 'GET',
|
|
|
|
'header' => 'User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/42.0.2311.135 Safari/537.36 Edge/12.246'
|
|
|
|
],
|
|
|
|
'ssl' => [
|
|
|
|
'verify_peer' => false,
|
|
|
|
'verify_peer_name' => false
|
|
|
|
]
|
|
|
|
];
|
|
|
|
$file_handle = fopen($url, 'r', null, stream_context_create($opts));
|
|
|
|
while (!feof($file_handle)) {
|
|
|
|
$line_of_text[] = fgetcsv($file_handle, 0, ',');
|
|
|
|
}
|
|
|
|
return true;
|
|
|
|
fclose($file_handle);
|
|
|
|
dd($line_of_text);
|
|
|
|
}
|
|
|
|
|
|
|
|
public function handleCatePid(){
|
...
|
...
|
|