761 lines
29 KiB
PHP
761 lines
29 KiB
PHP
<?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]);
|
||
}
|
||
}
|