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\Controllers\HasResourceActions;
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
{
    use HasResourceActions;

    public function index(Content $content)
    {
        echo 'sadfsdf';
    }

    /**
     * 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('face_audit',-1)->where(function($query){
                    $query->where('pen_audit',1)
                          ->orWhere('pen_audit',3);
                })->orderBy('post_id','asc')->get();
                break;
            case 'reexamine':
                $list = RecruitAppointInfo::where('recruit_id',$recruit_id)->where('audit',3)->where(function($query){
                    $query->where('face_audit',1)
                        ->orWhere('face_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){
            if(array_key_exists($v->post_id,$post_data)){
                $item = [
                    $v->realname,
                    $v->card,
                    $post_data[$v->post_id]
                ];
                array_push($data,$item);
            }else{
                continue;
            }
        }
        $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);
        }

        $ticket_type = $request->input('ticket_type');

        switch ($ticket_type){
            case 'pen':
                $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' => [],
                                'ex_start' => $pen['ex_start'],
                                'ex_end' => $pen['ex_end']
                            ];
                            $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_place',$field)){
                                    $row_data['ex_place'] = $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;
                }
                break;
            case 'face':
                $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'],
                            'ex_start' => $face['ex_start'],
                            'ex_end' => $face['ex_end']
                        ];
                        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' => [],
                                'ex_start' => $face['ex_start'],
                                'ex_end' => $face['ex_end']
                            ];
                            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(),
                                    'extra1' => $sheet->getCell("L{$row}")->getValue(),
                                    'extra2' => $sheet->getCell("M{$row}")->getValue(),
                                    'extra3' => $sheet->getCell("N{$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' => $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 'reexamine':
                $reexamine = $data['reexamine'];
                //面试通知书前置检查
                if($recruit->reexamine_ticket_type < 0){
                    return response()->json(['status' => 0, 'msg' => '未开启设置复试准考证的功能'], 200);
                }
                if(empty($recruit->reexamine_ticket_content)){
                    return response()->json(['status' => 0, 'msg' => '未设置准考证模板'], 200);
                }
                if($recruit->reexamine_ticket_status > 0){
                    return response()->json(['status' => 0, 'msg' => '复试准考证正在生成中或已生成，暂不允许操作，有疑问请联系技术人员'], 200);
                }
                if(!array_key_exists('type',$reexamine) || !in_array($reexamine['type'],[0,1,2])){
                    return response()->json(['status' => 0, 'msg' => '请指定正确的复试准考证生成方式'], 200);
                }
                if($reexamine['type'] == 2 && (!array_key_exists('data',$reexamine) || empty($reexamine['data']))){
                    return response()->json(['status' => 0, 'msg' => '请上传复试准考证数据'], 200);
                }
                if(!array_key_exists('ex_start',$reexamine) || empty($reexamine['ex_start'])){
                    return response()->json(['status' => 0, 'msg' => '准考证开启打印时间不能为空'], 200);
                }
                if(!array_key_exists('ex_end',$reexamine) || empty($reexamine['ex_end'])){
                    return response()->json(['status' => 0, 'msg' => '准考证结束打印时间不能为空'], 200);
                }

                switch ($reexamine['type']){
                    case '0':
                        Recruit::where('id',$data['recruit_id'])->update(['reexamine_ticket_status' => 1]);
                        $ticket = new TicketJob($data['recruit_id'],'face',['type' => '0','ex_start' => $reexamine['ex_start'], 'ex_end' => $reexamine['ex_end']]);
                        dispatch($ticket);
                        return response()->json(['status' => 1, 'msg' => '准考证生成成功'], 200);
                        break;
                    case '1':
                        //自动生成
                        $ticket_data = [
                            'type' => 1,
                            'auto_each_number' => $reexamine['auto_each_number'],
                            'ex_start' => $reexamine['ex_start'],
                            'ex_end' => $reexamine['ex_end']
                        ];
                        Recruit::where('id',$data['recruit_id'])->update(['reexamine_ticket_status' => 1]);
                        $ticket = new TicketJob($data['recruit_id'],'reexamine',$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['reexamine']['tmp_name']['data'],$ticket_url)){
                            $spreadsheet = IOFactory::load($ticket_url);
                            $sheet = $spreadsheet->getActiveSheet();
                            $rowCount = $sheet->getHighestRow();
                            $ticket_data = [
                                'type' => 2,
                                'list' => [],
                                'ex_start' => $reexamine['ex_start'],
                                'ex_end' => $reexamine['ex_end']
                            ];
                            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(),
                                    'extra1' => $sheet->getCell("L{$row}")->getValue(),
                                    'extra2' => $sheet->getCell("M{$row}")->getValue(),
                                    'extra3' => $sheet->getCell("N{$row}")->getValue()
                                ];
                            }
                            Recruit::where('id',$data['recruit_id'])->update(['reexamine_ticket_status' => 1]);
                            $ticket = new TicketJob($data['recruit_id'],'reexamine',$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' => $reexamine['auto_each_number']
                ];
                Recruit::where('id',$data['recruit_id'])->update(['reexamine_ticket_status' => 1]);
                $ticket = new TicketJob($data['recruit_id'],'reexamine',$ticket_data);
                dispatch($ticket);
                return response()->json(['status' => 1, 'msg' => '准考证生成成功'], 200);
                break;
        }

    }
}