oa/app/api/controller/Index.php

<?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 app\api\model\EditLog;
use smsservice\Smsservice;
use think\Image; // 引入Image类
use think\facade\Db;

class Index extends BaseController
{
	//上传文件
	public function upload()
	{
		if (request()->isPost()) {
			$param = get_params();
			$sourse = 'file';
			if(isset($param['sourse'])){
				$sourse = $param['sourse'];
			}
			if($sourse == 'file' || $sourse == 'tinymce'){
				if(request()->file('file')){
					$file = request()->file('file');
				}
				else{
					return to_assign(1, '没有选择上传文件');
				}
			}
			else{
				if (request()->file('editormd-image-file')) {
					$file = request()->file('editormd-image-file');
				} else {
					return to_assign(1, '没有选择上传文件');
				}
			}
			// 获取上传文件的hash散列值
			$sha1 = $file->hash('sha1');
			$md5 = $file->hash('md5');
			$rule = [
				'image' => 'jpg,png,jpeg,gif',
				'doc' => 'txt,doc,docx,ppt,pptx,xls,xlsx,pdf',
				'file' => 'zip,gz,7z,rar,tar',
				'video' => 'mpg,mp4,mpeg,avi,wmv,mov,flv,m4v',
				'audio' => 'mp3,wav,wma,flac,midi',
			];
			$fileExt = $rule['image'] . ',' . $rule['doc'] . ',' . $rule['file'] . ',' . $rule['video'] . ',' . $rule['audio'];
			//1M=1024*1024=1048576字节
			$file_size = get_system_config('system','upload_max_filesize');
			if(!isset($file_size)){
				$file_size=50;
			}
			$fileSize = $file_size * 1024 * 1024;
			if (isset($param['type']) && $param['type']) {
				$fileExt = $rule[$param['type']];
			}
			if (isset($param['size']) && $param['size']) {
				$fileSize = $param['size'];
			}
			$validate = \think\facade\Validate::rule([
				'image' => 'require|fileSize:' . $fileSize . '|fileExt:' . $fileExt,
			]);
			$file_check['image'] = $file;
			if (!$validate->check($file_check)) {
				return to_assign(1, $validate->getError());
			}
			// 日期前綴
			$dataPath = date('Ym');
			$use = 'thumb';
			$filename = \think\facade\Filesystem::disk('public')->putFile($dataPath, $file, function () use ($md5) {
				return set_salt(5).'_'.$md5;
			});
			if ($filename) {
				//写入到附件表
				$imagePath = get_config('filesystem.disks.public.url'). '/' . $filename;
				$thumbPath = '';
				if(in_array($file->extension(),['jpg','png','jpeg','gif'])){
					// 生成等比缩略图
					$image = Image::open(request()->file('file'));
					$thumbPath = dirname($imagePath) . '/thumb_' . basename($imagePath);
					// 生成等比缩略图保存到指定位置，这里设置最大宽度为360px, 高度自适应
					$image->thumb(360,360,Image::THUMB_CENTER)->save('./'.$thumbPath);
				}
				$data = [];
				$data['filepath'] = $imagePath;
				$data['thumbpath'] = $thumbPath;
				$data['name'] = $file->getOriginalName();
				$data['mimetype'] = $file->getOriginalMime();
				$data['fileext'] = $file->extension();
				$data['filesize'] = $file->getSize();
				$data['filename'] = $filename;
				$data['sha1'] = $sha1;
				$data['md5'] = $md5;
				$data['module'] = \think\facade\App::initialize()->http->getName();
				$data['action'] = app('request')->action();
				$data['uploadip'] = app('request')->ip();
				$data['create_time'] = time();
				$data['user_id'] = $this->uid;
				if ($data['module'] = 'admin') {
					//通过后台上传的文件直接审核通过
					$data['status'] = 1;
					$data['admin_id'] = $data['user_id'];
					$data['audit_time'] = time();
				}
				$data['use'] = request()->has('use') ? request()->param('use') : $use; //附件用处
				$res['id'] = Db::name('file')->insertGetId($data);
				$res['filepath'] = $data['filepath'];
				$res['name'] = $data['name'];
				$res['uid'] = $this->uid;
				$res['filename'] = $data['filename'];
				$res['filesize'] = $data['filesize'];
				$res['fileext'] = $data['fileext'];
				add_log('upload', $data['user_id'], $data,'文件');
				if($sourse == 'editormd'){
					//editormd编辑器上传返回
					return json(['success'=>1,'message'=>'上传成功','url'=>$data['filepath']]);
				}
				else if($sourse == 'tinymce'){
					//tinymce编辑器上传返回
					return json(['success'=>1,'message'=>'上传成功','location'=>$data['filepath']]);
				}
				else{
					//普通上传返回
					return to_assign(0, '上传成功', $res);
				}            
			 }
			 else {
				return to_assign(1, '上传失败，请重试');
			 }
		}
		else{
			return to_assign(1, '非法请求');
		} 
	}
	
	//执行分块上传的控制器方法
	public function chunkUpload() {
		if ($this->request->isPost()) {
			//执行分块上传流程
			$data = $this->request->post();
			//判断是否是分块上传
			if ($data['type'] === 'chunk') {
				$file = request()->file('file');
				
				$rule = [
					'image' => 'jpg,png,jpeg,gif',
					'doc' => 'txt,doc,docx,ppt,pptx,xls,xlsx,pdf',
					'file' => 'zip,gz,7z,rar,tar',
					'video' => 'mpg,mp4,mpeg,avi,wmv,mov,flv,m4v',
					'audio' => 'mp3,wav,wma,flac,midi',
				];
				$fileExt = $rule['image'] . ',' . $rule['doc'] . ',' . $rule['file'] . ',' . $rule['video'] . ',' . $rule['audio'];
				//1M=1024*1024=1048576字节
				$file_size = get_system_config('system','upload_max_filesize');
				if(!isset($file_size)){
					$file_size=50;
				}
				$fileSize = $file_size * 1024 * 1024;
				$validate = \think\facade\Validate::rule([
					'image' => 'require|fileSize:' . $fileSize . '|fileExt:' . $fileExt,
				]);
				$file_check['image'] = $file;
				if (!$validate->check($file_check)) {
					return to_assign(1, $validate->getError());
				}
				
				//获取对应的上传配置
				$fs = \think\facade\Filesystem::disk('public');
				$ext = $file->extension();
				$chunkPath = $data['file_id'].'/'.$file->md5().($ext ? '.'.$ext : '');
				//存储分片文件到指定路径
				$savename = $fs->putFileAs( 'chunk', $file,$chunkPath);
				if (!$savename) {
					return json([
						'code' => 1,
						'msg' => '上传失败',
						'data' => [],
					]);
				}
				if (!$data['is_end']) {
					$filepath = '';
				} else {
					//合并块文件
					$fileUrl = '';
					$chunkSaveDir = \think\facade\Filesystem::getDiskConfig('public');
					$smallChunkDir = $chunkSaveDir['root'].'/chunk/'.$data['file_id'];
					//获取已存储的属于源文件的所有分块文件 进行合并
					if ($handle = opendir($smallChunkDir)) {
						$chunkList = [];
						$modifyTime = [];
						while (false !== ($file = readdir($handle))) {
							if ($file != "." && $file != "..") {
								$temp['path'] = $smallChunkDir.'/'.$file;
								$temp['modify'] = filemtime($smallChunkDir.'/'.$file);
								$chunkList[] = $temp;
								$modifyTime[] = $temp['modify'];
							}
						}
						//对分块文件进行排序
						array_multisort($modifyTime,SORT_ASC,$chunkList);
						$saveDir = \think\facade\Filesystem::getDiskConfig('public');
						$saveName = md5($data['file_id'].$data['file_name']).'.'.$data['file_extension'];
						$newPath = $saveDir['root'].'/'.date('Ym').'/'.$saveName;
						if (!file_exists($saveDir['root'].'/'.date('Ym'))) {
							mkdir($saveDir['root'].'/'.date('Ym'),0777,true);
						}
						$newFileHandle = fopen($newPath,'a+b');
						foreach ($chunkList as $item) {
							fwrite($newFileHandle,file_get_contents($item['path']));
							unlink($item['path']);
						}
						rmdir($smallChunkDir);
						//将合并后的文件存储到指定路径
						$fileUrl = $saveDir['url'].'/'.date('Ym').'/'.$saveName;
						fclose($newFileHandle);
						closedir($handle);
					} else {
						return json([
							'code' => 1,
							'msg' => '目录：'.$chunkSaveDir['root'].'/chunk/'.$data['file_id'].'不存在',
							'data' => [],
						]);
					}
					$filepath = $fileUrl;
				}
				$res=[];
				//合并流程结束
				if ($filepath!='') {
					$fileinfo = [];
					$fileinfo['filepath'] = $filepath;
					$fileinfo['name'] = $data['file_name'];
					$fileinfo['fileext'] = $data['file_extension'];
					$fileinfo['filesize'] = $data['file_size'];
					$fileinfo['filename'] = date('Ym').'/'.$saveName;
					$fileinfo['sha1'] = $data['file_id'];
					$fileinfo['md5'] = $data['file_id'];
					$fileinfo['module'] = \think\facade\App::initialize()->http->getName();
					$fileinfo['action'] = app('request')->action();
					$fileinfo['uploadip'] = app('request')->ip();
					$fileinfo['create_time'] = time();
					$fileinfo['user_id'] = get_login_admin('id') ? get_login_admin('id') : 0;
					if ($fileinfo['module'] = 'admin') {
						//通过后台上传的文件直接审核通过
						$fileinfo['status'] = 1;
						$fileinfo['admin_id'] = $fileinfo['user_id'];
						$fileinfo['audit_time'] = time();
					}
					$fileinfo['use'] = 'big';
					$res['id'] = Db::name('file')->insertGetId($fileinfo);
					$res['filepath'] = $fileinfo['filepath'];
					$res['name'] = $fileinfo['name'];
					$res['filename'] = $fileinfo['filename'];
					$res['filesize'] = $fileinfo['filesize'];
					$res['fileext'] = $fileinfo['fileext'];
					add_log('upload', $fileinfo['user_id'], $fileinfo);
				} 
				return to_assign(0, '上传成功', $res);
			}
		}
		else{
			return to_assign(1, '非法请求', $res);
		}
	}

	//取消上传，删除临时文件
	public function clearChunk() {
		if ($this->request->isPost()) {
			$param = get_params();
			$saveDir = \think\facade\Filesystem::getDiskConfig('public');
			$smallChunkDir = $saveDir['root'].'/chunk/'.$param['file_id'];
			if(!is_dir($smallChunkDir)){
				return to_assign(0, '上传的临时文件已删除');
			}
			//获取已存储的属于源文件的所有分块文件
			if ($handle = opendir($smallChunkDir)) {
				while (false !== ($file = readdir($handle))) {
					if ($file != "." && $file != "..") {
						$temp['path'] = $smallChunkDir.'/'.$file;
						unlink($temp['path']);
					}
				}
				rmdir($smallChunkDir);
				closedir($handle);
				return to_assign(0, '已取消上传');
			}
		}
	}
 
    //附件重命名
    public function file_edit()
    {
        $param = get_params();
		if (Db::name('File')->where('id',$param['id'])->update(['name'=>$param['title']]) !== false) {
			add_log('edit', $param['id'], $param,'文件名称');
			return to_assign(0, "操作成功");
		} else {
			return to_assign(1, "操作失败");
		}
    }

    //获取编辑记录
    public function load_log()
    {
        $param = get_params();
		$log = new EditLog();
		$list = $log->datalist($param);
		$total = Db::name('EditLog')->where(['name'=>$param['name'],'action_id'=>$param['action_id']])->count();
		$totalRow['total'] = $total;
        return to_assign(0, '', $list,$totalRow);
    }


    //清空缓存
    public function cache_clear()
    {
        \think\facade\Cache::clear();
        return to_assign(0, '系统缓存已清空');
    }

    // 测试邮件发送
    public function email_test()
    {
        $sender = get_params('email');
        //检查是否邮箱格式
        if (!is_email($sender)) {
            return to_assign(1, '测试邮箱码格式有误');
        }
        $email_config = \think\facade\Db::name('config')->where('name', 'email')->find();
        $config = unserialize($email_config['content']);
        $content = $config['template'];
        //所有项目必须填写
        if (empty($config['smtp']) || empty($config['smtp_port']) || empty($config['smtp_user']) || empty($config['smtp_pwd'])) {
            return to_assign(1, '请完善邮件配置信息');
        }

        $send = send_email($sender, '测试邮件', $content);
        if ($send) {
            return to_assign(0, '邮件发送成功');
        } else {
            return to_assign(1, '邮件发送失败');
        }
    }
	
	//测试发送阿里云短信
	public function sms_test()
    {
        $phoneNumbers = '136xxxxxxxx';
       // $code = rand(1000, 9999); // 示例验证码
        $sms = new Smsservice();
        $result = $sms->sendSms($phoneNumbers, 'SMS_xxxxxx', ['name' => '勾股OA','title'=>'《测试阿里云短信发送成功》']);
		if ($result['code'] === 'OK') {
			return to_assign(0, '发送成功');
		} else {
			return to_assign(1, '发送失败：'.$result['message']);
		}
    }
	
	//获取未读消息
	public function get_msg()
	{
		$msg_map[] = ['to_uid', '=', $this->uid];
		$msg_map[] = ['read_time', '=', 0];
		$msg_map[] = ['delete_time', '=', 0];
		$msg_count = Db::name('Msg')->where($msg_map)->count();
		return to_assign(0, 'ok', $msg_count);
	}

    //获取部门
    public function get_department()
    {
        $department = get_department();
        return to_assign(0, '', $department);
    }

    //获取部门树形节点列表，用于tree前端组件
    public function get_department_tree()
    {
        $department = get_department();
        $list = get_tree($department);
        $data['trees'] = $list;
        return json($data);
    }
	
    //获取下属部门树形节点列表，用于tree前端组件
    public function get_department_tree_sub()
    {
		if($this->uid==1){
			$department = get_department();
		}
		else{
			$dids = get_leader_departments($this->uid);
			$department = Db::name('Department')->order('sort desc,id asc')->where([['status','=',1],['id','in',$dids]])->select()->toArray();
		}
        $list = get_tree($department,$department[0]['pid']);
        $data['trees'] = $list;
        return json($data);
    }
	
    //获取部门树形节点列表，用于X-select前端组件
    public function get_department_select()
    {
		$keyword = get_params('keyword');
		$selected = [];
		if(!empty($keyword)){
			$selected = explode(",",$keyword);
		}		
        $department = get_department();
        $list = get_select_tree($department, 0,0,$selected);
		return to_assign(0, '',$list);
    }

    //获取所有员工，did>0时时获取部门员工,用于picker签单组件
    public function get_employee($did = 0)
    {
		$where=[];
		$whereOr=[];
		if (!empty($did)) {
			$admin_array = Db::name('DepartmentAdmin')->where('department_id',$did)->column('admin_id');
			$map1=[
				['a.id','in',$admin_array],
			];
			$map2=[
				['a.did', '=', $did],
			];
			$whereOr =[$map1,$map2];
		}		
		$where[] = ['a.id', '>', 1];
		$where[] = ['a.status', '=', 1];
		$where[] = ['a.delete_time', '=', 0];
		$employee = Db::name('admin')
			->field('a.id,a.did,a.position_id,a.mobile,a.name,a.nickname,a.sex,a.status,a.thumb,a.username,d.title as department')
            ->alias('a')
			->join('Position p', 'p.id = a.position_id','left')
			->join('Department d', 'a.did = d.id','left')
			->where($where)
			->where(function ($query) use($whereOr) {
				if (!empty($whereOr)){
					$query->whereOr($whereOr);
				}
			})
			->group('a.id')
			->order('a.id desc')
			->select();
        return to_assign(0, '', $employee);
    }
	
   //获取所有下属员工，did>0时时获取部门员工,用于picker签单组件
    public function get_employee_sub($did = 0)
    {
		$where=[];
		$whereOr=[];
		if (!empty($did)) {
			$admin_array = Db::name('DepartmentAdmin')->where('department_id',$did)->column('admin_id');
			$map1=[
				['a.id','in',$admin_array],
			];
			$map2=[
				['a.did', '=', $did],
			];
			$whereOr =[$map1,$map2];
		}
		else{
			if($this->uid>1){
				$dids = get_leader_departments($this->uid);
				$where[] = ['a.did', 'in', $dids];
			}
		}
		$where[] = ['a.id', '>', 1];
		$where[] = ['a.status', '=', 1];
		$where[] = ['a.delete_time', '=', 0];
		$employee = Db::name('admin')
			->field('a.id,a.did,a.position_id,a.mobile,a.name,a.nickname,a.sex,a.status,a.thumb,a.username,d.title as department')
            ->alias('a')
			->join('Position p', 'p.id = a.position_id','left')
			->join('Department d', 'a.did = d.id','left')
			->where($where)
			->where(function ($query) use($whereOr) {
				if (!empty($whereOr)){
					$query->whereOr($whereOr);
				}
			})
			->group('a.id')
			->order('a.id desc')
			->select();
        return to_assign(0, '', $employee);
    }
	
    //获取所有员工
    public function get_personnel()
    {       
		$param = get_params();
		$where[] = ['a.status', '=', 1];
		$where[] = ['a.id', '>', 1];
		$where[] = ['a.delete_time', '=', 0];
		if (!empty($param['keywords'])) {
			$where[] = ['a.name', 'like', '%' . $param['keywords'] . '%'];
		}
		if(!empty($param['ids'])){
			//排除某些员工
			$where[] = ['a.id', 'notin', $param['ids']];
		}
		$rows = empty($param['limit']) ? get_config('app.page_size') : $param['limit'];
        $list = Db::name('admin')
            ->field('a.id,a.did,a.position_id,a.mobile,a.name,a.nickname,a.sex,a.status,a.thumb,a.username,d.title as department')
            ->alias('a')
            ->join('Department d', 'a.did = d.id')
            ->where($where)
			->order('a.id desc')
			->paginate(['list_rows'=> $rows]);
		return table_assign(0, '', $list);
    }	
	
    //获取所有员工，用于X-select前端组件,did>0时时获取部门员工
    public function get_employee_select($did=0)
    {
		$keyword = get_params('keyword');
		$selected = [];
		if(!empty($keyword)){
			$selected = explode(",",$keyword);
		}
		if($did == 0){
			$employee = Db::name('admin')->field('id as value,name')->where(['status' => 1,'delete_time'=>0])->select()->toArray();		
		}
		else{
			$employee = get_department_employee($did);
		}
		$list=[];
		foreach($employee as $k => $v){
			$select = '';
			if(in_array($v['id'],$selected)){
				$select = 'selected';
			}
			$list[]=[
				'value'=>$v['id'],
				'name'=>$v['name'],
				'selected'=>$select
			];
		}
        return to_assign(0, '', $list);
    }	


    //获取某部门的负责人
    public function get_department_leader($uid=0,$pid=0)
    {
        $leaders = get_department_leader($uid,$pid);
        return to_assign(0, '', $leaders);
    }

    //获取职位
    public function get_position()
    {
        $position = Db::name('Position')->field('id,title')->where([['status', '=', 1], ['id', '>', 1]])->select();
        return to_assign(0, '', $position);
    }
	
	//获取消息模板
    public function get_template()
    {
		$param = get_params();
		if (!empty($param['keywords'])) {
			$where[] = ['title', 'like', '%' . $param['keywords'] . '%'];
		}
		$where[] = ['status', '=', 1];
		$rows = empty($param['limit']) ? get_config('app.page_size') : $param['limit'];		
        $list = Db::name('Template')->field('id,title')->where($where)->paginate(['list_rows'=> $rows]);;
		return table_assign(0, '', $list);
    }
	
	//读取报销类型
	function get_expense_cate()
	{
		$cate = get_base_data('ExpenseCate');
		return to_assign(0, '', $cate);
	}

	//读取费用类型
	function get_cost_cate()
	{
		$cate = get_base_data('CostCate');
		return to_assign(0, '', $cate);
	}

	//读取印章类型
	function get_seal_cate()
	{
		$cate = get_base_data('SealCate');
		return to_assign(0, '', $cate);
	}

	//读取车辆类型
	function get_car_cate()
	{
		$cate = get_base_data('CarCate');
		return to_assign(0, '', $cate);
	}

	//读取企业主体
	function get_subject()
	{
		$subject = get_base_data('Subject');
		return to_assign(0, '', $subject);
	}

	//读取行业类型
	function get_industry()
	{
		$industry = get_base_data('Industry');
		return to_assign(0, '', $industry);
	}

	//读取服务类型
	function get_services()
	{
		$services = get_base_data('Services');
		return to_assign(0, '', $services);
	}
	
	//获取工作类型列表
    public function get_work_cate()
    {
        $cate = get_base_data('WorkCate');
        return to_assign(0, '', $cate);
    }
}