// +---------------------------------------------------------------------- declare (strict_types=1); namespace app\common\library\collector\provider\driver; use app\common\enum\goods\SpecType as GoodsSpecTypeEnum; use app\common\library\helper; use app\common\library\collector\provider\Driver; use cores\exception\BaseException; /** * 拼多多商品采集驱动 * Class Pdd * @package app\common\library\collector\provider\driver */ class Pdd extends Driver { // API地址 const API_URL = 'https://api09.99api.com/pdd/detail'; /** * 获取商品详情 * @param string $itemId * @return array * @throws BaseException */ public function detail(string $itemId): array { $result = $this->curlGet(self::API_URL, $itemId); return $this->formatGoods($result['data']); } /** * 格式化商品数据 * @param array $original * @return array */ private function formatGoods(array $original): array { $data = []; // 商品规格 $data['spec_type'] = !empty($original['item']['skus']) ? GoodsSpecTypeEnum::MULTI : GoodsSpecTypeEnum::SINGLE; $data['goods_name'] = $original['item']['goodsName']; $data['goodsImages'] = $this->goodsImages($original['item']['banner']); $data['content'] = $this->goodsContent($original['item']['detail']); // 整理多规格数据 if ($data['spec_type'] === GoodsSpecTypeEnum::MULTI) { $specList = $this->createSpecList($original['item']['skus']); $data['specData']['specList'] = $specList; $data['specData']['skuList'] = $this->createSkuList($original['item']['skus'], $specList); } elseif ($data['spec_type'] === GoodsSpecTypeEnum::SINGLE) { $skuInfo = \current($original['item']['skus']); $data['goods_price'] = $skuInfo['groupPrice']; $data['line_price'] = '0.00'; $data['stock_num'] = $skuInfo['quantity']; // 库存数量 $data['goods_weight'] = 1; // 重量默认1kg } return $data; } /** * 创建标准的商品SKU数据 * @param array $originalSkuList 商品SKU列表 * @param array $specList 商品规格 * @return array */ private function createSkuList(array $originalSkuList, array $specList): array { // 根据规格数据生成完整的SKU数据 (因为originalSkuList会有不存在的sku) $cartesian = $this->cartesian($specList); // 整理商品SKU列表 $skuList = []; foreach ($cartesian as $spec) { // 设置skuKeys数据 $skuKeys = []; foreach ($spec as $specValue) { $skuKeys[] = [ 'groupKey' => $specValue['groupKey'], 'valueKey' => $specValue['key'] ]; } // 查找已存在的SKU $originalSku = $this->findOriginalSku($originalSkuList, $spec); // 整理SKU数据 $skuList[] = [ 'image_id' => 0, 'goods_price' => $originalSku ? $originalSku['groupPrice'] : '0.00', 'line_price' => '0.00', 'stock_num' => $originalSku ? $originalSku['quantity'] : 0, // 库存数量 'goods_weight' => 1, // 重量默认1kg 'goods_sku_no' => $originalSku ? $originalSku['skuID'] : '', 'skuKeys' => $skuKeys, 'imageUrl' => $originalSku ? $this->imageUrl($originalSku['thumbUrl']) : '', ]; } return $skuList; } /** * 查找已存在的SKU * @param array $originalSkuList * @param array $spec * @return false|mixed */ private function findOriginalSku(array $originalSkuList, array $spec) { foreach ($originalSkuList as $item) { $temp = 0; foreach ($spec as $specValue) { if ($item['specs'][$specValue['groupKey']]['spec_value'] == $specValue['spec_value']) { $temp++; } } if ($temp === \count($spec)) { return $item; } } return false; } /** * 生成完整的SKU列表(笛卡尔积运算) * @param array $specList * @param array $tmp * @param array $nArr * @return int */ private function cartesian(array $specList, array $tmp = [], array $nArr = []) { foreach (array_shift($specList)['valueList'] as $v) { $tmp[] = $v; if ($specList) { $nArr = $this->cartesian($specList, $tmp, $nArr); } else { $nArr[] = $tmp; } array_pop($tmp); } return $nArr; } /** * 创建标准的商品规格数据(树状) * @param array $skus SKU列表 * @return array */ private function createSpecList(array $skus): array { $specList = []; foreach ($this->getProps($skus) as $prop) { $groupKey = \count($specList); $valueList = []; foreach ($prop['values'] as $valueName) { $valueList[] = [ 'key' => \count($valueList), 'groupKey' => $groupKey, 'spec_value' => $valueName, ]; } $specList[] = [ 'key' => $groupKey, 'spec_name' => $prop['name'], 'valueList' => $valueList, ]; } return $specList; } /** * @param array $skus * @return array */ private function getProps(array $skus): array { $props = []; foreach ($skus as $item) { foreach ($item['specs'] as $spec) { if (!isset($props[$spec['spec_key']]) || !in_array($spec['spec_value'], $props[$spec['spec_key']]['values'])) { $props[$spec['spec_key']]['name'] = $spec['spec_key']; $props[$spec['spec_key']]['values'][] = $spec['spec_value']; } } } return $props; } /** * 格式化商品主图 * @param array $banner * @return array */ private function goodsImages(array $banner): array { return array_map(function (array $item) { return $this->imageUrl($item['url']); }, \array_slice($banner, 0, 10)); } /** * 格式化图片url * @param string $url * @return string */ private function imageUrl(string $url): string { if (empty($url)) { return ''; } // 补全url协议 if (\substr($url, 0, 2) === '//') { return "https:{$url}"; } if (\substr($url, 0, 4) != 'http') { return "https://{$url}"; } // http替换为https return str_replace('http://', 'https://', $url); } /** * 格式化商品详情 * @param array $detail * @return string */ private function goodsContent(array $detail): string { $content = ''; foreach ($detail as $item) { $content .= "
"; } return $content; } }