// +---------------------------------------------------------------------- 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(); } }