phpstock/app/admin/controller/ActionProcess.php

<?php

namespace app\admin\controller;

use think\facade\Db;
use think\facade\Validate;
use app\admin\model\ActionProcess as APModel;
use app\admin\model\Process as PModel;

//流程节点
class ActionProcess extends Base
{

    //获取流程节点列表
    public function getList()
    {

        $param = $this->request->filter('trim')->only(['process_id', 'page' => 1, 'size' => 15], 'post');

        $val = Validate::rule([
            'process_id|流程id' => 'require|number|gt:0',
            'page|页码' => 'require|number|gt:0',
            'size|每页显示的页码' => 'require|number|gt:0',
        ]);

        if (!$val->check($param)) return error_show(1005, $val->getError());

        $where = [];
        if ($param['order_type'] != '') $where[] = ['order_type', '=', $param['order_type']];

        $count = Db::name('action_process')
            ->where($where)
            ->count('id');

        $list = APModel::field('id,status_name,order_process,status,action_type,operation_type,next_action_ids,creater,addtime,remark')
            ->where($where)
            ->order('id', 'desc')
            ->page($param['page'], $param['size'])
            ->select()
            ->toArray();

        $all_next_ids = implode(',', array_column($list, 'next_action_ids'));

        //处理下一个节点的名称
        $child = Db::name('action_process')
            ->whereIn('id', $all_next_ids)
            ->column('status_name', 'id');

        foreach ($list as &$item) {
            if ($item['next_action_ids']) {
                $next_action_ids = explode(',', $item['next_action_ids']);
                foreach ($next_action_ids as $next_action_id) {
                    if (isset($child[$next_action_id])) $item['next_actions'][] = $child[$next_action_id];
                }
            } else $item['next_actions'] = [];
        }

        return app_show(0, '获取成功', ['count' => $count, 'list' => $list]);

    }

    //新增
    public function add()
    {

        $param = $this->request->filter('trim')->only(['token', 'process_id', 'action_type', 'operation_type', 'status_name', 'order_process', 'next_action_ids' => '', 'remark' => ''], 'post');

        $val = Validate::rule([
            'token' => 'require',
            'process_id|流程id' => 'require|number|gt:0',
            'action_type|节点类型' => 'require|number|between:' . APModel::$action_type_start . ',' . APModel::$action_type_end,
            'operation_type|操作类型' => 'require|number|in:' . APModel::$operation_type_approval . ',' . APModel::$operation_type_system,
            'status_name|节点名称' => 'require|max:255',
            'order_process|节点值' => 'require|number|egt:0|checkOrderProcess:',
            'next_action_ids|下一节点' => 'array|requireIf:action_type,' . APModel::$action_type_start . '|requireIf:action_type,' . APModel::$action_type_process,
        ]);


        $val->extend('checkOrderProcess', function ($val, $rule, $data) {
            return APModel::where([
                'order_type' => $data['order_type'],
                'order_process' => $val,
                'is_del' => APModel::$is_del_normal
            ])->field('id')->findOrEmpty()->isEmpty() ? true : '同一个流程编码下该节点值已存在';
        });

        if (!$val->check($param)) return error_show(1005, $val->getError());

        $user = GetUserInfo($param['token']);

        $uid = isset($user['data']['id']) ? $user['data']['id'] : 0;
        $uname = isset($user['data']['nickname']) ? $user['data']['nickname'] : '';
        $date = date('Y-m-d H:i:s');

        return APModel::create(array_merge($param, [
            'status' => APModel::$status_normal,
            'is_del' => APModel::$is_del_normal,
            'createrid' => $uid,
            'creater' => $uname,
            'addtime' => $date,
            'updaterid' => $uid,
            'updater' => $uname,
            'updatetime' => $date,
        ]))->save() ? app_show(0, '新增流程节点成功') : error_show(1005, '新增流程节点失败');

    }

    //读取
    public function read()
    {

        $id = $this->request->filter('trim')->post('id/d', 0);

        $res = APModel::field(true)
            ->where(['id' => $id, 'is_del' => APModel::$is_del_normal])
            ->withAttr('next_action_ids', function ($val) {
                return explode(',', $val);
            })
            ->findOrEmpty()
            ->toArray();

        return app_show(0, '请求成功', $res);
    }

    //修改
    public function update()
    {

        $param = $this->request->filter('trim')->only(['token', 'id', 'process_id', 'action_type', 'operation_type', 'status_name', 'order_process', 'next_action_ids' => '', 'remark' => '', 'status' => '', 'is_del' => ''], 'post');

        $val = Validate::rule([
            'token' => 'require',
            'id|ID' => 'require|number|gt:0',
            'process_id' => 'number|gt:0',
            'action_type|节点类型' => 'number|between:' . APModel::$action_type_start . ',' . APModel::$action_type_end,
            'operation_type|操作类型' => 'number|in:' . APModel::$operation_type_approval . ',' . APModel::$operation_type_system,
            'status_name|节点名称' => 'max:255',
            'order_process|节点值' => 'number|egt:0|checkOrderProcess:',
            'next_action_ids|下一节点' => 'array|requireIf:action_type,' . APModel::$action_type_start . '|requireIf:action_type,' . APModel::$action_type_process,
            'is_del|是否删除' => 'eq:' . APModel::$is_deleted,
            'status|状态' => 'in:' . APModel::$status_disable . ',' . APModel::$status_normal,
        ]);


        $val->extend('checkOrderProcess', function ($val, $rule, $data) {
            if (isset($val) && isset($data['order_type'])) return APModel::where(['order_type' => $data['order_type'], 'order_process' => $val, 'is_del' => APModel::$is_del_normal])->where('id', '<>', $data['id'])->field('id')->findOrEmpty()->isEmpty() ? true : '同一个流程编码下该节点值已存在';
            else return true;
        });

        if (!$val->check($param)) return error_show(1005, $val->getError());

        $user = GetUserInfo($param['token']);

        $uid = isset($user['data']['id']) ? $user['data']['id'] : 0;
        $uname = isset($user['data']['nickname']) ? $user['data']['nickname'] : '';
        $date = date('Y-m-d H:i:s');

        return APModel::where(['id' => $param['id'], 'is_del' => APModel::$is_del_normal])->strict(false)->save(array_merge($param, ['updaterid' => $uid, 'updater' => $uname, 'updatetime' => $date])) ? app_show(0, '修改流程节点成功') : error_show(1005, '修改流程节点失败');

    }

    //获取所有流程的所有节点
    public function getAll()
    {

        $data = PModel::where(['is_del' => PModel::$is_del_normal, 'status' => PModel::$status_normal])
            ->column('id,process_name,process_type', 'id');

        $action = APModel::where(['is_del' => APModel::$is_del_normal, 'status' => APModel::$status_normal])
            ->field('id,process_id,order_process,status_name')
            ->cursor();

        foreach ($action as $item) {
            $data[$item->process_id]['child'][] = $item->toArray();
        }

        return app_show(0, '请求成功', array_column($data,null,null));

    }


}