only(['category_id', 'type', 'by', 'lat', 'lng']); $category_id = $formData['category_id'] ?? 0; $type = $formData['type'] ?? 0; $by = $formData['by'] ?? 0; $lat = $formData['lat'] ?? 0; $lng = $formData['lng'] ?? 0; $list = AgentProductView::list($this->agent_id)->addSelect('latitude', 'logitude', 'address'); if ($category_id) { $list = $list->whereIn('category_id', [$category_id, ...$this->get_category_child_ids($category_id)]); } // 距离排序,TODO 优化 if ($type == 4) { $list = $list->addSelect(DB::raw(<<orderBy($field, $by)->simplePaginate(); $list = $this->paginatePicAddHost($list); $list = $this->insertAd($list); return $this->success($list); } //递归获取指定分类下的所有子分类 private function get_category_child_ids($category_id): array { static $category = null; if ($category === null) { $category = Category::where('agent_id', $this->agent_id)->get()->toArray(); } $child = []; foreach ($category as $cat) { if ($cat['pid'] == $category_id) { $child[] = $cat['id']; $child = array_merge($child, $this->get_category_child_ids($cat['id'])); } } return $child; } //首页搜索框 public function search() { $category_id = request()->input('category_id'); $keywords = request()->input('keywords'); $type = request()->input('type', 0); $by = request()->input('by', 0); $list = AgentProduct::list($this->agent_id); if ($category_id) { $list = $list->whereIn('category_id', [$category_id, ...$this->get_category_child_ids($category_id)]); } if ($keywords) { $list = $list->where('title', 'like', "%$keywords%"); } $fields = ['id', 'sale', 'updated_at', 'price']; //排序字段 $field = $fields[$type] ?? $fields[0]; $by = $by == 0 ? 'desc' : 'asc'; $list = $list->orderBy($field, $by)->simplePaginate(); $list = $this->paginatePicAddHost($list); return $this->success($list); } //旅游线路搜索 public function travel_search() { $formData = request()->only(['departure_place', 'destination', 'type', 'by']); $type = $formData['type'] ?? 0; $by = $formData['by'] ?? 0; if (empty($formData['departure_place']) && empty($formData['destination'])) { return $this->error('请输入出发地和目的地'); } $fields = ['id', 'sale', 'updated_at', 'price']; //排序字段 $field = $fields[$type] ?? $fields[0]; $by = $by == 0 ? 'desc' : 'asc'; $list = AgentProduct::list($this->agent_id)->whereHas('product', function($query) use ($formData) { //出发地 if (!empty($formData['departure_place'])) { $query->whereRaw("extends->'$.field_0_departure_place' LIKE ?", ["%{$formData['departure_place']}%"]); } //目的地 if (!empty($formData['destination'])) { $query->whereRaw("extends->'$.field_0_destination' LIKE ?", ["%{$formData['destination']}%"]); } })->orderBy($field, $by)->simplePaginate(); $list = $this->paginatePicAddHost($list); return $this->success($list); } // 产品详情 public function show() { $id = (int)request()->input('id'); if (AgentProduct::where('agent_id', $this->agent_id)->withTrashed()->count() === 0) { //演示产品用 $where = ['id' => $id, 'status' => ProductStatus::ON_SALE]; } else { $where = ['id' => $id, 'agent_id' => $this->agent_id, 'status' => ProductStatus::ON_SALE]; } $agent_product = AgentProduct::with([ 'coupon:tag,agent_product_id', 'product' => function ($query) { $query->select(['id', 'type', 'extends', 'diy_form_id'])->with('diyForm', function ($query) { $query->select(['id', 'name'])->with('fields'); }); }, 'spec' => function($query) { return $query->has('productSpec')->with('productSpec', function ($query) { $query->select(['id', 'name', 'date'])->where('date', '>=', date('Y-m-d'))->orderBy('date', 'asc'); }); } ]) ->whereDoesntHave('agentProductItem', function ($query) { return $query->whereHas('product', function ($query) { return $query->where('stock', '<=', 0)->orWhere('status', '<>', ProductStatus::ON_SALE); }); }) ->where('stock', '>', 0) ->firstWhere($where); if (!$agent_product) { return $this->error('产品已下架或库存不足'); } $prefix = Storage::disk('public')->url(''); $agent_product->pictures = array_map(fn($item) => ($prefix . $item), $agent_product->pictures); if ($this->user_id) { $agent_product->is_collect = UserFav::query()->where(['user_id' => $this->user_id, 'agent_product_id' => $id])->exists() ? 1 : 0; //判断是否收藏 } else { $agent_product->is_collect = 0; } //计算折扣 if ($agent_product->price < $agent_product->original_price) { $agent_product->cost = round($agent_product->price / $agent_product->original_price * 10, 1); } else { $agent_product->cost = ''; } //处理自定义字段 if (!empty($agent_product->product->diyForm->fields) && !$agent_product->product->diyForm->fields->isEmpty()) { foreach ($agent_product->product->diyForm->fields as &$v) { if ($v['type'] == 'checkbox' && is_array($v['options'])) { $v['options'] = array_map(function ($v2) { $arr['checked'] = false; $arr['disabled'] = false; $arr['name'] = $v2; return $arr; }, $v['options']); } } } //处理规格 if (!$agent_product->spec->isEmpty()) { $specs = $agent_product->spec->toArray(); //二维数组转一维 $specs = array_map(function ($v) { if (is_array($v['product_spec'])) { unset($v['product_spec']['id']); $v = array_merge($v, $v['product_spec']); } unset($v['agent_product_id'], $v['product_spec_id'], $v['product_spec'], $v['deleted_at']); return $v; }, $specs); //去年name和date为空的数组 $specs = array_filter($specs, fn($v) => isset($v['name'], $v['date'])); $names = array_column($specs, 'name'); $names = array_values(array_unique($names)); $result = []; foreach ($names as $name) { $list = array_filter($specs, fn($v) => $v['name'] == $name); $result[] = [ 'name' => $name, 'date_start' => min(array_column($list, 'date')), 'date_end' => max(array_column($list, 'date')), 'original_price' => min(array_column($list, 'original_price')), 'price' => min(array_column($list, 'price')), 'list' => array_values($list), ]; } unset($agent_product->spec); $agent_product->spec = $result; } unset($agent_product->agent_id, $agent_product->status, $agent_product->deleted_at); return $this->success($agent_product); } // 猜你喜欢 public function guessLike() { $list = AgentProduct::list($this->agent_id)->orderBy('id', 'DESC')->simplePaginate(); $list = $this->paginatePicAddHost($list); $list = $list->toArray(); if (!empty($list['data']) && is_array($list['data'])) { shuffle($list['data']); //随机乱序 } $list = $this->insertAd($list); return $this->success($list); } //【我的】页面下方推荐 public function recommendList() { $list = AgentProduct::list($this->agent_id)->where(['is_rec' => 1]) ->orderBy('id', 'DESC')->simplePaginate(); $list = $this->paginatePicAddHost($list); $list = $this->insertAd($list); return $this->success($list); } //人气爆款列表,销量排序 public function hotList() { $list = AgentProduct::list($this->agent_id) ->orderBy('sale', 'DESC')->orderBy('id', 'DESC')->simplePaginate(); $list = $this->paginatePicAddHost($list); $list = $this->insertAd($list); return $this->success($list); } //分页列表产品图片加域名 private function paginatePicAddHost($list) { //如果是新入驻代理商没有数据,且没有删除过的数据,则显示最早的几条 if ($list->isEmpty()) { if (AgentProduct::where('agent_id', $this->agent_id)->withTrashed()->count() === 0 && request('page', 1) <= 2) { //只获取2页数据 $list = AgentProduct::list($this->agent_id)->orWhere([['status', '=', ProductStatus::ON_SALE], ['price', '>', 500]])->orderBy('id')->simplePaginate(); } else { return $list; //因为只获取2页数据,不return可能会导入下面的代码出错 } } $prefix = Storage::disk('public')->url(''); foreach ($list->items() as $k=>&$v) { $v->pictures = array_map(function($item) use ($prefix) { return strpos($item, $prefix) === false ? $prefix . $item : $item; }, $v->pictures); } return $list; } //插入瀑布流广告 private function insertAd($list) { //插入瀑布流广告,分别在第8个和第16个插入,同时需要考虑到分页。当所有瀑布流广告插入完之后,再次循环插入 if (is_object($list) && method_exists($list, 'toArray')) { $list = $list->toArray(); } $ad_total = Advertising::where(['agent_id' => $this->agent_id, 'status' => 1, 'display' => 2])->count(); if ($list['data'] && $ad_total > 0) { $page = (int)request()->input('page'); $start = ($page ? $page - 1 : 0) * 2 % $ad_total; $ad = Advertising::where(['agent_id' => $this->agent_id, 'status' => 1, 'display' => 2]) ->orderBy('sort')->orderBy('id', 'DESC') ->offset($start)->limit(2)->get(['title', 'picture', 'type', 'url'])->toArray(); $prefix = Storage::disk('public')->url(''); foreach ($ad as $k => &$v) { $v['is_ad'] = true; $v['picture'] = $prefix . $v['picture']; //每隔8个插入广告 $temp = 8 * ($k+1); if (!empty($list['data'][$temp - 1]) && !empty($ad[$k])) { array_splice($list['data'], $temp + $k, 0, [$ad[$k]]); } } } return $list; } }