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', ]; $fileExt = $rule['image'] . ',' . $rule['doc'] . ',' . $rule['file'] . ',' . $rule['video']; //1M=1024*1024=1048576字节 $fileSize = 100 * 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 $md5; }); if ($filename) { //写入到附件表 $data = []; $path = get_config('filesystem.disks.public.url'); $data['filepath'] = $path . '/' . $filename; $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['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, '上传失败,请重试'); } } //清空缓存 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 get_department() { $department = get_department(); return to_assign(0, '', $department); } //获取部门树形节点列表 public function get_department_tree() { $department = get_department(); $list = get_tree($department, 0, 2); $data['trees'] = $list; return json($data); } //获取部门树形节点列表2 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); } //获取子部门所有员工 public function get_employee($did = 0) { $did = get_params('did'); if ($did == 1) { $department = $did; } else { $department = get_department_son($did); } $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('Department d', 'a.did = d.id') ->where(['a.status' => 1]) ->where('a.id', ">", 1) ->where('a.did', "in", $department) ->select(); return to_assign(0, '', $employee); } //获取所有员工 public function get_personnel() { $param = get_params(); $where[] = ['a.status', '=', 1]; $where[] = ['a.id', '>', 1]; 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($rows, false, ['query' => $param]); return table_assign(0, '', $list); } //获取部门所有员工 public function get_employee_select() { $keyword = get_params('keyword'); $selected = []; if (!empty($keyword)) { $selected = explode(",", $keyword); } $employee = Db::name('admin') ->field('id as value,name') ->where(['status' => 1]) ->select()->toArray(); foreach ($employee as $k => &$v) { $v['selected'] = ''; if (in_array($v['value'], $selected)) { $v['selected'] = 'selected'; } } return to_assign(0, '', $employee); } //获取角色列表 public function get_position() { $position = Db::name('Position')->field('id,title as name')->where([['status', '=', 1], ['id', '>', 1]])->select(); return to_assign(0, '', $position); } //获取审核类型 public function get_flow_cate($type = 0) { $flows = Db::name('FlowType')->where(['type' => $type, 'status' => 1])->select()->toArray(); return to_assign(0, '', $flows); } //获取审核步骤人员 public function get_flow_users($id = 0) { $flow = Db::name('Flow')->where(['id' => $id])->find(); $flowData = unserialize($flow['flow_list']); if (!empty($flowData)) { foreach ($flowData as $key => &$val) { $val['user_id_info'] = Db::name('Admin')->field('id,name,thumb')->where('id', 'in', $val['flow_uids'])->select()->toArray(); } } $data['copy_uids'] = $flow['copy_uids']; $data['copy_unames'] = ''; if ($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'] = $flowData; return to_assign(0, '', $data); } //获取审核流程节点 public function get_flow_nodes($id = 0, $type = 1) { $flows = Db::name('FlowStep')->where(['action_id' => $id, 'type' => $type, 'delete_time' => 0])->order('sort asc')->select()->toArray(); foreach ($flows as $key => &$val) { $user_id_info = Db::name('Admin')->field('id,name,thumb')->where('id', 'in', $val['flow_uids'])->select()->toArray(); foreach ($user_id_info as $k => &$v) { $v['check_time'] = 0; $v['content'] = ''; $v['status'] = 0; $check_array = Db::name('FlowRecord')->where(['check_user_id' => $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['status'] = $checked['status']; } } $check_list = Db::name('FlowRecord') ->field('f.*,a.name,a.thumb') ->alias('f') ->join('Admin a', 'a.id = f.check_user_id', 'left') ->where(['f.step_id' => $val['id']])->select()->toArray(); foreach ($check_list as $kk => &$vv) { $vv['check_time_str'] = date('Y-m-d H:i', $vv['check_time']); } $val['user_id_info'] = $user_id_info; $val['check_list'] = $check_list; } return to_assign(0, '', $flows); } //获取审核流程节点 public function get_flow_record($id = 0, $type = 1) { $check_list = Db::name('FlowRecord') ->field('f.*,a.name,a.thumb') ->alias('f') ->join('Admin a', 'a.id = f.check_user_id', 'left') ->where(['f.action_id' => $id, 'f.type' => $type]) ->order('check_time asc') ->select()->toArray(); foreach ($check_list as $kk => &$vv) { $vv['check_time_str'] = date('Y-m-d H:i', $vv['check_time']); } return to_assign(0, '', $check_list); } //流程审核 public function flow_check() { $param = get_params(); $id = $param['id']; $type = $param['type']; $detail = []; $subject = '一个审批'; if ($type == 1) { //日常审核 $detail = Db::name('Approve')->where(['id' => $id])->find(); $subject = '一个日常审批'; $msg_title_type = $detail['type']; } else if ($type == 2) { //报销审核 $detail = Db::name('Expense')->where(['id' => $id])->find(); $subject = '一个报销审批'; $msg_title_type = 22; } else if ($type == 3) { //发票审核 $detail = Db::name('Invoice')->where(['id' => $id])->find(); $subject = '一个发票审批'; $msg_title_type = 23; } else if ($type == 4) { //合同审核 $detail = Db::name('Contract')->where(['id' => $id])->find(); $subject = '一个合同审批'; $msg_title_type = 24; } if (empty($detail)) { return to_assign(1, '审批数据错误'); } //当前审核节点详情 $step = Db::name('FlowStep')->where(['action_id' => $id, 'type' => $type, 'sort' => $detail['check_step_sort'], 'delete_time' => 0])->find(); //审核通过 if ($param['check'] == 1) { $check_admin_ids = explode(",", strval($detail['check_admin_ids'])); if (!in_array($this->uid, $check_admin_ids)) { return to_assign(1, '您没权限审核该审批'); } //多人会签审批 if ($step['flow_type'] == 4) { //查询当前会签记录数 $check_count = Db::name('FlowRecord')->where(['action_id' => $id, 'type' => $type, 'step_id' => $step['id']])->count(); //当前会签记应有记录数 $flow_count = explode(',', $step['flow_uids']); if (($check_count + 1) >= count($flow_count)) { $next_step = Db::name('FlowStep')->where(['action_id' => $id, 'type' => $type, 'sort' => ($detail['check_step_sort'] + 1), 'delete_time' => 0])->find(); if ($next_step) { //存在下一步审核 if ($next_step['flow_type'] == 1) { $param['check_admin_ids'] = get_department_leader($detail['admin_id']); } else if ($next_step['flow_type'] == 2) { $param['check_admin_ids'] = get_department_leader($detail['admin_id'], 1); } else { $param['check_admin_ids'] = $next_step['flow_uids']; } $param['check_step_sort'] = $detail['check_step_sort'] + 1; $param['check_status'] = 1; } else { //不存在下一步审核,审核结束 $param['check_status'] = 2; $param['check_admin_ids'] = ''; } } else { $param['check_status'] = 1; $param['check_admin_ids'] = $step['flow_uids']; } } else if ($step['flow_type'] == 0) { //自由人审批 if ($param['check_node'] == 2) { $next_step = $detail['check_step_sort'] + 1; $flow_step = array( 'action_id' => $id, 'sort' => $next_step, 'type' => $type, 'flow_uids' => $param['check_admin_ids'], 'create_time' => time() ); $fid = Db::name('FlowStep')->strict(false)->field(true)->insertGetId($flow_step); //下一步审核步骤 $param['check_admin_ids'] = $param['check_admin_ids']; $param['check_step_sort'] = $next_step; $param['check_status'] = 1; } else { //不存在下一步审核,审核结束 $param['check_status'] = 2; $param['check_admin_ids'] = ''; } } else { $next_step = Db::name('FlowStep')->where(['action_id' => $id, 'type' => $type, 'sort' => ($detail['check_step_sort'] + 1), 'delete_time' => 0])->find(); if ($next_step) { //存在下一步审核 if ($next_step['flow_type'] == 1) { $param['check_admin_ids'] = get_department_leader($detail['admin_id']); } else if ($next_step['flow_type'] == 2) { $param['check_admin_ids'] = get_department_leader($detail['admin_id'], 1); } else { $param['check_admin_ids'] = $next_step['flow_uids']; } $param['check_step_sort'] = $detail['check_step_sort'] + 1; $param['check_status'] = 1; } else { //不存在下一步审核,审核结束 $param['check_status'] = 2; $param['check_admin_ids'] = ''; } } if ($param['check_status'] == 1 && empty($param['check_admin_ids'])) { return to_assign(1, '找不到下一步的审批人,该审批流程设置有问题,请联系HR或者管理员'); } //审核通过数据操作 $param['last_admin_id'] = $this->uid; $param['flow_admin_ids'] = $detail['flow_admin_ids'] . $this->uid . ','; if ($type == 1) { //日常审核 $res = Db::name('Approve')->strict(false)->field('check_step_sort,check_status,last_admin_id,flow_admin_ids,check_admin_ids')->update($param); } else if ($type == 2) { //报销审核 $res = Db::name('Expense')->strict(false)->field('check_step_sort,check_status,last_admin_id,flow_admin_ids,check_admin_ids')->update($param); } else if ($type == 3) { //发票审核 $res = Db::name('Invoice')->strict(false)->field('check_step_sort,check_status,last_admin_id,flow_admin_ids,check_admin_ids')->update($param); } else if ($type == 4) { //合同审核 $res = Db::name('Contract')->strict(false)->field('check_step_sort,check_status,last_admin_id,flow_admin_ids,check_admin_ids')->update($param); } if ($res !== false) { $checkData = array( 'action_id' => $id, 'step_id' => $step['id'], 'check_user_id' => $this->uid, 'type' => $type, 'check_time' => time(), 'status' => $param['check'], 'content' => $param['content'], 'create_time' => time() ); $aid = Db::name('FlowRecord')->strict(false)->field(true)->insertGetId($checkData); add_log('check', $param['id'], $param, $subject); //发送消息通知 $msg = [ 'create_time' => date('Y-m-d H:i:s', $detail['create_time']), 'action_id' => $id, 'title' => Db::name('FlowType')->where('id', $msg_title_type)->value('title'), 'from_uid' => $detail['admin_id'] ]; if ($param['check_status'] == 1) { $users = $param['check_admin_ids']; sendMessage($users, ($type * 10 + 11), $msg); } if ($param['check_status'] == 2) { $users = $detail['admin_id']; sendMessage($users, ($type * 10 + 12), $msg); } return to_assign(); } else { return to_assign(1, '操作失败'); } } else if ($param['check'] == 2) { $check_admin_ids = explode(",", strval($detail['check_admin_ids'])); if (!in_array($this->uid, $check_admin_ids)) { return to_assign(1, '您没权限审核该审批'); } //拒绝审核,数据操作 $param['check_status'] = 3; $param['last_admin_id'] = $this->uid; $param['flow_admin_ids'] = $detail['flow_admin_ids'] . $this->uid . ','; $param['check_admin_ids'] = ''; if ($step['flow_type'] == 5) { //获取上一步的审核信息 $prev_step = Db::name('FlowStep')->where(['action_id' => $id, 'type' => $type, 'sort' => ($detail['check_step_sort'] - 1), 'delete_time' => 0])->find(); if ($prev_step) { //存在上一步审核 $param['check_step_sort'] = $prev_step['sort']; $param['check_admin_ids'] = $prev_step['flow_uids']; $param['check_status'] = 1; } else { //不存在上一步审核,审核初始化步骤 $param['check_step_sort'] = 0; $param['check_admin_ids'] = ''; $param['check_status'] = 0; } } if ($type == 1) { //日常审核 $res = Db::name('Approve')->strict(false)->field('check_step_sort,check_status,last_admin_id,flow_admin_ids,check_admin_ids')->update($param); } else if ($type == 2) { //报销审核 $res = Db::name('Expense')->strict(false)->field('check_step_sort,check_status,last_admin_id,flow_admin_ids,check_admin_ids')->update($param); } else if ($type == 3) { //发票审核 $res = Db::name('Invoice')->strict(false)->field('check_step_sort,check_status,last_admin_id,flow_admin_ids,check_admin_ids')->update($param); } else if ($type == 4) { //合同审核 $res = Db::name('Contract')->strict(false)->field('check_step_sort,check_status,last_admin_id,flow_admin_ids,check_admin_ids')->update($param); } if ($res !== false) { $checkData = array( 'action_id' => $id, 'step_id' => $step['id'], 'check_user_id' => $this->uid, 'type' => $type, 'check_time' => time(), 'status' => $param['check'], 'content' => $param['content'], 'create_time' => time() ); $aid = Db::name('FlowRecord')->strict(false)->field(true)->insertGetId($checkData); add_log('refue', $param['id'], $param, $subject); //发送消息通知 $msg = [ 'create_time' => date('Y-m-d H:i:s', $detail['create_time']), 'action_id' => $detail['id'], 'title' => Db::name('FlowType')->where('id', $msg_title_type)->value('title'), 'from_uid' => $detail['admin_id'] ]; $users = $detail['admin_id']; sendMessage($users, ($type * 10 + 13), $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_admin_ids'] = ''; $param['check_step_sort'] = 0; if ($type == 1) { //日常审核 $res = Db::name('Approve')->strict(false)->field('check_step_sort,check_status,check_admin_ids')->update($param); } else if ($type == 2) { //报销审核 $res = Db::name('Expense')->strict(false)->field('check_step_sort,check_status,check_admin_ids')->update($param); } else if ($type == 3) { //发票审核 $res = Db::name('Invoice')->strict(false)->field('check_step_sort,check_status,check_admin_ids')->update($param); } else if ($type == 4) { //合同审核 $res = Db::name('Contract')->strict(false)->field('check_step_sort,check_status,check_admin_ids')->update($param); } if ($res !== false) { $checkData = array( 'action_id' => $id, 'step_id' => 0, 'check_user_id' => $this->uid, 'type' => $type, 'check_time' => time(), 'status' => $param['check'], 'content' => $param['content'], 'create_time' => time() ); $aid = Db::name('FlowRecord')->strict(false)->field(true)->insertGetId($checkData); add_log('back', $param['id'], $param, $subject); return to_assign(); } else { return to_assign(1, '操作失败'); } } } //获取关键字 public function get_keyword_cate() { $keyword = Db::name('Keywords')->where(['status' => 1])->order('id desc')->select()->toArray(); return to_assign(0, '', $keyword); } //读取报销类型 function get_expense_cate() { $cate = get_expense_cate(); return to_assign(0, '', $cate); } //读取费用类型 function get_cost_cate() { $cate = get_cost_cate(); return to_assign(0, '', $cate); } //读取印章类型 function get_seal_cate() { $cate = get_seal_cate(); return to_assign(0, '', $cate); } //读取车辆类型 function get_car_cate() { $cate = get_car_cate(); return to_assign(0, '', $cate); } //读取企业主体 function get_subject() { $subject = get_subject(); return to_assign(0, '', $subject); } //读取行业类型 function get_industry() { $industry = get_industry(); return to_assign(0, '', $industry); } //读取服务类型 function get_services() { $services = get_services(); return to_assign(0, '', $services); } //获取工作类型列表 public function get_work_cate() { $cate = get_work_cate(); return to_assign(0, '', $cate); } }