jya-oa-api/application/common/model/Approval.php

<?php
namespace app\common\model;

use app\hander\HelpHander;
use think\Db;
use think\Exception;
use think\Model;

class Approval extends Model
{

    public function add(){
        $data = [
            'id' => input('id/d',0),
            'org_id' => input('orgId/d',0),
            'title' => input('title','','trim'),
            'cate_id' => input('cateId/d','0'),
            'icon' => input('icon','','trim'),
            'remark' => input('remark','','trim'),
            'approval_tips' => input('approvalTips','','trim'),
            'approval_required' => input('approvalRequired/d',0),
            'approval_visible' => input('approvalVisible/d',0),
            'form_json' => input('formJson','','trim'),
            'flow_json' => input('flowJson','','trim'),
            'type_Id' => input('typeId/d',0),
            'advanced' => input('advanced/d',0),
            'approvalSponsor' => input('approvalSponsor','','trim'),
            'max_day' => input('maxDay/d',0)
        ];

        $logdata = json_encode($data);

        $result = validate('Approval')->check($data,[],'add');
        if(true !== $result){
            HelpHander::error(validate('Approval')->getError());
        }

        $approvalSponsor = $data['approvalSponsor'];
        unset($data['approvalSponsor']);
        $id = $data['id'];
        unset($data['id']);

        $this->startTrans();
        try{
            $approvalId = $id;
            if($id > 0){
                $data['update_time'] = date('Y-m-d H:i:s');
                $ret = $this->allowField(true)->save($data,['id'=>$id]);
            }else{
                $data['create_time'] = date('Y-m-d H:i:s');
                $ret = $this->allowField(true)->save($data);
                $approvalId = $this->id;
            }
            if(!$ret){
                \exception('数据保存失败');
            }

            // 添加权限
            if($id > 0){
                Db::name('approval_sponsor')->where('approval_id',$id)->delete();
            }
            $approvalSponsor = json_decode($approvalSponsor,true);
            $sponsor = [];
            foreach ($approvalSponsor as $k=>$v){
                $sponsor[] = [
                    'sponsor_id' => $v['sponsorId'],
                    'approval_id' => $approvalId,
                    'type' => $v['type'],
                    'org_id' => $data['org_id']
                ];
            }
            Db::name('approval_sponsor')->insertAll($sponsor);

            $this->commit();
        }catch (Exception $e){
            $this->rollback();
            HelpHander::error('操作失败'.$e->getMessage());
        }

        if($id > 0){
            $content = '修改审批流程';
        }else{
            $content = '添加审批流程';
        }
        model('ActionLog')->add(2,$content,0,$logdata);

        return true;
    }

    public function lists($orgId){
        if($orgId){
            $map[] = ['org_id','=',$orgId];
        }
        $map[] = ['del','=',0];
        $lists = $this
            ->where($map)
            ->order('id asc')
            ->select();
        return $lists?$lists->toArray():[];
    }

    public function info($id,$userId,$orgId){
        $info = $this->where('id',$id)->where('del',0)->find();
        if(!$info){
            HelpHander::error('数据不存在');
        }
        $info = $info->toArray();
        $approvalSponsor = Db::name('approval_sponsor')->where('approval_id',$id)->select();
        $info['approval_sponsor'] = $approvalSponsor;

        $info['dep_list'] = model('Dep')->getUserDep($userId,$orgId);

        $flowJson = json_decode($info['flow_json'],true);
        $nodeList = $flowJson['nodeList'];
        $flowJson['nodeList'] = $this->formatNodeList($nodeList,$userId);

        $info['flow_json'] = json_encode($flowJson,JSON_UNESCAPED_UNICODE);

        if($info['advanced'] == 19){ //中心发文,把当前编号添加的选择项中
            $maxsn1 = Db::name('post_apply')
                ->where('status',1)
                ->where('type','新华')
                ->where('year',date('Y'))
                ->order('id desc')
                ->value('sn');
            $sn1 = $maxsn1>0?$maxsn1 + 1:1;

            $maxsn2 = Db::name('post_apply')
                ->where('status',1)
                ->where('type','新华人字')
                ->where('year',date('Y'))
                ->order('id desc')
                ->value('sn');
            $sn2 = $maxsn2>0?$maxsn2 + 1:1;

            $defaultOptions = [
                ['idx'=>1,'text'=>'发改基建'],
                ['idx'=>2,'text'=>'发改基人'],
                ['idx'=>3,'text'=>'新华['.$sn1.']号'],
                ['idx'=>4,'text'=>'新华人字['.$sn2.']号'],
            ];

            $formJson = json_decode($info['form_json'],true);
            foreach ($formJson as $k=>$v){
                if($v['componentName'] == 'ddpostfield'){
                    foreach ($v['components'] as $kk => $vv){
                        if($vv['idx'] == 0){
                            $formJson[$k]['components'][$kk]['defaultOptions'] = $defaultOptions;
                        }
                    }
                }
            }

            $info['form_json'] = json_encode($formJson,JSON_UNESCAPED_UNICODE);
        }
        trace($info);
        return $info;
    }

    // 格式化节点人员
    private function formatNodeList($nodeList,$userId){
        foreach ($nodeList as $k=>$v){
            if($v['type'] == 2){ // 审批节点
                $approval = $v['approval'];

                // 1=指定成员 2=角色 3=主管 4=发起人自选 5=发起人自己
                $users = [];
                if($approval['type'] == 1){ //指定成员
                    if(!empty($approval['selectUser'])){
                        foreach ($approval['selectUser'] as $key=>$val){
                            $users[] = [
                                'name' => $val['name'],
                                'userId' => $val['id']
                            ];
                        }
                    }
                } else if($approval['type'] == 2){ //角色
                    if(!empty($approval['rolesId'])){
                        $users = Db::name('user_roles')
                            ->alias('ur')
                            ->join('user u','u.id = ur.user_id')
                            ->join('user_info ui','u.id = ui.user_id')
                            ->where('ur.roles_id',$approval['rolesId'])
                            ->where('u.del',0)
                            ->where('u.enable',1)
                            ->field('u.id as userId,ui.name')
                            ->select();
                        $users = $users?$users:[];
                    }
                } else if ($approval['type'] == 3){ //主管
                    $leaderids = Db::name('user_job')
                        ->alias('uj')
                        ->join('job j','j.id = uj.job_id')
                        ->where('uj.user_id',$userId)
                        ->where('j.del',0)
                        ->where('j.enable',1)
                        ->column('j.leader');
                    if($leaderids){
                        $jobs = Db::name('job')
                            ->where('del',0)
                            ->where('enable',1)
                            ->where('id','in',$leaderids)
                            ->field('id,name')
                            ->select();
                        $jobs = $jobs?$jobs:[];
                        foreach ($jobs as $kk=>$vv){
                            $userNameDtos = Db::name('user_job')
                                ->alias('uj')
                                ->join('user u','uj.user_id = u.id')
                                ->join('user_info ui','ui.user_id = u.id')
                                ->where('uj.job_id',$vv['id'])
                                ->where('u.del',0)
                                ->where('u.enable',1)
                                ->field('u.id as userId,ui.name')
                                ->select();
                            $jobs[$kk]['userNameDtos'] = $userNameDtos?$userNameDtos:[];
                        }
                        $users = $jobs;
                    }
                } else if ($approval['type'] == 4){ //发起人自选
                    if($approval['optionalMode'] == 2){ // 指定人员
                        if($approval['optionalUsers']){
                            foreach ($approval['optionalUsers'] as $key=>$val){
                                $users[] = [
                                    'name' => $val['name'],
                                    'userId' => $val['id']
                                ];
                            }
                        }
                    } else if($approval['optionalMode'] == 3){ // 指定角色
                        if(!empty($approval['optionalRolesId'])){
                            $users = Db::name('user_roles')
                                ->alias('ur')
                                ->join('user u','u.id = ur.user_id')
                                ->join('user_info ui','u.id = ui.user_id')
                                ->where('ur.roles_id',$approval['optionalRolesId'])
                                ->where('u.del',0)
                                ->where('u.enable',1)
                                ->field('u.id as userId,ui.name')
                                ->select();
                            $users = $users?$users:[];
                        }
                    }
                }
                $approval['approverList'] = $users;

                $nodeList[$k]['approval'] = $approval;
            }
        }
        return $nodeList;
    }

    public function del($id){
        $ret = $this->where('id',$id)->setField('del',1);
        if(!$ret){
            HelpHander::error('删除失败');
        }
        $logdata = json_encode(['id' => $id]);
        model('ActionLog')->add(2,'删除审批流程',0,$logdata);

        return true;
    }

    public function changeStatus($id,$enable){
        $ret = $this->where('id',$id)->setField('enable',$enable);
        if(!$ret){
            HelpHander::error('操作失败');
        }
        return true;
    }

    // 获取用户流程
    public function queryApprovalCateList($userId,$orgId){
        // 获取用户的部门及所有上级部门
        $depids = model('Dep')->getUserDepIds($userId,$orgId);
        $map1 = [
            ['type','=',2],
            ['org_id','=',$orgId]
        ];
        $map2 = [
            ['type','=',0],
            ['sponsor_id','=',$userId]
        ];
        if(!$depids){
            $depids = [-1]; // 未开查询
        }
        $map3 = [
            ['type','=',1],
            ['sponsor_id','in',$depids]
        ];
        $approvalIds = Db::name('approval_sponsor')->whereOr([$map1, $map2, $map3])->column('approval_id');

        $lists = Db::name('approval_cate')
            ->where('org_id',$orgId)
            ->field('id,name')
            ->order('sort asc,id asc')
            ->select();
        $lists = $lists?$lists:[];
        $lists[] = [
            'id' => 0,
            'name' => '综合'
        ];

        $map[] = ['del','=',0];
        $map[] = ['enable','=',1];
        if($approvalIds){
            $map[] = ['id','in',$approvalIds];
        }
        foreach ($lists as $k=>$v){
            $approvalList = Db::name('approval')
                ->where('cate_id',$v['id'])
                ->where($map)
                ->field('id,title,remark,cate_id,icon')
                ->order('sort asc,id asc')
                ->select();
            $approvalList = $approvalList?$approvalList:[];
            foreach ($approvalList as $kk=>$vv){
                $approval_sponsor = Db::name('approval_sponsor')->where('approval_id',$vv['id'])->select();
                $approvalList[$kk]['approval_sponsors'] = $approval_sponsor?$approval_sponsor:[];
            }
            $lists[$k]['approval_sponsor_dto_list'] = $approvalList?$approvalList:[];
        }
        return $lists;

    }
}