php/app/controller/api/douhuomall/Take.php

<?php
namespace app\controller\api\douhuomall;

use app\traits\GongApiRequest;
use think\Exception;
use think\facade\Db;
use think\facade\Log;

class Take
{

    use GongApiRequest;

    public function get_goods_list(){
        try {
            set_time_limit(0);
            $allData = [];
            $page = 1;
            $limit = 100;
            $hasNextPage = true; // 是否有下一页的标志
            while ($hasNextPage) {
                $data = GongApiRequest::get_goods_list($page, $limit);
                if (!$data) {
                    break; // 如果请求失败，停止循环
                }
                $allData = array_merge($allData, $data['list']); // 数据在list键下
                if (!count($data['list']) || count($data['list']) < $limit) {
                    $hasNextPage = false; // 如果没有更多页面，停止循环
                } else {
                    $page++; // 增加页码数
                }
            }

            $goods_id_list = [];
            $spu_id_list = Db::name('douhuomall')->column('spu_id');
         
            // 同步到数据库
            foreach ($allData as $key=>$value) {
                sleep(1);
                // if($key != 0) continue;
                $goodsInfo = GongApiRequest::get_goods_info($value['goods_id']);
                if(!$goodsInfo) continue;

                //图片存放路径
                $targetDir = public_path() . 'images/gong/'.$value['goods_id'].'/';

                $this->deleteFilesInDirectory($targetDir);

                //spuId_info商品详细信息处理
                $goodsInfo['cover_url'] = $this->seveImg($value['goods_id'], $goodsInfo['main_img'], $targetDir);
                $goodsInfo['spu_id'] = $goodsInfo['goods_id'];

                $goodsInfo['detail'] = "";
                $detail_img = $this->seveImg($value['goods_id'], $goodsInfo['detail_img'], $targetDir);
                foreach($detail_img as $img_url){
                    $img_url = "<img src='".$img_url."' />";
                    $goodsInfo['detail'] = $goodsInfo['detail'].$img_url;
                }

                //sku信息处理
                $skuInfo = $goodsInfo['sku_list'];
                foreach ($skuInfo as $k=>$v) {
                    $skuInfo[$k]['cost_price'] = bcadd($v['plat_price'], bcmul($v['plat_price'], 0.03, 2),2);//成本价格 原来进价的基础上加百分之3
                    $skuInfo[$k]['market_price'] = bcadd($skuInfo[$k]['cost_price'], bcmul($skuInfo[$k]['cost_price'], 0.2, 2),2);//销售价格  售价在成本价格的基础上加百分20
                    $skuInfo[$k]['profit'] = bcdiv($skuInfo[$k]['cost_price'], $skuInfo[$k]['market_price'], 2);
                    $skuInfo[$k]['yanglaojin'] = '0.00';
                    if(count($v['attr'])){
                        $skuInfo[$k]['attribute_json'] = $v['attr'];
                    }else{
                        $skuInfo[$k]['attribute_json'] = [['val'=> '默认', 'name'=> '默认']];
                    }
                }
                unset($goodsInfo['sku_list']);

                $seveData = [
                    'spu_id' => $goodsInfo['spu_id'],
                    'skuId_info' => $skuInfo,
                    'sys_id' => '112',
                    'goods_id' => $goodsInfo['goods_id'],
                    'spuId_info' => $goodsInfo,
                    'sku_id' => $skuInfo[0]['sku_id'] ? $skuInfo[0]['sku_id'] : 0,
                    'status' => $goodsInfo['status'],
                    'cate_ids' => $goodsInfo['cate_ids'],
                    'title' => $goodsInfo['spu_name'],
                    'cxb_cate_id' => 0,   
                ];
                $this->add($seveData);
                $goods_id_list[] = $goodsInfo['spu_id'];
            }

            $goodsIds = array_diff($spu_id_list, $goods_id_list);
            $this->remove($goodsIds);
            return 'sussess';
        } catch (Exception $e) {
            Log::error('同步数据失败：' . $e->getMessage());
            echo '供应链拉取数据：' . $e->getFile() . '：' . $e->getLine() . '【' . $e->getMessage() . '】';
            return 'error';
        }
    }

    public function seveImg($goods_id, $img_url, $targetDir)
    {
        if (is_array($img_url)){
            $new_img_url = [];
            foreach ($img_url as $value) {
                $new_img_url[] = $this->seveImgUrl($goods_id, $value, $targetDir);
            }
        }else{  
            $new_img_url = $this->seveImgUrl($goods_id, $img_url, $targetDir);
        }
        return $new_img_url;
    }

    public function seveImgUrl($goods_id, $remoteImageUrl, $targetDir)
    {
        // 目标路径（确保目录存在）
        $targetDirTow = rand(1000, 10000). $this->upImgName(basename($remoteImageUrl));
        $targetPath = $targetDir . $targetDirTow; // 使用basename获取文件名
        
        // 检查目标目录是否存在，如果不存在则创建
        if (!is_dir($targetDir)) {
            mkdir($targetDir, 0777, true); // 第二个参数是权限，第三个参数是递归创建
        }
        
        // 获取远程图片内容
        $imageContent = file_get_contents($remoteImageUrl);
        
        // 检查是否成功获取内容
        if ($imageContent !== false) {
            // 保存图片到指定路径
            if (file_put_contents($targetPath, $imageContent)) {
                $new_img_url = env('APP_URL').'/images/gong/'.$goods_id.'/'. $targetDirTow;
                return $new_img_url;
            } else {
                echo "保存图片时发生错误。";
                return $remoteImageUrl;
            }
        } else {
            echo "无法获取远程图片内容。";
            return $remoteImageUrl;
        }
    }


    public function upImgName($filename)
    {
        $position = strpos($filename, '?');
        if ($position !== false) {
            $filename = substr($filename, 0, $position);
        }
        return $filename;
    }

    public function deleteFilesInDirectory($dir) {
        if (!is_dir($dir)) return true;

        // 打开目录
        $files = scandir($dir);
     
        // 遍历目录中的所有文件
        foreach ($files as $file) {
            // 如果是文件（排除 . 和 ..）
            if ($file !== '.' && $file !== '..') {
                $filePath = $dir . '/' . $file;
                // 删除文件
                if (is_file($filePath)) {
                    unlink($filePath);
                }
            }
        }
        return true;
    }


    public function add($data)
    {
        $findData = Db::name('douhuomall')->field('id,spu_id,status')->where('spu_id', $data['spu_id'])->find();
        try {
            $data['create_time'] = date('Y-m-d H:i:s');
            $data['update_time'] = date('Y-m-d H:i:s');
            $skuInfo = $this->arrSort($data['skuId_info'], 'cost_price', SORT_ASC);
            $data['cost_price'] = isset($skuInfo[0]['cost_price']) ? $skuInfo[0]['cost_price'] : 0;
            $data['market_price'] = isset($skuInfo[0]['market_price']) ? $skuInfo[0]['market_price'] : 0;
            $data['ot_price'] = isset($skuInfo[0]['retail_price']) ? $skuInfo[0]['retail_price'] : 0;
            $data['mer_profit'] = isset($skuInfo[0]['profit']) ? $skuInfo[0]['profit'] : 0;
            $data['pension'] = isset($skuInfo[0]['yanglaojin']) ? $skuInfo[0]['yanglaojin'] : 0;
            $data['profit'] = empty($data['cost_price']) || empty($data['market_price']) ? 0 : bcdiv($data['cost_price'], $data['market_price'], 2);
            if (empty($findData)) {
                $data['skuId_info'] = json_encode($data['skuId_info']);
                $data['spuId_info'] = json_encode($data['spuId_info']);
                Db::name('douhuomall')->insert($data);
            } else {
                Db::name('douhuomall')->where('spu_id', $findData['spu_id'])->update([
                    'status' => $data['status'],
                    'create_time' => date('Y-m-d H:i:s'),
                    'update_time' => date('Y-m-d H:i:s'),
                    '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']),
                    'spuId_info' => json_encode($data['spuId_info']),
                    'title' => $data['title'],
                    'cate_ids' => $data['cate_ids'],
                    'cxb_cate_id' => $data['cxb_cate_id']
                ]);
            }
            return true;
        } catch (Exception $e) {
            echo '供应链产品添加：' . $e->getFile() . '：' . $e->getLine() . '【' . $e->getMessage() . '】';
            return false;
        }
    }
    

    public function remove($goodsIds)
    {
        Db::startTrans();
        try{
            // 删除选品库对应的数据
            Db::name('douhuomall')->whereIn('spu_id', $goodsIds)->update([
                'status' => 3,
                'update_time' => date('Y-m-d H:i:s')
            ]);
            // 删除商品管理对应的数据
            Db::name('store_product')->whereIn('spu_id', $goodsIds)->update([
                'is_del' => 1,
                'is_show' => 0
            ]);
            Db::commit();
            return true;
        } catch (Exception $e) {
            Db::rollback();
            Log::channel("gong")->error('供应链取消商品失败：' . $e->getMessage());
            return false;
        }
    }


    /**
     * 二维数组根据某个字段排序
     * @param array $array 要排序的数组
     * @param string $keys   要排序的键字段
     * @param string $sort  排序类型  SORT_ASC     SORT_DESC
     * @return array 排序后的数组
     */
    function arrSort($array, $keys, $sort = SORT_DESC) {
        $keysValue = [];
        foreach ($array as $k => $v) {
            $keysValue[$k] = $v[$keys];
        }
        array_multisort($keysValue, $sort, $array);
        return $array;
    }
}