jucai/app/Services/Jobfairout/JobfairoutJobsService.php

<?php
/**
 * Created by PhpStorm.
 * User: wuzhenke
 * Date: 2019/1/22
 * Time: 15:38
 */

namespace App\Services\Jobfairout;

use App\Exceptions\ResponseException;
use App\Repositories\CompanyContactsRepository;
use App\Repositories\Jobfairout\JobfairoutCompanyRepository;
use App\Repositories\Jobfair\JobfairJobsContactRepository;
use App\Repositories\Jobfair\JobfairJobRepository;
use App\Repositories\Jobfairout\JobfairoutPutJobRepository;
use App\Repositories\MemberLogRepository;
use Exception;
use Illuminate\Support\Facades\DB;

class JobfairoutJobsService
{

    protected $jobfairJobRepository;
    protected $jobfairJobsContactRepository;
    protected $memberLogRepository;
    protected $jobfairoutCompanyRepository;
    protected $jobfairoutPutJobRepository;
    protected $companyContactsRepository;


    /**
     * JobfairJobsService constructor.
     * @param $jobfairJobRepository
     * @param $jobfairJobsContactRepository
     * @param $jobfairoutCompanyRepository
     * @param $jobfairoutPutJobRepository
     * @param $companyContactsRepository
     */
    public function __construct(JobfairJobRepository $jobfairJobRepository,  CompanyContactsRepository $companyContactsRepository, JobfairoutPutJobRepository $jobfairoutPutJobRepository, JobfairoutCompanyRepository $jobfairoutCompanyRepository, JobfairJobsContactRepository $jobfairJobsContactRepository, MemberLogRepository $memberLogRepository)
    {
        $this->jobfairJobRepository = $jobfairJobRepository;
        $this->jobfairJobsContactRepository = $jobfairJobsContactRepository;
        $this->memberLogRepository = $memberLogRepository;
        $this->jobfairoutCompanyRepository = $jobfairoutCompanyRepository;
        $this->jobfairoutPutJobRepository = $jobfairoutPutJobRepository;
        $this->companyContactsRepository = $companyContactsRepository;
    }

    /**招聘会职位库
     * @return array
     */
    public function jobfairoutJobsList()
    {
        $user = auth('web-company')->user();
        $where = [
            'company_id'=>$user->id,
            'type'=>2,
        ];
        $list = $this->jobfairJobRepository->getJobList($where);
        return $res = [
            'list'=>$list,
        ];
    }

    /**招聘会职位添加
     * @return array
     */
    public function jobfairoutJobsAdd()
    {
        $user = auth('web-company')->user();
        $user->landline =explode('-', $user->landline_tel);
        $jobfairJobContact = $this->jobfairJobsContactRepository->getContact(['pid'=>'']);
        $companyContact = $this->companyContactsRepository->getContacts(['company_id'=>$user->id]);

        return $result = [
            'company' =>$user,
            'jobfairJobContact' =>$jobfairJobContact,
            'companyContact' =>$companyContact,
        ];
    }

    /**招聘会职位修改
     * @param $id
     * @return array|bool
     */
    public function jobfairoutJobsEdit($id, $user)
    {
        $jobfair_job = $this->jobfairJobRepository->editJob($id);
        if (!$jobfair_job || $jobfair_job->company_id != $user->id) {
            return false;
        }
        $companyContact = $this->companyContactsRepository->getContacts(['company_id'=>$user->id]);
        $jobfair_job->tag = explode(',', $jobfair_job->tag);
        $jobfair_job->age = explode('-', $jobfair_job->age);
        $jobfair_job->jobsContact->landline_tel =$jobfair_job->jobsContact->landline_tel?explode('-', $jobfair_job->jobsContact->landline_tel):[];
        return $result = [
            'company' =>$user,
            'jobsInfo'=>$jobfair_job,
            'companyContact'=>$companyContact,
        ];
    }

    /**招聘会职位删除
     * @param $request
     * @return \Illuminate\Http\JsonResponse
     */
    public function jobfairoutJobsDel($request)
    {
        $user = auth('web-company')->user();
        $id = $request->y_id;
        $where['company_id'] = $user->id;
        if (!is_array($id)) {
            $ids = explode(',', $id);
        } else {
            $ids = $id;
        }
        DB::beginTransaction();
        try {
            if (!$this->jobfairJobRepository->deleteJobs($where, $ids)) {
                throw new Exception('招聘会职位删除失败！');
            }
            $this->jobfairJobsContactRepository->deleteJobContact($ids);
            $this->jobfairPutJobRepository->delJobIds($ids);
            $this->memberLogRepository->createLog($user, 1036, [implode(',', $ids)]);
            DB::commit();
            return response()->json(['status'=>1, 'msg'=>'招聘会职位删除成功！']);
        } catch (Exception $e) {
            DB::rollback();
            return response()->json(['status'=>0, 'msg'=>$e->getMessage()]);
        }
    }
    /**招聘会职位添加和修改
     * @param $data
     * @return \Illuminate\Http\JsonResponse
     */
    public function jobsSave($data, $user)
    {
        $message = '招聘会职位添加成功！';
        if ($id = $data['id']) {
            $message = '招聘会职位修改成功！';
            $company_id = $this->jobfairJobRepository->getColumn(['id'=>$id],'company_id');
            if($company_id != $user->id) {
                return response()->json(['status' => 0, 'msg' => '参数错误！']);
            }
        }

        $comArr = ['id','companyname','created_at','audit','trade','scale','map_x','map_y','map_zoom'];
        $contact = ['mobile','email','qq','landline_tel','address','contact','contact_show','email_show','landline_tel_show','telephone_show'];
        $data_job = [];
        $data_contact = [];
        if ($data['basis_contact']) {
            foreach ($contact as $key => $val) {
                $data_contact[$val] = $user->$val;
            }
        } else {
            $data_contact['contact'] = $data['contact'];
            $data_contact['mobile'] = $data['telephone'];
            $data_contact['email'] = $data['email'];
            $data_contact['landline_tel'] = $data['landline_tel'];
            $data_contact['address'] = $data['address'];
            $data_contact['landline_tel_show'] = $data['landline_tel_show'];
            $data_contact['contact_show'] = $data['contact_show'];
            $data_contact['email_show'] = $data['email_show'];
            $data_contact['telephone_show'] = $data['telephone_show'];
        }

        foreach ($comArr as $key => $val) {
            if ($val == "id") {
                $data_job['company_id'] = $user->id;
            } elseif ($val == 'companyname') {
                $data_job['company_name'] = $user->companyname;
            } elseif ($val == 'created_at') {
                $data_job['company_addtime'] = strtotime($user->created_at);
            } elseif ($val == 'audit') {
                $data_job['company_audit'] = $user->audit;
            } else {
                $data_job[$val] = $user->$val;
            }
        }
        $jobArr = ['nature','sex','age','amount','district','tag','education','experience','wage','wage_min','wage_max','jobs_content','major','zcid','zc_name'];
        foreach ($jobArr as $key => $val) {
            $data_job[$val] = $data[$val];
        }
        $data_job['type'] = 2;
        switch ($data_job['sex']) {
            case 0:
                $data_job['sex_cn']='不限';
                break;
            case 1:
                $data_job['sex_cn']='男';
                break;
            case 2:
                $data_job['sex_cn']='女';
                break;
        }

        if ($data['wage']==-1) {
            $data_job['wage'] = -1;
            $data_job['wage_min']=0;
            $data_job['wage_max']=0;
            $data_job['wage_cn'] ='面议';
        } else {
            if (intval($data_job['wage'])!=0) {
                $wage = explode('~', format_wage(get_category($data_job['wage'])));
                $data_job['wage_max'] = 0;
                if (isset($wage[1])) {
                    $data_job['wage_max'] =intval($wage[1]);
                }
                $data_job['wage_min'] =intval($wage[0]);
                $data_job['wage_cn'] =get_category($data_job['wage']);
            } else {
                $data_job['wage_min']=$data['wage_min'];
                $data_job['wage_max']=$data['wage_max'];
                $data_job['wage_cn'] =$data['wage_min'].'~'.$data['wage_max'].'/月';
            }
        }
        if ($data['syqxz_min'] && $data['syqxz_min'] < $data_job['wage_min']*0.8) {
            return response()->json(['status' => 0, 'msg' => '试用期薪资不得低于正式工资的80%']);
        }
        if($data['ygxs'] == 363){
            $data_job['wage_cn'] = $data['wage_min'].'/小时';
        }
        $jobcategory = explode('.', $data['jobcategory']);
        $data_job['topclass'] =$jobcategory[0];
        $data_job['category'] =$jobcategory[1];
        $data_job['subclass'] =$jobcategory[2];
        $data_job['category_cn'] =get_job_category_cn($data['jobcategory']);
        unset($data['jobcategory']);
        $data_job['trade_cn'] =get_category($data_job['trade']);
        $data_job['major_cn'] =get_category_major($data_job['major']);
        $data_job['nature_cn'] =get_category($data_job['nature']);
        $data_job['scale_cn'] =get_category($data_job['scale']);
        $data_job['district'] = getDistrict($data_job['district']);
        $data_job['district_cn'] =get_district_cn($data_job['district']);
        $data_job['tag_cn'] =get_tag_cn($data_job['tag']);
        $data_job['education_cn'] =get_category($data_job['education']);
        $data_job['experience_cn'] =get_category($data_job['experience']);
        $data_job['zc_cn'] =get_category($data_job['zcid']);
        $data_job['age'] =implode('-', $data['age']);
        $data_job['jobs_name'] = $data['jobs_name'];
        $data_job['syq'] = $data['syq'];
        $data_job['syqxz_min'] = $data['syqxz_min'];
        $data_job['ygxs'] = $data['ygxs'];
        $data_job['techlevel'] = $data['techlevel'];
        DB::beginTransaction();
        try {
            if ($id) {
                $data_job['audit'] = 2;
                if (!$this->jobfairJobRepository->update($data_job, $id)) {
                    throw new Exception('修改招聘会职位失败');
                }
                if (!$this->jobfairJobsContactRepository->update($data_contact, $id)) {
                    throw new Exception('修改联系方式失败');
                }

                $this->memberLogRepository->createLog($user, 1035, [$id]);
            } else {
                if (!$this->jobfairJobRepository->store($data_job)) {
                    throw new Exception('添加招聘会职位失败');
                }
                $data_contact['pid'] = DB::getPdo()->lastInsertId();
                if (!$this->jobfairJobsContactRepository->store($data_contact)) {
                    throw new Exception('添加联系方式失败');
                }
                $this->memberLogRepository->createLog($user, 1034, $data_contact['pid']);
            }
            DB::commit();
            return response()->json(['status' => 1, 'msg' => $message]);
        } catch (Exception $e) {
            DB::rollback();
            return response()->json(['status' => 0, 'msg' => $e->getMessage()]);
        }
    }

    /**职位添加到招聘会中
     * @param $request
     * @return array
     */
    public function jobfairoutJobsToJobfair($request)
    {
        $jids = $request->y_id;
        if (!$jids || !$request->exid_list) {
            return ['state'=>0,'msg'=>'请选择职位或加入的招聘会'];
        }
        $exidArr = explode(',', $request->exid_list);
        $exInfo = $this->jobfairoutCompanyRepository->findWhereIn('id', $exidArr, ['id','company_id','jobfair_id'])->toArray();
        $jobsInfo = $this->jobfairJobRepository->findWhereIn('id', $jids)->toArray();
        $jobName = [];
        foreach ($jobsInfo as $key => $val) {
            if ($val['audit'] != 1) {
                $jobName[]=$val['jobs_name'];
            }
        }
        if ($jobName) {
            return ['state'=>0,'msg'=>'【'.implode('、', $jobName).'】的职位状态为审核中或审核失败，无法添加至招聘会'];
        }
        DB::beginTransaction();
        try {
            $error = '';
            foreach ($exInfo as $key => $val) {
                $insert_data = [];
                foreach ($jobsInfo as $ke => $va) {
                    $doneArr = $this->jobfairoutPutJobRepository->findDone(['job_id'=>$va['id'], 'exid'=>$val['id'], 'jobfair_id'=>$val['jobfair_id']]);
                    if ($doneArr) {
                        $error .=  '【'.$doneArr->jobs->jobs_name.'】';
//                        return ['state'=>0,'msg'=>'【'.$doneArr->jobs->jobs_name.'】，已添加至举行的招聘会中，不可重复添加'];
                        continue;
                    }
                    $insert_data['exid'] = $val['id'];
                    $insert_data['jobfair_id'] = $val['jobfair_id'];
                    $insert_data['job_id'] = $va['id'];
                    $insert_data['jobs_name'] = $va['jobs_name'];
                    $insert_data['company_id'] = $va['company_id'];
                    $insert_data['company_name'] = $va['company_name'];
                    $insert_data['company_audit'] = $va['company_audit'];
                    $insert_data['stick'] = $va['stick'];
                    $insert_data['nature'] = $va['nature'];
                    $insert_data['nature_cn'] = $va['nature_cn'];
                    $insert_data['sex'] = $va['sex'];
                    $insert_data['sex_cn'] = $va['sex_cn'];
                    $insert_data['age'] = $va['age'];
                    $insert_data['amount'] = $va['amount'];
                    $insert_data['topclass'] = $va['topclass'];
                    $insert_data['category'] = $va['category'];
                    $insert_data['subclass'] = $va['subclass'];
                    $insert_data['category_cn'] = $va['category_cn'];
                    $insert_data['trade'] = $va['trade'];
                    $insert_data['trade_cn'] = $va['trade_cn'];
                    $insert_data['scale'] = $va['scale'];
                    $insert_data['scale_cn'] = $va['scale_cn'];
                    $insert_data['district'] = $va['district'];
                    $insert_data['district_cn'] = $va['district_cn'];
                    $insert_data['tag'] = $va['tag'];
                    $insert_data['tag_cn'] = $va['tag_cn'];
                    $insert_data['education'] = $va['education'];
                    $insert_data['education_cn'] = $va['education_cn'];
                    $insert_data['experience'] = $va['experience'];
                    $insert_data['experience_cn'] = $va['experience_cn'];
                    $insert_data['wage'] = $va['wage'];
                    $insert_data['wage_min'] = $va['wage_min'];
                    $insert_data['wage_max'] = $va['wage_max'];
                    $insert_data['wage_cn'] = $va['wage_cn'];
                    $insert_data['jobs_content'] = $va['jobs_content'];
                    $insert_data['audit'] = $va['audit'];
                    $insert_data['display'] = $va['display'];
                    $insert_data['click'] = $va['click'];
                    $insert_data['robot'] = $va['robot'];
                    $insert_data['map_x'] = $va['map_x'];
                    $insert_data['map_y'] = $va['map_y'];
                    $insert_data['map_zoom'] = $va['map_zoom'];
                    $insert_data['add_mode'] = $va['add_mode'];
                    $insert_data['is_entrust'] = $va['is_entrust'];
                    $insert_data['department'] = $va['department'];
                    $insert_data['major'] = $va['major'];
                    $insert_data['major_cn'] = $va['major_cn'];
                    $insert_data['zcid'] = $va['zcid'];
                    $insert_data['zc_cn'] = $va['zc_cn'];
                    $insert_data['zc_name'] = $va['zc_name'];
                    $insert_data['syq'] = $va['syq'];
                    $insert_data['syqxz_min'] = $va['syqxz_min'];
                    $insert_data['ygxs'] = $va['ygxs'];
                    $insert_data['techlevel'] = $va['techlevel'];
                    if (!$inser_id = $this->jobfairoutPutJobRepository->create($insert_data)) {
                        throw new \Exception($va['jobs_name'] . '添加失败');
                    }
                }
            }
            if($error){
                $error .= '已添加至举行的招聘会中，不可重复添加';
            }
            DB::commit();
        } catch (\Exception $e) {
            DB::rollback();
            return ['state'=>0,'msg'=>$e->getMessage()];
        }
        return ['state'=>1,'msg'=>'添加成功','error'=>$error];
    }

    public function isOwn($idsArr,$user)
    {
        $jobsIdArr = $this->jobfairJobRepository->getPluck(['company_id'=>$user->id],'id')->toArray();
        if(array_diff($idsArr,$jobsIdArr))
        {
            throw new ResponseException('抱歉，您只能操作自己的招聘会职位！');
        }
    }
}