// +---------------------------------------------------------------------- declare (strict_types=1); namespace app\dao\activity\seckill; use app\dao\BaseDao; use app\model\activity\seckill\StoreSeckill; /** * * Class StoreSeckillDao * @package app\dao\activity */ class StoreSeckillDao extends BaseDao { /** * 设置模型 * @return string */ protected function setModel(): string { return StoreSeckill::class; } /** * 搜索 * @param array $where * @param bool $search * @return \crmeb\basic\BaseModel|mixed|\think\Model * @throws \ReflectionException */ public function search(array $where = [], bool $search = false) { return parent::search($where)->when(isset($where['seckllTime']), function ($query) use ($where) { [$startTime, $stopTime] = is_array($where['seckllTime']) ? $where['seckllTime'] : [time(), time() - 86400]; $query->where('start_time', '<=', $startTime)->where('stop_time', '>=', $stopTime); })->when(isset($where['sid']) && $where['sid'], function ($query) use ($where) { $query->whereIn('product_id', function ($query) use ($where) { $query->name('store_product_cate')->where('cate_id', $where['sid'])->field('product_id')->select(); }); })->when(isset($where['cid']) && $where['cid'], function ($query) use ($where) { $query->whereIn('product_id', function ($query) use ($where) { $query->name('store_product_cate')->whereIn('cate_id', function ($query) use ($where) { $query->name('store_category')->where('pid', $where['cid'])->field('id')->select(); })->field('product_id')->select(); }); })->when(isset($where['storeProductId']), function ($query) { $query->where('product_id', 'IN', function ($query) { $query->name('store_product')->where('is_show', 1)->where('is_del', 0)->field('id'); }); })->when(isset($where['time_id']) && $where['time_id'], function ($query) use ($where) { $query->where('time_id', $where['time_id']); }); } /** * 条件获取数量 * @param array $where * @return int * @throws \ReflectionException */ public function getCount(array $where) { return $this->search($where)->count(); } /**获取秒杀列表 * @param array $where * @param int $page * @param int $limit * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function getList(array $where, int $page = 0, int $limit = 0) { return $this->search($where)->where('is_del', 0) ->when(isset($where['start_status']) && $where['start_status'] !== '', function ($query) use ($where) { $time = time(); switch ($where['start_status']) { case -1: $query->where('stop_time', '<', $time - 86400)->whereOr('status', 0); break; case 0: $query->where('start_time', '>', $time)->whereOr('status', 1); break; case 1: $query->where('start_time', '<=', $time)->where('stop_time', '>=', $time - 86400)->whereOr('status', 1); break; } })->when(isset($where['ids']) && $where['ids'], function ($query) use ($where) { if ((isset($where['priceOrder']) && $where['priceOrder'] != '') || (isset($where['salesOrder']) && $where['salesOrder'] != '')) { $query->whereIn('id', $where['ids']); } else { $query->whereIn('id', $where['ids'])->orderField('id', $where['ids'], 'asc'); } })->when($page != 0 && $limit != 0, function ($query) use ($page, $limit) { $query->page($page, $limit); })->with(['product'])->order('sort desc,id desc')->select()->toArray(); } /**获取秒杀列表 * @param array $where * @param int $page * @param int $limit * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function getHomeList(array $where, int $page = 0, int $limit = 0) { return $this->search($where)->where('is_del', 0)->where('status', 1) ->where('start_time', '<=', time()) ->where('stop_time', '>=', time() - 86400) ->when($page != 0 && $limit != 0, function ($query) use ($page, $limit) { $query->page($page, $limit); })->when(isset($where['priceOrder']) && $where['priceOrder'] != '', function ($query) use ($where) { if ($where['priceOrder'] === 'desc') { $query->order("price desc"); } else { $query->order("price asc"); } })->when(isset($where['newsOrder']) && $where['newsOrder'] != '', function ($query) use ($where) { if ($where['newsOrder'] === 'news') { $query->order("id desc"); } })->when(isset($where['salesOrder']) && $where['salesOrder'] != '', function ($query) use ($where) { if ($where['salesOrder'] === 'desc') { $query->order("sales desc"); } else { $query->order("sales asc"); } })->when(isset($where['ids']) && $where['ids'], function ($query) use ($where) { if ((isset($where['priceOrder']) && $where['priceOrder'] != '') || (isset($where['salesOrder']) && $where['salesOrder'] != '')) { $query->whereIn('id', $where['ids']); } else { $query->whereIn('id', $where['ids'])->orderField('id', $where['ids'], 'asc'); } })->with(['product'])->select()->toArray(); } /** * 根据商品id获取当前正在开启秒杀产品的列表以数组返回 * @param array $ids 为空查询所有 * @param array $field * @return array */ public function getSeckillIdsArray(array $ids = [], array $field = []) { return $this->search(['is_del' => 0, 'status' => 1]) ->where('start_time', '<=', time()) ->where('stop_time', '>=', time() - 86400) ->when($ids, function ($query) use ($ids) { $query->whereIn('product_id', $ids); })->field($field)->select()->toArray(); } /** * 获取某个时间段的秒杀列表 * @param int $time * @param int $page * @param int $limit * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function getListByTime(int $time, int $page, int $limit) { return $this->search(['is_del' => 0, 'status' => 1]) ->where('start_time', '<=', time()) ->where('stop_time', '>=', time() - 86400) ->where('time_id', $time) ->where('product_id', 'IN', function ($query) { $query->name('store_product')->where('is_show', 1)->where('is_del', 0)->field('id'); })->when($page != 0, function ($query) use ($page, $limit) { $query->page($page, $limit); })->order('sort desc,id desc')->select()->toArray(); } /** * 根据id获取秒杀数据 * @param array $ids * @param string $field * @return array * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function idSeckillList(array $ids, string $field) { return $this->getModel()->whereIn('id', $ids)->field($field)->select()->toArray(); } /**获取一条秒杀商品 * @param $id * @param $field * @return array|\think\Model|null * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function validProduct($id, $field) { $where = ['status' => 1, 'is_del' => 0]; $time = time(); return $this->search($where) ->where('id', $id) ->where('start_time', '<', $time) ->where('stop_time', '>', $time - 86400) ->field($field)->with(['product'])->find(); } }