huahuibao/console/controllers/MtController.php

<?php

namespace console\controllers;

use common\components\noticeUtil;
use common\components\oss;
use common\components\util;
use yii\console\Controller;
use biz\shop\classes\ShopClass;
use biz\shop\classes\ShopExtClass;
use bizHd\goods\classes\CategoryClass;
use bizHd\goods\classes\GoodsClass;
use common\components\dict;
use common\components\httpUtil;
use common\components\mtUtil;
use Shishaoqi\MeituanFlashPurchase\Application;
use linslin\yii2\curl;

class MtController extends Controller
{

    //同步商品 ssh 20220801
    public function actionSyncGoods()
    {
        global $argv;

        ini_set('memory_limit', '2045M');
        set_time_limit(0);

        $shopId = $argv[2] ?? 0;
        if (empty($shopId)) {
            util::stop('请填写门店id');
        }
        $ext = ShopExtClass::getByCondition(['shopId' => $shopId], true);
        if (empty($ext)) {
            util::stop('没有找到门店相信息');
        }
        $shop = ShopClass::getById($shopId, true);
        if (empty($shop)) {
            util::stop('没有找到门店');
        }
        $mainId = $shop->mainId ?? 0;
        $sjId = $shop->sjId ?? 0;
        $config = dict::getDict('mtConfig');
        $app = new Application($config);
        $accessToken = mtUtil::getAccessToken($ext);
        $params = ['app_poi_code' => $shopId, 'access_token' => $accessToken];
        $json = $app->retail->retailList($params);
        $arr = json_decode($json, true);
        if (isset($arr['data']) == false || empty($arr['data'])) {
            util::stop('没有商品');
        }

        $mtCategory = CategoryClass::getByCondition(['mainId' => $mainId, 'style' => 1], true);
        if (empty($mtCategory)) {
            $mtCategory = CategoryClass::add(['style' => 1, 'categoryName' => '美团', 'mainId' => $mainId, 'sjId' => $sjId], true);
        }
        $catId = $mtCategory->id ?? 0;
        if (empty($catId)) {
            util::stop('没有找到美团的商品分类');
        }

        $goodsList = $arr['data'];
        foreach ($goodsList as $key => $val) {

            $picture = $val['picture'] ?? '';
            $price = $val['price'] ?? 0;
            $name = $val['name'] ?? '';
            $mtGoodsSpu = $val['app_spu_code'] ?? '';
            $imgArr = explode(',', $picture);
            if (empty($mtGoodsSpu)) {
                noticeUtil::push('商家有商品没有spuId，' . $name, '15280215347');
                continue;
            }
            $current = GoodsClass::getByCondition(['mainId' => $mainId, 'spu' => $mtGoodsSpu], true);
            if (!empty($current)) {

            } else {
                $shopImg = [];
                foreach ($imgArr as $imgUrl) {
                    $shortUrl = httpUtil::downloadRemoteImg($sjId, $shopId, $imgUrl);
                    $shopImg[] = $shortUrl;
                }
                $cover = $shopImg[0];
                $goodsData = [
                    'spu' => $mtGoodsSpu,
                    'shopImg' => $shopImg,
                    'name' => $name,
                    'sjId' => $sjId,
                    'mainId' => $mainId,
                    'shopId' => $shopId,
                    'catId' => $catId,
                    'cover' => $cover,
                    'unitGoodsPrice' => $price,
                ];
                GoodsClass::orderCreateGoods($goodsData);
            }
        }
    }

    //同步商品 ssh 20220801
    public function actionBc()
    {
        global $argv;

        ini_set('memory_limit', '2045M');
        set_time_limit(0);

        $shopId = $argv[2] ?? 0;
        if (empty($shopId)) {
            util::stop('请填写门店id');
        }
        $ext = ShopExtClass::getByCondition(['shopId' => $shopId], true);
        if (empty($ext)) {
            util::stop('没有找到门店相信息');
        }
        $shop = ShopClass::getById($shopId, true);
        if (empty($shop)) {
            util::stop('没有找到门店');
        }
        $mainId = $shop->mainId ?? 0;
        $sjId = $shop->sjId ?? 0;
        $config = dict::getDict('mtConfig');
        $app = new Application($config);
        $accessToken = mtUtil::getAccessToken($ext);
        $params = ['app_poi_code' => $shopId, 'access_token' => $accessToken];
        $json = $app->retail->retailList($params);
        $arr = json_decode($json, true);
        if (isset($arr['data']) == false || empty($arr['data'])) {
            util::stop('没有商品');
        }

        $mtCategory = CategoryClass::getByCondition(['mainId' => $mainId, 'style' => 1], true);
        if (empty($mtCategory)) {
            $mtCategory = CategoryClass::add(['style' => 1, 'categoryName' => '美团', 'mainId' => $mainId, 'sjId' => $sjId], true);
        }
        $catId = $mtCategory->id ?? 0;
        if (empty($catId)) {
            util::stop('没有找到美团的商品分类');
        }

        $goodsList = $arr['data'];
        foreach ($goodsList as $key => $val) {
            $picture = $val['picture'] ?? '';
            $name = $val['name'] ?? '';
            $mtGoodsSpu = $val['app_spu_code'] ?? '';
            $imgArr = explode(',', $picture);
            if (empty($mtGoodsSpu)) {
                noticeUtil::push('商家有商品没有spuId，' . $name, '15280215347');
                continue;
            }
            $current = GoodsClass::getByCondition(['mainId' => $mainId, 'spu' => $mtGoodsSpu], true);
            if (!empty($current)) {
                $shopImg = $current->shopImg;
                $picArr = json_decode($shopImg, true);
                $hasErr = false;
                if (is_array($picArr)) {
                    foreach ($picArr as $item) {
                        $url = "https://img.wixhb.com/" . $item . '?x-oss-process=image/info';
                        $curl = new curl\Curl();
                        $result = $curl->get($url);
                        $res = json_decode($result, true);
                        if (isset($res['FileSize']) == false) {
                            $hasErr = true;
                        }
                    }
                }

                $cover = $current->cover;
                $url = "https://img.wixhb.com/" . $cover . '?x-oss-process=image/info';
                $curl = new curl\Curl();
                $result = $curl->get($url);
                $res = json_decode($result, true);
                if (isset($res['FileSize']) == false) {
                    $hasErr = true;
                }

                if ($hasErr == true) {
                    $newShopImg = [];
                    foreach ($imgArr as $imgUrl) {
                        $shortUrl = httpUtil::downloadRemoteImg($sjId, $shopId, $imgUrl);
                        $newShopImg[] = $shortUrl;
                    }
                    $current->shopImg = json_encode($newShopImg);
                    $current->cover = $newShopImg[0];
                    $current->save();
                    print_r($imgArr);
                    echo "\n";
                    echo $current->name . " ok \n";
                }
            }
        }
    }

}