363 lines
12 KiB
PHP
363 lines
12 KiB
PHP
<?php
|
|
|
|
namespace app\admin\service;
|
|
|
|
use app\admin\validate\BrandSeriesValidate;
|
|
use app\common\logic\Fingerprint;
|
|
use app\common\logic\ModelNaming;
|
|
use app\common\logic\SkuCodeBuilder;
|
|
use app\common\model\Brand;
|
|
use app\common\model\VehVehicleSku;
|
|
use app\common\service\CrawlService;
|
|
use app\common\service\VehVehicleSkuService;
|
|
use app\common\traits\crud\CrudServiceTrait;
|
|
use app\common\model\BrandSeries;
|
|
use app\common\utils\CrudUtil;
|
|
use GuzzleHttp\Client;
|
|
use support\Log;
|
|
use support\Request;
|
|
use Webman\RedisQueue\Redis;
|
|
|
|
class BrandSeriesService
|
|
{
|
|
|
|
use CrudServiceTrait;
|
|
|
|
/**
|
|
* 指定当前要操作的模型
|
|
*/
|
|
protected string $modelClass = BrandSeries::class;
|
|
|
|
/**
|
|
* 验证器
|
|
*/
|
|
protected $validator = BrandSeriesValidate::class;
|
|
|
|
/**
|
|
* 获取验证器
|
|
*/
|
|
public function getValidator()
|
|
{
|
|
return new $this->validator;
|
|
}
|
|
|
|
/**
|
|
* 构建查询条件
|
|
*/
|
|
|
|
protected function buildQueryConfig(Request $request, string $scene = 'default'): array
|
|
{
|
|
$p = $request->all();
|
|
|
|
$config = [];
|
|
$config['model'] = $this->modelClass;
|
|
switch ($scene) {
|
|
case 'index':
|
|
// ====== ====== 排序 ====== ======
|
|
$config['order']['sort'] = 'desc';
|
|
$config['order']['id'] = 'desc';
|
|
|
|
// ====== ====== 筛选 ====== ======
|
|
$config['where']['brand_id'] = $p['brand_id'];
|
|
// 状态
|
|
if (isset($p['status']) && in_array($p['status'], [0, 1])) {
|
|
$config['where']['status'] = $p['status'];
|
|
}
|
|
// 关键字
|
|
if (isset($p['keyword']) && $p['keyword']) {
|
|
$k = '%' . $p['keyword'] . '%';
|
|
foreach (['series_code', 'series_name'] as $col) {
|
|
$config['orWhere'][] = [$col, 'like', $k];
|
|
}
|
|
}
|
|
//$config['where']['status'] = 1;
|
|
break;
|
|
case 'show':
|
|
$config['where']['id'] = $p['id'];
|
|
//$config['where']['status'] = 1;
|
|
break;
|
|
case 'store':
|
|
break;
|
|
case 'update':
|
|
$config['where']['id'] = $p['id'];
|
|
break;
|
|
case 'destroy':
|
|
$config['where']['id'] = $p['id'];
|
|
break;
|
|
}
|
|
|
|
return $config;
|
|
}
|
|
|
|
/**
|
|
* 生成唯一的7位颜色编码
|
|
* 格式：C + (O/I) + 5位字母数字组合
|
|
*
|
|
* @param int $type 类型
|
|
* @return string 7位唯一编码
|
|
*/
|
|
public function generateUniqueModificationCode($brand_id)
|
|
{
|
|
$chars = '0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ';
|
|
$maxAttempts = 10; // 防止无限循环
|
|
|
|
$brand_code = Brand::where('id', $brand_id)->value('brand_code');
|
|
$brand_code = $brand_code ?? 'BS';
|
|
for ($attempt = 0; $attempt < $maxAttempts; $attempt++) {
|
|
// 生成后5位随机字符
|
|
$suffix = '';
|
|
for ($i = 0; $i < 6; $i++) {
|
|
$suffix .= $chars[rand(0, strlen($chars) - 1)];
|
|
}
|
|
|
|
$code = $brand_code . $suffix;
|
|
|
|
// 检查是否已存在
|
|
$existing = BrandSeries::where('series_code', $code)->first();
|
|
if (!$existing) {
|
|
return $code;
|
|
}
|
|
}
|
|
|
|
// 如果1000次尝试后仍然重复，使用时间戳确保唯一性
|
|
$timestamp = substr(time(), -6);
|
|
return $brand_code . $timestamp;
|
|
}
|
|
|
|
/**
|
|
* 添加前置处理
|
|
*/
|
|
public function beforeServiceStore($data, Request $request)
|
|
{
|
|
$brand_id = $data['brand_id'] ?? 0;
|
|
$data['series_code'] = $this->generateUniqueModificationCode($brand_id);
|
|
return $data;
|
|
}
|
|
|
|
/**
|
|
* 抓取车型数据（通过接口）
|
|
* @param Request $request
|
|
* @return array
|
|
* @throws \Exception
|
|
*/
|
|
public function crawlModel(Request $request): array
|
|
{
|
|
$series_id = $request->get('brand_series_id');
|
|
|
|
// 验证品牌是否存在
|
|
$series = BrandSeries::where('id', $series_id)->first();
|
|
if (!$series) {
|
|
throw new \Exception("系列ID {$series_id} 不存在");
|
|
}
|
|
|
|
// 获取品牌信息
|
|
$series = BrandSeries::where('id', $series_id)->first();
|
|
if (!$series) {
|
|
throw new \Exception("系列ID {$series_id} 不存在");
|
|
}
|
|
|
|
// 获取品牌信息
|
|
$brand = Brand::where('id', $series->brand_id)->first();
|
|
|
|
// 执行抓取
|
|
$crawlService = new CrawlService();
|
|
$href = $crawlService->modelSearch($brand->brand_name . ' ' . $series->series_name);
|
|
$seriesId = $this->extractSeriesId($href);
|
|
$client = new Client([
|
|
'verify' => false, // 禁用 SSL 验证
|
|
'timeout' => 10
|
|
]);
|
|
try {
|
|
$response = $client->get('https://www.dongchedi.com/motor/pc/car/series/car_list', [
|
|
'query' => ['series_id' => $seriesId],
|
|
'headers' => [
|
|
'User-Agent' => 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36'
|
|
]
|
|
]);
|
|
$data = json_decode($response->getBody()->getContents(), true);
|
|
if($data['status'] != 0 || (!isset($data['data']) && !isset($data['data']['tab_list']))){
|
|
Log::error('抓取车型数据失败' . $data['message'], $data);
|
|
throw new \Exception('抓取车型数据失败' . $data['message']);
|
|
}
|
|
$models = [];
|
|
foreach ($data['data']['tab_list'] as $item) {
|
|
if($item['tab_text'] == '在售' || $item['tab_text'] == '停售'){
|
|
unset($item['data'][0]);
|
|
$models = array_merge($models, $item['data']);
|
|
}
|
|
}
|
|
foreach ($models as $key => $model) {
|
|
if(!isset($model["info"]['car_name'])){
|
|
unset($models[$key]);
|
|
continue;
|
|
}
|
|
$official_price = 0;
|
|
if(!isset($model["info"]['official_price'])){
|
|
$official_price = (int)(str_replace("万", "", $model["info"]['official_price_str']) * 10000) ?? 0;
|
|
}else{
|
|
$official_price = $model["info"]['official_price'] * 10000;
|
|
}
|
|
$models[$key] = [
|
|
'title' => $model["info"]['year'] . '款 ' .$model["info"]['car_name'],
|
|
'brand_name' => $model["info"]['brand_name'],
|
|
'series_name' => $model["info"]['series_name'],
|
|
'year' => $model["info"]['year'],
|
|
'msrp' => $official_price,
|
|
'car_id' => $model["info"]['id'],
|
|
];
|
|
}
|
|
return array_values($models);
|
|
} catch (\Exception $e) {
|
|
throw new \Exception($e->getMessage());
|
|
}
|
|
|
|
|
|
// return $models;
|
|
}
|
|
|
|
/**
|
|
* 从懂车帝URL中提取series ID
|
|
* @param string $url 完整的URL
|
|
* @return string|null series ID或null
|
|
*/
|
|
function extractSeriesId($url) {
|
|
// 解析URL获取路径部分
|
|
$path = parse_url($url, PHP_URL_PATH);
|
|
|
|
if (!$path) {
|
|
return null;
|
|
}
|
|
|
|
// 按斜杠分割路径
|
|
$pathParts = explode('/', trim($path, '/'));
|
|
|
|
// 查找 'series' 的位置，下一个元素就是series ID
|
|
$seriesIndex = array_search('series', $pathParts);
|
|
|
|
if ($seriesIndex !== false && isset($pathParts[$seriesIndex + 1])) {
|
|
return $pathParts[$seriesIndex + 1];
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
/**
|
|
* 抓取车型数据(通过页面抓取)
|
|
* @param Request $request
|
|
* @return array
|
|
* @throws \Exception
|
|
*/
|
|
/*public function crawlModel(Request $request)
|
|
{
|
|
$series_id = $request->get('brand_series_id');
|
|
|
|
// 验证品牌是否存在
|
|
$series = BrandSeries::where('id', $series_id)->first();
|
|
if (!$series) {
|
|
throw new \Exception("系列ID {$series_id} 不存在");
|
|
}
|
|
|
|
// 获取品牌信息
|
|
$series = BrandSeries::where('id', $series_id)->first();
|
|
if (!$series) {
|
|
throw new \Exception("系列ID {$series_id} 不存在");
|
|
}
|
|
|
|
// 获取品牌信息
|
|
$brand = Brand::where('id', $series->brand_id)->first();
|
|
|
|
// 执行抓取
|
|
$crawlService = new CrawlService();
|
|
$models = $crawlService->seriesModel($brand->brand_name . ' ' . $series->series_name);
|
|
|
|
foreach ($models as $key => $model) {
|
|
$models[$key]['year'] = $this->extractYearFromCarModel($model['title']);
|
|
}
|
|
|
|
return $models;
|
|
}*/
|
|
|
|
/**
|
|
* @param Request $request
|
|
* @return array|string
|
|
* @throws \Exception
|
|
*/
|
|
public function crawlModelCreate(Request $request)
|
|
{
|
|
$series_id = $request->input('series_id');
|
|
// $brand_id = $request->input('brand_id');
|
|
$models = $request->input('models');
|
|
|
|
// 验证系列是否存在
|
|
$series = BrandSeries::where('id', $series_id)->first();
|
|
if (!$series) {
|
|
throw new \Exception("系列ID {$series_id} 不存在");
|
|
}
|
|
// 获取品牌信息
|
|
$brand = Brand::where('id', $series->brand_id)->first();
|
|
|
|
// 保存车型数据
|
|
$createdCount = 0;
|
|
$repeat = 0;
|
|
$fail = 0;
|
|
$msg = '';
|
|
|
|
foreach ($models as $item) {
|
|
$modelData = [
|
|
'brand_code' => $brand->brand_code,
|
|
'brand_name' => $brand->brand_name,
|
|
'series_code' => $series->series_code ?? '',
|
|
'series_name' => $series->series_name ?? '',
|
|
'model_name' => $item['title'],
|
|
'model_year' => $item['year'],
|
|
'msrp' => $item['msrp'],
|
|
];
|
|
$modelData['model_code'] = ModelNaming::buildModelCode($modelData);
|
|
$modelData['sku_code'] = SkuCodeBuilder::build($modelData);
|
|
// 指纹
|
|
$modelData['fingerprint'] = Fingerprint::makeFromArray($modelData);
|
|
|
|
try {
|
|
$model = VehVehicleSku::where('brand_name', $brand->brand_name)->where('series_name', $series->series_name)->where('model_name', $item['title'])->first();
|
|
if (!empty($model)) {
|
|
$repeat++;
|
|
continue;
|
|
}
|
|
CrudUtil::create(VehVehicleSku::class, $modelData);
|
|
$createdCount++;
|
|
} catch (\Exception $e) {
|
|
// 记录错误但继续处理其他车型
|
|
$msg .= "创建车型失败: " . $e->getMessage() . "\n";
|
|
Log::error("创建车型失败:" . $msg, ['series_id' => $series_id, 'model' => $item]);
|
|
$fail++;
|
|
}
|
|
}
|
|
|
|
Log::info('series-crawl-' . $series_id . ' ' . $msg);
|
|
$msg = '创建车型成功' . $createdCount . '条';
|
|
$msg .= (!empty($repeat)) ? '，重复' . $repeat . '条' : '';
|
|
$msg .= (!empty($fail)) ? '，失败' . $fail . '条' : '';
|
|
return $msg;
|
|
}
|
|
|
|
|
|
/**
|
|
* 从车型名中提取年份
|
|
* @param string $carModel 车型名称
|
|
* @return string|null 提取到的年份或null
|
|
*/
|
|
function extractYearFromCarModel($carModel)
|
|
{
|
|
// 匹配4位数字 + "款" 的模式
|
|
if (preg_match('/(\d{4})款/', $carModel, $matches)) {
|
|
return $matches[1];
|
|
}
|
|
|
|
// 匹配4位数字 + 空格或结尾的模式
|
|
if (preg_match('/^(\d{4})(?=\s|$)/', $carModel, $matches)) {
|
|
return $matches[1];
|
|
}
|
|
|
|
return null;
|
|
}
|
|
} |