hcsl/app/Service/EmployeeService.php

<?php

namespace App\Service;

use App\Model\Depart;
use App\Model\DXJ;
use App\Model\Employee;
use App\Model\EmployeeDepartPermission;
use App\Model\EmployeeManagerDepart;
use App\Model\EmployeeMenuPermission;
use App\Model\EmployeeRole;
use App\Model\EmployeeTeamPermission;
use App\Model\Role;
use App\Model\Setting;
use App\Model\SysMenu;
use App\Model\Team;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Hash;

/**
 * 人员相关
 * @package App\Models
 */
class EmployeeService extends Service
{
    public function employeeEdit($data,$user){
        list($status,$msg) = $this->employeeRule($data,false);
        if(!$status) return [$status,$msg];

        $model = new Employee();
        $model = $model->where('id',$data['id'])->first();
        $model->id_card = $data['id_card']??'';
        $model->number = $data['number'] ;
        $model->mobile = $data['mobile']??'';
        $model->emp_name = $data['emp_name'];
        $model->is_admin = $data['is_admin'];
        if($model->is_admin == 1){
            $model->account = $data['number'];
            if($data['password'] !== '********'){
                $model->password = Hash::make($data['password']);
            }
            $model->sqlserver_account = $data['sqlserver_account'] ?? '';
            if(! empty($data['sqlserver_password']) && $data['sqlserver_password'] !== '********'){
                $model->sqlserver_password = $data['sqlserver_password'];
            }else{
                $model->sqlserver_password = '';
            }
        }
        $model->save();

        $permisson_model = new EmployeeDepartPermission();
        $permisson_model = $permisson_model->where('employee_id',$data['id'])->first();
        if($permisson_model){
            $permisson_model->depart_id = $data['depart_id'] ?? 0;
            $permisson_model->save();
        }else{
            $permisson_model = new EmployeeDepartPermission();
            $permisson_model->employee_id = $data['id'];
            $permisson_model->depart_id = $data['depart_id'] ?? 0;
            $permisson_model->save();
        }

        return [true,'保存成功！'];
    }

    public function employeeAdd($data,$user){
        list($status,$msg) = $this->employeeRule($data);
        if(!$status) return [$status,$msg];

        $model = new Employee();
        $model->id_card = $data['id_card']??'';
        $model->number = $data['number'] ;
        $model->mobile = $data['mobile']??'';
        $model->emp_name = $data['emp_name'];
        $model->state = 1;
        $model->crt_id = $user['id'];
        $model->is_admin = $data['is_admin'];
        if($model->is_admin == 1){
            $model->account = $data['number'];
            $model->password   = Hash::make($data['password']);
            $model->sqlserver_account = $data['sqlserver_account'] ?? '';
            $model->sqlserver_password = $data['sqlserver_password'] ?? '';
        }
        $model->save();

        if(! empty($data['depart_id'])){
            $permisson_model = new EmployeeDepartPermission();
            $permisson_model->employee_id = $model->id;
            $permisson_model->depart_id = $data['depart_id'];
            $permisson_model->save();
        }

        return [true,'保存成功！'];
    }

    public function employeeDel($data){
        if($this->isEmpty($data,'id')) return [false,'ID必须！'];

        Employee::where('id',$data['id'])->update([
            'del_time'=>time()
        ]);

        return [true,'删除成功'];
    }

    public function employeeList($data){
        $model = Employee::where('del_time',0)
            ->select('id_card','emp_name','mobile','crt_time','account','is_admin','upd_time','id','number','sqlserver_account','sqlserver_password')
            ->orderBy('id','desc');

        if(! empty($data['depart_id'])) {
            $depart = Depart::where('del_time',0)
                ->select('id','parent_id')
                ->get()->toArray();
            $result = array_merge($this->getAllDescendants($depart,$data['depart_id']),[$data['depart_id']]);
            $employee_id = DB::table('employee_depart_permission')
                ->whereIn("depart_id", $result)
                ->select("employee_id")
                ->get()->toArray();
            $employee_id = array_column($employee_id,'employee_id');
            $model->whereIn("id", $employee_id);
        }
        if(! empty($data['number'])) $model->where('number', 'LIKE', '%'.$data['number'].'%');
        if(! empty($data['emp_name'])) $model->where('emp_name', 'LIKE', '%'.$data['emp_name'].'%');

        $list = $this->limit($model,'',$data);

        //组织数据
        $list = $this->organizationEmployeeData($list);

        return [200,$list];
    }

    public function organizationEmployeeData($data) {
        if (empty($data['data'])) return $data;

        $res = DB::table('employee_depart_permission as a')
            ->select('a.employee_id','b.title','b.id')
            ->join('depart as b','a.depart_id','=','b.id')
            ->whereIn("a.employee_id",array_column($data['data'],'id'))
            ->get()->toArray();
        $map = array_column($res,null,'employee_id');

        $res = DB::table('employee_team_permission as a')
            ->select('a.employee_id','b.title','b.id')
            ->join('team as b','a.team_id','=','b.id')
            ->whereIn("a.employee_id",array_column($data['data'],'id'))
            ->get()->toArray();
        $map2 = array_column($res,null,'employee_id');

        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['depart_id'] = $map[$value['id']]->id ?? '';
            $data['data'][$key]['depart_title'] = $map[$value['id']]->title ?? '';
            $data['data'][$key]['has_pwd'] = $value['sqlserver_password'] ? 1 : 0;
            unset($data['data'][$key]['sqlserver_password']);
        }
        return $data;
    }

    public function employeeRule($data,$is_add = true){
        if($this->isEmpty($data,'number')) return [false,'工号不存在！'];
        if($this->isEmpty($data,'emp_name')) return [false,'姓名不存在！'];
        if(! $is_add){
            if($this->isEmpty($data,'id')) return [false,'ID不能为空！'];
            $bool = Employee::where('number',$data['number'])
                ->where('id','<>',$data['id'])
                ->where('del_time',0)->exists();
        }else{
            $bool = Employee::where('number',$data['number'])
                ->where('del_time',0)->exists();
        }
        if($bool) return [false,'工号已存在！'];

        return [true,''];
    }

    public function roleEdit($data){
        list($status,$msg) = $this->roleRule($data);
        if(!$status) return [$status,$msg];
        $first = Role::where('title',$data['title'])->where('id','<>',$data['id'])->where('del_time',0)->first();
        if(!empty($first))return [false,'名称已存在！'];

        $model = new Role();
        $model = $model->where('id',$data['id'])->first();

        $model->title = $data['title'];
        $model->save();
        return [true,'保存成功！'];

    }

    public function roleAdd($data,$user){


//        if($this->isEmpty($data,'title')) return [201,'名称不存在！'];
        list($status,$msg) = $this->roleRule($data);
        if(!$status) return [$status,$msg];
        $first = SysMenu::where('title',$data['title'])->where('del_time',0)->first();
        if(!empty($first))return [false,'名称已存在！'];

        $model = new Role();

        $model->title = $data['title'] ;

        $model->save();

        return [true,'保存成功！'];

    }

    public function roleDel($data){
        if($this->isEmpty($data,'id')) return [false,'ID必须！'];

        Role::where('id',$data['id'])->update([
            'del_time'=>time()
        ]);

        return [true,'删除成功'];
    }

    public function roleList($data){
        $list = Role::where('del_time',0)->select('title','title','crt_time','id','upd_time')->orderBy('id','desc');

        $list = $this->limit($list,'',$data);

        return [200,$list];
    }

    public function roleRule($data){
        if($this->isEmpty($data,'title')) return [false,'名称不存在！'];

        return [true,''];
    }

    public function departEdit($data){
        list($status,$msg) = $this->departRule($data,false);
        if(!$status) return [$status,$msg];

        $update = $msg['data'][0];

        $model = new Depart();
        $model->where('id',$data['id'])->update($update);

        return [true,'保存成功！'];
    }

    public function departAdd($data){
        list($status,$msg) = $this->departRule($data);
        if(!$status) return [$status,$msg];

        Depart::insert($msg['data']);

        return [true,'保存成功！'];
    }

    public function departDel($data){
        list($status,$msg) = $this->checkDepartDel($data);
        if(! $status) return [false, $msg];

        Depart::whereIn('id',$data['id'])->update([
            'del_time'=>time()
        ]);

        return [true,'删除成功'];
    }

    public function departList($data){
        $model = Depart::where('del_time',0)
            ->select('title','id','code','parent_id','is_use')
            ->orderby('code', 'asc');
        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
        if(! empty($data['code'])) $model->where('code', 'LIKE', '%'.$data['code'].'%');

        $list = $model->get()->toArray();
        if(! empty($list)) {
            $list = $this->makeTree(0,$list);
            $list = $this->set_sort_circle($list);
        }

        return [200,$list];
    }

    public function departRule($data, $is_check = true){
        if($this->isEmpty($data,'data')) return [false,'数据不能为空！'];

        $code = array_column($data['data'],'code');
        $title = array_column($data['data'],'title');
        $code = array_map(function($val) {
            return $val !== null ? $val : 0;
        }, $code);
        $title = array_map(function($val) {
            return $val !== null ? $val : 0;
        }, $title);
        $code_count = array_count_values($code);
        $title_count = array_count_values($title);
        foreach ($code as $value){
            if(empty($value)) return [false,'编码不能为空！'];
            if($code_count[$value] > 1) return [false,'编码不能重复'];
        }
        foreach ($title as $value){
            if(empty($value)) return [false,'名称不能为空！'];
            if($title_count[$value] > 1) return [false,'名称不能重复'];
        }

        $depart_id = array_filter(array_column($data['data'],'parent_id'));
        $res = $this->checkDepartHasPerson($depart_id);
        if($res) return [false,'部门下已有人员,不能新建子部门！'];

        foreach ($data['data'] as $key => $value){
            if(empty($value['parent_id'])) $data['data'][$key]['parent_id'] = 0;

            $data['data'][$key]['upd_time'] = time();
            if($is_check){
                $data['data'][$key]['crt_time'] = time();
                $bool = Depart::whereRaw("(binary code = '{$value['code']}' OR title = '{$value['title']}')")
                    ->where('del_time',0)
                    ->exists();
            }else{
                if($this->isEmpty($data,'id')) return [false,'id不能为空！'];

                if(! $value['is_use']) {
                    $bool_is = $this->checkDepartHasPerson([$data['id']]);
                    if($bool_is) return [false,'部门下已经有人员，停用失败！'];
                }
                $bool = Depart::whereRaw("(binary code = '{$value['code']}' OR title = '{$value['title']}')")
                    ->where('id','<>',$data['id'])
                    ->where('del_time',0)
                    ->exists();
            }
            if($bool) return [false,'编码或部门名称不能重复'];
        }

        return [true, $data];
    }

    public function checkDepartDel($data){
        if($this->isEmpty($data,'id')) return [false,'ID必须！'];

        $bool = Depart::whereIn('parent_id',$data['id'])->where('del_time',0)->exists();
        if($bool) return [false,'部门下有子部门！'];

        if($this->checkDepartHasPerson($data['id'])) return [false,'部门下有人员档案！'];

        return [true, ''];
    }

    //检测部门下是否存在人员
    public function checkDepartHasPerson($depart_id = []){
        if(empty($depart_id)) return false;

        $bool = EmployeeDepartPermission::from('employee_depart_permission as a')
            ->leftJoin('employee as b','b.id','a.employee_id')
            ->where('b.del_time',0)
            ->whereIn('a.depart_id',$depart_id)
            ->exists();

        return $bool;
    }

    public function teamEdit($data){
        list($status,$msg) = $this->teamRule($data,false);
        if(!$status) return [$status,$msg];

        $model = new Team();
        $model = $model->where('id',$data['id'])->first();
        $model->title = $data['title'];
        $model->code = $data['code'];
        $model->save();

        return [true,'保存成功！'];
    }

    public function teamAdd($data,$user){
        list($status,$msg) = $this->teamRule($data);
        if(!$status) return [$status,$msg];

        $model = new Team();
        $model->title = $data['title'] ;
        $model->code = $data['code'];
        $model->save();

        return [true,'保存成功！'];
    }

    public function teamDel($data){
        if($this->isEmpty($data,'id')) return [false,'ID必须！'];

        Team::where('id',$data['id'])->update([
            'del_time'=>time()
        ]);

        return [true,'删除成功'];
    }

    public function teamList($data){
        $list = Team::where('del_time',0)->select('title','id','crt_time','upd_time','code')->orderBy('id','desc');

        $list = $this->limit($list,'',$data);

        return [200,$list];
    }

    public function teamRule($data,$is_add = true){
        if($this->isEmpty($data,'title')) return [false,'名称不存在！'];
        if($this->isEmpty($data,'code')) return [false,'编码不存在'];

        $model = Team::where('title',$data['title'])
            ->where('code',$data['code'])
            ->where('del_time',0);
        if(! $is_add){
            if($this->isEmpty($data,'id')) return [false,'ID不能为空'];
            $model->where('id','<>',$data['id']);
        }
        $bool = $model->exists();
        if($bool) return [false,'名称和编码已存在！'];

        return [true,''];
    }

    public function teamDetail($data){
        if($this->isEmpty($data,'id')) return [false,'ID不能为空！'];

        $result = EmployeeTeamPermission::from('employee_team_permission as a')
            ->leftJoin('employee as b','b.id','a.employee_id')
            ->where('team_id',$data['id'])
            ->select('b.id','b.emp_name','b.number as code')
            ->get()->toArray();

        return [true,$result];
    }

    public function employeeRole($data){
        $role_ids = [];
        $employee_ids = [];
        foreach ($data as $v){
            if(isset($v['role_id'])){
                if(!in_array($v['role_id'],$role_ids)){
                    $role_ids[] = $v['role_id'];
                }
            }

            if(isset($v['employee_id'])){
                if(!in_array($v['employee_id'],$employee_ids)){
                    $employee_ids[] = $v['employee_id'];
                }
            }
        }

        EmployeeMenuPermission::wherein('role_id',$role_ids)->delete();
        EmployeeMenuPermission::wherein('employee_id',$employee_ids)->delete();


        EmployeeMenuPermission::insert($data);

        return [200,'保存成功!'];

    }

    public function employeeDepart($data){
        if($this->isEmpty($data,'insert')) return [false,'数据不能为空！'];

        DB::beginTransaction();
        try {
            if($data['type'] == 1){
                EmployeeDepartPermission::whereIn('depart_id',$data['insert']['depart_id'])->delete();
            }else{
                EmployeeDepartPermission::whereIn('employee_id',$data['insert']['employee_id'])->delete();
            }

            $insert = [];
            foreach ($data['insert']['depart_id'] as $t){
                foreach ($data['insert']['employee_id'] as $e){
                    $insert[] = [
                        'depart_id' => $t,
                        'employee_id' => $e
                    ];
                }
            }
            EmployeeDepartPermission::insert($insert);

            DB::commit();
        }catch (\Throwable $exception){
            DB::rollBack();
            return [false,$exception->getMessage()];
        }

        return [true,'保存成功!'];
    }

    public function employeeTeam($data){
        if($this->isEmpty($data,'insert')) return [false,'数据不能为空！'];

        DB::beginTransaction();
        try {
            if($data['type'] == 1){
                EmployeeTeamPermission::whereIn('team_id',$data['insert']['team_id'])->delete();
            }else{
                EmployeeTeamPermission::whereIn('employee_id',$data['insert']['employee_id'])->delete();
            }

            $insert = [];
            foreach ($data['insert']['team_id'] as $t){
                foreach ($data['insert']['employee_id'] as $e){
                    $insert[] = [
                        'team_id' => $t,
                        'employee_id' => $e
                    ];
                }
            }
            EmployeeTeamPermission::insert($insert);

            DB::commit();
        }catch (\Throwable $exception){
            DB::rollBack();
            return [false,$exception->getMessage()];
        }

        return [true,'保存成功!'];
    }

    public function loginRule($data){
        if($this->isEmpty($data,'account')) return [false,'账号不能为空！'];
        if($this->isEmpty($data,'password')) return [false,'密码不存在！'];

        $account = $data['account'];
        $res = Employee::where('del_time',0)
            ->where(function ($query)use($account) {
                $query->where('account', $account)
                    ->orWhere('emp_name', $account);
            })
            ->get()->toArray();

        if(empty($res)) return [false,'账号不存在或已被删除！'];

        $res = reset($res);
        if(! Hash::check($data['password'], $res['password'])) return [false,'密码错误！'];
        if($res['is_admin'] != Employee::IS_ADMIN) return [false,'该账号不能登录！'];
        if($res['state'] == Employee::NOT_USE) return [false,'账号停用！'];

        return [true, ['id'=>$res['id'], 'name'=>$res['emp_name'], 'account' => $res['account']]];
    }

    public static function checkUser($userId, $psd){
        $res = Employee::where('id', $userId)
            ->where('del_time',0)
            ->where('is_admin',Employee::IS_ADMIN)
            ->where('state',Employee::USE)->get()->first();
        if(empty($res)) return [false, '该账号无法登录,请联系管理员！'];
        if(! Hash::check($psd, $res->password)) return [false,'账号密码失效,请重新登录'];

        return [true, $res];
    }

    //获取登录账号的角色
    public static function getPersonRole($employee_id){
        if(empty($employee_id)) return [];
        $role = EmployeeRole::where('del_time',0)
            ->where('employee_id',$employee_id)
            ->select('role_id')
            ->get()->toArray();

        //组织
        $role_id = array_column($role,'role_id');
        asort($role_id);
        $role_id = array_values($role_id);

        return $role_id;
    }

    //获取登录账号的权限部门
    public static function getPersonDepart($employee_id){
        if(empty($employee_id)) return [];

        //admin账号
        if($employee_id == Employee::SPECIAL_ADMIN) return [Depart::RULE_DEPART];

        //操作人员直接绑定部门
        $employee_manager_depart = EmployeeManagerDepart::where('del_time',0)
            ->where('employee_id',$employee_id)
            ->select('depart_id')
            ->get()->toArray();

        //操作人员绑定角色
        $employee_role = EmployeeRole::from('employee_role as a')
            ->leftJoin('role_depart as b','b.role_id','a.role_id')
            ->select('b.depart_id','b.role_id')
            ->where('a.del_time',0)
            ->where('b.del_time',0)
            ->where('a.employee_id',$employee_id)
            ->get()->toArray();

        return array_filter(array_merge_recursive(array_column($employee_manager_depart,'depart_id'),array_column($employee_role,'depart_id')));
    }

    //人员直接绑定部门
    public function employeeManagerDepart($data,$user){
        if($user['id'] != Employee::SPECIAL_ADMIN) return [false,'非ADMIN账号不能操作'];

        if($this->isEmpty($data,'employee_id')) return [false,'请选择操作人员'];
        if($this->isEmpty($data,'depart_id')) return [false,'请选择部门'];

        EmployeeManagerDepart::where('employee_id',$data['employee_id'])->update([
            'del_time' => time()
        ]);

        $insert = [];
        foreach ($data['depart_id'] as $value){
            $insert[] = [
                'employee_id' => $data['employee_id'],
                'depart_id' => $value,
                'crt_time' => time(),
                'upd_time' => time(),
            ];
        }
        EmployeeManagerDepart::insert($insert);

        return [true,''];
    }

    public function settingList(){
        $model = Setting::select('show_title','setting_name','setting_value')
            ->orderby('sort', 'asc');
        $list = $model->get()->toArray();

        return [true, $list];
    }

    public function settingEdit($data){
        $model = new Setting();
        $model = $model->where('setting_name',$data['setting_name'])->first();
        $model->setting_value = $data['setting_value'];
        $model->save();

        return [true,''];
    }

    public function dxjEdit($data){
        list($status,$msg) = $this->dxjRule($data,false);
        if(!$status) return [$status,$msg];

        $update = $msg['data'][0];

        $model = new DXJ();
        $model->where('id',$data['id'])->update($update);

        return [true,''];
    }

    public function dxjAdd($data){
        list($status,$msg) = $this->dxjRule($data);
        if(!$status) return [$status,$msg];

        DXJ::insert($msg['data']);

        return [true,''];
    }

    public function dxjDel($data){
        DXJ::whereIn('id',$data['id'])->update([
            'del_time'=>time()
        ]);

        return [true,''];
    }

    public function dxjList($data){
        $model = DXJ::where('del_time',0)
            ->select('title','id')
            ->orderby('id', 'asc');
        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');

        $list = $model->get()->toArray();

        return [true, $list];
    }

    public function dxjRule($data, $is_check = true){
        if($this->isEmpty($data,'data')) return [false,'数据不能为空！'];

        $title = array_column($data['data'],'title');
        $title = array_map(function($val) {
            return $val !== null ? $val : 0;
        }, $title);
        $title_count = array_count_values($title);
        foreach ($title as $value){
            if(empty($value)) return [false,'名称不能为空！'];
            if($title_count[$value] > 1) return [false,'名称不能重复'];
        }

        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['upd_time'] = time();
            if($is_check){
                $data['data'][$key]['crt_time'] = time();
                $bool = DXJ::where('title', $value['title'])
                    ->where('del_time',0)
                    ->exists();
            }else{
                if($this->isEmpty($data,'id')) return [false,'id不能为空！'];

                $bool = Depart::where('title', $value['title'])
                    ->where('id','<>',$data['id'])
                    ->where('del_time',0)
                    ->exists();
            }
            if($bool) return [false,'名称不能重复'];
        }

        return [true, $data];
    }

    public function is_auto($user, $column = ""){
        if(empty($column)) return 1;

        //是否自动审核
        $auto = $user['setting'][$column]['setting_value'] ?? 1;
        $auto = intval($auto);
        if($auto >= 1) $auto = 1;
        else $auto = 0;

        return $auto;
    }
}