梳理拉取微唯宝商品代码

app/controller/api/douhuomall/Take.php

@@ -11,9 +11,17 @@ class Take
 
     use GongApiRequest;
 
-    public function get_goods_list(){
+    /**
+     * 同步 微唯宝 商品数据
+     * @return string
+     */
+    public function get_goods_list()
+    {
         try {
+            // 1、不设置超时
             set_time_limit(0);
+
+            // 2、循环拉取 商品 数据
             $allData = [];
             $page = 1;
             $limit = 100;
@@ -31,45 +39,48 @@ class Take
                 }
             }
 
+            // 3、获取 微唯宝 商品表 SPUId集合
             $goods_id_list = [];
             $spu_id_list = Db::name('douhuomall')->column('spu_id');
-         
+
+            // 4、
             // 同步到数据库
-            foreach ($allData as $key=>$value) {
+            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'].'/';
+                // 4.1 获取商品详情
+                $goodsInfo = GongApiRequest::get_goods_info($value['goods_id']);
+                if (!$goodsInfo) continue;
 
+                // 4.2 图片存放路径
+                $targetDir = public_path() . 'images/gong/' . $value['goods_id'] . '/';
+                // 4.3 清空路径下的文件
                 $this->deleteFilesInDirectory($targetDir);
 
-                //spuId_info商品详细信息处理
+                // 4.4 获取图片地址 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."' referrerpolicy='no-referrer' />";
-                    $goodsInfo['detail'] = $goodsInfo['detail'].$img_url;
+                foreach ($detail_img as $img_url) {
+                    $img_url = "<img src='" . $img_url . "' referrerpolicy='no-referrer' />";
+                    $goodsInfo['detail'] = $goodsInfo['detail'] . $img_url;
                 }
 
                 //sku信息处理
                 $skuInfo = $goodsInfo['sku_list'];
-                foreach ($skuInfo as $k=>$v) {
+                foreach ($skuInfo as $k => $v) {
                     $skuInfo[$k]['img_url'] = $this->seveImg($value['goods_id'], $v['main_img'], $targetDir);//规格图片
-                    $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]['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]['market_price'], $skuInfo[$k]['cost_price'], 2);
                     $skuInfo[$k]['mer_profit'] = bcsub($skuInfo[$k]['market_price'], $skuInfo[$k]['cost_price'], 2);
                     $skuInfo[$k]['yanglaojin'] = '0.00';
-                    if(count($v['attr'])){
+                    if (count($v['attr'])) {
                         $skuInfo[$k]['attribute_json'] = $v['attr'];
-                    }else{
-                        $skuInfo[$k]['attribute_json'] = [['val'=> '默认', 'name'=> '默认']];
+                    } else {
+                        $skuInfo[$k]['attribute_json'] = [['val' => '默认', 'name' => '默认']];
                     }
                 }
                 unset($goodsInfo['sku_list']);
@@ -84,17 +95,21 @@ class Take
                     'status' => $goodsInfo['status'],
                     'cate_ids' => $goodsInfo['cate_ids'],
                     'title' => $goodsInfo['spu_name'],
-                    'cxb_cate_id' => 0,   
+                    'cxb_cate_id' => 0,
                 ];
+
+                // 4.5 保存商品信心到本地
                 $this->add($seveData);
                 $goods_id_list[] = $goodsInfo['spu_id'];
 
-
+                // 4.6 如果上架到商品表 则更新商品表的图片
                 $this->updata_product_img($goodsInfo['spu_id']);
             }
 
+            // 5、将 未同步到的商品 进行下架
             $goodsIds = array_diff($spu_id_list, $goods_id_list);
             $this->remove($goodsIds);
+
             return 'sussess';
         } catch (Exception $e) {
             Log::error('供应链拉取数据：' . $e->getFile() . '：' . $e->getLine() . '【' . $e->getMessage() . '】');
@@ -105,12 +120,14 @@ class Take
     }
 
     public function updata_product_img($spu_id){
+        // 1、验证该 SPUId 是否上架了 如果上架了 需要去更新商品 图片
         $product_id = Db::name('store_product')->where('spu_id',$spu_id)->value('product_id');
         if(!$product_id) return true;
 
+        // 2、查找微唯宝 商品
         $data = Db::name('douhuomall')->where('spu_id',$spu_id)->find();
 
-        //商品主图
+        // 3、获取 商品主图
         $spuId_info=json_decode($data['spuId_info'],true);
         $slider_image=$spuId_info['detail_img_list']??'';
         $image=$spuId_info['cover_url']??'';