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

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

use App\Http\Requests\Admin\Coupon as Request;
use App\Models\AdminUser;
use App\Models\Coupon as Model;
use App\Models\CouponProduct;
use App\Models\CouponRebate;
use App\Models\Custom;
use App\Models\CustomCoupon;
use App\Models\Product;
use App\Models\FilesManager;
use Illuminate\Support\Facades\DB;

/**
 * 优惠券管理
 *
 * @author    刘相欣
 *
 */
class Coupon extends Auth{
	
	protected function _initialize(){
		parent::_initialize();
		$this->assign('breadcrumb1','营销管理');
		$this->assign('breadcrumb2','优惠券管理');
	}

	/**
	 * 首页列表
	 * 
	 * */
    public function index(Model $Model,AdminUser $AdminUser,CustomCoupon $CustomCoupon){
		// 接受参数
		$code					= request('coupon_code','');
		$status					= request('status');
		$startTime				= request('start_time','');
		$endTime				= request('end_time','');
		// 编码转ID
		$id						= $code ? $Model->codeToId($code) : 0;
		// 查询条件
		$map 					= [];
		// 编码ID
		if( $id )				$map[] = ['id','=',$id];
		if( $startTime )		$map[] = ['start_time','>=',strtotime($startTime)];
		if( $endTime )			$map[] = ['end_time','<=',strtotime($endTime)];
		if( !is_null($status) )	$map[] = ['status','=',$status];
		// 查询数据
		$list					= $Model->query()->where($map)->orderByDesc('id')->paginate(request('limit',config('page_num',10)))->appends(request()->all());
		// 计算各个优惠券的数量
		$customTotal			= $CustomCoupon->whereIn('coupon_id',array_column($list->toArray()['data'],'id'))->groupBy('coupon_id')->select([DB::raw('count(*) as total'),'coupon_id'])->pluck('total','coupon_id')->toArray();
		// 循环处理数据
		foreach ($list as $key => $value) {
			// id转编号
			$value['coupon_code']= $Model->idToCode($value['id']);
			// id转编号
			$value['admin_name'] = $AdminUser->getOne($value['admin_uid'],'username');
			// 过期时间
			$value['exp_time']	 = $Model->getExpTime($value['exp_time']);
			// 如果过期时间
			if( $value['status'] == 0 && ( $value['exp_time']>0 && $value['exp_time']< time() ) ) {
				// 设置过期状态
				$Model->setStatusByExpire();
				// 状态设置
				$value['status'] =3;
			}
			// id转编号
			$value['custom_total'] = isset($customTotal[$value['id']]) ? $customTotal[$value['id']] : 0;
			// 重组
			$list[$key]			= $value;
		}
		// 分配数据
		$this->assign('empty', '<tr><td colspan="20">~~暂无数据</td></tr>');
		$this->assign('list', $list);
		// 加载模板
		return					$this->fetch();
    }

	/**
	 * 添加
	 * 
	 * */
	public function add( Request $request, Model $Model,Product $Product,Custom $Custom,FilesManager $FilesManager,CouponRebate $CouponRebate,CustomCoupon $CustomCoupon,CouponProduct $CouponProduct){
		if( request()->isMethod('post') ){
			// 验证参数
			$request->scene('add')->validate();
			// 组合数据
			$data['name']			= request('name',0);
			$data['rebate_type']	= request('rebate_type',0);
			$data['std_pay']		= request('std_pay',0);
			$data['rebate']			= request('rebate',0);
			$data['issue_total']	= request('issue_total',0);
			$data['start_time']		= request('start_time',date('Y-m-d'));
			$data['end_time'] 		= request('end_time','');
			$data['type_id']		= request('type_id',1);
			$data['is_appt']		= request('is_appt',1);
			// 根据是否上传了商品范围文件
			if( $data['type_id'] == 1 && !request()->hasFile('product_file') )  return json_send(['code'=>'error','msg'=>'请上传指定商品范围']);
			// 根据是否上传了客户范围文件
			if( $data['is_appt'] == 1 && !request()->hasFile('custom_file') )  return json_send(['code'=>'error','msg'=>'请上传指定客户范围']);
			// 转换时间，默认现在现在生效
			$data['start_time']		= $data['start_time'] ? strtotime($data['start_time']) : time();
			// 转换时间，默认无结束时间
			$data['end_time']		= $data['end_time'] ? strtotime($data['end_time'].' 23:59:59') : 0;
			// 判断有效时间类型。获取不同的过期时间
			$data['exp_time'] 		= request('exp_type',0) == 1 ? request('exp_days',0) : $data['end_time'];
			// 赠品ID
			$rebateId				= 0;
			// 如果是赠品表的话。处理赠品逻辑
			if( $data['rebate_type'] == 3 ) {
				// 产品编码
				$rebateId 			= $Product->codeToId($data['rebate']);
				// 赠品ID不存在
				if( !$rebateId )	return json_send(['code'=>'error','msg'=>'赠品编码格式有误']);
				// 设置为0,避免数据异常
				$data['rebate']     = 0;
			}
			// 商品范围
			$products				= [];
			// 如果是商品范围
			if( $data['type_id'] == 1 ) {
				// 读取文件获取指定的商品范围
				$products 			= $FilesManager->excelToCode(request()->file('product_file'),$Product);
				// 产品范围不存在
				if( !$products )	return json_send(['code'=>'error','msg'=>'请上传可用的商品范围']);
				// 去重
				$products			= array_values(array_unique($products));
				// 商品数量
				if( count($products) > 1000 ) return json_send(['code'=>'error','msg'=>'可用的商品范围请勿超过1000']);
			}
			// 客户范围
			$customs				= [];
			// 如果是客户范围
			if( $data['is_appt'] == 1 ) {
				// 读取文件获取指定的客户范围
				$customs 			= $FilesManager->excelToCode(request()->file('custom_file'),$Custom);
				// 客户范围不存在
				if( !$customs )		return json_send(['code'=>'error','msg'=>'请上传可用的客户范围']);
				// 去重
				$customs			= array_values(array_unique($customs));
				// 客户数量
				if( count($customs) > 10000 ) return json_send(['code'=>'error','msg'=>'客户范围请勿超过10000']);
				// 如果超过数量，不允许发放
				if( $data['issue_total'] < count($customs) ) return json_send(['code'=>'error','msg'=>'客户数量请勿超过发行数量']);
			}
			// 组合数据，写入订单表，子表
			DB::beginTransaction();
			try {
				// 写入
				$id					= $Model->add($data);
				// 提示新增失败
				if( !$id )			{
					// 回滚
					DB::rollBack();
					// 提示失败
					return			json_send(['code'=>'error','msg'=>'新增失败']);
				}
				// 当前时间
				$time 				= time();
				// 如果有商品范围
				if( $products )		{
					// 循环商品
					foreach ($products as $key => $value) {
						// 时间处理
						$value		= ['coupon_id'=>$id,'product_id'=>$value,'insert_time'=>$time,'update_time'=>$time];
						// 重组
						$products[$key] = $value;
					}
					// 写入数据
					$result 		= $CouponProduct->insert($products);
					// 提示新增失败
					if( !$result )	{
						// 回滚
						DB::rollBack();
						// 提示失败
						return		json_send(['code'=>'error','msg'=>'商品范围写入失败']);
					}
				}
				// 如果是赠品
				if( $rebateId )		{
					// 写入数据
					$result 		= $CouponRebate->add(['coupon_id'=>$id,'product_id'=>$rebateId,'rebate_num'=>1]);
					// 提示新增失败
					if( !$result )	{
						// 回滚
						DB::rollBack();
						// 提示失败
						return		json_send(['code'=>'error','msg'=>'赠品结果写入失败']);
					}
				}
				// 如果有客户范围
				if( $customs )		{
					// 分块，每1000一批写入
					foreach (array_chunk($customs,1000) as $chunk) {
						// 循环客户
						foreach ($chunk as $key => $value) {
							// 时间处理
							$value		= ['coupon_id'=>$id,'custom_uid'=>$value,'exp_time'=>$Model->getExpTime($data['exp_time']),'insert_time'=>$time,'update_time'=>$time];
							// 重组
							$chunk[$key] = $value;
						}
						// 写入数据
						$result 		= $CustomCoupon->insert($chunk);
						// 提示新增失败
						if( !$result )	{
							// 回滚
							DB::rollBack();
							// 提示失败
							return		json_send(['code'=>'error','msg'=>'客户范围写入失败']);
						}
					}
				}
				// 提交
				DB::commit();
			} catch (\Throwable $th) {
				// 回滚
				DB::rollBack();
				// 提示失败
				return				json_send(['code'=>'error','msg'=>'内部错误，请重试','data'=>['error'=>$th->getMessage()]]);
			}
			// 记录行为
			$this->addAdminHistory(admin('uid'),$Model->getTable(),$id,1,[],$data);
			// 告知结果
			return					json_send(['code'=>'success','msg'=>'新增成功','action'=>'add']);
		}
		// 分配数据
		$this->assign('crumbs','新增');
		// 加载模板
		return 					$this->fetch();
	}
	
	/**
	 * 编辑
	 * 
	 * */
	public function edit( Request $request, Model $Model,Product $Product,Custom $Custom,FilesManager $FilesManager,CouponRebate $CouponRebate,CustomCoupon $CustomCoupon,CouponProduct $CouponProduct){
		// 接收参数
		$id							= request('id',0);
		// 查询数据
		$oldData					= $Model->where(['id'=>$id])->first();
		// 修改
		if(request()->isMethod('post')){
			// 验证参数
			$request->scene('edit')->validate();
			// 组合数据
			$data['name']			= request('name',0);
			$data['rebate_type']	= request('rebate_type',0);
			$data['std_pay']		= request('std_pay',0);
			$data['rebate']			= request('rebate',0);
			$data['issue_total']	= request('issue_total',0);
			$data['start_time']		= request('start_time',date('Y-m-d'));
			$data['end_time'] 		= request('end_time','');
			$data['type_id']		= request('type_id',1);
			$data['is_appt']		= request('is_appt',1);
			// 转换时间，默认现在现在生效
			$data['start_time']		= $data['start_time'] ? strtotime($data['start_time']) : time();
			// 转换时间，默认无结束时间
			$data['end_time']		= $data['end_time'] ? strtotime($data['end_time'].' 23:59:59') : 0;
			// 判断有效时间类型。获取不同的过期时间
			$data['exp_time'] 		= request('exp_type',0) == 1 ? request('exp_days',0) : $data['end_time'];
			// 折扣不能超过10
			if( $data['rebate_type'] == 2 && $data['rebate'] > 9.99 ) return json_send(['code'=>'error','msg'=>'不能设置大于9.99折']);
			// 赠品ID
			$rebateId				= 0;
			// 如果是赠品表的话。处理赠品逻辑
			if( $data['rebate_type'] == 3 ) {
				// 产品编码
				$rebateId 			= $Product->codeToId($data['rebate']);
				// 赠品ID不存在
				if( !$rebateId )	return json_send(['code'=>'error','msg'=>'赠品编码格式有误']);
				// 设置为0,避免数据异常
				$data['rebate']     = 0;
			}
			// 商品范围
			$products				= [];
			// 如果是商品范围，并且上传了文件
			if( $data['type_id'] == 1 && request()->hasFile('product_file')) {
				// 读取文件获取指定的商品范围
				$products 			= $FilesManager->excelToCode(request()->file('product_file'),$Product);
				// 产品范围不存在
				if( !$products )	return json_send(['code'=>'error','msg'=>'请上传可用的商品范围']);
				// 去重
				$products			= array_values(array_unique($products));
				// 商品数量
				if( count($products) > 1000 ) return json_send(['code'=>'error','msg'=>'可用的商品范围请勿超过1000']);
			}
			// 客户范围
			$customs				= [];
			// 如果是客户范围，并且上传了文件
			if( $data['is_appt'] == 1 && request()->hasFile('custom_file') ) {
				// 客户范围不存在
				if( !$customs )		return json_send(['code'=>'error','msg'=>'请上传可用的客户范围']);
				// 去重
				$customs			= array_values(array_unique($customs));
				// 客户数量
				if( count($customs) > 10000 ) return json_send(['code'=>'error','msg'=>'客户范围请勿超过10000']);
				// 如果超过数量，不允许发放
				if( $data['issue_total'] < count($customs) ) return json_send(['code'=>'error','msg'=>'客户数量请勿超过发行数量']);
			}
			// 组合数据，写入订单表，子表
			DB::beginTransaction();
			try {
				// 写入
				$result				= $Model->edit($id,$data);
				// 提示新增失败
				if( !$result )		{
					// 回滚
					DB::rollBack();
					// 提示失败
					return			json_send(['code'=>'error','msg'=>'新增失败']);
				}
				// 如果是赠品券
				if( $rebateId )		{
					// 查询旧的
					$oldRebateId 		= $CouponRebate->query()->where([['coupon_id','=',$id],['product_id','=',$rebateId]])->value('id');
					// 如果旧的与新的不一致
					if(  $oldRebateId != $rebateId ) {
						// 删除旧的
						$CouponRebate->query()->where([['coupon_id','=',$id],['product_id','=',$rebateId]])->delete();
						// 有旧的修改，无则添加新的
						$result 		= $oldRebateId ? $CouponRebate->edit($oldRebateId,['product_id'=>$rebateId,'rebate_num'=>1]) : $CouponRebate->add(['coupon_id'=>$id,'product_id'=>$rebateId,'rebate_num'=>1]);
						// 提示新增失败
						if( !$result )	{
							// 回滚
							DB::rollBack();
							// 提示失败
							return		json_send(['code'=>'error','msg'=>'赠品结果写入失败']);
						}
					}
				}
				// 当前时间
				$time 				= time();
				// 如果有商品范围
				if( $products )		{
					// 循环商品
					foreach ($products as $key => $value) {
						// 重复的产品移除
						$oldProduct		= $CouponProduct->query()->where([['coupon_id','=',$id],['product_id','=',$value]])->value('product_id');
						// 存在产品，移除
						if( $oldProduct ) {
							unset($products[$key]);
							continue;
						}
						// 时间处理
						$value			= ['coupon_id'=>$id,'product_id'=>$value,'insert_time'=>$time,'update_time'=>$time];
						// 重组
						$products[$key] = $value;
					}
					// 格式化
					$products		= array_values($products);
					// 写入数据
					$result 		= $CouponProduct->insert($products);
					// 提示新增失败
					if( !$result )	{
						// 回滚
						DB::rollBack();
						// 提示失败
						return		json_send(['code'=>'error','msg'=>'商品范围写入失败']);
					}
				}
				// 如果有客户范围
				if( $customs )		{
					// 分块，每1000一批写入
					foreach (array_chunk($customs,1000) as $chunk) {
						// 循环客户
						foreach ($chunk as $key => $value) {
							// 时间处理
							$value		= ['coupon_id'=>$id,'custom_uid'=>$value,'exp_time'=>$Model->getExpTime($data['exp_time']),'insert_time'=>$time,'update_time'=>$time];
							// 重组
							$chunk[$key] = $value;
						}
						// 写入数据
						$result 		= $CustomCoupon->insert($chunk);
						// 提示新增失败
						if( !$result )	{
							// 回滚
							DB::rollBack();
							// 提示失败
							return		json_send(['code'=>'error','msg'=>'客户范围写入失败']);
						}
					}
				}
				// 提交
				DB::commit();
			} catch (\Throwable $th) {
				// 回滚
				DB::rollBack();
				// 提示失败
				return				json_send(['code'=>'error','msg'=>'内部错误，请重试','data'=>['error'=>$th->getMessage()]]);
			}
			// 记录行为
			$this->addAdminHistory(admin('uid'),$Model->getTable(),$id,2,[],$data);
			// 告知结果
			return					json_send(['code'=>'success','msg'=>'修改成功','action'=>'edit']);			
		}
		// 如果是没有数据
		if( !$oldData ) 			return $this->error('查无数据');
		// 如果是赠品表的话。处理赠品逻辑
		if( $oldData['rebate_type'] == 3 ) {
			// 产品编码
			$rebateId 			= $CouponRebate->getProductByCouponId($oldData['id']);
			// 产品ID
			$rebateId 			= isset($rebateId[0]['product_id']) ? $Product->idToCode($rebateId[0]['product_id']) : '';
			// 设置为0,避免数据异常
			$oldData['rebate']  = $rebateId;
		}
		// 有效期，时间戳或者时间为0表示的时间段，否则表示领取后N天
		$oldData['exp_type']	= $oldData['exp_time'] > 1000 ? 2 : 1;
		// 分配数据
		$this->assign('oldData',$oldData);
		$this->assign('crumbs','修改');
		// 加载模板
		return 					$this->fetch();
	}

	/**
	 * 状态
	 * 
	 * */
	public function set_status( Request $request, Model $Model,CustomCoupon $CustomCoupon ){
		// 验证参数
		$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'=>'设置失败']);
		// 查询数据
		$result			= $CustomCoupon->setStatusByCouponId($id,$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'=>'']);
	}

}