erp/app/Http/Controllers/Shop/ShopsController.php

<?php

namespace App\Http\Controllers\Shop;

use App\Http\Controllers\Controller;
use App\Models\BusinessGoodsSku;
use App\Models\GoodsSku;
use App\Models\Shop;
use App\Http\Resources\ShopsResource;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Validator;
use App\Services\Business\BusinessFactory;
use Illuminate\Validation\Rule;
use App\Models\BusinessOrderItem;

class ShopsController extends Controller
{
    public function index(Request $request)
    {
        $shops = Shop::query()->filter()->paginate($request->get('per_page'));
        $time = time();
        foreach ($shops as $shop) {
            $shop->authUrl = '';
            if ('妙选' !== $shop->plat_id && ('未授权' === $shop->status || '重新授权' === $shop->status)) {
                $shop->authUrl = BusinessFactory::init()->make($shop->plat_id)->getAuthUrl($shop->id, $shop->getOriginal('plat_id'));
            }
            if ($shop->expires_at && $time >= $shop->expires_at) {
                Shop::query()->where('id', $shop->id)->update(['status' => Shop::$STATUS_UNAUTHORIZED]);
            }
        }

        return ShopsResource::collection($shops);
    }

    public function getPlatList()
    {
        $shop = new Shop();

        return new ShopsResource($shop->getPlatList());
    }

    public function store(Request $request)
    {
        $validator = Validator::make($request->all(), [
            'name' => 'required|string|max:191|unique:shops,name',
            'plat_id' => 'required|integer',
            'ratio' => 'required',
        ]);
        if ($validator->fails()) {
            $this->setValidatorFailResponse($validator->getMessageBag()->getMessages());

            return response($this->res, $this->res['httpCode']);
        }
        $operator = substr($request->ratio, 0, 1);
        if (!in_array($operator, ['+', '-', '*', '/'])) {
            $this->res->errorMessage = '运算符号仅允许+,-,*,/';
            return response($this->res, $this->res['httpCode']);
        }
        $shop = new Shop();
        $shop->name = $request->name;
        $shop->plat_id = $request->plat_id;
        $shop->ratio = $request->ratio;
        if (0 == $request->plat_id) {
            $shop->status = 2;
        }
        $shop->save();

        return response($this->res, $this->res['httpCode']);
    }

    public function update(Request $request, $id)
    {
        $operator = substr($request->ratio, 0, 1);
        if (!in_array($operator, ['+', '-', '*', '/'])) {
            $this->res->errorMessage = '运算符号仅允许+,-,*,/';
            return response($this->res, $this->res['httpCode']);
        }
        $shop = Shop::query()->find($id);
        $shop->ratio = $request->ratio;
        $shop->save();

        return response($this->res, $this->res['httpCode']);
    }

    public function authBind(Request $request)
    {
        [$shopId, $platId] = explode('_', $request->get('state'));
        $shop = new Shop();
        $platList = $shop->getPlatList();
        $shop = $shop->find($shopId);
        if ($platList[$platId] === $shop->plat_id) {
            BusinessFactory::init()->make($shop->plat_id)->authCallback($request->get('code'), $shop);
        } else {
            $this->res = [
                'httpCode' => 403,
                'errorCode' => 403400,
                'errorMessage' => '信息不匹配',
            ];
        }

        return response($this->res, $this->res['httpCode']);
    }

    public function business(Request $request)
    {
        $validator = Validator::make($request->all(), [
            'type' => ['required', 'string', Rule::in(['goods', 'orders'])],
            'erp_shop_id' => ['required', 'integer', 'exists:shops,id'],
        ]);
        if ($validator->fails()) {
            $this->setValidatorFailResponse($validator->getMessageBag()->getMessages());

            return response($this->res, $this->res['httpCode']);
        }
        $shop = new Shop();
        $shop = $shop->find($request->get('erp_shop_id'));
        $business = BusinessFactory::init()->make($shop->plat_id);
        $business->setShop($shop);
        if ('goods' === $request->get('type')) {
            $business->bindGoods($request->get('data'));
        }
        if ('orders' === $request->get('type')) {
            $business->saveOrders($request->get('data'));
        }

        return response(['Code' => 10000, 'Message' => 'SUCCESS']);
    }

    public function countOrdersNumWithSkuCode(Request $request)
    {
        $validator = Validator::make($request->all(), [
            'sku_code' => ['required', 'array'],
        ]);
        if ($validator->fails()) {
            $this->setValidatorFailResponse($validator->getMessageBag()->getMessages());

            return response($this->res, $this->res['httpCode']);
        }
        $fields = implode(',', [
            'shop_id',
            'external_sku_id',
            'sum(goods_number) as num',
        ]);
        $res = BusinessOrderItem::query()
            ->select(DB::raw($fields))
            ->whereIn('external_sku_id', $request->get('sku_code'))
            ->groupBy(['shop_id', 'external_sku_id'])
            ->with(['shop:id,name'])
            ->get();
        $data = [];
        foreach ($res as $item) {
            $sku = GoodsSku::query()
                ->where('external_sku_id', $item['external_sku_id'])
                ->first();
            if (empty($sku)) {
                continue;
            }
            $sku = $sku->toArray();
            if (!isset($data[$sku['id']]['total'])) {
                $data[$sku['id']]['total'] = 0;
            }
            $data[$sku['id']]['total'] += $item->num;
            $data[$sku['id']]['items'][] = [
                'shop_name' => $item->shop->name,
                'num' => $item->num,
            ];
        }

        return $data;
    }

    public function downloadGoods($id, Request $request)
    {
        $shop = Shop::query()->find($id);
        $business = BusinessFactory::init()->make($shop->plat_id);
        $business->setShop($shop);
        $res = $business->queryGroup();
        if (isset($res['ktt_group_query_list_response'])) {
            foreach ($res['ktt_group_query_list_response']['activity_list'] as $activity) {
                if (0 === $activity['is_help_sell']) {
                    $business->downloadGoodsListAndBind($activity['activity_no'], $activity['title']);
                }
            }
        }

        return response($this->res, $this->res['httpCode']);
    }

    public function syncStock(Request $request)
    {
        $shopId = $request->get('shop_id');
        $builder = Shop::query()->where('expires_at', '>', time());
        if ('all' === $shopId) {
            $shops = $builder->get();
        } else {
            $shops = $builder->where('id', $shopId)->get();
        }
        $skus = GoodsSku::query()
            ->where('updated_at', '>', date('Y-m-d 07:01:00'))
            ->whereNotNull('external_sku_id')
            ->pluck('stock', 'external_sku_id')
            ->toArray();
        foreach ($shops as $shop) {
            $business = BusinessFactory::init()->make($shop->plat_id);
            $business->setShop($shop);
            foreach ($skus as $externalSkuId => $stock) {
                $businessGoodsSkus = BusinessGoodsSku::query()
                    ->select(['goods_id', 'sku_id', 'external_sku_id'])
                    ->where('shop_id', $shop->id)
                    ->where('is_sync', 1)
                    ->where('external_sku_id', $externalSkuId)
                    ->get()
                    ->toArray();
                $business->batchIncrQuantity($businessGoodsSkus, $stock, false);
            }
        }

        return response($this->res, $this->res['httpCode']);
    }
}