kailin/app/Http/Controllers/Admin/Product.php

<?php namespace App\Http\Controllers\Admin;

use App\Http\Requests\Admin\Product as Request;
use App\Models\AdminHistory;
use App\Models\Business;
use App\Models\City;
use App\Models\OrdersProduct;
use App\Models\Producer;
use App\Models\Product as Model;
use Illuminate\Support\Carbon;
use App\Models\Product\Spec as ProductSpec;
use App\Models\Product\Type as ProductType;
use App\Models\Product\Attr as ProductAttr;
use App\Models\Product\Skus as ProductSkus;
use App\Models\Product\City as ProductCity;
use App\Models\ProductPhoto;
use Illuminate\Support\Facades\DB;
use App\Models\WeiBan\Tags as WeiBanTags;
use Intervention\Image\Facades\Image;
use Intervention\Image\Gd\Font;
use App\Facades\Servers\WechatMini\Mini;

/**
 * 产品管理
 *
 * @author    刘相欣
 *
 */
class Product extends Auth{
	
	protected function _initialize(){
		parent::_initialize();
		$this->assign('breadcrumb1','基础信息');
		$this->assign('breadcrumb2','产品管理');
	}
	
	/**
	 * 首页列表
	 * 
	 * */
    public function index(Model $Model,City $City,ProductCity $ProductCity,OrdersProduct $OrdersProduct,AdminHistory $AdminHistory,Business $Business){
		// 接受参数
		$code					= request('product_code','');
		$name					= request('name','');
		$status					= request('status');
		$startTime				= request('start_time','');
		$businessId				= request('business_id','');
		$cityIds				= request('city_ids',[]);
		// 编码转ID
		$id						= $code ? $Model->codeToId($code) : 0;
		// 查询条件
		$map 					= [];
		// 是否有城市
		$whereIn				= $cityIds ? $cityIds : [];
		// 编码ID
		if( $id )				$map[] = ['product.id','=',$id];
		if( $businessId )		$map[] = ['product.business_id','=',$businessId];
		if( $name )				$map[] = ['product.name','like','%'.$name.'%'];
		if( $startTime )		$map[] = ['product.insert_time','>=',Carbon::createFromFormat('Y-m-d',$startTime)->startOfDay()->getTimestamp()];
		if( $startTime )		$map[] = ['product.insert_time','<=',Carbon::createFromFormat('Y-m-d',$startTime)->endOfDay()->getTimestamp()];
		if( !is_null($status) )	$map[] = ['product.status','=',$status];
        $session                = session('userRule');
        if ($session){
            $map[] = ['product.company_id','=',$session['company_id']];
            if ($session['business_id']){
                $map[] = ['product.business_id','=',$session['business_id']];
            }
            if ($session['menu_type'] == 1 && $session['data_type'] == 2){
                $shopIds       =  Business::query()->where('leader_uid',$session['admin_uid'])->pluck('id')->toArray();
            }
        }
		// 查询数据
		$list					= $Model->query();
		if( $whereIn )			$list = $list->join('product_city','product_city.product_id','=','product.id')->whereIn('product_city.city_id',$whereIn);
        if(isset($shopIds))		$list = $list->whereIn('product.business_id',$shopIds);
        $list 					= $list->groupBy('product.id')
								->where($map)
								->orderBy('product.sort')
								->orderByDesc('product.id')
								->select(['product.*'])
								->paginate(request('limit',config('page_num',10)))->appends(request()->all());
		// 统计销量
		$salesList				= $OrdersProduct->query()->where([['status','<>',4]])->whereIn('product_id',array_column($list->items(),'id'))->groupBy('product_id')->select([DB::raw('sum(`buy_num`) as sales_total'),'product_id'])->pluck('sales_total','product_id')->toArray();
		// 循环处理数据
		foreach ($list as $key => $value) {
			// 判断总库存
			if( !$value['stock_total'] )	{
				// 以首次添加时的为准
				$value['stock_total']= (int) $AdminHistory->query()->where([['table_name','=','product'],['primary_id','=',$value['id']],['notes_type','=',1],['column_name','=','stock']])->orderBy('update_time')->value('after_value');
				// 修改库存
				$Model->edit($value['id'],['stock_total'=>$value['stock_total']]);
			}
			// id转编号
			$value['product_code']	= $Model->idToCode($value['id']);
            $value['business_name']= Business::query()->where('id',$value['business_id'])->value('name');
			// id转编号
			$cityName				= [];
			// 获取城市列表
			$cityIds				= $ProductCity->query()->where([['product_id','=',$value['id']]])->pluck('city_id');
			// 如果有的话
			if( $cityIds )			{
				// 返回结果
				foreach ($cityIds as $cityId) {
					// 城市ID
					if( $cityId == 1 ) continue;
					// 获取城市名
					$cityName[] = $City->getOne($cityId,'name');
				}
			}
			// 销量统计
			$value['sales_total']	= isset($salesList[$value['id']])?$salesList[$value['id']]:0;
			// 城市
			$value['city_name']		= implode('、',$cityName);
			// 重组
			$list[$key]			  	= $value;
		}
		// 获取列表
		$cityList					= $City->getCityList();
        $businessList 			    = $Business->getList();
		// 分配数据
		$this->assign('empty', '<tr><td colspan="20">~~暂无数据</td></tr>');
		$this->assign('cityList',$cityList);
		$this->assign('businessList',$businessList);
		$this->assign('list', $list);
		// 加载模板
		return $this->fetch();
    }

	/**
	 * 获取小程序海报
	 * 
	 */
	public function get_poster(Model $Model){
		// 接收参数
		$id								= request('id',0);
		// // 查询用户
		$oldData						= $Model->where(['id'=>$id])->first();
		// // 错误告知
		if( !$oldData )					return $this->error('查无数据');
		// url有效期
		$urlLink						= '';//$this->getUrlLink($id);
		// 获取分享海报图片
		$result 						= $this->getShareImage('id='.$id,$oldData);
		// 错误提示
		if( isset($result['error']) )	return $this->error($result['error']);
		// 分配数据
		$this->assign('image',$result);
		$this->assign('urlLink',$urlLink);
		$this->assign('oldData',$oldData);
		$this->assign('crumbs','海报');
		// 加载模板
		return 							$this->fetch();
	}

	/**
	 * 获取小程序链接
	 * 
	 */
	private function getUrlLink($id){
		// 结果数据
        $link                  = cache('admin:product:urllink:product_id'.$id);
        // 不存在数据
        if ( is_null($link) ) {
            // 从数据库获取数据
            $link              = Mini::getUrlLink('pages/product/index','product_id='.$id);
            // 存起来
            cache(['admin:product:urllink:product_id'.$id=>$link],$link ? now()->addDays(23) : now()->addMinutes(3));
        }
        // 返回结果
        return                  $link;
	}

	/**
	 * 获取分享海报图片
	 * @param  int $scene  场景值
	 * 
	 */
	private function getShareImage($scene,$oldData){
		// 尝试执行
		try {
			// 加载图片
			$image							= Image::make(public_path('uploads/images/poster/').'product.png');
			// 产品缩略图
			$thumb							= Image::make(path_compat($oldData['thumb']))->resize(1000,1000);
			// 设置文字样式（字体、大小、颜色等）
			$fontPath						= public_path().'/fonts/msyh14.ttf';// 指定字体文件路径
			// 生成小程序二维码
			$qrcode							= Mini::getUnlimit($scene,['page'=>'pages/product/index','width'=>280,'is_hyaline'=>true]);
			// 错误提示
			if( isset($qrcode['error']) )	return $qrcode;
			// 加载图片
			$qrcode							= Image::make($qrcode)->resize(250,250);
			// 插入图片
			$image->insert($thumb,'top-center',0,130);
			// 插入图片
			$image->insert($qrcode,'bottom-left',120,120);
			// 给图片写入文字
			$image->text('￥'.$oldData['price'], 360,1280,function (Font $font) use ($fontPath) {
				$font->file($fontPath);		// 字体文件地址
				$font->size(88);			// 字体大小
				$font->color('#333333');
				$font->align('left');
			});
			// 给图片写入文字
			$image->text($oldData['name'], 120,1380,function (Font $font) use ($fontPath) {
				$font->file($fontPath);		// 字体文件地址
				$font->size(48);			// 字体大小
				$font->color('#333333');
				$font->align('left');
			});
			// 转码成字符串
			$image							= $image->encode('jpg', 90)->__toString();
			// 转base64
			$base64							= 'data:image/jpg;base64,' . base64_encode($image);
			// 返回结果
			return							$base64;
		} catch (\Throwable $th) {
			// 错误提示
			return 							['error'=>$th->getMessage()];
		}
	}

	/**
	 * 添加
	 * 
	 * */
	public function add(Request $request, Model $Model, WeiBanTags $WeiBanTags, ProductPhoto $ProductPhoto, Producer $Producer, Business $Business, ProductType $ProductType, ProductSpec $ProductSpec, ProductAttr $ProductAttr, ProductSkus $ProductSkus, City $City, ProductCity $ProductCity){
		if( request()->isMethod('post') ){
			// 验证参数
			$request->scene('add')->validate();
			// 组合数据
			$data['name']			= request('name','');
			$data['thumb']			= request('thumb','');
			$data['poster']			= request('poster','');
			$data['spec']			= request('spec','');
			$data['price']			= request('price',0);
			$data['market_price']	= request('market_price',0);
			$data['producer_id']	= request('producer_id',0);
			$data['business_id']	= request('business_id',0);
			$data['quota']			= request('quota',0);
			$data['min_quota']		= request('min_quota',0);
			$data['quota_start']	= request('quota_start','');
			$data['quota_end']		= request('quota_end','');
			$data['puton_time']		= request('puton_time','');
			$data['putoff_time']	= request('putoff_time','');
			$data['stock']			= request('stock',0);
			$data['status']			= 1;
			$data['admin_uid']		= admin('uid');
			$description			= request('description','');
			$attr					= request('attr',[]);
			$skuList				= request('sku',[]);
			$cityIds				= request('city_ids',[]);
			$photoList				= request('photo_list',[]);
			$tagScope				= request('tag_scope',[]);
			$data['tag_scope']		= implode(',',$tagScope);
			$tagExclude				= request('tag_exclude',[]);
			$data['tag_exclude']	= implode(',',$tagExclude);
            $session                = session('userRule');
            if ($session){
                $data['company_id']	        = $session['company_id'];
            }
			// 循环
			foreach ($photoList as $key => $value) {
				if( !$value )		unset($photoList[$key]);
			}
			$photoList				= array_values($photoList);
			// 如果没有选择，则意味着全部
			$cityIds				= $cityIds ? $cityIds : [1];
			$data['quota_start']	= $data['quota_start'] ? strtotime($data['quota_start']) : 0;
			$data['quota_end']		= $data['quota_end'] ? strtotime($data['quota_end']) : 0;
			$data['puton_time']		= $data['puton_time'] ? strtotime($data['puton_time']) : 0;
			$data['putoff_time']	= $data['putoff_time'] ? strtotime($data['putoff_time']) : 0;
			// 限购提示
			if( !$data['thumb'] ) 	return json_send(['code'=>'error','msg'=>'请上传产品主图','data'=>['error'=>'请上传产品主图']]);
			// 限购提示
			if( $attr && !$skuList ) return json_send(['code'=>'error','msg'=>'规格属性存在时，请填写SKU','data'=>['error'=>'规格属性存在时，请填写SKU']]);
			// 限购提示
			if( $data['quota'] && ( !$data['quota_start'] || !$data['quota_end'] )) 	return json_send(['code'=>'error','msg'=>'限购必填限购时间','data'=>['error'=>'限购必填限购时间']]);
			// 限购提示
			if( $data['min_quota'] > $data['quota'] ) 	return json_send(['code'=>'error','msg'=>'起购数量请勿大于限购数量','data'=>['error'=>'起购数量请勿大于限购数量']]);
			// SKU存在的时候，判断限购数量
			if( $skuList )			{
				// 循环处理
				foreach ($skuList as $attrNames => $value) {
					// SKU限购，所以限购时间也必须填
					if( $value['quota'] && ( !$data['quota_start'] || !$data['quota_end'] )) return json_send(['code'=>'error','msg'=>'SKU限购时，请填限购时间','data'=>['error'=>'SKU限购时，请填限购时间']]);
					// 限购提示
					if( $value['min_quota'] > $value['quota'] ) 	return json_send(['code'=>'error','msg'=>$attrNames.'起购数量请勿大于限购数量','data'=>['error'=>$attrNames.'起购数量请勿大于限购数量']]);
					// 提示起购数量异常,如果总起购数量小于SKU起购数量，提示
					if( $value['min_quota'] && $value['min_quota'] < $data['min_quota'] ) return json_send(['code'=>'error','msg'=>'SKU的起购数量不能小于总起购数量','data'=>['error'=>'SKU的起购数量不能小于总起购数量']]);
				}
				// 限购数量
				$quota 				= array_sum(array_column($skuList,'quota'));
				// 提示限购数量异常
				if( $data['quota']&& $data['quota'] < $quota ) 	return json_send(['code'=>'error','msg'=>'总限购数量不能小于SKU的限购数量','data'=>['error'=>'总限购数量不能小于SKU的限购数量']]);
			}
			// 上下架
			if( $data['puton_time'] ) 	{
				// 下架时间必填
				if( !$data['putoff_time'] )	return json_send(['code'=>'error','msg'=>'请填写自动下架时间','data'=>['error'=>'自动上架请填写下架时间']]);
				// 下架时间必填
				if( $data['putoff_time'] <= $data['puton_time'] ) return json_send(['code'=>'error','msg'=>'下架时间请晚于上架时间','data'=>['error'=>'下架时间请晚于上架时间']]);
			}
			// 总库存
			if( $skuList )			$data['stock'] = array_sum(array_column($skuList,'stock'));
			// 总库存
			$data['stock_total']	= $data['stock'];
			// 获取规格属性
			$specAttr				= $this->getSpecAttr($attr,$ProductSpec,true);
			// 开启事务
			DB::beginTransaction();
			try {
				// 写入
				$id						= $Model->add($data);
				// 提示新增失败
				if( !$id )				{
					// 回滚
					DB::rollBack();
					// 提示
					return 				json_send(['code'=>'error','msg'=>'新增失败']);
				}
				// 组合数据
				foreach ($specAttr as $key => $value) {
					// 查询结果
					$value['id']		= $ProductAttr->upsertByName($value,$id);
					// 提示新增失败
					if( !$value['id'] )	{
						// 回滚
						DB::rollBack();
						// 提示
						return 			json_send(['code'=>'error','msg'=>'商品属性新增失败']);
					}
					// 重组
					$specAttr[$key]		= $value;
				}
				// 图册
				foreach ($photoList as $key => $value) {
					// 整理数据
					$value				= ['sort'=>$key,'thumb'=>$value,'product_id'=>$id,'insert_time'=>time(),'update_time'=>time()];
					// 重新整理
					$photoList[$key]	= $value;
				}
				// 存在图册
				if( $photoList )		{
					// 写入失败
					$result 			= $ProductPhoto->query()->insert($photoList);
					// 提示新增失败
					if( !$result )		{
						// 回滚
						DB::rollBack();
						// 提示
						return 			json_send(['code'=>'error','msg'=>'商品图册写入失败']);
					}
				}
				// 循环SKU
				foreach ($skuList as $attrNames => $value) {
					// 属性ID值
					$value['attr_ids']	= [];
					// 规格属性值组合
					$value['attr_names']= $attrNames;
					// 切割成数据
					$names				= explode(',',$attrNames);
					// 循环处理
					foreach ($names as $name) {
						foreach ($specAttr as $vv) {
							if( $name == $vv['name'] )  {
								// 提示新增失败
								if( !$vv['id'] )	{
									// 回滚
									DB::rollBack();
									// 提示
									return 			json_send(['code'=>'error','msg'=>'属性SKU匹配失败']);
								}
								$value['attr_ids'][] = $vv['id'];
							}
						}
					}
					// 转成好存储的数据
					$value['attr_ids']	 = implode(',',$value['attr_ids']);
					// 转成好存储的数据
					$value['product_id'] = $id;
					// 转成好存储的数据
					$value['sku_thumb']  = (string)$value['sku_thumb'];
					// 转成好存储的数据
					$value['stock_total']= $value['stock'];
					// 转成好存储的数据
					$value['insert_time']= time();
					// 转成好存储的数据
					$value['update_time']= time();
					// SKU结果
					$skuList[$attrNames] = $value;
				}
				// 循环城市范围
				foreach ($cityIds as $key => $value) {
					// 重组数据
					$cityIds[$key]		= ['city_id'=>$value,'product_id'=>$id,'insert_time'=>time(),'update_time'=>time()];
				}
				// 写入城市范围
				$ProductCity->query()->insert($cityIds);
				// 返回结果
				$result 				= $ProductSkus->insert($skuList);
				// 提示新增失败
				if( !$result )			{
					// 回滚
					DB::rollBack();
					// 提示
					return 				json_send(['code'=>'error','msg'=>'SKU插入失败']);
				}
				// 更新内容
				$Model->updateDesc($id,$description);
				// 提交
				DB::commit();
				// 记录行为
				$this->addAdminHistory(admin('uid'),$Model->getTable(),$id,1,[],$data);
				// 告知结果
				return					json_send(['code'=>'success','msg'=>'新增成功','action'=>'add']);
			} catch (\Throwable $th) {
				// 回滚
				DB::rollBack();
				// 提示
				return 				json_send(['code'=>'error','msg'=>'系统异常,写入失败','data'=>$th->getMessage()]);
			}
		}
		// 获取类型数据
		$typeList				= $ProductType->getList();
		$cityList				= $City->getCityList();
		$businessList 			= $Business->getList();
		$producerList			= $Producer->getList();
		// 标签列表
		$tagData				= $WeiBanTags->query()->groupBy('group')->groupBy('name')->get(['group','name'])->toArray();
		// 标签列表
		$tagList				= [];
		// 循环数据
		foreach ($tagData as $value) {
			$tagList[$value['group']][] = $value['name'];
		}
		// 分配数据
		$this->assign('crumbs','新增');
		$this->assign('tagList',$tagList);
		$this->assign('typeList',$typeList);
		$this->assign('cityList',$cityList);
		$this->assign('businessList',$businessList);
		$this->assign('producerList',$producerList);
		// 加载模板
		return 					$this->fetch();
	}
	
	/**
	 * 编辑
	 * 
	 * */
	public function edit(Request $request, Model $Model, WeiBanTags $WeiBanTags, ProductPhoto $ProductPhoto, Producer $Producer, Business $Business, ProductType $ProductType, ProductSpec $ProductSpec, ProductAttr $ProductAttr, ProductSkus $ProductSkus, City $City, ProductCity $ProductCity){
		if(request()->isMethod('post')){
			// 验证参数
			$request->scene('edit')->validate();
			// 组合数据
			$id						= request('id',0);
			$data['name']			= request('name','');
			$data['thumb']			= request('thumb','');
			$data['poster']			= request('poster','');
			$data['spec']			= request('spec','');
			$data['price']			= request('price',0);
			$data['market_price']	= request('market_price',0);
			$data['quota']			= request('quota',0);
			$data['min_quota']		= request('min_quota',0);
			$data['quota_start']	= request('quota_start','');
			$data['quota_end']		= request('quota_end','');
			$data['puton_time']		= request('puton_time','');
			$data['putoff_time']	= request('putoff_time','');
			$data['producer_id']	= request('producer_id',0);
			$data['business_id']	= request('business_id',0);
			$data['stock']			= request('stock',0);
			$data['status']			= 1;
			$description			= request('description','');
			$attr					= request('attr',[]);
			$skuList				= request('sku',[]);
			$cityIds				= request('city_ids',[]);
			$photoList				= request('photo_list',[]);
			$tagScope				= request('tag_scope',[]);
			$data['tag_scope']		= implode(',',$tagScope);
			$tagExclude				= request('tag_exclude',[]);
			$data['tag_exclude']	= implode(',',$tagExclude);
			// 循环
			foreach ($photoList as $key => $value) {
				if( !$value )		unset($photoList[$key]);
			}
			$photoList				= array_values($photoList);
			// 如果没有选择，则意味着全部
			$cityIds				= $cityIds ? $cityIds : [1];
			$data['quota_start']	= $data['quota_start'] ? strtotime($data['quota_start']) : 0;
			$data['quota_end']		= $data['quota_end'] ? strtotime($data['quota_end']) : 0;
			$data['puton_time']		= $data['puton_time'] ? strtotime($data['puton_time']) : 0;
			$data['putoff_time']	= $data['putoff_time'] ? strtotime($data['putoff_time']) : 0;
			// 限购提示
			if( !$data['thumb'] ) 	return json_send(['code'=>'error','msg'=>'请上传产品主图','data'=>['error'=>'请上传产品主图']]);
			// 限购提示
			if( $attr && !$skuList ) return json_send(['code'=>'error','msg'=>'规格属性存在时，请填写SKU','data'=>['error'=>'规格属性存在时，请填写SKU']]);
			// 限购提示
			if( $data['quota'] && ( !$data['quota_start'] || !$data['quota_end'] )) 	return json_send(['code'=>'error','msg'=>'限购必填限购时间','data'=>['error'=>'限购必填限购时间']]);
			// 限购提示
			if( $data['min_quota'] > $data['quota'] ) 	return json_send(['code'=>'error','msg'=>'起购数量请勿大于限购数量','data'=>['error'=>'起购数量请勿大于限购数量']]);
			// SKU存在的时候，判断限购数量
			if( $skuList )			{
				// 循环处理
				foreach ($skuList as $attrNames => $value) {
					// SKU限购，所以限购时间也必须填
					if( $value['quota'] && ( !$data['quota_start'] || !$data['quota_end'] )) 	return json_send(['code'=>'error','msg'=>'SKU限购时，请填限购时间','data'=>['error'=>'SKU限购时，请填限购时间']]);
					// 限购提示
					if( $value['min_quota'] > $value['quota'] ) 	return json_send(['code'=>'error','msg'=>$attrNames.'起购数量请勿大于限购数量','data'=>['error'=>$attrNames.'起购数量请勿大于限购数量']]);
					// 提示起购数量异常,如果总起购数量小于SKU起购数量，提示
					if( $value['min_quota'] && $value['min_quota'] < $data['min_quota'] ) 	return json_send(['code'=>'error','msg'=>'SKU的起购数量不能小于总起购数量','data'=>['error'=>'SKU的起购数量不能小于总起购数量']]);
				}
				// 限购数量
				$quota 				= array_sum(array_column($skuList,'quota'));
				// 提示限购数量异常
				if( $data['quota']&& $data['quota'] < $quota ) 	return json_send(['code'=>'error','msg'=>'总限购数量不能小于SKU的限购数量','data'=>['error'=>'总限购数量不能小于SKU的限购数量']]);
			}
			// 上下架
			if( $data['puton_time'] ) 	{
				// 下架时间必填
				if( !$data['putoff_time'] )	return json_send(['code'=>'error','msg'=>'请填写自动下架时间','data'=>['error'=>'自动上架请填写下架时间']]);
				// 下架时间必填
				if( $data['putoff_time'] <= $data['puton_time'] ) return json_send(['code'=>'error','msg'=>'下架时间请晚于上架时间','data'=>['error'=>'下架时间请晚于上架时间']]);
			}
			// 总库存
			if( $skuList )			$data['stock'] = array_sum(array_column($skuList,'stock'));
			// 总库存
			$data['stock_total']	= $data['stock'];
			// 获取规格属性
			$specAttr				= $this->getSpecAttr($attr,$ProductSpec,true);
			// 开启事务
			DB::beginTransaction();
			try {
				// 写入
				$result					= $Model->edit($id,$data);
				// 提示新增失败
				if( !$result )			{
					// 回滚
					DB::rollBack();
					// 提示
					return 				json_send(['code'=>'error','msg'=>'修改失败']);
				}
				// 获取旧图册
				$oldPhoto				= $ProductPhoto->getListByProductId($id);
				// 循环个数
				for ($i=0; $i < 4; $i++) { 
					// 如果存在旧数据与新数据，修改
					if( isset($oldPhoto[$i]) && isset($photoList[$i]) )  $ProductPhoto->query()->where([['product_id','=',$id],['sort','=',$i]])->update(['thumb'=>(string)$photoList[$i],'update_time'=>time()]);
					// 如果存在旧数据，不存在新数据，删除
					if( isset($oldPhoto[$i]) && !isset($photoList[$i]) ) $ProductPhoto->query()->where([['product_id','=',$id],['sort','=',$i]])->delete();
					// 如果不存在旧数据，存在新数据，新增
					if( !isset($oldPhoto[$i]) && isset($photoList[$i]) ) $ProductPhoto->add(['sort'=>$i,'product_id'=>$id,'thumb'=>(string)$photoList[$i],'insert_time'=>time(),'update_time'=>time()]);
				}
				// 组合数据
				foreach ($specAttr as $key => $value) {
					// 查询结果
					$value['id']		= $ProductAttr->upsertByName($value,$id);
					// 提示新增失败
					if( !$value['id'] )	{
						// 回滚
						DB::rollBack();
						// 提示
						return 			json_send(['code'=>'error','msg'=>'商品属性新增失败']);
					}
					// 重组
					$specAttr[$key]		= $value;
				}
				// 如果不在这个属性列表中的数据删除
				$ProductAttr->query()->where([['product_id','=',$id]])->whereNotIn('id',array_column($specAttr,'id'))->delete();
				// 循环SKU
				foreach ($skuList as $attrNames => $value) {
					// 属性ID值
					$value['attr_ids']	= [];
					// 规格属性值组合
					$value['attr_names']= $attrNames;
					// 切割成数据
					$names				= explode(',',$attrNames);
					// 循环处理
					foreach ($names as $name) {
						foreach ($specAttr as $vv) {
							if( $name == $vv['name'] )  {
								// 提示新增失败
								if( !$vv['id'] )	{
									// 回滚
									DB::rollBack();
									// 提示
									return 			json_send(['code'=>'error','msg'=>'属性SKU匹配失败']);
								}
								$value['attr_ids'][] = $vv['id'];
							}
						}
					}
					// 转成好存储的数据
					$value['attr_ids']	= implode(',',$value['attr_ids']);
					// 转成好存储的数据
					$value['sku_thumb']  = (string)$value['sku_thumb'];
					// 转成好存储的数据
					$value['stock_total']= $value['stock'];
					// 转成好存储的数据
					$value['product_id']= $id;
					// 查询
					$oldSkuId			= $ProductSkus->query()->where([['product_id','=',$id],['attr_ids','=',$value['attr_ids']]])->value('id');
					// 判断是否存在ID
					$value['id']		= $oldSkuId ? $ProductSkus->edit($oldSkuId,$value) : $ProductSkus->add($value);
					// SKU结果
					$skuList[$attrNames]= $value;
				}
				// 如果不在这个属性列表中的数据删除
				$ProductSkus->query()->where([['product_id','=',$id]])->whereNotIn('id',array_column($skuList,'id'))->delete();
				// 获取之前的城市ID
				$oldCityIds				= $ProductCity->getListByProductId($id);
				// 循环城市范围
				foreach ($cityIds as $key => $value) {
					// 不存在则新增
					if( !in_array($value,$oldCityIds) ) $ProductCity->add(['city_id'=>$value,'product_id'=>$id]);
				}
				// 不存在的城市删除
				$ProductCity->query()->where([['product_id','=',$id]])->whereNotIn('city_id',$cityIds)->delete();
				// 更新内容
				$Model->updateDesc($id,$description);
				// 提交
				DB::commit();
				// 记录行为
				$this->addAdminHistory(admin('uid'),$Model->getTable(),$id,2,[],$data);
				// 告知结果
				return					json_send(['code'=>'success','msg'=>'修改成功','action'=>'edit']);
			} catch (\Throwable $th) {
				// 回滚
				DB::rollBack();
				// 提示
				return 				json_send(['code'=>'error','msg'=>'系统异常,写入失败','data'=>$th->getMessage() .'=>'.$th->getLine()]);
			}	
		}
		// 接收参数
		$id							= request('id',0);
		// 查询数据
		$oldData					= $Model->where(['id'=>$id])->first();
		// 如果是没有数据
		if( !$oldData ) 			return $this->error('查无数据');
		// 产品信息转格式
		$oldData					= $oldData->toArray();
		$oldData['description']		= $Model->getDesc($id);
		$oldData['city_ids']		= $ProductCity->getListByProductId($id);
		$oldData['tag_scope']		= explode(',',$oldData['tag_scope']);
		$oldData['tag_exclude']		= explode(',',$oldData['tag_exclude']);
		$photoList					= $ProductPhoto->getListByProductId($id);
		// 获取产品属性
		$attrList					= $ProductAttr->getListByProductId($id);
		// 规格属性
		$specList					= [];
		// 获取数据
		foreach ($attrList as $value) {
			$value['active']		= 0;
			if( !isset($specList[$value['spec_id']]) ) $specList[$value['spec_id']]		= $ProductSpec->getOne($value['spec_id']);
			$specList[$value['spec_id']]['attr_list'][]	= $value;
		}
		// 产品类型
		$skuList					= $ProductSkus->getListByProductId($id);
		// 循环处理
		foreach ($skuList as $key => $value) {
			// 数据解析
			$value['attr_ids']		= explode(',',$value['attr_ids']);
			// 循环处理
			foreach ( $value['attr_ids'] as $k=>$attrId ) {
				// 获取ids对应的name
				$value['attr_ids'][$k] = $ProductAttr->getValueById($attrId,'name');
			}
			// 数据合并
			$value['attr_ids']		= implode(',',$value['attr_ids']);
			// 重组
			$skuList[$key]			= $value;
		}
		// 获取类型数据
		$typeList				= $ProductType->getList();
		$cityList				= $City->getCityList();
		$businessList 			= $Business->getList();
		$producerList			= $Producer->getList();
		// 标签列表
		$tagData					= $WeiBanTags->query()->groupBy('group')->groupBy('name')->get(['group','name'])->toArray();
		// 标签列表
		$tagList					= [];
		// 循环数据
		foreach ($tagData as $value) {
			$tagList[$value['group']][] = $value['name'];
		}
		// 分配数据
		$this->assign('tagList',$tagList);
		$this->assign('typeList',$typeList);
		$this->assign('cityList',$cityList);
		$this->assign('businessList',$businessList);
		$this->assign('producerList',$producerList);
		$this->assign('oldData',$oldData);
		$this->assign('photoList',$photoList);
		$this->assign('skuList',$skuList);
		$this->assign('specList',$specList);
		$this->assign('crumbs','修改');
		// 加载模板
		return 						$this->fetch();
	}


	/**
	 * 编辑
	 * 
	 * */
	public function copy(Request $request, Model $Model, WeiBanTags $WeiBanTags, ProductPhoto $ProductPhoto, Producer $Producer, Business $Business, ProductType $ProductType, ProductSpec $ProductSpec, ProductAttr $ProductAttr, ProductSkus $ProductSkus, City $City, ProductCity $ProductCity){
		if( request()->isMethod('post') ){
			// 验证参数
			$request->scene('add')->validate();
			// 组合数据
			$data['name']			= request('name','');
			$data['thumb']			= request('thumb','');
			$data['poster']			= request('poster','');
			$data['spec']			= request('spec','');
			$data['price']			= request('price',0);
			$data['market_price']	= request('market_price',0);
			$data['producer_id']	= request('producer_id',0);
			$data['business_id']	= request('business_id',0);
			$data['quota']			= request('quota',0);
			$data['min_quota']		= request('min_quota',0);
			$data['quota_start']	= request('quota_start','');
			$data['quota_end']		= request('quota_end','');
			$data['stock']			= request('stock',0);
			$data['status']			= 1;
			$data['admin_uid']		= admin('uid');
			$description			= request('description','');
			$attr					= request('attr',[]);
			$skuList				= request('sku',[]);
			$cityIds				= request('city_ids',[]);
			$photoList				= request('photo_list',[]);
			$tagScope				= request('tag_scope',[]);
			$data['tag_scope']		= implode(',',$tagScope);
			$tagExclude				= request('tag_exclude',[]);
			$data['tag_exclude']	= implode(',',$tagExclude);
			// 循环
			foreach ($photoList as $key => $value) {
				if( !$value )		unset($photoList[$key]);
			}
			$photoList				= array_values($photoList);
			// 如果没有选择，则意味着全部
			$cityIds				= $cityIds ? $cityIds : [1];
			$data['quota_start']	= $data['quota_start'] ? strtotime($data['quota_start']) : 0;
			$data['quota_end']		= $data['quota_end'] ? strtotime($data['quota_end']) : 0;
			// 限购提示
			if( !$data['thumb'] ) 	return json_send(['code'=>'error','msg'=>'请上传产品主图','data'=>['error'=>'请上传产品主图']]);
			// 限购提示
			if( $attr && !$skuList ) return json_send(['code'=>'error','msg'=>'规格属性存在时，请填写SKU','data'=>['error'=>'规格属性存在时，请填写SKU']]);
			// 限购提示
			if( $data['quota'] && ( !$data['quota_start'] || !$data['quota_end'] )) 	return json_send(['code'=>'error','msg'=>'限购必填限购时间','data'=>['error'=>'限购必填限购时间']]);
			// 限购提示
			if( $data['min_quota'] > $data['quota'] ) 	return json_send(['code'=>'error','msg'=>'起购数量请勿大于限购数量','data'=>['error'=>'起购数量请勿大于限购数量']]);
			// 总库存
			if( $skuList )			$data['stock'] = array_sum(array_column($skuList,'stock'));
			// SKU存在的时候，判断限购数量
			if( $skuList )			{
				// 循环处理
				foreach ($skuList as $attrNames => $value) {
					// SKU限购，所以限购时间也必须填
					if( $value['quota'] && ( !$data['quota_start'] || !$data['quota_end'] )) 	return json_send(['code'=>'error','msg'=>'SKU限购时，请填限购时间','data'=>['error'=>'SKU限购时，请填限购时间']]);
					// 限购提示
					if( $value['min_quota'] > $value['quota'] ) 	return json_send(['code'=>'error','msg'=>$attrNames.'起购数量请勿大于限购数量','data'=>['error'=>$attrNames.'起购数量请勿大于限购数量']]);
					// 提示起购数量异常,如果总起购数量小于SKU起购数量，提示
					if( $value['min_quota'] && $value['min_quota'] < $data['min_quota'] ) 	return json_send(['code'=>'error','msg'=>'SKU的起购数量不能小于总起购数量','data'=>['error'=>'SKU的起购数量不能小于总起购数量']]);
				}
				// 限购数量
				$quota 				= array_sum(array_column($skuList,'quota'));
				// 提示限购数量异常
				if( $data['quota'] && $data['quota'] < $quota ) 	return json_send(['code'=>'error','msg'=>'总限购数量不能小于SKU的限购数量','data'=>['error'=>'总限购数量不能小于SKU的限购数量']]);
			}
			// 总库存
			$data['stock_total']	= $data['stock'];
			// 获取规格属性
			$specAttr				= $this->getSpecAttr($attr,$ProductSpec,true);
			// 开启事务
			DB::beginTransaction();
			try {
				// 写入
				$id						= $Model->add($data);
				// 提示新增失败
				if( !$id )				{
					// 回滚
					DB::rollBack();
					// 提示
					return 				json_send(['code'=>'error','msg'=>'新增失败']);
				}
				// 图册
				foreach ($photoList as $key => $value) {
					// 整理数据
					$value				= ['sort'=>$key,'thumb'=>$value,'product_id'=>$id,'insert_time'=>time(),'update_time'=>time()];
					// 重新整理
					$photoList[$key]	= $value;
				}
				// 存在图册
				if( $photoList )		{
					// 写入失败
					$result 			= $ProductPhoto->query()->insert($photoList);
					// 提示新增失败
					if( !$result )		{
						// 回滚
						DB::rollBack();
						// 提示
						return 			json_send(['code'=>'error','msg'=>'商品图册写入失败']);
					}
				}
				// 组合数据
				foreach ($specAttr as $key => $value) {
					// 查询结果
					$value['id']		= $ProductAttr->upsertByName($value,$id);
					// 提示新增失败
					if( !$value['id'] )	{
						// 回滚
						DB::rollBack();
						// 提示
						return 			json_send(['code'=>'error','msg'=>'商品属性新增失败']);
					}
					// 重组
					$specAttr[$key]		= $value;
				}
				// 循环SKU
				foreach ($skuList as $attrNames => $value) {
					// 属性ID值
					$value['attr_ids']	= [];
					// 规格属性值组合
					$value['attr_names']= $attrNames;
					// 切割成数据
					$names				= explode(',',$attrNames);
					// 循环处理
					foreach ($names as $name) {
						foreach ($specAttr as $vv) {
							if( $name == $vv['name'] )  {
								// 提示新增失败
								if( !$vv['id'] )	{
									// 回滚
									DB::rollBack();
									// 提示
									return 			json_send(['code'=>'error','msg'=>'属性SKU匹配失败']);
								}
								$value['attr_ids'][] = $vv['id'];
							}
						}
					}
					// 转成好存储的数据
					$value['attr_ids']	= implode(',',$value['attr_ids']);
					// 转成好存储的数据
					$value['product_id']= $id;
					// 转成好存储的数据
                    $value['sku_thumb']  = (string) $value['sku_thumb'];
					// 转成好存储的数据
					$value['stock_total']= $value['stock'];
					// 转成好存储的数据
					$value['insert_time']= time();
					// 转成好存储的数据
					$value['update_time']= time();
					// SKU结果
					$skuList[$attrNames] = $value;
				}
				// 循环城市范围
				foreach ($cityIds as $key => $value) {
					// 重组数据
					$cityIds[$key]		= ['city_id'=>$value,'product_id'=>$id,'insert_time'=>time(),'update_time'=>time()];
				}
				// 写入城市范围
				$ProductCity->query()->insert($cityIds);
				// 返回结果
				$result 				= $ProductSkus->insert($skuList);
				// 提示新增失败
				if( !$result )			{
					// 回滚
					DB::rollBack();
					// 提示
					return 				json_send(['code'=>'error','msg'=>'SKU插入失败']);
				}
				// 更新内容
				$Model->updateDesc($id,$description);
				// 提交
				DB::commit();
				// 记录行为
				$this->addAdminHistory(admin('uid'),$Model->getTable(),$id,1,[],$data);
				// 告知结果
				return					json_send(['code'=>'success','msg'=>'新增成功','action'=>'add']);
			} catch (\Throwable $th) {
				// 回滚
				DB::rollBack();
				// 提示
				return 				json_send(['code'=>'error','msg'=>'系统异常,写入失败','data'=>$th->getMessage()]);
			}
		}
		// 接收参数
		$id							= request('id',0);
		// 查询数据
		$oldData					= $Model->where(['id'=>$id])->first();
		// 如果是没有数据
		if( !$oldData ) 			return $this->error('查无数据');
		// 产品信息转格式
		$oldData					= $oldData->toArray();
		$oldData['description']		= $Model->getDesc($id);
		$oldData['city_ids']		= $ProductCity->getListByProductId($id);
		$oldData['tag_scope']		= explode(',',$oldData['tag_scope']);
		$oldData['tag_exclude']		= explode(',',$oldData['tag_exclude']);
		$photoList					= $ProductPhoto->getListByProductId($id);
		// 获取产品属性
		$attrList					= $ProductAttr->getListByProductId($id);
		// 规格属性
		$specList					= [];
		// 获取数据
		foreach ($attrList as $value) {
			$value['active']		= 0;
			if( !isset($specList[$value['spec_id']]) ) $specList[$value['spec_id']]		= $ProductSpec->getOne($value['spec_id']);
			$specList[$value['spec_id']]['attr_list'][]	= $value;
		}
		// 产品类型
		$skuList					= $ProductSkus->getListByProductId($id);
		// 循环处理
		foreach ($skuList as $key => $value) {
			// 数据解析
			$value['attr_ids']		= explode(',',$value['attr_ids']);
			// 循环处理
			foreach ( $value['attr_ids'] as $k=>$attrId ) {
				// 获取ids对应的name
				$value['attr_ids'][$k] = $ProductAttr->getValueById($attrId,'name');
			}
			// 数据合并
			$value['attr_ids']		= implode(',',$value['attr_ids']);
			// 重组
			$skuList[$key]			= $value;
		}
		// 标签列表
		$tagData					= $WeiBanTags->query()->groupBy('group')->groupBy('name')->get(['group','name'])->toArray();
		// 标签列表
		$tagList					= [];
		// 循环数据
		foreach ($tagData as $value) {
			$tagList[$value['group']][] = $value['name'];
		}
		// 获取类型数据
		$typeList				= $ProductType->getList();
		$cityList				= $City->getCityList();
		$businessList 			= $Business->getList();
		$producerList			= $Producer->getList();
		// 分配数据
		$this->assign('tagList',$tagList);
		$this->assign('typeList',$typeList);
		$this->assign('cityList',$cityList);
		$this->assign('businessList',$businessList);
		$this->assign('producerList',$producerList);
		$this->assign('oldData',$oldData);
		$this->assign('photoList',$photoList);
		$this->assign('skuList',$skuList);
		$this->assign('specList',$specList);
		$this->assign('crumbs','复制');
		// 加载模板
		return 						$this->fetch();
	}

	/**
	 * 状态
	 * 
	 * */
	public function set_status( Request $request, Model $Model ){
		// 验证参数
		$request->scene('set_status')->validate();
		// 接收参数
		$id				= request('id',0);
		$status			= request('status',0);
		// 查询数据
		$result			= $Model->edit($id,['status'=>$status]);
		// 提示新增失败
		if( !$result )	return json_send(['code'=>'error','msg'=>'设置失败']);
		// 记录行为
		$this->addAdminHistory(admin('uid'),$Model->getTable(),$id,2,[],['status'=>$status]);
		// 告知结果
		return			json_send(['code'=>'success','msg'=>'设置成功','path'=>'']);
	}


	/**
	 * 获取某个类目下的规格
	 * 
	 */
	public function get_spec_html( ProductSpec $ProductSpec){
		// 接收参数
		$typeId			= request('type_id',0);
		// 查询数据
		$specList		= $ProductSpec->getList();
		// 循环处理
		foreach ($specList as $key => $value) {
			if( $value['type_id'] != $typeId  ) unset($specList[$key]);
		}
		// 分配数据
		$this->assign('specList',$specList);
		// 加载模板
		return 			$this->fetch();
	}

	/**
	 * 获取某个类目下的规格
	 * 
	 */
	public function get_sku_html( ProductSpec $ProductSpec,ProductSkus $ProductSkus){
		// 接收参数
		$attr			= request('attr',[]);
		$id				= request('product_id',0);
		// 产品类型
		$oldSkus		= $id ? $ProductSkus->getListByProductId($id) : [];
		// 获取规格属性
		$specAttr		= $this->getSpecAttr($attr,$ProductSpec);
		// 组合SKU
		$brushList		= [];
		// 循环规格属性
		foreach ($specAttr as $specId => $value) {
			// 获取SKU组合
			$brushList[$specId]	= array_column($value['attr_list'],'name');
		}
		// sku列表
		$skuList 		= $this->brush([],$brushList);
		// 循环规格属性
		foreach ($skuList as $newKey => $new) {
			// 获取新数据
			$new		= ['attr_names'=>$new,'price'=>0,'market_price'=>0,'stock'=>0,'min_quota'=>0,'quota'=>0,'status'=>0,'sku_thumb'=>''];
			// 循环旧的sku
			foreach ($oldSkus as $old) {
				// 如果有相等的规格
				if( $old['attr_names'] == $new['attr_names']) {
					$new['sku_thumb']	= $old['sku_thumb'];
					$new['market_price']= $old['market_price'];
					$new['price']		= $old['price'];
					$new['stock']		= $old['stock'];
					$new['status']		= $old['status'];
					$new['min_quota']	= $old['min_quota'];
					$new['quota']	= $old['quota'];
				}
			}
			$skuList[$newKey]	= $new;
		}
		// 分配数据
		$this->assign('specAttr',$specAttr);
		$this->assign('skuList',$skuList);
		// 加载模板
		return 			$this->fetch();
	}

	/**
	 * 获取规格属性
	 * @param ProductSpec  $ProductSpec
	 * 
	 */
	private function getSpecAttr($attr,$ProductSpec,$onlyList=false){
		// 组合参数
		$specAttr 			= [];
		// 循环处理数据
		foreach ($attr as $specId => $value) {
			$specAttr[$specId]['spec_id']   = $specId;
			$specAttr[$specId]['spec_name'] = $ProductSpec->getOne($specId,'name');
			$specAttr[$specId]['attr_list'] = [];
			foreach ($value['name'] as $key => $name) {
				// 如果没有名称的，跳过
				if( !$name )					continue;
				// 结果
				$temp 							= ['id'=>0,'spec_id'=>$specId,'thumb'=>'','name'=>'','remark'=>''];
				// 获取名称
                $temp['name']                   = str_ireplace(',','',$name);
                // 获取对应的备注信息
				if( !empty($value['remark'][$key]) ) $temp['remark'] = $value['remark'][$key];
				if( !empty($value['thumb'][$key]) ) $temp['thumb'] = $value['thumb'][$key];
				// 获取对应的数据
				$specAttr[$specId]['attr_list'][]= $temp;
			}
			// 没有属性的规格，移除
			if( !$specAttr[$specId]['attr_list'] )   unset($specAttr[$specId]);
		}
		// 仅获取属性列表
		if( $onlyList ) 	{
			// 属性列表
			$attrList							= [];
			// 判断结果
			foreach ($specAttr as $value) 		{
				// 获取数据
				array_push($attrList,...$value['attr_list']);
			}
			// 返回结果
			$specAttr							= $attrList;
		}
		// 返回结果
		return $specAttr;
	}

	/**
	 * 组合SKU
	 * 
	 */
	private function brush($res = [], $arr = []){
		// 获取第一个规格的属性
		if (empty($res)) 		$res = (array) array_shift($arr);
		// 如果只有一个规格，返回该规格的属性即可
		if (empty($arr)) 		return $res;
		// 接下来要参与计算的一组属性
		$current 				= array_shift($arr);
		// 计算的列表
		$last 				    = [];
		// 循环上一次已经算出的集合
		foreach ($res as $attr) {
			foreach ($current as $col_val) {
				$last[] 		= $attr . ',' . $col_val;
			}
		}
		return					$this->brush($last,$arr); # 递归处理, 直到$arr滚到最后一组属性
	}

	/**
	 * 排序
	 * 
	 * */
	public function set_sort( Request $request, Model $Model ){
		// 验证参数
		$request->scene('set_sort')->validate();
		// 接收参数
		$id				= request('id',0);
		$sort			= request('sort',0);
		// 查询数据
		$result			= $Model->edit($id,['sort'=>$sort]);
		// 提示新增失败
		if( !$result )	return json_send(['code'=>'error','msg'=>'设置失败']);
		// 记录行为
		$this->addAdminHistory(admin('uid'),$Model->getTable(),$id,2,[],['sort'=>$sort]);
		// 告知结果
		return			json_send(['code'=>'success','msg'=>'设置成功','path'=>'']);
	}

}