|
|
|
@ -81,22 +81,22 @@ class Collector extends Command |
|
|
|
} |
|
|
|
|
|
|
|
if (ctype_digit($supplier_id)) { |
|
|
|
$ids = [$supplier_id]; |
|
|
|
} else if ($supplier_id == 'all') { |
|
|
|
$ids = Supplier::query()->pluck('id'); |
|
|
|
} else { |
|
|
|
return; |
|
|
|
} |
|
|
|
|
|
|
|
foreach ($ids as $supplier_id) { |
|
|
|
$this->line('正在导入 ' . $supplier_id); |
|
|
|
array_walk($import_data, function ($v) use ($supplier_id) { |
|
|
|
$v['supplier_id'] = $supplier_id; |
|
|
|
unset($v['unique_id'], $v['site']); |
|
|
|
|
|
|
|
Product::query()->updateOrCreate(['supplier_id' => $supplier_id, 'title' => $v['title']], $v); |
|
|
|
}); |
|
|
|
} else if ($supplier_id == 'all') { |
|
|
|
$ids = Supplier::query()->pluck('id'); |
|
|
|
foreach ($ids as $supplier_id) { |
|
|
|
array_walk($import_data, function ($v) use ($supplier_id) { |
|
|
|
$v['supplier_id'] = $supplier_id; |
|
|
|
unset($v['unique_id'], $v['site']); |
|
|
|
|
|
|
|
Product::query()->updateOrCreate(['supplier_id' => $supplier_id, 'title' => $v['title']], $v); |
|
|
|
}); |
|
|
|
} |
|
|
|
$this->line("导入 $supplier_id 结束"); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|