hainan/app/Http/Controllers/Api/AgentProductController.php

<?php

namespace App\Http\Controllers\Api;
use App\Common\ProductStatus;
use App\Http\Controllers\Controller;
use App\Models\Advertising;
use App\Models\AgentProduct;
use App\Models\Category;
use App\Models\UserFav;
use App\Models\Views\AgentProduct as AgentProductView;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Storage;

/**
 * 代理商产品
 * Class AgentProductController
 * @package App\Http\Controllers\Api
 */
class AgentProductController extends Controller
{
	// 代理商产品列表
	public function index()
	{
		$formData = request()->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);
		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(<<<SQL
round(
	(((6371.393 * 2) * asin(
		sqrt((
			pow( sin((((( {$lat} * 3.1415926 ) / 180 ) - (( `latitude` * pi()) / 180 )) / 2 )), 2 )
			+
			(
				(cos((({$lat} * 3.1415926) / 180)) * cos(((`latitude` * pi()) / 180)))
				*
				pow( sin((((( {$lng} * 3.1415926 ) / 180 ) - (( `logitude` * pi()) / 180 )) / 2 )), 2 ))))
	)) * 1000),0) AS `distance_m`
SQL));
		}

		$fields = ['id', 'sale', 'updated_at', 'price', 'distance_m']; //排序字段 TODO 还有距离排序

		$field = $fields[$type] ?? $fields[0];
		$by = $by == 0 ? 'desc' : 'asc';

		$list = $list->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;
	}
}