jucai/app/Admin/Controllers/Recruit/RecruitTicketController.php

<?php

namespace App\Admin\Controllers\Recruit;

use App\Http\Controllers\Controller;
use App\Models\Recruit;
use App\Models\RecruitAppointInfo;
use App\Models\RecruitPost;
use App\Models\RecruitTicket;
use Encore\Admin\Layout\Content;
use Encore\Admin\Form;
use Illuminate\Http\Request;
use PhpOffice\PhpSpreadsheet\IOFactory;
use PhpOffice\PhpSpreadsheet\Cell\DataType;
use App\Jobs\TicketJob;
use Illuminate\Support\Facades\Storage;

class RecruitTicketController extends Controller
{

    public function index($id, Content $content)
    {
        return $content
            ->header('新闻')
            ->description(' ')
            ->body($this->form($id)->edit($id));
    }

    /**
     * Make a form builder.
     *
     * @return Form
     */
    protected function form($id)
    {
        $form = new Form(new RecruitTicket);
        $recruit = Recruit::findOrFail($id);
        if(in_array('3',explode(',',$recruit->step))){
            $form->tab('笔试', function ($form) {
                $form->radio('pen_ticket_type', '准考证类型')->options(['1' => '纸质', '2' => '短信']);
                $form->text('pen_ticket_content', '准考证内容')->help('当类型为纸质时，此处填入准考证模板的路径，当类型为短信时，此处填入短信标识');
            });
        }
        if(in_array('4',explode(',',$recruit->step))){
            $form->tab('上机', function ($form) {
                $form->radio('computer_ticket_type', '准考证类型')->options(['1' => '纸质', '2' => '短信']);
                $form->text('computer_ticket_content', '准考证内容')->help('当类型为纸质时，此处填入准考证模板的路径，当类型为短信时，此处填入短信标识');
            });
        }
        if(in_array('5',explode(',',$recruit->step))){
            $form->tab('面试', function ($form) {
                $form->radio('face_ticket_type', '准考证类型')->options(['1' => '纸质', '2' => '短信']);
                $form->text('face_ticket_content', '准考证内容')->help('当类型为纸质时，此处填入准考证模板的路径，当类型为短信时，此处填入短信标识');
            });
        }
        $form->setAction('/ST3IXxKlOa4eGEv0eTw0CfORI9444Mgj/recruit/ticket/'.$id.'/ticket_save');


        return $form;
    }

    public function ticket_save(Request $request)
    {
        $data = $request->all();
        dd($data);
    }

    /**
     * 获取准考证生成页面
     *
     * @access public
     */
    public function ajax_ticket(Request $request)
    {
        $recruit_id = $request->input('recruit_id');
        if(!$recruit_id){
            return response()->json(['status' => 0, 'msg' => '请指定招考场次'], 200);
        }
        $recruit = Recruit::where('id',$recruit_id)->first();
        if(empty($recruit)){
            return response()->json(['status' => 0, 'msg' => '找不到对应招考场次'], 200);
        }

        $view_data = [
            'recruit'   =>  $recruit
        ];
        return response(['data' => view('admin.recruit.ajax_ticket')->with($view_data)->render(), 'status' => 1], '200');
    }

    /**
     * 考试数据模板
     * @param Request $request
     * @return \Illuminate\Http\JsonResponse
     * @throws \PhpOffice\PhpSpreadsheet\Exception
     * @throws \PhpOffice\PhpSpreadsheet\Reader\Exception
     * @throws \PhpOffice\PhpSpreadsheet\Writer\Exception
     */
    public function ticket_data_template(Request $request)
    {
        $recruit_id = $request->input('recruit_id');
        if(!$recruit_id){
            return response()->json(['status' => 0, 'msg' => '请指定招考场次'], 200);
        }
        $recruit = Recruit::where('id',$recruit_id)->first();
        if(empty($recruit)){
            return response()->json(['status' => 0, 'msg' => '找不到对应招考场次'], 200);
        }
        $type = $request->input('type');
        switch ($type)
        {
            case 'pen':
                $list = RecruitAppointInfo::where('recruit_id',$recruit_id)->where('audit',3)->where('pen_audit',-1)->orderBy('post_id','asc')->get();
                break;
            case 'face':
                $list = RecruitAppointInfo::where('recruit_id',$recruit_id)->where('audit',3)->where(function($query){
                    $query->where('pen_audit',1)
                          ->orWhere('pen_audit',3);
                })->orderBy('post_id','asc')->get();
                break;
        }

        $post_data = RecruitPost::where('recruit_id',$recruit_id)->where('status',1)->selectRaw('id, CONCAT(code," ",name) as post')->pluck('post', 'id');
        $data = [];
        foreach ($list as $k => $v){
            $item = [
                $v->realname,
                $v->card,
                $post_data[$v->post_id]
            ];
            array_push($data,$item);
        }
        $spreadsheet = IOFactory::load(base_path() . '/storage/app/public/recruit/ticket/template/ticket_data_template.xlsx');
        $sheet = $spreadsheet->getActiveSheet();

        $row = 2;
        foreach($data as $k => $v){
            for ($i = 0;$i<count($v);$i++){
                if($i == 1){
                    $sheet->setCellValueExplicitByColumnAndRow($i+1, $row, $v[$i], DataType::TYPE_STRING);
                }else{
                    $sheet->setCellValueByColumnAndRow($i+1, $row, $v[$i]);
                }
            }
            $row++;
        }

        $file_name = $recruit->company;
        header('Content-Type: application/vnd.openxmlformats-officedocument.spreadsheetml.sheet');
        header('Content-Disposition: attachment;filename="'.$file_name.'.xlsx"');
        header('Cache-Control: max-age=0');
        // If you're serving to IE 9, then the following may be needed
        header('Cache-Control: max-age=1');
        // If you're serving to IE over SSL, then the following may be needed
        header('Expires: Mon, 26 Jul 1997 05:00:00 GMT'); // Date in the past
        header('Last-Modified: ' . gmdate('D, d M Y H:i:s') . ' GMT'); // always modified
        header('Cache-Control: cache, must-revalidate'); // HTTP/1.1
        header('Pragma: public'); // HTTP/1.0
        $writer = IOFactory::createWriter($spreadsheet, 'Xlsx');
        $writer->save('php://output');
    }

    public function create_ticket(Request $request)
    {
        $data = $request->all();
        if(!array_key_exists('recruit_id',$data) || !$data['recruit_id']){
            return response()->json(['status' => 0, 'msg' => '请指定招考场次'], 200);
        }
        $recruit = Recruit::where('id',$data['recruit_id'])->first();
        if(empty($recruit)){
            return response()->json(['status' => 0, 'msg' => '找不到对应招考场次'], 200);
        }


        if(array_key_exists('pen',$data)){
            $pen = $data['pen'];
            //有设置笔试准考证，前置数据检查
            if($recruit->pen_ticket_type < 0){
                return response()->json(['status' => 0, 'msg' => '未开启设置笔试准考证的功能'], 200);
            }
            if(empty($recruit->pen_ticket_content)){
                return response()->json(['status' => 0, 'msg' => '未设置准考证模板'], 200);
            }
            if($recruit->pen_ticket_status > 0){
                return response()->json(['status' => 0, 'msg' => '笔试准考证正在生成中或已生成，暂不允许操作，有疑问请联系技术人员'], 200);
            }
            if(!array_key_exists('type',$pen) || !in_array($pen['type'],[1,2])){
                return response()->json(['status' => 0, 'msg' => '请指定正确的笔试准考证生成方式'], 200);
            }
            if($pen['type'] == 2 && (!array_key_exists('data',$pen) || empty($pen['data']))){
                return response()->json(['status' => 0, 'msg' => '请上传笔试准考证数据'], 200);
            }
            if($pen['type'] == 1){
                if(!array_key_exists('auto_each_number',$pen) || empty($pen['auto_each_number'])){
                    return response()->json(['status' => 0, 'msg' => '请输入每间考试的人员数量'], 200);
                }
            }
            if(!array_key_exists('ex_start',$pen) || empty($pen['ex_start'])){
                return response()->json(['status' => 0, 'msg' => '准考证开启打印时间不能为空'], 200);
            }
            if(!array_key_exists('ex_end',$pen) || empty($pen['ex_end'])){
                return response()->json(['status' => 0, 'msg' => '准考证结束打印时间不能为空'], 200);
            }

            switch ($pen['type']){
                case '1':
                    //自动生成
                    $list = RecruitAppointInfo::where('recruit_id',$data['recruit_id'])->where('audit',3)->where('pen_audit',-1)->select('id','realname','card','post_id','avatar')->orderBy('post_id','asc')->orderBy('created_at','asc')->get()->toArray();
                    if(!$list || count($list) == 0){
                        return response()->json(['status' => 0, 'msg' => '无数据可生成'], 200);
                    }
                    //$post_data = RecruitPost::where('recruit_id',$data['recruit_id'])->where('status',1)->selectRaw('id, CONCAT(code," ",name) as post')->pluck('post', 'id');
                    $list = array_chunk($list,$pen['auto_each_number'],true);
                    if(count($list) <= 10){
                        //小于10个队列数直接处理
                        foreach ($list as $room => $room_list){
                            if(is_array($room_list)){
                                $ticket_data = [
                                    'type' => 1,
                                    'multiple' => 0,
                                    'list' => $room_list,
                                    'room' => $room,
                                    'ex_start' => $pen['ex_start'],
                                    'ex_end' => $pen['ex_end']
                                ];
                                $ticket = new TicketJob($data['recruit_id'],'pen',$ticket_data);
                                dispatch($ticket);
                            }
                        }
                    }else{
                        //划分10个队列任务
                        $number = count($list) / 10 +1;
                        $list = array_chunk($list,$number,true);
                        foreach ($list as $k => $v){
                            $ticket_data = [
                                'type' => 1,
                                'multiple' => 1,
                                'list' => $v,
                                'ex_start' => $pen['ex_start'],
                                'ex_end' => $pen['ex_end']
                            ];
                            $ticket = new TicketJob($data['recruit_id'],'pen',$ticket_data);
                            dispatch($ticket);
                        }
                    }

                    Recruit::where('id',$data['recruit_id'])->update(['pen_ticket_status' => 2]);
                    return response()->json(['status' => 1, 'msg' => '准考证生成成功'], 200);
                    break;
                case '2':
                    $ticket_url = base_path() . "/storage/app/public/recruit/ticket/" . uniqid() . '.xlsx';
                    if(move_uploaded_file($_FILES['pen']['tmp_name']['data'],$ticket_url)){
                        $spreadsheet = IOFactory::load($ticket_url);
                        $sheet = $spreadsheet->getActiveSheet();
                        $rowCount = $sheet->getHighestRow();
                        $ticket_data = [
                            'type' => 2,
                            'list' => []
                        ];
                        $field = explode(',',$recruit['pen_ticket_field']);
                        for($row = 2;$row<=$rowCount;$row++){
                            $row_data = [];
                            if(in_array('ex_number',$field)){
                                $row_data['ex_number'] = $sheet->getCell("D{$row}")->getValue();
                            }
                            if(in_array('ex_subject',$field)){
                                $row_data['ex_subject'] = $sheet->getCell("E{$row}")->getValue();
                            }
                            if(in_array('ex_room',$field)){
                                $row_data['ex_room'] = $sheet->getCell("F{$row}")->getValue();
                            }
                            if(in_array('ex_seat',$field)){
                                $row_data['ex_seat'] = $sheet->getCell("G{$row}")->getValue();
                            }
                            if(in_array('ex_time',$field)){
                                $row_data['ex_time'] = $sheet->getCell("H{$row}")->getValue();
                            }
                            if(in_array('ex_name',$field)){
                                $row_data['ex_name'] = $sheet->getCell("I{$row}")->getValue();
                            }
                            if(in_array('ex_address',$field)){
                                $row_data['ex_address'] = $sheet->getCell("J{$row}")->getValue();
                            }

                            $ticket_data['list'][$sheet->getCell("B{$row}")->getValue()] = $row_data;
                        }
                        Recruit::where('id',$data['recruit_id'])->update(['pen_ticket_status' => 1]);
                        $ticket = new TicketJob($data['recruit_id'],'pen',$ticket_data);
                        dispatch($ticket);
                        return response()->json(['status' => 1, 'msg' => '准考证生成成功'], 200);
                    }else{
                        return response()->json(['status' => 0, 'msg' => '准考证生成失败'], 200);
                    }
                    break;
            }
        }

        if(array_key_exists('face',$data)){
            $face = $data['face'];
            //面试通知书前置检查
            if($recruit->face_ticket_type < 0){
                return response()->json(['status' => 0, 'msg' => '未开启设置面试准考证的功能'], 200);
            }
            if(empty($recruit->face_ticket_content)){
                return response()->json(['status' => 0, 'msg' => '未设置准考证模板'], 200);
            }
            if($recruit->face_ticket_status > 0){
                return response()->json(['status' => 0, 'msg' => '面试准考证正在生成中或已生成，暂不允许操作，有疑问请联系技术人员'], 200);
            }
            if(!array_key_exists('type',$face) || !in_array($face['type'],[0,1,2])){
                return response()->json(['status' => 0, 'msg' => '请指定正确的面试准考证生成方式'], 200);
            }
            if($face['type'] == 2 && (!array_key_exists('data',$face) || empty($face['data']))){
                return response()->json(['status' => 0, 'msg' => '请上传面试准考证数据'], 200);
            }
            if(!array_key_exists('ex_start',$face) || empty($face['ex_start'])){
                return response()->json(['status' => 0, 'msg' => '准考证开启打印时间不能为空'], 200);
            }
            if(!array_key_exists('ex_end',$face) || empty($face['ex_end'])){
                return response()->json(['status' => 0, 'msg' => '准考证结束打印时间不能为空'], 200);
            }

            switch ($face['type']){
                case '0':
                    Recruit::where('id',$data['recruit_id'])->update(['face_ticket_status' => 1]);
                    $ticket = new TicketJob($data['recruit_id'],'face',['type' => '0','ex_start' => $face['ex_start'], 'ex_end' => $face['ex_end']]);
                    dispatch($ticket);
                    return response()->json(['status' => 1, 'msg' => '准考证生成成功'], 200);
                    break;
                case '1':
                    //自动生成
                    $ticket_data = [
                        'type' => 1,
                        'auto_each_number' => $face['auto_each_number']
                    ];
                    Recruit::where('id',$data['recruit_id'])->update(['face_ticket_status' => 1]);
                    $ticket = new TicketJob($data['recruit_id'],'face',$ticket_data);
                    dispatch($ticket);
                    return response()->json(['status' => 1, 'msg' => '准考证生成成功'], 200);
                    break;
                case '2':
                    $ticket_url = base_path() . "/storage/app/public/recruit/ticket/" . uniqid() . '.xlsx';
                    if(move_uploaded_file($_FILES['face']['tmp_name']['data'],$ticket_url)){
                        $spreadsheet = IOFactory::load($ticket_url);
                        $sheet = $spreadsheet->getActiveSheet();
                        $rowCount = $sheet->getHighestRow();
                        $ticket_data = [
                            'type' => 2,
                            'list' => []
                        ];
                        for($row = 2;$row<=$rowCount;$row++){
                            $ticket_data['list'][$sheet->getCell("B{$row}")->getValue()] = [
                                'ex_number' => $sheet->getCell("D{$row}")->getValue(),
                                'ex_subject' => $sheet->getCell("E{$row}")->getValue(),
                                'ex_room' => $sheet->getCell("F{$row}")->getValue(),
                                'ex_seat' => $sheet->getCell("G{$row}")->getValue(),
                                'ex_time' => $sheet->getCell("H{$row}")->getValue(),
                                'ex_name' => $sheet->getCell("I{$row}")->getValue(),
                                'ex_address' => $sheet->getCell("J{$row}")->getValue(),
                                'ex_ready_time' => $sheet->getCell("K{$row}")->getValue()
                            ];
                        }
                        Recruit::where('id',$data['recruit_id'])->update(['face_ticket_status' => 1]);
                        $ticket = new TicketJob($data['recruit_id'],'face',$ticket_data);
                        dispatch($ticket);
                        return response()->json(['status' => 1, 'msg' => '准考证生成成功'], 200);
                    }else{
                        return response()->json(['status' => 0, 'msg' => '准考证生成失败'], 200);
                    }
                    break;
            }

            $ticket_data = [
                'type' => 1,
                'auto_each_number' => $pen['auto_each_number']
            ];
            Recruit::where('id',$data['recruit_id'])->update(['pen_ticket_status' => 1]);
            $ticket = new TicketJob($data['recruit_id'],'face',$ticket_data);
            dispatch($ticket);
            return response()->json(['status' => 1, 'msg' => '准考证生成成功'], 200);
        }
    }
}