qimall/addons/QiJuhe/backend/controllers/GoodsController.php

<?php

namespace addons\QiJuhe\backend\controllers;

use addons\QiJuhe\common\enums\QiJuheEnum;
use addons\QiJuhe\common\service\ApiService;
use addons\QiJuhe\common\service\GoodsService;
use addons\QiJuhe\common\service\StorageService;
use yii\helpers\Json;

class GoodsController extends BaseController
{
    public $enableCsrfValidation = false;

    public function actionIndex()
    {
        if ($this->request->isAjax) {
            $param = $this->request->getQueryParams();
            $supply_id = $this->request->get('supply_id', 0);
            $goods = new GoodsService(['mall_id' => $this->mall_id, 'supply_id' => $supply_id]);
            $goods_list = $goods->getGoodsList($param);
            return $goods_list ? $this->success('ok', $goods_list) : $this->error($goods->error);
        }

        return $this->render('index', [
            'supply_chain_map' => Json::encode(QiJuheEnum::SUPPLY_CHAIN_MAP)
        ]);
    }

    // 获取平台列表
    public function actionSource()
    {
        $supply_id = $this->request->get('supply_id') ?? 0;
        $api = ApiService::getConnect($this->mall_id, $supply_id);
        $list = $api->getSupplySource();
        return $this->success('ok', $list);
    }

    public function actionNewSource()
    {
        $supply_id = $this->request->get('supply_id') ?? 0;
        $api = ApiService::getConnect($this->mall_id, $supply_id);
        $list = $api->getGatherSupplyAndSource();
        if ($list === false) return $this->error($api->error);
        return $this->success('ok', $list);
    }

    // 加入选品库
    public function actionAddStorage()
    {
        $goods_ids = $this->request->post('goods_ids');
        $supply_id = $this->request->post('supply_id');
        $service = new StorageService(['mall_id' => $this->mall_id, 'supply_id' => $supply_id]);
        $res = $service->add($goods_ids);
        return $res ? $this->success("成功导入 " . count($res) . "商品") : $this->error($service->error);
    }
}