php/app/command/WiwibaoProductSync.php

<?php
declare (strict_types=1);

namespace app\command;

use app\common\enum\CommonEnum;
use app\common\enum\douhuomall\DouhuomallEnum;
use app\common\enum\store\ProductEnum;
use app\common\repositories\store\product\ProductRepository;
use app\traits\GongApiRequest;
use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\db\exception\DataNotFoundException;
use think\db\exception\DbException;
use think\db\exception\ModelNotFoundException;
use think\facade\Db;
use think\facade\Log;

class WiwibaoProductSync extends Command
{

    use GongApiRequest;

    // 配置参数
    protected $config = [
        'page_size' => 100,      // 每页拉取数量
        'max_pages' => 0,       // 最大页数限制
        'price_change_rate' => 0.0, // 价格变动比率阈值（10%）
        'mer_id' => CommonEnum::DESIGN_MERCHANT_ID['WonderfulLiving']['code']
    ];

    protected function configure()
    {
        // 指令配置
        $this->setName('wiwibaoproductsync')
            ->setDescription('the wiwibaoproductsync command');
    }

    protected function execute(Input $input, Output $output)
    {
        $output->writeln('定时任务执行中...');

        $this->syncGoodsFromGong();

        $output->writeln('定时任务执行完成');
    }

    /**
     * 同步微唯宝商品数据（主方法）
     */
    public function syncGoodsFromGong()
    {
        try {
            set_time_limit(0);

            // 1. 批量拉取所有商品数据
            $allProducts = $this->fetchAllProducts();

            if (empty($allProducts)) {
                Log::info('未拉取到任何商品数据');
                return 'success';
            }

            // 2. 获取本地所有SPU ID
            $douhuomallDataMap = [];
            $localSpuIds = [];
            $douhuomallDataList = Db::name('douhuomall')
                ->select()
                ->toArray();
            if (!empty($douhuomallDataList)) {
                $douhuomallDataMap = array_column($douhuomallDataList, null, 'spu_id');
                $localSpuIds = array_keys($douhuomallDataMap);
            }

            $syncedSpuIds = [];

            // 3. 批量处理商品数据
            foreach ($allProducts as $product) {
                try {
                    $spuId = $this->processSingleProduct($product, $douhuomallDataMap[$product['goods_id']] ?? []);
                    if ($spuId) {
                        $syncedSpuIds[] = $spuId;
                    }
                } catch (\Exception $e) {
                    Log::error("处理商品 {$product['goods_id']} 失败: " . $e->getMessage());
                    continue;
                }
            }

            // 4. 处理需要下架的商品（本地有但第三方已下架）
            $this->handleOfflineProducts($localSpuIds, $syncedSpuIds);

            return 'success';

        } catch (\Exception $e) {
            $this->logError('商品同步失败', $e);
            return 'error';
        }
    }

    /**
     * 批量拉取所有商品数据
     */
    protected function fetchAllProducts()
    {
        $allData = [];

        // 第一页
        $firstPageData = GongApiRequest::get_goods_list(1, $this->config['page_size']);
        if (empty($firstPageData['list'])) {
            return [];
        }

        $allData = $firstPageData['list'];
        $totalPages = $firstPageData['pages'] ?? 1;
        if (!empty($this->config['max_pages'])) {
            $totalPages = min($totalPages, $this->config['max_pages']);
        }

        // 并行获取剩余页面
        for ($page = 2; $page <= $totalPages; $page++) {
            $pageData = GongApiRequest::get_goods_list($page, $this->config['page_size']);
            if (!empty($pageData['list'])) {
                $allData = array_merge($allData, $pageData['list']);
            }
        }

        return $allData;
    }

    /**
     * 处理单个商品
     */
    protected function processSingleProduct($productData, $douhuomallData)
    {
        $goodsId = $productData['goods_id'];

        // 1. 获取商品详情
        $goodsInfo = GongApiRequest::get_goods_info($goodsId);
        if (!$goodsInfo) {
            return null;
        }

        // 2. 处理图片信息
        $imageData = $this->processProductImages($goodsId, $goodsInfo);

        // 3. 处理SKU信息
        $skuInfo = $this->processSkuInfo($goodsInfo['sku_list'] ?? [], $goodsId);

        // 4. 构建保存数据
        $saveData = $this->buildSaveData($goodsInfo, $skuInfo, $imageData);

        // 5. 保存到本地（使用原有的add方法逻辑）
        $spuId = $this->addToDouhuomall($saveData, $douhuomallData);

        // 6. 检查并处理已上架商品的价格变动
        $this->checkAndProcessOnlineProduct($spuId, $saveData);

        return $spuId;
    }

    /**
     * 处理商品图片信息
     */
    protected function processProductImages($goodsId, $goodsInfo)
    {
        // 如果你需要保存图片到本地，可以在这里实现
        // 否则直接返回URL
        return [
            'cover_url' => $goodsInfo['main_img'] ?? '',
            'detail_images' => $goodsInfo['detail_img'] ?? [],
            'detail_img_list' => $goodsInfo['detail_img'] ?? [] // 为了兼容以前写的代码，建议保留这个数据项，之前用的是detail_img_list字段，但我感觉他们意义一样
        ];
    }

    /**
     * 处理SKU信息
     */
    protected function processSkuInfo($skuList, $goodsId)
    {
        if (empty($skuList)) {
            return [];
        }

        $processedSkus = [];
        foreach ($skuList as $sku) {
            if (empty($sku['plat_price'])) {
                continue;
            }

            $processedSku = [
                'sku_id' => $sku['sku_id'] ?? 0,
                'plat_price' => $sku['plat_price'],
                'img_url' => $sku['main_img'],
                'retail_price' => $sku['retail_price'] ?? 0,
                'cost_price' => $this->calculateCostPrice($sku['plat_price']),
                'market_price' => $this->calculateMarketPrice($sku['plat_price']),
                'profit' => $this->calculateProfit($sku['plat_price']),
                'mer_profit' => $this->calculateMerProfit($sku['plat_price']),
                'yanglaojin' => '0.00',
                'main_img' => $sku['main_img'] ?? '',
                'attribute_json' => !empty($sku['attr']) ? $sku['attr'] : [['val' => '默认', 'name' => '默认']]
            ];

            $processedSkus[] = array_merge($sku, $processedSku);
        }

        return $processedSkus;
    }

    /**
     * 构建保存数据
     */
    protected function buildSaveData($goodsInfo, $skuInfo, $imageData)
    {
        // 构建详情HTML
        $detailHtml = $this->buildDetailHtml($imageData['detail_images']);

        return [
            'spu_id' => $goodsInfo['goods_id'],
            'skuId_info' => $skuInfo,
            'sys_id' => '112',
            'goods_id' => $goodsInfo['goods_id'],
            'spuId_info' => array_merge(
                $goodsInfo,
                [
                    'cover_url' => $imageData['cover_url'],
                    'detail' => $detailHtml,
                    'detail_img_list' => $imageData['detail_img_list']
                ]
            ),
            'sku_id' => $skuInfo[0]['sku_id'] ?? 0,
            'status' => $goodsInfo['status'] ?? 0,
            'cate_ids' => $goodsInfo['cate_ids'] ?? '',
            'title' => $goodsInfo['spu_name'] ?? '',
            'cxb_cate_id' => 0
        ];
    }

    /**
     * 构建详情HTML
     */
    protected function buildDetailHtml($detailImages)
    {
        if (empty($detailImages)) {
            return '';
        }

        $detailHtml = '';
        foreach ((array)$detailImages as $imgUrl) {
            $detailHtml .= "<img src='{$imgUrl}' referrerpolicy='no-referrer' />";
        }

        return $detailHtml;
    }

    /**
     * @param $data
     * @param $findData
     * @return mixed
     * @throws DbException
     */
    protected function addToDouhuomall($data, $findData)
    {
        try {
            // 对SKU按成本价排序，获取最低成本价的SKU
            $skuInfo = $this->arrSort($data['skuId_info'], 'cost_price', SORT_ASC);

            // 计算价格字段
            $data['cost_price'] = $skuInfo[0]['cost_price'] ?? 0;
            $data['market_price'] = $skuInfo[0]['market_price'] ?? 0;
            $data['ot_price'] = $skuInfo[0]['retail_price'] ?? 0;
            $data['mer_profit'] = $skuInfo[0]['mer_profit'] ?? 0;
            $data['pension'] = $skuInfo[0]['yanglaojin'] ?? 0;
            $data['profit'] = (empty($data['cost_price']) || empty($data['market_price']))
                ? 0
                : bcdiv((string)$data['market_price'], (string)$data['cost_price'], 2);

            $now = date('Y-m-d H:i:s');

            if (empty($findData)) {
                // 新增
                $insertData = [
                    'spu_id' => $data['spu_id'],
                    'skuId_info' => json_encode($data['skuId_info'], JSON_UNESCAPED_UNICODE),
                    'sys_id' => $data['sys_id'],
                    'goods_id' => $data['goods_id'],
                    'spuId_info' => json_encode($data['spuId_info'], JSON_UNESCAPED_UNICODE),
                    'create_time' => $now,
                    'update_time' => $now,
                    'sku_id' => $data['sku_id'],
                    'status' => $data['status'],
                    'cate_ids' => $data['cate_ids'],
                    'title' => $data['title'],
                    'cost_price' => $data['cost_price'],
                    'market_price' => $data['market_price'],
                    'ot_price' => $data['ot_price'],
                    'profit' => $data['profit'],
                    'mer_profit' => $data['mer_profit'],
                    'pension' => $data['pension'],
                    'cxb_cate_id' => $data['cxb_cate_id']
                ];
                Db::name('douhuomall')->insert($insertData);
            } else {
                // 更新
                //  无意义 // 检查是否需要恢复已删除商品的上架状态
                // $shouldRestore = $this->shouldRestoreProduct($findData, $data);
                // if ($shouldRestore) {
                //     $this->restoreProduct($data['spu_id']);
                // }
                $updateData = [
                    'status' => $data['status'],
                    'update_time' => $now,
                    'cost_price' => $data['cost_price'],
                    'market_price' => $data['market_price'],
                    'ot_price' => $data['ot_price'],
                    'mer_profit' => $data['mer_profit'],
                    'pension' => $data['pension'],
                    'profit' => $data['profit'],
                    'skuId_info' => json_encode($data['skuId_info'], JSON_UNESCAPED_UNICODE),
                    'spuId_info' => json_encode($data['spuId_info'], JSON_UNESCAPED_UNICODE),
                    'title' => $data['title'],
                    'cate_ids' => $data['cate_ids'],
                    'cxb_cate_id' => $data['cxb_cate_id']
                ];
                Db::name('douhuomall')
                    ->where('spu_id', $findData['spu_id'])
                    ->update($updateData);
            }

            return $data['spu_id'];

        } catch (\Exception $e) {
            Log::error("保存商品到douhuomall失败: " . $e->getMessage());
            throw $e;
        }
    }

    /**
     * 检查是否需要恢复已删除商品的上架状态
     */
    protected function shouldRestoreProduct($findData, $newData)
    {
        // 原有逻辑：如果货物属于已被删除状态，并且新更新进来的状态非删除状态
        // 并且成本价、零售价、市场价、利润率没有变动的话
        if ($findData['status'] == DouhuomallEnum::STATUS['Delete']['code']
            && $newData['status'] !== DouhuomallEnum::STATUS['Delete']['code']
            && $newData['cost_price'] == $findData['cost_price']
            && $newData['ot_price'] == $findData['ot_price']
            && $newData['market_price'] == $findData['market_price']
            && $newData['profit'] == $findData['profit']) {

            // 检查是否有已下架的商品
            $count = Db::name('store_product')
                ->where('spu_id', $newData['spu_id'])
                ->where('is_show', ProductEnum::IS_SHOW['No']['code'])
                ->where('is_status', ProductEnum::IS_STATUS['Automatic']['code'])
                ->count();

            return $count > 0;
        }

        return false;
    }

    /**
     * 恢复商品上架状态
     */
    protected function restoreProduct($spuId)
    {
        Db::name('store_product')
            ->where('spu_id', $spuId)
            ->update([
                'is_show' => ProductEnum::IS_SHOW['Yes']['code'],
                'status' => ProductEnum::STATUS['Approved']['code']
            ]);

        Log::info("恢复商品上架（恢复到仓库中）状态: spu_id={$spuId}");
    }

    /**
     * 检查并处理已上架商品
     */
    protected function checkAndProcessOnlineProduct($spuId, $syncData)
    {
        // 检查商品是否已上架
        try {
            $productList = Db::name('store_product')
                // ->where('is_show', ProductEnum::IS_SHOW['Yes']['code'])
                ->where('spu_id', $spuId)
                ->select()
                ->toArray();

            if (empty($productList)) {
                // 如果没有该商品则自动上架
                $this->insert_product($spuId, $this->config['mer_id']);
                return;
            }

            // 解析同步数据中的价格
            $syncPrices = [];
            foreach ($syncData['skuId_info'] as $sku) {
                $syncPrices[] = [
                    'sku_id' => $sku['sku_id'] ?? '',
                    'market_price' => $sku['market_price'] ?? 0,
                    'cost_price' => $sku['cost_price'] ?? 0,
                    'retail_price' => $sku['retail_price'] ?? 0
                ];
            }

            foreach ($productList as $product) {

                if ($product['is_show'] == ProductEnum::IS_SHOW['No']['code'] && $product['is_status'] == ProductEnum::IS_STATUS['Triggered']['code']) {
                    // 如果商品 属于未上架商品（或是被员工下架了） 则不做任何处理
                    continue;
                }

                // 获取本地商品价格信息
                // 获取SKU价格
                $skus = Db::name('store_product_attr_value')
                    ->where('product_id', $product['product_id'])
                    ->field('gong_sku_id, sku, price, cost')
                    ->select()
                    ->toArray();
                $localPrices = [
                    'product_price' => $product['price'] ?? 0,
                    'product_cost' => $product['cost'] ?? 0,
                    'product_ot_price' => $product['ot_price'] ?? 0,
                    'skus' => $skus
                ];

                // 比较价格，判断是否需要下架
                $priceChanged = $this->checkPriceChange($localPrices, $syncPrices);

                if ($priceChanged['result'] ?? false) {
                    // 价格变动超过阈值，下架商品并记录
                    // $this->offlineProductWithRecord($product, $syncData, $localPrices, $syncPrices);

                    $changeSkuAttrDataList = [];
                    foreach ($skus as $sku) {
                        $edit_price = bcadd(
                            $sku['price'],
                            (string)$priceChanged['sku_difference_map'][$sku['gong_sku_id']] ?? ($priceChanged['spu_difference'] ?? '0.00'),
                            2
                        );
                        Log::info('商品价格变动：' . json_encode([
                                'product_id' => $product['product_id'],
                                'sku_id' => $sku['gong_sku_id'],
                                'before_price' => $sku['price'],
                                'edit_price' => $edit_price
                            ])
                        );
                        $changeSkuAttrDataList[] = [
                            'sku_id' => $sku['gong_sku_id'],
                            'edit_price' => $edit_price
                        ];
                    }
                    // 新规则 根据价格变动 增减商品售价
                    /** @var ProductRepository $productRepository */
                    $productRepository = app()->make(ProductRepository::class);
                    $productRepository->editPrice($product['product_id'], $changeSkuAttrDataList);

                    // 如果是系统下架的商品 则对商品重新上架
                    if ($product['is_show'] == ProductEnum::IS_SHOW['No']['code'] && $product['is_status'] == ProductEnum::IS_STATUS['Automatic']['code']) {
                        $this->restoreProduct($product['spu_id']);
                    }
                } else {
                    // 价格未变动或变动很小，只更新图片
                    $this->updateProductImages($spuId);
                }
            }
        } catch (DataNotFoundException|ModelNotFoundException|DbException $e) {

        }
    }

    /**
     * 检查价格是否变动超过阈值
     */
    protected function checkPriceChange($localPrices, $syncPrices)
    {
        $res = [
            'result' => false,
            'spu_difference' => 0.00,
            'sku_difference_map' => []
        ];
        // 如果成本价不变 则没有必要更新商品信息
        // 如果没有SKU，比较商品主价格
        if (empty($localPrices['skus'])) {
            $localPrice = $localPrices['product_cost'];
            $syncPrice = $syncPrices[0]['cost_price'] ?? 0;

            if ($localPrice > 0 && $syncPrice > 0) {
                $changeRate = abs(($syncPrice - $localPrice) / $localPrice);
                $res['result'] = $changeRate > $this->config['price_change_rate'];
                $res['spu_difference'] = bcsub((string)$syncPrice, $localPrice, 2);
            }
            return $res;
        }

        // 如果有SKU，匹配SKU进行比较
        foreach ($localPrices['skus'] as $localSku) {
            foreach ($syncPrices as $syncSku) {
                // 尝试匹配SKU
                if ($this->matchSku($localSku, $syncSku)) {
                    $localPrice = $localSku['cost'] ?? 0;
                    $syncPrice = $syncSku['cost_price'] ?? 0;

                    if ($localPrice > 0 && $syncPrice > 0) {
                        $changeRate = abs(($syncPrice - $localPrice) / $localPrice);
                        $res['result'] = $changeRate > $this->config['price_change_rate'];
                        $res['sku_difference_map'][$localSku['gong_sku_id']] = bcsub((string)$syncPrice, $localPrice, 2);
                    }
                }
            }
        }

        return $res;
    }

    /**
     * 匹配SKU（根据业务逻辑实现）
     */
    protected function matchSku($localSku, $syncSku)
    {
        // 根据SKU ID匹配
        if (!empty($localSku['gong_sku_id']) && !empty($syncSku['sku_id'])) {
            return $localSku['gong_sku_id'] == $syncSku['sku_id'];
        }

        // 可以根据其他属性匹配，如规格等
        return false;
    }

    /**
     * 下架商品并记录变动
     */
    protected function offlineProductWithRecord($product, $syncData, $localPrices, $syncPrices)
    {
        $productId = $product['product_id'];
        $spuId = $product['spu_id'];

        // 1. 收集变动前数据
        $beforeData = [
            'product_id' => $productId,
            'spu_id' => $spuId,
            'title' => $product['store_name'] ?? '',
            'status' => $product['is_show'] ?? 0,
            'price_info' => $localPrices,
            'images' => [
                'image' => $product['image'] ?? '',
                'slider_image' => $product['slider_image'] ?? ''
            ],
            'record_time' => date('Y-m-d H:i:s')
        ];

        // 2. 下架商品
        Db::name('store_product')
            ->where('product_id', $productId)
            ->update([
                'is_show' => ProductEnum::IS_SHOW['No']['code'],
                'status' => ProductEnum::STATUS['Withdrawn']['code'],
                'is_status' => ProductEnum::IS_STATUS['Automatic']['code']
            ]);

        // 3. 收集变动后数据
        $afterData = [
            'spu_id' => $spuId,
            'sync_price_info' => $syncPrices,
            'sync_title' => $syncData['title'],
            'sync_status' => $syncData['status'],
            'sync_time' => date('Y-m-d H:i:s')
        ];

        // 4. 记录变动日志
        $this->recordChangeLog(
            $productId,
            $spuId,
            'price_change',
            '第三方平台价格变动超过阈值',
            $beforeData,
            $afterData
        );

        Log::info("商品下架: product_id={$productId}, spu_id={$spuId}, 原因: 价格变动");
    }

    /**
     * 更新商品图片（基于原有updata_product_img方法）
     */
    protected function updateProductImages($spuId)
    {
        // 1. 验证该SPU是否已上架
        $productId = Db::name('store_product')
            ->where('spu_id', $spuId)
            ->value('product_id');

        if (!$productId) {
            return true;
        }

        // 2. 查找微唯宝商品
        $data = Db::name('douhuomall')
            ->where('spu_id', $spuId)
            ->find();

        if (!$data) {
            return false;
        }

        // 3. 解析商品信息
        $spuIdInfo = json_decode($data['spuId_info'], true);

        // 4. 处理图片数据
        $sliderImage = $spuIdInfo['detail_img_list'] ?: '[]';
        $image = $spuIdInfo['cover_url'] ?? '';

        if (is_string($sliderImage)) {
            $sliderImage = implode(',', json_decode($sliderImage, true));
        } else if (is_array($sliderImage)) {
            $sliderImage = implode(',', $sliderImage);
        } else {
            $sliderImage = $image;
        }

        // 5. 更新产品图片数据
        $updateData = [
            'image' => $image,
            'slider_image' => $sliderImage,
        ];

        Db::name('store_product')
            ->where('product_id', $productId)
            ->update($updateData);

        // 6. 更新商品详情
        $detail = $spuIdInfo['detail'] ?? '';
        if (!is_null(json_decode($detail))) {
            $detailList = json_decode($detail);
            $newDetail = '';
            foreach ($detailList as $value) {
                $newDetail .= "<img src='{$value}' referrerpolicy='no-referrer' /></img>";
            }
            $detail = $newDetail;
        }

        Db::name('store_product_content')
            ->where('product_id', $productId)
            ->update(['content' => $detail]);

        return true;
    }

    /**
     * 处理需要下架的商品（第三方已下架）
     */
    protected function handleOfflineProducts($localSpuIds, $syncedSpuIds)
    {
        $offlineSpuIds = array_diff($localSpuIds, $syncedSpuIds);

        if (empty($offlineSpuIds)) {
            return;
        }

        foreach ($offlineSpuIds as $spuId) {
            $this->offlineProductBySpuId($spuId, 'third_party_offline');
        }

        Log::info("下架第三方已下架商品" . json_encode(['count' => count($offlineSpuIds), 'spu_ids' => $offlineSpuIds]));
    }

    /**
     * 根据SPU ID下架商品
     */
    protected function offlineProductBySpuId($spuId, $reason)
    {
        // 查找已上架的商品
        $products = Db::name('store_product')
            ->where('spu_id', $spuId)
            ->select();
        $douhuomallData = Db::name('douhuomall')->where('spu_id', $spuId)->select()->toArray();

        foreach ($products as $product) {
            // 下架商品
            Db::name('store_product')
                ->where('product_id', $product['product_id'])
                ->update([
                    'is_show' => ProductEnum::IS_SHOW['No']['code'],
                    'status' => ProductEnum::STATUS['Withdrawn']['code'],
                    'is_status' => ProductEnum::IS_STATUS['Automatic']['code']
                ]);

            // 记录日志
            $this->recordChangeLog(
                $product['product_id'],
                $spuId,
                'third_party_offline',
                $reason,
                ['product' => $product, 'douhuomallData' => $douhuomallData],
                []
            );
        }

        // 从douhuomall表中删除
        Db::name('douhuomall')->where('spu_id', $spuId)->delete();
    }

    /**
     * 记录变动日志
     */
    protected function recordChangeLog($productId, $spuId, $changeType, $reason, $beforeData, $afterData)
    {
        $logData = [
            'product_id' => $productId,
            'spu_id' => $spuId,
            'change_type' => $changeType,
            'change_reason' => $reason,
            'before_data' => json_encode($beforeData, JSON_UNESCAPED_UNICODE),
            'after_data' => json_encode($afterData, JSON_UNESCAPED_UNICODE),
            'change_time' => time(),
            'create_time' => time()
        ];

        Db::name('product_change_log')->insert($logData);
    }

    /**
     * 数组排序（从原有add方法中提取）
     */
    protected function arrSort($array, $keys, $sort = SORT_DESC)
    {
        $keysValue = [];
        foreach ($array as $k => $v) {
            $keysValue[$k] = $v[$keys] ?? 0;
        }
        array_multisort($keysValue, $sort, $array);
        return $array;
    }

    /**
     * 计算成本价
     */
    protected function calculateCostPrice($platPrice)
    {
        return bcadd((string)$platPrice, bcmul((string)$platPrice, '0.03', 4), 2);
    }

    /**
     * 计算市场价
     */
    protected function calculateMarketPrice($platPrice)
    {
        $costPrice = $this->calculateCostPrice($platPrice);
        return bcadd($costPrice, bcmul($costPrice, '0.2', 4), 2);
    }

    /**
     * 计算利润率
     */
    protected function calculateProfit($platPrice)
    {
        $costPrice = $this->calculateCostPrice($platPrice);
        $marketPrice = $this->calculateMarketPrice($platPrice);
        return bcdiv($marketPrice, $costPrice, 2);
    }

    /**
     * 计算毛利
     */
    protected function calculateMerProfit($platPrice)
    {
        $costPrice = $this->calculateCostPrice($platPrice);
        $marketPrice = $this->calculateMarketPrice($platPrice);
        return bcsub($marketPrice, $costPrice, 2);
    }

    /**
     * 记录错误
     */
    protected function logError($message, \Exception $e)
    {
        $errorInfo = [
            'message' => $message,
            'file' => $e->getFile(),
            'line' => $e->getLine(),
            'error' => $e->getMessage()
        ];

        Log::error('商品同步错误' . json_encode($errorInfo, JSON_UNESCAPED_UNICODE));

        Db::name('log')->insert([
            'data' => json_encode($errorInfo, JSON_UNESCAPED_UNICODE),
            'time' => date('Y-m-d H:i:s')
        ]);
    }

    // 借用 app\controller\merchant\gong\Goods.php 控制器内方法

    /**
     * 将 微唯宝商品 选品（加入） 到系统内部商户商品表
     * @param $spu_id
     * @param $mer_id
     * @return bool
     */
    public function insert_product($spu_id, $mer_id)
    {
        try {
            // 1、获取商品信息
            $data = Db::name('douhuomall')->where('spu_id', $spu_id)->find();

            // 2、是否为多规格
            $sku_data = json_decode($data['skuId_info'], true);
            $spec_type = count($sku_data);
            if ($spec_type > 1) {
                $spec_type = 1;
            } else {
                $spec_type = 0;
            }

            // 3、商品主图
            $spuId_info = json_decode($data['spuId_info'], true);
            $slider_image = $spuId_info['detail_img_list'] ?? '';
            $image = $spuId_info['cover_url'] ?? '';
            if (empty($slider_image)) {
                $slider_image = $image;
            } else if (is_string($slider_image)) {
                $slider_image = implode(',', json_decode($slider_image, true));
            } else if (is_array($slider_image)) {
                $slider_image = implode(',', $slider_image);
            }
            $yanglaojin_scale = (!empty($data['pension']) && !empty($data['market_price'])) ? bcdiv($data['pension'], $data['market_price'], 2) : 0;

            // 4、商品入库数据
            $product_insert_data = [
                'mer_id' => $mer_id,
                'image' => $image,
                'slider_image' => $slider_image,
                'store_name' => $data['title'],
                'store_info' => 1,
                'keyword' => mb_substr($data['title'], 0, 3),
                'is_show' => 1,
                'status' => 1,
                'cate_id' => $data['cate_ids'],
                'unit_name' => '个',
                'price' => $data['market_price'],
                'cost' => $data['cost_price'],
                'ot_price' => $data['ot_price'],
                'stock' => '1000',
                'spec_type' => $spec_type,
                'extension_type' => 1,
                'mer_status' => 1,
                'is_used' => 1,
                'old_product_id' => $data['id'],
                'volunteer' => 0,
                'type' => 1,
                'pension' => '0.00',
                'commission' => 5,
                'spu_id' => $data['spu_id'],
                'temp_id' => 105,
                'plate_mer_profit' => $data['mer_profit'],
                'concession_pri' => $data['mer_profit'],
                'yanglaojin_scale' => $yanglaojin_scale
            ];
            $insert_id = Db::name('store_product')->insertGetId($product_insert_data);

            // 5、更新商品详情表
            $detail = $spuId_info['detail'];
            if (!is_null(json_decode($detail))) {
                $detail_list = json_decode($detail);
                $detail = '';
                foreach ($detail_list as $value) {
                    $detail .= '<img src="' . $value . '"></img>';
                }
            }
            Db::name('store_product_content')->insert(['content' => $detail, 'product_id' => $insert_id]);

            // 6、
            $this->insert_sku($insert_id, $sku_data);
            return true;
        } catch (\Exception $e) {
            Log::error($spu_id . "加入选品失败：" . $e->getMessage());
            return false;
        }
    }

    // 借用 app\controller\merchant\gong\Goods.php 控制器内方法
    public function insert_sku($id, $data)
    {
        // 1、获取 所有SKU的 规格属性值
        $sku_attr_data = array_column($data, 'attribute_json');
        $name = '';

        // 2、写入 商品属性表
        /** @var ProductRepository $ProductRepository */
        $ProductRepository = app()->make(ProductRepository::class);
        if (empty($sku_attr_data[0][0])) {
            // 写入商品属性表
            Db::name('store_product_attr')->insert(['product_id' => $id, 'attr_name' => '规格', 'attr_values' => $name]);
            $key = '';
            $num = 1;
            // 写入 SKU 商品属性值表
            foreach ($data as $k => $v) {
                Db::name('store_product_attr_value')->insert([
                    'product_id' => $id,
                    'detail' => json_encode(['规格' => $key]),
                    'sku' => $key,
                    'image' => $v['img_url'],
                    'cost' => $v['cost_price'],
                    'ot_price' => $v['retail_price'],
                    'price' => $v['market_price'],
                    'unique' => $ProductRepository->setUnique($id, $v['sku_id'], 0),
                    'stock' => 100,
                    'cost_price' => $v['cost_price'],
                    'extension_one' => 5,
                    'gong_sku_id' => $v['sku_id'],
                    'gong_mer_profit' => $v['mer_profit'],
                    'gong_pension' => $v['yanglaojin'],
                    'gong_market_price' => $v['market_price'],
                    'plate_mer_profit' => $v['mer_profit']
                ]);
                $key = '';
                $num++;
            }
        } else {
            foreach ($sku_attr_data as $kk => $vv) {
                foreach ($vv as $k1 => $v1) {
                    $name .= $v1['val'];
                }
                $name .= '-!-';
            }
            $name = rtrim($name, '-!-');
            Db::name('store_product_attr')->insert(['product_id' => $id, 'attr_name' => '规格', 'attr_values' => $name]);
            $key = '';
            $num = 1;
            foreach ($data as $k => $v) {
                foreach ($v['attribute_json'] as $k2 => $v2) {
                    $key .= $v2['val'];
                }

                Db::name('store_product_attr_value')->insert([
                    'product_id' => $id,
                    'detail' => json_encode(['规格' => $key]),
                    'sku' => $key,
                    'image' => $v['img_url'],
                    'cost' => $v['cost_price'],
                    'ot_price' => $v['retail_price'],
                    'price' => $v['market_price'],
                    'unique' => $ProductRepository->setUnique((int)$id, $v['sku_id'], 0),
                    'stock' => 100,
                    'cost_price' => $v['cost_price'],
                    'extension_one' => 5,
                    'gong_sku_id' => $v['sku_id'],
                    'gong_mer_profit' => $v['mer_profit'],
                    'gong_pension' => $v['yanglaojin'],
                    'gong_market_price' => $v['market_price'],
                    'plate_mer_profit' => $v['mer_profit']
                ]);
                $key = '';
                $num++;
            }
        }
    }
}