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\AgentProductSpec;
use App\Models\Category;
use App\Models\UserFav;
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  = (int)($formData['category_id'] ?? 0);
		$type = $formData['type'] ?? 0;
		$by = $formData['by'] ?? 0;
		$lat = $formData['lat'] ?? 0;
		$lng = $formData['lng'] ?? 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 ($lat && $lng) {
			$list = $list->addSelect('latitude', 'longitude', 'address', 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 ) - (( `longitude` * pi()) / 180 )) / 2 )), 2 ))))
	)) * 1000),0) AS `distance_m`
SQL
			));
		}
		$fields = ['id', 'sale', 'updated_at', 'price', 'distance_m']; //排序字段

		//距离排序只有升序
		if ($type == 4) {
			$by = 1;
		}

		$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([
				'diyForm.fields',
				'coupon:tag,agent_product_id',
				'product' => function ($query) {
					$query->select(['id', 'type', 'extends', 'diy_form_id', 'longitude', 'latitude', 'address'])
						->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');
					});
				}
			])
			->where(function ($query) {
				$query->whereHas('product', function ($query) {
					return $query->where([['stock', '>', 0], ['status', '=', ProductStatus::ON_SALE]]);
				})->orWhere('product_id', 0);
			})
			->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);

			unset($agent_product->spec, $agent_product->product->longitude, $agent_product->product->latitude, $agent_product->product->address); //unset后才能重新赋值
			$agent_product->spec = $this->spec_format($specs);

			//位置信息
			$agent_product->longitude = $agent_product->product->longitude ?? 0;
			$agent_product->latitude = $agent_product->product->latitude ?? 0;
			$agent_product->address = $agent_product->product->address ?? '';
		}

		//自营产品
		if ($agent_product->product_id == 0) {
			//自营产品规格
			$specs = AgentProductSpec::orderBy('date', 'asc')
				->where([
					['agent_product_id', '=', $agent_product->id],
					['date', '>=', date('Y-m-d')],
				])
				->get(['id', 'name', 'date', 'stock', 'original_price', 'price'])->toArray();
			unset($agent_product->spec); //unset后才能重新赋值
			$agent_product->spec = $this->spec_format($specs);

			//自营产品product
			$product = [
				'product_id' => 0,
				'type' => $agent_product->tpl_type,
				'extends' => $agent_product->extends,
				'diy_form' => $agent_product->diyForm ? [
					'id' => $agent_product->diyForm->id ?? 0,
					'name' => $agent_product->diyForm->name ?? '',
					'fields' => $agent_product->diyForm->fields ?? null,
				] : null,
			];
			unset($agent_product->product, $agent_product->tpl_type, $agent_product->extends, $agent_product->diyForm);
			$agent_product->product = $product;
		}

		unset($agent_product->agent_id, $agent_product->status, $agent_product->deleted_at);
		return $this->success($agent_product);
	}

	private function spec_format(array $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),
			];
		}
		return $result;
	}

	// 猜你喜欢
	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 !str_contains($item, $prefix) ? $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;
	}
}