qimall/addons/QiJuhe/common/models/MallGoodsModel.php

<?php

namespace addons\QiJuhe\common\models;

use common\enums\StatusEnum;
use common\events\goods\GoodsCreateEvent;
use common\events\goods\SupplyChainGoodsChangeEvent;
use common\models\goods\Goods;
use Exception;
use Yii;
use yii\base\Model;
use yii\helpers\Json;

/**
 * Class MallGoodsModel
 * @package addons\QiJuhe\common\models
 */
class MallGoodsModel extends Goods
{
    // const PLUGIN_SIGN = 'juhe_shop';

    public static $static_error;

    public static $mall_id;

    /**
     * @param $mall_id
     * @param $goods_id
     * time:2021-10-12-21:36
     * user: 林深时见鹿
     * title:商品下架
     * desc:
     */
    public static function updateDown($mall_id, $goods_id)
    {
        $where = [
            'mall_id' => $mall_id,
            'mch_id' => 0,
            // 'goods_source' => QiJuheEnum::PLUGIN_SIGN,
            'id' => $goods_id,
        ];
        return self::updateAll(['is_on_sale' => 0, 'updated_at' => time()], $where);
    }

    /**
     * 商品数据
     *
     * @param integer $goods_id
     * @return void
     */
    public static function getDetail($goods_id)
    {
        $detail = self::getOne([['id' => $goods_id]], true, ['cats', 'attr', 'extra']);

        $detail['freight_type'] = !empty($detail['freight_type']) ? explode(',', $detail['freight_type']) : [];
        $detail['services'] = !empty($detail['services']) ? explode(',', $detail['services']) : [];
        $detail['labels'] = !empty($detail['labels']) ? explode(',', $detail['labels']) : [];
        $detail['attr_groups'] = Json::decode($detail['attr_groups'], true) ?? [];
        $detail['bannar_pic'] = Json::decode($detail['bannar_pic'], true) ?? [];
        $detail['attr_groups_format'] = Json::decode($detail['attr_groups_format'], true) ?? [];
        $detail['area_limit'] = Json::decode($detail['area_limit'], true) ?? [];
        $detail['pay_limit'] = Json::decode($detail['pay_limit'], true) ?? [];
        $detail['cats'] = self::getCatsArr($detail['cats']);

        return $detail;
    }

    /**
     * 获取分类ID
     *
     * @param array $cats
     * @return array
     */
    private static function getCatsArr($cats)
    {
        if (empty($cats)) return [];

        return array_column($cats, 'id');
    }

    /**
     * 保存商品
     *
     * @return boolean|MallGoodsModel
     */
    public function saveGoods($params)
    {
        self::$mall_id = $params['mall_id'];

        // 获取商品额外属性
        $params['extra'] = self::getGoodsExtra($params);

        // 去添加
        $goods_model = MallGoodsModel::setData($params/* , QiJuheEnum::PLUGIN_SIGN, function ($attr, $model, $goods_id) {
            return self::addJuheGoodsAttr($attr, $model->id, $goods_id);
        } */);
        if ($goods_model === false) {
            throw new Exception(MallGoodsModel::getStaticError());
        }

        $data['goods_id'] = $goods_model->id;
        $data['mall_id']  = $params['mall_id'];
        // 新增商品出发新增事件
        if (empty($params['id'])) {
            $event = new GoodsCreateEvent($params['mall_id']);
            Yii::$app->services->events->dispatch($event, $data, $event->listeners);
        }

        $event = new SupplyChainGoodsChangeEvent();
        Yii::$app->services->events->dispatch($event, $data, $event->listeners);

        self::matchingSku($goods_model, $params['attr']);

        return $goods_model;
    }

    /**
     * 储存商城sku和聚合sku关系
     *
     * @param array $attr
     * @param int $sku_id
     * @return boolean
     */
    private static function addJuheGoodsAttr($attr, $attr_id, $goods_id)
    {
        $mall_id = self::$mall_id;
        $sku_id = $attr['sku_id'];

        $params = [
            'mall_id' => $mall_id,
            'goods_id' => $goods_id,
            'attr_id' => $attr_id,
        ];
        $model = GoodsSkuModel::find()->where($params)->one();
        if (empty($model)) {
            $model = new GoodsSkuModel();

            $model->mall_id = $mall_id;
            $model->goods_id = $goods_id;
            $model->attr_id = $attr_id;
            $model->supply_goods_id = $attr['supply_goods_id'];
            $model->supply_id = $attr['supply_id'];
        }

        // 删除之前的sku
        self::deleteAttr($mall_id, $goods_id, $sku_id);
        $model->sku_id = $sku_id;

        return $model->save() ? true : false;
    }

    /**
     * 匹配商城sku
     *
     * @param array $attr_models
     * @param array $attr
     * @return boolean
     */
    private static function matchingSku($goods_model, $attrs)
    {
        if (count($attrs) > 1) {
            // 多规格添加
            foreach ($goods_model->attr as $model) {
                // 商城attr
                $sign_arr = explode(':', $model->sign_id);
                foreach ($attrs as $attr) {
                    // 聚合attr
                    $attr_id_arr = array_column($attr['attr_list'], 'attr_id');
                    sort($sign_arr);
                    sort($attr_id_arr);
                    // 两个数组相等
                    if ($attr_id_arr == $sign_arr) {
                        $res = self::addJuheGoodsAttr($attr, $model->id, $goods_model->id);
                        if ($res === false) {
                            throw new Exception("goods_id:{$goods_model->id},sku关系添加失败");
                        }
                    }
                }
            }
        } else {
            // 单规格添加
            foreach ($goods_model->attr as $model) {
                foreach ($attrs as $attr) {
                    $res = self::addJuheGoodsAttr($attr, $model->id, $goods_model->id);
                    if ($res === false) {
                        throw new Exception("goods_id:{$goods_model->id},sku关系添加失败");
                    }
                }
            }
        }
    }

    /**
     * 删除sku
     *
     * @param integer $mall_id
     * @param integer $goods_id
     * @param integer $sku_id
     * @return void
     */
    private static function deleteAttr($mall_id, $goods_id, $sku_id)
    {
        GoodsSkuModel::updateAll(['is_delete' => 1], [
            'mall_id' => $mall_id,
            'goods_id' => $goods_id,
            'sku_id' => $sku_id,
        ]);
    }

    /**
     * 获取商品额外属性
     *
     * @return void
     */
    private static function getGoodsExtra($params)
    {
        if (isset($params['extra']) && $params['extra']) {
            isset($params['extra']['score_give_setting']) && $params['extra']['score_give_setting'] = Json::decode($params['extra']['score_give_setting']);
            isset($params['extra']['member_buy_limit_setting']) && $params['extra']['member_buy_limit_setting'] = Json::decode($params['extra']['member_buy_limit_setting']);
            return $params['extra'];
        }

        return [
            // 营销配置
            'full_reduce_price_limit' => 0,
            'score_give_setting' => [
                'code' => 'score',
                'name' => '积分',
                'give_num' => 0,
                'give_type' => 1,
            ],
            // 会员权益
            'is_member_price' => 0,
            'member_price_setting' => [],
            'member_buy_limit_setting' => [
                'member_level' => [],
                'every_num' => 0,
                'every_day_num' => 0,
                'every_week_num' => 0,
                'every_month_num' => 0,
                'nums' => 0,
                'total_num' => 0,
            ],
        ];
    }
}