mirror of
https://gitee.com/liuxioabin/fengketrade.git
synced 2026-04-17 21:03:17 +08:00
628 lines
18 KiB
PHP
628 lines
18 KiB
PHP
<?php
|
||
|
||
namespace app\admin\model\shopro\goods;
|
||
|
||
use app\admin\model\shopro\Common;
|
||
use traits\model\SoftDelete;
|
||
use addons\shopro\library\Tree;
|
||
use app\admin\model\shopro\Category;
|
||
use app\admin\model\shopro\activity\Activity as ActivityModel;
|
||
use app\admin\model\shopro\activity\SkuPrice as ActivitySkuPriceModel;
|
||
use app\admin\model\shopro\app\ScoreSkuPrice;
|
||
use app\admin\model\shopro\user\GoodsLog;
|
||
use app\admin\model\shopro\order\Order;
|
||
use app\admin\model\shopro\order\OrderItem;
|
||
use addons\shopro\facade\Activity as ActivityFacade;
|
||
|
||
|
||
class Goods extends Common
|
||
{
|
||
|
||
use SoftDelete;
|
||
|
||
protected $deleteTime = 'deletetime';
|
||
|
||
// 表名
|
||
protected $name = 'shopro_goods';
|
||
|
||
protected $type = [
|
||
'images' => 'json',
|
||
'image_wh' => 'json',
|
||
'params' => 'json',
|
||
];
|
||
|
||
// 追加属性
|
||
protected $append = [
|
||
'status_text',
|
||
'type_text',
|
||
'dispatch_type_text',
|
||
'score_discount_percent',
|
||
'max_use_score',
|
||
'score_exchange_rate'
|
||
];
|
||
|
||
|
||
protected $hidden = [
|
||
'content',
|
||
'max_sku_price',
|
||
'score_sku_prices',
|
||
'activity_sku_prices',
|
||
'total_sales' // 商品列表，销量排序会用到
|
||
];
|
||
|
||
/**
|
||
* type 中文
|
||
*/
|
||
public function typeList()
|
||
{
|
||
return [
|
||
'normal' => '实体商品',
|
||
'virtual' => '虚拟商品',
|
||
'card' => '电子卡密',
|
||
];
|
||
}
|
||
|
||
/**
|
||
* status 中文
|
||
*/
|
||
public function statusList()
|
||
{
|
||
return [
|
||
'up' => '上架中',
|
||
'down' => '已下架',
|
||
'hidden' => '已隐藏',
|
||
];
|
||
}
|
||
|
||
/**
|
||
* status 中文
|
||
*/
|
||
public function dispatchTypeList()
|
||
{
|
||
return [
|
||
'express' => '快递物流',
|
||
'autosend' => '自动发货',
|
||
'custom' => '商家发货'
|
||
];
|
||
}
|
||
|
||
|
||
/**
|
||
* 修改器 service_ids
|
||
*
|
||
* @param array|string $value
|
||
* @param array $data
|
||
* @return string
|
||
*/
|
||
public function setServiceIdsAttr($value, $data)
|
||
{
|
||
$service_ids = is_array($value) ? join(',', $value) : $value;
|
||
return $service_ids;
|
||
}
|
||
|
||
|
||
public function setIsOfflineAttr($value, $data)
|
||
{
|
||
// 除了实体商品，其他都是 0
|
||
return $data['type'] == 'normal' ? $value : 0;
|
||
}
|
||
|
||
|
||
public function scopeShow($query)
|
||
{
|
||
return $query->whereIn('status', ['up', 'hidden']);
|
||
}
|
||
|
||
|
||
public function getDispatchTypeTextAttr($value, $data)
|
||
{
|
||
$value = $value ?: ($data['dispatch_type'] ?? null);
|
||
|
||
$list = $this->dispatchTypeList();
|
||
return isset($list[$value]) ? $list[$value] : '';
|
||
}
|
||
|
||
|
||
public function getPriceAttr($value, $data)
|
||
{
|
||
// 前端传入的 session_id
|
||
$activity_id = session('goods-activity_id:' . $data['id']);
|
||
if ($activity_id && $this->activity) {
|
||
// 活动商品的价格
|
||
$skuPrices = $data['new_sku_prices'] ?? [];
|
||
$prices = $skuPrices instanceof \think\Collection ? $skuPrices->column('min_price') : array_column($skuPrices, 'min_price');
|
||
$maxPrices = $skuPrices instanceof \think\Collection ? $skuPrices->column('max_price') : array_column($skuPrices, 'max_price');
|
||
$min_price = $prices ? min($prices) : $data['price'];
|
||
$max_price = $maxPrices ? max($maxPrices) : $data['price'];
|
||
$priceArr[] = $min_price;
|
||
if ($min_price < $max_price) {
|
||
$priceArr[] = $max_price;
|
||
}
|
||
} else if (isset($data['show_score_shop'])) {
|
||
// 积分商品价格
|
||
$skuPrices = $data['new_sku_prices'] ?? [];
|
||
$skuPrices = $skuPrices instanceof \think\Collection ? $skuPrices->column(null, 'score') : array_column($skuPrices, null, 'score');
|
||
ksort($skuPrices);
|
||
$skuPrice = current($skuPrices); // 需要积分最少的规格
|
||
if ($skuPrice) {
|
||
// 不自动拼接积分
|
||
// $price = $skuPrice['score'] . '积分';
|
||
// if ($skuPrice['price'] > 0) {
|
||
// $price .= '+￥' . $skuPrice['price'];
|
||
// }
|
||
// $priceArr[] = $price;
|
||
$priceArr[] = $skuPrice['price'];
|
||
} else {
|
||
// 防止没有规格
|
||
$priceArr[] = $data['price'];
|
||
}
|
||
} else {
|
||
// 普通商品的价格区间
|
||
$price = $value ? $value : ($data['price'] ?? 0);
|
||
$priceArr = [$price];
|
||
if ($price && isset($data['is_sku']) && $data['is_sku']) {
|
||
$max_price = $this->max_sku_price->price;
|
||
if ($price < $max_price) {
|
||
$priceArr[] = $max_price;
|
||
}
|
||
}
|
||
}
|
||
|
||
return $priceArr;
|
||
}
|
||
|
||
|
||
|
||
/**
|
||
* 这个目前只有拼团单独购买要使用
|
||
*
|
||
* @return void
|
||
*/
|
||
public function getOriginalGoodsPriceAttr($value, $data)
|
||
{
|
||
$activity_id = session('goods-activity_id:' . $data['id']);
|
||
$priceArr = [];
|
||
if ($activity_id && $this->activity) {
|
||
// 活动商品的价格
|
||
$skuPrices = $data['new_sku_prices'] ?? [];
|
||
$prices = $skuPrices instanceof \think\Collection ? $skuPrices->column('old_price') : array_column($skuPrices, 'old_price');
|
||
$min_price = $prices ? min($prices) : $data['price'];
|
||
$max_price = $prices ? max($prices) : $data['price'];
|
||
$priceArr[] = $min_price;
|
||
if ($min_price < $max_price) {
|
||
$priceArr[] = $max_price;
|
||
}
|
||
}
|
||
|
||
return $priceArr;
|
||
}
|
||
|
||
|
||
/**
|
||
* 前端积分商城列表，获取默认所需积分（价格不自动拼接积分了，所以这里单独设置一个属性）
|
||
*/
|
||
public function getScoreAttr($value, $data)
|
||
{
|
||
// 积分商品价格
|
||
$skuPrices = $data['new_sku_prices'] ?? [];
|
||
$skuPrices = $skuPrices instanceof \think\Collection ? $skuPrices->column(null, 'score') : array_column($skuPrices, null, 'score');
|
||
ksort($skuPrices);
|
||
$skuPrice = current($skuPrices); // 需要积分最少的规格
|
||
if ($skuPrice) {
|
||
$scoreAmount = $skuPrice['score'] ?? 0;
|
||
} else {
|
||
// 防止没有规格
|
||
$scoreAmount = 0;
|
||
}
|
||
|
||
return $scoreAmount;
|
||
}
|
||
|
||
|
||
public function getSalesAttr($value, $data)
|
||
{
|
||
// 前端传入的 session_id
|
||
$activity_id = session('goods-activity_id:' . $data['id']);
|
||
$sales = $data['sales'] ?? 0;
|
||
$sales += ($data['show_sales'] ?? 0);
|
||
if ($activity_id && $this->activity) {
|
||
if ($this->activity['rules'] && isset($this->activity['rules']['sales_show_type']) && $this->activity['rules']['sales_show_type'] == 'real') {
|
||
// 活动设置显示真实销量
|
||
$skuPrices = $data['new_sku_prices'] ?? [];
|
||
$sales = array_sum($skuPrices instanceof \think\Collection ? $skuPrices->column('sales') : array_column($skuPrices, 'sales'));
|
||
}
|
||
} else if (isset($data['show_score_shop'])) {
|
||
// 积分商城显示真实销量
|
||
$skuPrices = $data['new_sku_prices'] ?? [];
|
||
$sales = array_sum($skuPrices instanceof \think\Collection ? $skuPrices->column('sales') : array_column($skuPrices, 'sales'));
|
||
}
|
||
|
||
return $sales;
|
||
}
|
||
|
||
|
||
|
||
/**
|
||
* 真实销量
|
||
*/
|
||
public function getRealSalesAttr($value, $data)
|
||
{
|
||
$sales = $data['sales'] ?? 0;
|
||
return $sales;
|
||
}
|
||
|
||
|
||
/**
|
||
* 相关商品（包含活动）购买用户，只查三个
|
||
*
|
||
* @param [type] $value
|
||
* @param [type] $data
|
||
* @return void
|
||
*/
|
||
public function getBuyersAttr($value, $data)
|
||
{
|
||
// 查询活动正在购买的人Goods
|
||
$activity_id = session('goods-activity_id:' . $data['id']);
|
||
$orderItems = OrderItem::with(['user' => function ($query) {
|
||
return $query->field('id,nickname,avatar');
|
||
}])->whereExists(function ($query) {
|
||
$order_name = (new Order())->getQuery()->getTable();
|
||
$order_item_name = (new OrderItem())->getQuery()->getTable();
|
||
|
||
$query->table($order_name)->where($order_item_name . '.order_id=' . $order_name . '.id')->whereIn('status', [Order::STATUS_PAID, Order::STATUS_COMPLETED, Order::STATUS_PENDING]);
|
||
});
|
||
|
||
if ($activity_id) {
|
||
$orderItems = $orderItems->where('activity_id', $activity_id);
|
||
}
|
||
|
||
$orderItems = $orderItems->fieldRaw('max(id),user_id')->where('goods_id', $data['id'])->group('user_id')->limit(3)->select();
|
||
|
||
$user = [];
|
||
foreach ($orderItems as $item) {
|
||
if ($item['user']) {
|
||
$user[] = $item['user'];
|
||
}
|
||
}
|
||
|
||
return $user;
|
||
}
|
||
|
||
|
||
public function getIsScoreShopAttr($value, $data)
|
||
{
|
||
$scoreGoodsIds = ScoreSkuPrice::group('goods_id')->cache(20)->column('goods_id');
|
||
|
||
return in_array($data['id'], $scoreGoodsIds) ? 1 : 0;
|
||
}
|
||
|
||
|
||
/**
|
||
* 获取当前商品所属分类的所有上级
|
||
*
|
||
* @param string $value
|
||
* @param array $data
|
||
* @return array
|
||
*/
|
||
public function getCategoryIdsArrAttr($value, $data)
|
||
{
|
||
$categoryIds = $data['category_ids'] ? explode(',', $data['category_ids']) : [];
|
||
|
||
$categoryIdsArr = [];
|
||
$category = new Category();
|
||
|
||
foreach ($categoryIds as $key => $category_id) {
|
||
$currentCategoryIds = (new Tree($category))->getParentFields($category_id);
|
||
if ($currentCategoryIds) {
|
||
$categoryIdsArr[] = $currentCategoryIds;
|
||
}
|
||
}
|
||
|
||
return $categoryIdsArr;
|
||
}
|
||
|
||
|
||
/**
|
||
* 获取服务ids数组
|
||
*
|
||
* @param [type] $value
|
||
* @param [type] $data
|
||
* @return void
|
||
*/
|
||
public function getServiceIdsAttr($value, $data)
|
||
{
|
||
$serviceIds = $this->attrFormatComma($value, $data, 'service_ids', true);
|
||
|
||
return $serviceIds ? array_values(array_filter(array_map("intval", $serviceIds))) : $serviceIds;
|
||
}
|
||
|
||
|
||
|
||
/**
|
||
* 获取所有服务列表
|
||
*
|
||
* @param string $value
|
||
* @param array $data
|
||
* @return array
|
||
*/
|
||
public function getServiceAttr($value, $data)
|
||
{
|
||
$serviceIds = $this->attrFormatComma($value, $data, 'service_ids');
|
||
|
||
$serviceData = [];
|
||
if ($serviceIds) {
|
||
$serviceData = Service::whereIn('id', $serviceIds)->select();
|
||
}
|
||
return $serviceData;
|
||
}
|
||
|
||
|
||
/**
|
||
* 获取规格列表
|
||
*
|
||
* @param string $value
|
||
* @param array $data
|
||
* @return array
|
||
*/
|
||
public function getSkusAttr($value, $data)
|
||
{
|
||
$sku = Sku::with('children')->where('goods_id', $data['id'])->where('parent_id', 0)->select();
|
||
return $sku;
|
||
}
|
||
|
||
/**
|
||
* 获取规格项列表
|
||
*
|
||
* @param string $value
|
||
* @param array $data
|
||
* @return array
|
||
*/
|
||
public function getSkuPricesAttr($value, $data)
|
||
{
|
||
$skuPrices = collection(SkuPrice::where('goods_id', $data['id'])->select());
|
||
return $skuPrices;
|
||
}
|
||
|
||
|
||
|
||
/**
|
||
* 获取器获取所有活动
|
||
*
|
||
* @param string $value
|
||
* @param array $data
|
||
* @return array
|
||
*/
|
||
public function getActivitiesAttr($value, $data)
|
||
{
|
||
$activities = ActivityFacade::getGoodsActivitys($data['id']);
|
||
|
||
return $activities;
|
||
}
|
||
|
||
|
||
/**
|
||
* 获取器获取指定活动
|
||
*
|
||
* @param string $value
|
||
* @param array $data
|
||
* @return array
|
||
*/
|
||
public function getActivityAttr($value, $data)
|
||
{
|
||
$activity_id = session('goods-activity_id:' . $data['id']);
|
||
$activities = ActivityFacade::getGoodsActivityByActivity($data['id'], $activity_id);
|
||
|
||
return $activities;
|
||
}
|
||
|
||
|
||
public function getPromosAttr($value, $data)
|
||
{
|
||
$promos = ActivityFacade::getGoodsPromos($data['id']);
|
||
|
||
foreach ($promos as $key => $promo) {
|
||
$rules = $promo['rules'];
|
||
$rules['simple'] = true;
|
||
$tags = ActivityFacade::formatRuleTags($rules, $promo['type']);
|
||
|
||
$promo['tag'] = $tags[0] ?? '';
|
||
$promo['tags'] = $tags;
|
||
|
||
$texts = ActivityFacade::formatRuleTexts($rules, $promo['type']);
|
||
$promo['texts'] = $texts;
|
||
|
||
$promos[$key] = $promo;
|
||
}
|
||
|
||
return $promos ?? [];
|
||
}
|
||
|
||
|
||
/**
|
||
* 积分商城价格，积分商城的属性
|
||
*
|
||
* @param string $value
|
||
* @param array $data
|
||
* @return string
|
||
*/
|
||
public function getScorePriceAttr($value, $data)
|
||
{
|
||
$scoreSkuPrices = collection($this->score_sku_prices)->column(null, 'score');
|
||
ksort($scoreSkuPrices);
|
||
$scoreSkuPrice = current($scoreSkuPrices); // 需要积分最少的规格
|
||
// print_r($scoreSkuPrices);exit;
|
||
if ($scoreSkuPrice) {
|
||
$price['score'] = $scoreSkuPrice['score'] ?? 0;
|
||
$price['price'] = $scoreSkuPrice['price'] ?? 0;
|
||
return $price;
|
||
} else {
|
||
return null;
|
||
}
|
||
|
||
// return $score . '积分' . ($price > 0 ? '+￥' . $price : '');
|
||
}
|
||
|
||
|
||
/**
|
||
* 积分商城销量
|
||
*
|
||
* @param string $value
|
||
* @param array $data
|
||
* @return string
|
||
*/
|
||
public function getScoreSalesAttr($value, $data)
|
||
{
|
||
$scoreSkuPrices = $this->score_sku_prices;
|
||
|
||
return array_sum(collection($scoreSkuPrices)->column('sales'));
|
||
}
|
||
|
||
|
||
/**
|
||
* 积分商城库存
|
||
*
|
||
* @param string $value
|
||
* @param array $data
|
||
* @return string
|
||
*/
|
||
public function getScoreStockAttr($value, $data)
|
||
{
|
||
$scoreSkuPrices = $this->score_sku_prices;
|
||
|
||
return array_sum(collection($scoreSkuPrices)->column('stock'));
|
||
}
|
||
|
||
|
||
public function maxSkuPrice()
|
||
{
|
||
return $this->hasOne(SkuPrice::class, 'goods_id')->order('price', 'desc');
|
||
}
|
||
|
||
public function favorite()
|
||
{
|
||
$user = auth_user();
|
||
$user_id = empty($user) ? 0 : $user->id;
|
||
return $this->hasOne(GoodsLog::class, 'goods_id', 'id')->where('user_id', $user_id)->favorite();
|
||
}
|
||
|
||
public function activitySkuPrices()
|
||
{
|
||
return $this->hasMany(ActivitySkuPriceModel::class, 'goods_id');
|
||
}
|
||
|
||
public function scoreSkuPrices()
|
||
{
|
||
return $this->hasMany(ScoreSkuPrice::class, 'goods_id')->up();
|
||
}
|
||
|
||
|
||
/**
|
||
* 包含下架的积分规格
|
||
*/
|
||
public function allScoreSkuPrices()
|
||
{
|
||
return $this->hasMany(ScoreSkuPrice::class, 'goods_id');
|
||
}
|
||
|
||
public function delScoreSkuPrices()
|
||
{
|
||
return $this->hasMany(ScoreSkuPrice::class, 'goods_id')->removeOption('soft_delete')->whereNotNull('deletetime'); // 只查被删除的记录，这里使用 onlyTrashed 报错
|
||
}
|
||
|
||
/**
|
||
* 获取积分抵扣百分比
|
||
*
|
||
* @param mixed $value
|
||
* @param array $data
|
||
* @return int
|
||
*/
|
||
public function getScoreDiscountPercentAttr($value, $data)
|
||
{
|
||
// TODO: 后续应该从系统配置中读取，目前硬编码为90%
|
||
return 90;
|
||
}
|
||
|
||
/**
|
||
* 获取积分兑换率（多少积分=1元）
|
||
*
|
||
* @param mixed $value
|
||
* @param array $data
|
||
* @return int
|
||
*/
|
||
public function getScoreExchangeRateAttr($value, $data)
|
||
{
|
||
// TODO: 后续应该从系统配置中读取，目前硬编码为700分=1元
|
||
return 700;
|
||
}
|
||
|
||
/**
|
||
* 获取最高可使用积分
|
||
* 计算公式：商品实际销售价 * 积分抵扣百分比 * 积分兑换率
|
||
* 例如：¥159.00 * 90% * 700 = 100,170积分
|
||
*
|
||
* 注意：
|
||
* 1. 积分向下取整（不四舍五入，避免超出实际可用）
|
||
* 2. 建行最低积分门槛：700积分 = 1元
|
||
* 3. 价格低于1元的商品返回0（不支持积分抵扣）
|
||
*
|
||
* @param mixed $value
|
||
* @param array $data
|
||
* @return int
|
||
*/
|
||
public function getMaxUseScoreAttr($value, $data)
|
||
{
|
||
// 建行最低积分门槛：700积分 = 1元（TODO: 应该从配置读取）
|
||
$minScoreThreshold = 700;
|
||
|
||
// 获取商品实际销售价格（可能是活动价或原价）
|
||
$price = 0;
|
||
|
||
// 方法1：尝试通过 price 获取器获取（会自动处理活动价）
|
||
// 注意：getPriceAttr 返回的是数组，格式为 [min_price] 或 [min_price, max_price]
|
||
try {
|
||
$priceAttr = $this->price; // 触发 getPriceAttr 获取器
|
||
if (is_array($priceAttr) && count($priceAttr) > 0) {
|
||
// 取最低价作为积分计算基准（用户一般按最低价下单）
|
||
$price = floatval($priceAttr[0]);
|
||
}
|
||
} catch (\Exception $e) {
|
||
// 获取器执行失败，使用原始价格
|
||
}
|
||
|
||
// 方法2：如果方法1失败，回退到原始价格
|
||
if ($price == 0 && isset($data['price'])) {
|
||
$price = floatval($data['price']);
|
||
}
|
||
|
||
// 如果价格为0或负数，返回0积分
|
||
if ($price <= 0) {
|
||
return 0;
|
||
}
|
||
|
||
// 计算最高可使用积分
|
||
// 公式：价格 * 抵扣百分比(90%) * 兑换率(700分/元)
|
||
$discountPercent = $this->score_discount_percent / 100; // 90% = 0.9
|
||
$exchangeRate = $this->score_exchange_rate; // 700
|
||
|
||
$maxScore = $price * $discountPercent * $exchangeRate;
|
||
|
||
// 向下取整（floor），避免四舍五入导致超出实际可用积分
|
||
// 例如：6.9积分 -> 6积分（不是7积分）
|
||
$maxScore = (int)floor($maxScore);
|
||
|
||
// 如果低于最低门槛，返回0（不支持积分抵扣）
|
||
if ($maxScore < $minScoreThreshold) {
|
||
return 0;
|
||
}
|
||
|
||
return $maxScore;
|
||
}
|
||
|
||
// -- commission code start --
|
||
public function commissionGoods()
|
||
{
|
||
return $this->hasOne(\app\admin\model\shopro\commission\CommissionGoods::class, 'goods_id');
|
||
}
|
||
// -- commission code end --
|
||
}
|