<?php

namespace App\Http\Controllers\Api;

use App\Module\Doo;
use Request;
use Session;
use Response;
use Madzipper;
use Carbon\Carbon;
use App\Models\User;
use App\Module\Base;
use App\Module\Ihttp;
use App\Tasks\PushTask;
use App\Module\BillExport;
use App\Models\WebSocketDialog;
use App\Models\ApproveProcMsg;
use App\Exceptions\ApiException;
use App\Models\UserDepartment;
use App\Models\WebSocketDialogMsg;
use App\Module\BillMultipleExport;
use Hhxsv5\LaravelS\Swoole\Task\Task;

/**
 * @apiDefine approve
 *
 * 工作流
 */
class ApproveController extends AbstractController
{
    private $flow_url = '';

    public function __construct()
    {
        $this->flow_url = env('FLOW_URL') ?: 'http://approve';
    }

    /**
     * @api {get} api/approve/verifyToken          01. 验证APi登录
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName verifyToken
     *
     * @apiSuccess {String} version
     * @apiSuccess {String} publish
     */
    public function verifyToken()
    {
        try {
            $user = User::auth();
            $user->checkAdmin();
            return Base::retSuccess('成功');
        } catch (\Throwable $th) {
            return response('身份无效', 400)->header('Content-Type', 'text/plain');
        }
    }

    /**
     * @api {post} api/approve/procdef/all          02. 查询流程定义
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName procdef__all
     *
     * @apiQuery {String} name               流程名称
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function procdef__all()
    {
        User::auth();
        $data['name'] = Request::input('name');
        $ret = Ihttp::ihttp_post($this->flow_url . '/api/v1/workflow/procdef/findAll', json_encode($data));
        $procdef = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$procdef || $procdef['status'] != 200 || $ret['ret'] == 0) {
            // info($ret);
            return Base::retError($procdef['message'] ?? '查询失败');
        }
        return Base::retSuccess('success', Base::arrayKeyToUnderline($procdef['data']));
    }

    /**
     * @api {get} api/approve/procdef/del          03. 删除流程定义
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName procdef__del
     *
     * @apiQuery {String} id               流程ID
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function procdef__del()
    {
        User::auth('admin');
        $data['id'] = Request::input('id');
        $ret = Ihttp::ihttp_get($this->flow_url . '/api/v1/workflow/procdef/delById?' . http_build_query($data));
        $procdef = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$procdef || $procdef['status'] != 200) {
            return Base::retError($procdef['message'] ?? '删除失败');
        }
        return Base::retSuccess('success', Base::arrayKeyToUnderline($procdef['data']));
    }

    /**
     * @api {post} api/approve/process/start          04. 启动流程（审批中）
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName process__start
     *
     * @apiQuery {String} proc_name            流程名称
     * @apiQuery {Number} department_id        部门ID
     * @apiQuery {Array} [var]                 启动流程类型信息（格式：[{type,startTime,endTime,description}]）
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function process__start()
    {
        $user = User::auth();
        $data['userid'] = (string)$user->userid;
        $data['department_id'] = intval(Request::input('department_id'));
        $data['proc_name'] = Request::input('proc_name');
        //
        $var = json_decode(Request::input('var'), true);
        $data['var'] = $var;
        $ret = Ihttp::ihttp_post($this->flow_url . '/api/v1/workflow/process/start', json_encode(Base::arrayKeyToCamel($data)));
        $process = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$process || $process['status'] != 200) {
            return Base::retError($process['message'] ?? '启动失败');
        }
        //
        $process = Base::arrayKeyToUnderline($process['data']);
        $process = $this->getProcessById($process['id']); //获取最新的流程信息
        if ($process['candidate']) {
            $userid = explode(',', $process['candidate']);
            $toUser = User::whereIn('userid', $userid)->get()->toArray();
            $botUser = User::botGetOrCreate('approval-alert');
            if (empty($botUser)) {
                return Base::retError('审批机器人不存在');
            }
            foreach ($toUser as $val) {
                if ($val['bot']) {
                    continue;
                }
                $dialog = WebSocketDialog::checkUserDialog($botUser, $val['userid']);
                if (empty($dialog)) {
                    continue;
                }
                $this->approveMsg('approve_reviewer', $dialog, $botUser, $val, $process, 'start');
            }
            // 抄送人
            $notifier = $this->handleProcessNode($process);
            if ($notifier) {
                foreach ($notifier as $val) {
                    $dialog = WebSocketDialog::checkUserDialog($botUser, $val['target_id']);
                    $this->approveMsg('approve_notifier', $dialog, $botUser, $process, $process);
                }
            }
        }

        return Base::retSuccess('创建成功', $process);
    }

    /**
     * @api {post} api/approve/process/addGlobalComment          05. 添加全局评论
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName process__addGlobalComment
     *
     * @apiQuery {Number} proc_inst_id        流程实例ID
     * @apiQuery {String} content             评论内容
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function process__addGlobalComment()
    {
        $user = User::auth();
        $data['proc_inst_id'] = intval(Request::input('proc_inst_id'));
        $data['userid'] = (string)$user->userid;
        $data['content'] = Request::input('content'); //内容+图片

        $processInst = $this->getProcessById($data['proc_inst_id']);

        $ret = Ihttp::ihttp_post($this->flow_url . '/api/v1/workflow/process/addGlobalComment', json_encode(Base::arrayKeyToCamel($data)));
        $process = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$process || $process['status'] != 200) {
            return Base::retError($process['message'] ?? '添加失败');
        }

        // 推送通知
        $botUser = User::botGetOrCreate('approval-alert');
        foreach ($processInst['userids'] as $id) {
            if ($id != $user->userid) {
                $dialog = WebSocketDialog::checkUserDialog($botUser, $id);
                $processInst['comment_user_id'] = $user->userid;
                $processInst['comment_contents'] = json_decode($data['content'], true) ?? [];
                $this->approveMsg('approve_comment_notifier', $dialog, $botUser, $processInst, $processInst);
            }
        }

        $res = Base::arrayKeyToUnderline($process['data']);
        return Base::retSuccess('success', $res);
    }

    /**
     * @api {post} api/approve/task/complete          06. 审批
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName task__complete
     *
     * @apiQuery {Number} task_id               流程ID
     * @apiQuery {String} pass                  标题 [true-通过，false-拒绝]
     * @apiQuery {String} comment               评论
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function task__complete()
    {
        $user = User::auth();
        $data['userid'] = (string)$user->userid;
        $data['task_id'] = intval(Request::input('task_id'));
        $data['pass'] = Request::input('pass');
        $data['comment'] = Request::input('comment');
        $ret = Ihttp::ihttp_post($this->flow_url . '/api/v1/workflow/task/complete', json_encode(Base::arrayKeyToCamel($data)));
        $task = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$task || $task['status'] != 200) {
            return Base::retError($task['message'] ?? '审批失败');
        }
        //
        $task = Base::arrayKeyToUnderline($task['data']);
        $pass = $data['pass'] == 'true' ? 'pass' : 'refuse';
        $process = $this->getProcessById($task['proc_inst_id']);
        $botUser = User::botGetOrCreate('approval-alert');
        if (empty($botUser)) {
            return Base::retError('审批机器人不存在');
        }
        // 在流程信息关联的用户中查找
        $toUser = ApproveProcMsg::where('proc_inst_id', $process['id'])->get()->toArray();
        foreach ($toUser as $val) {
            $dialog = WebSocketDialog::checkUserDialog($botUser, $val['userid']);
            if (empty($dialog)) {
                continue;
            }
            $this->approveMsg('approve_reviewer', $dialog, $botUser, $val, $process, $pass);
        }
        // 发起人
        if ($process['is_finished']) {
            $dialog = WebSocketDialog::checkUserDialog($botUser, $process['start_user_id']);
            if (!empty($dialog)) {
                $this->approveMsg('approve_submitter', $dialog, $botUser, ['userid' => $data['userid']], $process, $pass);
            }
        } else if ($process['candidate']) {
            // 下个审批人
            $userid = explode(',', $process['candidate']);
            $toUser = User::whereIn('userid', $userid)->get()->toArray();
            foreach ($toUser as $val) {
                if ($val['bot']) {
                    continue;
                }
                $dialog = WebSocketDialog::checkUserDialog($botUser, $val['userid']);
                if (empty($dialog)) {
                    continue;
                }
                $this->approveMsg('approve_reviewer', $dialog, $botUser, $val, $process, 'start');
            }
        }

        // 抄送人
        $notifier = $this->handleProcessNode($process);
        if ($notifier && $pass == 'pass') {
            foreach ($notifier as $val) {
                $dialog = WebSocketDialog::checkUserDialog($botUser, $val['target_id']);
                if (!empty($dialog)) {
                    $this->approveMsg('approve_notifier', $dialog, $botUser, $process, $process);
                }
            }
        }
        return Base::retSuccess($pass == 'pass' ? '已通过' : '已拒绝', $task);
    }

    /**
     * @api {post} api/approve/task/withdraw          07. 撤回
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName task__withdraw
     *
     * @apiQuery {Number} task_id               流程ID
     * @apiQuery {Number} proc_inst_id          流程实例ID
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function task__withdraw()
    {
        $user = User::auth();
        $data['userid'] = (string)$user->userid;
        $data['task_id'] = intval(Request::input('task_id'));
        $data['proc_inst_id'] = intval(Request::input('proc_inst_id'));
        $ret = Ihttp::ihttp_post($this->flow_url . '/api/v1/workflow/task/withdraw', json_encode(Base::arrayKeyToCamel($data)));
        $task = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$task || $task['status'] != 200) {
            return Base::retError($task['message'] ?? '撤回失败');
        }
        //
        $process = $this->getProcessById($data['proc_inst_id']);
        $botUser = User::botGetOrCreate('approval-alert');
        if (empty($botUser)) {
            return Base::retError('审批机器人不存在');
        }
        // 在流程信息关联的用户中查找
        $toUser = ApproveProcMsg::where('proc_inst_id', $process['id'])->get()->toArray();
        foreach ($toUser as $val) {
            $dialog = WebSocketDialog::checkUserDialog($botUser, $val['userid']);
            if (empty($dialog)) {
                continue;
            }
            //发送撤回提醒
            $this->approveMsg('approve_reviewer', $dialog, $botUser, $val, $process, 'withdraw');
        }
        return Base::retSuccess('已撤回', Base::arrayKeyToUnderline($task['data']));
    }

    /**
     * @api {post} api/approve/process/findTask          08. 查询需要我审批的流程（审批中）
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName process__findTask
     *
     * @apiQuery {String} proc_def_name         流程名称
     * @apiQuery {String} sort                  排序[asc升序，desc降序]
     * @apiQuery {Number} page                  页码
     * @apiQuery {Number} page_size             每页条数
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function process__findTask()
    {
        $user = User::auth();
        $data['userid'] = (string)$user->userid;
        $data['username'] = Request::input('username');
        $data['procName'] = Request::input('proc_def_name');
        $data['sort'] = Request::input('sort');
        $data['pageIndex'] = intval(Request::input('page'));
        $data['pageSize'] = intval(Request::input('page_size'));
        $ret = Ihttp::ihttp_post($this->flow_url . '/api/v1/workflow/process/findTask', json_encode(Base::arrayKeyToCamel($data)));
        $process = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$process || $process['status'] != 200) {
            return Base::retError($process['message'] ?? '查询失败');
        }
        //
        $res = Base::arrayKeyToUnderline($process['data']);
        foreach ($res['rows'] as &$val) {
            $info = User::whereUserid($val['start_user_id'])->first();
            if (!$info) {
                continue;
            }
            $val['userimg'] = User::getAvatar($info->userid, $info->userimg, $info->email, $info->nickname);
        }
        return Base::retSuccess('success', $res);
    }

    /**
     * @api {post} api/approve/process/startByMyselfAll          09. 查询我启动的流程（全部）
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName process__startByMyselfAll
     *
     * @apiQuery {String} proc_def_name         流程分类
     * @apiQuery {String} state                 流程状态[0全部，1审批中，2通过，3拒绝，4撤回]
     * @apiQuery {Number} page                  页码
     * @apiQuery {Number} page_size             每页条数
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function process__startByMyselfAll()
    {
        $user = User::auth();
        $data['userid'] = (string)$user->userid;
        $data['username'] = Request::input('username');
        $data['procName'] = Request::input('proc_def_name'); //分类
        $data['state'] = intval(Request::input('state')); //状态
        $data['pageIndex'] = intval(Request::input('page'));
        $data['pageSize'] = intval(Request::input('page_size'));
        $ret = Ihttp::ihttp_post($this->flow_url . '/api/v1/workflow/process/startByMyselfAll', json_encode($data));
        $process = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$process || $process['status'] != 200) {
            return Base::retError($process['message'] ?? '查询失败');
        }
        //
        $res = Base::arrayKeyToUnderline($process['data']);
        foreach ($res['rows'] as &$val) {
            $info = User::whereUserid($val['start_user_id'])->first();
            if (!$info) {
                continue;
            }
            $val['userimg'] = User::getAvatar($info->userid, $info->userimg, $info->email, $info->nickname);
        }
        return Base::retSuccess('success', $res);
    }

    /**
     * @api {post} api/approve/process/startByMyself          10. 查询我启动的流程（审批中）
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName process__startByMyself
     *
     * @apiQuery {Number} page                  页码
     * @apiQuery {Number} page_size             每页条数
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function process__startByMyself()
    {
        $user = User::auth();
        $data['userid'] = (string)$user->userid;
        $data['pageIndex'] = intval(Request::input('page'));
        $data['pageSize'] = intval(Request::input('page_size'));
        $ret = Ihttp::ihttp_post($this->flow_url . '/api/v1/workflow/process/startByMyself', json_encode($data));
        $process = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$process || $process['status'] != 200) {
            return Base::retError($process['message'] ?? '查询失败');
        }
        //
        $res = Base::arrayKeyToUnderline($process['data']);
        foreach ($res['rows'] as &$val) {
            $info = User::whereUserid($val['start_user_id'])->first();
            if (!$info) {
                continue;
            }
            $val['userimg'] = User::getAvatar($info->userid, $info->userimg, $info->email, $info->nickname);
        }
        return Base::retSuccess('success', $res);
    }

    /**
     * @api {post} api/approve/process/findProcNotify          11. 查询抄送我的流程（审批中）
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName process__findProcNotify
     *
     * @apiQuery {Number} userid               用户ID
     * @apiQuery {String} proc_def_name        流程分类
     * @apiQuery {String} sort                 排序[asc升序，desc降序]
     * @apiQuery {Number} page                  页码
     * @apiQuery {Number} page_size             每页条数
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function process__findProcNotify()
    {
        $user = User::auth();
        $data['userid'] = (string)$user->userid;
        $data['procName'] = Request::input('proc_def_name');
        $data['sort'] = Request::input('sort');
        $data['pageIndex'] = intval(Request::input('page'));
        $data['pageSize'] = intval(Request::input('page_size'));

        $ret = Ihttp::ihttp_post($this->flow_url . '/api/v1/workflow/process/findProcNotify', json_encode($data));
        $process = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$process || $process['status'] != 200) {
            return Base::retError($process['message'] ?? '查询失败');
        }
        //
        $res = Base::arrayKeyToUnderline($process['data']);
        foreach ($res['rows'] as &$val) {
            $info = User::whereUserid($val['start_user_id'])->first();
            if (!$info) {
                continue;
            }
            $val['userimg'] = User::getAvatar($info->userid, $info->userimg, $info->email, $info->nickname);
        }
        return Base::retSuccess('success', $res);
    }

    /**
     * @api {get} api/approve/identitylink/findParticipant          12. 查询流程实例的参与者（审批中）
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName identitylink__findParticipant
     *
     * @apiQuery {Number} proc_inst_id             流程实例ID
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function identitylink__findParticipant()
    {
        User::auth();
        $proc_inst_id = Request::input('proc_inst_id');
        $ret = Ihttp::ihttp_get($this->flow_url . '/api/v1/workflow/identitylink/findParticipant?procInstId=' . $proc_inst_id);
        $identitylink = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$identitylink || $identitylink['status'] != 200) {
            return Base::retError($identitylink['message'] ?? '查询失败');
        }
        //
        $res = Base::arrayKeyToUnderline($identitylink['data']);
        foreach ($res as &$val) {
            $info = User::whereUserid($val['userid'])->first();
            if (!$info) {
                continue;
            }
            $val['userimg'] = User::getAvatar($info->userid, $info->userimg, $info->email, $info->nickname);
        }
        return Base::retSuccess('success', $res);
    }

    /**
     * @api {post} api/approve/procHistory/findTask          13. 查询需要我审批的流程（已结束）
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName procHistory__findTask
     *
     * @apiQuery {String} proc_def_name        流程分类
     * @apiQuery {String} sort                 排序[asc升序，desc降序]
     * @apiQuery {Number} page                  页码
     * @apiQuery {Number} page_size             每页条数
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function procHistory__findTask()
    {
        $user = User::auth();
        $data['userid'] = (string)$user->userid;
        $data['username'] = Request::input('username');
        $data['procName'] = Request::input('proc_def_name');
        $data['sort'] = Request::input('sort');
        $data['pageIndex'] = intval(Request::input('page'));
        $data['pageSize'] = intval(Request::input('page_size'));
        $ret = Ihttp::ihttp_post($this->flow_url . '/api/v1/workflow/procHistory/findTask', json_encode(Base::arrayKeyToCamel($data)));
        $process = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$process || $process['status'] != 200) {
            return Base::retError($process['message'] ?? '查询失败');
        }
        //
        $res = Base::arrayKeyToUnderline($process['data']);
        foreach ($res['rows'] as &$val) {
            $info = User::whereUserid($val['start_user_id'])->first();
            if (!$info) {
                continue;
            }
            $val['userimg'] = User::getAvatar($info->userid, $info->userimg, $info->email, $info->nickname);
        }
        return Base::retSuccess('success', $res);
    }

    /**
     * @api {post} api/approve/procHistory/startByMyself          14. 查询我启动的流程（已结束）
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName procHistory__startByMyself
     *
     * @apiQuery {Number} page                  页码
     * @apiQuery {Number} page_size             每页条数
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function procHistory__startByMyself()
    {
        $user = User::auth();
        $data['userid'] = (string)$user->userid;
        $data['pageIndex'] = intval(Request::input('page'));
        $data['pageSize'] = intval(Request::input('page_size'));
        $ret = Ihttp::ihttp_post($this->flow_url . '/api/v1/workflow/procHistory/startByMyself', json_encode($data));
        $process = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$process || $process['status'] != 200) {
            return Base::retError($process['message'] ?? '查询失败');
        }
        //
        $res = Base::arrayKeyToUnderline($process['data']);
        foreach ($res['rows'] as &$val) {
            $info = User::whereUserid($val['start_user_id'])->first();
            if (!$info) {
                continue;
            }
            $val['userimg'] = User::getAvatar($info->userid, $info->userimg, $info->email, $info->nickname);
        }
        return Base::retSuccess('success', $res);
    }

    /**
     * @api {post} api/approve/procHistory/findProcNotify          15. 查询抄送我的流程（已结束）
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName procHistory__findProcNotify
     *
     * @apiQuery {String} proc_def_name         流程分类
     * @apiQuery {String} sort                  排序[asc升序，desc降序]
     * @apiQuery {Number} page                  页码
     * @apiQuery {Number} page_size             每页条数
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function procHistory__findProcNotify()
    {
        $user = User::auth();
        $data['userid'] = (string)$user->userid;
        $data['username'] = Request::input('username');
        $data['procName'] = Request::input('proc_def_name');
        $data['sort'] = Request::input('sort');
        $data['pageIndex'] = intval(Request::input('page'));
        $data['pageSize'] = intval(Request::input('page_size'));

        $ret = Ihttp::ihttp_post($this->flow_url . '/api/v1/workflow/procHistory/findProcNotify', json_encode($data));
        $process = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$process || $process['status'] != 200) {
            return Base::retError($process['message'] ?? '查询失败');
        }
        //
        $res = Base::arrayKeyToUnderline($process['data']);
        foreach ($res['rows'] as &$val) {
            $info = User::whereUserid($val['start_user_id'])->first();
            if (!$info) {
                continue;
            }
            $val['userimg'] = User::getAvatar($info->userid, $info->userimg, $info->email, $info->nickname);
        }
        return Base::retSuccess('success', $res);
    }

    /**
     * @api {get} api/approve/identitylinkHistory/findParticipant          16. 查询流程实例的参与者（已结束）
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName identitylinkHistory__findParticipant
     *
     * @apiQuery {Number} proc_inst_id             流程实例ID
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function identitylinkHistory__findParticipant()
    {
        User::auth();
        $proc_inst_id = Request::input('proc_inst_id');
        $ret = Ihttp::ihttp_get($this->flow_url . '/api/v1/workflow/identitylinkHistory/findParticipant?procInstId=' . $proc_inst_id);
        $identitylink = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$identitylink || $identitylink['status'] != 200) {
            return Base::retError($identitylink['message'] ?? '查询失败');
        }
        //
        $res = Base::arrayKeyToUnderline($identitylink['data']);
        foreach ($res as &$val) {
            $info = User::whereUserid($val['userid'])->first();
            if (!$info) {
                continue;
            }
            $val['userimg'] = User::getAvatar($info->userid, $info->userimg, $info->email, $info->nickname);
        }
        return Base::retSuccess('success', $res);
    }

    /**
     * @api {get} api/approve/process/detail          17. 根据流程ID查询流程详情
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName process__detail
     *
     * @apiQuery {Number} id               流程ID
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function process__detail()
    {
        User::auth();
        $data['id'] = intval(Request::input('id'));
        $approve = $this->getProcessById($data['id']);
        return Base::retSuccess('success', $approve);
    }

    /**
     * @api {post} api/approve/export          18. 导出数据
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName export
     *
     * @apiQuery {String} proc_def_name         流程分类
     * @apiQuery {String} state                 流程状态[0全部，1审批中，2通过，3拒绝，4撤回]
     * @apiQuery {String} is_finished           是否完成
     * @apiQuery {Array} [date]                 指定日期范围，如：['2020-12-12', '2020-12-30']
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function export()
    {
        $user = User::auth('admin');
        $name = $data['procName'] = Request::input('proc_def_name'); //分类
        $data['state'] = intval(Request::input('state')); //状态
        $data['isFinished'] = intval(Request::input('is_finished')); //是否完成
        $date = Request::input('date');
        $data['startTime'] = $date[0]; //开始时间
        $data['endTime'] = Carbon::parse($date[1])->addDay()->toDateString(); //结束时间 + 1天
        //
        if (empty($name) || empty($date)) {
            return Base::retError('参数错误');
        }
        if (!(is_array($date) && Base::isDate($date[0]) && Base::isDate($date[1]))) {
            return Base::retError('日期选择错误');
        }
        if (Carbon::parse($date[1])->timestamp - Carbon::parse($date[0])->timestamp > 35 * 86400) {
            return Base::retError('日期范围限制最大35天');
        }
        //
        $ret = Ihttp::ihttp_post($this->flow_url . '/api/v1/workflow/process/findAllProcIns', json_encode($data));
        $process = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$process || $process['status'] != 200) {
            return Base::retError($process['message'] ?? '查询失败');
        }
        //
        $res = Base::arrayKeyToUnderline($process['data']);
        //
        $headings = [];
        $headings[] = Doo::translate('申请编号');
        $headings[] = Doo::translate('标题');
        $headings[] = Doo::translate('申请状态');
        $headings[] = Doo::translate('发起时间');
        $headings[] = Doo::translate('完成时间');
        $headings[] = Doo::translate('发起人工号');
        $headings[] = Doo::translate('发起人User ID');
        $headings[] = Doo::translate('发起人姓名');
        $headings[] = Doo::translate('发起人部门');
        $headings[] = Doo::translate('发起人部门ID');
        $headings[] = Doo::translate('部门负责人');
        $headings[] = Doo::translate('历史审批人');
        $headings[] = Doo::translate('历史办理人');
        $headings[] = Doo::translate('审批记录');
        $headings[] = Doo::translate('当前处理人');
        $headings[] = Doo::translate('审批节点');
        $headings[] = Doo::translate('审批人数');
        $headings[] = Doo::translate('审批耗时');
        $headings[] = Doo::translate('假期类型');
        $headings[] = Doo::translate('开始时间');
        $headings[] = Doo::translate('结束时间');
        $headings[] = Doo::translate('时长');
        $headings[] = Doo::translate('请假事由');
        $headings[] = Doo::translate('请假单位');
        //
        $datas = [];
        foreach ($res as $val) {
            //
            $nickname = Base::filterEmoji($val['start_user_name']);
            $participant = $this->getUserProcessParticipantById($val['id']); // 获取参与人
            $participant = $this->handleParticipant($val, $participant['data']); // 处理参与人返回数据
            //
            $job_number = ''; // 发起人工号
            $department_leader = User::userid2nickname(UserDepartment::find(1, ['owner_userid'])['owner_userid']); // 部门负责人
            $historical_approver = $participant['historical_approver'] ?? ''; // 历史审批人
            $historical_agent = ''; // 历史办理人
            $approval_record = $participant['approval_record'] ?? ''; // 审批记录
            $current_handler = !$val['is_finished'] ? implode(',', User::whereIn('userid', explode(';', $val['candidate']))->pluck('nickname')->toArray()) : ''; // 当前处理人
            $approved_node = $participant['approved_node'] ?? 0; // 审批节点
            $approved_num = $participant['approved_num'] ?? 0; // 审批人数
            // 计算审批耗时
            $startTime = Carbon::parse($val['start_time'])->timestamp;
            $endTime = $val['end_time'] ? Carbon::parse($val['end_time'])->timestamp : time();
            $approval_time = Doo::translate(Base::timeDiff($startTime, $endTime)); // 审批耗时
            // 计算时长
            $varStartTime = Carbon::parse($val['var']['start_time']);
            $varEndTime = Carbon::parse($val['var']['end_time']);
            $duration = $varEndTime->floatDiffInHours($varStartTime);
            $duration_unit = Doo::translate('小时'); // 时长单位
            $datas[] = [
                $val['id'], // 申请编号
                $val['proc_def_name'], // 标题
                $this->getStateDescription($val['state']), // 申请状态
                $val['start_time'], // 发起时间
                $val['end_time'], // 完成时间
                $job_number, // 发起人工号
                $val['start_user_id'], // 发起人User ID
                $nickname, // 发起人姓名
                $val['department'], // 发起人部门
                $val['department_id'], // 发起人部门ID
                $department_leader, // 部门负责人
                $historical_approver, // 历史审批人
                $historical_agent, // 历史办理人
                $approval_record, // 审批记录
                $current_handler, // 当前处理人
                $approved_node, // 审批节点
                $approved_num, // 审批人数
                $approval_time, // 审批耗时
                $val['var']['type'], // 假期类型
                $val['var']['start_time'], // 开始时间
                $val['var']['end_time'], // 结束时间
                $duration, // 时长
                $val['var']['description'], // 请假事由
                $duration_unit, // 请假单位
            ];
        }
        if (empty($datas)) {
            return Base::retError('没有任何数据');
        }
        //
        $title = Doo::translate("审批记录");
        $sheets = [
            BillExport::create()->setTitle($title)->setHeadings($headings)->setData($datas)->setStyles(["A1:Y1" => ["font" => ["bold" => true]]])
        ];
        //
        $fileName = $title . '_' . Base::time() . '.xlsx';
        $filePath = "temp/approve/export/" . date("Ym", Base::time());
        $export = new BillMultipleExport($sheets);
        $res = $export->store($filePath . "/" . $fileName);
        if ($res != 1) {
            return Base::retError('导出失败，' . $fileName . '！');
        }
        $xlsPath = storage_path("app/" . $filePath . "/" . $fileName);
        $zipFile = "app/" . $filePath . "/" . Base::rightDelete($fileName, '.xlsx') . ".zip";
        $zipPath = storage_path($zipFile);
        if (file_exists($zipPath)) {
            Base::deleteDirAndFile($zipPath, true);
        }
        try {
            Madzipper::make($zipPath)->add($xlsPath)->close();
        } catch (\Throwable) {
        }
        //
        if (file_exists($zipPath)) {
            $base64 = base64_encode(Base::array2string([
                'file' => $zipFile,
            ]));
            Session::put('approve::export:userid', $user->userid);
            return Base::retSuccess('success', [
                'size' => Base::twoFloat(filesize($zipPath) / 1024, true),
                'url' => Base::fillUrl('api/approve/down?key=' . urlencode($base64)),
            ]);
        } else {
            return Base::retError('打包失败，请稍后再试...');
        }
    }

    function getStateDescription($state)
    {
        $state_map = array(
            0 => '全部',
            1 => '审批中',
            2 => '通过',
            3 => '拒绝',
            4 => '撤回'
        );
        return $state_map[$state] ?? '';
    }

    /**
     * @api {get} api/approve/down          19. 下载导出的审批数据
     *
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName down
     *
     * @apiParam {String} key               通过export接口得到的下载钥匙
     *
     * @apiSuccess {File} data     返回数据（直接下载文件）
     */
    public function down()
    {
        $userid = Session::get('approve::export:userid');
        if (empty($userid)) {
            return Base::ajaxError("请求已过期，请重新导出！", [], 0, 502);
        }
        //
        $array = Base::string2array(base64_decode(urldecode(Request::input('key'))));
        $file = $array['file'];
        if (empty($file) || !file_exists(storage_path($file))) {
            return Base::ajaxError("文件不存在！", [], 0, 502);
        }
        return Response::download(storage_path($file));
    }

    // 处理参与人返回数据
    public function handleParticipant($process, $participant)
    {
        // 如果空
        if (empty($participant)) {
            return [];
        }
        $res = [];
        $historical_approver = [];
        $approved_node = 0; // 审批节点
        $approved_num = 0; // 审批人数
        foreach ($participant as $val) {
            // 如果是审批人
            if ($val['type'] == 'participant') {
                if ($val['step'] != 0) {
                    // 过滤掉空的审批意见
                    if ($val['comment'] == '' || in_array($val['username'], $historical_approver)) {
                        continue;
                    }
                    $historical_approver = array_unique(array_merge($historical_approver, explode(',', $val['username'])));
                    $approved_node++;
                    $approved_num++;
                }
                // 审批记录
                $name = $val['username'] . '|';
                $call = $val['step'] == 0 ? '发起审批' . '|' : '同意' . '|';
                $time = $val['step'] == 0 ? $process['start_time'] . '|' : '';
                $comment = $val['step'] == 0 ? '' : ($val['comment'] ?? '') . '|';
                $res['approval_record'] .= $name . $call . $time . $comment;
            }
        }
        $res['historical_approver'] = trim(implode(';', $historical_approver), ';');
        $res['approved_node'] = $approved_node;
        $res['approved_num'] = $approved_num;
        $res['historical_agent'] = $res['historical_approver'];
        return $res;
    }

    // 审批机器人消息
    public function approveMsg($type, $dialog, $botUser, $toUser, $process, $action = null)
    {
        $data = [
            'id' => $process['id'],
            'nickname' => User::userid2nickname($type == 'approve_submitter' ? $toUser['userid'] : $process['start_user_id']),
            'start_nickname' => User::userid2nickname($process['start_user_id']),
            'proc_def_name' => $process['proc_def_name'],
            'department' => $process['department'],
            'type' => $process['var']['type'],
            'start_time' => $process['var']['start_time'],
            'start_day_of_week' => '周' . Base::getTimeWeek(Carbon::parse($process['var']['start_time'])->timestamp),
            'end_time' => $process['var']['end_time'],
            'end_day_of_week' => '周' . Base::getTimeWeek(Carbon::parse($process['var']['end_time'])->timestamp),
            'description' => $process['var']['description'],
            'comment_nickname' => $process['comment_user_id'] ? User::userid2nickname($process['comment_user_id']) : '',
            'comment_content' => $process['comment_contents']['content'] ?? '',
            'comment_pictures' => $process['comment_contents']['pictures'] ?? []
        ];
        $thumb = null;
        if ($type === 'approve_reviewer') {
            $thumb = $process['var']['other'];
        } elseif ($type === 'approve_comment_notifier') {
            $thumb = $data['comment_pictures'] ? $data['comment_pictures'][0] : null;
        }
        if ($thumb && file_exists(public_path($thumb))) {
            $imageSize = getimagesize(public_path($thumb));
            $data['thumb'] = [
                'url' => $thumb,
                'width' => $imageSize[0],
                'height' => $imageSize[1]
            ];
        }
        $msgAction = null;
        $msgData = [
            'type' => $type,
            'action' => $action,
            'is_finished' => $process['is_finished'],
            'data' => $data
        ];
        $msgData['title'] = match ($type) {
            'approve_reviewer' => $data['nickname'] . " 提交的「{$data['proc_def_name']}」待你审批",
            'approve_notifier' => "抄送 {$data['nickname']} 提交的「{$data['proc_def_name']}」记录",
            'approve_comment_notifier' => $data['comment_nickname'] . " 评论了 {$data['nickname']} 的「{$data['proc_def_name']}」审批",
            'approve_submitter' => $action == 'pass' ? "您发起的「{$data['proc_def_name']}」已通过" : "您发起的「{$data['proc_def_name']}」被 {$data['nickname']} 拒绝",
            default => '不支持的指令',
        };
        if ($action == 'withdraw' || $action == 'pass' || $action == 'refuse') {
            // 任务完成，给发起人发送消息
            if ($type == 'approve_submitter' && $action != 'withdraw') {
                return WebSocketDialogMsg::sendMsg($msgAction, $dialog->id, 'template', $msgData, $botUser->userid, false, false, true);
            }
            // 查找最后一条消息msg_id
            $msgAction = 'change-' . $toUser['msg_id'];
        }
        //
        $msg = WebSocketDialogMsg::sendMsg($msgAction, $dialog->id, 'template', $msgData, $process['start_user_id'], false, false, true);
        // 关联信息
        if ($action == 'start') {
            $proc_msg = new ApproveProcMsg();
            $proc_msg->proc_inst_id = $process['id'];
            $proc_msg->msg_id = $msg['data']->id;
            $proc_msg->userid = $toUser['userid'];
            $proc_msg->save();
        }
        // 更新审批 未读数量
        if ($type == 'approve_reviewer' && $toUser['userid']) {
            $params = [
                'userid' => [$toUser['userid'], User::userid()],
                'msg' => [
                    'type' => 'approve',
                    'action' => 'unread',
                    'userid' => $toUser['userid'],
                ]
            ];
            Task::deliver(new PushTask($params, false));
        }
        return true;
    }

    // 根据ID获取流程
    public function getProcessById($id)
    {
        $data['id'] = intval($id);
        $ret = Ihttp::ihttp_get($this->flow_url . "/api/v1/workflow/process/findById?" . http_build_query($data));
        $process = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$process || $process['status'] != 200) {
            throw new ApiException($process['message'] ?? '查询失败');
        }
        //
        $res = Base::arrayKeyToUnderline($process['data']);
        $res['userids'] = [];
        foreach ($res['node_infos'] as &$val) {
            if (isset($val['node_user_list'])) {
                $node = $val['node_user_list'];
                foreach ($node as $k => &$item) {
                    $info = User::whereUserid($item['target_id'])->first();
                    if (!$info) {
                        continue;
                    }
                    $val['node_user_list'][$k]['userimg'] = User::getAvatar($info->userid, $info->userimg, $info->email, $info->nickname);
                    $res['userids'][] = $item['target_id'];
                }
            } else if ($val['aprover_id']) {
                $info = User::whereUserid($val['aprover_id'])->first();
                $val['userimg'] = $info ? User::getAvatar($info->userid, $info->userimg, $info->email, $info->nickname) : '';
                $res['userids'][] = $val['aprover_id'];
            }
        }
        // 全局评论
        unset($res['global_comment']);
        if (isset($res['global_comments'])) {
            foreach ($res['global_comments'] as $k => $globalComment) {
                $info = User::whereUserid($globalComment['user_id'])->first();
                if (!$info) {
                    continue;
                }
                $res['global_comments'][$k]['userimg'] = User::getAvatar($info->userid, $info->userimg, $info->email, $info->nickname);
                $res['global_comments'][$k]['nickname'] = $info->nickname;
            }
        } else {
            $res['global_comments'] = [];
        }
        $info = User::whereUserid($res['start_user_id'])->first();
        $res['userimg'] = $info ? User::getAvatar($info->userid, $info->userimg, $info->email, $info->nickname) : '';
        //
        $res['userids'][] = $info->userid;
        $res['userids'] = array_unique($res['userids']);
        //
        return $res;
    }

    // 处理流程节点返回是否有抄送人
    public function handleProcessNode($process)
    {
        // 获取流程节点
        $process_node = $process['node_infos'];
        $notifier = [];
        foreach ($process_node as $key => $val) {
            if ($val['type'] == 'notifier') {
                $notifier = array_merge($notifier, $val['node_user_list']);
            }
            // 判断到达的节点
            if ($process['node_id'] == $val['node_id']) {
                break;
            }
        }
        return array_unique($notifier, SORT_REGULAR) ?? [];
    }

    // 根据ID查询流程实例的参与者（所有）
    public function getUserProcessParticipantById($id)
    {
        $data['procInstId'] = intval($id);
        $ret = Ihttp::ihttp_get($this->flow_url . "/api/v1/workflow/identitylink/findParticipantAll?" . http_build_query($data));
        $process = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$process || $process['status'] != 200) {
            throw new ApiException($process['message'] ?? '查询失败');
        }
        return $process;
    }


    /**
     * @api {get} api/approve/user/status          20. 获取用户审批状态
     *
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName user__status
     *
     * @apiParam {String} userid
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function user__status()
    {
        $data['userid'] = intval(Request::input('userid'));
        $ret = Ihttp::ihttp_get($this->flow_url . '/api/v1/workflow/process/getUserApprovalStatus?' . http_build_query($data));
        $procdef = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (isset($procdef['status']) && $procdef['status'] == 200) {
            return Base::retSuccess('success', $procdef['data']["proc_def_name"] ?? '');
        }
        return Base::retSuccess('success', '');
    }

    /**
     * @api {get} api/approve/process/doto          21. 查询需要我审批的流程数量
     *
     * @apiDescription 需要token身份
     * @apiVersion 1.0.0
     * @apiGroup approve
     * @apiName process__doto
     *
     * @apiSuccess {Number} ret     返回状态码（1正确、0错误）
     * @apiSuccess {String} msg     返回信息（错误描述）
     * @apiSuccess {Object} data    返回数据
     */
    public function process__doto()
    {
        $user = User::auth();
        $ret = Ihttp::ihttp_get($this->flow_url . '/api/v1/workflow/process/findTaskTotal?userid=' . $user->userid);
        $process = json_decode($ret['ret'] == 1 ? $ret['data'] : '{}', true);
        if (!$process || $process['status'] != 200) {
            return Base::retError($process['message'] ?? '查询失败');
        }
        return Base::retSuccess('success', $process['data']);
    }

}