<?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\home\controller;
|
|
use app\api\BaseController;
|
use think\facade\Db;
|
use think\facade\View;
|
|
class Approve extends BaseController
|
{
|
public function index()
|
{
|
$department = $this->did;
|
$module = Db::name('FlowModule')->where(['status'=>1])->select()->toArray();
|
$whereOr = [];
|
if($this->uid>1){
|
$map1=[
|
['department_ids', '=', '']
|
];
|
$map2=[
|
['', 'exp', Db::raw("FIND_IN_SET('{$department}',department_ids)")]
|
];
|
$whereOr =[$map1,$map2];
|
}
|
|
foreach ($module as &$row) {
|
// 处理每一行数据
|
$row['list'] = Db::name('FlowCate')
|
->where([['module_id','=',$row['id']],['status','=',1],['is_list','=',1]])
|
->where(function ($query) use($whereOr) {
|
if (!empty($whereOr)){
|
$query->whereOr($whereOr);
|
}
|
})
|
->select()->toArray();
|
}
|
View::assign('module', $module);
|
return view();
|
}
|
|
public function get_list($where,$param)
|
{
|
$tables = Db::name('FlowCate')->field('name,check_table')->where('status',1)->select()->toArray();
|
$prefix = get_config('database.connections.mysql.prefix');
|
$sqlParts = [];
|
$sqlCounts = [];
|
$fortable =[];
|
foreach ($tables as $table) {
|
$dbname = $table['check_table'];
|
if(in_array($dbname,$fortable)){
|
continue;
|
}
|
$check_name = $table['name'];
|
$tableName = $prefix.$dbname;
|
$sqlPart = "SELECT id,admin_id,did,create_time,check_status,check_flow_id,check_step_sort,check_uids,check_last_uid,check_history_uids,check_copy_uids,check_time,'{$dbname}' as table_name,'{$check_name}' as check_name,'{$check_name}' as invoice_type,'{$check_name}' as types FROM {$tableName} WHERE {$where}";
|
if($dbname=='invoice' || $dbname=='ticket'){
|
$sqlPart = "SELECT id,admin_id,did,create_time,check_status,check_flow_id,check_step_sort,check_uids,check_last_uid,check_history_uids,check_copy_uids,check_time,'{$dbname}' as table_name,'{$check_name}' as check_name,invoice_type,'{$check_name}' as types FROM {$tableName} WHERE {$where}";
|
}
|
if($dbname=='approve'){
|
$sqlPart = "SELECT id,admin_id,did,create_time,check_status,check_flow_id,check_step_sort,check_uids,check_last_uid,check_history_uids,check_copy_uids,check_time,'{$dbname}' as table_name,'{$check_name}' as check_name,'{$check_name}' as invoice_type,types FROM {$tableName} WHERE {$where}";
|
}
|
$sqlCount = "SELECT COUNT(*) AS count FROM {$tableName} WHERE {$where}";
|
// 查询数据库中是否存在该数据表
|
$is_table = Db::query("SHOW TABLES LIKE '{$tableName}'");
|
// 判断查询结果
|
if (!empty($is_table)) {
|
$sqlParts[] = $sqlPart;
|
$sqlCounts[] = $sqlCount;
|
$fortable[] = $table['check_table'];
|
}
|
}
|
|
// 使用implode将各个部分用UNION ALL连接起来
|
$unionSql = implode(" UNION ALL ", $sqlParts);
|
|
$totalCount = 0;
|
foreach ($sqlCounts as $sql) {
|
$count = Db::query($sql)[0]['count']; // 假设每个查询都返回了一个包含'count'键的数组
|
$totalCount += $count;
|
}
|
// 添加排序和分页逻辑
|
$page = isset($param['page']) ? $param['page'] : 1;
|
$pageSize = $param['limit'];
|
$offset = ($page - 1) * $pageSize;
|
|
// 注意：不同的数据库分页语法可能有所不同，这里以MySQL为例
|
$finalSql = $unionSql . " ORDER BY create_time DESC LIMIT {$offset}, {$pageSize}";
|
|
// 执行查询
|
$result = Db::query($finalSql);
|
// 处理结果
|
foreach ($result as &$row) {
|
// 处理每一行数据
|
$row['create_time'] = date('Y-m-d H:i:s',$row['create_time']);
|
$row['admin_name'] = Db::name('Admin')->where('id',$row['admin_id'])->value('name');
|
$row['department'] = Db::name('Department')->where('id',$row['did'])->value('title');
|
$row['check_status_str'] = check_status_name($row['check_status']);
|
if($row['check_status']==1 && !empty($row['check_uids'])){
|
$check_users = Db::name('Admin')->where('id','in',$row['check_uids'])->column('name');
|
$row['check_users'] = implode(',',$check_users);
|
}
|
else{
|
$row['check_users']='-';
|
}
|
if(!empty($row['check_copy_uids'])){
|
$check_copy_users = Db::name('Admin')->where('id','in',$row['check_copy_uids'])->column('name');
|
$row['check_copy_users'] = implode(',',$check_copy_users);
|
}
|
else{
|
$row['check_copy_users']='-';
|
}
|
|
$check_name=$row['check_name'];
|
if($row['table_name'] == 'invoice' || $row['table_name']=='ticket'){
|
if($row['invoice_type']==0){
|
$check_name=$row['table_name'].'a';
|
}
|
else{
|
$check_name=$row['table_name'];
|
}
|
}
|
if($row['table_name'] == 'approve'){
|
$check_name='approve_'.$row['types'];
|
}
|
$flow_cate = Db::name('FlowCate')->where('name',$check_name)->find();
|
$row['types_name'] = $flow_cate['title'];
|
$row['view_url'] = $flow_cate['view_url'];
|
$row['add_url'] = $flow_cate['add_url'];
|
}
|
$list=array(
|
'data'=>$result,
|
'total'=>$totalCount
|
);
|
return $list;
|
}
|
|
|
//我申请的
|
public function mylist()
|
{
|
if (request()->isAjax()) {
|
$param = get_params();
|
$status = isset($param['status']) ? $param['status'] : 0;
|
$uid = $this->uid;
|
$where = "delete_time = 0";
|
if($status == 1){
|
$where.= " AND check_status < 2";
|
}
|
if($status == 2){
|
$where.= " AND check_status = 2";
|
}
|
if($status == 3){
|
$where.= " AND check_status > 2";
|
}
|
$where.= ' AND admin_id = '.$uid;
|
//关联抄送人
|
//$where.= " AND FIND_IN_SET('{$uid}',check_copy_uids)";
|
//关联审核人
|
//$where.= " AND (FIND_IN_SET('{$uid}',check_uids) or FIND_IN_SET('{$uid}',check_history_uids))";
|
$list = $this->get_list($where,$param);
|
return table_assign(0, '', $list);
|
} else {
|
return view();
|
}
|
}
|
|
public function checklist()
|
{
|
if (request()->isAjax()) {
|
$param = get_params();
|
$uid = $this->uid;
|
$status = isset($param['status']) ? $param['status'] : 0;
|
$where = "delete_time = 0";
|
if($status == 0){
|
$where.= " AND (FIND_IN_SET('{$uid}',check_uids) or FIND_IN_SET('{$uid}',check_history_uids))";
|
}
|
if($status == 1){
|
$where.= " AND FIND_IN_SET('{$uid}',check_uids)";
|
}
|
if($status == 2){
|
$where.= " AND FIND_IN_SET('{$uid}',check_history_uids)";
|
}
|
$list = $this->get_list($where,$param);
|
return table_assign(0, '', $list);
|
} else {
|
return view();
|
}
|
}
|
|
public function copylist()
|
{
|
if (request()->isAjax()) {
|
$param = get_params();
|
$status = isset($param['status']) ? $param['status'] : 0;
|
$uid = $this->uid;
|
$where = "delete_time = 0";
|
if($status == 1){
|
$where.= " AND check_status < 2";
|
}
|
if($status == 2){
|
$where.= " AND check_status = 2";
|
}
|
if($status == 3){
|
$where.= " AND check_status > 2";
|
}
|
//关联抄送人
|
$where.= " AND FIND_IN_SET('{$uid}', check_copy_uids) > 0";
|
$list = $this->get_list($where,$param);
|
return table_assign(0, '', $list);
|
} else {
|
return view();
|
}
|
}
|
|
//全部审批
|
public function all()
|
{
|
$auth_approve = isAuth($this->uid,'office_admin','conf_1');
|
if (request()->isAjax()) {
|
if($auth_approve==0){
|
return to_assign(1, '无权限访问');
|
}
|
$param = get_params();
|
$status = isset($param['status']) ? $param['status'] : 0;
|
$uid = $this->uid;
|
$where = "delete_time = 0";
|
if($status == 1){
|
$where.= " AND check_status < 2";
|
}
|
if($status == 2){
|
$where.= " AND check_status = 2";
|
}
|
if($status == 3){
|
$where.= " AND check_status > 2";
|
}
|
if(!empty($param['uid'])){
|
$where.= ' AND admin_id = '.$param['uid'];
|
}
|
$list = $this->get_list($where,$param);
|
return table_assign(0, '', $list);
|
} else {
|
if($auth_approve==0){
|
throw new \think\exception\HttpException(405, '无权限访问');
|
}
|
return view();
|
}
|
}
|
}
|
