Files
2026-07-23 09:40:36 +08:00

638 lines
20 KiB
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);
}
}