lachang/app/store/model/Goods.php

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

namespace app\store\model;

use app\common\library\helper;
use app\store\model\Spec as SpecModel;
use app\common\model\Goods as GoodsModel;
use app\store\model\GoodsSku as GoodsSkuModel;
use app\store\model\GoodsImage as GoodsImageModel;
use app\store\model\GoodsSpecRel as GoodsSpecRelModel;
use app\store\model\goods\ServiceRel as GoodsServiceRelModel;
use app\store\model\GoodsCategoryRel as GoodsCategoryRelModel;
use app\store\service\Goods as GoodsService;
use app\common\enum\goods\SpecType as SpecTypeEnum;
use app\common\enum\goods\Status as GoodsStatusEnum;
use app\common\exception\BaseException;
use app\common\model\GoodsSku;
use think\facade\Db;
use app\store\model\GoodsPackage as GoodsPackageModel;

/**
 * 商品模型
 * Class Goods
 * @package app\store\model
 */
class Goods extends GoodsModel
{
    /**
     * 获取商品详情
     * @param int $goodsId
     * @return mixed
     * @throws BaseException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getDetail(int $goodsId)
    {
        // 关联查询
        $with = ['images' => ['file'], 'skuList' => ['image']];
        // 获取商品记录
        $goodsInfo = static::detail($goodsId, $with);
        empty($goodsInfo) && throwError('很抱歉，商品信息不存');
        // 整理商品数据并返回
        $goodsInfo = parent::setGoodsData($goodsInfo);
        // 分类ID集
        $goodsInfo['categoryIds'] = GoodsCategoryRelModel::getCategoryIds($goodsInfo['goods_id']);
        // 商品规格列表
        $goodsInfo['specList'] = GoodsSpecRelModel::getSpecList($goodsInfo['goods_id']);
        // 服务与承诺
        $goodsInfo['serviceIds'] = GoodsServiceRelModel::getServiceIds($goodsInfo['goods_id']);
        if($goodsInfo['goods_type']==Goods::PACKAGETYPE){
            $dataset = [];
            $packageList = GoodsPackageModel::where('goods_id',$goodsId)->select();
            $skuList =[];
            foreach($packageList as $item){
                $filter['goods_id'] = $item['rel_goods_id'];
                $filter['goods_sku_id'] = $item['rel_goods_sku_id'];
                $sku = GoodsSkuModel::where($filter)->find();
                if(!empty($sku)){
                    $sku = $sku->toArray();
                    $sku['goods_name'] = GoodsModel::where('goods_id',$item['rel_goods_id'])->value("goods_name");
                    $skuList[] = $sku;
                }
            }
            $goodsInfo['packageSkuData'] = $skuList;
        }
     


        // 商品基本信息
        return $goodsInfo;
    }

    /**
     * 添加商品
     * @param array $data
     * @return bool
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function add(array $data)
    {
        //判断商品结构的合法性
        if(!$this->validateGoods($data)){
            return false;
        }
        $data['goods_type'] = $data['goods_type']??30;
        // 创建商品数据
        $data = $this->createData($data);
        // 事务处理
        $this->transaction(function () use ($data) {
            // 添加商品
            $this->save($data);
            // 新增商品与分类关联
            GoodsCategoryRelModel::increased((int)$this['goods_id'], $data['categoryIds']);
            // 新增商品与图片关联
            GoodsImageModel::increased((int)$this['goods_id'], $data['imagesIds']);
            //非套餐商品
            // if($data['goods_type']!=Goods::PACKAGETYPE){
                 // 新增商品与规格关联
            GoodsSpecRelModel::increased((int)$this['goods_id'], $data['newSpecList']);
                // 新增商品sku信息
            GoodsSkuModel::add((int)$this['goods_id'], $data['spec_type'], $data['newSkuList']);
            // }
            
            // 新增服务与承诺关联
            GoodsServiceRelModel::increased((int)$this['goods_id'], $data['serviceIds']);
            //套餐 $data
            if($data['goods_type']==Goods::PACKAGETYPE){
                $packageList = $data['packageSkuData']??[];//sku商品
                GoodsPackageModel::add((int)$this['goods_id'], $data['spec_type'], $packageList);
            }
        });
        return true;
    }

    /**
     * 创建商品数据
     * @param array $data
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    private function createData(array $data)
    {
        if (!$this->goods_id) {
            $data['goods_no'] = self::makeGoodsNo(); // 生成商品编号
        }

        // 默认数据
        $data = array_merge($data, [
            'line_price' => $data['line_price'] ?? 0,
            'content' => $data['content'] ?? '',
            'newSpecList' => [],
            'newSkuList' => [],
            'store_id' => self::$storeId,
        ]);
        // 库存总量 stock_total
        // 商品价格 最低最高
        if ($data['spec_type'] == SpecTypeEnum::MULTI) {
            $data['stock_total'] = GoodsSkuModel::getStockTotal($data['specData']['skuList']);
            $data['alarm_stock_total'] = GoodsSkuModel::getAlarmStockTotal($data['specData']['skuList']);
            list($data['goods_price_min'], $data['goods_price_max']) = GoodsSkuModel::getGoodsPrices($data['specData']['skuList']);
            list($data['line_price_min'], $data['line_price_max']) = GoodsSkuModel::getLinePrices($data['specData']['skuList']);
        } elseif ($data['spec_type'] == SpecTypeEnum::SINGLE) {
            $data['goods_price_min'] = $data['goods_price_max'] = $data['goods_price'];
            $data['line_price_min'] = $data['line_price_max'] = $data['line_price'];
            $data['stock_total'] = $data['stock_num'];
            $data['alarm_stock_total'] = $data['alarm_stock_num'] ?? 0;
        }
        // 规格和sku数据处理
        if ($data['spec_type'] == SpecTypeEnum::MULTI) {
            // 生成多规格数据(携带id)
            $data['newSpecList'] = SpecModel::getNewSpecList($data['specData']['specList']);
            // 生成skuList ( 携带goods_sku_id )
            $data['newSkuList'] = GoodsSkuModel::getNewSkuList($data['newSpecList'], $data['specData']['skuList'], $data['goods_no'], $this->goods_id);
        } elseif ($data['spec_type'] == SpecTypeEnum::SINGLE) {
            // 生成skuItem
            $data['newSkuList'] = helper::pick($data, ['goods_price', 'line_price', 'stock_num', 'alarm_stock_num', 'goods_weight', 'goods_gross_weight','specs']);
            $data['newSkuList']['goods_sku_no'] = $data['goods_sku_no'];
            if ($this->goods_id) {
                $oldSkuInfo = GoodsSkuModel::where('goods_id', $this->goods_id)->where('goods_sku_id', 0)->find();
                $data['newSkuList']['clearing_price'] = $oldSkuInfo['clearing_price'] ?? 0;
                $data['newSkuList']['platform_rate'] = $oldSkuInfo['platform_rate'] ?? 0;
            }
        }
        // 单独设置折扣的配置
//        $data['is_enable_grade'] == 0 && $data['is_alone_grade'] = 0;
//        $aloneGradeEquity = [];
//        if ($data['is_alone_grade'] == 1) {
//            foreach ($data['alone_grade_equity'] as $key => $value) {
//                $gradeId = str_replace('grade_id:', '', $key);
//                $aloneGradeEquity[$gradeId] = $value;
//            }
//        }
//        $data['alone_grade_equity'] = $aloneGradeEquity;

        $data['province_id'] = $data['cascader'][0] ?? 0;
        $data['city_id'] = $data['cascader'][1] ?? 0;
        $data['region_id'] = $data['cascader'][2] ?? 0;
        return $data;
    }

    /**
     * 验证商品的合法性
     * @param $data
     * @return bool
     * @author: zjwhust
     * @Time: 2022/1/10 17:58
     */
    public function validateGoods($data){
        // 规格和sku数据处理
        if ($data['spec_type'] == SpecTypeEnum::MULTI) {//多规格
            $skuList = [];
            foreach ($data['specData']['skuList'] as $key=>&$sku) {
                if (!isset($sku['goods_sku_no']) || empty($sku['goods_sku_no'])) {//如果没有设置sku编号
                    $this->error = '商品SKU编码不能为空';
                    return false;
                }
                $skuList[] = $sku['goods_sku_no'];
                if(!$this->goods_id){ //新增
                    if(GoodsSkuModel::where(['goods_sku_no'=>$sku['goods_sku_no']])->count()){
                        $this->error = '商品SKU编码已存在';
                        return false;
                    }
                }else{ //编辑
                    if(GoodsSkuModel::where(['goods_sku_no'=>$sku['goods_sku_no']])->where('goods_id','<>',$this->goods_id)->count()){
                        $this->error = '商品SKU编码已存在';
                        return false;
                    }
                }
            }
            if(count(array_unique($skuList))!=count($data['specData']['skuList'])){
                $this->error = '商品SKU编码不能重复';
                return false;
            }

        } elseif ($data['spec_type'] == SpecTypeEnum::SINGLE) {//单规格
            if(!isset($data['goods_sku_no']) || empty($data['goods_sku_no'])){//如果没有设置sku编号
                $this->error = '商品SKU编码不能为空';
                return false;
            }
            if(!$this->goods_id){ //新增
                if(GoodsSkuModel::where(['goods_sku_no'=>$data['goods_sku_no']])->count()){
                    $this->error = '商品SKU编码已存在';
                    return false;
                }
            }else{ //编辑
                if(GoodsSkuModel::where(['goods_sku_no'=>$data['goods_sku_no']])->where('goods_id','<>',$this->goods_id)->count()){
                    $this->error = '商品SKU编码已存在';
                    return false;
                }
            }
        }
        return true;
    }

    /**
     * 编辑商品
     * @param array $data
     * @return bool
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function edit(array $data)
    {
        //判断商品结构的合法性
        if(!$this->validateGoods($data)){
            return false;
        }
        // 创建商品数据
        $data = $this->createData($data);
        //判断商品结构的合法性
        $this->validateGoods($data);
        // 事务处理
        $this->transaction(function () use ($data) {
            // 更新商品
            $this->save($data);
            // 更新商品与分类关联
            GoodsCategoryRelModel::updates((int)$this['goods_id'], $data['categoryIds']);
            // 更新商品与图片关联
            GoodsImageModel::updates((int)$this['goods_id'], $data['imagesIds']);
            // 更新商品与规格关联
            //非套餐商品
            // if($data['goods_type']!=Goods::PACKAGETYPE){

            GoodsSpecRelModel::updates((int)$this['goods_id'], $data['newSpecList']);
                // 更新商品sku信息
            GoodsSkuModel::edit((int)$this['goods_id'], $data['spec_type'], $data['newSkuList']);
            // }
            // 更新服务与承诺关联
            GoodsServiceRelModel::updates((int)$this['goods_id'], $data['serviceIds']);
            //套餐商品
            // if($data['goods_type']==Goods::PACKAGETYPE){
            $packageSkuList = $data['packageSkuData']??[];//sku商品
            GoodsPackageModel::edit((int)$this['goods_id'], $data['spec_type'], $packageSkuList);
            // }
        });
        return true;
    }

    /**
     * Notes:生成商品编号
     * 规则：SP+年+月+日期+时+分+秒+随机3位数
     * Author: zhangs
     * DateTime: 2021/10/11 16:11
     * @return string
     */
    public static function makeGoodsNo()
    {
        return "SP".date('YmdHis') . substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 3);
    }

    /**
     * Notes:生成商品SKU编号
     * 规则：商品编码的数字部分+2位数字 ，如2021 09 22 11 56 22 666 01
     * Author: zhangs
     * DateTime: 2021/10/11 16:15
     * @param $goodsNo
     * @return mixed
     */
    public static function makeGoodsSkuNo($goodsNo, $key)
    {
        return $goodsNo . pad_left($key);
//        return $goodsNo . substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 2);
    }

    /**
     * 修改商品状态
     * @param array $goodsIds 商品id集
     * @param bool $state 为true表示上架
     * @return false|int
     */

    /**
     * @param array $goodsIds
     * @param bool $state
     * @return bool
     */
    public function setStatus(array $goodsIds, bool $state)
    {
        // 批量更新记录
        return static::updateBase(['status' => $state ? 10 : 20], [['goods_id', 'in', $goodsIds]]);
    }

    /**
     * 软删除
     * @param array $goodsIds
     * @return bool
     */
    public function setDelete(array $goodsIds)
    {
        foreach ($goodsIds as $goodsId) {
            if (!GoodsService::checkIsAllowDelete($goodsId)) {
                $this->error = '当前商品正在参与其他活动，不允许删除';
                return false;
            }
        }
        // 批量更新记录
        return static::updateBase(['is_delete' => 1], [['goods_id', 'in', $goodsIds]]);
    }

    // 获取已售罄的商品
    public function getSoldoutGoodsTotal()
    {
        $filter = [
            ['stock_total', '=', 0],
            ['status', '=', GoodsStatusEnum::ON_SALE]
        ];
        return $this->getGoodsTotal($filter);
    }

    // 获取库存预警的商品
    public function getAlarmGoodsTotal()
    {
        return GoodsSku::alias('sku')
            ->leftJoin('goods', 'goods.goods_id=sku.goods_id')
            ->where([
                ['goods.status', '=', GoodsStatusEnum::ON_SALE],
                ['goods.is_delete', '=', 0],
                ['sku.stock_num', 'exp', Db::raw('< `alarm_stock_num`')]
            ])
            ->count();
    }

    // 获取在售商品总数
    public function getOnSaleGoodsTotal()
    {
        $filter = [
            ['status', '=', GoodsStatusEnum::ON_SALE]
        ];
        return $this->getGoodsTotal($filter);
    }

    /**
     * 获取当前商品总数
     * @param array $where
     * @return int
     */
    public function getGoodsTotal($where = [])
    {
        return $this->where($where)->where('is_delete', '=', 0)->count();
    }

}