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

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

use App\Http\Requests\Admin\RegimentActive as Request;
use App\Models\Business;
use App\Models\RegimentActive as Model;
use App\Models\Regiment;
use App\Models\Product as Product;
use Illuminate\Support\Facades\DB;


/**
 * 拼团活动
 *
 * @author    jun
 * 
 */
class RegimentActive extends Auth{

	protected function _initialize(){
		parent::_initialize();
		$this->assign('breadcrumb1','拼团活动');
		$this->assign('breadcrumb2','活动列表');
	}

    /**
     * 列表页
     *
     * */
    public function index(Model $Model){
        // 接收参数
        $code					= request('code','');
        $name					= request('name','');
        $productName			= request('product_name','');
        $status			        = request('status','');
        $start_time			    = request('start_time','');
        $end_time			    = request('end_time','');
        // 查询条件
        $map 					= [];
        // 组合条件
        if( $name )				$map[] = ['regiment_active.name','=',$name];
        if( $code ){
            $id                 =   $Model->codeToId($code);
            $map[] = ['regiment_active.id','=',$id];
        }
        if( $productName )		$map[] = ['product.name','=',$productName];
        if( $status )			$map[] = ['regiment_active.status','=',$status];
        if( $start_time )		{
            $start_time         =   strtotime($start_time);
            $map[] = ['regiment_active.start_time','>=',$start_time];
        }
        if( $end_time )		{
            $end_time         =   strtotime($end_time);
            $map[] = ['regiment_active.end_time','<=',$end_time];
        }
        // 当前登录的角色数据
        $session                = session('userRule') ? session('userRule') : ['business_id'=>0,'menu_type'=>0,'data_type'=>0];
		// 是否存在对应的店铺ID
       	if ( $session['business_id'] ) $map[] = ['regiment_active.business_id','=',$session['business_id']];
		// 数据类型
		$shopIds				= ($session['menu_type'] == 1 && $session['data_type'] == 2)  ? Business::query()->where('leader_uid',$session['admin_uid'])->pluck('id')->toArray() : [];
		
        // 查询数据
        $list					= $Model->query()
                                ->join('product','product.id','=','regiment_active.product_id');
        if ( $shopIds )         $list->whereIn('regiment_active.business_id',$shopIds);
        $list					= $list->where($map)
                                ->select(['regiment_active.*','product.name as product_name'])
                                ->orderByDesc('regiment_active.id')
                                ->paginate(config('page_num',10))->appends(request()->all());
        // 循环处理数据
        foreach ($list as &$value) {
            $value['code']	= $Model->idToCode($value['id']);
            $value['business_name']	= Business::query()->where([['id','=',$value['business_id']]])->value('name');
        }
        // 分配数据
        $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,Business $Business){
        if( request()->isMethod('post') ){
            // 验证参数
            $request->scene('add')->validate();
            // 接收数据
            $product_code		            = request('product_code','');
            $data['product_id']		        = $Product->codeToId($product_code);
            if (!$data['product_id'])       return json_send(['code'=>'error','msg'=>'产品不存在']);
            $data['regiment_price']		    = request('regiment_price',0);
            $data['quota']	                = request('quota','');
            $data['name']	                = request('name','');
            $data['number']	                = request('number',0);
            $expiration_hours	            = request('expiration_hours',0);
            //$data['expiration']	        = $expiration_day * 24 + $expiration_hours;
            $data['expiration']	            = $expiration_hours;
            $data['start_time']		        = request('start_time','');
            $data['end_time']		        = request('end_time','');
            $data['start_time']		        = $data['start_time'] ? strtotime($data['start_time']) : 0;
            $data['end_time']		        = $data['end_time'] ? strtotime($data['end_time']) : 0;
            $data['participation_number']	= request('participation_number',0);
            $data['open_people']			= request('open_people',0);
            $data['partake_people']			= request('partake_people',0);
            $data['exceed_people']			= request('exceed_people',0);
            $data['automatic']				= request('automatic',0);
            $data['virtually']				= request('virtually',0);
            $data['status']			        = 1;
            // 核对产品
            $product_res                    = $Model->query()->where([['status','=', 1],['product_id','=', $data['product_id']],['end_time','>=', time()]])->first();
            // 提示
            if ($product_res)               return json_send(['code'=>'error','msg'=>'该产品正在参加拼团活动']);
            // 核对产品
            $product_res                    = $Product->query()->where([['id','=', $data['product_id']]])->first();
            if (!$product_res)               return json_send(['code'=>'error','msg'=>'该产品不存在']);
            //核对产品价格
            $productInfo                    = $Product->getOne($data['product_id']);
            // 如果拼团价格大于产品价格
            if ($productInfo['price'] < $data['regiment_price'])    return json_send(['code'=>'error','msg'=>'拼团价格不能大于产品价格']);
            // 写入数据表
            $id						        = $Model->add($data);
            // 如果操作失败
            if( !$id ) 				        return json_send(['code'=>'error','msg'=>'新增失败']);
            //商户开团
            if ($data['automatic'] == 1 )   {
                // 开团信息
                $regimentData               = [
                                                'custom_uid'    =>  0,
                                                'active_id'     =>  $id,
                                                'product_id'    =>  $data['product_id'],
                                                'status'        =>  0,
                                                'start_time'    =>  $data['start_time'],
                                                'end_time'      =>  $data['start_time'] + $data['expiration']*60*60,
                                                'update_time'   =>  time(),
                                                'insert_time'   =>  time(),
                                            ];
                // 开团
                $regimentRes                = Regiment::query()->insert($regimentData);
                // 开团结果
                if (!$regimentRes)          return json_send(['code'=>'error','msg'=>'商户开团失败']);
            }
            // 记录行为
            $this->addAdminHistory(admin('uid'),$Model->getTable(),$id,1,[],$data);
            // 告知结果
            return					        json_send(['code'=>'success','msg'=>'新增成功','action'=>'add']);
        }
        // 标签列表
        $tagList					        = [];
        $cityList					        = [];
        $businessList 			            = $Business->getListByAdmin();
        // 分配数据
        $this->assign('cityList',$cityList);
        $this->assign('tagList',$tagList);
        $this->assign('businessList',$businessList);
        $this->assign('crumbs','新增');
        // 加载模板
        return						        $this->fetch();
    }

    /**
     * 修改
     *
     * */
    public function edit(Request $request,Model $Model,Product $Product,Business $Business){
        // 接收参数
        $id							        = request('id',0);
        // 查询用户
        $oldData					        = $Model->where(['id'=>$id])->first()->toArray();
        // 修改
        if(request()->isMethod('post'))     {
            // 验证参数
            $request->scene('edit')->validate();
            // 接收数据
            $product_code		            = request('product_code','');
            $data['product_id']		        = $Product->codeToId($product_code);
            if (!$data['product_id'])       return json_send(['code'=>'error','msg'=>'产品不存在']);
            $data['regiment_price']		    = request('regiment_price',0);
            $data['quota']	                = request('quota','');
            $data['name']	                = request('name','');
            $data['number']	                = request('number',0);
            $expiration_day	                = request('expiration_day',0);
            $expiration_hours	            = request('expiration_hours',0);
            $data['expiration']	            = $expiration_day * 24 + $expiration_hours;
            $data['start_time']		        = request('start_time','');
            $data['end_time']		        = request('end_time','');
            $data['start_time']		        = $data['start_time'] ? strtotime($data['start_time']) : 0;
            $data['end_time']		        = $data['end_time'] ? strtotime($data['end_time']) : 0;
            $data['participation_number']	= request('participation_number',0);
            $data['open_people']			= request('open_people',0);
            $data['partake_people']			= request('partake_people',0);
            $data['exceed_people']			= request('exceed_people',0);
            $data['automatic']				= request('automatic',0);
            $data['virtually']				= request('virtually',0);
            $data['status']			        = 1;
            // 核对产品
            $product_res                    = $Model::query()->where([['id','><', $id],['status','=', 1],['product_id','=', $data['product_id']],['end_time','>=', time()]])->first();
            // 提示
            if ($product_res)               return json_send(['code'=>'error','msg'=>'该产品正在参加拼团活动']);
            //核对产品价格
            $productInfo                    =   $Product->getOne($data['product_id']);
            if ($productInfo['price'] < $data['regiment_price'])    return json_send(['code'=>'error','msg'=>'拼团价格不能大于产品价格']);
            // 写入数据表
            $id						        = $Model->edit($id,$data);
            // 如果操作失败
            if( !$id ) 				        return json_send(['code'=>'error','msg'=>'新增失败']);
            //商户开团
            if ($data['automatic'] == 1 )   {
                // 开团信息
                $regimentData               = [
                                                'custom_uid'    =>  0,
                                                'active_id'     =>  $id,
                                                'product_id'    =>  $data['product_id'],
                                                'status'        =>  1,
                                                'start_time'    =>  $data['start_time'],
                                                'end_time'      =>  $data['start_time'] + $data['expiration']*60*60,
                                                'update_time'   =>  time(),
                                                'insert_time'   =>  time(),
                                            ];
                //查询开团信息
                $regimentIfo                = Regiment::query()->where([['active_id','=',$id]])->first();
                if (!$regimentIfo){
                    // 开团
                    $regimentRes                = Regiment::query()->insert($regimentData);
                    // 开团结果
                    if (!$regimentRes)          return json_send(['code'=>'error','msg'=>'商户开团失败']);
                }
            }
            // 记录行为
            $this->addAdminHistory(admin('uid'),$Model->getTable(),$id,2,$oldData,$data);
            // 告知结果
            return					        json_send(['code'=>'success','msg'=>'修改成功','action'=>'edit']);
        }
        // 错误告知
        if( !$oldData )				        return $this->error('查无数据');
        $businessList 			            = $Business->getListByAdmin();
        // 返回结果
        $oldData['product_code']	        = $Product->idToCode($oldData['product_id']);
        $this->assign('oldData',$oldData);
        $this->assign('businessList',$businessList);
        $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);
        // 查询用户
        $oldData		= $Model->where(['id'=>$id])->first();
        // 如果用户不存在
        if( !$oldData )	return json_send(['code'=>'error','msg'=>'数据不存在']);
        // 执行修改
        $result			= $Model->edit($id,['status'=>$status]);
        // 提示新增失败
        if( !$result )	return json_send(['code'=>'error','msg'=>'设置失败']);
        // 记录行为
        $this->addAdminHistory(admin('uid'),$Model->getTable(),$id,2,$oldData,['status'=>$status]);
        // 告知结果
        return 			json_send(['code'=>'success','msg'=>'设置成功','path'=>'']);
    }

    /**
     * 复制
     *
     * */
    public function copy(Request $request,Model $Model,Product $Product){
        // 接收参数
        $id							        = request('id',0);
        // 查询用户
        $oldData					        = $Model->where(['id'=>$id])->first()->toArray();
        // 修改
        if(request()->isMethod('post'))     {
            // 验证参数
            $request->scene('edit')->validate();
            // 接收数据
            $product_code		            = request('product_code','');
            $data['product_id']		        = $Product->codeToId($product_code);
            if (!$data['product_id'])       return json_send(['code'=>'error','msg'=>'产品不存在']);
            $data['regiment_price']		    = request('regiment_price',0);
            $data['quota']	                = request('quota','');
            $data['name']	                = request('name','');
            $data['number']	                = request('number',0);
            $expiration_day	                = request('expiration_day',0);
            $expiration_hours	            = request('expiration_hours',0);
            $data['expiration']	            = $expiration_day * 24 + $expiration_hours;
            $data['start_time']		        = request('start_time','');
            $data['end_time']		        = request('end_time','');
            $data['start_time']		        = $data['start_time'] ? strtotime($data['start_time']) : 0;
            $data['end_time']		        = $data['end_time'] ? strtotime($data['end_time']) : 0;
            $data['participation_number']	= request('participation_number',0);
            $data['open_people']			= request('open_people',0);
            $data['partake_people']			= request('partake_people',0);
            $data['exceed_people']			= request('exceed_people',0);
            $data['automatic']				= request('automatic',0);
            $data['virtually']				= request('virtually',0);
            // 核对产品
            $product_res                    = $Model::query()->where([['status','=', 1],['product_id','=', $data['product_id']],['end_time','>=', time()]])->first();
            // 提示
            if ($product_res)               return json_send(['code'=>'error','msg'=>'该产品正在参加拼团活动']);
            // 写入数据表
            $result					        = $Model->add($data);
            // 如果操作失败
            if( !$result ) 			        return json_send(['code'=>'error','msg'=>'复制失败']);
            //商户开团
            if ($data['automatic'] == 1 )   {
                // 开团信息
                $regimentData               = [
                                                'custom_uid'    =>  0,
                                                'active_id'     =>  $id,
                                                'product_id'    =>  $data['product_id'],
                                                'status'        =>  1,
                                                'start_time'    =>  $data['start_time'],
                                                'end_time'      =>  $data['start_time'] + $data['expiration']*60*60,
                                                'update_time'   =>  time(),
                                                'insert_time'   =>  time(),
                                            ];
                // 开团
                $regimentRes                = Regiment::query()->insert($regimentData);
                // 开团结果
                if (!$regimentRes)          return json_send(['code'=>'error','msg'=>'商户开团失败']);
            }
            // 记录行为
            $this->addAdminHistory(admin('uid'),$Model->getTable(),$id,2,$oldData,$data);
            // 告知结果
            return					        json_send(['code'=>'success','msg'=>'复制成功','action'=>'edit']);
        }
        // 错误告知
        if( !$oldData )				        return $this->error('查无数据');
        // 返回结果
        $oldData['product_code']	        = $Product->idToCode($oldData['product_id']);
        $this->assign('oldData',$oldData);
        $this->assign('crumbs','修改');
        // 加载模板
        return						        $this->fetch();
    }
}