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

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

use App\Http\Requests\Admin\RegimentActive as Request;
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){
        // 接收参数
        $name					= request('name','');
        // 查询条件
        $map 					= [];
        // 组合条件
        if( $name )				$map[] = ['regiment_active.name','=',$name];
        $select = ['regiment_active.*','product.name as product_name'];
        // 查询数据
        $list					= $Model->query()
            ->join('product','product.id','=','regiment_active.product_id')
            ->where($map)
            ->select($select)
            ->orderByDesc('regiment_active.id')
            ->paginate(config('page_num',10));
        // 循环处理数据
        foreach ($list as $key => &$value) {
            $value['code']	= $Model->idToCode($value['id']);
        }
        // 分配数据
        $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){
        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_day	                = request('expiration_day',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',1);
            $data['partake_people']			= request('partake_people',1);
            $data['exceed_people']			= request('exceed_people',1);
            $data['automatic']				= request('automatic',1);
            $data['virtually']				= request('virtually',1);
            $data['status']			        = 1;
            $where                          =   [
                ['status','=', 1],
                ['product_id','=', $data['product_id']],
                ['end_time','>=', time()]
            ];
            $product_res                    = $Model::query()->where($where)->first();
            if ($product_res)               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'        =>  1,
                    'start_time'    =>  $data['start_time'],
                    'end_time'      =>  $data['start_time'] + $data['expiration']*60*60,
                    'update_time'   =>  time(),
                    'insert_time'   =>  time(),
                ];
                $regimentRes            =   Regiment::query()->where($where)->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					= [];
        // 分配数据
        $this->assign('cityList',$cityList);
        $this->assign('tagList',$tagList);
        $this->assign('crumbs','新增');
        // 加载模板
        return						$this->fetch();
    }

    /**
     * 修改
     *
     * */
    public function edit(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',1);
            $data['partake_people']			= request('partake_people',1);
            $data['exceed_people']			= request('exceed_people',1);
            $data['automatic']				= request('automatic',1);
            $data['virtually']				= request('virtually',1);
            // 写入数据表
            $result					= $Model->edit($id,$data);
            // 如果操作失败
            if( !$result ) 			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();
    }

    /**
     * 修改状态
     *
     * */
    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,Clockin $Clockin){
        // 验证参数
        $request->scene('copy')->validate();
        // 设置状态
        $id				= request('id',0);
        $time           =   time();
        // 查询
        $data		    = $Model->where(['id'=>$id])->first()->toArray();
        if (!$data)     json_send(['code'=>'error','msg'=>'复制失败,活动不存在']);
        $clockinList    = $Clockin->getActiveList($id);
        DB::beginTransaction();
        try {
            unset($data['id']);
            $data['status'] = 1;
            $data['name'] = $data['name'].'复制';
            //复制活动
            $newId          = $Model->add($data);
            if (!$newId){
                DB::rollBack();
                return json_send(['code'=>'error','msg'=>'复制失败']);
            }
            if ($clockinList){
                foreach ($clockinList as &$clockin){
                    $clockin['active_id'] = $newId;
                    $clockin['insert_time'] = $time;
                    $clockin['update_time'] = $time;
                    unset($clockin['id']);
                }
                $re = $Clockin->Query()->insert($clockinList);
                if (!$re)   return  json_send(['code'=>'error','msg'=>'复制失败']);
            }
            DB::commit();
        }catch (\Exception $e){
            // 回退数据
            DB::rollBack();
            // 失败提示
            return						json_send(['code'=>'error','msg'=>'复制失败','data'=>['error'=>$e->getMessage().$e->getLine()]]);
        }
        return json_send(['code'=>'success','msg'=>'复制成功','path'=>'']);
    }
}