zhangxin
/
zx
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
zx/app/common/dao/store/product/ProductDao.php

761 lines
29 KiB
PHP
Raw Permalink Normal View History

first
2024-07-02 15:32:59 +08:00
<?php
// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2022 https://www.crmeb.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
// +----------------------------------------------------------------------
// | Author: CRMEB Team <admin@crmeb.com>
// +----------------------------------------------------------------------
namespace app\common\dao\store\product;
use app\common\dao\BaseDao;
use app\common\model\store\product\Product as model;
use app\common\repositories\store\product\SpuRepository;
use app\common\repositories\store\StoreCategoryRepository;
use crmeb\jobs\ChangeSpuStatusJob;
use think\db\BaseQuery;
use think\db\exception\DbException;
use think\Exception;
use think\facade\Db;
use think\facade\Queue;
class ProductDao extends BaseDao
{
protected function getModel(): string
{
return model::class;
}
/**
* @Author:Qinii
* @Date: 2020/5/9
* @param int $id
* @param array $data
*/
public function createAttr(int $id, array $data)
{
($this->getModel()::withTrashed()->find($id))->attr()->saveAll($data);
}
/**
* @Author:Qinii
* @Date: 2020/5/9
* @param int $id
* @param array $data
*/
public function createAttrValue(int $id, array $data)
{
($this->getModel()::withTrashed()->find($id))->attrValue()->saveAll($data);
}
/**
* @Author:Qinii
* @Date: 2020/5/9
* @param int $id
* @param array $data
*/
public function createContent(int $id, array $data)
{
($this->getModel()::withTrashed()->find($id))->content()->save($data);
}
/**
* @Author:Qinii
* @Date: 2020/5/9
* @param int $merId
* @param $field
* @param $value
* @param null $except
* @return bool
*/
public function merFieldExists(?int $merId, $field, $value, $except = null)
{
return model::withTrashed()->when($except, function ($query, $except) use ($field) {
$query->where($field, '<>', $except);
})->when($merId, function ($query, $merId) {
$query->where('mer_id', $merId);
})->where($field, $value)->count() > 0;
}
public function apiFieldExists(int $merId, $field, $value, $except = null)
{
return ($this->getModel())::getDB()->when($except, function ($query, $except) use ($field) {
$query->where($field, '<>', $except);
})->when($merId, function ($query, $merId) {
$query->where('mer_id', $merId);
})->where(['status' => 1])->where($field, $value)->count() > 0;
}
/**
* @param int $merId
* @param int $productId
* @return bool
* @author Qinii
*/
public function getDeleteExists(int $merId, int $productId)
{
return ($this->getModel())::onlyTrashed()->where('mer_id', $merId)->where($this->getPk(), $productId)->count() > 0;
}
/**
* @Author:Qinii
* @Date: 2020/5/11
* @param $merId
* @param array $where
* @return mixed
*/
public function search($merId, array $where)
{
$keyArray = $whereArr = [];
$out = ['soft', 'us_status', 'mer_labels', 'sys_labels', 'order', 'hot_type', 'is_action','seckill_active_id','level_one_cate_ids'];
foreach ($where as $key => $item) {
if ($item !== '' && !in_array($key, $out)) {
$keyArray[] = $key;
$whereArr[$key] = $item;
}
}
$query = isset($where['soft']) ? model::onlyTrashed()->alias('Product')->where('delete', 0) : model::alias('Product');
if (isset($where['is_trader']) && $where['is_trader'] !== '') {
$query->hasWhere('merchant', function ($query) use ($where) {
$query->where('is_trader', $where['is_trader']);
});
}
$query->withSearch($keyArray, $whereArr)->Join('StoreSpu U', 'Product.product_id = U.product_id')->where('U.product_type', $where['product_type'] ?? 0);
$query->when((isset($where['level_one_cate_ids']) && !empty($where['level_one_cate_ids'])), function ($query) use ($where) {
$storeCategoryRepository = app()->make(StoreCategoryRepository::class);
$where['level_one_cate_ids'] = explode(',',$where['level_one_cate_ids']);
if(!empty($where['level_one_cate_ids'])){
$levelTwoCateIds = $storeCategoryRepository->getSearch([])->whereIn('pid',$where['level_one_cate_ids'])->column('store_category_id');//选中的一级分类下的二级分类ID数组
if(!empty($levelTwoCateIds)){
$levelThreeCateIds = $storeCategoryRepository->getSearch([])->whereIn('pid',$levelTwoCateIds)->column('store_category_id');
if(!empty($levelThreeCateIds)){
$query->whereIn('cate_id',$levelThreeCateIds);
}
}
}
});
$query->when((isset($where['cate_id']) && !empty($where['cate_id'])), function ($query) use ($where) {
$query->where(['cate_id'=>$where['cate_id']]);
});
$query->when((isset($where['seckill_active_id']) && is_array($where['seckill_active_id']) && !empty($where['seckill_active_id'])), function ($query) use ($where) {
$query->whereIn('Product.active_id', $where['seckill_active_id']);
});
$query->when((isset($where['seckill_active_id']) && !is_array($where['seckill_active_id']) && $where['seckill_active_id']), function ($query) use ($where) {
$query->where('Product.active_id', $where['seckill_active_id']);
});
$query->when($merId, function ($query) use ($merId) {
if(is_array($merId)){
$query->whereIn('Product.mer_id', $merId);
}else if(!is_array($merId)){
$query->where('Product.mer_id', $merId);
}
})
->when(isset($where['hot_type']) && $where['hot_type'] !== '', function ($query) use ($where) {
if ($where['hot_type'] == 'new')
$query->where('is_new', 1);
else if ($where['hot_type'] == 'hot')
$query->where('is_hot', 1);
else if ($where['hot_type'] == 'best')
$query->where('is_best', 1);
else if ($where['hot_type'] == 'good')
$query->where('is_benefit', 1);
})
->when(isset($where['us_status']) && $where['us_status'] !== '', function ($query) use ($where) {
if ($where['us_status'] == 0) {
$query->where('Product.is_show', 0)->where('Product.is_used', 1)->where('Product.status', 1);
}
if ($where['us_status'] == 1) {
$query->where('Product.is_show', 1)->where('Product.is_used', 1)->where('Product.status', 1);
}
if ($where['us_status'] == -1) {
$query->where(function ($query) {
$query->where('Product.is_used', 0)->whereOr('Product.status', '<>', 1);
});
}
})
// ->when(isset($where['status']) && $where['status'] !== '', function ($query) use ($where) {
// $query->where('Product.status', $where['status']);
// })
->when(isset($where['mer_labels']) && $where['mer_labels'] !== '', function ($query) use ($where) {
$query->whereLike('U.mer_labels', "%,{$where['mer_labels']},%");
})
//活动商品列表
->when(isset($where['is_action']) && $where['is_action'] !== '', function ($query) use ($where) {
$query->where('type', '<>', 2);
})
->when(isset($where['sys_labels']) && $where['sys_labels'] !== '', function ($query) use ($where) {
$query->whereLike('U.sys_labels', "%,{$where['sys_labels']},%");
})
->when(isset($where['svip_price_type']) && $where['svip_price_type'] !== '', function ($query) use ($where) {
$query->where('Product.svip_price_type', $where['svip_price_type']);
})
->when(isset($where['product_type']) && $where['product_type'] == 1, function ($query) use ($where) {
$query->where('active_id','>',0);
})
->when(isset($where['order']), function ($query) use ($where, $merId) {
if (in_array($where['order'], ['is_new', 'price_asc', 'price_desc', 'rate', 'sales'])) {
if ($where['order'] == 'price_asc') {
$where['order'] = 'price ASC';
} else if ($where['order'] == 'price_desc') {
$where['order'] = 'price DESC';
} else {
$where['order'] = $where['order'] . ' DESC';
}
$query->order($where['order'] . ',rank DESC ,create_time DESC ');
} else if ($where['order'] !== '') {
$query->order('U.' . $where['order'] . ' DESC,U.create_time DESC');
} else {
$query->order('U.create_time DESC');
}
})
->when(isset($where['star']), function ($query) use ($where) {
$query->when($where['star'] !== '', function ($query) use ($where) {
$query->where('U.star', $where['star']);
});
$query->order('U.star DESC,U.rank DESC,Product.create_time DESC');
})
->when(isset($where['sort']), function ($query) use ($where) {
$query->when($where['sort'] !== '', function ($query) use ($where) {
$query->where('U.sort', $where['sort']);
});
$query->order('Product.sort DESC,Product.create_time DESC');
})
->when(isset($where['is_good']) && $where['is_good'] !== '', function ($query) use ($where) {
$query->where('Product.is_good', $where['is_good']);
});
return $query;
}
/**
* TODO
* @param array $where
* @return BaseQuery
* @author Qinii
* @day 2020-08-04
*/
public function seckillSearch(array $where)
{
$query = model::hasWhere('seckillActive', function ($query) use ($where) {
$query->where('status', 1);
// $query->whereTime('start_day', '<=', $where['day'])->whereTime('end_day', '>=', $where['day']);
// $query->where('start_time', '<=', $where['start_time'])
// ->where('end_time', '>', $where['start_time'])
// ->where('end_time', '<=', $where['end_time']);
});
$query->Join('StoreSpu U', 'Product.product_id = U.product_id')->where('U.product_type', 1);
$query->where([
'Product.is_show' => 1,
'Product.status' => 1,
'Product.is_used' => 1,
'Product.mer_status' => 1,
'Product.product_type' => 1,
'Product.is_gift_bag' => 0,
])
->when(isset($where['mer_id']) && $where['mer_id'] !== '', function ($query) use ($where) {
$query->where('Product.mer_id', $where['mer_id']);
})
->when(isset($where['active_id']) && !empty($where['active_id']) && is_array($where['active_id']), function ($query) use ($where) {
$query->whereIn('Product.active_id', $where['active_id']);
})
->when(isset($where['star']), function ($query) use ($where) {
$query->when($where['star'] !== '', function ($query) use ($where) {
$query->where('U.star', $where['star']);
});
$query->order('U.star DESC,Product.rank DESC');
});
return $query;
}
/**
* @Author:Qinii
* @Date: 2020/5/18
* @param int $id
* @param bool $soft
* @return int|mixed
*/
public function delete(int $id, $soft = false)
{
if ($soft) {
(($this->getModel())::onlyTrashed()->find($id))->force()->delete();
} else {
$this->getModel()::where($this->getPk(), $id)->update(['is_del' => 1]);
}
app()->make(SpuRepository::class)->getSearch(['product_id' => $id])->update(['is_del' => 1, 'status' => 0]);
event('product.delete', compact('id'));
}
public function destory(int $id)
{
try {
$this->getModel()::withTrashed()->where('product_id', $id)->update(['delete' => 1]);
app()->make(SpuRepository::class)->getSearch(['product_id' => $id])->delete();
event('product.delete', compact('id'));
} catch (Exception $e) {
}
}
/**
* TODO
* @param $id
* @return mixed
* @author Qinii
* @day 2020-07-03
*/
public function restore($id)
{
$res = ($this->getModel())::onlyTrashed()->find($id);
app()->make(SpuRepository::class)->delProduct($id, 0);
return $res->restore();
}
public function getOnlyTranshed($where)
{
return ($this->getModel())::onlyTrashed()->where($where)->order('product_id DESC');
}
/**
* @Author:Qinii
* @Date: 2020/5/18
* @param int $id
* @param array $status
* @return mixed
*/
public function switchStatus(int $id, array $status)
{
return ($this->getModel()::getDB())->where($this->getPk(), $id)->update($status);
}
/**
* @param int $merId
* @param array $productIds
* @return array
* @author xaboy
* @day 2020/5/26
*/
public function productIdByImage(int $merId, array $productIds)
{
return model::getDB()->where('mer_id', $merId)->whereIn('product_id', $productIds)->column('product_id,image');
}
/**
* @param array $ids
* @return array
* @author xaboy
* @day 2020/5/30
*/
public function intersectionKey(array $ids): array
{
return model::getDB()->whereIn('product_id', $ids)->column('product_id');
}
/**
* @Author:Qinii
* @Date: 2020/5/30
* @param $id
* @return mixed
*/
public function productIdByMerId($id)
{
return model::getDB()->where('product_id', $id)->value('mer_id');
}
/**
* @param int $productId
* @param int $desc
* @return int
* @throws DbException
* @author xaboy
* @day 2020/6/8
*/
public function descStock(int $productId, int $desc)
{
return model::getDB()->where('product_id', $productId)->update([
'stock' => Db::raw('stock-' . $desc),
'sales' => Db::raw('sales+' . $desc)
]);
}
/**
* @param int $productId
* @param int $inc
* @return int
* @throws DbException
* @author xaboy
* @day 2020/6/8
*/
public function incStock(int $productId, int $inc)
{
model::getDB()->where('product_id', $productId)->inc('stock', $inc)->update();
model::getDB()->where('product_id', $productId)->where('sales', '>=', $inc)->dec('sales', $inc)->update();
}
public function descSales(int $productId, int $desc)
{
return model::getDB()->where('product_id', $productId)->update([
'sales' => Db::raw('sales-' . $desc)
]);
}
public function incSales(int $productId, int $inc)
{
return model::getDB()->where('product_id', $productId)->update([
'sales' => Db::raw('sales+' . $inc)
]);
}
public function descIntegral(int $productId, $integral_total, $integral_price_total)
{
return model::getDB()->where('product_id', $productId)->update([
'integral_total' => Db::raw('integral_total-' . $integral_total),
'integral_price_total' => Db::raw('integral_price_total-' . $integral_price_total),
]);
}
public function incIntegral(int $productId, $integral_total, $integral_price_total)
{
model::getDB()->where('product_id', $productId)->inc('integral_total', $integral_total)->inc('integral_price_total', $integral_price_total)->update();
}
public function visitProductGroup($date, $merId = null, $limit = 7)
{
return model::getDB()->alias('A')->leftJoin('UserRelation B', 'A.product_id = B.type_id')
->field(Db::raw('count(B.type_id) as total,A.product_id,A.store_name,A.image'))
->when($date, function ($query, $date) {
getModelTime($query, $date, 'B.create_time');
})->when($merId, function ($query, $merId) {
$query->where('A.mer_id', $merId);
})->where('B.type', 1)->group('A.product_id')->limit($limit)->order('total DESC')->select();
}
public function cartProductGroup($date, $merId = null, $limit = 7)
{
return model::getDB()->alias('A')->leftJoin('StoreCart B', 'A.product_id = B.product_id')
->field(Db::raw('sum(B.cart_num) as total,A.product_id,A.store_name,A.image'))
->when($date, function ($query, $date) {
getModelTime($query, $date, 'B.create_time');
})->when($merId, function ($query, $merId) {
$query->where('A.mer_id', $merId);
})->where('B.product_type', 0)->where('B.is_pay', 0)->where('B.is_del', 0)
->where('B.is_new', 0)->where('B.is_fail', 0)->group('A.product_id')->limit($limit)->order('total DESC')->select();
}
public function changeMerchantProduct($merId, $data)
{
($this->getModel()::getDB())->where('mer_id', $merId)->update($data);
}
/**
* TODO
* @param int $productId
* @author Qinii
* @day 2020-07-09
*/
public function incCareCount(int $productId)
{
($this->getModel()::getDB())->where($this->getPk(), $productId)->inc('care_count', 1)->update();
}
/**
* TODO
* @param int $productId
* @author Qinii
* @day 2020-07-09
*/
public function decCareCount(array $productId)
{
($this->getModel()::getDB())->whereIn($this->getPk(), $productId)->where('care_count', '>', 0)->dec('care_count', 1)->update();
}
/**
* TODO api展示的商品条件
* @return array
* @author Qinii
* @day 2020-08-18
*/
public function productShow()
{
return [
'is_show' => 1, // 上架
'status' => 1, // 审核通过
'is_used' => 1, // 显示
'product_type' => 0, // 普通商品
'mer_status' => 1, //商铺状态正常
'is_gift_bag' => 0, //不是礼包
];
}
/**
* TODO api展示的礼包商品条件
* @return array
* @author Qinii
* @day 2020-08-18
*/
public function bagShow()
{
return [
'is_show' => 1,
'status' => 1,
'is_used' => 1,
'mer_status' => 1,
'product_type' => 0,
'is_gift_bag' => 1,
];
}
/**
* TODO api展示的秒杀商品条件
* @return array
* @author Qinii
* @day 2020-08-18
*/
public function seckillShow()
{
return [
'is_show' => 1,
'status' => 1,
'is_used' => 1,
'mer_status' => 1,
'product_type' => 1,
'is_gift_bag' => 0,
];
}
public function getProductTypeById(int $productId, ?int $exsistType)
{
$product_type = $this->getModel()::getDB()
->when($exsistType, function ($query) use ($exsistType) {
$query->where('product_type', $exsistType);
})
->where($this->getPk(), $productId)->where('is_del', 0)->value('product_type');
return $product_type == 0 ? true : false;
}
public function getFailProduct(int $productId)
{
return $this->getModel()::withTrashed()->field('product_type,product_id,image,store_name,is_show,status,is_del,unit_name,price,mer_status,is_used,mer_form_id')->find($productId);
}
public function geTrashedtProduct(int $id)
{
return model::withTrashed()->where($this->getPk(), $id);
}
/**
* TODO 获取各种有效时间内的活动
* @param int $productType
* @return BaseQuery
*
* @date 2023/09/22
* @author yyw
*/
public function activitSearch(int $productType)
{
$query = model::getDB()->alias('P')
->where('P.is_del', 0)
->where('P.mer_status', 1)
->where('P.product_type', $productType);
switch ($productType) {
case 0:
// $query->where('P.is_show',1)
// ->where('P.is_used',1)
// ->field('product_id,product_type,mer_id,store_name,keyword,price,rank,sort,image,status,temp_id');
break;
case 1:
$query->join('StoreSeckillActive S', 'S.seckill_active_id = P.active_id')
->field('P.*,S.status,S.seckill_active_id,S.end_time');
break;
case 2:
$query->join('StoreProductPresell R', 'R.product_id = P.product_id')
->where('R.is_del', 0)
->field('P.*,R.product_presell_id,R.store_name,R.price,R.status,R.is_show,R.product_status,R.action_status');
break;
case 3:
$query->join('StoreProductAssist A', 'A.product_id = P.product_id')
->where('A.is_del', 0)
->field('P.*,A.product_assist_id,A.store_name,A.status,A.is_show,A.product_status,A.action_status');
break;
case 4:
$query->join('StoreProductGroup G', 'G.product_id = P.product_id')
->where('G.is_del', 0)
->field('P.*,G.product_group_id,G.price,G.status,G.is_show,G.product_status,G.action_status');
break;
default:
break;
}
return $query;
}
public function commandChangeProductStatus($data)
{
$ret = [];
foreach ($data as $item) {
$status = 0;
switch ($item['product_type']) {
case 0:
if ($item['is_show'] && $item['is_used']) $status = 1;
$ret[] = [
'activity_id' => 0,
'product_id' => $item['product_id'],
'mer_id' => $item['mer_id'],
'keyword' => $item['keyword'],
'price' => $item['price'],
'rank' => $item['rank'],
'sort' => $item['sort'],
'image' => $item['image'],
'status' => $status,
'temp_id' => $item['temp_id'],
'store_name' => $item['store_name'],
'product_type' => $item['product_type'],
];
break;
case 1:
if ($item['is_show'] && $item['is_used'] && $item['status'] && ($item['end_time'] > time())) $status = 1;
$ret[] = [
'activity_id' => $item['seckill_active_id'],
'product_id' => $item['product_id'],
'mer_id' => $item['mer_id'],
'keyword' => $item['keyword'],
'price' => $item['price'],
'rank' => $item['rank'],
'sort' => $item['sort'],
'image' => $item['image'],
'status' => $status,
'temp_id' => $item['temp_id'],
'store_name' => $item['store_name'],
'product_type' => $item['product_type'],
];
break;
case 2:
if ($item['is_show'] && $item['action_status'] && $item['status'] && $item['product_status']) $status = 1;
$ret[] = [
'activity_id' => $item['product_presell_id'],
'product_id' => $item['product_id'],
'mer_id' => $item['mer_id'],
'keyword' => $item['keyword'],
'price' => $item['price'],
'rank' => $item['rank'],
'sort' => $item['sort'],
'image' => $item['image'],
'status' => $status,
'temp_id' => $item['temp_id'],
'store_name' => $item['store_name'],
'product_type' => $item['product_type'],
];
break;
case 3:
if ($item['is_show'] && $item['action_status'] && $item['status'] && $item['product_status']) $status = 1;
$ret[] = [
'activity_id' => $item['product_assist_id'],
'product_id' => $item['product_id'],
'mer_id' => $item['mer_id'],
'keyword' => $item['keyword'],
'price' => $item['price'],
'rank' => $item['rank'],
'sort' => $item['sort'],
'image' => $item['image'],
'status' => $status,
'temp_id' => $item['temp_id'],
'store_name' => $item['store_name'],
'product_type' => $item['product_type'],
];
break;
case 4:
if ($item['is_show'] && $item['action_status'] && $item['status'] && $item['product_status']) $status = 1;
$ret[] = [
'activity_id' => $item['product_group_id'],
'product_id' => $item['product_id'],
'mer_id' => $item['mer_id'],
'keyword' => $item['keyword'],
'price' => $item['price'],
'rank' => $item['rank'],
'sort' => $item['sort'],
'image' => $item['image'],
'status' => $status,
'temp_id' => $item['temp_id'],
'store_name' => $item['store_name'],
'product_type' => $item['product_type'],
];
break;
default:
if ($item['is_show'] && $item['is_used']) $status = 1;
$ret[] = [
'activity_id' => 0,
'product_id' => $item['product_id'],
'mer_id' => $item['mer_id'],
'keyword' => $item['keyword'],
'price' => $item['price'],
'rank' => $item['rank'],
'sort' => $item['sort'],
'image' => $item['image'],
'status' => $status,
'temp_id' => $item['temp_id'],
'store_name' => $item['store_name'],
'product_type' => $item['product_type'],
];
break;
}
}
return $ret;
}
/**
* TODO 软删除商户的所有商品
* @param $merId
* @author Qinii
* @day 5/15/21
*/
public function clearProduct($merId)
{
$this->getModel()::withTrashed()->where('mer_id', $merId)->delete();
}
/**
* 获取好物推荐列表
* @param array|null $good_ids
* @param $is_mer
* @return array|mixed
*
* @date 2023/10/30
* @author yyw
*/
public function getGoodList(array $good_ids, int $merId, $is_show = true)
{
if (empty($good_ids) && !$is_show) return [];
$filed = 'product_id,image,store_name,price,create_time,is_gift_bag,is_good,is_show,mer_id,sales,status';
$where = [];
$limit = 30;
if ($is_show) {
$where = $this->productShow();
$limit = 18;
}
$query = $this->getModel()::getDB()->where('mer_id', $merId)->where($where)
->when(!empty($good_ids), function ($query) use ($good_ids) {
$query->whereIn($this->getPk(), $good_ids);
})->field($filed);
$list = $query->limit($limit)->select()->toArray();
if ($is_show && count($list) < 6) {
$res = $query->where('is_good', 1)->orderRaw("RAND()")->limit(6 - count($list))->select()->toArray();
if ($res) $list = array_merge($list,$res);
}
return $list;
}
public function deleteProductFormByFormId(int $form_id, int $mer_id)
{
return $this->getModel()::getDB()->where('mer_form_id', $form_id)->where('mer_id', $mer_id)->update(['mer_form_id' => 0]);
}
}