唯微宝拉去商品入库

app/controller/admin/gong/Goods.php

@@ -277,7 +277,7 @@ class Goods extends BaseController
                 'spu_id'=>$data['spu_id'],
                 'temp_id' => 105,
                 'plate_mer_profit' => $data['mer_profit'],
-		'concession_pri' => $data['mer_profit'],
+		        'concession_pri' => $data['mer_profit'],
                 'yanglaojin_scale' => $yanglaojin_scale
             ];
             $insert_id=Db::name('store_product')->insertGetId($product_insert_data);

app/controller/api/douhuomall/Take.php

@@ -2,18 +2,177 @@
 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(){
-        //spu_id列表
-        $spu_list = GongApiRequest::get_goods_list();
-        dump($spu_list);
+    public function get_goods_list(){
+        try {
+            $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;
+
+                //spuId_info商品详细信息处理
+                $goodsInfo['cover_url'] = $goodsInfo['main_img'];
+                $goodsInfo['spu_id'] = $goodsInfo['goods_id'];
+
+                $goodsInfo['detail'] = "";
+                $detail_img = $goodsInfo['detail_img'];
+                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 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;
+    }
 }

app/controller/merchant/gong/Goods.php

@@ -275,7 +275,7 @@ class Goods extends BaseController
                 'spu_id'=>$data['spu_id'],
                 'temp_id' => 105,
                 'plate_mer_profit' => $data['mer_profit'],
-		'concession_pri' => $data['mer_profit'],
+		        'concession_pri' => $data['mer_profit'],
                 'yanglaojin_scale' => $yanglaojin_scale
             ];
             $insert_id=Db::name('store_product')->insertGetId($product_insert_data);

app/traits/GongApiRequest.php

@@ -19,7 +19,7 @@ trait GongApiRequest
     private static $mobile = '17855366921';
 
     public static function get_access_token(){
-        $url = '/api/noAuth/access_token';
+        $url = '/api_v2/noAuth/getAccessToken';
         $time = time();
         $body = [
             'app_id' => self::$app_id,
@@ -37,7 +37,7 @@ trait GongApiRequest
 
     public static function access_token(){
         $gong_access_token = Cache::get('gong_access_token');
-        $url = '/api/category/get_list';
+        $url = '/api_v2/Goods/getGoodsList';
         $body = ['access_token' => $gong_access_token];
         $res = self::curl_post(self::$path.$url,$body);
         if(!$gong_access_token || ($res['error_code'] == 1001)){
@@ -47,7 +47,7 @@ trait GongApiRequest
         return $gong_access_token;
     }
 
-    //分类
+    //分类(未更改)
     public static function get_category(){
         $url = '/api/category/get_list';
         $body = [
@@ -72,7 +72,7 @@ trait GongApiRequest
      * @created 2022年5月19日11:31:59
      */
     public static function get_goods_list($page=1,$limit=50){
-        $url = '/api/goods/get_spuid_list';
+        $url = '/api_v2/Goods/getGoodsList';
         $body = [
             'access_token' => self::access_token(),
             'page' => $page,
@@ -87,16 +87,16 @@ trait GongApiRequest
 
     /**
      * 商品详情
-     * @param array $spu_id 商品spu_id
+     * @param array $goods_id 商品goods_id
      * @return array|boolean
      * @author lin
      * @created 2022年5月19日11:31:59
      */
-    public static function get_goods_info($spu_id){
-        $url = '/api/goods/get_spuId_info';
+    public static function get_goods_info($goods_id){
+        $url = '/api_v2/Goods/getGoodsDetail';
         $body = [
             'access_token' => self::access_token(),
-            'spu_id' => $spu_id,
+            'goods_id' => $goods_id,
         ];
         $res = self::curl_post(self::$path.$url,$body);
         if ($res['error_code'] == 2001) {
@@ -108,18 +108,42 @@ trait GongApiRequest
         return false;
     }
 
+
+
+    /**
+     * 规格详情
+     * @param array $sku_id 商品sku_id
+     * @return array|boolean
+     * @author lin
+     * @created 2022年5月19日11:31:59
+     */
+    public static function get_sku_detail($sku_id){
+        $url = '/api_v2/Goods/getSkuDetail';
+        $body = [
+            'access_token' => self::access_token(),
+            'sku_id' => $sku_id,
+        ];
+        $res = self::curl_post(self::$path.$url,$body);
+        echo json_encode($res);
+        if($res['error_code'] == 0){
+            return $res['result'];
+        }
+        return false;
+    }
+
+
     /**
      * 商品规格
-     * @param array $spu_id 商品spu_id
+     * @param array $sku_sn 商品sku_sn
      * @return array|boolean
      * @author lin
      * @created 2022年5月19日11:31:59
      */
-    public static function get_sku($spu_id){
-        $url = '/api/goods/get_skuId_info';
+    public static function get_sku($sku_sn){
+        $url = '/api/Goods/getSkuDetail';
         $body = [
             'access_token' => self::access_token(),
-            'spu_id' => $spu_id
+            'sku_sn' => $sku_sn
         ];
         $res = self::curl_post(self::$path.$url,$body);
         if($res['error_code'] == 0){
@@ -127,9 +151,10 @@ trait GongApiRequest
         }
         return false;
     }
+    
 
     /**
-     * 商品价格
+     * 商品价格(未更改)
      * @param string $sku_id 商品skuid,[‘984783’,’984784’]
      * @return array|boolean
      * @author lin
@@ -149,7 +174,7 @@ trait GongApiRequest
     }
 
     /**
-     * 商品是否有货
+     * 商品是否有货(未更改)
      * @param int $sku_id 商品sku_id
      * @param int $address_id 地址id（区id或者接到id）
      * @param int $goods_num 商品数量
@@ -173,7 +198,7 @@ trait GongApiRequest
     }
 
     /**
-     * 查询商品上下架
+     * 查询商品上下架(未更改)
      * @param string $spu_id 商品spu_id
      * @return array|boolean
      * @author lin
@@ -201,7 +226,7 @@ trait GongApiRequest
      * @created 2022年5月19日11:46:54
      */
     public static function sku_stock(string $sku_list, int $address_id){
-        $url = '/api/goods/find_sku_stock';
+        $url = '/api_v2/Goods/stock';
         $body = [
             'access_token' => self::access_token(),
             'sku_list' => $sku_list,
@@ -215,19 +240,19 @@ trait GongApiRequest
     }
 
     /**
-     * 运费查询（下单前调用，确定可售）
+     * 运费查询（下单前调用，确定可售） (未对接)
      * @param string $address_id 地址id
-     * @param array $sku_id sku列表 [{‘sku_id’:80,‘num’:5},{‘sku_id’:81,‘num’:2}]
+     * @param array $sku_list sku列表 [{‘sku_id’:80,‘num’:5},{‘sku_id’:81,‘num’:2}]
      * @return array|boolean
      * @author lin
      * @created 2022年5月19日11:46:54
      */
-    public static function freight(string $address_id, array $sku_id){
-        $url = '/api/order/freight';
+    public static function freight(string $address_id, array $sku_list){
+        $url = '/api_v2/order/getFreightPrice';
         $body = [
             'access_token' => self::access_token(),
             'address_id' => $address_id,
-            'sku_list' => $sku_id
+            'sku_list' => $sku_list
         ];
         $res = self::curl_post(self::$path.$url,$body);
         if($res['error_code'] == 0){
@@ -239,7 +264,7 @@ trait GongApiRequest
     /**
      * 正式下单
      * @param string $address_id 地址id
-     * @param array $sku_id sku列表 [{‘sku_id’:80,‘num’:5},{‘sku_id’:81,‘num’:2}]
+     * @param array $sku_list sku列表 [{‘sku_id’:80,‘num’:5},{‘sku_id’:81,‘num’:2}]
      * @param string $address 详细地址
      * @param string $third_order 订单id
      * @param string $other 备注
@@ -249,17 +274,17 @@ trait GongApiRequest
      * @author lin
      * @created 2022年5月19日13:22:09
      */
-    public static function submit(string $address_id, array $sku_id, string $address, string $third_order, string $other, string $receiver, string $receiver_phone){
-        $url = '/api/order/submit';
+    public static function submit(string $address_id, array $sku_list, string $address, string $third_order, string $other, string $receiver, string $receiver_phone){
+        $url = '/api_v2/order/submit';
         $body = [
             'access_token' => self::access_token(),
             'address_id' => $address_id,
-            'sku_list' => $sku_id,
+            'sku_list' => $sku_list,
+            'receiver' => $receiver,
+            'receiver_phone' => $receiver_phone,
             'address' => $address,
-            'third_order' => $third_order,
             'other' => $other,
-            'receiver' => $receiver,
-            'receiver_phone' => $receiver_phone
+            'third_order' => $third_order
         ];
 //        Db::name('log')->insert(['data'=>'供应链发货-------2：']);
         $res = self::curl_post(self::$path.$url,$body);
@@ -267,7 +292,7 @@ trait GongApiRequest
     }
 
     /**
-     * 手动发货
+     * 手动发货(未对接)
      * @param string $out_order_no 订单编号
      * @param string $logistics_number 物流单号
      * @param string $logistics_company 物流名称
@@ -291,7 +316,7 @@ trait GongApiRequest
     }
 
     /**
-     * 查询订单状态
+     * 查询订单状态(未对接)
      * @param string $out_order_no 订单编号
      * @return string|boolean 订单状态值 0失败 1待付款 2待发货 3待收货 4已完成 5已取消 6售后中 7售后完成8拒收
      * @author lin
@@ -318,7 +343,7 @@ trait GongApiRequest
      * @created 2022年5月19日11:46:54
      */
     public static function order_details(string $out_order_no){
-        $url = '/api/order/details';
+        $url = '/api_v2/order/getOrderDetail';
         $body = [
             'access_token' => self::access_token(),
             'out_order_no' => $out_order_no,
@@ -338,7 +363,7 @@ trait GongApiRequest
      * @created 2022年5月19日11:46:54
      */
     public static function order_track(string $out_order_no){
-        $url = '/api/order/track';
+        $url = '/api_v2/order/track';
         $body = [
             'access_token' => self::access_token(),
             'out_order_no' => $out_order_no,
@@ -352,7 +377,7 @@ trait GongApiRequest
 
 
     /**
-     * 确认收货
+     * 确认收货(未对接)
      * @param string $out_order_no 订单编号
      * @return array|boolean
      * @author lin
@@ -372,14 +397,14 @@ trait GongApiRequest
     }
 
     /**
-     * 查询商品是否可售后属性
+     * 查询商品是否可售后属性(未对接)
      * @param string $out_order_no 订单编号
      * @return array|boolean
      * @author lin
      * @created 2022年5月19日11:46:54
      */
     public static function after_is_can(string $out_order_no){
-        $url = '/api/after/is_can   ';
+        $url = '/api/after/is_can';
         $body = [
             'access_token' => self::access_token(),
             'out_order_no' => $out_order_no,
@@ -392,7 +417,7 @@ trait GongApiRequest
     }
 
     /**
-     * 申请售后
+     * 申请售后(未对接)
      * @param string $out_order_no 订单编号
      * @param string $customer_expect 1-退货。2-换货
      * @param string $question_desc 申请理由
@@ -417,7 +442,7 @@ trait GongApiRequest
     }
 
     /**
-     * 申请售后
+     * 申请售后(未对接)
      * @param string $order_goods_id 订单商品id
      * @param string $out_order_no 系统订单号
      * @param string $after_type 1=未收货退款，2=退货退款，3=换货补发，4=不退货仅退款
@@ -443,7 +468,7 @@ trait GongApiRequest
 
 
     /**
-     * 查询订单是否可售后
+     * 查询订单是否可售后(未对接)
      * @param string $out_order_no 系统订单号
      * @return mixed|string
      */
@@ -459,7 +484,7 @@ trait GongApiRequest
     }
 
     /**
-     * 售后订单状态
+     * 售后订单状态(未对接)
      * @param string $after_sn 售后订单号
      * @return array|boolean
      */
@@ -474,7 +499,7 @@ trait GongApiRequest
     }
 
     /**
-     * 售后订单状态
+     * 售后订单状态(未对接)
      * @param string $after_sn 售后订单号
      * @return array|boolean
      */
@@ -489,7 +514,7 @@ trait GongApiRequest
     }
 
     /**
-     * 退换货发货信息
+     * 退换货发货信息(未对接)
      * @param string $after_sn 售后订单编号。申请售后接口返回
      * @param string $logistics_company 1-退货。2-换货
      * @param string $logistics_number 申请理由
@@ -513,7 +538,7 @@ trait GongApiRequest
     }
 
     /**
-     * 取消申请售后
+     * 取消申请售后(未对接)
      * @param string $after_sn 售后订单编号。申请售后接口返回
      * @param string $out_order_no 订单编号
      * @return string|boolean
@@ -535,7 +560,7 @@ trait GongApiRequest
     }
 
     /**
-     * 获取地区
+     * 获取地区(未对接)
      * @param string $code 地区代码，为空查询省级信息，否则查询code的下级
      * @return string|boolean
      * @author lin
@@ -555,7 +580,7 @@ trait GongApiRequest
     }
 
     /**
-     * 获取消息池消息
+     * 获取消息池消息(未对接)
      * @param int $type 1-订单状态变动, 2-商品详情, 3-sku价格, 4-商品删除, 5-规格状态变更, 6-规格删除, 7-规格详情, 8-商品状态变更
      * @return  array|boolean
      * @author lin

route/api.php

@@ -1210,6 +1210,8 @@ Route::group('api/', function () {
     Route::get('close_seckill','api.warehouse.Product/close_seckill');//每小时 执行关闭秒杀任务
     Route::post('send_order/:id','api.douhuomall.Order/send_order');//测试下单 供应链
 
+    Route::get('get_goods_list','api.douhuomall.Take/get_goods_list');//测试拉去唯微宝商品
+
     Route::get('pay_demo', 'api.merchant.sxy.Access/pay_demo');
 
     Route::get('refund_test', 'api.store.order.StoreOrder/refund_test');//首信易测试订单退款