dingding/application/common/service/ApproveService.php

<?php

namespace app\common\service;

use app\common\constant\CommonConstant;
use app\common\model\Approve;
use app\common\model\User;
use think\Db;
use think\Exception;

/**
 * 审批服务类
 */
class ApproveService
{

    /**
     * 审批列表
     *
     * @param integer $status 处理状态
     * @param integer $module 模块类型
     * @param string $start_time 申请开始时间
     * @param string $end_time 申请结束时间
     * @param string $search 搜索
     * @param integer $offset 起始位置
     * @param integer $length 查询数量
     * @param mixed $user 用户信息
     **/
    public static function get_list($status, $module, $start_time, $end_time, $search, $offset, $length, $user)
    {
        if (!in_array($status, [1, 2, 3])) {
            return [];
        }
        if ($module && !array_key_exists($module, CommonConstant::get_module_list())) {
            return [];
        }

        $userids = $search && !is_numeric($search) ? User::where('name', 'like', '%' . $search . '%')->column('userid') : [];

        $userid = $user['userid'];
        $aliasName = 'approve.';
        $jobName = 'approveInfo.';
        $field = 'id as approve_id,info_id,status,create_at';
        $joinField = 'user_id,order_no,apply_date,reason,type,desc,start_time,end_time';
        $field = self::getAliasField($field, $aliasName);
        $joinField = self::getAliasField($joinField, $jobName);
        $field = implode(',', array_merge($field, $joinField));
        $list = Approve::alias('approve')
            ->field($field)
            ->when($status, function ($query) use ($aliasName, $status) {
                if ($status == 1) {
                    $query->where($aliasName . 'status', 'in', [CommonConstant::STATUS_1, CommonConstant::STATUS_2]);
                }
                if ($status == 2) {
                    $query->where($aliasName . 'status', 'in', [CommonConstant::STATUS_3, CommonConstant::STATUS_4]);
                }
            })
            ->where($aliasName . 'is_deleted', CommonConstant::IS_DELETED_0)
            ->where($aliasName . 'approve_user', $userid)
            ->where($jobName . 'is_deleted', CommonConstant::IS_DELETED_0)
            ->when($module, function ($query) use ($jobName, $module) {
                $query->where($jobName . 'module', 'in', $module);
            })
            ->when(!empty($start_time) && !empty($end_time), function ($query) use ($aliasName, $start_time, $end_time) {
                $query->where($aliasName . 'create_at', 'BETWEEN', [$start_time, $end_time]);
            })
            ->when($userids, function ($query) use ($jobName, $userids) {
                $query->where($jobName . 'user_id', 'in', $userids);
            })
            ->when($search, function ($query) use ($search, $userids) {
                if (!$userids) {
                    if (!is_numeric($search)) {
                        $query->where('order_no|reason', 'like', '%' . $search . '%');
                    } else {
                        $query->where('order_no', 'like', '%' . $search . '%');
                    }
                }
            })
            ->join('__APPROVE_INFO__ approveInfo', 'approve.info_id = approveInfo.id', 'INNER');
        if ($status == 1) {
            // 待处理(待审批 审批中) 才关联 审批人信息
            $list->with(['approveInfoUser' => function ($query) {
                $query->field('userid,name');
            }, 'approveOne' => function ($query) {
                $query->field('id,info_id,status,approve_user')
                    ->where('status', CommonConstant::STATUS_2)
                    ->with(['user' => function ($query) {
                        $query->field('userid,name');
                    }]);
            }]);
        } else {
            $list->with(['approveInfoUser' => function ($query) {
                $query->field('userid,name');
            }]);
        }
        $list = $list->limit($offset, $length)
            ->order('approve_id desc')
            ->select();

//        $info_ids = [];
//        foreach ($list as $value){
//            if($value['status'] == CommonConstant::STATUS_1) {
//                $info_ids[] = $value['info_id'];
//            }
//        }
//        if($info_ids){
//            $approve_one_list = Approve::field('id,info_id,status,approve_user')
//                ->where('info_id','in',$info_ids)
//                ->where('status',CommonConstant::STATUS_2)
//                ->where('is_deleted', CommonConstant::IS_DELETED_0)
//                ->with(['user' => function ($query) {
//                    $query->field('userid,name');
//                }])
//                ->select();
//            $approve_one_data = array_column($approve_one_list, null, 'info_id');
//            foreach ($list as $val){
//                if(array_key_exists($val['info_id'],$approve_one_data)){
//                    $val['approve_one'] = $approve_one_data[$val['info_id']];
//                }
//            }
//        }

        return $list;
    }

    /**
     * 详情
     *
     * @param integer $id 审批ID
     * @param mixed $user 用户信息
     * @param string $type 类型:detail=详情,info=信息
     **/
    public static function get_detail($id, $user, $type)
    {
        $userid = $user['userid'];
        $info = Approve::field('id,info_id,status')
            ->where('approve_user', $userid)
            ->where('is_deleted', CommonConstant::IS_DELETED_0)
            ->find($id);
        $data = [];
        if ($info) {
            $data = ApproveInfoService::get_detail($info['info_id'], '', $type);
            $data['approve_id'] = $id;
            $data['approve_status'] = $info['status'];
        }
        return $data;
    }

    /**
     * 审批
     *
     * @param integer $id 审批ID
     * @param string $status 审批状态
     * @param string $remark 审批意见
     * @param mixed $user 用户信息
     **/
    public static function audit($id, $status, $remark, $user)
    {
        $userid = $user['userid'];
        $info = Approve::field('id,info_id,status,approve_flow,approve_time')
            ->where('approve_user', $userid)
            ->where('is_deleted', CommonConstant::IS_DELETED_0)
            ->with([
                'approveInfo' => function ($query) {
                    $query->field('is_deleted', true);
                }
            ])
            ->find($id);
        if (!$info) {
            throw new Exception('审批记录不存在或已删除');
        }
        if ($info->status != CommonConstant::STATUS_2) {
            throw new Exception('非待处理状态无法操作');
        }
        $approve_info = $info->approve_info;
        if (!$approve_info) {
            throw new Exception(CommonConstant::get_module_list()[$approve_info->module] . '记录不存在或已删除');
        }
        if ($approve_info->status != CommonConstant::STATUS_2) {
            throw new Exception('非待处理状态无法操作!');
        }

        $approve_time = date('Y-m-d H:i:s');
        $duration = time() - strtotime($info['approve_time']);

        // 更新审批
        $info->status = $status;
        $info->approve_time = $approve_time;
        $info->remark = $remark;
        $info->time = $duration;
        $info->time_text = get_stay_time($duration);
        $info->save();

        // 更新审批申请
        if ($status == CommonConstant::STATUS_3) {
            if ($info['approve_flow'] < $approve_info['approve_num']) {
                // 更新下一级审批状态
                Approve::where(['info_id' => $info['info_id'], 'approve_flow' => $info['approve_flow'] + 1])->update(['status' => CommonConstant::STATUS_2, 'approve_time' => $approve_time]);
            } else {
                $approve_info->status = $status;
            }
        } else {
            $approve_info->status = $status;
        }
        $approve_info->cur_num = $approve_info['cur_num'] + 1;
        $approve_info->save();
    }

    /**
     * 修改
     *
     * @param integer $id 审批ID
     * @param integer $module 模块类型
     * @param array $params 数组
     * @param mixed $user 用户信息
     **/
    public static function edit($id, $module, $params, $user)
    {
        $userid = $user['userid'];
    }

    /**
     * 拼接查询字段
     */
    public static function getAliasField($field, $aliasName)
    {
        $field = explode(',', $field);
        foreach ($field as &$value) {
            $value = $aliasName . $value;
        }
        return $field;
    }

}