增加淘宝联盟交互

app/common/dao/third/ThirdPartyGoodCacheDao.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace app\common\dao\third;
+
+use app\common\dao\BaseDao;
+use app\common\model\third\ThirdPartyGoodCacheModel;
+use app\entity\CommonEntity;
+use app\entity\data\third\ThirdPartyGoodCacheEntity;
+
+class ThirdPartyGoodCacheDao extends BaseDao
+{
+
+    protected function getModel(): string
+    {
+        return ThirdPartyGoodCacheModel::class;
+    }
+
+    /**
+     * @param array $productIdList
+     * @return CommonEntity[]
+     */
+    public function getThirdPartyGoodCacheEntityListByProductIdList(array $productIdList): array
+    {
+        $entityList = [];
+        try {
+            /** @var ThirdPartyGoodCacheModel $model */
+            $model = $this->getModel();
+            $dataRes = $model::getDB()
+                ->whereIn('product_id', $productIdList)
+                ->select()
+                ->toArray();
+            if (!empty($dataRes)) {
+                $entityList = array_map(function ($data) {
+                    return ThirdPartyGoodCacheEntity::newInstance($data);
+                }, $dataRes);
+            }
+        } catch (\Exception $e) {
+
+        }
+        return $entityList;
+    }
+}

app/common/enum/third/ThirdPartyGoodCacheEnum.php

@@ -0,0 +1,34 @@
+<?php
+
+namespace app\common\enum\third;
+
+use app\common\enum\CommonEnum;
+
+class ThirdPartyGoodCacheEnum extends CommonEnum
+{
+    const PLATFORM = [
+        'Taobao' => ['code' => 'TB', 'name' => '淘宝'],
+        'Jingdong' => ['code' => 'JD', 'name' => '京东'],
+        'Pdd' => ['code' => 'PDD', 'name' => '拼多多'],
+        'Suning' => ['code' => 'SN', 'name' => '苏宁'],
+        'Vipshop' => ['code' => 'VPH', 'name' => '唯品会'],
+        'Douyin' => ['code' => 'DY', 'name' => '抖音']
+    ];
+
+    /**
+     * @param $type
+     * @return mixed
+     */
+    public static function platformCodeMapByThirdPartyGoodEnumTypeCode($type)
+    {
+        $map = [
+            1 => self::PLATFORM['Taobao']['code'],
+            2 => self::PLATFORM['Jingdong']['code'],
+            3 => self::PLATFORM['Pdd']['code'],
+            4 => self::PLATFORM['Suning']['code'],
+            5 => self::PLATFORM['Vipshop']['code'],
+            9 => self::PLATFORM['Douyin']['code']
+        ];
+        return $map[$type];
+    }
+}

app/common/enum/third/ThirdPartyGoodEnum.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace app\common\enum\third;
+
+use app\common\enum\CommonEnum;
+
+class ThirdPartyGoodEnum extends CommonEnum
+{
+    // 1-淘宝，2-京东，3-拼多多，4-苏宁，5-唯品会，9-抖音
+    const TYPE = [
+        'Taobao' => ['code' => 1, 'name' => '淘宝'],
+        'Jingdong' => ['code' => 2, 'name' => '京东'],
+        'Pdd' => ['code' => 3, 'name' => '拼多多'],
+        'Suning' => ['code' => 4, 'name' => '苏宁'],
+        'Vipshop' => ['code' => 5, 'name' => '唯品会'],
+        'Douyin' => ['code' => 9, 'name' => '抖音'],
+    ];
+}

app/common/model/third/ThirdPartyGoodCacheModel.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace app\common\model\third;
+
+use app\common\model\BaseModel;
+
+class ThirdPartyGoodCacheModel extends BaseModel
+{
+    public static function tablePk(): string
+    {
+        return 'product_id';
+    }
+
+    public static function tableName(): string
+    {
+        return 'third_party_good_cache';
+    }
+}

app/common/repositories/third/ThirdPartyGoodCacheRepository.php

@@ -0,0 +1,128 @@
+<?php
+
+namespace app\common\repositories\third;
+
+use app\common\dao\third\ThirdPartyGoodCacheDao;
+use app\common\enum\third\ThirdPartyGoodCacheEnum;
+use app\common\repositories\BaseRepository;
+use app\entity\data\third\ThirdPartyGoodCacheEntity;
+use think\exception\ValidateException;
+
+class ThirdPartyGoodCacheRepository extends BaseRepository
+{
+    /**
+     * @var ThirdPartyGoodCacheDao
+     */
+    protected $dao;
+
+    public function __construct(ThirdPartyGoodCacheDao $dao)
+    {
+        $this->dao = $dao;
+    }
+
+    public function create($data)
+    {
+        return $this->dao->create($data);
+    }
+
+    /**
+     * 写入贡献值记录
+     * @param ThirdPartyGoodCacheEntity $storeGroupOrderEntity
+     * @return ThirdPartyGoodCacheEntity
+     */
+    public function createByEntity(ThirdPartyGoodCacheEntity $storeGroupOrderEntity): ThirdPartyGoodCacheEntity
+    {
+        $result = $this->create($storeGroupOrderEntity->toUnderlineArray())->toArray();
+        /** @var ThirdPartyGoodCacheEntity $entity */
+        $entity = ThirdPartyGoodCacheEntity::newInstance($result);
+        return $entity;
+    }
+
+    /**
+     * @param $ids
+     * @param $data
+     * @return int
+     * @throws \think\db\exception\DbException
+     */
+    public function updates($ids, $data): int
+    {
+        return $this->dao->updates($ids, $data);
+    }
+
+    /**
+     * @param ThirdPartyGoodCacheEntity $thirdPartyProductEntity
+     * @return ThirdPartyGoodCacheEntity|false
+     * @throws \think\db\exception\DbException
+     */
+    public function updatesByEntity(ThirdPartyGoodCacheEntity $thirdPartyProductEntity)
+    {
+        $result = $this->updates([$thirdPartyProductEntity->getProductId()], $thirdPartyProductEntity->toUnderlineArray());
+        if (empty($result)) {
+            return false;
+        }
+        return $thirdPartyProductEntity;
+    }
+
+    /**
+     * @param string $productId
+     * @return ThirdPartyGoodCacheEntity
+     */
+    public function getThirdPartyGoodCacheEntityByProductId(string $productId): ThirdPartyGoodCacheEntity
+    {
+        $entityList = $this->getThirdPartyGoodCacheEntityListByProductIdList([$productId]);
+        $entity = array_shift($entityList);
+        if ($entity instanceof ThirdPartyGoodCacheEntity) {
+            return $entity;
+        } else {
+            /** @var ThirdPartyGoodCacheEntity */
+            return ThirdPartyGoodCacheEntity::newInstance();
+        }
+    }
+
+    /**
+     * @param array $productIdList
+     * @return ThirdPartyGoodCacheEntity[]
+     */
+    public function getThirdPartyGoodCacheEntityListByProductIdList(array $productIdList): array
+    {
+        return $this->dao->getThirdPartyGoodCacheEntityListByProductIdList($productIdList);
+    }
+
+    /**
+     * @param $param
+     * @return ThirdPartyGoodCacheEntity
+     * @throws \think\db\exception\DbException
+     */
+    public function saveGoodCacheByFit($param): ThirdPartyGoodCacheEntity
+    {
+        if (empty($param['skuId']) || empty($param['type'])) {
+            throw new ValidateException('缺少必要参数');
+        }
+        $skuId = $param['skuId'];
+        $platform = ThirdPartyGoodCacheEnum::platformCodeMapByThirdPartyGoodEnumTypeCode($param['type']);
+
+        /** @var ThirdPartyGoodCacheRepository $thirdPartyProductRepository */
+        $thirdPartyProductRepository = app()->make(ThirdPartyGoodCacheRepository::class);
+        $thirdPartyProductEntity = $thirdPartyProductRepository->getThirdPartyGoodCacheEntityByProductId($skuId);
+
+        if (empty($thirdPartyProductEntity->getProductId())) {
+            /** @var ThirdPartyGoodCacheEntity $thirdPartyProductEntity */
+            $thirdPartyProductEntity = ThirdPartyGoodCacheEntity::newInstance();
+            $thirdPartyProductEntity
+                ->setProductId($skuId)
+                ->setPlatform($platform)
+                ->setExtraContent($param);
+            $thirdPartyProductEntity = $thirdPartyProductRepository->createByEntity($thirdPartyProductEntity);
+            if (empty($thirdPartyProductEntity->getProductId())) {
+                throw new ValidateException('保存失败');
+            }
+        } else {
+            $thirdPartyProductEntity
+                ->setProductId($skuId)
+                ->setPlatform($platform)
+                ->setExtraContent($param);
+            $thirdPartyProductRepository->updatesByEntity($thirdPartyProductEntity);
+        }
+        return $thirdPartyProductEntity;
+    }
+}

app/controller/api/thirdParty/Taobao/EcoController.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace app\controller\api\thirdParty\Taobao;
+
+
+use app\services\ThirdParty\Taobao\ProductService;
+use think\Request;
+
+class EcoController
+{
+
+    /**
+     * 查询 商品信息
+     * @param Request $request
+     * @return mixed
+     */
+    public function searchProducts(Request $request)
+    {
+        try {
+            /** @var ProductService $productService */
+            $productService = app()->make(ProductService::class);
+            $products = $productService->searchProducts($request->param());
+            $productDataList = $productService->generateUniversalTemplate($products);
+            return app("json")->success($productDataList);
+        } catch (\Exception $exception) {
+            return app('json')->fail($exception->getMessage(), null, 401);
+        }
+    }
+}

app/controller/api/thirdParty/ThirdPartyGoodCacheController.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace app\controller\api\thirdParty;
+
+use app\common\repositories\third\ThirdPartyGoodCacheRepository;
+use think\db\exception\DbException;
+use think\Request;
+
+class ThirdPartyGoodCacheController
+{
+    protected $repository;
+
+    public function __construct(ThirdPartyGoodCacheRepository $repository)
+    {
+        $this->repository = $repository;
+    }
+
+    /**
+     * @param Request $request
+     * @return void
+     */
+    public function saveGoodCacheByFit(Request $request)
+    {
+        try {
+            $thirdPartyGoodCacheEntity = $this->repository->saveGoodCacheByFit($request->param());
+            return app("json")->success($thirdPartyGoodCacheEntity->toArray());
+        } catch (DbException $e) {
+            return app('json')->fail($e->getMessage(), null, 401);
+        }
+    }
+
+    public function getGoodCache(Request $request)
+    {
+        if (empty($request['productId'])) {
+            return app('json')->fail('缺少必要参数', null, 401);
+        }
+        $thirdPartyGoodCacheEntity = $this->repository->getThirdPartyGoodCacheEntityByProductId($request['productId']);
+        return app("json")->success($thirdPartyGoodCacheEntity->toArray());
+    }
+}

app/entity/data/third/ThirdPartyGoodCacheEntity.php

@@ -0,0 +1,107 @@
+<?php
+
+namespace app\entity\data\third;
+
+use app\entity\data\DataEntity;
+
+class ThirdPartyGoodCacheEntity extends DataEntity
+{
+    public $productId = null;  // 商品ID
+    public $platform = null;    // 所属平台前缀
+    public $extraContent = null; // 扩展信息
+    public $createTime = null;  // 添加时间
+    public $updateTime = null;  // 更新时间
+
+    /**
+     * @return mixed
+     */
+    public function getProductId()
+    {
+        return $this->productId;
+    }
+
+    /**
+     * @param mixed $productId
+     * @return ThirdPartyGoodCacheEntity
+     */
+    public function setProductId($productId): ThirdPartyGoodCacheEntity
+    {
+        $this->productId = $productId;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getPlatform()
+    {
+        return $this->platform;
+    }
+
+    /**
+     * @param mixed $platform
+     * @return ThirdPartyGoodCacheEntity
+     */
+    public function setPlatform($platform): ThirdPartyGoodCacheEntity
+    {
+        $this->platform = $platform;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getExtraContent()
+    {
+        return $this->extraContent;
+    }
+
+    /**
+     * @param mixed $extraContent
+     * @return ThirdPartyGoodCacheEntity
+     */
+    public function setExtraContent($extraContent): ThirdPartyGoodCacheEntity
+    {
+        if (is_array($extraContent)) {
+            $extraContent = json_encode($extraContent, JSON_UNESCAPED_UNICODE);
+        }
+        $this->extraContent = $extraContent;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getCreateTime()
+    {
+        return $this->createTime;
+    }
+
+    /**
+     * @param mixed $createTime
+     * @return ThirdPartyGoodCacheEntity
+     */
+    public function setCreateTime($createTime): ThirdPartyGoodCacheEntity
+    {
+        $this->createTime = $createTime;
+        return $this;
+    }
+
+    /**
+     * @return mixed
+     */
+    public function getUpdateTime()
+    {
+        return $this->updateTime;
+    }
+
+    /**
+     * @param mixed $updateTime
+     * @return ThirdPartyGoodCacheEntity
+     */
+    public function setUpdateTime($updateTime): ThirdPartyGoodCacheEntity
+    {
+        $this->updateTime = $updateTime;
+        return $this;
+    }
+}

app/services/ThirdParty/Taobao/ProductService.php

@@ -0,0 +1,143 @@
+<?php
+
+namespace app\services\ThirdParty\Taobao;
+
+use app\common\enum\third\ThirdPartyGoodCacheEnum;
+use app\common\enum\third\ThirdPartyGoodEnum;
+use app\utils\ArrayUtil;
+use think\exception\ValidateException;
+
+class ProductService extends TaobaoService
+{
+
+    protected $cat;
+
+    public function __construct()
+    {
+        parent::__construct();
+
+        $this->cat = $this->config['taobao']['cat'];
+    }
+
+    /**
+     * 商品搜索 TbkDgMaterialRecommendRequest
+     * 推广者使用，支持入参对应的“推广位”和官方提供的“物料id”，获取指定物料信息和推广链接。
+     * Tack：taobao.tbk.dg.material.optional.upgrade
+     * 官方文档地址：https://open.taobao.com/api.htm?spm=a219a.7386797.0.0.5cf2669aEojnlE&source=search&docId=64759&docType=2#responseParams
+     * @param $params
+     * @return mixed
+     */
+    public function searchProducts($params)
+    {
+        $req = new \TbkDgMaterialOptionalUpgradeRequest();
+        $this->batchSetProperties($req, $params);
+        $req->setAdzoneId($this->adzoneId);
+        // 商品筛选-后台类目ID 和 商品筛选-查询词 必须填一个
+        if (empty($req->getQ())) {
+            $req->setCat($this->cat);
+        }
+        // SimpleXMLElement
+        $res = $this->execute($req);
+        if (!$res) {
+            throw new ValidateException('网络错误，请稍后重试');
+        }
+        return $res;
+    }
+
+    /**
+     * @param $res
+     * @return array
+     */
+    public function generateUniversalTemplate($res): array
+    {
+        // 将 SimpleXMLElement 转换为数组
+        $resMap = json_decode(json_encode($res), true);
+        $productList = [];
+        if (!empty($resMap['result_list']['map_data'])) {
+            foreach ($resMap['result_list']['map_data'] as $data) {
+                // $productList[] = $data;
+                $coupon_money = [];
+                // 链接-宝贝+券二合一页面链接 || 链接-宝贝推广链接
+                $coupon_share_url = $data['publish_info']['coupon_share_url'] ?? ($data['publish_info']['click_url'] ?? '');
+                // 商品佣金金额
+                $commissionMoney = $data['publish_info']['income_info']['commission_amount'];
+                $commissionMoney = bcmul($commissionMoney, 0.8, 2);
+
+                // 到手价优惠路径列表 也就是 需要把列表内所有优惠叠加 才能从划线价 到达 到手价
+                if (!empty($data['price_promotion_info']['final_promotion_path_list']['final_promotion_path_map_data'])) {
+                    if (is_array($data['price_promotion_info']['final_promotion_path_list']['final_promotion_path_map_data'])) {
+                        $depth = ArrayUtil::array_depth($data['price_promotion_info']['final_promotion_path_list']['final_promotion_path_map_data']);
+                        if ($depth === 1) {
+                            $coupon_money[] = [
+                                'discount' => $data['price_promotion_info']['final_promotion_path_list']['final_promotion_path_map_data']['promotion_fee'], // 实际优惠金额（元）
+                                'getStartTime' => '',
+                                'getEndTime' => '',
+                                'link' => $data['publish_info']['coupon_share_url'] ?? '',
+                                'useStartTime' => '',
+                                'useEndTime' => '',
+                            ];
+                        } else {
+                            foreach ($data['price_promotion_info']['final_promotion_path_list']['final_promotion_path_map_data'] as $coupon) {
+                                if (!empty($coupon['promotion_fee']) && (0.00 < (double)$coupon['promotion_fee'])) {
+                                    $coupon_money[] = [
+                                        'discount' => $coupon['promotion_fee'], // 实际优惠金额（元）
+                                        'getStartTime' => '',
+                                        'getEndTime' => '',
+                                        'link' => $data['publish_info']['coupon_share_url'] ?? '',
+                                        'useStartTime' => '',
+                                        'useEndTime' => '',
+                                    ];
+                                }
+                            }
+                        }
+                    }
+
+                }
+
+                if (empty($data['item_id'])) {
+                    throw new ValidateException('缺少必要参数');
+                }
+                $skuId = $data['item_id'];
+                $segments = explode('-', $skuId);
+                $skuId = end($segments);
+                $skuId = ThirdPartyGoodCacheEnum::PLATFORM['Taobao']['code'] . '_' . $skuId;
+
+                $productList[] = [
+                    // 商品信息-淘宝客新商品id；
+                    'skuId' => $skuId,
+                    'itemId' => $data['item_id'],
+                    'type' => ThirdPartyGoodEnum::TYPE['Taobao']['code'],
+                    // 商品信息-商品标题
+                    'name' => $data['item_basic_info']['title'] ?? '',
+                    // 商品信息-商品主图
+                    'thumb' => $data['item_basic_info']['pict_url'] ?? '',
+
+                    'pv' => bcmul($commissionMoney, 0.7, 2),//PV金额
+                    'gongxian' => bcmul($commissionMoney, 0.7, 2),
+                    'jifen' => bcmul($commissionMoney, 0.7, 2),
+                    'yanglaojin' => bcmul($commissionMoney, 0.3, 2),
+
+                    // 商品佣金金额
+                    'commission' => $data['publish_info']['income_info']['commission_amount'] ?? 0.00,
+                    // 商品佣金比率
+                    'commission_rate' => bcdiv($data['publish_info']['income_info']['commission_rate'] ?? 0, 100, 2),
+                    // 优惠券集合
+                    'coupon_money' => $coupon_money,
+                    // 优惠券地址
+                    'coupon_link' => $coupon_share_url,
+                    // 最低 实际价格 促销信息-预估到手价(元)。若属于预售商品，付定金时间内，预估到手价价=定金+尾款的预估到手价
+                    'lowestCouponPrice' => $data['price_promotion_info']['final_promotion_price'],
+                    // 划线价 促销信息-销售价格，无促销时等于一口价，有促销时为促销价。若属于预售商品，付定金时间内，在线售卖价=预售价 ?? 商品信息-一口价通常显示为划线价
+                    'price' => $data['price_promotion_info']['zk_final_price'] ?? $data['price_promotion_info']['reserve_price'],
+                    'imageList' => $data['item_basic_info']['small_images']['string'],
+                    'materialUrl' => $coupon_share_url,
+                    // 最低 实际价格 促销信息-预估到手价(元)。若属于预售商品，付定金时间内，预估到手价价=定金+尾款的预估到手价
+                    'commission_' => $data['price_promotion_info']['final_promotion_price'],
+                    'monthSales' => 0.00,
+                    'cid' => 0
+                ];
+            }
+        }
+        return $productList;
+    }
+}

app/services/ThirdParty/Taobao/TaobaoService.php

@@ -0,0 +1,76 @@
+<?php
+
+namespace app\services\ThirdParty\Taobao;
+
+use think\facade\Config;
+use think\facade\Log;
+
+class TaobaoService
+{
+    protected $client;
+    protected $config;
+    protected $adzoneId;
+
+    public function __construct()
+    {
+        // 从配置文件读取淘宝联盟配置
+        $this->config = Config::get('third_party');
+
+        // 引入淘宝SDK
+        require_once app()->getRootPath() . 'extend/TaobaoSdk/TopSdk.php';
+
+        $this->client = new \TopClient();
+        $this->client->appkey = $this->config['taobao']['appKey'];
+        $this->client->secretKey = $this->config['taobao']['appSecret'];
+        // 推广位ID
+        $this->adzoneId = $this->config['taobao']['adzoneId'];
+    }
+
+    /**
+     * 执行API请求
+     * @param $request
+     * @return false|mixed
+     */
+    protected function execute($request)
+    {
+        try {
+            $response = $this->client->execute($request);
+            // var_dump($response);
+            return $this->formatResponse($response);
+        } catch (\Exception $e) {
+            // 记录错误日志
+            Log::error('淘宝API请求失败: ' . $e->getMessage());
+            return false;
+        }
+    }
+
+    /**
+     * 格式化响应
+     * @param $response
+     * @return false|mixed
+     */
+    protected function formatResponse($response)
+    {
+        if (isset($response->code) && $response->code) {
+            // API返回错误
+            Log::error("淘宝API错误: {$response->msg} [{$response->code}]");
+            return false;
+        }
+        return $response;
+    }
+
+    /**
+     * 批量设置对象属性
+     * @param object $object 目标对象
+     * @param array $params 参数数组
+     */
+    protected function batchSetProperties($object, array $params)
+    {
+        foreach ($params as $key => $value) {
+            $setter = 'set' . ucfirst($key);
+            if (method_exists($object, $setter)) {
+                $object->$setter($value);
+            }
+        }
+    }
+}

app/utils/ArrayUtil.php

@@ -43,4 +43,24 @@ class ArrayUtil
         }
         return null;
     }
+
+    /**
+     * 获取数组维度 几维数组
+     * @param $array
+     * @return int
+     */
+    public static function array_depth($array): int
+    {
+        if (!is_array($array)) return 0;
+        $max_depth = 1;
+        foreach ($array as $value) {
+            if (is_array($value)) {
+                $depth = self::array_depth($value) + 1;
+                if ($depth > $max_depth) {
+                    $max_depth = $depth;
+                }
+            }
+        }
+        return $max_depth;
+    }
 }

config/third_party.php

@@ -0,0 +1,12 @@
+<?php
+
+return [
+    'taobao' => [
+        'appKey' => '35214206',
+        'appSecret' => 'b4ec4e885fb4a189d3beb475fbb15dc6',
+        // 推广位ID
+        'adzoneId' => 116174700455,
+        // 商品筛选-后台类目ID。用,分割，最大10个
+        'cat' => '50016422,50012486,50008164,50002766,50050359,50022703,50000436,50011130,50011277,50020579'
+    ]
+];

route/api.php

@@ -32,6 +32,18 @@ Route::group('lplplp',function (){
     ->middleware(\app\common\middleware\InstallMiddleware::class)
     ->middleware(\app\common\middleware\CheckSiteOpenMiddleware::class);
 Route::group('api/', function () {
+
+    Route::group('thirdParty', function () {
+        // 保存第三方商品信息
+        Route::post('saveGoodCacheByFit', 'ThirdPartyGoodCacheController/saveGoodCacheByFit');
+        // 获取第三方商品信息
+        Route::get('getGoodCache', 'ThirdPartyGoodCacheController/getGoodCache');
+
+        Route::group('taobao', function () {
+            Route::get('eco/searchProducts', 'EcoController/searchProducts');
+        })->prefix('api.thirdParty.taobao.');
+    })->prefix('api.thirdParty.');
+
     Route::any('huiFuSettleIn','admin.system.merchant.MerchantIntention/huiFuSettleIn');//汇付入驻测试
     Route::any('test', 'api.Auth/test');
     Route::any('queryHaike', 'api.Auth/queryHaike');