phpstock/app/admin/controller/Proorder.php

<?php

namespace app\admin\controller;

use app\admin\model\ProcessWait;
use think\App;
use think\facade\Db;

//消息(已读未读)
class Proorder extends Base
{

public function __construct(App $app)
{
    parent::__construct($app);
}


    //已读列表
    public function list()
    {

        /**暂时屏蔽
         * $page = isset($this->post['page']) && $this->post['page'] !==""? intval($this->post['page']) :"1";
         * $size = isset($this->post['size']) && $this->post['size'] !==""? intval($this->post['size']) :"10";
         * $where =[['is_del',"=",0],['a.order_status',"=",2]];
         * $role=$this->checkRole();
         * if(!empty($role['write'])){
         * $where[]=["a.action_uid","in",$role['write']];
         * }
         * $count = Db::name('process_order')->alias("a")->leftJoin("workflow b","a.order_type=b.order_type and a.order_code=b.order_code")->where($where)->count();
         * $total = ceil("$count/$size");
         * $page = $page>$total ? $total:$page;
         * $list = Db::name('process_order')->alias("a")->leftJoin("workflow b","a.order_type=b.order_type and a.order_code=b.order_code")
         * ->field("b.apply_id,b.apply_name,a.addtime,a.action_uid,a.action_name,a.order_status,a.action_status,a.order_type,a.action_process,a.order_code,a.order_id,a.id")
         * ->where($where)->page($page,$size)->order("a.addtime desc")->select();
         * $data=[];
         * foreach ($list as $value){
         * $str = Db::name("process")->where(['process_type' => $value['order_type']])->field("process_name,status")->find();
         * $var = Db::name("action_process")->where(['order_type'=>$value['order_type'],'order_process'=>$value['action_status']])->field("status_name,order_process,order_name,roleid")->find();
         * $value['process_name']=$str['process_name'];
         * $value['order_name']=$var['order_name'];
         * $value['status_name'] = $var['status_name'];
         * $data[]=$value;
         * }
         * return app_show(0,"获取成功",['count'=>$count,'list'=>$data]);
         * **/

        {

            $param = $this->request->filter('trim')->only(['token', 'apply_id' => '', 'action_uid' => '', 'order_code' => '', 'page' => 1, 'size' => 10], 'post');

            $db = ProcessWait::alias("a")
                ->leftJoin("workflow b", "a.order_type=b.order_type and a.order_code=b.order_code")
                ->where(['is_del' => 0, 'a.status' => ProcessWait::$status_finish]);

            $db->where(function ($query) use ($param) {
                //所属角色
                $role = $this->checkRole();
//                if (!empty($role['write']) || $role['roleid'] == 33) $query->whereFindInSet('roleid', $role['roleid']);
                $query->whereFindInSet('roleid', $role['roleid']);

                //本人id
                $user = GetUserInfo($param['token']);
                if (isset($user['data']['id'])) $query->whereOr('wait_id', $user['data']['id']);
            });

            if ($param['order_code'] != '') $db->whereLike("a.order_code", '%' . $param['order_code'] . '%');
            if ($param['action_uid'] != '') $db->where('a.action_uid', $param['action_uid']);

            $count = $db->count();

            $total = ceil($count / $param['size']);
            $page = $param['page'] > $total ? $total : $param['page'];
            $list = $db
                ->field("b.apply_id,b.apply_name,a.addtime,a.action_uid,a.action_name,a.order_status,a.order_type,a.order_process,a.order_code,a.order_id,a.id")
                ->page($page, $param['size'])
                ->order("a.addtime desc")
                ->select()
                ->toArray();

            //所有流程名称
            $all_process = Db::name("process")
                ->whereIn('process_type', array_column($list, 'order_type'))
                ->column("process_name", 'process_type');

            $data = [];
            foreach ($list as $value) {
                $var = Db::name("action_process")
                    ->where(['order_type' => $value['order_type'], 'order_process' => $value['order_process']])
                    ->field("status_name,order_process,order_name,roleid")
                    ->find();
                $value['process_name'] = isset($all_process[$value['order_type']]) ? $all_process[$value['order_type']] : '';
                $value['order_name'] = $var['order_name'];
                $value['status_name'] = $var['status_name'];
                $data[] = $value;
            }
            return app_show(0, "获取成功", ["list" => $data, 'count' => $count]);
        }


    }

    //待处理列表
    public function waitlist()
    {

        $param = $this->request->filter('trim')->only(['token', 'apply_id' => '', 'action_uid' => '', 'order_code' => '', 'page' => 1, 'size' => 10], 'post');

        $db = ProcessWait::alias("a")
            ->leftJoin('workflow b', 'a.order_type=b.order_type and a.order_code=b.order_code')
            ->leftJoin('process p', 'p.process_type=a.order_type AND p.is_del=0 AND p.status=1')
            ->where(['a.status' => ProcessWait::$status_wait]);

        $db->where(function ($query) use ($param) {
            //所属角色
            $role = $this->checkRole();

//            if (!empty($role['write']) || $role['roleid'] == 33) $query->whereFindInSet('roleid', $role['roleid']);
            $query->whereFindInSet('roleid', $role['roleid']);

            //本人id
            $query->whereOr('wait_id', $this->uid);
        });

        if ($param['order_code'] != '') $db->whereLike('a.order_code', '%' . $param['order_code'] . '%');
        if ($param['action_uid'] != '') $db->where('a.action_uid', $param['action_uid']);

        $count = $db->count();

        $total = ceil($count / $param['size']);
        $page = $param['page'] > $total ? $total : $param['page'];
        $list = $db
            ->field("a.id,b.apply_id,b.apply_name,a.addtime,a.action_uid,a.action_name,a.order_status,a.order_type,a.order_process,a.order_code,a.order_id,a.roleid,a.wait_name,p.api_url")
            ->page($page, $param['size'])
            ->order("a.addtime desc")
            ->append(['handle_user_list'])
            ->withAttr('handle_user_list', function ($val, $da) {
                return [];
            })
            ->select()
            ->toArray();

        //所有流程名称
        $all_process = Db::name("process")
            ->whereIn('process_type', array_column($list, 'order_type'))
            ->column("process_name", 'process_type');

        $data = [];
        foreach ($list as $value) {
            $var = Db::name("action_process")
                ->where(['order_type' => $value['order_type'], 'order_process' => $value['order_process']])
                ->field("status_name,order_process,order_name,roleid")
                ->find();
            $value['process_name'] = isset($all_process[$value['order_type']]) ? $all_process[$value['order_type']] : '';
            $value['order_name'] = $var['order_name'];
            $value['status_name'] = $var['status_name'];

            //找到流程对应记录的所有人(创建人 or 申请人 or 采购员)
            $holder_id = 0;
            switch ($value['order_type']) {
                //1.采购单流程
                case 'CGD':
                    $holder_id = Db::name('purchease_order')->where(['id' => $value['order_id'], 'is_del' => 0])->value('cgder_id', 0);
                    break;
                //2.采购单入库流程
                case 'RKD':
                    $holder_id = Db::name('purchease_in')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
                    break;
                //3.备货申请单流程
                case 'BHD':
                    $holder_id = Db::name('purchease')->where(['id' => $value['order_id'], 'is_del' => 0])->value('apply_id', 0);
                    break;
                //4.销售订单流程
                case 'XSQRD':
                    $holder_id = Db::name('sale')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
                    break;
                //5.发货申请单流程
                case 'CKD':
                    $holder_id = Db::name('order_out')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
                    break;
                //6.售后申请单流程
                case 'SHD':
                    $holder_id = Db::name('order_return')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
                    break;
                //7.售后退货单流程
                case 'CKTHD':
                    $holder_id = Db::name('order_back')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
                    break;
                //8.销售退货单流程
                case 'XSTHD':
                    $holder_id = Db::name('sale_return')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
                    break;
                //9.采购工差单流程
                case 'CGGCD':
                    $holder_id = Db::name('purchease_diff')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
                    break;
                //10.销售工差单流程
                case 'XSGCD':
                    $holder_id = Db::name('sale_diff')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
                    break;
                //11.调拨单流程
                case 'DBD':
                    $holder_id = Db::name('allot_stock')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
                    break;
                //12.盘点单流程
                case 'PDD':
                    $holder_id = Db::name('good_check')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
                    break;
                //13.议价单流程
                case 'YJD':
                    $holder_id = Db::name('bargain_order')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
                    break;
                //14.项目单流程
                case 'PRO':
                    $holder_id = Db::name('project')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
                    break;
                //15.商品成本流程
                case 'SPCB':
                    $holder_id = Db::name('good_basic')->where(['id' => 'order_id', 'is_del' => 0])->value('chargerid', 0);
                    break;
                //16.商品上线流程
                case 'SPSX':
                    $holder_id = Db::name('good')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
                    break;
                //17.活动流程
                case 'HD':
                    $holder_id = Db::name('good_activity')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
                    break;
                //19.有赞商品上架流程
                case 'YZSX':
                    $holder_id = Db::name('good_basic')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
                    break;
                //20.有赞订单审核流程
//                case 'YZQRD':
//                    $holder_id = Db::name('')->where(['id' => 'order_id', 'is_del' => 0])->value('', 0);
//                    break;
                //22.离职交接流程
                case 'LZJJ':
                    $holder_id = Db::name('resign_info')->where(['id' => 'order_id', 'is_del' => 0])->value('hand_uid', 0);
                    break;
                //23.采购单退货流程
                case 'CGTHD':
                    $holder_id = Db::name('purchease_return')->where(['id' => 'order_id', 'is_del' => 0])->value('apply_id', 0);
                    break;
                //24.竞价单流程
                case 'ZXD':
                    $holder_id = Db::name('consult_order')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
                    break;
                //25.商品下线流程
                case 'GOL':
                    $holder_id = Db::name('good_offline_log')->where(['id' => 'order_id', 'is_del' => 0])->value('createrid', 0);
                    break;
            }


            //根据记录的所有人判断哪些人能看到它的记录
            $uids_1 = $this->get_uids_by_group_share($holder_id, $value['api_url']);

            //根据角色筛选
            $uids_2 = Db::name('user_role')
                ->where([
                    ['is_del', '=', 0],
                    ['roleid', 'in', $value['roleid']],
                    ['status', '=', 1],
                    ['roleid', '<>', 1],//超级管理员不在这个范围内
                ])
                ->column('uid');

            $uids = array_intersect($uids_1['1'], $uids_2);

            $users = Db::name('depart_user')->where(['is_del' => 0, 'status' => 1])->whereIn('uid', $uids)->column('nickname');

            //当前操作人
            $value['handle_user_list'] = $value['wait_name'] ? array_merge($users, [$value['wait_name']]) : $users;

            $data[] = $value;
        }
        return app_show(0, "获取成功", ["list" => $data, 'count' => $count]);
    }
public function all(){
    $token = isset($this->post['token']) ? trim($this->post['token']) : "";
    if($token==""){
        return error_show(101,'token不能为空');
    }
    $effetc = VerifyTokens($token);
    if(!empty($effetc) && $effetc['code']!=0){
        return error_show($effetc['code'],$effetc['message']);
    }
    $where=[["is_del","=",0]];
    $process_name = isset($this->post['process_name']) && $this->post['process_name'] !==""? trim($this->post['process_name']) :"";
    if($process_name!=""){
        $where[]=["process_name","like","%$process_name%"];
    }
    $process_type = isset($this->post['process_type']) && $this->post['process_type'] !==""? trim($this->post['process_type']) :"";
    if($process_type!=""){
        $where[]=["process_type","like","%$process_type%"];
    }
    $list = Db::name('process')->where($where)->order("addtime desc")->select();
    return app_show(0,"获取成功",$list);
}

//我能被哪些人看到？
    private function get_uids_by_group_share(int $uid = 0, string $api_url = '')
    {
        //原始数据
        $data = [1 => [$uid], 2 => [$uid], 3 => []];

        //用户组
        $group = Db::name('data_group_userid')
            ->alias('a')
            ->leftJoin('data_group b', 'b.id=a.data_group_id')
            ->where([
                'a.is_del' => 0,
                'a.status' => 1,
                'a.uid' => $uid,
                'b.is_del' => 0,
                'b.status' => 1,
            ])->order('a.data_group_id')
            ->column('b.type', 'a.data_group_id');

        $group_user = Db::name('data_group_userid')
            ->where([
                'is_del' => 0,
                'status' => 1,
            ])->whereIn('data_group_id', array_keys($group))
            ->field('id,data_group_id,uid')
            ->order('uid')
            ->cursor();

        foreach ($group_user as $g_u) {
            $data[$group[$g_u['data_group_id']]][] = $g_u['uid'];
        }

        //当前请求的接口地址
        if ($api_url == '') $api_url = app('http')->getName() . '/' . request()->pathinfo();
        $menu_id = Db::name('admin_menu')
            ->where(['is_del' => 0, 'menu_api' => $api_url])
            ->value('id', 0);

        if ($menu_id) {
            //共享规则
            $share = Db::name('data_share')
                ->field('id,type,uid,data_group_id')
                ->where([
                    'is_del' => 0,
                    'status' => 1,
                ])
                ->whereFindInSet('menu_ids', $menu_id)
                ->where(function ($query) use ($uid, $group) {
                    return $query->where('source_uid', $uid)->whereOr('source_data_group_id', 'in', array_keys($group));
                })
                ->cursor();

            foreach ($share as $s) {
                $source_group_uid = Db::name('data_group_userid')
                    ->where([
                        'is_del' => 0,
                        'status' => 1,
                        'data_group_id' => $s['data_group_id'],
                    ])->order('uid')->column('uid');

                //$s['source_uid'] ? [$s['source_uid']] : []  排除默认值0
                $data[$s['type']] = array_merge($data[$s['type']], $s['uid'] ? [$s['uid']] : [], $source_group_uid);
            }
        }

        unset($data[3]);

        $data[0] = array_merge($data[1], $data[2]);

        sort($data[0]);
        $data[0] = array_unique($data[0]);

        return $data;

    }

}