<?php
/**
+-----------------------------------------------------------------------------------------------
* GouGuOPEN [ 左手研发，右手开源，未来可期！]
+-----------------------------------------------------------------------------------------------
* @Copyright (c) 2021~2024 http://www.gouguoa.com All rights reserved.
+-----------------------------------------------------------------------------------------------
* @Licensed 勾股OA，开源且可免费使用，但并不是自由软件，未经授权许可不能去除勾股OA的相关版权信息
+-----------------------------------------------------------------------------------------------
* @Author 勾股工作室 <hdm58@qq.com>
+-----------------------------------------------------------------------------------------------
*/

declare (strict_types = 1);
namespace app\api\controller;

use app\api\BaseController;
use think\facade\Db;

class Check extends BaseController
{	
	//获取审核流程
    public function get_flows($check_name='')
    {
		$cate_id = Db::name('FlowCate')->where(['name' => $check_name,'status'=>1])->value('id');
        $flow = Db::name('Flow')->where(['cate_id' => $cate_id,'status'=>1,'delete_time'=>0])->select()->toArray();
        return to_assign(0, '', $flow);
    }
	//获取审核步骤人员
    public function get_flow_users($id=0)
    {
        $flow = Db::name('Flow')->where(['id' => $id])->find();
        $flow_data = unserialize($flow['flow_list']);
		if(!empty($flow_data)){
			foreach ($flow_data as $key => &$val) {
				$val['check_position'] = '';
				if($val['check_role'] == 1){
					$val['check_uids'] = get_department_leader($this->uid);
				}
				if($val['check_role'] == 2){
					$val['check_uids'] = get_department_leader($this->uid,1);
				}
				if($val['check_role'] == 3){
					$val['check_position'] = Db::name('Position')->where('id',$val['check_position_id'])->value('title');
					$check_uids = Db::name('Admin')->where(['position_id'=>$val['check_position_id'],'status'=>1])->column('id');
					$val['check_uids'] = implode(',',$check_uids);
				}
				$val['check_uids_info'] = Db::name('Admin')->field('id,name,thumb')->where('id','in',$val['check_uids'])->select()->toArray();
			}
		}
		else{
			$flow_data = [];
		}
		
		$data['copy_uids'] = $flow['copy_uids'];
		$data['copy_unames'] ='';
		if(!empty($flow['copy_uids'])){
			$copy_unames = Db::name('Admin')->where('id', 'in', $flow['copy_uids'])->column('name');
			$data['copy_unames'] = implode(',', $copy_unames);
		}
		$data['flow_data'] = $flow_data;
        return to_assign(0, '', $data);
    }
	
	//提交审批申请
    public function submit_check()
    {
		$param = get_params();
		$flow_cate = Db::name('FlowCate')->where(['name' => $param['check_name']])->find();
		$flow_list = Db::name('Flow')->where('id',$param['flow_id'])->value('flow_list');
		$flow = unserialize($flow_list);
		$subject = $flow_cate['title'];
		$check_table = $flow_cate['check_table'];
		//var_dump($flow);exit;
		//删除原来的审核流程和审核记录
		Db::name('FlowStep')->where(['action_id'=>$param['action_id'],'flow_id'=>$param['flow_id'],'delete_time'=>0])->update(['delete_time'=>time()]);
		Db::name('FlowRecord')->where(['action_id'=>$param['action_id'],'check_table'=>$check_table,'delete_time'=>0])->update(['delete_time'=>time()]);		
		$recordData=array(
			'action_id' => $param['action_id'],
			'check_table' => $check_table,
			'step_id' => 0,
			'check_uid' => $this->uid,
			'flow_id' => $param['flow_id'],
			'check_time' => time(),
			'check_status' => 0,
			'content' => '提交申请',
			'create_time' => time()
		);	
		if (!isset($param['check_uids'])) {
			//非自由审批模式
			$step=[];
			$sort=0;
			foreach ($flow as $key => &$value){
				if($value['check_role'] == 1){
					$value['check_uids'] = get_department_leader($this->uid);
					$value['flow_name'] = '当前部门负责人';
					$value['check_position_id']=0;
				}
				if($value['check_role'] == 2){
					$value['check_uids'] = get_department_leader($this->uid,1);
					$value['flow_name'] = '上级部门负责人';
					$value['check_position_id']=0;
				}
				if($value['check_role'] == 3){
					$check_position = Db::name('Position')->where('id',$value['check_position_id'])->value('title');
					$check_uids = Db::name('Admin')->where(['position_id'=>$value['check_position_id'],'status'=>1])->column('id');
					$value['check_uids'] = implode(',',$check_uids);
					$value['flow_name'] = $check_position;
				}
				if($value['check_role'] == 4){
					$value['flow_name'] = '指定人员';
					$value['check_position_id']=0;
				}
				if($value['check_role'] == 5){
					$value['flow_name'] = '指定人员';
					$value['check_position_id']=0;
					$value['check_types']=1;
				}
				if(!empty($value['check_uids'])){
					$step[]=[
						'action_id' => $param['action_id'],
						'flow_id' => $param['flow_id'],
						'flow_name' => $value['flow_name'],
						'check_position_id' => $value['check_position_id'],
						'check_role' => $value['check_role'],
						'check_types' => $value['check_types'],
						'check_uids' => $value['check_uids'],
						'create_time' => time(),
						'sort'=>$sort					
					];
					$sort++;
				}
			}
			if(empty($step)){
				return to_assign(1,'审批流程设置有问题，无法提交审批申请，请联系HR或者管理员重新设置审批流程');
			}
			$res = Db::name('FlowStep')->strict(false)->field(true)->insertAll($step);
			if($res!=false){
				Db::name('FlowRecord')->strict(false)->field(true)->insertGetId($recordData);
				Db::name($check_table)->strict(false)->field(true)->update([
					'id'=>$param['action_id'],
					'check_flow_id'=>$param['flow_id'],
					'check_status'=>1,
					'check_step_sort'=>0,
					'check_uids'=>$step[0]['check_uids'],
					'check_copy_uids'=>isset($param['check_copy_uids'])?$param['check_copy_uids']:''
				]);
				//发送消息通知
				if($flow_cate['template_id']>0){
					$msg=[
						'from_uid'=>$this->uid,//发送人
						'to_uids'=>$step[0]['check_uids'],//接收人
						'template_id'=>$flow_cate['template_id'],//消息模板ID
						'template_field'=>'0',//消息模板字段
						'content'=>[ //消息内容
							'create_time'=>date('Y-m-d H:i:s'),
							'action_id'=>$param['action_id'],
							'title' => $subject
						]
					];
					event('SendMessage',$msg);
				}
				return to_assign();
			}
			else{
				return to_assign(1,'操作失败');
			}
		}
		else{
			//自由审批模式
			$flow_step = array(
				'action_id' => $param['action_id'],
				'flow_id' => $param['flow_id'],
				'flow_name' => '自由审批',
				'check_uids' => $param['check_uids'],
				'create_time' => time()
			);
			$res = Db::name('FlowStep')->strict(false)->field(true)->insertGetId($flow_step);
			if($res!=false){
				Db::name('FlowRecord')->strict(false)->field(true)->insertGetId($recordData);
				Db::name($check_table)->strict(false)->field(true)->update([
					  'id'=>$param['action_id'],
					  'check_flow_id'=>$param['flow_id'],
					  'check_status'=>1,
					  'check_step_sort'=>0,
					  'check_uids'=>$param['check_uids'],
					  'check_copy_uids'=>isset($param['check_copy_uids'])?$param['check_copy_uids']:''
				]);
				//发送消息通知
				if($flow_cate['template_id']>0){
					$msg=[
						'from_uid'=>$this->uid,//发送人
						'to_uids'=>$param['check_uids'],//接收人
						'template_id'=>$flow_cate['template_id'],//消息模板ID
						'template_field'=>'0',//消息模板字段
						'content'=>[ //消息内容
							'create_time'=>date('Y-m-d H:i:s'),
							'action_id'=>$param['action_id'],
							'title' => $subject
						]
					];
					event('SendMessage',$msg);
				}
				return to_assign();
			}
			else{
				return to_assign(1,'操作失败');
			}
		}
	}
	
	//获取审核流程节点
    public function get_flow_nodes($check_name='',$action_id=0,$flow_id=0)
    {		
		$flow_cate = Db::name('FlowCate')->where(['name' => $check_name])->find();
		if($action_id==0){
			$did = $this->did;
			$map = [];
			$map[] = ['cate_id','=',$flow_cate['id']];
			$map[] = ['status','=',1];
			$map[] = ['delete_time','=',0];		
			$map1=[
				['department_ids','=','']
			];
			$map2=[
				['', 'exp', Db::raw("FIND_IN_SET('{$did}',department_ids)")]
			];
			$whereOr =[$map1,$map2];
			$flow = Db::name('Flow')
				->where($map)
				->where(function ($query) use($whereOr) {
					if (!empty($whereOr)){
						$query->whereOr($whereOr);
					}
				})
				->select()->toArray();
			return to_assign(0, '', $flow);
		}
		$check_table = $flow_cate['check_table'];
		$detail = Db::name($check_table)->where('id',$action_id)->field('id,admin_id,check_status,check_flow_id,check_step_sort,check_uids,check_copy_uids')->find();
		//创建人
		$is_creater=0;
		if($detail['admin_id'] == $this->uid){
			$is_creater=1;
		}
		$detail['is_creater'] = $is_creater;
		$detail['admin_name'] = Db::name('Admin')->where('id',$detail['admin_id'])->value('name');
		//当前审批人
		$is_checker=0;
		if(in_array($this->uid,explode(',',$detail['check_uids']))){
			$is_checker=1;
		}
		$detail['is_checker'] = $is_checker;
		//审批记录
		$check_record = Db::name('FlowRecord')
						->field('f.*,a.name')
						->alias('f')
						->join('Admin a', 'a.id = f.check_uid', 'left')
						->where(['f.action_id' => $action_id,'f.check_table'=>$check_table])->select()->toArray();				
		foreach ($check_record as $kk => &$vv) {		
			$vv['check_time_str'] = date('Y-m-d H:i', $vv['check_time']);
			$vv['status_str'] = '提交';
			if($vv['check_status'] == 1){
				$vv['status_str'] = '审核通过';
			}
			else if($vv['check_status'] == 2){
				$vv['status_str'] = '审核拒绝';
			}
			if($vv['check_status'] == 3){
				$vv['status_str'] = '撤销';
			}
			if($vv['check_status'] == 4){
				$vv['status_str'] = '反确认';
			}
		}
		$detail['check_record'] = $check_record;
		if($detail['check_status']==0 || $detail['check_status']==4){
			$flow = Db::name('Flow')->where(['cate_id' => $flow_cate['id'],'status'=>1,'delete_time'=>0])->select()->toArray();
			$detail['flow'] = $flow;
		}
		else{				
			//当前审批人
			$detail['check_unames']='-';
			if(!empty($detail['check_uids'])){
				$check_unames = Db::name('Admin')->where('id','in',$detail['check_uids'])->column('name');
				$detail['check_unames'] = implode(',',$check_unames);
			}
			//抄送人
			$detail['copy_unames']='-';
			if(!empty($detail['check_copy_uids'])){
				$copy_uids = Db::name('Admin')->where('id','in',$detail['check_copy_uids'])->column('name');
				$detail['copy_unames'] = implode(',',$copy_uids);
			}
			
			//审批节点步骤
			$nodes = Db::name('FlowStep')->where(['action_id'=>$action_id,'flow_id'=>$flow_id,'delete_time'=>0])->order('sort asc')->select()->toArray();
			foreach ($nodes as $key => &$val) {
				$check_uids_info = Db::name('Admin')->field('id,name,thumb')->where('id','in',$val['check_uids'])->select()->toArray();						
				foreach ($check_uids_info as $k => &$v) {
					$v['check_time'] = 0;
					$v['content'] = '';
					$v['check_status'] = 0;			
					$check_array = Db::name('FlowRecord')->where(['check_uid' => $v['id'],'step_id' => $val['id']])->order('check_time desc')->select()->toArray();
					if(!empty($check_array)){
						$checked = $check_array[0];
						$v['check_time'] = date('Y-m-d H:i', $checked['check_time']);
						$v['content'] = $checked['content'];
						$v['check_status'] = $checked['check_status'];	
					}
				}
				$val['check_uids_info'] = $check_uids_info;
				
				if(!empty($val['check_position_id'])){
					$val['check_position'] = Db::name('Position')->where('id',$val['check_position_id'])->value('title');
				}
				else{
					$val['check_position'] = '';
				}

				$check_list = [];
				foreach ($check_record as $kkk => $vvv) {
					if($vvv['step_id'] == $val['id'])
					$check_list[] = $vvv;
				}
				$val['check_list'] = $check_list;
			}
			$detail['nodes'] = $nodes;
			
			//当前审核节点
			$step = Db::name('FlowStep')->where(['action_id'=>$action_id,'flow_id'=>$flow_id,'sort'=>$detail['check_step_sort'],'delete_time'=>0])->find();
			$detail['step'] = $step;
		}
        return to_assign(0, '', $detail);
    }
	
    //流程审核
    public function flow_check()
    {
        $param = get_params();
		$flow_cate = Db::name('FlowCate')->where(['name' => $param['check_name']])->find();
		$subject = $flow_cate['title'];
		$action_id = $param['action_id'];
		$check_table = $flow_cate['check_table'];
		//审核内容详情
		$detail = Db::name($check_table)->where(['id' => $action_id])->find();
		if (empty($detail)){		
			return to_assign(1,'审批数据错误');
		}
		//当前审核节点详情
		$step = Db::name('FlowStep')->where(['action_id'=>$action_id,'flow_id'=>$detail['check_flow_id'],'sort'=>$detail['check_step_sort'],'delete_time'=>0])->find();
		//审核通过时
		if($param['check'] == 1){
			$check_uids = explode(",",strval($detail['check_uids']));
			if (!in_array($this->uid, $check_uids)){		
				return to_assign(1,'您没权限审核该审批');
			}
			//审批通过
			if($step['check_role'] == 0){
				//自由人审批
				if($param['check_node'] == 2){
					$next_step = $detail['check_step_sort']+1;
					$flow_step = array(
						'action_id' => $action_id,
						'sort' => $next_step,
						'flow_id' => $detail['check_flow_id'],
						'check_uids' => $param['check_uids'],
						'create_time' => time()
					);
					$fid = Db::name('FlowStep')->strict(false)->field(true)->insertGetId($flow_step);
					//下一步审核步骤
					$param['check_step_sort'] = $next_step;
					$param['check_status'] = 1;
				}
				else{
					//不存在下一步审核，审核结束
					$param['check_status'] = 2;
					$param['check_uids'] ='';
				}
			}
			else{
				//查询当前步骤审批记录数
				$check_count = Db::name('FlowRecord')->where(['action_id'=>$action_id,'flow_id'=>$detail['check_flow_id'],'step_id'=>$step['id']])->count();
				//当前当前步骤审批应有记录数
				$flow_count = explode(',', $step['check_uids']);
				$param['check_status'] = 1;
				$uids_array = explode(',',$detail['check_uids']);
				$new_uids= array_diff($uids_array, [$this->uid]);
				$param['check_uids'] = implode(',',$new_uids);
				if((($check_count+1) >= count($flow_count) && $step['check_types']==1) || $step['check_types']==2){
					//会签
					$next_step = Db::name('FlowStep')->where(['action_id'=>$action_id,'flow_id'=>$detail['check_flow_id'],'sort'=>($detail['check_step_sort']+1),'delete_time'=>0])->find();
					if($next_step){
						//存在下一步审核
						if($next_step['check_role'] == 1){
							$param['check_uids'] = get_department_leader($detail['admin_id']);
						}
						else if($next_step['check_role'] == 2){
							$param['check_uids'] = get_department_leader($detail['admin_id'],1);
						}
						else if($next_step['check_role'] == 3){						
							$uids = Db::name('Admin')->where(['position_id'=>$next_step['check_position_id'],'status'=>1])->column('id');
							$param['check_uids'] = implode(',' ,$uids);
						}
						else{
							$param['check_uids'] = $next_step['check_uids'];
						}
						$param['check_step_sort'] = $detail['check_step_sort']+1;
						$param['check_status'] = 1;
					}
					else{
						//不存在下一步审核，审核结束
						$param['check_status'] = 2;
						$param['check_uids'] ='';
					}
				}
			}
			if($param['check_status'] == 1 && empty($param['check_uids'])){
				return to_assign(1,'找不到下一步的审批人，该审批流程设置有问题，请联系HR或者管理员');
			}			
			//添加历史审核人
			if(empty($detail['check_history_uids'])){
				$param['check_history_uids'] = $this->uid;
			}
			else{
				$param['check_history_uids'] = $detail['check_history_uids'].','.$this->uid;
			}			
			$res = Db::name($check_table)->strict(false)->field('check_step_sort,check_status,check_history_uids,check_uids')->where(['id' => $action_id])->update($param);
			
			if($res!==false){
				$checkData=array(
					'action_id' => $action_id,
					'check_table' => $check_table,
					'step_id' => $step['id'],
					'check_uid' => $this->uid,
					'flow_id' => $detail['check_flow_id'],
					'check_time' => time(),
					'check_status' => $param['check'],
					'content' => $param['content'],
					'create_time' => time()
				);	
				$aid = Db::name('FlowRecord')->strict(false)->field(true)->insertGetId($checkData);
				add_log('check', $action_id, $param,$subject);
				//发送消息通知
				if($param['check_status'] == 1){
					if($flow_cate['template_id']>0){
						$msg=[
							'from_uid'=>$detail['admin_id'],//发送人
							'to_uids'=>$param['check_uids'],//接收人
							'template_id'=>$flow_cate['template_id'],//消息模板ID
							'template_field'=>'0',//消息模板字段
							'content'=>[ //消息内容
								'create_time'=>date('Y-m-d H:i:s',$detail['create_time']),
								'action_id'=>$action_id,
								'title' => $subject
							]
						];
						event('SendMessage',$msg);
					}
				}
				if($param['check_status'] == 2){
					if($flow_cate['template_id']>0){
						$msg=[
							'from_uid'=>$this->uid,//发送人
							'to_uids'=>$detail['admin_id'],//接收人
							'template_id'=>$flow_cate['template_id'],//消息模板ID
							'template_field'=>'1',//消息模板字段
							'content'=>[ //消息内容
								'create_time'=>date('Y-m-d H:i:s',$detail['create_time']),
								'action_id'=>$action_id,
								'title' => $subject
							]
						];
						event('SendMessage',$msg);
					}
				}
				return to_assign();
			}
			else{
				return to_assign(1,'操作失败');
			}
		}
		else if($param['check'] == 2){
			$check_uids = explode(",",strval($detail['check_uids']));
			if (!in_array($this->uid, $check_uids)){		
				return to_assign(1,'您没权限审核该审批');
			}
			//拒绝审核，数据操作
			$param['check_status'] = 3;
			//添加历史审核人
			if(empty($detail['check_history_uids'])){
				$param['check_history_uids'] = $this->uid;
			}
			else{
				$param['check_history_uids'] = $detail['check_history_uids'].','.$this->uid;
			}
			$param['check_uids'] ='';
			if($step['check_role'] == 5){
				//获取上一步的审核信息
				$prev_step = Db::name('FlowStep')->where(['action_id'=>$action_id,'flow_id'=>$detail['check_flow_id'],'sort'=>($detail['check_step_sort']-1),'delete_time'=>0])->find();
				if($prev_step){
					//存在上一步审核
					$param['check_step_sort'] = $prev_step['sort'];
					$param['check_uids'] = $prev_step['check_uids'];
					$param['check_status'] = 1;
				}
				else{
					//不存在上一步审核，审核初始化步骤
					$param['check_step_sort'] = 0;
					$param['check_uids'] = '';					
					$param['check_status'] = 0;
				}
			}
			
			$res = Db::name($check_table)->strict(false)->field('check_step_sort,check_status,check_history_uids,check_uids')->where(['id' => $action_id])->update($param);
			if($res!==false){
				$checkData=array(
					'action_id' => $action_id,
					'check_table' => $check_table,
					'step_id' => $step['id'],
					'check_uid' => $this->uid,
					'flow_id' => $detail['check_flow_id'],
					'check_time' => time(),
					'check_status' => $param['check'],
					'content' => $param['content'],
					'create_time' => time()
				);	
				$aid = Db::name('FlowRecord')->strict(false)->field(true)->insertGetId($checkData);
				add_log('refue', $action_id, $param,$subject);
				//发送消息通知
				if($flow_cate['template_id']>0){
					$msg=[
						'from_uid'=>$this->uid,//发送人
						'to_uids'=>$detail['admin_id'],//接收人
						'template_id'=>$flow_cate['template_id'],//消息模板ID
						'template_field'=>'2',//消息模板字段
						'content'=>[ //消息内容
							'create_time'=>date('Y-m-d H:i:s',$detail['create_time']),
							'action_id'=>$detail['id'],
							'title' => $subject
						]
					];
					event('SendMessage',$msg);
				}
				return to_assign();
			}
			else{
				return to_assign(1,'操作失败');
			}			
		}		
		else if($param['check'] == 3){
			//审批撤回
			if($detail['admin_id'] != $this->uid){
				return to_assign(1,'你没权限操作');
			}
			//撤销审核，数据操作
			$param['check_status'] = 4;
			$param['check_uids'] ='';
			$param['check_step_sort'] =0;
			
			$res = Db::name($check_table)->strict(false)->field('check_step_sort,check_status,check_uids')->where(['id' => $action_id])->update($param);
			if($res!==false){
				$checkData=array(
					'action_id' => $action_id,
					'check_table' => $check_table,
					'step_id' => $step['id'],
					'check_uid' => $this->uid,
					'flow_id' => $detail['check_flow_id'],
					'check_time' => time(),
					'check_status' => $param['check'],
					'content' => $param['content'],
					'create_time' => time()
				);
				$aid = Db::name('FlowRecord')->strict(false)->field(true)->insertGetId($checkData);
				add_log('back', $action_id, $param,$subject);
				return to_assign();
			}else{
				return to_assign(1,'操作失败');
			}
		}
		else if($param['check'] == 4){
			//审批反确认
			//反确认审核，数据回到待提交审批
			$param['check_status'] = 0;
			$param['check_uids'] ='';
			$param['check_step_sort'] =0;
			
			$res = Db::name($check_table)->strict(false)->field('check_step_sort,check_status,check_uids')->where(['id' => $action_id])->update($param);
			if($res!==false){
				$checkData=array(
					'action_id' => $action_id,
					'check_table' => $check_table,
					'step_id' => $step['id'],
					'check_uid' => $this->uid,
					'flow_id' => $detail['check_flow_id'],
					'check_time' => time(),
					'check_status' => $param['check'],
					'content' => $param['content'],
					'create_time' => time()
				);
				$aid = Db::name('FlowRecord')->strict(false)->field(true)->insertGetId($checkData);
				add_log('back', $action_id, $param,$subject);
				return to_assign();
			}else{
				return to_assign(1,'操作失败');
			}
		}
    }
}