yanzong/app/api/model/Goods.php

<?php
// +----------------------------------------------------------------------
// | 萤火商城系统 [ 致力于通过产品和服务，帮助商家高效化开拓市场 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2017~2023 https://www.yiovo.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed 这不是一个自由软件，不允许对程序代码以任何形式任何目的的再发行
// +----------------------------------------------------------------------
// | Author: 萤火科技 <admin@yiovo.com>
// +----------------------------------------------------------------------
declare (strict_types=1);

namespace app\api\model;

use app\api\model\GoodsBrowseLog;
use app\api\service\Goods as GoodsService;
use app\api\service\User as UserService;
use app\api\service\user\Grade as UserGradeService;
use app\api\model\GoodsSku as GoodsSkuModel;
use app\api\model\store\Module as StoreModuleModel;
use app\common\model\GoodsCategoryRel as GoodsCategoryRelModel;
use app\api\model\GoodsSpecRel as GoodsSpecRelModel;
use app\common\model\Goods as GoodsModel;
use app\common\enum\goods\Status as GoodsStatusEnum;
use cores\exception\BaseException;
use think\db\exception\DataNotFoundException;
use think\db\exception\DbException;
use think\db\exception\ModelNotFoundException;
use app\store\model\goods\GoodsPrice as GoodsPriceModel;

/**
 * 商品模型
 * Class Goods
 * @package app\api\model
 */
class Goods extends GoodsModel
{
    /**
     * 隐藏字段
     * @var array
     */
    public $hidden = [
        'images',
        'delivery',
        'deduct_stock_type',
        'sales_initial',
        'sales_actual',
        'sort',
        'is_delete',
        'store_id',
        'create_time',
        'update_time'
    ];

    // 是否启用会员折扣价
    private bool $enableGradeMoney = true;

    /**
     * 商品详情：HTML实体转换回普通字符
     * @param $value
     * @return string
     */
    public function getContentAttr($value): string
    {
        return \htmlspecialchars_decode((string)$value);
    }

    /**
     * 设置是否启用会员折扣价
     * @param bool $value
     * @return $this
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     */
    public function setEnableGradeMoney(bool $value): Goods
    {
        $this->enableGradeMoney = $value && StoreModuleModel::checkModuleKey('user-grade');
        return $this;
    }

    /**
     * 获取是否启用会员折扣价
     * @return bool
     * @throws DataNotFoundException
     * @throws DbException
     * @throws ModelNotFoundException
     */
    private function getEnableGradeMoney(): bool
    {
        return $this->enableGradeMoney && StoreModuleModel::checkModuleKey('user-grade');
    }

    /**
     * 获取商品列表
     * @param array $param 查询条件
     * @param int $listRows 分页数量
     * @return mixed|\think\model\Collection|\think\Paginator
     * @throws \think\db\exception\DbException
     */
    public function getList(array $param = [], int $listRows = 15)
    {

        // 整理查询参数
        $params = array_merge($param, ['status' => GoodsStatusEnum::ON_SALE]);

        // 获取商品列表
        $list = parent::getList($params, $listRows);

        if ($list->isEmpty()) {
            return $list;
        }
        // 隐藏冗余的属性
        $list->hidden(static::getHidden(['content', 'goods_images', 'images']));
        // 整理列表数据并返回
        return $this->setGoodsListDataFromApi($list);
    }


    public function browseLog()
    {
        $userId = UserService::getCurrentLoginUserId(true);

        $list = GoodsBrowseLog::where([
            'store_id' => request()->header()['storeid'],
            'user_id' => $userId,
        ])->order('id desc')->paginate(15)->column('ctime');
        $list = array_unique($list);
        $res = [];

        foreach ($list as $k => $v) {
            $all = GoodsBrowseLog::alias('a')
                ->join('goods b', 'a.goods_id = b.goods_id')
                ->join('goods_sku c', 'a.goods_id = c.goods_id')
                ->where([
                    'a.store_id' => request()->header()['storeid'],
                    'a.user_id' => $userId,
                    'a.ctime' => $v,
                    'b.is_delete' => 0,
                    'b.status' => 10
                ])->field('a.ctime,a.goods_id,c.goods_props')->order('a.id desc')->select()->toArray();
            foreach ($all as $k2 => &$v2) {
                $v2['goods_props'] = \Qiniu\json_decode($v2['goods_props'], 1)[0] ?? '';
                $v2['image'] = $this->getDetails2($v2['goods_id'])->toArray()['goods_images'][0]->toArray()['preview_url'] ?? '';
            }
            $res[$v] = $all;
        }
        return $res;
    }


    public function browseDel()
    {
        $userId = UserService::getCurrentLoginUserId(true);
        $info = GoodsBrowseLog::where([
            'store_id' => request()->header()['storeid'],
            'user_id' => $userId,
        ])->whereIn('id', $_POST['ids'])->delete();
        return $info;
    }

    /**
     * 获取商品详情 (详细数据用于页面展示)
     * @param int $goodsId 商品ID
     * @param bool $verifyStatus 是否验证商品状态(上架)
     * @return mixed
     * @throws BaseException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getDetails(int $goodsId, bool $verifyStatus = true)
    {
        // 关联查询(商品图片、sku列表)
        $with = ['images.file', 'skuList.image', 'video', 'videoCover'];
        // 获取商品记录
        $goodsInfo = $this->getGoodsMain($goodsId, $with, $verifyStatus);
        // 商品规格列表
        $goodsInfo['specList'] = GoodsSpecRelModel::getSpecList($goodsInfo['goods_id']);
        $GoodsCategoryRelModel = new GoodsCategoryRelModel();
        $category = $GoodsCategoryRelModel
            ->alias('a')
            ->join('category b', 'a.category_id = b.category_id')
            ->where([
                'a.goods_id' => $goodsId,
                'a.store_id' => request()->header()['storeid']
            ])->find()->toArray();
        $goodsInfo->category = $category;
        //多规格
        $goodsInfo->specifications = [];
        $skuList = [];
        $specList = [];
        if ($goodsInfo->spu_id > 0) {
            //查同规格的商品
            $spe = GoodsModel::where([
                'spu_id' => $goodsInfo->spu_id,
                'store_id' => request()->header()['storeid'],
                'is_delete' => 0
            ])->column('goods_id');
            foreach ($spe as $v) {
                $skuList[] = $this->getSpecData($v)['skuList']->toArray()[0];
                $specList[] = $this->getSpecData($v)['specList'][0];
            }
            $newList = [
                'skuList' => $skuList,
                'specList' => $specList
            ];
            $goodsInfo->specifications = $newList;
        }
        $goodsInfo = $goodsInfo->toArray();
        //替换原规格数组
        $goodsInfo['skuList2'] = $skuList;
        $goodsInfo['specList2'] = $specList;
        //加入足迹
        $userId = UserService::getCurrentLoginUserId(false) ?? '';
        if ($userId) {
            $info = GoodsBrowseLog::where([
                'user_id' => $userId,
                'goods_id' => $goodsId,
                'store_id' => request()->header()['storeid'],
                'ctime' => date('Y-m-d')
            ])->find();
            if (!$info) {
                GoodsBrowseLog::insert([
                    'user_id' => $userId,
                    'goods_id' => $goodsId,
                    'store_id' => request()->header()['storeid'],
                    'ctime' => date('Y-m-d')
                ]);
            }
        }

        return $goodsInfo;
    }

    public function getDetails2(int $goodsId, bool $verifyStatus = true)
    {
        // 关联查询(商品图片、sku列表)
        $with = ['images.file'];
        // 获取商品记录
        $goodsInfo = $this->getGoodsMain($goodsId, $with, $verifyStatus);

        return $goodsInfo;
    }

    /**
     * 获取商品详情 (仅包含主商品信息和商品图片)
     * @param int $goodsId 商品ID
     * @param bool $verifyStatus 是否验证商品状态(上架)
     * @return mixed
     * @throws BaseException
     */
    public function getBasic(int $goodsId, bool $verifyStatus = true)
    {
        // 关联查询(商品图片)
        $with = ['images.file'];
        // 获取商品记录
        return $this->getGoodsMain($goodsId, $with, $verifyStatus);
    }

    /**
     * 获取商品规格数据
     * @param int $goodsId
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getSpecData(int $goodsId): array
    {
        $data = [];
        // 商品SKU列表
        $data['skuList'] = GoodsSkuModel::getSkuList($goodsId, true);
        // 商品规格列表
        $data['specList'] = GoodsSpecRelModel::getSpecList($goodsId);
        return $data;
    }

    /**
     * 获取商品主体信息
     * @param int $goodsId 商品ID
     * @param array $with 关联查询
     * @param bool $verifyStatus 是否验证商品状态(上架)
     * @return mixed
     * @throws BaseException
     */
    private function getGoodsMain(int $goodsId, array $with = [], bool $verifyStatus = true)
    {
        // 获取商品记录
        $goodsInfo = static::detail($goodsId, $with);
        // 判断商品是否存在
        if (empty($goodsInfo) || $goodsInfo['is_delete']) {
            throwError('很抱歉，商品信息不存在');
        }
        // 判断商品状态(上架)
        if ($verifyStatus && $goodsInfo['status'] == GoodsStatusEnum::OFF_SALE) {
            throwError('很抱歉，当前商品已下架');
        }
        // 整理商品数据并返回
        return $this->setGoodsDataFromApi($goodsInfo);
    }

    /**
     * 根据商品id集获取商品列表
     * @param array $goodsIds
     * @return mixed
     */
    public function getListByIdsFromApi(array $goodsIds)
    {
        // 获取商品列表
        $data = $this->getListByIds($goodsIds, GoodsStatusEnum::ON_SALE);
        // 整理列表数据并返回
        return $this->setGoodsListDataFromApi($data);
    }

    /**
     * 获取商品指定的sku信息并且设置商品的会员价
     * @param mixed $goodsInfo 商品信息
     * @param string $goodsSkuId 商品SKUID
     * @param bool $enableGradeMoney 是否设置会员折扣价
     * @return \app\common\model\GoodsSku|array|null
     * @throws BaseException
     */
    public static function getSkuInfo($goodsInfo, string $goodsSkuId, bool $enableGradeMoney = true)
    {
        $goodsInfo['skuInfo'] = GoodsService::getSkuInfo($goodsInfo['goods_id'], $goodsSkuId);
        $enableGradeMoney && (new static)->setGoodsGradeMoney($goodsInfo);
        return $goodsInfo['skuInfo'];
    }

    /**
     * 设置商品展示的数据 api模块
     * @param $data
     * @return mixed
     */
    private function setGoodsListDataFromApi($data)
    {
        return $this->setGoodsListData($data, function ($goods) {
            // 整理商品数据 api模块
            $this->setGoodsDataFromApi($goods);
        });
    }

    /**
     * 整理商品数据 api模块
     * @param $goodsInfo
     * @return mixed
     */
    private function setGoodsDataFromApi($goodsInfo)
    {
        return $this->setGoodsData($goodsInfo, function ($goods) {
            // 计算并设置商品会员价
            $this->getEnableGradeMoney() && $this->setGoodsGradeMoney($goods);
            //计算plus 分销价格
            $this->setGoodsMoney($goods);
        });
    }

    /**
     * 设置商品plus 分销价格
     * @param Goods $goods
     * @throws BaseException
     */
    private function setGoodsMoney(self $goods)
    {
        // 判断是否登录
        if (!UserService::isLogin()) {
            return;
        }
        $catService = new \app\store\model\GoodsCategoryRel();
        $catIds = $catService->where(['goods_id' => $goods->goods_id])->column('category_id');
        //读取分类集
        $price_list_plus = $price_list_dealer = [];
        foreach ($catIds as $k => $v) {
            $price_list_plus[] = GoodsPriceModel::getDiscountPrice($v, 1, $goods['goods_price_min']);
            $price_list_dealer[] = GoodsPriceModel::getDiscountPrice($v, 2, $goods['goods_price_min']);
        }
        //价格判断
        if (UserService::isstore()) {
            $goods['goods_price_min_plus'] = min($price_list_plus);
            $goods['goods_price_min_dealer'] = min($price_list_dealer);
        } elseif (UserService::isPlusMember()) {
            $goods['goods_price_min_plus'] = min($price_list_plus);
        } elseif (UserService::isDealerMember()) {
            $goods['goods_price_min_dealer'] = min($price_list_dealer);
        }
        // 会员折扣价: 商品sku列表
        if ($goods->getRelation('skuList')) {
            foreach ($goods['skuList'] as &$skuItem) {
                $temp_price_plus = $temp_price_dealer =  [];
                foreach ($catIds as $k => $v) {
                    $temp_price_plus[] = GoodsPriceModel::getDiscountPrice($v, 1, $skuItem['goods_price']);
                    $temp_price_dealer[] = GoodsPriceModel::getDiscountPrice($v, 2, $skuItem['goods_price']);
                }
                //价格判断
                if (UserService::isstore()) {
                    $skuItem['goods_price_plus'] = min($temp_price_plus);
                    $skuItem['goods_price_dealer'] = min($temp_price_dealer);
                } elseif (UserService::isPlusMember()) {
                    $skuItem['goods_price_plus'] = min($temp_price_plus);
                } elseif (UserService::isDealerMember()) {
                    $skuItem['goods_price_dealer'] = min($temp_price_dealer);
                }

            }
        }
        // 折扣价: 已选择的商品sku（用于购物车）
        if ($goods->getAttr('skuInfo')) {
            if (UserService::isPlusMember()) {
                $sku_price_plus = [];
                foreach ($catIds as $k => $v) {
                    $sku_price_plus[] = GoodsPriceModel::getDiscountPrice($v, 1, $goods['skuInfo']['goods_price']);
                }
                $goods['skuInfo']['goods_price'] = min($sku_price_plus);
            } elseif (UserService::isDealerMember()) {
                $sku_price_dealer = [];
                foreach ($catIds as $k => $v) {
                    $sku_price_dealer[] = GoodsPriceModel::getDiscountPrice($v, 2, $goods['skuInfo']['goods_price']);
                }
                $goods['skuInfo']['goods_price'] = min($sku_price_dealer);
            }

        }
    }

    /**
     * 设置商品的会员价
     * @param Goods $goods
     * @throws BaseException
     */
    private function setGoodsGradeMoney(self $goods)
    {
        // 设置当前商品是否使用会员等级折扣价
        $goods['is_user_grade'] = false;
        // 获取当前登录用户的会员等级信息
        $gradeInfo = UserGradeService::getCurrentGradeInfo();
        // 判断商品是否参与会员折扣
        if (empty($gradeInfo) || !$goods['is_enable_grade']) {
            return;
        }
        // 默认的折扣比例
        $discountRatio = $gradeInfo['equity']['discount'];
        // 商品单独设置了会员折扣
        if ($goods['is_alone_grade'] && isset($goods['alone_grade_equity'][$gradeInfo['grade_id']])) {
            $discountRatio = $goods['alone_grade_equity'][$gradeInfo['grade_id']];
        }
        if (empty($discountRatio)) {
            return;
        }
        // 标记参与会员折扣
        $goods['is_user_grade'] = true;
        // 会员折扣价: 商品基础价格
        $goods['goods_price_min'] = UserGradeService::getDiscountPrice($goods['goods_price_min'], $discountRatio);
        $goods['goods_price_max'] = UserGradeService::getDiscountPrice($goods['goods_price_max'], $discountRatio);
        // 会员折扣价: 商品sku列表
        if ($goods->getRelation('skuList')) {
            foreach ($goods['skuList'] as &$skuItem) {
                $skuItem['goods_price'] = UserGradeService::getDiscountPrice($skuItem['goods_price'], $discountRatio);
            }
        }
        // 会员折扣价: 已选择的商品sku（用于购物车）
        if ($goods->getAttr('skuInfo')) {
            $goods['skuInfo']['goods_price'] = UserGradeService::getDiscountPrice($goods['skuInfo']['goods_price'], $discountRatio);
        }
    }
}